新增自定义流程属性

distributed-print-business/pom.xml

@@ -4,7 +4,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.qmth.distributed.print.business</groupId>
     <artifactId>distributed-print-business</artifactId>
-    <version>2.2.2</version>
+    <version>3.0.0</version>
     <build>
         <plugins>
             <plugin>
@@ -22,7 +22,7 @@
     <parent>
         <groupId>com.qmth.distributed.print.service</groupId>
         <artifactId>distributed-print-service</artifactId>
-        <version>2.2.2</version>
+        <version>3.0.0</version>
     </parent>
 
     <dependencies>
@@ -202,6 +202,10 @@
             <artifactId>spring-test</artifactId>
             <version>5.2.12.RELEASE</version>
         </dependency>
+        <dependency>
+            <groupId>org.activiti</groupId>
+            <artifactId>activiti-bpmn-layout</artifactId>
+        </dependency>
     </dependencies>
 
 </project>

distributed-print-business/src/main/java/com/qmth/distributed/print/business/service/ActivitiService.java

@@ -130,4 +130,12 @@ public interface ActivitiService {
      * @return
      */
     public List<FlowTaskSubmitPeopleAllResult> taskApproverSubmitList(String examTaskId);
+
+    /**
+     * 动态创建流程图
+     *
+     * @param id
+     * @throws IOException
+     */
+    public void dynamicBuildBpmn(String id) throws IOException;
 }

distributed-print-business/src/main/java/com/qmth/distributed/print/business/service/impl/ActivitiServiceImpl.java

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.qmth.boot.api.exception.ApiException;
 import com.qmth.distributed.print.business.bean.result.*;
 import com.qmth.distributed.print.business.entity.*;
+import com.qmth.distributed.print.business.enums.CustomFlowTypeEnum;
 import com.qmth.distributed.print.business.enums.ExamStatusEnum;
 import com.qmth.distributed.print.business.enums.FlowModelEnum;
 import com.qmth.distributed.print.business.service.*;
@@ -19,6 +20,7 @@ import com.qmth.teachcloud.common.service.SysUserService;
 import com.qmth.teachcloud.common.util.RedisUtil;
 import com.qmth.teachcloud.common.util.ResultUtil;
 import com.qmth.teachcloud.common.util.ServletUtil;
+import org.activiti.bpmn.BpmnAutoLayout;
 import org.activiti.bpmn.model.Process;
 import org.activiti.bpmn.model.*;
 import org.activiti.engine.HistoryService;
@@ -27,9 +29,11 @@ import org.activiti.engine.RuntimeService;
 import org.activiti.engine.TaskService;
 import org.activiti.engine.impl.RepositoryServiceImpl;
 import org.activiti.engine.impl.persistence.entity.ProcessDefinitionEntity;
+import org.activiti.engine.repository.Deployment;
 import org.activiti.engine.repository.DeploymentBuilder;
 import org.activiti.engine.runtime.ProcessInstance;
 import org.activiti.engine.task.Task;
+import org.apache.commons.io.FileUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
@@ -39,6 +43,7 @@ import org.springframework.web.multipart.MultipartFile;
 import javax.annotation.Resource;
 import java.io.File;
 import java.io.IOException;
+import java.io.InputStream;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -1390,4 +1395,153 @@ public class ActivitiServiceImpl implements ActivitiService {
         }
         map.computeIfAbsent(SystemConstant.APPROVE, v -> approve.getId());
     }
