Activiti如何实现流程的回退

1.概述

流程回退一直以来是个老旧的难题，也一直没有好的解决方法，本文就来详述流程回退的解决办法。首先我们来分析一下不同的流程审批情况，并在对应的节点上实现流程的回退处理，以及应该提供的回退处理，当然我们说的回退不是指通过在流程节点上画一条线回退到想回的节点上。

创新互联专注于网站建设，为客户提供网站设计制作、做网站、网页设计开发服务，多年建网站服务经验，各类网站都可以开发，高端网站设计，公司官网，公司展示网站，网站设计，建网站费用，建网站多少钱，价格优惠，收费合理。

回退时，需要解决两种情况：

•     回退到发起人

•     回退到上一步及逐步回退

因为回退至任一节点上，Activiti本身的api是不支持的，我们只能通过扩展activiti的的api，以实现自由跳转才达到回退至任一节点上，但有情况是例外的，回退的时候，需要注意，否则activiti在跳转的时候，数据是容易出问题的，主要是在并发的节点分支里跳到外面时（如下图所示,B、D节点回到A节点时），其执行的实例Id会变化，因此，需要注意对这种情况下的流程跳转作一些限制。

那么我们需要在当前审批的任务上，需要进行回退到任何一个节点，实现自由跳转时，如何扩展，如下为我们扩展activiti来实现自由跳转的实现方式：

/**
  * 将节点之后的节点删除然后指向新的节点。 
  * @param actDefId   流程定义ID
  * @param nodeId   流程节点ID
  * @param aryDestination 需要跳转的节点
  * @return Map 返回节点和需要恢复节点的集合。
  */@SuppressWarnings("unchecked")
private Map  prepare(String actDefId,String nodeId,String[] aryDestination){
  Map map=new HashMap();
 
 //修改流程定义 ProcessDefinitionEntity processDefinition = (ProcessDefinitionEntity)repositoryService.getProcessDefinition(actDefId);
 
  ActivityImpl curAct= processDefinition.findActivity(nodeId);
  List outTrans= curAct.getOutgoingTransitions();
 try{
   List cloneOutTrans=(List) FileUtil.cloneObject(outTrans);
   map.put("outTrans", cloneOutTrans);
 }
 catch(Exception ex){
  
 }
 
 /**
   * 解决通过选择自由跳转指向同步节点导致的流程终止的问题。
   * 在目标节点中删除指向自己的流转。
   */ for(Iterator it=outTrans.iterator();it.hasNext();){
   PvmTransition transition=it.next();
   PvmActivity activity= transition.getDestination();
   List inTrans= activity.getIncomingTransitions();
  for(Iterator itIn=inTrans.iterator();itIn.hasNext();){
    PvmTransition inTransition=itIn.next();
   if(inTransition.getSource().getId().equals(curAct.getId())){
     itIn.remove();
   }
  }
 }
 
 
  curAct.getOutgoingTransitions().clear();
 
 if(aryDestination!=null && aryDestination.length>0){
  for(String dest:aryDestination){
   //创建一个连接   ActivityImpl destAct= processDefinition.findActivity(dest);
    TransitionImpl transitionImpl = curAct.createOutgoingTransition();
    transitionImpl.setDestination(destAct);
  }
 }
 
  map.put("activity", curAct);
 
 
 return map;
 
}/**
  * 将临时节点清除掉，加回原来的节点。
  * @param map 
  * void
  */@SuppressWarnings("unchecked")
private void restore(Map map){
  ActivityImpl curAct=(ActivityImpl) map.get("activity");
  List outTrans=(List) map.get("outTrans");
  curAct.getOutgoingTransitions().clear();
  curAct.getOutgoingTransitions().addAll(outTrans);
}/**
  * 通过指定目标节点，实现任务的跳转
  * @param taskId 任务ID
  * @param destNodeIds 跳至的目标节点ID
  * @param vars 流程变量
  */public synchronized void completeTask(String taskId,String[] destNodeIds,Map vars) {
  TaskEntity task=(TaskEntity)taskService.createTaskQuery().taskId(taskId).singleResult();
 
  String curNodeId=task.getTaskDefinitionKey();
  String actDefId=task.getProcessDefinitionId();
 
  Map activityMap= prepare(actDefId, curNodeId, destNodeIds);
 try{
   taskService.complete(taskId);
 }
 catch(Exception ex){
  throw new RuntimeException(ex);
 }
 finally{
  //恢复  restore(activityMap);
 }
}

若我们需要进行跳转，就需要知道回退上一步时，其上一步是什么节点。如何仅是通过流程获得其回退的节点，这是达不到业务的需求的，因为有时我们需要回退到某个节点处理后，下一步需要回到原来的节点上，如我们在上图E节点上，回退时，E回退需要回到D或C上，完成后再回到B，这种情况下我们可以要求E必须需要去到G1节点上，往下执行。这种回退就会显得人性化，同时也保证流程实例在后续的执行过程中，其信号及各参数是正常的，这时就要求我们需要有一个完整记录流程实例执行经过的各个节点ID的数据，并且通过以下的数据可以快速找到当前节点回退时，应该回退到哪一个节点上，并且当时这个节点的执行人员是谁。

