在处理流程回退时,需要获取某个节点当前可以回退到的节点,简单分析下:
1. 只支持回退到userTask。
2. 如果流程流转过某节点时生成了多个任务,从其中某一个任务回退到该节点后,不处理另外的任务。
3. 只能回退到当前节点前已经处理过的节点。
基于这个考虑,获取哪些节点可以回退按如下处理:
1. 从历史任务表查当前节点所在流程实例已经完成过的所有任务,有可能包括当前节点以后的任务(比如当前节点本来就是由后面节点回退的)
2. 判断任务是不是当前节点以前的userTask节点任务,如果是,加入返回列表。
3. 同一个节点只返回一次。
在这种处理前提下,需要获取流程中所有userTask节点的前后关系。我用深度优先的方式对流程的所有节点进行了一个遍历,把所有节点的前后关系保存在一个map里,map的内容为:
key: 前面的节点编号#后面的节点编号
value:从前面节点到后面节点中间要经过几个节点。
如果一个节点前有多个节点,比如 流程是 A-->B-->C-->D,那么 map的数据类似:
{A#B:1,A#C:2,A#D:3,B#C:1,B#D:2,C#D:1}
在这种情况下,所有的可能性都存储了一份,但是在后面判断节点的前后关系时相对比较容易,只要把要判断的节点和当前节点编号拼接在一起,判断 要判断的节点#当前节点 是不是在map里存在就好了。
一般来说,流程的节点数不会太多,这样已经够用了。
由于回退不是在流程上通过划线处理的,所以一般不会出现环状的流程图,因此用深度优先方式遍历也适用,感觉上应该用广度优先的方式遍历更合适一点。
附部分代码:
private static Map<String,Map<String,Object>> PROCESS_NODE_MAP = null; private Map getFlowNodeRel(String processDefKey){if (null == PROCESS_NODE_MAP){PROCESS_NODE_MAP = new HashMap<String, Map<String, Object>>();}if(null == PROCESS_NODE_MAP.get(processDefKey)){ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();List<Process> processList = engine.getRepositoryService().getBpmnModel(processDefKey).getProcesses();Process process = null;if(processList.size()>0){process = processList.get(0);Map relationMap = new HashMap<String,Integer>();setFlowNodeRel(process,relationMap);PROCESS_NODE_MAP.put(processDefKey, relationMap);}}return PROCESS_NODE_MAP.get(processDefKey);}//根据process往relationMap里写入UserTask之间的前后关系,从start开始遍历节点,不循环private void setFlowNodeRel(Process process,Map relationMap){Iterator<FlowElement> iterator = process.getFlowElements().iterator();HashMap nodeMap = new HashMap<String,FlowElement>();setFlowNodeMap(process,nodeMap);//获取start节点StartEvent startEvent = (StartEvent) nodeMap.get("startEvent");//处理节点关系setFlowNodeRel("","startEvent",nodeMap,relationMap,1);}//根据节点ID设置关系private void setFlowNodeRel(String parentKey,String nodeId,Map<String,FlowElement> nodeMap,Map relationMap,int level){FlowElement element = nodeMap.get(nodeId);if(element instanceof UserTask){relationMap.put(nodeId, element);}if(!(element instanceof FlowNode)){return;}List<SequenceFlow> outFlows = ((FlowNode)element).getOutgoingFlows(); if(outFlows.size() == 0){return;}//采用深度遍历for(int index=0;index < outFlows.size();index++){SequenceFlow tmpSequence = outFlows.get(index);String target = tmpSequence.getTargetRef();String key = nodeId + "#" + target;String loopKey = target + "#" + nodeId;FlowElement tmpElement = nodeMap.get(target);//只是源和目标都是 用户任务 才写入if(relationMap.containsKey(loopKey) || relationMap.containsKey(key)){continue;}if(tmpElement instanceof UserTask && element instanceof UserTask){setRelMapValue(relationMap,parentKey,target, level);}//递归找下一个任务的关系setFlowNodeRel(parentKey+"#"+target,target,nodeMap,relationMap,level+1);}}private void setRelMapValue(Map relationMap,String parentKey,String nodeKey,int level){if(parentKey.length() > 0){String[] parentArr = parentKey.split("#");for(String parent:parentArr){if(StringUtils.isNotEmpty(parent)){String key = parent + "#" + nodeKey;String loopKey = nodeKey + "#" + parent;if(relationMap.containsKey(loopKey) || relationMap.containsKey(key)){continue;}else{relationMap.put(key, level);}}}}}//把流程节点设置到map属性里private void setFlowNodeMap(Process process,Map<String,FlowElement> nodeMap){Iterator<FlowElement> iterator = process.getFlowElements().iterator();while(iterator.hasNext()){FlowElement element = iterator.next(); if(element instanceof StartEvent){nodeMap.put("startEvent", element);}else{nodeMap.put(element.getId(),element);}}}