+
+    /**
+     * 动态创建流程图
+     *
+     * @param id
+     * @throws IOException
+     */
+    @Override
+    public void dynamicBuildBpmn(String id) throws IOException {
+        BpmnModel model = new BpmnModel();
+        Process process = new Process();
+        model.addProcess(process);
+        process.setId(id);
+
+        // 判断是否仅为一个节点任务
+        List<String> taskList = new ArrayList<String>();
+        taskList.add("报销申请");
+//        taskList.add("主管审批");
+//        taskList.add("经理审批");
+//        taskList.add("总经理审批");
+        //单节点任务
+        if (taskList.size() == 1) {
+            process.addFlowElement(createStartEvent());
+            process.addFlowElement(createUserTask("task1", taskList.get(0), null));
+            process.addFlowElement(createEndEvent());
+            process.addFlowElement(createSequenceFlow("start", "task1", "", ""));
+            process.addFlowElement(createSequenceFlow("task1", "end", "", ""));
+        } else {
+            // 多节点任务
+            // 构造开始节点任务
+            process.addFlowElement(createStartEvent());
+            // 构造首个节点任务
+            process.addFlowElement(createUserTask("task1", taskList.get(0), null));
+            // 构造除去首尾节点的任务
+            for (int i = 1; i < taskList.size() - 1; i++) {
+                process.addFlowElement(createExclusiveGateway("createExclusiveGateway" + i));
+                process.addFlowElement(createUserTask("task" + (i + 1), taskList.get(i), null));
+            }
+            // 构造尾节点任务
+            process.addFlowElement(createExclusiveGateway("createExclusiveGateway" + (taskList.size() - 1)));
+            process.addFlowElement(createUserTask("task" + taskList.size(), taskList.get(taskList.size() - 1), null));
+            // 构造结束节点任务
+            process.addFlowElement(createEndEvent());
+
+            // 构造连线(加网关)
+            process.addFlowElement(createSequenceFlow("start", "task1", "", ""));
+            // 第一个节点任务到第二个百分百通过的，因此不存在网关
+            process.addFlowElement(createSequenceFlow("task1", "task2", "", ""));
+            for (int i = 1; i < taskList.size(); i++) {
+                process.addFlowElement(createSequenceFlow("task" + (i + 1), "createExclusiveGateway" + i, "", ""));
+                // 判断网关走向(同意则直接到下一节点即可，不同意需要判断回退层级，决定回退到哪个节点，returnLevel等于0，即回退到task1)
+                // i等于几，即意味着回退的线路有几种可能，例如i等于1，即是task2,那么只能回退 到task1
+                // 如果i等于2，即是task3,那么此时可以回退到task1和task2;returnLevel =1 ，即回退到task1，所以这里我是扩展了可以驳回到任意阶段节点任务
+                for (int j = 1; j <= i; j++) {
+                    process.addFlowElement(createSequenceFlow("createExclusiveGateway" + i, "task" + j, "不通过",
+                            "${result == '0' && returnLevel== '" + j + "'}"));
+                }
+                // 操作结果为通过时，需要判断是否为最后一个节点任务，若是则直接到end
+                if (i == taskList.size() - 1) {
+                    process.addFlowElement(
+                            createSequenceFlow("createExclusiveGateway" + i, "end", "通过", "${result == '1'} "));
+
+                } else {
+                    process.addFlowElement(createSequenceFlow("createExclusiveGateway" + i, "task" + (i + 2), "通过",
+                            "${result == '1'}"));
+                }
+            }
+        }
+        //生成图像信息
+        new BpmnAutoLayout(model).execute();
+        //部署流程
+        Deployment deployment = repositoryService.createDeployment().addBpmnModel(id + "-dynamic-model.bpmn", model)
+                .name(id + "-multiple process deployment").deploy();
+        //启动流程
+        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(id);
+        //保存png图片和xml文件(这一步可做可不做)
+        InputStream processDiagram = repositoryService.getProcessDiagram(processInstance.getProcessDefinitionId());
+        FileUtils.copyInputStreamToFile(processDiagram, new File("target" + File.separator + id + "-multiple-process-diagram.png"));
+
+        InputStream processBpmn = repositoryService.getResourceAsStream(deployment.getId(), id + "-dynamic-model.bpmn");
+        FileUtils.copyInputStreamToFile(processBpmn, new File("target" + File.separator + id + "-multiple-process.bpmn20.xml"));
+
+        InputStream processBpmn1 = repositoryService.getResourceAsStream(deployment.getId(), id + "-dynamic-model.bpmn");
+        FileUtils.copyInputStreamToFile(processBpmn1, new File("target" + File.separator + id + "-multiple-process.bpmn"));
+    }
+
+    /**
+     * 开始任务节点
+     *
+     * @return
+     */
+    protected StartEvent createStartEvent() {
+        StartEvent startEvent = new StartEvent();
+        startEvent.setId(CustomFlowTypeEnum.START.name());
+        return startEvent;
+    }
+
+    /**
+     * 结束任务节点
+     *
+     * @return
+     */
+    protected EndEvent createEndEvent() {
+        EndEvent endEvent = new EndEvent();
+        endEvent.setId(CustomFlowTypeEnum.END.name());
+        return endEvent;
+    }
+
+    /**
+     * @param id       对应我们画流程图中节点任务id
+     * @param name     节点任务名称
+     * @param assignee 任务的执行者(这一块自行决定是否添加每一环节的执行者，若是动态分配的话，可以不用传值)
+     * @return
+     */
+    protected UserTask createUserTask(String id, String name, String assignee) {
+        UserTask userTask = new UserTask();
+        userTask.setName(name);
+        userTask.setId(id);
+        userTask.setAssignee(assignee);
+        return userTask;
+    }
+
+    /**
+     * @param id 网关id
+     * @return
+     */
+    protected ExclusiveGateway createExclusiveGateway(String id) {
+        ExclusiveGateway exclusiveGateway = new ExclusiveGateway();
+        exclusiveGateway.setId(id);
+        return exclusiveGateway;
+    }
+
+    /**
+     * @param from                连线来源节点
+     * @param to                  连线目标节点
+     * @param name                连线名称(可不填)
+     * @param conditionExpression 网关每一种线路走向的条件表达式
+     * @return
+     */
+    protected SequenceFlow createSequenceFlow(String from, String to, String name, String conditionExpression) {
+        SequenceFlow flow = new SequenceFlow();
+        flow.setSourceRef(from);
+        flow.setTargetRef(to);
+        flow.setName(name);
+        if (Objects.nonNull(conditionExpression)) {
+            flow.setConditionExpression(conditionExpression);
+        }
+        return flow;
+    }
 }

