基于Flowable的低代码开源工作流引擎设计源码

package com.cxygzl.core.utils; import cn.hutool.core.util.IdUtil; import cn.hutool.core.util.RandomUtil; import cn.hutool.core.util.StrUtil; import com.cxygzl.common.constants.NodeTypeEnum; import com.cxygzl.common.constants.ProcessInstanceConstant; import com.cxygzl.common.dto.flow.ExpireSetting; import com.cxygzl.common.dto.flow.Node; import com.cxygzl.common.utils.NodeUtil; import com.cxygzl.core.expression.condition.NodeExpressionStrategyFactory; import com.cxygzl.core.listeners.ApprovalCreateListener; import com.cxygzl.core.listeners.FlowProcessEventListener; import com.cxygzl.core.node.INodeDataStoreHandler; import com.cxygzl.core.node.NodeDataStoreFactory; import com.cxygzl.core.servicetask.ApproveServiceTask; import com.cxygzl.core.servicetask.CopyServiceTask; import lombok.extern.slf4j.Slf4j; import org.flowable.bpmn.model.Process; import org.flowable.bpmn.model.*; import java.util.ArrayList; import java.util.List; /** * 模型工具类 处理模型构建相关的 */ @Slf4j public class ModelUtil { /** * 构建模型 * * @param nodeDto 前端传输节点 * @return */ public static BpmnModel buildBpmnModel(Node nodeDto, String processName, String flowId) { BpmnModel bpmnModel = new BpmnModel(); bpmnModel.setTargetNamespace("cxygzl"); Process process = new Process(); process.setId(flowId); process.setName(processName); //流程监听器 ArrayList<EventListener> eventListeners = new ArrayList<>(); { //流程实例监听器 EventListener eventListener = new EventListener(); eventListener.setImplementationType("class"); eventListener.setImplementation(FlowProcessEventListener.class.getCanonicalName()); eventListeners.add(eventListener); } process.setEventListeners(eventListeners); NodeUtil.addEndNode(nodeDto); //创建所有的节点 buildAllNode(process, nodeDto, flowId); //创建所有的内部节点连接线 buildAllNodeInnerSequence(process, nodeDto, flowId); //创建节点间连线 buildAllNodeOuterSequence(process, nodeDto, null); //处理分支和下级连线 bpmnModel.addProcess(process); return bpmnModel; } /** * 先创建所有的节点 * * @param process * @param nodeDto * @param flowId */ public static void buildAllNode(Process process, Node nodeDto, String flowId) { if (!NodeUtil.isNode(nodeDto)) { return; } List<FlowElement> flowElementList = buildNode(nodeDto, flowId); for (FlowElement flowElement : flowElementList) { if (process.getFlowElement(flowElement.getId()) == null) { process.addFlowElement(flowElement); } } //子节点 Node children = nodeDto.getChildNode(); if (NodeTypeEnum.getByValue(nodeDto.getType()).getBranch()) { //条件分支 List<Node> branchs = nodeDto.getConditionNodes(); for (Node branch : branchs) { buildAllNode(process, branch.getChildNode(), flowId); } if (NodeUtil.isNode(children)) { buildAllNode(process, children, flowId); } } else { if (NodeUtil.isNode(children)) { buildAllNode(process, children, flowId); } } } /** * 先创建所有的内部节点连接线 * * @param process * @param nodeDto * @param flowId */ public static void buildAllNodeInnerSequence(Process process, Node nodeDto, String flowId) { if (!NodeUtil.isNode(nodeDto)) { return; } //画内部线 List<SequenceFlow> flowList = buildInnerSequenceFlow(nodeDto, flowId); for (SequenceFlow sequenceFlow : flowList) { process.addFlowElement(sequenceFlow); } //子节点 Node children = nodeDto.getChildNode(); if (NodeTypeEnum.getByValue(nodeDto.getType()).getBranch() ) { //条件分支 List<Node> branchs = nodeDto.getConditionNodes(); for (Node branch : branchs) { buildAllNodeInnerSequence(process, branch.getChildNode(), flowId); } if (NodeUtil.isNode(children)) { buildAllNodeInnerSequence(process, children, flowId); } } else { if (NodeUtil.isNode(children)) { buildAllNodeInnerSequence(process, children, flowId); } } } /** * 递归创建节点间连线 * * @param process 流程 * @param nodeDto 节点对象 * @param nextId */ public static void buildAllNodeOuterSequence(Process process, Node nodeDto, String nextId) { if (!NodeUtil.isNode(nodeDto)) { return; } //子节点 Node children = nodeDto.getChildNode(); if (NodeTypeEnum.getByValue(nodeDto.getType()).getBranch() ) { // children = children.getChildren(); //条件分支 List<Node> branchs = nodeDto.getConditionNodes(); int ord = 1; int size = branchs.size(); for (Node branch : branchs) { buildAllNodeOuterSequence(process, branch.getChildNode(), nodeDto.getTailId()); String expression = null; if (nodeDto.getType() == NodeTypeEnum.EXCLUSIVE_GATEWAY.getValue().intValue() ) { if (ord == size) { expression = NodeExpressionStrategyFactory.handleDefaultBranch(branchs, ord - 1); } else if (nodeDto.getType() == NodeTypeEnum.EXCLUSIVE_GATEWAY.getValue().intValue() && ord > 1) { expression = NodeExpressionStrategyFactory.handleDefaultBranch(branchs, ord - 1); } else { expression = NodeExpressionStrategyFactory.handle(branch); } } //添加连线 if (!NodeUtil.isNode(branch.getChildNode())) { //当前分支 没有其他节点了 所有就是网关和网关后面节点直接连线 SequenceFlow sequenceFlow = buildSingleSequenceFlow(nodeDto.getId(), nodeDto.getTailId(), expression, StrUtil.format("{}->{}", nodeDto.getNodeName(), nodeDto.getNodeName()) ); process.addFlowElement(sequenceFlow); } else { SequenceFlow sequenceFlow = buildSingleSequenceFlow(nodeDto.getId(), branch.getChildNode().getHeadId(), expression, StrUtil.format("{}->{}", nodeDto.getNodeName(), branch.getChildNode().getNodeName()) ); process.addFlowElement(sequenceFlow); } ord++; } //分支结尾的合并分支节点-》下一个节点 if (children != null && StrUtil.isNotBlank(children.getHeadId()) && StrUtil.isNotBlank(nodeDto.getTailId())) { SequenceFlow sequenceFlow = buildSingleSequenceFlow(nodeDto.getTailId(), children.getHeadId(), "", StrUtil.format("{}->{}", nodeDto.getNodeName(), children.getNodeName()) ); process.addFlowElement(sequenceFlow); } else if (StrUtil.isAllNotBlank(nodeDto.getTailId(), nextId)) { SequenceFlow sequenceFlow = buildSingleSequenceFlow(nodeDto.getTailId(), nextId, "", StrUtil.format("{}->{}", nodeDto.getNodeName(), nextId) );