2.如何记录流程的执行过程

为了更好记录流程经过的树节点，我们采用了一个树结构来存储流程实例执行时，经过的流程节点，如上图所示，其执行的树型图所示所示：

我们需要在各个节点那里可以找到其退回至上一步环节的父节点那里，这需要一个算法，如在B或D那里回退，我们让他退回A，在C回退我们让他回到B，若我们在E位置回退，我们需要让他回到G1那里。这个算法的实现不算复杂，有这个树型的执行树数据后，一切变得很简单。但要注意一点，我们在回退时，需要记录他是从哪个节点回退过来的，若用户处理完成后，可以要求他直接回到原回退的节点去，也可以按流程定义重新走一次审批。假如执行到E，让他回退时并且重新审批，其执行的树图如下所示：

注意G1，那里有指向E，当完成时，可以让他来跳到E上，这就是任务完成后，可以找到它应该跳至哪一个任务节点上。

3.扩展表记录流程的执行的路径

/*==============================================================*//* Table: BPM_RU_PATH                                           *//*==============================================================*/CREATE TABLE BPM_RU_PATH
(
   PATH_ID_             VARCHAR(64) NOT NULL,
   INST_ID_             VARCHAR(64) NOT NULL COMMENT '流程实例ID',
   ACT_DEF_ID_          VARCHAR(64) NOT NULL COMMENT 'Act定义ID',
   ACT_INST_ID_         VARCHAR(64) NOT NULL COMMENT 'Act实例ID',
   SOL_ID_              VARCHAR(64) NOT NULL COMMENT '解决方案ID',
   NODE_ID_             VARCHAR(255) NOT NULL COMMENT '节点ID',
   NODE_NAME_           VARCHAR(255) COMMENT '节点名称',
   NODE_TYPE_           VARCHAR(50) COMMENT '节点类型',
   START_TIME_          DATETIME NOT NULL COMMENT '开始时间',
   END_TIME_            DATETIME COMMENT '结束时间',
   DURATION_            INT COMMENT '持续时长',
   DURATION_VAL_        INT COMMENT '有效审批时长',
   ASSIGNEE_            VARCHAR(64) COMMENT '处理人ID',
   TO_USER_ID_          VARCHAR(64) COMMENT '代理人ID',
   IS_MULTIPLE_         VARCHAR(20) COMMENT '是否为多实例',
   EXECUTION_ID_        VARCHAR(64) COMMENT '活动执行ID',
   USER_IDS_            VARCHAR(300) COMMENT '原执行人IDS',
   PARENT_ID_           VARCHAR(64) COMMENT '父ID',
   LEVEL_               INT COMMENT '层次',
   OUT_TRAN_ID_         VARCHAR(255) COMMENT '跳出路线ID',
   TOKEN_               VARCHAR(255) COMMENT '路线令牌',
   JUMP_TYPE_           VARCHAR(50) COMMENT '跳到该节点的方式
            正常跳转
            自由跳转
            回退跳转',
   NEXT_JUMP_TYPE_      VARCHAR(50) COMMENT '下一步跳转方式',
   OPINION_             VARCHAR(500) COMMENT '审批意见',
   REF_PATH_ID_         VARCHAR(64) COMMENT '引用路径ID
            当回退时，重新生成的结点，需要记录引用的回退节点，方便新生成的路径再次回退。',
   TENANT_ID_           VARCHAR(64) COMMENT '租用机构ID',
   CREATE_BY_           VARCHAR(64) COMMENT '创建人ID',
   CREATE_TIME_         DATETIME COMMENT '创建时间',
   UPDATE_BY_           VARCHAR(64) COMMENT '更新人ID',
   UPDATE_TIME_         DATETIME COMMENT '更新时间',
  PRIMARY KEY (PATH_ID_)
);

ALTER TABLE BPM_RU_PATH COMMENT ‘流程实例运行路线’;

4.如何创建执行路径

有了面的表结构后，如何让activiti在执行的过程中，往上面的表加上我们需要的数据，这时我们就需要利用activiti的全局事件监听器，具体的实现请参考我的全局事件监听处理。

其中Activiti提供了两个不错的事件监听，一个是执行实体创建事件ACTIVITY_STARTED，一个实体完成的事件ACTIVITY_COMPLETED。我们分别在这两个事件上加上bpm_ru_path表的记录创建与更新即可。在其回退的时候，通过算法找到其需要回退的节点，然后通过上文提供的自由跳转方法，即可以实现流程的回退。

5.流程回退处理

有了以上的执行数据，流程的回退，就可以通过算法找到其需要回退的流程节点，从而可以实现流程的回退处理，注意以下的获得当前任务的回退节点Id,然后指定这个节点Id为执行完成后，需要跳转至这个节点上。
注意这部分代码 BpmRuPath bpmRuPath = getBackNodeId(task.getProcessInstanceId(), task.getTaskDefinitionKey());

