Activiti7并行子流程的使用 - SpringBoot

不念不忘少年蓝@ 2022-11-19 07:56 589阅读 0赞

![image.png][]

assigneeList 为 集合，例如\["kermit", "gonzo", "fozzie"\]；

activiti:elementVariable="assignee" 为 接收 loop 中的值的变量名；

activiti:assignee="$\{assignee\}" 相当于将认领人指定为loop中取得的变量对象，就和java 中 foreach 差不多的意思；

**nrOfInstances**：实例总数

**nrOfActiveInstances**：当前活动（即尚未完成）实例的数量。对于顺序多实例，这将始终为1。

**nrOfCompletedInstances**：已完成实例的数量。

注意，这三个变量存在当前执行的**父执行**中。

**$\{nrOfCompletedInstances/nrOfInstances >= 0.6 \}** ，意思不言而喻，就是完成改执行的量大于等于60%就可以通过该节点进入下一节点。

![image.png][image.png 1]

配置节点监听器

import com.triman.zhxz.xsgl.utils.SpringUtils;
    import org.activiti.engine.TaskService;
    import org.activiti.engine.delegate.DelegateExecution;
    import org.activiti.engine.delegate.ExecutionListener;
    import org.activiti.engine.task.Task;
     
    import java.util.Map;
     
    /**
     * 消息通知任务监听器
     */
    public class FileCheckExecutionListener implements ExecutionListener {
     
     
        @Override
        public void notify(DelegateExecution execution) {
            System.out.println("进入监听器 - FileCheckExecutionListener ...");
            //修改审批状态
            Map<String, Object> variables = execution.getVariables();
            System.out.println("运行变量");
            System.out.println(variables);
            execution.setVariable("pass","no");
    
    //在执行监听器中通过，执行实例id获取当前任务信息
    //        TaskService taskService = SpringUtils.getBean(TaskService.class);
    //        Task task = taskService.createTaskQuery().processInstanceId(execution.getProcessInstanceId()).executionId(execution.getId()).singleResult();
    //        if (task == null) {
    //            return;
    //        }
    //获取当前任务执行人
    //        String assignee = task.getAssignee();
    //        System.out.println(assignee);
    //全部审批完
    //            Integer complete = (Integer) execution.getParent().getVariable("nrOfCompletedInstances");
    //            Integer all = (Integer) execution.getParent().getVariable("nrOfInstances");
    //            execution.setVariable("nrOfCompletedInstances", complete);
    //            //说明都完成了并且没有人拒绝
    //            if ((complete + 1) / all == 1) {
    //                execution.setVariable("pass", "no");
    //            }
            System.out.println("离开监听器 - FileCheckExecutionListener ...");
        }
    }

### 流程图核心xml ###

<callActivity id="callactivity1" name="子流程" calledElement="${call}" activiti:inheritVariables="false">
          <extensionElements>
            <activiti:in source="startUserId" target="startUserId" />
            <activiti:executionListener class="com.triman.zhxz.xsgl.service.FileCheckExecutionListener" event="end" />
          </extensionElements>
          <incoming>SequenceFlow_175153q</incoming>
          <outgoing>SequenceFlow_0d2cc0g</outgoing>
          <multiInstanceLoopCharacteristics activiti:collection="${assigneeList}" activiti:elementVariable="${startUserId}">
            <loopCardinality>${num}</loopCardinality>
            <completionCondition>${(nrOfCompletedInstances == nrOfInstances) || (pass == 'no')}</completionCondition>
          </multiInstanceLoopCharacteristics>
        </callActivity>

[image.png]: /images/20221119/fc473e9fa49d4072bc99ada4ab023928.png
[image.png 1]: /images/20221119/4ccee0a662454303a03b2c012710550a.png