package com.vci.ubcs.flow.engine.utils;
|
|
import com.vci.ubcs.flow.core.utils.TaskUtil;
|
import com.vci.ubcs.flow.core.vo.FlowTaskHisVO;
|
import com.vci.ubcs.flow.engine.constant.FlowEngineConstant;
|
import com.vci.ubcs.starter.exception.VciBaseException;
|
import com.vci.ubcs.starter.web.util.VciBaseUtil;
|
import com.vci.ubcs.system.user.cache.UserCache;
|
import com.vci.ubcs.system.user.entity.User;
|
import com.vci.ubcs.system.user.vo.UserVO;
|
import org.apache.commons.lang3.StringUtils;
|
import org.flowable.bpmn.model.*;
|
import org.flowable.engine.HistoryService;
|
import org.flowable.engine.TaskService;
|
import org.flowable.engine.history.HistoricActivityInstance;
|
import org.flowable.engine.history.HistoricProcessInstance;
|
import org.flowable.engine.impl.bpmn.behavior.ParallelMultiInstanceBehavior;
|
import org.flowable.engine.impl.bpmn.behavior.SequentialMultiInstanceBehavior;
|
import org.flowable.engine.task.Comment;
|
import org.flowable.variable.api.history.HistoricVariableInstance;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* @author weidy
|
* @date 2021/4/2
|
*/
|
public class FlowableUtils {
|
/**
|
* 根据节点，获取入口连线
|
* @param source 节点
|
* @return 包含的线
|
*/
|
public static List<SequenceFlow> getElementIncomingFlows(FlowElement source) {
|
List<SequenceFlow> sequenceFlows = null;
|
if (source instanceof Task) {
|
sequenceFlows = ((Task) source).getIncomingFlows();
|
} else if (source instanceof Gateway) {
|
sequenceFlows = ((Gateway) source).getIncomingFlows();
|
} else if (source instanceof SubProcess) {
|
sequenceFlows = ((SubProcess) source).getIncomingFlows();
|
} else if (source instanceof StartEvent) {
|
sequenceFlows = ((StartEvent) source).getIncomingFlows();
|
} else if (source instanceof EndEvent) {
|
sequenceFlows = ((EndEvent) source).getIncomingFlows();
|
}
|
return sequenceFlows;
|
}
|
|
/**
|
* 根据节点，获取出口连线
|
* @param source 节点
|
* @return 出口的线
|
*/
|
public static List<SequenceFlow> getElementOutgoingFlows(FlowElement source) {
|
List<SequenceFlow> sequenceFlows = null;
|
if (source instanceof Task) {
|
sequenceFlows = ((Task) source).getOutgoingFlows();
|
} else if (source instanceof Gateway) {
|
sequenceFlows = ((Gateway) source).getOutgoingFlows();
|
} else if (source instanceof SubProcess) {
|
sequenceFlows = ((SubProcess) source).getOutgoingFlows();
|
} else if (source instanceof StartEvent) {
|
sequenceFlows = ((StartEvent) source).getOutgoingFlows();
|
} else if (source instanceof EndEvent) {
|
sequenceFlows = ((EndEvent) source).getOutgoingFlows();
|
}
|
return sequenceFlows;
|
}
|
|
/**
|
* 获取全部节点列表，包含子流程节点
|
* @param flowElements 节点
|
* @param allElements 所有的节点
|
* @return 节点的内容
|
*/
|
public static Collection<FlowElement> getAllElements(Collection<FlowElement> flowElements, Collection<FlowElement> allElements) {
|
allElements = allElements == null ? new ArrayList<>() : allElements;
|
|
for (FlowElement flowElement : flowElements) {
|
allElements.add(flowElement);
|
if (flowElement instanceof SubProcess) {
|
// 继续深入子流程，进一步获取子流程
|
allElements = FlowableUtils.getAllElements(((SubProcess) flowElement).getFlowElements(), allElements);
|
}
|
}
|
return allElements;
|
}
|
|
/**
|
* 迭代获取父级任务节点列表，向前找
|
* @param source 起始节点
|
* @param hasSequenceFlow 已经经过的连线的 ID，用于判断线路是否重复
|
* @param userTaskList 已找到的用户任务节点
|
* @return
|
*/
|
public static List<UserTask> iteratorFindParentUserTasks(FlowElement source, Set<String> hasSequenceFlow, List<UserTask> userTaskList) {
|
userTaskList = userTaskList == null ? new ArrayList<>() : userTaskList;
|
hasSequenceFlow = hasSequenceFlow == null ? new HashSet<>() : hasSequenceFlow;
|
|
// 如果该节点为开始节点，且存在上级子节点，则顺着上级子节点继续迭代
|
if (source instanceof StartEvent && source.getSubProcess() != null) {
|
userTaskList = iteratorFindParentUserTasks(source.getSubProcess(), hasSequenceFlow, userTaskList);
|
}
|
|
// 根据类型，获取入口连线
|
List<SequenceFlow> sequenceFlows = getElementIncomingFlows(source);
|
|
if (sequenceFlows != null) {
|
// 循环找到目标元素
|
for (SequenceFlow sequenceFlow: sequenceFlows) {
|
// 如果发现连线重复，说明循环了，跳过这个循环
|
if (hasSequenceFlow.contains(sequenceFlow.getId())) {
|
continue;
|
}
|
// 添加已经走过的连线
|
hasSequenceFlow.add(sequenceFlow.getId());
|
// 类型为用户节点，则新增父级节点
|
if (sequenceFlow.getSourceFlowElement() instanceof UserTask) {
|
userTaskList.add((UserTask) sequenceFlow.getSourceFlowElement());
|
continue;
|
}
|
// 类型为子流程，则添加子流程开始节点出口处相连的节点
|
if (sequenceFlow.getSourceFlowElement() instanceof SubProcess) {
|
// 获取子流程用户任务节点
|
List<UserTask> childUserTaskList = findChildProcessUserTasks((StartEvent) ((SubProcess) sequenceFlow.getSourceFlowElement()).getFlowElements().toArray()[0], null, null);
|
// 如果找到节点，则说明该线路找到节点，不继续向下找，反之继续
|
if (childUserTaskList != null && childUserTaskList.size() > 0) {
|
userTaskList.addAll(childUserTaskList);
|
continue;
|
}
|
}
|
// 继续迭代
|
// 注意：已经经过的节点与连线都应该用浅拷贝出来的对象
|
// 比如分支：a->b->c与a->d->c，走完a->b->c后走另一个路线是，已经经过的节点应该不包含a->b->c路线的数据
|
userTaskList = iteratorFindParentUserTasks(sequenceFlow.getSourceFlowElement(), new HashSet<>(hasSequenceFlow), userTaskList);
|
}
|
}
|
return userTaskList;
|
}
|
|
/**
|
* 根据正在运行的任务节点，迭代获取子级任务节点列表，向后找
|
* @param source 起始节点
|
* @param runActiveIdList 正在运行的任务 Key，用于校验任务节点是否是正在运行的节点
|
* @param hasSequenceFlow 已经经过的连线的 ID，用于判断线路是否重复
|
* @param flowElementList 需要撤回的用户任务列表
|
* @return 节点的信息
|
*/
|
public static List<FlowElement> iteratorFindChildUserTasks(FlowElement source, List<String> runActiveIdList, Set<String> hasSequenceFlow, List<FlowElement> flowElementList) {
|
hasSequenceFlow = hasSequenceFlow == null ? new HashSet<>() : hasSequenceFlow;
|
flowElementList = flowElementList == null ? new ArrayList<>() : flowElementList;
|
|
// 如果该节点为开始节点，且存在上级子节点，则顺着上级子节点继续迭代
|
if (source instanceof EndEvent && source.getSubProcess() != null) {
|
flowElementList = iteratorFindChildUserTasks(source.getSubProcess(), runActiveIdList, hasSequenceFlow, flowElementList);
|
}
|
|
// 根据类型，获取出口连线
|
List<SequenceFlow> sequenceFlows = getElementOutgoingFlows(source);
|
|
if (sequenceFlows != null) {
|
// 循环找到目标元素
|
for (SequenceFlow sequenceFlow: sequenceFlows) {
|
// 如果发现连线重复，说明循环了，跳过这个循环
|
if (hasSequenceFlow.contains(sequenceFlow.getId())) {
|
continue;
|
}
|
// 添加已经走过的连线
|
hasSequenceFlow.add(sequenceFlow.getId());
|
// 如果为用户任务类型，或者为网关
|
// 活动节点ID 在运行的任务中存在，添加
|
if ((sequenceFlow.getTargetFlowElement() instanceof UserTask || sequenceFlow.getTargetFlowElement() instanceof Gateway) && runActiveIdList.contains((sequenceFlow.getTargetFlowElement()).getId())) {
|
flowElementList.add(sequenceFlow.getTargetFlowElement());
|
continue;
|
}
|
// 如果节点为子流程节点情况，则从节点中的第一个节点开始获取
|
if (sequenceFlow.getTargetFlowElement() instanceof SubProcess) {
|
List<FlowElement> childUserTaskList = iteratorFindChildUserTasks((FlowElement) (((SubProcess) sequenceFlow.getTargetFlowElement()).getFlowElements().toArray()[0]), runActiveIdList, hasSequenceFlow, null);
|
// 如果找到节点，则说明该线路找到节点，不继续向下找，反之继续
|
if (childUserTaskList != null && childUserTaskList.size() > 0) {
|
flowElementList.addAll(childUserTaskList);
|
continue;
|
}
|
}
|
// 继续迭代
|
// 注意：已经经过的节点与连线都应该用浅拷贝出来的对象
|
// 比如分支：a->b->c与a->d->c，走完a->b->c后走另一个路线是，已经经过的节点应该不包含a->b->c路线的数据
|
flowElementList = iteratorFindChildUserTasks(sequenceFlow.getTargetFlowElement(), runActiveIdList, new HashSet<>(hasSequenceFlow), flowElementList);
|
}
|
}
|
return flowElementList;
|
}
|
|
/**
|
* 迭代获取子流程用户任务节点
|
* @param source 起始节点
|
* @param hasSequenceFlow 已经经过的连线的 ID，用于判断线路是否重复
|
* @param userTaskList 需要撤回的用户任务列表
|
* @return 任务
|
*/
|
public static List<UserTask> findChildProcessUserTasks(FlowElement source, Set<String> hasSequenceFlow, List<UserTask> userTaskList) {
|
hasSequenceFlow = hasSequenceFlow == null ? new HashSet<>() : hasSequenceFlow;
|
userTaskList = userTaskList == null ? new ArrayList<>() : userTaskList;
|
|
// 根据类型，获取出口连线
|
List<SequenceFlow> sequenceFlows = getElementOutgoingFlows(source);
|
|
if (sequenceFlows != null) {
|
// 循环找到目标元素
|
for (SequenceFlow sequenceFlow: sequenceFlows) {
|
// 如果发现连线重复，说明循环了，跳过这个循环
|
if (hasSequenceFlow.contains(sequenceFlow.getId())) {
|
continue;
|
}
|
// 添加已经走过的连线
|
hasSequenceFlow.add(sequenceFlow.getId());
|
// 如果为用户任务类型，且任务节点的 Key 正在运行的任务中存在，添加
|
if (sequenceFlow.getTargetFlowElement() instanceof UserTask) {
|
userTaskList.add((UserTask) sequenceFlow.getTargetFlowElement());
|
continue;
|
}
|
// 如果节点为子流程节点情况，则从节点中的第一个节点开始获取
|
if (sequenceFlow.getTargetFlowElement() instanceof SubProcess) {
|
List<UserTask> childUserTaskList = findChildProcessUserTasks((FlowElement) (((SubProcess) sequenceFlow.getTargetFlowElement()).getFlowElements().toArray()[0]), hasSequenceFlow, null);
|
// 如果找到节点，则说明该线路找到节点，不继续向下找，反之继续
|
if (childUserTaskList != null && childUserTaskList.size() > 0) {
|
userTaskList.addAll(childUserTaskList);
|
continue;
|
}
|
}
|
// 继续迭代
|
// 注意：已经经过的节点与连线都应该用浅拷贝出来的对象
|
// 比如分支：a->b->c与a->d->c，走完a->b->c后走另一个路线是，已经经过的节点应该不包含a->b->c路线的数据
|
userTaskList = findChildProcessUserTasks(sequenceFlow.getTargetFlowElement(), new HashSet<>(hasSequenceFlow), userTaskList);
|
}
|
}
|
return userTaskList;
|
}
|
|
/**
|
* 从后向前寻路，获取所有脏线路上的点
|
* @param source 起始节点
|
* @param passRoads 已经经过的点集合
|
* @param hasSequenceFlow 已经经过的连线的 ID，用于判断线路是否重复
|
* @param targets 目标脏线路终点
|
* @param dirtyRoads 确定为脏数据的点，因为不需要重复，因此使用 set 存储
|
* @return 路线
|
*/
|
public static Set<String> iteratorFindDirtyRoads(FlowElement source, List<String> passRoads, Set<String> hasSequenceFlow, List<String> targets, Set<String> dirtyRoads) {
|
passRoads = passRoads == null ? new ArrayList<>() : passRoads;
|
dirtyRoads = dirtyRoads == null ? new HashSet<>() : dirtyRoads;
|
hasSequenceFlow = hasSequenceFlow == null ? new HashSet<>() : hasSequenceFlow;
|
|
// 如果该节点为开始节点，且存在上级子节点，则顺着上级子节点继续迭代
|
if (source instanceof StartEvent && source.getSubProcess() != null) {
|
dirtyRoads = iteratorFindDirtyRoads(source.getSubProcess(), passRoads, hasSequenceFlow, targets, dirtyRoads);
|
}
|
|
// 根据类型，获取入口连线
|
List<SequenceFlow> sequenceFlows = getElementIncomingFlows(source);
|
|
if (sequenceFlows != null) {
|
// 循环找到目标元素
|
for (SequenceFlow sequenceFlow: sequenceFlows) {
|
// 如果发现连线重复，说明循环了，跳过这个循环
|
if (hasSequenceFlow.contains(sequenceFlow.getId())) {
|
continue;
|
}
|
// 添加已经走过的连线
|
hasSequenceFlow.add(sequenceFlow.getId());
|
// 新增经过的路线
|
passRoads.add(sequenceFlow.getSourceFlowElement().getId());
|
// 如果此点为目标点，确定经过的路线为脏线路，添加点到脏线路中，然后找下个连线
|
if (targets.contains(sequenceFlow.getSourceFlowElement().getId())) {
|
dirtyRoads.addAll(passRoads);
|
continue;
|
}
|
// 如果该节点为开始节点，且存在上级子节点，则顺着上级子节点继续迭代
|
if (sequenceFlow.getSourceFlowElement() instanceof SubProcess) {
|
dirtyRoads = findChildProcessAllDirtyRoad((StartEvent) ((SubProcess) sequenceFlow.getSourceFlowElement()).getFlowElements().toArray()[0], null, dirtyRoads);
|
// 是否存在子流程上，true 是，false 否
|
Boolean isInChildProcess = dirtyTargetInChildProcess((StartEvent) ((SubProcess) sequenceFlow.getSourceFlowElement()).getFlowElements().toArray()[0], null, targets, null);
|
if (isInChildProcess) {
|
// 已在子流程上找到，该路线结束
|
continue;
|
}
|
}
|
// 继续迭代
|
// 注意：已经经过的节点与连线都应该用浅拷贝出来的对象
|
// 比如分支：a->b->c与a->d->c，走完a->b->c后走另一个路线是，已经经过的节点应该不包含a->b->c路线的数据
|
dirtyRoads = iteratorFindDirtyRoads(sequenceFlow.getSourceFlowElement(), new ArrayList<>(passRoads), new HashSet<>(hasSequenceFlow), targets, dirtyRoads);
|
}
|
}
|
return dirtyRoads;
|
}
|
|
/**
|
* 迭代获取子流程脏路线
|
* 说明，假如回退的点就是子流程，那么也肯定会回退到子流程最初的用户任务节点，因此子流程中的节点全是脏路线
|
* @param source 起始节点
|
* @param hasSequenceFlow 已经经过的连线的 ID，用于判断线路是否重复
|
* @param dirtyRoads 确定为脏数据的点，因为不需要重复，因此使用 set 存储
|
* @return 路线
|
*/
|
public static Set<String> findChildProcessAllDirtyRoad(FlowElement source, Set<String> hasSequenceFlow, Set<String> dirtyRoads) {
|
hasSequenceFlow = hasSequenceFlow == null ? new HashSet<>() : hasSequenceFlow;
|
dirtyRoads = dirtyRoads == null ? new HashSet<>() : dirtyRoads;
|
|
// 根据类型，获取出口连线
|
List<SequenceFlow> sequenceFlows = getElementOutgoingFlows(source);
|
|
if (sequenceFlows != null) {
|
// 循环找到目标元素
|
for (SequenceFlow sequenceFlow: sequenceFlows) {
|
// 如果发现连线重复，说明循环了，跳过这个循环
|
if (hasSequenceFlow.contains(sequenceFlow.getId())) {
|
continue;
|
}
|
// 添加已经走过的连线
|
hasSequenceFlow.add(sequenceFlow.getId());
|
// 添加脏路线
|
dirtyRoads.add(sequenceFlow.getTargetFlowElement().getId());
|
// 如果节点为子流程节点情况，则从节点中的第一个节点开始获取
|
if (sequenceFlow.getTargetFlowElement() instanceof SubProcess) {
|
dirtyRoads = findChildProcessAllDirtyRoad((FlowElement) (((SubProcess) sequenceFlow.getTargetFlowElement()).getFlowElements().toArray()[0]), hasSequenceFlow, dirtyRoads);
|
}
|
// 继续迭代
|
// 注意：已经经过的节点与连线都应该用浅拷贝出来的对象
|
// 比如分支：a->b->c与a->d->c，走完a->b->c后走另一个路线是，已经经过的节点应该不包含a->b->c路线的数据
|
dirtyRoads = findChildProcessAllDirtyRoad(sequenceFlow.getTargetFlowElement(), new HashSet<>(hasSequenceFlow), dirtyRoads);
|
}
|
}
|
return dirtyRoads;
|
}
|
|
/**
|
* 判断脏路线结束节点是否在子流程上
|
* @param source 起始节点
|
* @param hasSequenceFlow 已经经过的连线的 ID，用于判断线路是否重复
|
* @param targets 判断脏路线节点是否存在子流程上，只要存在一个，说明脏路线只到子流程为止
|
* @param inChildProcess 是否存在子流程上，true 是，false 否
|
* @return 是否
|
*/
|
public static Boolean dirtyTargetInChildProcess(FlowElement source, Set<String> hasSequenceFlow, List<String> targets, Boolean inChildProcess) {
|
hasSequenceFlow = hasSequenceFlow == null ? new HashSet<>() : hasSequenceFlow;
|
inChildProcess = inChildProcess == null ? false : inChildProcess;
|
|
// 根据类型，获取出口连线
|
List<SequenceFlow> sequenceFlows = getElementOutgoingFlows(source);
|
|
if (sequenceFlows != null && !inChildProcess) {
|
// 循环找到目标元素
|
for (SequenceFlow sequenceFlow: sequenceFlows) {
|
// 如果发现连线重复，说明循环了，跳过这个循环
|
if (hasSequenceFlow.contains(sequenceFlow.getId())) {
|
continue;
|
}
|
// 添加已经走过的连线
|
hasSequenceFlow.add(sequenceFlow.getId());
|
// 如果发现目标点在子流程上存在，说明只到子流程为止
|
if (targets.contains(sequenceFlow.getTargetFlowElement().getId())) {
|
inChildProcess = true;
|
break;
|
}
|
// 如果节点为子流程节点情况，则从节点中的第一个节点开始获取
|
if (sequenceFlow.getTargetFlowElement() instanceof SubProcess) {
|
inChildProcess = dirtyTargetInChildProcess((FlowElement) (((SubProcess) sequenceFlow.getTargetFlowElement()).getFlowElements().toArray()[0]), hasSequenceFlow, targets, inChildProcess);
|
}
|
// 继续迭代
|
// 注意：已经经过的节点与连线都应该用浅拷贝出来的对象
|
// 比如分支：a->b->c与a->d->c，走完a->b->c后走另一个路线是，已经经过的节点应该不包含a->b->c路线的数据
|
inChildProcess = dirtyTargetInChildProcess(sequenceFlow.getTargetFlowElement(), new HashSet<>(hasSequenceFlow), targets, inChildProcess);
|
}
|
}
|
return inChildProcess;
|
}
|
|
/**
|
* 迭代从后向前扫描，判断目标节点相对于当前节点是否是串行
|
* 不存在直接回退到子流程中的情况，但存在从子流程出去到父流程情况
|
* @param source 起始节点
|
* @param isSequential 是否串行
|
* @param hasSequenceFlow 已经经过的连线的 ID，用于判断线路是否重复
|
* @param targetKsy 目标节点
|
* @return 是否
|
*/
|
public static Boolean iteratorCheckSequentialReferTarget(FlowElement source, String targetKsy, Set<String> hasSequenceFlow, Boolean isSequential) {
|
isSequential = isSequential == null ? true : isSequential;
|
hasSequenceFlow = hasSequenceFlow == null ? new HashSet<>() : hasSequenceFlow;
|
|
// 如果该节点为开始节点，且存在上级子节点，则顺着上级子节点继续迭代
|
if (source instanceof StartEvent && source.getSubProcess() != null) {
|
isSequential = iteratorCheckSequentialReferTarget(source.getSubProcess(), targetKsy, hasSequenceFlow, isSequential);
|
}
|
|
// 根据类型，获取入口连线
|
List<SequenceFlow> sequenceFlows = getElementIncomingFlows(source);
|
|
if (sequenceFlows != null) {
|
// 循环找到目标元素
|
for (SequenceFlow sequenceFlow: sequenceFlows) {
|
// 如果发现连线重复，说明循环了，跳过这个循环
|
if (hasSequenceFlow.contains(sequenceFlow.getId())) {
|
continue;
|
}
|
// 添加已经走过的连线
|
hasSequenceFlow.add(sequenceFlow.getId());
|
// 如果目标节点已被判断为并行，后面都不需要执行，直接返回
|
if (isSequential == false) {
|
break;
|
}
|
// 这条线路存在目标节点，这条线路完成，进入下个线路
|
if (targetKsy.equals(sequenceFlow.getSourceFlowElement().getId())) {
|
continue;
|
}
|
if (sequenceFlow.getSourceFlowElement() instanceof StartEvent) {
|
isSequential = false;
|
break;
|
}
|
// 否则就继续迭代
|
// 注意：已经经过的节点与连线都应该用浅拷贝出来的对象
|
// 比如分支：a->b->c与a->d->c，走完a->b->c后走另一个路线是，已经经过的节点应该不包含a->b->c路线的数据
|
isSequential = iteratorCheckSequentialReferTarget(sequenceFlow.getSourceFlowElement(), targetKsy, new HashSet<>(hasSequenceFlow), isSequential);
|
}
|
}
|
return isSequential;
|
}
|
|
/**
|
* 从后向前寻路，获取到达节点的所有路线
|
* 不存在直接回退到子流程，但是存在回退到父级流程的情况
|
* @param source 起始节点
|
* @param passRoads 已经经过的点集合
|
* @param roads 路线
|
* @return 任务
|
*/
|
public static List<List<UserTask>> findRoad(FlowElement source, List<UserTask> passRoads, Set<String> hasSequenceFlow, List<List<UserTask>> roads) {
|
passRoads = passRoads == null ? new ArrayList<>() : passRoads;
|
roads = roads == null ? new ArrayList<>() : roads;
|
hasSequenceFlow = hasSequenceFlow == null ? new HashSet<>() : hasSequenceFlow;
|
|
// 如果该节点为开始节点，且存在上级子节点，则顺着上级子节点继续迭代
|
if (source instanceof StartEvent && source.getSubProcess() != null) {
|
roads = findRoad(source.getSubProcess(), passRoads, hasSequenceFlow, roads);
|
}
|
|
// 根据类型，获取入口连线
|
List<SequenceFlow> sequenceFlows = getElementIncomingFlows(source);
|
|
if (sequenceFlows != null && sequenceFlows.size() != 0) {
|
for (SequenceFlow sequenceFlow: sequenceFlows) {
|
// 如果发现连线重复，说明循环了，跳过这个循环
|
if (hasSequenceFlow.contains(sequenceFlow.getId())) {
|
continue;
|
}
|
// 添加已经走过的连线
|
hasSequenceFlow.add(sequenceFlow.getId());
|
// 添加经过路线
|
if (sequenceFlow.getSourceFlowElement() instanceof UserTask) {
|
passRoads.add((UserTask) sequenceFlow.getSourceFlowElement());
|
}
|
// 继续迭代
|
// 注意：已经经过的节点与连线都应该用浅拷贝出来的对象
|
// 比如分支：a->b->c与a->d->c，走完a->b->c后走另一个路线是，已经经过的节点应该不包含a->b->c路线的数据
|
roads = findRoad(sequenceFlow.getSourceFlowElement(), new ArrayList<>(passRoads), new HashSet<>(hasSequenceFlow), roads);
|
}
|
} else {
|
// 添加路线
|
roads.add(passRoads);
|
}
|
return roads;
|
}
|
|
/**
|
* 历史节点数据清洗，清洗掉又回滚导致的脏数据
|
* @param allElements 全部节点信息
|
* @param historicActivityIdList 历史任务实例信息，数据采用开始时间升序
|
* @return 历史数据
|
*/
|
public static List<String> historicTaskInstanceClean(Collection<FlowElement> allElements, List<HistoricActivityInstance> historicActivityIdList) {
|
// 会签节点收集
|
List<String> multiTask = new ArrayList<>();
|
allElements.forEach(flowElement -> {
|
if (flowElement instanceof UserTask) {
|
// 如果该节点的行为为会签行为，说明该节点为会签节点
|
if (((UserTask) flowElement).getBehavior() instanceof ParallelMultiInstanceBehavior || ((UserTask) flowElement).getBehavior() instanceof SequentialMultiInstanceBehavior) {
|
multiTask.add(flowElement.getId());
|
}
|
}
|
});
|
// 循环放入栈，栈 LIFO：后进先出
|
Stack<HistoricActivityInstance> stack = new Stack<>();
|
historicActivityIdList.forEach(item -> stack.push(item));
|
// 清洗后的历史任务实例
|
List<String> lastHistoricTaskInstanceList = new ArrayList<>();
|
// 网关存在可能只走了部分分支情况，且还存在跳转废弃数据以及其他分支数据的干扰，因此需要对历史节点数据进行清洗
|
// 临时用户任务 key
|
StringBuilder userTaskKey = null;
|
// 临时被删掉的任务 key，存在并行情况
|
List<String> deleteKeyList = new ArrayList<>();
|
// 临时脏数据线路
|
List<Set<String>> dirtyDataLineList = new ArrayList<>();
|
// 由某个点跳到会签点,此时出现多个会签实例对应 1 个跳转情况，需要把这些连续脏数据都找到
|
// 会签特殊处理下标
|
int multiIndex = -1;
|
// 会签特殊处理 key
|
StringBuilder multiKey = null;
|
// 会签特殊处理操作标识
|
boolean multiOpera = false;
|
while (!stack.empty()) {
|
// 从这里开始 userTaskKey 都还是上个栈的 key
|
// 是否是脏数据线路上的点
|
final boolean[] isDirtyData = {false};
|
for (Set<String> oldDirtyDataLine : dirtyDataLineList) {
|
if (oldDirtyDataLine.contains(stack.peek().getActivityId())) {
|
isDirtyData[0] = true;
|
}
|
}
|
// 删除原因不为空，说明从这条数据开始回跳或者回退的
|
// MI_END：会签完成后，其他未签到节点的删除原因，不在处理范围内
|
if (stack.peek().getDeleteReason() != null && !stack.peek().getDeleteReason().equals("MI_END")) {
|
// 可以理解为脏线路起点
|
String dirtyPoint = "";
|
if (stack.peek().getDeleteReason().indexOf("Change activity to ") >= 0) {
|
dirtyPoint = stack.peek().getDeleteReason().replace("Change activity to ", "");
|
}
|
// 会签回退删除原因有点不同
|
if (stack.peek().getDeleteReason().indexOf("Change parent activity to ") >= 0) {
|
dirtyPoint = stack.peek().getDeleteReason().replace("Change parent activity to ", "");
|
}
|
FlowElement dirtyTask = null;
|
// 获取变更节点的对应的入口处连线
|
// 如果是网关并行回退情况，会变成两条脏数据路线，效果一样
|
for (FlowElement flowElement : allElements) {
|
if (flowElement.getId().equals(stack.peek().getActivityId())) {
|
dirtyTask = flowElement;
|
}
|
}
|
// 获取脏数据线路
|
Set<String> dirtyDataLine = FlowableUtils.iteratorFindDirtyRoads(dirtyTask, null, null, Arrays.asList(dirtyPoint.split(",")), null);
|
// 自己本身也是脏线路上的点，加进去
|
dirtyDataLine.add(stack.peek().getActivityId());
|
//logger.info(stack.peek().getActivityId() + "点脏路线集合：" + dirtyDataLine);
|
// 是全新的需要添加的脏线路
|
boolean isNewDirtyData = true;
|
for (int i = 0; i < dirtyDataLineList.size(); i++) {
|
// 如果发现他的上个节点在脏线路内，说明这个点可能是并行的节点，或者连续驳回
|
// 这时，都以之前的脏线路节点为标准，只需合并脏线路即可，也就是路线补全
|
if (dirtyDataLineList.get(i).contains(userTaskKey.toString())) {
|
isNewDirtyData = false;
|
dirtyDataLineList.get(i).addAll(dirtyDataLine);
|
}
|
}
|
// 已确定时全新的脏线路
|
if (isNewDirtyData) {
|
// deleteKey 单一路线驳回到并行，这种同时生成多个新实例记录情况，这时 deleteKey 其实是由多个值组成
|
// 按照逻辑，回退后立刻生成的实例记录就是回退的记录
|
// 至于驳回所生成的 Key，直接从删除原因中获取，因为存在驳回到并行的情况
|
deleteKeyList.add(dirtyPoint + ",");
|
dirtyDataLineList.add(dirtyDataLine);
|
}
|
// 添加后，现在这个点变成脏线路上的点了
|
isDirtyData[0] = true;
|
}
|
// 如果不是脏线路上的点，说明是有效数据，添加历史实例 Key
|
if (!isDirtyData[0]) {
|
lastHistoricTaskInstanceList.add(stack.peek().getActivityId());
|
}
|
// 校验脏线路是否结束
|
for (int i = 0; i < deleteKeyList.size(); i ++) {
|
// 如果发现脏数据属于会签，记录下下标与对应 Key，以备后续比对，会签脏数据范畴开始
|
if (multiKey == null && multiTask.contains(stack.peek().getActivityId())
|
&& deleteKeyList.get(i).contains(stack.peek().getActivityId())) {
|
multiIndex = i;
|
multiKey = new StringBuilder(stack.peek().getActivityId());
|
}
|
// 会签脏数据处理，节点退回会签清空
|
// 如果在会签脏数据范畴中发现 Key改变，说明会签脏数据在上个节点就结束了，可以把会签脏数据删掉
|
if (multiKey != null && !multiKey.toString().equals(stack.peek().getActivityId())) {
|
deleteKeyList.set(multiIndex , deleteKeyList.get(multiIndex).replace(stack.peek().getActivityId() + ",", ""));
|
multiKey = null;
|
// 结束进行下校验删除
|
multiOpera = true;
|
}
|
// 其他脏数据处理
|
// 发现该路线最后一条脏数据，说明这条脏数据线路处理完了，删除脏数据信息
|
// 脏数据产生的新实例中是否包含这条数据
|
if (multiKey == null && deleteKeyList.get(i).contains(stack.peek().getActivityId())) {
|
// 删除匹配到的部分
|
deleteKeyList.set(i , deleteKeyList.get(i).replace(stack.peek().getActivityId() + ",", ""));
|
}
|
// 如果每组中的元素都以匹配过，说明脏数据结束
|
if ("".equals(deleteKeyList.get(i))) {
|
// 同时删除脏数据
|
deleteKeyList.remove(i);
|
dirtyDataLineList.remove(i);
|
break;
|
}
|
}
|
// 会签数据处理需要在循环外处理，否则可能导致溢出
|
// 会签的数据肯定是之前放进去的所以理论上不会溢出，但还是校验下
|
if (multiOpera && deleteKeyList.size() > multiIndex && "".equals(deleteKeyList.get(multiIndex))) {
|
// 同时删除脏数据
|
deleteKeyList.remove(multiIndex);
|
dirtyDataLineList.remove(multiIndex);
|
multiIndex = -1;
|
multiOpera = false;
|
}
|
// pop() 方法与 peek() 方法不同，在返回值的同时，会把值从栈中移除
|
// 保存新的 userTaskKey 在下个循环中使用
|
userTaskKey = new StringBuilder(stack.pop().getActivityId());
|
}
|
//logger.info("清洗后的历史节点数据：" + lastHistoricTaskInstanceList);
|
return lastHistoricTaskInstanceList;
|
}
|
|
/**
|
* 获取相关的历史
|
* @param processInstanceId 流程实例的主键
|
* @param historyService 历史服务
|
* @param taskService 任务服务
|
* @return 历史的信息
|
*/
|
public static List<FlowTaskHisVO> listTaskHistory(String processInstanceId, HistoryService historyService, TaskService taskService){
|
HistoricProcessInstance processInstance = historyService.createHistoricProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();
|
if(processInstance == null || StringUtils.isBlank(processInstance.getId())){
|
throw new VciBaseException("流程未找到");
|
}
|
List<HistoricActivityInstance> hisList = historyService.createHistoricActivityInstanceQuery().processInstanceId(processInstanceId).activityType("userTask").orderByHistoricActivityInstanceEndTime().desc().list();
|
Map<String,FlowTaskHisVO> hisVOList = new HashMap<>();
|
if(!CollectionUtils.isEmpty(hisList)){
|
List<HistoricActivityInstance> allowTaskInstances = new ArrayList<>();
|
Map<String,List<Comment>> taskOidCommentsMap = new HashMap<>();
|
for(int i = 0 ; i < hisList.size(); i ++){
|
HistoricActivityInstance his = hisList.get(i);
|
//我们找当时的审批信息，这样可以判断是否为不同意
|
List<Comment> comments = taskService.getTaskComments(his.getTaskId());
|
if(!CollectionUtils.isEmpty(comments)){
|
taskOidCommentsMap.put(his.getId(),comments);
|
//查询
|
}//第一个可能没有
|
allowTaskInstances.add(his);
|
}
|
if(!CollectionUtils.isEmpty(allowTaskInstances)){
|
List<HistoricVariableInstance> variableInstances = historyService.createHistoricVariableInstanceQuery().processInstanceId(processInstanceId).list();
|
Map<String,Object> variableMap = switchVariable(variableInstances);
|
Set<Long> userIds = new HashSet<>();
|
Set<String> processInstanceIds = new HashSet<>();
|
for(int i = 0 ; i < allowTaskInstances.size() ; i ++){
|
HistoricActivityInstance activityInstance = allowTaskInstances.get(i);
|
if(!hisVOList.containsKey(activityInstance.getId())) {
|
FlowTaskHisVO hisVO = new FlowTaskHisVO();
|
hisVO.setOid(activityInstance.getId());
|
hisVO.setActivityId(activityInstance.getActivityId());
|
hisVO.setActivityName(activityInstance.getActivityName());
|
hisVO.setActivityType(activityInstance.getActivityType());
|
hisVO.setProcessDefinitionId(activityInstance.getProcessDefinitionId());
|
hisVO.setProcessInstanceId(activityInstance.getProcessInstanceId());
|
hisVO.setExecutionId(activityInstance.getExecutionId());
|
hisVO.setTaskId(activityInstance.getTaskId());
|
hisVO.setCalledProcessInstanceId(activityInstance.getCalledProcessInstanceId());
|
hisVO.setAssignee(activityInstance.getAssignee());
|
if (StringUtils.isNotBlank(hisVO.getAssignee())) {
|
userIds.add(TaskUtil.getUserId(hisVO.getAssignee()));
|
}
|
hisVO.setStartTime(activityInstance.getStartTime());
|
hisVO.setEndTime(activityInstance.getEndTime());
|
hisVO.setDurationInMillis(activityInstance.getDurationInMillis());
|
hisVO.setDeleteReason(activityInstance.getDeleteReason());
|
hisVO.setTenantId(activityInstance.getTenantId());
|
hisVO.setVariablesMap(variableMap);
|
hisVO.setBtmType(variableMap.getOrDefault(FlowEngineConstant.BTMTYPE,"").toString());
|
hisVO.setLinkBusinessOids(VciBaseUtil.str2List(variableMap.getOrDefault(FlowEngineConstant.OIDS,"").toString()));
|
List<Comment> comments = taskOidCommentsMap.getOrDefault(activityInstance.getId(),new ArrayList<>());
|
hisVO.setDescription(comments.stream().map(s->{
|
String fullMsg = s.getFullMessage();
|
if(StringUtils.isNotBlank(fullMsg) && fullMsg.contains(":")){
|
fullMsg = fullMsg.substring(fullMsg.indexOf(":")+1);
|
}
|
return fullMsg;
|
}).collect(Collectors.joining(";")));
|
processInstanceIds.add(activityInstance.getProcessInstanceId());
|
hisVO.setProcessName(processInstance.getName());
|
hisVO.setProcessDefinitionName(processInstance.getProcessDefinitionName());
|
hisVOList.put(hisVO.getActivityId(), hisVO);
|
}
|
}
|
if(!CollectionUtils.isEmpty(userIds) && !CollectionUtils.isEmpty(hisVOList)){
|
List<User> userList = new ArrayList<>();
|
for(Long userId : userIds){
|
userList.add(UserCache.getUser(userId));
|
}
|
if(!CollectionUtils.isEmpty(userList)){
|
Map<Long, User> userVOMap = userList.stream().collect(Collectors.toMap(s -> s.getId(), t -> t, (o1, o2) -> o1));
|
hisVOList.values().forEach(history->{
|
List<String> thisUserIds = VciBaseUtil.str2List(TaskUtil.getTaskUser(history.getAssignee()));
|
List<String> thisUserNames = new ArrayList<>();
|
if(!CollectionUtils.isEmpty(thisUserIds)) {
|
thisUserIds.forEach(userId -> {
|
thisUserNames.add(userVOMap.getOrDefault(userId, new User()).getName());
|
});
|
}
|
history.setAssigneeName(thisUserNames.stream().collect(Collectors.joining(",")));
|
});
|
}
|
}
|
}
|
}
|
return hisVOList.values().stream().collect(Collectors.toList());
|
}
|
|
/**
|
* 转换变量
|
* @param variableInstances 变量的实例
|
* @return 变量
|
*/
|
public static Map<String,Object> switchVariable(List<HistoricVariableInstance> variableInstances){
|
Map<String,Object> variableMap = new HashMap<>();
|
if(!CollectionUtils.isEmpty(variableInstances)){
|
variableMap = variableInstances.stream().collect(Collectors.toMap(s->s.getVariableName(),t->t.getValue() == null?"":t.getValue()));
|
}
|
return variableMap;
|
}
|
}
|
