Activiti并行网关

╰+哭是因爲堅強的太久メ 2022-09-29 04:27 307阅读 0赞

在我上一篇博文上讲了  排他网关：执行到该网关到多条线路时，根据条件执行其中某一条路线。

并行网关：是会有多条线路同时并行执行，当都执行完才继续执行后面的。

重新画一个流程图取名 employeeMyProcess4.bpmn：

![Center][]

整体业务是： 员工发起请假申请——>需要项目组长、项目经理多同意审批——>才进入最好部门总监审批

——>需要以上所有人同意方能请假成功

测试代码如下：

package com.activiti;
    import java.util.List;
    import org.activiti.engine.ProcessEngine;
    import org.activiti.engine.ProcessEngines;
    import org.activiti.engine.repository.Deployment;
    import org.activiti.engine.runtime.ProcessInstance;
    import org.activiti.engine.task.Task;
    import org.junit.Test;
    
    public class ActivitiEmployeeTest4 {
    	/**
         * 获取默认流程引擎实例，会自动读取activiti.cfg.xml文件
         */
        private ProcessEngine processEngine=ProcessEngines.getDefaultProcessEngine();
         
        /**
         * 部署流程定义
         */
        @Test
        public void deploy(){
            Deployment deployment=processEngine.getRepositoryService() // 获取部署相关Service
                    .createDeployment() // 创建部署
                    .addClasspathResource("diagrams/employeeMyProcess4.bpmn") // 加载资源文件
                    .addClasspathResource("diagrams/employeeMyProcess4.png") // 加载资源文件
                    .name("员工请假流程4") // 流程名称
                    .deploy(); // 部署
            System.out.println("流程部署ID:"+deployment.getId()); 
            System.out.println("流程部署Name:"+deployment.getName());
        }
         
        /**
         * 启动流程实例
         */
        @Test
        public void start(){
            ProcessInstance pi=processEngine.getRuntimeService() // 运行时Service
                .startProcessInstanceByKey("employeeMyProcess4"); // 流程定义表的KEY字段值
            System.out.println("流程实例ID:"+pi.getId());
            System.out.println("流程定义ID:"+pi.getProcessDefinitionId()); 
        }
         
         
        /**
         * 查看任务
         */
        @Test
        public void findTask(){
            List<Task> taskList=processEngine.getTaskService() // 任务相关Service
                .createTaskQuery() // 创建任务查询
                .taskAssignee("李四") // 指定某个人
                .list();
            for(Task task:taskList){
                System.out.println("任务ID:"+task.getId()); 
                System.out.println("任务名称:"+task.getName());
                System.out.println("任务创建时间:"+task.getCreateTime());
                System.out.println("任务委派人:"+task.getAssignee());
                System.out.println("流程实例ID:"+task.getProcessInstanceId());
            }
        }
         
         
        /**
         * 完成任务
         */
        @Test
        public void completeTask(){
            processEngine.getTaskService() // 任务相关Service
                .complete("265003");
        }
         
    }

[Center]: /images/20220708/f6a30e134cec426cbbf4b93ffe9a4aeb.png