【工作流Activiti7】3、Activiti7 回退与会签

╰半夏微凉° 2024-03-30 11:48 49阅读 0赞

1. 回退（驳回）

回退的思路就是动态更改节点的流向。先遇水搭桥，最后再过河拆桥。

具体操作如下：

1.  取得当前节点的信息
2.  取得当前节点的上一个节点的信息
3.  保存当前节点的流向
4.  新建流向，由当前节点指向上一个节点
5.  将当前节点的流向设置为上面新建的流向
6.  当前节点完成任务
7.  将当前节点的流向还原
8.  取得之前上个节点的执行人
9.  设置上个节点的assignee为之前的执行人

代码实现起来可能是这样的：

@Test
    public void huitui() throws Exception {
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        TaskService taskService = processEngine.getTaskService();
        Task task = taskService.createTaskQuery().processInstanceId("55001").singleResult();
        backProcess(task);
    }
    
    /**
     * 驳回 / 回退
     * 按照这种方法，可以回退至任意节点
     * @param task
     * @throws Exception
     */
    public void backProcess(Task task) throws Exception {
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        HistoryService historyService = processEngine.getHistoryService();
        RepositoryService repositoryService = processEngine.getRepositoryService();
        TaskService taskService = processEngine.getTaskService();
    
        String processInstanceId = task.getProcessInstanceId();
    
        //  获取所有历史任务（按创建时间降序）
        List<HistoricTaskInstance> hisTaskList = historyService.createHistoricTaskInstanceQuery()
                .processInstanceId(processInstanceId)
                .orderByTaskCreateTime()
                .desc()
                .list();
    
        List<HistoricActivityInstance> hisActivityList = historyService.createHistoricActivityInstanceQuery()
                .processInstanceId(processInstanceId).list();
    
        if (CollectionUtils.isEmpty(hisTaskList) || hisTaskList.size() < 2) {
            return;
        }
    
        //  当前任务
        HistoricTaskInstance currentTask = hisTaskList.get(0);
        //  前一个任务
        HistoricTaskInstance lastTask = hisTaskList.get(1);
        //  当前活动
        HistoricActivityInstance currentActivity = hisActivityList.stream().filter(e -> currentTask.getId().equals(e.getTaskId())).collect(Collectors.toList()).get(0);
        //  前一个活动
        HistoricActivityInstance lastActivity = hisActivityList.stream().filter(e -> lastTask.getId().equals(e.getTaskId())).collect(Collectors.toList()).get(0);
    
        BpmnModel bpmnModel = repositoryService.getBpmnModel(task.getProcessDefinitionId());
    
        //  获取前一个活动节点
        FlowNode lastFlowNode = (FlowNode) bpmnModel.getMainProcess().getFlowElement(lastActivity.getActivityId());
        //  获取当前活动节点
        FlowNode currentFlowNode = (FlowNode) bpmnModel.getMainProcess().getFlowElement(currentActivity.getActivityId());
    
        //  临时保存当前活动的原始方向
        List<SequenceFlow> originalSequenceFlowList = new ArrayList<>();
        originalSequenceFlowList.addAll(currentFlowNode.getOutgoingFlows());
        //  清理活动方向
        currentFlowNode.getOutgoingFlows().clear();
    
        //  建立新方向
        SequenceFlow newSequenceFlow = new SequenceFlow();
        newSequenceFlow.setId("newSequenceFlowId");
        newSequenceFlow.setSourceFlowElement(currentFlowNode);
        newSequenceFlow.setTargetFlowElement(lastFlowNode);
        List<SequenceFlow> newSequenceFlowList = new ArrayList<>();
        newSequenceFlowList.add(newSequenceFlow);
        //  当前节点指向新的方向
        currentFlowNode.setOutgoingFlows(newSequenceFlowList);
    
        //  完成当前任务
        taskService.complete(task.getId());
    
        //  重新查询当前任务
        Task nextTask = taskService.createTaskQuery().processInstanceId(processInstanceId).singleResult();
        if (null != nextTask) {
            taskService.setAssignee(nextTask.getId(), lastTask.getAssignee());
        }
    
        //  恢复原始方向
        currentFlowNode.setOutgoingFlows(originalSequenceFlowList);
    }

以请假为例

![2090fa354b84505c4d814b0879353c5b.png][]

假设现在已经到“人事审批”这个节点了，当前活动是usertask3

![946e02fff790a11fd154f4753ebabf40.png][]

![01f6e1e4f61d3f0378bc5247d7e607c6.png][]

![d570f37246379d30a929e10910b5a089.png][]

