Activiti7实现驳回功能

所谓驳回，其实就是返回到上个执行节点，但是这个里面又分两种情况

单个执行人assignee的情况

第一种情况比较简单，直接在流程图里用一个变量控制，比如audit为true时代表审核通过，走下一个节点，audit为false时代表驳回，返回上一个节点，这时直接连线到上一个节点，然后设置条件为${audit == false}即可。

多个候选人candidate user的情况

第二种情况就比较麻烦。用第一种情况的方法是不行的。为什么不行？有人说用上面的方法不是可以回到上次执行的节点吗？是的，虽然可以回到上次的节点，但是状态还是初始状态，即assignee为空的状态，我们知道，candidate需要先拾取任务，然后才能完成任务。举个例子，candidate user为张三和李四两个人，张三拾取任务后完成任务，到下一步后被驳回，这时上面的方法回到上一步时，为任务未拾取的状态，这时李四还可以拾取任务并完成。这样显然是不对的，驳回时应该打回到张三，也就是返回上一个节点时应该指定assignee为张三才对。

要实现上述效果，就要进行一些底层的操作了。大概思路如下：

• 取得当前节点的信息
• 取得当前节点的上一个节点的信息
• 保存当前节点的流向
• 新建流向，由当前节点指向上一个节点
• 将当前节点的流向设置为上面新建的流向
• 当前节点完成任务
• 将当前节点的流向还原
• 取得之前上个节点的执行人
• 设置上个节点的assignee为之前的执行人

好了，talk is cheap, show me the code，下面直接上代码（已测试通过）

如有问题，欢迎指正！

/**
 *
 * 退回到上一节点
 *
 * @param task 当前任务
 */
public void backProcess(Task task) throws Exception {

    String processInstanceId = task.getProcessInstanceId();

    // 取得所有历史任务按时间降序排序
    List<HistoricTaskInstance> htiList = historyService.createHistoricTaskInstanceQuery()
            .processInstanceId(processInstanceId)
            .orderByTaskCreateTime()
            .desc()
            .list();

    if (ObjectUtils.isEmpty(htiList) || htiList.size() < 2) {
        return;
    }

    // list里的第二条代表上一个任务
    HistoricTaskInstance lastTask = htiList.get(1);

    // list里第二条代表当前任务
    HistoricTaskInstance curTask = htiList.get(0);

    // 当前节点的executionId
    String curExecutionId = curTask.getExecutionId();


    // 上个节点的taskId
    String lastTaskId = lastTask.getId();
    // 上个节点的executionId
    String lastExecutionId = lastTask.getExecutionId();

    if (null == lastTaskId) {
        throw new Exception("LAST TASK IS NULL");
    }

    String processDefinitionId = lastTask.getProcessDefinitionId();
    BpmnModel bpmnModel = repositoryService.getBpmnModel(processDefinitionId);

    String lastActivityId = null;
    List<HistoricActivityInstance> haiFinishedList = historyService.createHistoricActivityInstanceQuery()
            .executionId(lastExecutionId).finished().list();

    for (HistoricActivityInstance hai : haiFinishedList) {
        if (lastTaskId.equals(hai.getTaskId())) {
            // 得到ActivityId，只有HistoricActivityInstance对象里才有此方法
            lastActivityId = hai.getActivityId();
            break;
        }
    }

    // 得到上个节点的信息
    FlowNode lastFlowNode = (FlowNode) bpmnModel.getMainProcess().getFlowElement(lastActivityId);


    // 取得当前节点的信息
    Execution execution = runtimeService.createExecutionQuery().executionId(curExecutionId).singleResult();
    String curActivityId = execution.getActivityId();
    FlowNode curFlowNode = (FlowNode) bpmnModel.getMainProcess().getFlowElement(curActivityId);

    //记录当前节点的原活动方向
    List<SequenceFlow> oriSequenceFlows = new ArrayList<>();
    oriSequenceFlows.addAll(curFlowNode.getOutgoingFlows());

    //清理活动方向
    curFlowNode.getOutgoingFlows().clear();

    //建立新方向
    List<SequenceFlow> newSequenceFlowList = new ArrayList<>();
    SequenceFlow newSequenceFlow = new SequenceFlow();
    newSequenceFlow.setId("newSequenceFlowId");
    newSequenceFlow.setSourceFlowElement(curFlowNode);
    newSequenceFlow.setTargetFlowElement(lastFlowNode);
    newSequenceFlowList.add(newSequenceFlow);
    curFlowNode.setOutgoingFlows(newSequenceFlowList);

    // 完成任务
    taskService.complete(task.getId());

    //恢复原方向
    curFlowNode.setOutgoingFlows(oriSequenceFlows);

    org.activiti.engine.task.Task nextTask = taskService
            .createTaskQuery().processInstanceId(processInstanceId).singleResult();

    // 设置执行人
    if(nextTask!=null) {
        taskService.setAssignee(nextTask.getId(), lastTask.getAssignee());
    }
}