activiti7的网关

向右看齐 2023-01-02 12:30 299阅读 0赞

工作流 —activiti7网关

1. 排他网关

排他网关（也叫异或（XOR）网关，或叫基于数据的排他网关），用来在流程中实现决策。

当流程执行到这个网关，所有分支都会判断条件是否为true，如果为 true 则执行该分支，

**　　注意，排他网关只会选择一个为** **true** **的分支执行**。(即使有两个分支条件都为 true，排他网关也会只选择一条分支去执行)

1.1 定义流程

![1397047-20200407144506759-1902386904.png][]

1.2 部署流程

![复制代码][Image 1]

/**
         * 流程部署的方法
         */
        @Test
        public void deployment() {
            //获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            //获取RepositoryService对象
            RepositoryService repositoryService = processEngine.getRepositoryService();
            //流程部署
            Deployment deploy = repositoryService.createDeployment()
                    .addClasspathResource("holiday/holidayOld.bpmn")
                    .name("请假流程-排他网关")
                    .deploy();
            System.out.println("流程部署成功:" + deploy.getName());
        }

![复制代码][Image 1]

1.3 启动流程  当前给的流程变量是5 两个条件都符合

![复制代码][Image 1]

/**
         * 启动流程实例，设置流程变量的值
         */
        @Test
        public void startInstance() {
            //获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            //获取RuntimeService
            RuntimeService runtimeService = processEngine.getRuntimeService();
            //设置流程变量
            Holiday holiday = new Holiday();
            holiday.setNum(5);
            Map<String, Object> assMap = new HashMap<>();
            assMap.put("holiday", holiday);
            //启动流程实例
            ProcessInstance holidayGroup = runtimeService.startProcessInstanceByKey("holidaygetway", assMap);
            System.out.println("流程实例：" + holidayGroup.getId());
        }

![复制代码][Image 1]

1.4 处理任务

![复制代码][Image 1]

/**
         * 处理任务
         */
        @Test
        public void commitTask() {
            //获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            //获取TaskService对象
            TaskService taskService = processEngine.getTaskService();
            //查询到自己的任务，然后通过任务ID进行提交
            Task task = taskService.createTaskQuery().processDefinitionKey("holidaygetway").taskAssignee("zhangsan").singleResult();
            //处理任务
            taskService.complete(task.getId());
        }

![复制代码][Image 1]

1.5  处理lisi的任务

![复制代码][Image 1]

/**
         * 处理任务
         */
        @Test
        public void commitTask() {
            //获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            //获取TaskService对象
            TaskService taskService = processEngine.getTaskService();
            //查询到自己的任务，然后通过任务ID进行提交
            Task task = taskService.createTaskQuery().processDefinitionKey("holidaygetway").taskAssignee("lisi").singleResult();
            //处理任务
            taskService.complete(task.getId());
        }

![复制代码][Image 1]

1.6 处理完lisi的任务时条件两者都符合时选择ID最小的分支

![1397047-20200407150049406-2117131861.png][]

1.7 查看数据库任务表

![1397047-20200407150309620-1431479669.png][]

2. 并行网关

并行网关允许将流程分成多条分支，也可以把多条分支汇聚到一起，并行网关的功能是基于进 入和外出顺序流的：

fork 分支：

并行后的所有外出顺序流，为每个顺序流都创建一个并发分支。

join 汇聚：

所有到达并行网关，在此等待的进入分支， 直到所有进入顺序流的分支都到达以后，  流程就会通过汇聚网关。

注意，如果同一个并行网关有多个进入和多个外出顺序流， 它就同时具有分支和汇聚功能。

这时， 网关会先汇聚所有进入的顺序流，然后再切分成多个并行分支。 与其他网关的主要区别是，

并行网关不会解析条件。 即使顺序流中定义了条件，也会被忽略。

2.1 定义流程图

![1397047-20200408150712159-1975221713.png][]

2.2 部署流程

![复制代码][Image 1]

/**
         * 流程部署
         */
        @Test
        public void deployment(){
            //获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            //获取RepositoryService对象
            RepositoryService repositoryService = processEngine.getRepositoryService();
            //流程部署
            Deployment deploy = repositoryService.createDeployment()
                    .addClasspathResource("holiday/holidayPar.bpmn")
                    .name("请假流程-并行网关")
                    .deploy();
            System.out.println("流程部署成功:" + deploy.getName());
        }

![复制代码][Image 1]

2.3 启动流程

![复制代码][Image 1]