![e7ecf22495c90a69dee067db0404d3fe.png][]

接下来，我们运行上面的代码，回退到上一个节点“部门经理审批”，于是

![41c3472dad629bbd7bd63f94e91daa99.png][]

![32e75bce8c6fefe73fc795148077d81c.png][]

![f555020ac9dd74d938fd1026ffc182b0.png][]

![17a85215a89c8408c34fa3350706e517.png][]

流程重新从“部门经理审批”节点开始往下走，当流程走完以后

![d2b6595cc4c2efaf751e23b80658e6dc.png][]

![a6cdeb572fa6777e6dfcae1456935678.png][]

证明，思路正确，写法没啥问题。但是，上面的代码可以简化一下，如下：

/**
     * 跳到最开始的任务节点（直接打回）
     * @param task 当前任务
     */
    public void jumpToStart(Task task) {
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        HistoryService historyService = processEngine.getHistoryService();
        RepositoryService repositoryService = processEngine.getRepositoryService();
        TaskService taskService = processEngine.getTaskService();
    
        String processInstanceId = task.getProcessInstanceId();
    
        //  获取所有历史任务（按创建时间升序）
        List<HistoricTaskInstance> hisTaskList = historyService.createHistoricTaskInstanceQuery()
                .processInstanceId(processInstanceId)
                .orderByTaskCreateTime()
                .asc()
                .list();
    
        if (CollectionUtils.isEmpty(hisTaskList) || hisTaskList.size() < 2) {
            return;
        }
    
        //  第一个任务
        HistoricTaskInstance startTask = hisTaskList.get(0);
        //  当前任务
        HistoricTaskInstance currentTask = hisTaskList.get(hisTaskList.size() - 1);
    
        BpmnModel bpmnModel = repositoryService.getBpmnModel(task.getProcessDefinitionId());
    
        //  获取第一个活动节点
        FlowNode startFlowNode = (FlowNode) bpmnModel.getMainProcess().getFlowElement(startTask.getTaskDefinitionKey());
        //  获取当前活动节点
        FlowNode currentFlowNode = (FlowNode) bpmnModel.getMainProcess().getFlowElement(currentTask.getTaskDefinitionKey());
    
        //  临时保存当前活动的原始方向
        List<SequenceFlow> originalSequenceFlowList = new ArrayList<>();
        originalSequenceFlowList.addAll(currentFlowNode.getOutgoingFlows());
        //  清理活动方向
        currentFlowNode.getOutgoingFlows().clear();
    
        //  建立新方向
        SequenceFlow newSequenceFlow = new SequenceFlow();
        newSequenceFlow.setId("newSequenceFlowId");
        newSequenceFlow.setSourceFlowElement(currentFlowNode);
        newSequenceFlow.setTargetFlowElement(startFlowNode);
        List<SequenceFlow> newSequenceFlowList = new ArrayList<>();
        newSequenceFlowList.add(newSequenceFlow);
        //  当前节点指向新的方向
        currentFlowNode.setOutgoingFlows(newSequenceFlowList);
    
        //  完成当前任务
        taskService.complete(task.getId());
    
        //  重新查询当前任务
        Task nextTask = taskService.createTaskQuery().processInstanceId(processInstanceId).singleResult();
        if (null != nextTask) {
            taskService.setAssignee(nextTask.getId(), startTask.getAssignee());
        }
    
        //  恢复原始方向
        currentFlowNode.setOutgoingFlows(originalSequenceFlowList);
    }

![967e0e0ac6baf7b32c52d613c191916f.png][]

![3cfe68355e1eace8a8704661a139c2eb.png][]

2. 会签

多个人同时处理一个任务，这种任务我们称之为会签任务 。Activiti实现会签是基于多实例任务，将节点设置成多实例，主要通过在UserTask节点的属性上配置。

![61fee033ac2d854872235c26720f5b3e.png][]

会签的种类：

*  按数量通过： 达到一定数量的通过表决后，会签通过。
 *  按比例通过： 达到一定比例的通过表决后，会签通过。
 *  一票否决： 只要有一个表决时否定的，会签通过。
 *  一票通过： 只要有一个表决通过的，会签通过。

每个实例有以下变量：

*  nrOfInstances: 实例总数
 *  nrOfActiveInstances: 当前激活的（未完成的）实例总数。 如果串行执行，则改值永远是1
 *  nrOfCompletedInstances: 已完成的实例总数

条件$\{nrOfInstances == nrOfCompletedInstances\}表示所有人员审批完成后会签结束。

条件$\{ nrOfCompletedInstances == 1\}表示一个人完成审批，该会签就结束。

