| | |
| | | if (!(targetFlowElement instanceof UserTask) && !subtask) { |
| | | throw new ServerException("开始节点后第一个节点必须是用户任务!"); |
| | | } |
| | | |
| | | //开始节点后第一个节点申请人节点 |
| | | if ((targetFlowElement instanceof UserTask) && !subtask) { |
| | | UserTask userTask = (UserTask) targetFlowElement; |
| | | if (StringUtils.isBlank(userTask.getFormKey())) { |
| | | throw new ServerException("申请人节点必须选择表单!"); |
| | | } |
| | | } |
| | | List<EndEvent> endEventList = flowElements.stream().filter(EndEvent.class::isInstance).map(EndEvent.class::cast).collect(Collectors.toList()); |
| | | if (CollUtil.isEmpty(endEventList)) { |
| | | throw new ServerException(subtask ? "子流程必须存在结束节点!" : "必须存在结束节点!"); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 获取流程全部用户节点 |
| | | * |
| | | * @param processDefinitionId 流程定义id |
| | | */ |
| | | public static List<UserTask> getUserTaskFlowElements(String processDefinitionId) { |
| | | BpmnModel bpmnModel = PROCESS_ENGINE.getRepositoryService().getBpmnModel(processDefinitionId); |
| | | List<UserTask> list = new ArrayList<>(); |
| | | List<Process> processes = bpmnModel.getProcesses(); |
| | | Collection<FlowElement> flowElements = processes.get(0).getFlowElements(); |
| | | buildUserTaskFlowElements(flowElements, list); |
| | | return list; |
| | | } |
| | | |
| | | /** |
| | | * 递归获取所有节点 |
| | | * |
| | | * @param flowElements 节点信息 |
| | | * @param list 集合 |
| | | */ |
| | | private static void buildUserTaskFlowElements(Collection<FlowElement> flowElements, List<UserTask> list) { |
| | | for (FlowElement flowElement : flowElements) { |
| | | if (flowElement instanceof SubProcess) { |
| | | Collection<FlowElement> subFlowElements = ((SubProcess) flowElement).getFlowElements(); |
| | | buildUserTaskFlowElements(subFlowElements, list); |
| | | } else if (flowElement instanceof UserTask) { |
| | | list.add((UserTask) flowElement); |
| | | } |
| | | } |
| | | } |
| | | |
| | |
| | | FlowNode flowNode = (FlowNode) bpmnModel.getFlowElement(taskDefinitionKey); |
| | | return flowNode instanceof UserTask; |
| | | } |
| | | |
| | | /** |
| | | * 获取申请人节点 |
| | | * |
| | | * @param processDefinitionId 流程定义id |
| | | * @return 结果 |
| | | */ |
| | | public static UserTask getApplyUserTask(String processDefinitionId) { |
| | | BpmnModel bpmnModel = PROCESS_ENGINE.getRepositoryService().getBpmnModel(processDefinitionId); |
| | | Collection<FlowElement> flowElements = bpmnModel.getMainProcess().getFlowElements(); |
| | | List<StartEvent> startEventList = flowElements.stream().filter(StartEvent.class::isInstance).map(StartEvent.class::cast).collect(Collectors.toList()); |
| | | StartEvent startEvent = startEventList.get(0); |
| | | List<SequenceFlow> outgoingFlows = startEvent.getOutgoingFlows(); |
| | | FlowElement targetFlowElement = outgoingFlows.get(0).getTargetFlowElement(); |
| | | return (UserTask) targetFlowElement; |
| | | } |
| | | } |