/**
  * 任务往下跳转
  * 
  * @param taskId
  * @param jsonData
  * @param vars
  * @throws Exception
  */public void doNext(ProcessNextCmd cmd) throws Exception {
 
 boolean isSetBackPath = false;
 try {
   TaskEntity task = (TaskEntity) taskService.createTaskQuery().taskId(cmd.getTaskId()).singleResult();
  
   UserTaskConfig userTaskConfig=bpmNodeSetManager.getTaskConfig(task.getSolId(), task.getTaskDefinitionKey());
    
  //String processInstanceId = task.getProcessInstanceId();  // 加上executionId，用来记录执行的路径  cmd.setNodeId(task.getTaskDefinitionKey());
  // 加上线程变量  ProcessHandleHelper.setProcessCmd(cmd);
   BpmInst bpmInst = bpmInstManager.getByActInstId(task.getProcessInstanceId());
   BpmFormInst bpmFormInst = bpmFormInstManager.get(bpmInst.getFormInstId());
  try {
    String newJson = JSONUtil.copyJsons(bpmFormInst.getJsonData(), cmd.getJsonData());
    bpmFormInst.setJsonData(newJson);
    bpmFormInstManager.saveOrUpdate(bpmFormInst);
  } catch (Exception ex) {
    logger.error(ex.getCause());
  }
   Map vars = handleTaskVars(task, cmd.getJsonData());
  // 加上外围传过来的变量  if (cmd.getVars() != null) {
    vars.putAll(cmd.getVars());
  }
  // 若为回退，则处理回退的操作  if (TaskOptionType.BACK.name().equals(cmd.getJumpType())) {
    BpmRuPath bpmRuPath = getBackNodeId(task.getProcessInstanceId(), task.getTaskDefinitionKey());
   // 没有找到回退的节点，提示用户   if (bpmRuPath == null) {
     ProcessHandleHelper.getProcessMessage().getErrorMsges().add("本环节不能回退！没有找到上一步的回退审批环节!");
    return;
   } else {// 设置回退的节点    cmd.setDestNodeId(bpmRuPath.getNodeId());
     ProcessHandleHelper.setBackPath(bpmRuPath);
     isSetBackPath = true;
   }
  } else if (TaskOptionType.BACK_TO_STARTOR.name().equals(cmd.getJumpType())) {// 回退至发起人   ActNodeDef afterNode = actRepService.getNodeAfterStart(task.getProcessDefinitionId());
   if (afterNode == null) {
     ProcessHandleHelper.getProcessMessage().getErrorMsges().add("没有找到发起人所在的审批环节！");
    return;
   } else {
     cmd.setDestNodeId(afterNode.getNodeId());
   }
  } else {
   // 查找是否为原路返回的模式，即当前任务是否由回退处理的   BpmRuPath ruPath = bpmRuPathManager.getFarestPath(task.getProcessInstanceId(), task.getTaskDefinitionKey());
   if (ruPath != null && "".equals(ruPath.getNextJumpType())) {
     BpmRuPath toNodePath = bpmRuPathManager.get(ruPath.getParentId());
    if (toNodePath != null) {
      cmd.setDestNodeId(toNodePath.getNodeId());
    }
   }
  }
  
  //加上前置处理  if(StringUtils.isNotEmpty(userTaskConfig.getPreHandle())){
    Object preBean=AppBeanUtil.getBean(userTaskConfig.getPreHandle());
   if(preBean instanceof TaskPreHandler){
     TaskPreHandler handler=(TaskPreHandler)preBean;
     handler.taskPreHandle(cmd, task, bpmInst.getBusKey());
   }   
  }
  // 以下为任务的跳转处理  if (StringUtils.isNotEmpty(cmd.getDestNodeId())) {// 进行指定节点的跳转   actTaskService.completeTask(cmd.getTaskId(), new String[] { cmd.getDestNodeId() }, vars);
  } else {// 正常跳转   taskService.complete(cmd.getTaskId(), vars);
  }
  
  //加上后置处理  if(StringUtils.isNotEmpty(userTaskConfig.getAfterHandle())){
    Object preBean=AppBeanUtil.getBean(userTaskConfig.getAfterHandle());
   if(preBean instanceof TaskAfterHandler){
     TaskAfterHandler handler=(TaskAfterHandler)preBean;
     handler.taskAfterHandle(cmd, task.getTaskDefinitionKey(), bpmInst.getBusKey());
   } 
  }
 } catch (Exception e) {
   e.printStackTrace();
   logger.error(e.getCause());
  throw e;
 } finally {
   ProcessHandleHelper.clearProcessCmd();
  if (isSetBackPath) {
    ProcessHandleHelper.clearBackPath();
  }
 }
}

具体的实现效果可以参考如下在线示例，

需要在流程解决方案的节点配置中，打开回退按钮，如下图所示：

了解咨询QQ:1361783075