其他条件依次类推，同时这里也可以写自己添加的流程变量。

相关文档如下：

> ![b6140e7cb498b412cae314dd8106b293.png][]
> 
> ![54b1f3c84b466bb5ac5b61dfb04169d1.png][]
> 
> ![c309152806eecfbb3cda58afbdfbac6d.png][]
> 
> ![74f00cfd02d64d7dd78b9a64054540da.png][]

**下面举个例子：**

![111063c794fd81e5feacb0391e06292e.png][]

![dbc6ba332e34073b5ea2562c15f11bfe.png][]

编写代码：

//  部署流程定义
    RepositoryService repositoryService = processEngine.getRepositoryService();
    Deployment deployment = repositoryService.createDeployment()
                    .addClasspathResource("diagram/countersign.bpmn")
                    .name("会签示例")
                    .key("countersign")
                    .deploy();
    
    //  启动流程实例
    RuntimeService runtimeService = processEngine.getRuntimeService();
    Map<String, Object> variables = new HashMap<>();
    variables.put("approverList", Arrays.asList("lisi","wangwu","zhaoliu"));
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("countersign", variables);
    
    //  完成任务
    TaskService taskService = processEngine.getTaskService();
    Task task = taskService.createTaskQuery().processInstanceId("107501").taskAssignee("zhaoliu").singleResult();
    if (null != task) {
        taskService.complete(task.getId());
    }

流程启动后，首先是zhangsan审批

![5c0b8f2c9d69a14241cd507431535e4d.png][]

![ef464fd5cbec6829be8bac1385bb8cb7.png][]

当zhangsan完成自己的任务后，进入会签环节，于是我们看到当前有3个激活的任务

![58d9007a31656eb9d3a7971452065491.png][]

![1e240088d120dee2cdde487caf4f2bc7.png][]

当lisi完成任务以后，当前任务剩下2个

![11754e475148129624dc8d5dc79ea6a2.png][]

![285fbc27f21828f5fd48807e05b4d482.png][]

当wangwu和zhaoliu都完成任务了以后，会签任务完成，进入下一个环节

![06b09a936d5cf36260a25147e12602c0.png][]

![ee93f068139a7a5a10008f634dff6721.png][]

刚才的例子中没有考虑到审批不通过的情况，接下来我们完善一下，考虑下面的流程

![16984d412a0150e7ab4e7b488d14fa46.png][]

![467e346feb0bf122dfcf9dcbb45b0fdc.png][]

<process id="countersign" name="countersign" isExecutable="true">
        <startEvent id="startevent1" name="Start"></startEvent>
        <userTask id="usertask1" name="申请" activiti:assignee="zhangsan"></userTask>
        <sequenceFlow id="flow1" sourceRef="startevent1" targetRef="usertask1"></sequenceFlow>
        <userTask id="usertask2" name="会签审批" activiti:assignee="${approver}">
            <multiInstanceLoopCharacteristics isSequential="false" activiti:collection="${approverList}" activiti:elementVariable="approver">
                <completionCondition>${nrOfCompletedInstances / nrOfInstances == 1 || pass == false}</completionCondition>
            </multiInstanceLoopCharacteristics>
        </userTask>
        <sequenceFlow id="flow2" sourceRef="usertask1" targetRef="usertask2"></sequenceFlow>
        <userTask id="usertask3" name="备案" activiti:assignee="tianqi"></userTask>
        <exclusiveGateway id="exclusivegateway1" name="Exclusive Gateway"></exclusiveGateway>
        <sequenceFlow id="flow5" sourceRef="usertask2" targetRef="exclusivegateway1"></sequenceFlow>
        <sequenceFlow id="flow6" name="通过" sourceRef="exclusivegateway1" targetRef="usertask3">
            <conditionExpression xsi:type="tFormalExpression"><![CDATA[${pass == true}]]></conditionExpression>
        </sequenceFlow>
        <sequenceFlow id="flow7" name="拒绝" sourceRef="exclusivegateway1" targetRef="usertask1">
            <conditionExpression xsi:type="tFormalExpression"><![CDATA[${pass == false}]]></conditionExpression>
        </sequenceFlow>
        <endEvent id="endevent1" name="End"></endEvent>
        <sequenceFlow id="flow8" sourceRef="usertask3" targetRef="endevent1"></sequenceFlow>
    </process>

在会签审批完成任务时就要加上流程变量pass了

