//flowable/activiti 如何退回上一个节点？下面使用代码演示：

//退回上一个节点： public String rollBackWorkFlow(String taskId) {   this.taskService=processEngine.getTaskService();   this.historyService = processEngine.getHistoryService();   this.repositoryService = processEngine.getRepositoryService();   this.runtimeService = processEngine.getRuntimeService();     try {         Map variables;         // 取得当前任务.当前任务节点         HistoricTaskInstance currTask = historyService                 .createHistoricTaskInstanceQuery().taskId(taskId)                 .singleResult();         // 取得流程实例，流程实例         ProcessInstance instance = runtimeService                 .createProcessInstanceQuery()                 .processInstanceId(currTask.getProcessInstanceId())                 .singleResult();         if (instance == null) {          log.info("流程结束");             log.error("出错啦！流程已经结束");             return "ERROR";         }         variables = instance.getProcessVariables();         // 取得流程定义         ProcessDefinitionEntity definition = (ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService)                 .getDeployedProcessDefinition(currTask                         .getProcessDefinitionId());         if (definition == null) {          log.info("流程定义未找到");             log.error("出错啦！流程定义未找到");             return "ERROR";         }         // 取得上一步活动         ActivityImpl currActivity = ((ProcessDefinitionImpl) definition)                 .findActivity(currTask.getTaskDefinitionKey());         //也就是节点间的连线         List nextTransitionList = currActivity                 .getIncomingTransitions();         // 清除当前活动的出口         List oriPvmTransitionList = new ArrayList();         //新建一个节点连线关系集合         List pvmTransitionList = currActivity                 .getOutgoingTransitions();         //         for (PvmTransition pvmTransition : pvmTransitionList) {             oriPvmTransitionList.add(pvmTransition);         }         pvmTransitionList.clear();         // 建立新出口         List newTransitions = new ArrayList();         for (PvmTransition nextTransition : nextTransitionList) {             PvmActivity nextActivity = nextTransition.getSource();             ActivityImpl nextActivityImpl = ((ProcessDefinitionImpl) definition)                     .findActivity(nextActivity.getId());             TransitionImpl newTransition = currActivity                     .createOutgoingTransition();             newTransition.setDestination(nextActivityImpl);             newTransitions.add(newTransition);         }         // 完成任务         List tasks = taskService.createTaskQuery()                 .processInstanceId(instance.getId())                 .taskDefinitionKey(currTask.getTaskDefinitionKey()).list();         for (Task task : tasks) {             taskService.complete(task.getId(), variables);             historyService.deleteHistoricTaskInstance(task.getId());         }         // 恢复方向         for (TransitionImpl transitionImpl : newTransitions) {             currActivity.getOutgoingTransitions().remove(transitionImpl);         }         for (PvmTransition pvmTransition : oriPvmTransitionList) {             pvmTransitionList.add(pvmTransition);         }         log.info("OK");         log.info("流程结束");         return "SUCCESS";     } catch (Exception e) {      log.error("失败");         log.error(e.getMessage());         return "ERROR";     } } //回退到指定节点： public String rollBackToAssignWorkFlow(String taskId,String destTaskkey) {   this.taskService=processEngine.getTaskService();   this.historyService = processEngine.getHistoryService();   this.repositoryService = processEngine.getRepositoryService();   this.runtimeService = processEngine.getRuntimeService();     try {         Map variables;         // 取得当前任务.当前任务节点         HistoricTaskInstance currTask = historyService                 .createHistoricTaskInstanceQuery().taskId(taskId)                 .singleResult();         // 取得流程实例，流程实例         ProcessInstance instance = runtimeService                 .createProcessInstanceQuery()                 .processInstanceId(currTask.getProcessInstanceId())                 .singleResult();         if (instance == null) {          log.info("流程结束");             log.error("出错啦！流程已经结束");             return "ERROR";         }         variables = instance.getProcessVariables();         // 取得流程定义         ProcessDefinitionEntity definition = (ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService)                 .getDeployedProcessDefinition(currTask                         .getProcessDefinitionId());         if (definition == null) {          log.info("流程定义未找到");             log.error("出错啦！流程定义未找到");             return "ERROR";         }        //取得当前活动节点         ActivityImpl currActivity = ((ProcessDefinitionImpl) definition)                 .findActivity(currTask.getTaskDefinitionKey());          log.info("currActivity"+currActivity);          // 取得上一步活动         //也就是节点间的连线         //获取来源节点的关系         List nextTransitionList = currActivity.getIncomingTransitions();         // 清除当前活动的出口         List oriPvmTransitionList = new ArrayList();         //新建一个节点连线关系集合         //获取出口节点的关系         List pvmTransitionList = currActivity                 .getOutgoingTransitions();         //         for (PvmTransition pvmTransition : pvmTransitionList) {             oriPvmTransitionList.add(pvmTransition);         }         pvmTransitionList.clear();         // 建立新出口         List newTransitions = new ArrayList();         for (PvmTransition nextTransition : nextTransitionList) {             PvmActivity nextActivity = nextTransition.getSource();                         log.info("nextActivity"+nextActivity);                         log.info("nextActivity.getId()"+nextActivity.getId());                         //destTaskkey             ActivityImpl nextActivityImpl = ((ProcessDefinitionImpl) definition)                    // .findActivity(nextActivity.getId());               .findActivity(destTaskkey);             TransitionImpl newTransition = currActivity                     .createOutgoingTransition();             newTransition.setDestination(nextActivityImpl);             newTransitions.add(newTransition);         }         // 完成任务         List tasks = taskService.createTaskQuery()                 .processInstanceId(instance.getId())                 .taskDefinitionKey(currTask.getTaskDefinitionKey()).list();         for (Task task : tasks) {             taskService.complete(task.getId(), variables);             historyService.deleteHistoricTaskInstance(task.getId());         }         // 恢复方向         for (TransitionImpl transitionImpl : newTransitions) {             currActivity.getOutgoingTransitions().remove(transitionImpl);         }         for (PvmTransition pvmTransition : oriPvmTransitionList) {          pvmTransitionList.add(pvmTransition);         }         log.info("OK");         log.info("流程结束");         return "SUCCESS";     } catch (Exception e) {      log.error("失败");         log.error(e.getMessage());         return "ERROR";     } }  