/**
         * 启动流程实例
         */
        @Test
        public void startInstance() {
            //获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            //获取RuntimeService
            RuntimeService runtimeService = processEngine.getRuntimeService();
            //设置流程变量
    
            Map<String, Object> assMap = new HashMap<>();
            assMap.put("num", 3);
            //启动流程实例
            ProcessInstance holidayGroup = runtimeService.startProcessInstanceByKey("holidayPar", assMap);
            System.out.println("流程实例：" + holidayGroup.getId());
        }

![复制代码][Image 1]

2.4 执行流程zhangsan

![复制代码][Image 1]

/**
         * 执行流程
         */
        @Test
        public void commitTask() {
            //获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            //获取TaskService对象
            TaskService taskService = processEngine.getTaskService();
            //查询到自己的任务，然后通过任务ID进行提交
            Task task = taskService.createTaskQuery().processDefinitionKey("holidayPar").taskAssignee("zhangsan").singleResult();
            //处理任务
            taskService.complete(task.getId());
        }

![复制代码][Image 1]

2.5 执行lisi任务因为天数为3所以直接到人事存档zhaoliu

![复制代码][Image 1]

/**
         * 执行流程
         */
        @Test
        public void commitTask() {
            //获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            //获取TaskService对象
            TaskService taskService = processEngine.getTaskService();
            //查询到自己的任务，然后通过任务ID进行提交
            Task task = taskService.createTaskQuery().processDefinitionKey("holidayPar").taskAssignee("lisi").singleResult();
            //处理任务
            taskService.complete(task.getId());
        }

![复制代码][Image 1]

2.6 执行zhaoliu任务后进入并行网关 会有两个待执行任务

![复制代码][Image 1]

/**
         * 执行流程
         */
        @Test
        public void commitTask() {
            //获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            //获取TaskService对象
            TaskService taskService = processEngine.getTaskService();
            //查询到自己的任务，然后通过任务ID进行提交
            Task task = taskService.createTaskQuery().processDefinitionKey("holidayPar").taskAssignee("zhaoliu").singleResult();
            //处理任务
            taskService.complete(task.getId());
        }

![复制代码][Image 1]

2.7 查看数据库任务表

![1397047-20200408152724259-1052685983.png][]

2.8 查看数据库历史表

![1397047-20200408152859071-1518888218.png][]

2.9 执行sunqi任务

![复制代码][Image 1]

/**
         * 执行流程
         */
        @Test
        public void commitTask() {
            //获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            //获取TaskService对象
            TaskService taskService = processEngine.getTaskService();
            //查询到自己的任务，然后通过任务ID进行提交
            Task task = taskService.createTaskQuery().processDefinitionKey("holidayPar").taskAssignee("sunqi").singleResult();
            //处理任务
            taskService.complete(task.getId());
        }

![复制代码][Image 1]

2.10 查看数据库任务表

![1397047-20200408153045400-107223946.png][]

2.11 查看数据库历史表

![1397047-20200408153217507-2125446207.png][]

2.12 执行sunba任务

![复制代码][Image 1]

/**
         * 执行流程
         */
        @Test
        public void commitTask() {
            //获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            //获取TaskService对象
            TaskService taskService = processEngine.getTaskService();
            //查询到自己的任务，然后通过任务ID进行提交
            Task task = taskService.createTaskQuery().processDefinitionKey("holidayPar").taskAssignee("zhouba").singleResult();
            //处理任务
            taskService.complete(task.getId());
        }

![复制代码][Image 1]

2.13 查看数据库任务表

![1397047-20200408153429582-1853459852.png][]

2.14 查看数据库历史表  当并行网关的所有任务都执行完毕后才会进入下一个任务

![1397047-20200408153601177-258641069.png][]

3. 包含网关*　*

包含网关可以看做是排他网关和并行网关的结合体。 和排他网关一样，你可以在外出顺序流上定义条件，

包含网关会解析它们。 但是主要的区别是包含网关可以选择多于一条顺序流，这和并行网关一样。

包含网关的功能是基于进入和外出顺序流的

3.1 流程定义

![1397047-20200408160158645-1306197478.png][]

3.2 部署流程

![复制代码][Image 1]

/**
         * 流程部署
         */
        @Test
        public void deployment(){
            //获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            //获取RepositoryService对象
            RepositoryService repositoryService = processEngine.getRepositoryService();
            //流程部署
            Deployment deploy = repositoryService.createDeployment()
                    .addClasspathResource("medical/medical.bpmn")
                    .name("体检流程-包含网关")
                    .deploy();
            System.out.println("流程部署成功:" + deploy.getName());
        }

