Activiti7-网关-并行网关（常用于会签）

分手后的思念是犯贱 2024-03-30 10:33 46阅读 0赞

![e5a95e6e163445bebf3b5e0e99f46cdb.png][]

![4700b62f61b54829810988afd04c7b82.png][]

![facae8a18a9d4313b6a49b62f8692864.png][]设计并行网关：

![2c27a7d43f524a4a93eb1082eecd8ffa.png][]

![aa60e088a5db4bdaa1c88f35074f2e5d.png][]

![6ebbfd054e3c47d4a1cef0465956ec8e.png][]

张三申请：

![2a8ba902763a4f88bd746d33a5bba00e.png][]

查询任务：

![70cccef473e347c7b0aa1f942b43feaa.png][]

刘经理和王总监都收到了任务，说明并行网关设计成功。

刘经理审批：

![9eccb97c57134679a5e2ee14218920e0.png][]

查询任务：可以看到还有王总监没有审批

![fc903a0cb15e4c46af29f70e77f66f5b.png][]

王总监审批：

![41d2bea525ce4764afe63c0ccf96fa21.png][]

查询任务：还有周总经理没有审批

![2537e84a5d7847b7acaa394169dae463.png][]

周总经理审批：

![d3c627ee80b143c78c27c4d2afdf486e.png][]

查询任务：周总经理审批完了流程结束

![4b7bb068c50d4943881ea10deea6e304.png][]

参考代码：

package com.nanjing;
    
    import com.nanjing.pojo.Evection;
    import org.activiti.engine.*;
    import org.activiti.engine.repository.Deployment;
    import org.activiti.engine.runtime.ProcessInstance;
    import org.activiti.engine.task.Task;
    import org.junit.Test;
    
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    
    public class ActivitiGatewayParallel {
        /**
         * 部署流程定义
         */
        @Test
        public void testDeployment(){
    //        1、创建ProcessEngine
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    //        2、得到RepositoryService实例
            RepositoryService repositoryService = processEngine.getRepositoryService();
    //        3、使用RepositoryService进行部署
            Deployment deployment = repositoryService.createDeployment()
                    .addClasspathResource("leave14.bpmn20.xml") // 添加bpmn资源
    //                .addClasspathResource("bpmn/evection.png")  // 添加png资源
                    .name("出差申请流程-并行网关")
                    .deploy();
    //        4、输出部署信息
            System.out.println("流程部署id：" + deployment.getId());
            System.out.println("流程部署名称：" + deployment.getName());
        }
    
        /**
         * 启动流程实例,设置流程变量的值
         */
        @Test
        public void startProcess(){
    //        获取流程引擎
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    //        获取RunTimeService
            RuntimeService runtimeService = processEngine.getRuntimeService();
    //        流程定义key
            String key = "myEvection14";
    //       创建变量集合
            Map<String, Object> map = new HashMap<>();
    //        创建出差pojo对象
            Evection evection = new Evection();
    //        设置出差天数
            evection.setNum(4d);
    //      定义流程变量，把出差pojo对象放入map
            map.put("evection",evection);
            map.put("assignee0","张三");
            map.put("assignee1","刘经理");
            map.put("assignee11","王总监");
            map.put("assignee2","周总经理");
    //        启动流程实例，并设置流程变量的值（把map传入）
            ProcessInstance processInstance = runtimeService
                    .startProcessInstanceByKey(key, map);
    //      输出
            System.out.println("流程实例名称="+processInstance.getName());
            System.out.println("流程定义id=="+processInstance.getProcessDefinitionId());
        }
    
        /**
         * 启动流程实例
         */
        @Test
        public void testStartProcess(){
    //        1、创建ProcessEngine
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    //        2、获取RunTimeService
            RuntimeService runtimeService = processEngine.getRuntimeService();
    //        3、根据流程定义Id启动流程
            ProcessInstance processInstance = runtimeService
                    .startProcessInstanceByKey("myEvection14");
    //        输出内容
            System.out.println("流程定义id：" + processInstance.getProcessDefinitionId());
            System.out.println("流程实例id：" + processInstance.getId());
            System.out.println("当前活动Id：" + processInstance.getActivityId());
        }
    
    
        @Test
        public void completTask(){
    //        流程定义的Key
            String key = "myEvection14";
    //        任务负责人
            String assingee = "周总经理";
            //        获取流程引擎
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    //        获取taskservice
            TaskService taskService = processEngine.getTaskService();
    //        查询任务
            Task task = taskService.createTaskQuery()
                    .processDefinitionKey(key)
                    .taskAssignee(assingee)
                    .singleResult();
            if(task != null){
                //     根据任务id来   完成任务
                taskService.complete(task.getId());
            }
    
        }
    
    
        @Test
        public void queryTask(){
    //        流程定义的Key
            String key = "myEvection14";
    //        任务负责人
            //String assingee = "周总经理";
    
            //        获取流程引擎
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    //        获取taskservice
            TaskService taskService = processEngine.getTaskService();
    //        查询任务
            final List<Task> tasks = taskService.createTaskQuery()
                    .processDefinitionKey(key)
    //                .taskAssignee(assingee)
                    .list();
            for(Task task:tasks){
                //     根据任务id来   完成任务
                System.out.println(task.getId());
                System.out.println(task.getName());
                System.out.println(task.getAssignee());
            }
    
        }
    }

[e5a95e6e163445bebf3b5e0e99f46cdb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/705e9fdeba874f4486dd5d2cd983ef4d.png
[4700b62f61b54829810988afd04c7b82.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/42e7a578b7d24e49ae5709a337f90be6.png
[facae8a18a9d4313b6a49b62f8692864.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/905aa0364ef0407db62bd5acbeaa1900.png
[2c27a7d43f524a4a93eb1082eecd8ffa.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/eac9c3f897624fbb882eb2d0f5f7bf96.png
[aa60e088a5db4bdaa1c88f35074f2e5d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/ce1a126e452c4bdeaa739db4fb6149e6.png
[6ebbfd054e3c47d4a1cef0465956ec8e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/1d485e0535004b7caa3ebbb88c66f8ec.png
[2a8ba902763a4f88bd746d33a5bba00e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/f584f1fc880a4379a95ca10e1ec004b8.png
[70cccef473e347c7b0aa1f942b43feaa.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/ea1dd8fd5ff9486fb15820f9124b0771.png
[9eccb97c57134679a5e2ee14218920e0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/3b5de3d256d24c3e8292f62fa3a77e34.png
[fc903a0cb15e4c46af29f70e77f66f5b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/8a7f583b3c5f4eb1af92f982baed8b36.png
[41d2bea525ce4764afe63c0ccf96fa21.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/04ca2fc6a77a47aa8fdd1bb948f88a52.png
[2537e84a5d7847b7acaa394169dae463.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/658252b5ce6745a189779d5c9b813ea0.png
[d3c627ee80b143c78c27c4d2afdf486e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/696862535e7343cba502ddae2921011c.png
[4b7bb068c50d4943881ea10deea6e304.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/155c9bf17c2c41c29f854767eb75a0b0.png