一、驳回/退回上一步/退回到（历史某一个节点）

        我们经常需要工作流中退回上一步，或者退回历史某一个节点。但由于流程的场景是很复杂的，回退有以下一些场景：

1.串行路线上的退回：流程中没有任何网关（排他网关/并行网关）和会签多实例。

2.退回到并行网关分支中的某一个节点上：

3.并行网关中的某一个分支节点上发起退回，退回到并行网关前面的某一个节点上

4.子流程中退回到主干流程中某一个节点/主干流程退回到子流程中某一个节点。

如下图：

 

 

二、flowable实现：

1.普通串行路线上的退回（此流程中没有并行网关的退回时），此方法支持普通串行节点/会签多实例节点/排他网关节点：

runtimeService.createChangeActivityStateBuilder()

        .processInstanceId(proInstanceId)

        .moveActivityIdsToSingleActivityId(curTaskKeys, targetTaskKey)

        .changeState();

或者

moveActivityIdTo(String currentActivityId,String newActivityId)；

2.并行网关中发起退回（即撤销当前的网关）,这个地方不能用moveActivityIdTo(String currentActivityId,String newActivityId)；是因为当某一个分支完成，它的is_active为0，另一条分支没有完成时。这时候这个方法是取不到所的分支的key的，它只有is_active为1的key能取到，不然就会造成多一条垃圾数据，同时再走并行时，任何一个分支不会等另一个分支就完走到分支的合并节点上，这就是bug，所以要改为以下方法：

// 并行网关的退回

List currentExecutionIds = new ArrayList<>();

List executions = runtimeService.createExecutionQuery().parentId(proInstanceId).list();

for (Execution execution : executions) {

    System.out.println("并行网关节点数："+execution.getActivityId());

    currentExecutionIds.add(execution.getId());

}

runtimeService.createChangeActivityStateBuilder()

        .moveExecutionsToSingleActivityId(currentExecutionIds, targetTaskKey)

        .changeState();

3.退回到并行网关中的某一个节点：经试验退回时必须同时退回并行网关中的所有分支。

List targetTaskKeys = new ArrayList<>();

targetTaskKeys.add("sid-CA74ADED-7E70-451D-951C-95988BFC3F07");

targetTaskKeys.add("sid-7922C598-74FD-4848-95AC-D9790AF68432");

 

runtimeService.createChangeActivityStateBuilder()

        .processInstanceId(proInstanceId)

        .moveSingleActivityIdToActivityIds("sid-CAD50E6F-7E0C-437D-816B-DDBA1A976A79", targetTaskKeys)

        .changeState();

4.主干流程和子流程的退回（没有试验过），官方提供了以下方法：

moveActivityIdToParentActivityId(String currentActivityId, String newActivityId)

moveActivityIdToSubProcessInstanceActivityId(String currentActivityId, String newActivityId, String callActivityId)

moveActivityIdToSubProcessInstanceActivityId(String currentActivityId,  String newActivityId, String callActivityId,Integer subProcessDefinitionVersion)

1、自己新写了一个Command，需要实现org.flowable.engine.common.impl.interceptor.Command

 接口，覆盖其execute

 方法，并增加一个有参构造方法

 2、通过flowable的org.flowable.engine.ManagementService，调用自己写的Command，实现回退。

  manageMentService.executeCommand(new JumpCmd(flowElement,currentTask,hisTaskEntity)); 

  //第一个参数flowElement是需要跳转到的节点信息，这里因为要求的是回退到上一节点，所以这里只上一节点信息

  //第二个参数是值当前任务实体

  //第三个参数指需要跳转到的节点的任务实体，这里指上一节点的任务实体

 

 

 

 说明：对于无分支的流程，需要回退到上一节点，可以直接利用flowable现有的API，调用方法如下：

 runtimeService.createChangeActivityStateBuilder().processInstanceId(processInstanceId).cancelActivityId(currentNode).startActivityId(beforeNode).changeState();