RuntimeService runtimeService = processEngine.getRuntimeService();
    TaskService taskService = processEngine.getTaskService();
    
    Task task = taskService.createTaskQuery().processInstanceId("152501").taskAssignee("lisi").singleResult();
    if (null != task) {
        Map<String, Object> variables = new HashMap<>();
        variables.put("pass", true);
    //            variables.put("pass", false);
        taskService.complete(task.getId(), variables);
    
        runtimeService.getVariable(task.getExecutionId(), "nrOfCompletedInstances");
    }

zhaoliu审批的时候pass传的false，于是流程又走到zhangsan那里，流程重新又走了一遍才全部完成

![cc81176d9847284be0f5acaee8b111b4.png][]

![0d1996f88deb8fc90f1004662d9a544a.png][]

回退和会签就先讲到这里

[2090fa354b84505c4d814b0879353c5b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/e797b6065c2b4028be89bd9c2ad6f596.png
[946e02fff790a11fd154f4753ebabf40.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/ba4af7cf0d074675834fa519de26fb86.png
[01f6e1e4f61d3f0378bc5247d7e607c6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/42dc841a8a2a4ccbadffbbcd1d79013b.png
[d570f37246379d30a929e10910b5a089.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/9a11b05281bc4908a00bbf3c99d969d3.png
[e7ecf22495c90a69dee067db0404d3fe.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/ba2d2bd0ea174aa9844f4ff10ef24b8e.png
[41c3472dad629bbd7bd63f94e91daa99.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/498ea7bf039349eca68162938a2639e8.png
[32e75bce8c6fefe73fc795148077d81c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/a231c36cf5c2459c97feb61bfe43a0ba.png
[f555020ac9dd74d938fd1026ffc182b0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/db5cfa03f7204f3d8ec95b409baa7a53.png
[17a85215a89c8408c34fa3350706e517.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/d2f8f1e0809f4d979d419666c02a6d5e.png
[d2b6595cc4c2efaf751e23b80658e6dc.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/ba512946f82e46e3b74832d56426a04d.png
[a6cdeb572fa6777e6dfcae1456935678.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/a4231480cb024c68953afbe0ba808f3a.png
[967e0e0ac6baf7b32c52d613c191916f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/d943ae6911814e90b63c832259f93049.png
[3cfe68355e1eace8a8704661a139c2eb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/2b24f7e0510d49c69b55391372d6a08a.png
[61fee033ac2d854872235c26720f5b3e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/5d9ea1ed990541ff9eb5f5035f5d9938.png
[b6140e7cb498b412cae314dd8106b293.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/691a7846b2a14291b69d97d4f9a24fea.png
[54b1f3c84b466bb5ac5b61dfb04169d1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/459ec2e21ac749fe91eab2078c6fa64b.png
[c309152806eecfbb3cda58afbdfbac6d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/7fc3adc2ed6b484d8bccbc2cb3dd73f8.png
[74f00cfd02d64d7dd78b9a64054540da.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/8064f9ee61fe4650818da0b03b33d927.png
[111063c794fd81e5feacb0391e06292e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/0eccbbfd10fc44b9a6d26478eb841b16.png
[dbc6ba332e34073b5ea2562c15f11bfe.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/ac189b4a030944c3bfdf773926bef59e.png
[5c0b8f2c9d69a14241cd507431535e4d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/b7c4d8544d7742faa936e529ee16e475.png
[ef464fd5cbec6829be8bac1385bb8cb7.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/4e49faa7d5a541c5ae9492de8fa4a38a.png
[58d9007a31656eb9d3a7971452065491.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/40c5cf053c0743a2862cf79414ec822e.png
[1e240088d120dee2cdde487caf4f2bc7.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/adaef4766bb44fd1a8c84823734e3060.png
[11754e475148129624dc8d5dc79ea6a2.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/c071b255bf914578b9bfab4366426058.png
[285fbc27f21828f5fd48807e05b4d482.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/c732c98aa1c34f498196b4a11414e105.png
[06b09a936d5cf36260a25147e12602c0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/704a5abd4c9842d1a23a31cd007851cd.png
[ee93f068139a7a5a10008f634dff6721.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/b1ae6229fd4d4af4b783e6c2c18348c8.png
[16984d412a0150e7ab4e7b488d14fa46.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/da0a2777d97246769279ad418b4b16c3.png
[467e346feb0bf122dfcf9dcbb45b0fdc.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/a9b71dff684e46e19322a86795fcd19f.png
[cc81176d9847284be0f5acaee8b111b4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/5646f85666b64d91ba47cd734cd2052c.png
[0d1996f88deb8fc90f1004662d9a544a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/258b55d803134da2a2a3ebeb965a2165.png