流程引擎 Camunda工作流的退回

Posted 2022-03-12 学习使得吾快乐

Camunda工作流的退回操作

话不多说,直接上代码

代码块 1:

/**
 * 退回到起点
 */
@Test
public void deny()
    String processInstanceId = "37f9f9f4-9f72-11ec-8d1f-5254000c17ac";

    Task activeTask = taskService.createTaskQuery()
            .processInstanceId(processInstanceId)
            .active()
            .singleResult();
    HistoricTaskInstance taskInstance = historyService.createHistoricTaskInstanceQuery()
            .taskId(activeTask.getId())
            .singleResult();

    // 获取流程定义
    ProcessDefinitionEntity processDefinitionEntity = (ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService).getDeployedProcessDefinition(taskInstance.getProcessDefinitionId());

    // 获取当前活动
    ActivityImpl currentActivity = processDefinitionEntity.findActivity(taskInstance.getTaskDefinitionKey());

    // 获取起始活动
    List<HistoricActivityInstance> historicActivityInstances = historyService.createHistoricActivityInstanceQuery()
            .activityType("userTask")
            .processInstanceId(processInstanceId)
            .finished()
            .orderByHistoricActivityInstanceEndTime()
            .asc()
            .list();
    if(historicActivityInstances.size() == 0)
       return ;
    
    ActivityImpl lastActivity = processDefinitionEntity.findActivity(historicActivityInstances.get(0).getActivityId());

    // 退回至起点
    runtimeService.createProcessInstanceModification(processInstanceId)
            .cancelAllForActivity(currentActivity.getActivityId())
            .startBeforeActivity(lastActivity.getActivityId())
            .setVariable("denyReason","就是搞你,就给你退回去")
            .execute();

这段代码是参考Camunda官网来写来的,具体地址: https://docs.camunda.org/manual/7.15/user-guide/process-engine/process-instance-modification/#process-instance-modification-in-junit-tests

还有一段代码是参照activiti的退回写的,代码如下:

代码块 2:

/**
 * 任务回退到开始
 */
@Test
public void rollBackToShangYiJi()
    //String processInstanceId = "49b521ac-9f50-11ec-8d1f-5254000c17ac";
    String processInstanceId = "37f9f9f4-9f72-11ec-8d1f-5254000c17ac";
    // 根据流程实例 id 获取当前任务
    Task activeTask = taskService.createTaskQuery()
            .processInstanceId(processInstanceId)
            .active()
            .singleResult();
    HistoricTaskInstance taskInstance = historyService.createHistoricTaskInstanceQuery()
            .taskId(activeTask.getId())
            .singleResult();

    // 获取流程定义
    ProcessDefinitionEntity processDefinitionEntity = (ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService).getDeployedProcessDefinition(taskInstance.getProcessDefinitionId());

    // 获取当前活动
    ActivityImpl currentActivity = processDefinitionEntity.findActivity(taskInstance.getTaskDefinitionKey());

    //清除当前活动出口
    List<PvmTransition> originPvmTransitions = new ArrayList<>();
    List<PvmTransition> pvmTransitionList = currentActivity.getOutgoingTransitions();
    for (PvmTransition pvmTransition : pvmTransitionList) 
        originPvmTransitions.add(pvmTransition);
    
    pvmTransitionList.clear();

    //查找最开始的user task节点
    List<HistoricActivityInstance> historicActivityInstances = historyService.createHistoricActivityInstanceQuery()
            .activityType("userTask")
            .processInstanceId(processInstanceId)
            .finished()
            .orderByHistoricActivityInstanceEndTime()
            .asc()
            .list();
    TransitionImpl transition = null;
    if(historicActivityInstances.size() > 0)
        ActivityImpl lastActivity = processDefinitionEntity.findActivity(historicActivityInstances.get(0).getActivityId());
        //把当前任务的新出口设置为最开始的userTask节点
        transition = currentActivity.createOutgoingTransition(lastActivity.getId());
        transition.setDestination(lastActivity);
    
    // 完成任务
    List<Task> tasks = taskService.createTaskQuery()
            .processInstanceId(processInstanceId)
            .taskDefinitionKey(taskInstance.getTaskDefinitionKey())
            .list();

    for(Task task : tasks)
        taskService.complete(task.getId());
        historyService.deleteHistoricTaskInstance(task.getId());
    
    //恢复活动方向
    currentActivity.getOutgoingTransitions().remove(transition);
    for (PvmTransition pvmTransition : originPvmTransitions) 
        pvmTransitionList.add(pvmTransition);
    

参考网址:https://blog.csdn.net/qq_41136963/article/details/108184871

目前存在的问题

代码块1:

无法添加退回意见

代码块2:

测试时可以反复退回
但在实际环境下,二次退回时,节点的namedOutgoingTransitions无法清空,导致无法使当前节点的出口设置为起始节点
博主在找不到解决方案的情况下选择了代码块1

关于退回到上一级

假如存在 o -> 1 -> 2 ->3 -> O 的流程
如果用户在2节点和3节点之间反复横跳,来回的同意和退回,就会导致出现一大堆的historicActivityInstances数据
如果还使用上面的两个代码块中的代码,仅仅通过调整数字下标是无法准确定位到当前节点的上一级节点的
如何准确的获取上一级节点,方式还需要去研究

最后,欢迎大家留言讨论, 共同进步,一起成长