distributed-print/pom.xml

@@ -4,13 +4,13 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.qmth.distributed.print</groupId>
     <artifactId>distributed-print</artifactId>
-    <version>2.2.2</version>
+    <version>3.0.0</version>
     <packaging>jar</packaging>
 
     <parent>
         <groupId>com.qmth.distributed.print.service</groupId>
         <artifactId>distributed-print-service</artifactId>
-        <version>2.2.2</version>
+        <version>3.0.0</version>
     </parent>
 
     <dependencies>

pom.xml

@@ -4,7 +4,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.qmth.distributed.print.service</groupId>
     <artifactId>distributed-print-service</artifactId>
-    <version>2.2.2</version>
+    <version>3.0.0</version>
     <packaging>pom</packaging>
 
     <modules>
@@ -292,6 +292,11 @@
                 <artifactId>activiti-modeler</artifactId>
                 <version>${activiti-modeler.version}</version>
             </dependency>
+            <dependency>
+                <groupId>org.activiti</groupId>
+                <artifactId>activiti-bpmn-layout</artifactId>
+                <version>${activiti.version}</version>
+            </dependency>
         </dependencies>
     </dependencyManagement>
 

teachcloud-common-api/pom.xml

@@ -4,13 +4,13 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>com.qmth.teachcloud.common.api</groupId>
 	<artifactId>teachcloud-common-api</artifactId>
-	<version>2.2.2</version>
+	<version>3.0.0</version>
 	<packaging>jar</packaging>
 
 	<parent>
 		<groupId>com.qmth.distributed.print.service</groupId>
 		<artifactId>distributed-print-service</artifactId>
-		<version>2.2.2</version>
+		<version>3.0.0</version>
 	</parent>
 
 	<dependencies>

teachcloud-common/pom.xml

@@ -4,13 +4,13 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.qmth.teachcloud.common</groupId>
     <artifactId>teachcloud-common</artifactId>
-    <version>2.2.2</version>
+    <version>3.0.0</version>
     <packaging>jar</packaging>
 
     <parent>
         <groupId>com.qmth.distributed.print.service</groupId>
         <artifactId>distributed-print-service</artifactId>
-        <version>2.2.2</version>
+        <version>3.0.0</version>
     </parent>
 
     <dependencies>

teachcloud-report-business/pom.xml

@@ -4,7 +4,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>com.qmth.teachcloud.report.business</groupId>
 	<artifactId>teachcloud-report-business</artifactId>
-	<version>2.2.2</version>
+	<version>3.0.0</version>
 	<build>
 		<plugins>
 			<plugin>
@@ -22,7 +22,7 @@
 	<parent>
 		<groupId>com.qmth.distributed.print.service</groupId>
 		<artifactId>distributed-print-service</artifactId>
-		<version>2.2.2</version>
+		<version>3.0.0</version>
 	</parent>
 
 	<dependencies>

teachcloud-report/pom.xml

@@ -4,13 +4,13 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>com.qmth.teachcloud.report</groupId>
 	<artifactId>teachcloud-report</artifactId>
-	<version>2.2.2</version>
+	<version>3.0.0</version>
 	<packaging>jar</packaging>
 
 	<parent>
 		<groupId>com.qmth.distributed.print.service</groupId>
 		<artifactId>distributed-print-service</artifactId>
-		<version>2.2.2</version>
+		<version>3.0.0</version>
 	</parent>
 
 	<dependencies>

teachcloud-task/pom.xml

@@ -4,13 +4,13 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.qmth.teachcloud.task</groupId>
     <artifactId>teachcloud-task</artifactId>
-    <version>2.2.2</version>
+    <version>3.0.0</version>
     <packaging>jar</packaging>
 
     <parent>
         <groupId>com.qmth.distributed.print.service</groupId>
         <artifactId>distributed-print-service</artifactId>
-        <version>2.2.2</version>
+        <version>3.0.0</version>
     </parent>
 
     <dependencies>