![复制代码][Image 1]

3.3 启动流程实例   当前流程变量为1

![复制代码][Image 1]

/**
         * 启动流程实例
         */
        @Test
        public void startInstance() {
            //获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            //获取RuntimeService
            RuntimeService runtimeService = processEngine.getRuntimeService();
            //设置流程变量
    
            Map<String, Object> assMap = new HashMap<>();
            assMap.put("userType", 1);
            //启动流程实例
            ProcessInstance holidayGroup = runtimeService.startProcessInstanceByKey("medical", assMap);
            System.out.println("流程实例：" + holidayGroup.getId());
        }

![复制代码][Image 1]

3.4 执行zhangsan任务

![复制代码][Image 1]

/**
         * 执行流程
         */
        @Test
        public void commitTask() {
            //获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            //获取TaskService对象
            TaskService taskService = processEngine.getTaskService();
            //查询到自己的任务，然后通过任务ID进行提交
            Task task = taskService.createTaskQuery().processDefinitionKey("medical").taskAssignee("zhangsan").singleResult();
            //处理任务
            taskService.complete(task.getId());
        }

![复制代码][Image 1]

3.5 查看数据库任务表

![1397047-20200408161716045-84406716.png][]

3.6 执行lisi任务

![复制代码][Image 1]

/**
         * 执行流程
         */
        @Test
        public void commitTask() {
            //获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            //获取TaskService对象
            TaskService taskService = processEngine.getTaskService();
            //查询到自己的任务，然后通过任务ID进行提交
            Task task = taskService.createTaskQuery().processDefinitionKey("medical").taskAssignee("lisi").singleResult();
            //处理任务
            taskService.complete(task.getId());
        }

![复制代码][Image 1]

3.7 查看数据库任务表

![1397047-20200408161911930-1975867655.png][]

3.8 执行wangwu任务

![复制代码][Image 1]

/**
         * 执行流程
         */
        @Test
        public void commitTask() {
            //获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            //获取TaskService对象
            TaskService taskService = processEngine.getTaskService();
            //查询到自己的任务，然后通过任务ID进行提交
            Task task = taskService.createTaskQuery().processDefinitionKey("medical").taskAssignee("wangwu").singleResult();
            //处理任务
            taskService.complete(task.getId());
        }

![复制代码][Image 1]

3.9 查看数据库任务表 包含网关任务

![1397047-20200408162007478-1328287587.png][]

3.10 查看数据库历史表  都已经执行完毕

![1397047-20200408162202893-910649248.png][]

[1397047-20200407144506759-1902386904.png]: /images/20221119/e3d981151256476eb10f8efc9dd5faf1.png
[Image 1]: 
[1397047-20200407150049406-2117131861.png]: /images/20221119/fc7b47770ada46319f98b254e0553e24.png
[1397047-20200407150309620-1431479669.png]: /images/20221119/f73c920d93b34a9e9c026f737dbc65d2.png
[1397047-20200408150712159-1975221713.png]: /images/20221119/ba4203211ccb4b939e50d4cb6d074871.png
[1397047-20200408152724259-1052685983.png]: /images/20221119/bb4144ce66384379b1df0070a6aa6b92.png
[1397047-20200408152859071-1518888218.png]: /images/20221119/c8d7dbbed32c4927855a54f3a97790b7.png
[1397047-20200408153045400-107223946.png]: /images/20221119/e8dfb5f6ad334615b53727aa841ccd9c.png
[1397047-20200408153217507-2125446207.png]: /images/20221119/887bae60952e4982baea070e927d5bbc.png
[1397047-20200408153429582-1853459852.png]: /images/20221119/1c587726298742e5b6fc2bb70ed2f1c8.png
[1397047-20200408153601177-258641069.png]: /images/20221119/9c5dbb9ff6ed4855892b92700a298fc7.png
[1397047-20200408160158645-1306197478.png]: /images/20221119/931c3d0211d54f749ad92da8f2e37e10.png
[1397047-20200408161716045-84406716.png]: /images/20221119/dc5ad3fbfc364e4b86a84d6269704c53.png
[1397047-20200408161911930-1975867655.png]: /images/20221119/797ff59baad148fca6a9ccff0685d937.png
[1397047-20200408162007478-1328287587.png]: /images/20221119/ea40d716ef0145278f0fad32edca3812.png
[1397047-20200408162202893-910649248.png]: /images/20221119/32873422f1d84f559e864813899b59b2.png