代码重构
This commit is contained in:
@@ -0,0 +1,82 @@
|
||||
package com.gear.flowable.common.constant;
|
||||
|
||||
/**
|
||||
* 流程常量信息
|
||||
*
|
||||
* @author Xuan xuan
|
||||
* @date 2021/4/17 22:46
|
||||
*/
|
||||
public class ProcessConstants {
|
||||
|
||||
public static final String SUFFIX = ".bpmn";
|
||||
|
||||
/**
|
||||
* 动态数据
|
||||
*/
|
||||
public static final String DATA_TYPE = "dynamic";
|
||||
|
||||
/**
|
||||
* 单个审批人
|
||||
*/
|
||||
public static final String USER_TYPE_ASSIGNEE = "assignee";
|
||||
|
||||
|
||||
/**
|
||||
* 候选人
|
||||
*/
|
||||
public static final String USER_TYPE_USERS = "candidateUsers";
|
||||
|
||||
|
||||
/**
|
||||
* 审批组
|
||||
*/
|
||||
public static final String USER_TYPE_ROUPS = "candidateGroups";
|
||||
|
||||
/**
|
||||
* 单个审批人
|
||||
*/
|
||||
public static final String PROCESS_APPROVAL = "approval";
|
||||
|
||||
/**
|
||||
* 会签人员
|
||||
*/
|
||||
public static final String PROCESS_MULTI_INSTANCE_USER = "userList";
|
||||
|
||||
/**
|
||||
* nameapace
|
||||
*/
|
||||
public static final String NAMASPASE = "http://flowable.org/bpmn";
|
||||
|
||||
/**
|
||||
* 会签节点
|
||||
*/
|
||||
public static final String PROCESS_MULTI_INSTANCE = "multiInstance";
|
||||
|
||||
/**
|
||||
* 自定义属性 dataType
|
||||
*/
|
||||
public static final String PROCESS_CUSTOM_DATA_TYPE = "dataType";
|
||||
|
||||
/**
|
||||
* 自定义属性 userType
|
||||
*/
|
||||
public static final String PROCESS_CUSTOM_USER_TYPE = "userType";
|
||||
|
||||
/**
|
||||
* 自定义属性 localScope
|
||||
*/
|
||||
public static final String PROCESS_FORM_LOCAL_SCOPE = "localScope";
|
||||
|
||||
/**
|
||||
* 自定义属性 流程状态
|
||||
*/
|
||||
public static final String PROCESS_STATUS_KEY = "processStatus";
|
||||
|
||||
|
||||
/**
|
||||
* 流程跳过
|
||||
*/
|
||||
public static final String FLOWABLE_SKIP_EXPRESSION_ENABLED = "_FLOWABLE_SKIP_EXPRESSION_ENABLED";
|
||||
|
||||
|
||||
}
|
||||
@@ -0,0 +1,23 @@
|
||||
package com.gear.flowable.common.constant;
|
||||
|
||||
/**
|
||||
* @author konbai
|
||||
* @createTime 2022/4/24 13:24
|
||||
*/
|
||||
public class TaskConstants {
|
||||
|
||||
/**
|
||||
* 流程发起人
|
||||
*/
|
||||
public static final String PROCESS_INITIATOR = "initiator";
|
||||
|
||||
/**
|
||||
* 角色候选组前缀
|
||||
*/
|
||||
public static final String ROLE_GROUP_PREFIX = "ROLE";
|
||||
|
||||
/**
|
||||
* 部门候选组前缀
|
||||
*/
|
||||
public static final String DEPT_GROUP_PREFIX = "DEPT";
|
||||
}
|
||||
@@ -0,0 +1,44 @@
|
||||
package com.gear.flowable.common.enums;
|
||||
|
||||
/**
|
||||
* 流程意见类型
|
||||
*
|
||||
* @author Xuan xuan
|
||||
* @date 2021/4/19
|
||||
*/
|
||||
public enum FlowComment {
|
||||
|
||||
/**
|
||||
* 说明
|
||||
*/
|
||||
NORMAL("1", "正常"),
|
||||
REBACK("2", "退回"),
|
||||
REJECT("3", "驳回"),
|
||||
DELEGATE("4", "委派"),
|
||||
TRANSFER("5", "转办"),
|
||||
STOP("6", "终止"),
|
||||
REVOKE("7", "撤回");
|
||||
|
||||
/**
|
||||
* 类型
|
||||
*/
|
||||
private final String type;
|
||||
|
||||
/**
|
||||
* 说明
|
||||
*/
|
||||
private final String remark;
|
||||
|
||||
FlowComment(String type, String remark) {
|
||||
this.type = type;
|
||||
this.remark = remark;
|
||||
}
|
||||
|
||||
public String getType() {
|
||||
return type;
|
||||
}
|
||||
|
||||
public String getRemark() {
|
||||
return remark;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,33 @@
|
||||
package com.gear.flowable.common.enums;
|
||||
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Getter;
|
||||
|
||||
/**
|
||||
* @author KonBAI
|
||||
* @createTime 2022/6/28 9:51
|
||||
*/
|
||||
@Getter
|
||||
@AllArgsConstructor
|
||||
public enum FormType {
|
||||
|
||||
/**
|
||||
* 流程表单
|
||||
*/
|
||||
PROCESS(0),
|
||||
|
||||
/**
|
||||
* 外置表单
|
||||
*/
|
||||
EXTERNAL(1),
|
||||
|
||||
/**
|
||||
* 节点独立表单
|
||||
*/
|
||||
INDEPENDENT(2);
|
||||
|
||||
/**
|
||||
* 表单类型
|
||||
*/
|
||||
private final Integer type;
|
||||
}
|
||||
@@ -0,0 +1,44 @@
|
||||
package com.gear.flowable.common.enums;
|
||||
|
||||
import com.gear.common.utils.StringUtils;
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Getter;
|
||||
|
||||
/**
|
||||
* @author konbai
|
||||
* @since 2023/3/9 00:45
|
||||
*/
|
||||
@Getter
|
||||
@AllArgsConstructor
|
||||
public enum ProcessStatus {
|
||||
|
||||
/**
|
||||
* 进行中（审批中）
|
||||
*/
|
||||
RUNNING("running"),
|
||||
/**
|
||||
* 已终止
|
||||
*/
|
||||
TERMINATED("terminated"),
|
||||
/**
|
||||
* 已完成
|
||||
*/
|
||||
COMPLETED("completed"),
|
||||
/**
|
||||
* 已取消
|
||||
*/
|
||||
CANCELED("canceled");
|
||||
|
||||
private final String status;
|
||||
|
||||
public static ProcessStatus getProcessStatus(String str) {
|
||||
if (StringUtils.isNotBlank(str)) {
|
||||
for (ProcessStatus value : values()) {
|
||||
if (StringUtils.equalsIgnoreCase(str, value.getStatus())) {
|
||||
return value;
|
||||
}
|
||||
}
|
||||
}
|
||||
return null;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,28 @@
|
||||
package com.gear.flowable.config;
|
||||
|
||||
import com.gear.flowable.listener.GlobalEventListener;
|
||||
import lombok.AllArgsConstructor;
|
||||
import org.flowable.common.engine.api.delegate.event.FlowableEngineEventType;
|
||||
import org.flowable.engine.RuntimeService;
|
||||
import org.springframework.context.ApplicationListener;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
import org.springframework.context.event.ContextRefreshedEvent;
|
||||
|
||||
/**
|
||||
* flowable全局监听配置
|
||||
*
|
||||
* @author ssc
|
||||
*/
|
||||
@Configuration
|
||||
@AllArgsConstructor
|
||||
public class GlobalEventListenerConfig implements ApplicationListener<ContextRefreshedEvent> {
|
||||
|
||||
private final GlobalEventListener globalEventListener;
|
||||
private final RuntimeService runtimeService;
|
||||
|
||||
@Override
|
||||
public void onApplicationEvent(ContextRefreshedEvent event) {
|
||||
// 流程正常结束
|
||||
runtimeService.addEventListener(globalEventListener, FlowableEngineEventType.PROCESS_COMPLETED);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,94 @@
|
||||
package com.gear.flowable.config;
|
||||
|
||||
import org.flowable.bpmn.model.AssociationDirection;
|
||||
import org.flowable.image.impl.DefaultProcessDiagramCanvas;
|
||||
|
||||
import java.awt.*;
|
||||
import java.awt.geom.Line2D;
|
||||
import java.awt.geom.RoundRectangle2D;
|
||||
|
||||
/**
|
||||
* @author XuanXuan
|
||||
* @date 2021-04-03
|
||||
*/
|
||||
public class MyDefaultProcessDiagramCanvas extends DefaultProcessDiagramCanvas {
|
||||
//设置高亮线的颜色 这里我设置成绿色
|
||||
protected static Color HIGHLIGHT_SEQUENCEFLOW_COLOR = Color.GREEN;
|
||||
|
||||
public MyDefaultProcessDiagramCanvas(int width, int height, int minX, int minY, String imageType, String activityFontName, String labelFontName, String annotationFontName, ClassLoader customClassLoader) {
|
||||
super(width, height, minX, minY, imageType, activityFontName, labelFontName, annotationFontName, customClassLoader);
|
||||
}
|
||||
|
||||
public MyDefaultProcessDiagramCanvas(int width, int height, int minX, int minY, String imageType) {
|
||||
super(width, height, minX, minY, imageType);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 画线颜色设置
|
||||
*/
|
||||
@Override
|
||||
public void drawConnection(int[] xPoints, int[] yPoints, boolean conditional, boolean isDefault, String connectionType,
|
||||
AssociationDirection associationDirection, boolean highLighted, double scaleFactor) {
|
||||
|
||||
Paint originalPaint = g.getPaint();
|
||||
Stroke originalStroke = g.getStroke();
|
||||
|
||||
g.setPaint(CONNECTION_COLOR);
|
||||
if (connectionType.equals("association")) {
|
||||
g.setStroke(ASSOCIATION_STROKE);
|
||||
} else if (highLighted) {
|
||||
//设置线的颜色
|
||||
g.setPaint(originalPaint);
|
||||
g.setStroke(HIGHLIGHT_FLOW_STROKE);
|
||||
}
|
||||
|
||||
for (int i = 1; i < xPoints.length; i++) {
|
||||
Integer sourceX = xPoints[i - 1];
|
||||
Integer sourceY = yPoints[i - 1];
|
||||
Integer targetX = xPoints[i];
|
||||
Integer targetY = yPoints[i];
|
||||
Line2D.Double line = new Line2D.Double(sourceX, sourceY, targetX, targetY);
|
||||
g.draw(line);
|
||||
}
|
||||
|
||||
if (isDefault) {
|
||||
Line2D.Double line = new Line2D.Double(xPoints[0], yPoints[0], xPoints[1], yPoints[1]);
|
||||
drawDefaultSequenceFlowIndicator(line, scaleFactor);
|
||||
}
|
||||
|
||||
if (conditional) {
|
||||
Line2D.Double line = new Line2D.Double(xPoints[0], yPoints[0], xPoints[1], yPoints[1]);
|
||||
drawConditionalSequenceFlowIndicator(line, scaleFactor);
|
||||
}
|
||||
|
||||
if (associationDirection == AssociationDirection.ONE || associationDirection == AssociationDirection.BOTH) {
|
||||
Line2D.Double line = new Line2D.Double(xPoints[xPoints.length - 2], yPoints[xPoints.length - 2], xPoints[xPoints.length - 1], yPoints[xPoints.length - 1]);
|
||||
drawArrowHead(line, scaleFactor);
|
||||
}
|
||||
if (associationDirection == AssociationDirection.BOTH) {
|
||||
Line2D.Double line = new Line2D.Double(xPoints[1], yPoints[1], xPoints[0], yPoints[0]);
|
||||
drawArrowHead(line, scaleFactor);
|
||||
}
|
||||
g.setPaint(originalPaint);
|
||||
g.setStroke(originalStroke);
|
||||
}
|
||||
|
||||
/**
|
||||
* 高亮节点设置
|
||||
*/
|
||||
@Override
|
||||
public void drawHighLight(int x, int y, int width, int height) {
|
||||
Paint originalPaint = g.getPaint();
|
||||
Stroke originalStroke = g.getStroke();
|
||||
//设置高亮节点的颜色
|
||||
g.setPaint(HIGHLIGHT_COLOR);
|
||||
g.setStroke(THICK_TASK_BORDER_STROKE);
|
||||
|
||||
RoundRectangle2D rect = new RoundRectangle2D.Double(x, y, width, height, 20, 20);
|
||||
g.draw(rect);
|
||||
|
||||
g.setPaint(originalPaint);
|
||||
g.setStroke(originalStroke);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,65 @@
|
||||
package com.gear.flowable.core;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* 表单属性类
|
||||
*
|
||||
* @author KonBAI
|
||||
* @createTime 2022/8/6 18:54
|
||||
*/
|
||||
@Data
|
||||
public class FormConf {
|
||||
|
||||
/**
|
||||
* 标题
|
||||
*/
|
||||
private String title;
|
||||
/**
|
||||
* 表单名
|
||||
*/
|
||||
private String formRef;
|
||||
/**
|
||||
* 表单模型
|
||||
*/
|
||||
private String formModel;
|
||||
/**
|
||||
* 表单尺寸
|
||||
*/
|
||||
private String size;
|
||||
/**
|
||||
* 标签对齐
|
||||
*/
|
||||
private String labelPosition;
|
||||
/**
|
||||
* 标签宽度
|
||||
*/
|
||||
private Integer labelWidth;
|
||||
/**
|
||||
* 校验模型
|
||||
*/
|
||||
private String formRules;
|
||||
/**
|
||||
* 栅格间隔
|
||||
*/
|
||||
private Integer gutter;
|
||||
/**
|
||||
* 禁用表单
|
||||
*/
|
||||
private Boolean disabled = false;
|
||||
/**
|
||||
* 栅格占据的列数
|
||||
*/
|
||||
private Integer span;
|
||||
/**
|
||||
* 表单按钮
|
||||
*/
|
||||
private Boolean formBtns = true;
|
||||
/**
|
||||
* 表单项
|
||||
*/
|
||||
private List<Map<String, Object>> fields;
|
||||
}
|
||||
@@ -0,0 +1,41 @@
|
||||
package com.gear.flowable.core.domain;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* 流程查询实体对象
|
||||
*
|
||||
* @author KonBAI
|
||||
* @createTime 2022/6/11 01:15
|
||||
*/
|
||||
@Data
|
||||
public class ProcessQuery {
|
||||
|
||||
/**
|
||||
* 流程标识
|
||||
*/
|
||||
private String processKey;
|
||||
|
||||
/**
|
||||
* 流程名称
|
||||
*/
|
||||
private String processName;
|
||||
|
||||
/**
|
||||
* 流程分类
|
||||
*/
|
||||
private String category;
|
||||
|
||||
/**
|
||||
* 状态
|
||||
*/
|
||||
private String state;
|
||||
|
||||
/**
|
||||
* 请求参数
|
||||
*/
|
||||
private Map<String, Object> params = new HashMap<>();
|
||||
}
|
||||
@@ -0,0 +1,44 @@
|
||||
package com.gear.flowable.factory;
|
||||
|
||||
import lombok.Getter;
|
||||
import org.flowable.engine.*;
|
||||
import org.springframework.beans.factory.annotation.Qualifier;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
|
||||
/**
|
||||
* flowable 引擎注入封装
|
||||
* @author XuanXuan
|
||||
* @date 2021-04-03
|
||||
*/
|
||||
@Component
|
||||
@Getter
|
||||
public class FlowServiceFactory {
|
||||
|
||||
@Resource
|
||||
protected RepositoryService repositoryService;
|
||||
|
||||
@Resource
|
||||
protected RuntimeService runtimeService;
|
||||
|
||||
@Resource
|
||||
protected IdentityService identityService;
|
||||
|
||||
@Resource
|
||||
protected TaskService taskService;
|
||||
|
||||
@Resource
|
||||
protected FormService formService;
|
||||
|
||||
@Resource
|
||||
protected HistoryService historyService;
|
||||
|
||||
@Resource
|
||||
protected ManagementService managementService;
|
||||
|
||||
@Qualifier("processEngine")
|
||||
@Resource
|
||||
protected ProcessEngine processEngine;
|
||||
|
||||
}
|
||||
@@ -0,0 +1,370 @@
|
||||
package com.gear.flowable.flow;
|
||||
|
||||
import org.flowable.bpmn.model.AssociationDirection;
|
||||
import org.flowable.bpmn.model.GraphicInfo;
|
||||
import org.flowable.image.impl.DefaultProcessDiagramCanvas;
|
||||
import org.flowable.image.util.ReflectUtil;
|
||||
|
||||
import javax.imageio.ImageIO;
|
||||
import java.awt.*;
|
||||
import java.awt.font.FontRenderContext;
|
||||
import java.awt.font.LineBreakMeasurer;
|
||||
import java.awt.font.TextAttribute;
|
||||
import java.awt.font.TextLayout;
|
||||
import java.awt.geom.Ellipse2D;
|
||||
import java.awt.geom.Rectangle2D;
|
||||
import java.awt.geom.RoundRectangle2D;
|
||||
import java.awt.image.BufferedImage;
|
||||
import java.io.IOException;
|
||||
import java.text.AttributedCharacterIterator;
|
||||
import java.text.AttributedString;
|
||||
|
||||
/**
|
||||
* @author XuanXuan
|
||||
* @date 2021/4/4 23:58
|
||||
*/
|
||||
public class CustomProcessDiagramCanvas extends DefaultProcessDiagramCanvas {
|
||||
//定义走过流程连线颜色为绿色
|
||||
protected static Color HIGHLIGHT_SequenceFlow_COLOR = Color.GREEN;
|
||||
//设置未走过流程的连接线颜色
|
||||
protected static Color CONNECTION_COLOR = Color.BLACK;
|
||||
//设置flows连接线字体颜色red
|
||||
protected static Color LABEL_COLOR = new Color(0, 0, 0);
|
||||
//高亮显示task框颜色
|
||||
protected static Color HIGHLIGHT_COLOR = Color.GREEN;
|
||||
protected static Color HIGHLIGHT_COLOR1 = Color.RED;
|
||||
|
||||
public CustomProcessDiagramCanvas(int width, int height, int minX, int minY, String imageType, String activityFontName, String labelFontName, String annotationFontName, ClassLoader customClassLoader) {
|
||||
super(width, height, minX, minY, imageType, activityFontName, labelFontName, annotationFontName, customClassLoader);
|
||||
this.initialize(imageType);
|
||||
}
|
||||
|
||||
/**
|
||||
* 重写绘制连线的方式,设置绘制颜色
|
||||
* @param xPoints
|
||||
* @param yPoints
|
||||
* @param conditional
|
||||
* @param isDefault
|
||||
* @param connectionType
|
||||
* @param associationDirection
|
||||
* @param highLighted
|
||||
* @param scaleFactor
|
||||
*/
|
||||
@Override
|
||||
public void drawConnection(int[] xPoints, int[] yPoints, boolean conditional, boolean isDefault, String connectionType, AssociationDirection associationDirection, boolean highLighted, double scaleFactor) {
|
||||
Paint originalPaint = this.g.getPaint();
|
||||
Stroke originalStroke = this.g.getStroke();
|
||||
this.g.setPaint(CONNECTION_COLOR);
|
||||
if (connectionType.equals("association")) {
|
||||
this.g.setStroke(ASSOCIATION_STROKE);
|
||||
} else if (highLighted) {
|
||||
this.g.setPaint(HIGHLIGHT_SequenceFlow_COLOR);
|
||||
this.g.setStroke(HIGHLIGHT_FLOW_STROKE);
|
||||
}
|
||||
|
||||
for (int i = 1; i < xPoints.length; ++i) {
|
||||
int sourceX = xPoints[i - 1];
|
||||
int sourceY = yPoints[i - 1];
|
||||
int targetX = xPoints[i];
|
||||
int targetY = yPoints[i];
|
||||
java.awt.geom.Line2D.Double line = new java.awt.geom.Line2D.Double((double) sourceX, (double) sourceY, (double) targetX, (double) targetY);
|
||||
this.g.draw(line);
|
||||
}
|
||||
|
||||
java.awt.geom.Line2D.Double line;
|
||||
if (isDefault) {
|
||||
line = new java.awt.geom.Line2D.Double((double) xPoints[0], (double) yPoints[0], (double) xPoints[1], (double) yPoints[1]);
|
||||
this.drawDefaultSequenceFlowIndicator(line, scaleFactor);
|
||||
}
|
||||
|
||||
if (conditional) {
|
||||
line = new java.awt.geom.Line2D.Double((double) xPoints[0], (double) yPoints[0], (double) xPoints[1], (double) yPoints[1]);
|
||||
this.drawConditionalSequenceFlowIndicator(line, scaleFactor);
|
||||
}
|
||||
|
||||
if (associationDirection.equals(AssociationDirection.ONE) || associationDirection.equals(AssociationDirection.BOTH)) {
|
||||
line = new java.awt.geom.Line2D.Double((double) xPoints[xPoints.length - 2], (double) yPoints[xPoints.length - 2], (double) xPoints[xPoints.length - 1], (double) yPoints[xPoints.length - 1]);
|
||||
this.drawArrowHead(line, scaleFactor);
|
||||
}
|
||||
|
||||
if (associationDirection.equals(AssociationDirection.BOTH)) {
|
||||
line = new java.awt.geom.Line2D.Double((double) xPoints[1], (double) yPoints[1], (double) xPoints[0], (double) yPoints[0]);
|
||||
this.drawArrowHead(line, scaleFactor);
|
||||
}
|
||||
|
||||
this.g.setPaint(originalPaint);
|
||||
this.g.setStroke(originalStroke);
|
||||
}
|
||||
|
||||
/**
|
||||
* 设置字体大小图标颜色
|
||||
* @param imageType
|
||||
*/
|
||||
@Override
|
||||
public void initialize(String imageType) {
|
||||
if ("png".equalsIgnoreCase(imageType)) {
|
||||
this.processDiagram = new BufferedImage(this.canvasWidth, this.canvasHeight, 2);
|
||||
} else {
|
||||
this.processDiagram = new BufferedImage(this.canvasWidth, this.canvasHeight, 1);
|
||||
}
|
||||
|
||||
this.g = this.processDiagram.createGraphics();
|
||||
if (!"png".equalsIgnoreCase(imageType)) {
|
||||
this.g.setBackground(new Color(255, 255, 255, 0));
|
||||
this.g.clearRect(0, 0, this.canvasWidth, this.canvasHeight);
|
||||
}
|
||||
|
||||
this.g.setRenderingHint(RenderingHints.KEY_ANTIALIASING, RenderingHints.VALUE_ANTIALIAS_ON);
|
||||
//修改图标颜色，修改图标字体大小
|
||||
this.g.setPaint(Color.black);
|
||||
Font font = new Font(this.activityFontName, 10, 14);
|
||||
this.g.setFont(font);
|
||||
this.fontMetrics = this.g.getFontMetrics();
|
||||
//修改连接线字体大小
|
||||
LABEL_FONT = new Font(this.labelFontName, 10, 15);
|
||||
ANNOTATION_FONT = new Font(this.annotationFontName, 0, 11);
|
||||
|
||||
try {
|
||||
USERTASK_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/userTask.png", this.customClassLoader));
|
||||
SCRIPTTASK_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/scriptTask.png", this.customClassLoader));
|
||||
SERVICETASK_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/serviceTask.png", this.customClassLoader));
|
||||
RECEIVETASK_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/receiveTask.png", this.customClassLoader));
|
||||
SENDTASK_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/sendTask.png", this.customClassLoader));
|
||||
MANUALTASK_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/manualTask.png", this.customClassLoader));
|
||||
BUSINESS_RULE_TASK_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/businessRuleTask.png", this.customClassLoader));
|
||||
SHELL_TASK_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/shellTask.png", this.customClassLoader));
|
||||
DMN_TASK_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/dmnTask.png", this.customClassLoader));
|
||||
CAMEL_TASK_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/camelTask.png", this.customClassLoader));
|
||||
MULE_TASK_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/muleTask.png", this.customClassLoader));
|
||||
HTTP_TASK_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/httpTask.png", this.customClassLoader));
|
||||
TIMER_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/timer.png", this.customClassLoader));
|
||||
COMPENSATE_THROW_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/compensate-throw.png", this.customClassLoader));
|
||||
COMPENSATE_CATCH_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/compensate.png", this.customClassLoader));
|
||||
ERROR_THROW_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/error-throw.png", this.customClassLoader));
|
||||
ERROR_CATCH_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/error.png", this.customClassLoader));
|
||||
MESSAGE_THROW_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/message-throw.png", this.customClassLoader));
|
||||
MESSAGE_CATCH_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/message.png", this.customClassLoader));
|
||||
SIGNAL_THROW_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/signal-throw.png", this.customClassLoader));
|
||||
SIGNAL_CATCH_IMAGE = ImageIO.read(ReflectUtil.getResource("org/flowable/icons/signal.png", this.customClassLoader));
|
||||
} catch (IOException var4) {
|
||||
LOGGER.warn("Could not load image for process diagram creation: {}", var4.getMessage());
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* 设置连接线字体
|
||||
* @param text
|
||||
* @param graphicInfo
|
||||
* @param centered
|
||||
*/
|
||||
@Override
|
||||
public void drawLabel(String text, GraphicInfo graphicInfo, boolean centered) {
|
||||
float interline = 1.0f;
|
||||
|
||||
// text
|
||||
if (text != null && text.length() > 0) {
|
||||
Paint originalPaint = g.getPaint();
|
||||
Font originalFont = g.getFont();
|
||||
|
||||
g.setPaint(LABEL_COLOR);
|
||||
g.setFont(LABEL_FONT);
|
||||
|
||||
int wrapWidth = 100;
|
||||
int textY = (int) graphicInfo.getY();
|
||||
|
||||
// TODO: use drawMultilineText()
|
||||
AttributedString as = new AttributedString(text);
|
||||
as.addAttribute(TextAttribute.FOREGROUND, g.getPaint());
|
||||
as.addAttribute(TextAttribute.FONT, g.getFont());
|
||||
AttributedCharacterIterator aci = as.getIterator();
|
||||
FontRenderContext frc = new FontRenderContext(null, true, false);
|
||||
LineBreakMeasurer lbm = new LineBreakMeasurer(aci, frc);
|
||||
|
||||
while (lbm.getPosition() < text.length()) {
|
||||
TextLayout tl = lbm.nextLayout(wrapWidth);
|
||||
textY += tl.getAscent();
|
||||
|
||||
Rectangle2D bb = tl.getBounds();
|
||||
double tX = graphicInfo.getX();
|
||||
|
||||
if (centered) {
|
||||
tX += (int) (graphicInfo.getWidth() / 2 - bb.getWidth() / 2);
|
||||
}
|
||||
tl.draw(g, (float) tX, textY);
|
||||
textY += tl.getDescent() + tl.getLeading() + (interline - 1.0f) * tl.getAscent();
|
||||
}
|
||||
|
||||
// restore originals
|
||||
g.setFont(originalFont);
|
||||
g.setPaint(originalPaint);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 高亮显示task框完成的
|
||||
* @param x
|
||||
* @param y
|
||||
* @param width
|
||||
* @param height
|
||||
*/
|
||||
@Override
|
||||
public void drawHighLight(int x, int y, int width, int height) {
|
||||
Paint originalPaint = g.getPaint();
|
||||
Stroke originalStroke = g.getStroke();
|
||||
|
||||
g.setPaint(HIGHLIGHT_COLOR);
|
||||
g.setStroke(THICK_TASK_BORDER_STROKE);
|
||||
|
||||
RoundRectangle2D rect = new RoundRectangle2D.Double(x, y, width, height, 20, 20);
|
||||
g.draw(rect);
|
||||
|
||||
g.setPaint(originalPaint);
|
||||
g.setStroke(originalStroke);
|
||||
}
|
||||
|
||||
/**
|
||||
* 自定义task框当前的位置
|
||||
* @param x
|
||||
* @param y
|
||||
* @param width
|
||||
* @param height
|
||||
*/
|
||||
public void drawHighLightNow(int x, int y, int width, int height) {
|
||||
Paint originalPaint = g.getPaint();
|
||||
Stroke originalStroke = g.getStroke();
|
||||
|
||||
g.setPaint(HIGHLIGHT_COLOR1);
|
||||
g.setStroke(THICK_TASK_BORDER_STROKE);
|
||||
|
||||
RoundRectangle2D rect = new RoundRectangle2D.Double(x, y, width, height, 20, 20);
|
||||
g.draw(rect);
|
||||
|
||||
g.setPaint(originalPaint);
|
||||
g.setStroke(originalStroke);
|
||||
}
|
||||
|
||||
/**
|
||||
* 自定义结束节点
|
||||
* @param x
|
||||
* @param y
|
||||
* @param width
|
||||
* @param height
|
||||
*/
|
||||
public void drawHighLightEnd(int x, int y, int width, int height) {
|
||||
Paint originalPaint = g.getPaint();
|
||||
Stroke originalStroke = g.getStroke();
|
||||
|
||||
g.setPaint(HIGHLIGHT_COLOR);
|
||||
g.setStroke(THICK_TASK_BORDER_STROKE);
|
||||
|
||||
RoundRectangle2D rect = new RoundRectangle2D.Double(x, y, width, height, 20, 20);
|
||||
g.draw(rect);
|
||||
|
||||
g.setPaint(originalPaint);
|
||||
g.setStroke(originalStroke);
|
||||
}
|
||||
|
||||
/**
|
||||
* task框自定义文字
|
||||
* @param name
|
||||
* @param graphicInfo
|
||||
* @param thickBorder
|
||||
* @param scaleFactor
|
||||
*/
|
||||
@Override
|
||||
protected void drawTask(String name, GraphicInfo graphicInfo, boolean thickBorder, double scaleFactor) {
|
||||
|
||||
Paint originalPaint = g.getPaint();
|
||||
int x = (int) graphicInfo.getX();
|
||||
int y = (int) graphicInfo.getY();
|
||||
int width = (int) graphicInfo.getWidth();
|
||||
int height = (int) graphicInfo.getHeight();
|
||||
|
||||
// Create a new gradient paint for every task box, gradient depends on x and y and is not relative
|
||||
g.setPaint(TASK_BOX_COLOR);
|
||||
|
||||
int arcR = 6;
|
||||
if (thickBorder) {
|
||||
arcR = 3;
|
||||
}
|
||||
|
||||
// shape
|
||||
RoundRectangle2D rect = new RoundRectangle2D.Double(x, y, width, height, arcR, arcR);
|
||||
g.fill(rect);
|
||||
g.setPaint(TASK_BORDER_COLOR);
|
||||
|
||||
if (thickBorder) {
|
||||
Stroke originalStroke = g.getStroke();
|
||||
g.setStroke(THICK_TASK_BORDER_STROKE);
|
||||
g.draw(rect);
|
||||
g.setStroke(originalStroke);
|
||||
} else {
|
||||
g.draw(rect);
|
||||
}
|
||||
|
||||
g.setPaint(originalPaint);
|
||||
// text
|
||||
if (scaleFactor == 1.0 && name != null && name.length() > 0) {
|
||||
int boxWidth = width - (2 * TEXT_PADDING);
|
||||
int boxHeight = height - 16 - ICON_PADDING - ICON_PADDING - MARKER_WIDTH - 2 - 2;
|
||||
int boxX = x + width / 2 - boxWidth / 2;
|
||||
int boxY = y + height / 2 - boxHeight / 2 + ICON_PADDING + ICON_PADDING - 2 - 2;
|
||||
|
||||
drawMultilineCentredText(name, boxX, boxY, boxWidth, boxHeight);
|
||||
}
|
||||
}
|
||||
|
||||
protected static Color EVENT_COLOR = new Color(255, 255, 255);
|
||||
|
||||
/**
|
||||
* 重写开始事件
|
||||
* @param graphicInfo
|
||||
* @param image
|
||||
* @param scaleFactor
|
||||
*/
|
||||
@Override
|
||||
public void drawStartEvent(GraphicInfo graphicInfo, BufferedImage image, double scaleFactor) {
|
||||
Paint originalPaint = g.getPaint();
|
||||
g.setPaint(EVENT_COLOR);
|
||||
Ellipse2D circle = new Ellipse2D.Double(graphicInfo.getX(), graphicInfo.getY(),
|
||||
graphicInfo.getWidth(), graphicInfo.getHeight());
|
||||
g.fill(circle);
|
||||
g.setPaint(EVENT_BORDER_COLOR);
|
||||
g.draw(circle);
|
||||
g.setPaint(originalPaint);
|
||||
if (image != null) {
|
||||
// calculate coordinates to center image
|
||||
int imageX = (int) Math.round(graphicInfo.getX() + (graphicInfo.getWidth() / 2) - (image.getWidth() / (2 * scaleFactor)));
|
||||
int imageY = (int) Math.round(graphicInfo.getY() + (graphicInfo.getHeight() / 2) - (image.getHeight() / (2 * scaleFactor)));
|
||||
g.drawImage(image, imageX, imageY,
|
||||
(int) (image.getWidth() / scaleFactor), (int) (image.getHeight() / scaleFactor), null);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* 重写结束事件
|
||||
* @param graphicInfo
|
||||
* @param scaleFactor
|
||||
*/
|
||||
@Override
|
||||
public void drawNoneEndEvent(GraphicInfo graphicInfo, double scaleFactor) {
|
||||
Paint originalPaint = g.getPaint();
|
||||
Stroke originalStroke = g.getStroke();
|
||||
g.setPaint(EVENT_COLOR);
|
||||
Ellipse2D circle = new Ellipse2D.Double(graphicInfo.getX(), graphicInfo.getY(),
|
||||
graphicInfo.getWidth(), graphicInfo.getHeight());
|
||||
g.fill(circle);
|
||||
g.setPaint(EVENT_BORDER_COLOR);
|
||||
// g.setPaint(HIGHLIGHT_COLOR);
|
||||
if (scaleFactor == 1.0) {
|
||||
g.setStroke(END_EVENT_STROKE);
|
||||
} else {
|
||||
g.setStroke(new BasicStroke(2.0f));
|
||||
}
|
||||
g.draw(circle);
|
||||
g.setStroke(originalStroke);
|
||||
g.setPaint(originalPaint);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,404 @@
|
||||
package com.gear.flowable.flow;
|
||||
|
||||
|
||||
import org.flowable.bpmn.model.Process;
|
||||
import org.flowable.bpmn.model.*;
|
||||
import org.flowable.image.impl.DefaultProcessDiagramCanvas;
|
||||
import org.flowable.image.impl.DefaultProcessDiagramGenerator;
|
||||
|
||||
import java.util.Iterator;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @author XuanXuan
|
||||
* @date 2021/4/5 0:31
|
||||
*/
|
||||
public class CustomProcessDiagramGenerator extends DefaultProcessDiagramGenerator {
|
||||
@Override
|
||||
protected DefaultProcessDiagramCanvas generateProcessDiagram(BpmnModel bpmnModel, String imageType, List<String> highLightedActivities, List<String> highLightedFlows, String activityFontName, String labelFontName, String annotationFontName, ClassLoader customClassLoader, double scaleFactor, boolean drawSequenceFlowNameWithNoLabelDI) {
|
||||
this.prepareBpmnModel(bpmnModel);
|
||||
DefaultProcessDiagramCanvas processDiagramCanvas = initProcessDiagramCanvas(bpmnModel, imageType, activityFontName, labelFontName, annotationFontName, customClassLoader);
|
||||
Iterator var13 = bpmnModel.getPools().iterator();
|
||||
|
||||
while (var13.hasNext()) {
|
||||
Pool process = (Pool) var13.next();
|
||||
GraphicInfo subProcesses = bpmnModel.getGraphicInfo(process.getId());
|
||||
processDiagramCanvas.drawPoolOrLane(process.getName(), subProcesses, scaleFactor);
|
||||
}
|
||||
|
||||
var13 = bpmnModel.getProcesses().iterator();
|
||||
|
||||
Process process1;
|
||||
Iterator subProcesses1;
|
||||
while (var13.hasNext()) {
|
||||
process1 = (Process) var13.next();
|
||||
subProcesses1 = process1.getLanes().iterator();
|
||||
|
||||
while (subProcesses1.hasNext()) {
|
||||
Lane artifact = (Lane) subProcesses1.next();
|
||||
GraphicInfo subProcess = bpmnModel.getGraphicInfo(artifact.getId());
|
||||
processDiagramCanvas.drawPoolOrLane(artifact.getName(), subProcess, scaleFactor);
|
||||
}
|
||||
}
|
||||
|
||||
var13 = bpmnModel.getProcesses().iterator();
|
||||
|
||||
while (var13.hasNext()) {
|
||||
process1 = (Process) var13.next();
|
||||
subProcesses1 = process1.findFlowElementsOfType(FlowNode.class).iterator();
|
||||
|
||||
while (subProcesses1.hasNext()) {
|
||||
FlowNode artifact1 = (FlowNode) subProcesses1.next();
|
||||
if (!this.isPartOfCollapsedSubProcess(artifact1, bpmnModel)) {
|
||||
this.drawActivity(processDiagramCanvas, bpmnModel, artifact1, highLightedActivities, highLightedFlows, scaleFactor, Boolean.valueOf(drawSequenceFlowNameWithNoLabelDI));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
var13 = bpmnModel.getProcesses().iterator();
|
||||
|
||||
label75:
|
||||
while (true) {
|
||||
List subProcesses2;
|
||||
do {
|
||||
if (!var13.hasNext()) {
|
||||
return processDiagramCanvas;
|
||||
}
|
||||
|
||||
process1 = (Process) var13.next();
|
||||
subProcesses1 = process1.getArtifacts().iterator();
|
||||
|
||||
while (subProcesses1.hasNext()) {
|
||||
Artifact artifact2 = (Artifact) subProcesses1.next();
|
||||
this.drawArtifact(processDiagramCanvas, bpmnModel, artifact2);
|
||||
}
|
||||
|
||||
subProcesses2 = process1.findFlowElementsOfType(SubProcess.class, true);
|
||||
} while (subProcesses2 == null);
|
||||
|
||||
Iterator artifact3 = subProcesses2.iterator();
|
||||
|
||||
while (true) {
|
||||
GraphicInfo graphicInfo;
|
||||
SubProcess subProcess1;
|
||||
do {
|
||||
do {
|
||||
if (!artifact3.hasNext()) {
|
||||
continue label75;
|
||||
}
|
||||
|
||||
subProcess1 = (SubProcess) artifact3.next();
|
||||
graphicInfo = bpmnModel.getGraphicInfo(subProcess1.getId());
|
||||
} while (graphicInfo != null && graphicInfo.getExpanded() != null && !graphicInfo.getExpanded().booleanValue());
|
||||
} while (this.isPartOfCollapsedSubProcess(subProcess1, bpmnModel));
|
||||
|
||||
Iterator var19 = subProcess1.getArtifacts().iterator();
|
||||
|
||||
while (var19.hasNext()) {
|
||||
Artifact subProcessArtifact = (Artifact) var19.next();
|
||||
this.drawArtifact(processDiagramCanvas, bpmnModel, subProcessArtifact);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
protected static DefaultProcessDiagramCanvas initProcessDiagramCanvas(BpmnModel bpmnModel, String imageType, String activityFontName, String labelFontName, String annotationFontName, ClassLoader customClassLoader) {
|
||||
double minX = 1.7976931348623157E308D;
|
||||
double maxX = 0.0D;
|
||||
double minY = 1.7976931348623157E308D;
|
||||
double maxY = 0.0D;
|
||||
|
||||
GraphicInfo nrOfLanes;
|
||||
for (Iterator flowNodes = bpmnModel.getPools().iterator(); flowNodes.hasNext(); maxY = nrOfLanes.getY() + nrOfLanes.getHeight()) {
|
||||
Pool artifacts = (Pool) flowNodes.next();
|
||||
nrOfLanes = bpmnModel.getGraphicInfo(artifacts.getId());
|
||||
minX = nrOfLanes.getX();
|
||||
maxX = nrOfLanes.getX() + nrOfLanes.getWidth();
|
||||
minY = nrOfLanes.getY();
|
||||
}
|
||||
|
||||
List var23 = gatherAllFlowNodes(bpmnModel);
|
||||
Iterator var24 = var23.iterator();
|
||||
|
||||
label155:
|
||||
while (var24.hasNext()) {
|
||||
FlowNode var26 = (FlowNode) var24.next();
|
||||
GraphicInfo artifact = bpmnModel.getGraphicInfo(var26.getId());
|
||||
if (artifact.getX() + artifact.getWidth() > maxX) {
|
||||
maxX = artifact.getX() + artifact.getWidth();
|
||||
}
|
||||
|
||||
if (artifact.getX() < minX) {
|
||||
minX = artifact.getX();
|
||||
}
|
||||
|
||||
if (artifact.getY() + artifact.getHeight() > maxY) {
|
||||
maxY = artifact.getY() + artifact.getHeight();
|
||||
}
|
||||
|
||||
if (artifact.getY() < minY) {
|
||||
minY = artifact.getY();
|
||||
}
|
||||
|
||||
Iterator process = var26.getOutgoingFlows().iterator();
|
||||
|
||||
while (true) {
|
||||
List l;
|
||||
do {
|
||||
if (!process.hasNext()) {
|
||||
continue label155;
|
||||
}
|
||||
|
||||
SequenceFlow graphicInfoList = (SequenceFlow) process.next();
|
||||
l = bpmnModel.getFlowLocationGraphicInfo(graphicInfoList.getId());
|
||||
} while (l == null);
|
||||
|
||||
Iterator graphicInfo = l.iterator();
|
||||
|
||||
while (graphicInfo.hasNext()) {
|
||||
GraphicInfo graphicInfo1 = (GraphicInfo) graphicInfo.next();
|
||||
if (graphicInfo1.getX() > maxX) {
|
||||
maxX = graphicInfo1.getX();
|
||||
}
|
||||
|
||||
if (graphicInfo1.getX() < minX) {
|
||||
minX = graphicInfo1.getX();
|
||||
}
|
||||
|
||||
if (graphicInfo1.getY() > maxY) {
|
||||
maxY = graphicInfo1.getY();
|
||||
}
|
||||
|
||||
if (graphicInfo1.getY() < minY) {
|
||||
minY = graphicInfo1.getY();
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
List var25 = gatherAllArtifacts(bpmnModel);
|
||||
Iterator var27 = var25.iterator();
|
||||
|
||||
GraphicInfo var37;
|
||||
while (var27.hasNext()) {
|
||||
Artifact var29 = (Artifact) var27.next();
|
||||
GraphicInfo var31 = bpmnModel.getGraphicInfo(var29.getId());
|
||||
if (var31 != null) {
|
||||
if (var31.getX() + var31.getWidth() > maxX) {
|
||||
maxX = var31.getX() + var31.getWidth();
|
||||
}
|
||||
|
||||
if (var31.getX() < minX) {
|
||||
minX = var31.getX();
|
||||
}
|
||||
|
||||
if (var31.getY() + var31.getHeight() > maxY) {
|
||||
maxY = var31.getY() + var31.getHeight();
|
||||
}
|
||||
|
||||
if (var31.getY() < minY) {
|
||||
minY = var31.getY();
|
||||
}
|
||||
}
|
||||
|
||||
List var33 = bpmnModel.getFlowLocationGraphicInfo(var29.getId());
|
||||
if (var33 != null) {
|
||||
Iterator var35 = var33.iterator();
|
||||
|
||||
while (var35.hasNext()) {
|
||||
var37 = (GraphicInfo) var35.next();
|
||||
if (var37.getX() > maxX) {
|
||||
maxX = var37.getX();
|
||||
}
|
||||
|
||||
if (var37.getX() < minX) {
|
||||
minX = var37.getX();
|
||||
}
|
||||
|
||||
if (var37.getY() > maxY) {
|
||||
maxY = var37.getY();
|
||||
}
|
||||
|
||||
if (var37.getY() < minY) {
|
||||
minY = var37.getY();
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
int var28 = 0;
|
||||
Iterator var30 = bpmnModel.getProcesses().iterator();
|
||||
|
||||
while (var30.hasNext()) {
|
||||
Process var32 = (Process) var30.next();
|
||||
Iterator var34 = var32.getLanes().iterator();
|
||||
|
||||
while (var34.hasNext()) {
|
||||
Lane var36 = (Lane) var34.next();
|
||||
++var28;
|
||||
var37 = bpmnModel.getGraphicInfo(var36.getId());
|
||||
if (var37.getX() + var37.getWidth() > maxX) {
|
||||
maxX = var37.getX() + var37.getWidth();
|
||||
}
|
||||
|
||||
if (var37.getX() < minX) {
|
||||
minX = var37.getX();
|
||||
}
|
||||
|
||||
if (var37.getY() + var37.getHeight() > maxY) {
|
||||
maxY = var37.getY() + var37.getHeight();
|
||||
}
|
||||
|
||||
if (var37.getY() < minY) {
|
||||
minY = var37.getY();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if (var23.isEmpty() && bpmnModel.getPools().isEmpty() && var28 == 0) {
|
||||
minX = 0.0D;
|
||||
minY = 0.0D;
|
||||
}
|
||||
|
||||
return new CustomProcessDiagramCanvas((int) maxX + 10, (int) maxY + 10, (int) minX, (int) minY, imageType, activityFontName, labelFontName, annotationFontName, customClassLoader);
|
||||
}
|
||||
|
||||
|
||||
private static void drawHighLight(DefaultProcessDiagramCanvas processDiagramCanvas, GraphicInfo graphicInfo) {
|
||||
processDiagramCanvas.drawHighLight((int) graphicInfo.getX(), (int) graphicInfo.getY(), (int) graphicInfo.getWidth(), (int) graphicInfo.getHeight());
|
||||
|
||||
}
|
||||
|
||||
private static void drawHighLightNow(CustomProcessDiagramCanvas processDiagramCanvas, GraphicInfo graphicInfo) {
|
||||
processDiagramCanvas.drawHighLightNow((int) graphicInfo.getX(), (int) graphicInfo.getY(), (int) graphicInfo.getWidth(), (int) graphicInfo.getHeight());
|
||||
|
||||
}
|
||||
|
||||
private static void drawHighLightEnd(CustomProcessDiagramCanvas processDiagramCanvas, GraphicInfo graphicInfo) {
|
||||
processDiagramCanvas.drawHighLightEnd((int) graphicInfo.getX(), (int) graphicInfo.getY(), (int) graphicInfo.getWidth(), (int) graphicInfo.getHeight());
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void drawActivity(DefaultProcessDiagramCanvas processDiagramCanvas, BpmnModel bpmnModel,
|
||||
FlowNode flowNode, List<String> highLightedActivities, List<String> highLightedFlows, double scaleFactor, Boolean drawSequenceFlowNameWithNoLabelDI) {
|
||||
|
||||
ActivityDrawInstruction drawInstruction = activityDrawInstructions.get(flowNode.getClass());
|
||||
if (drawInstruction != null) {
|
||||
|
||||
drawInstruction.draw(processDiagramCanvas, bpmnModel, flowNode);
|
||||
|
||||
// Gather info on the multi instance marker
|
||||
boolean multiInstanceSequential = false;
|
||||
boolean multiInstanceParallel = false;
|
||||
boolean collapsed = false;
|
||||
if (flowNode instanceof Activity) {
|
||||
Activity activity = (Activity) flowNode;
|
||||
MultiInstanceLoopCharacteristics multiInstanceLoopCharacteristics = activity.getLoopCharacteristics();
|
||||
if (multiInstanceLoopCharacteristics != null) {
|
||||
multiInstanceSequential = multiInstanceLoopCharacteristics.isSequential();
|
||||
multiInstanceParallel = !multiInstanceSequential;
|
||||
}
|
||||
}
|
||||
|
||||
// Gather info on the collapsed marker
|
||||
GraphicInfo graphicInfo = bpmnModel.getGraphicInfo(flowNode.getId());
|
||||
if (flowNode instanceof SubProcess) {
|
||||
collapsed = graphicInfo.getExpanded() != null && !graphicInfo.getExpanded();
|
||||
} else if (flowNode instanceof CallActivity) {
|
||||
collapsed = true;
|
||||
}
|
||||
|
||||
if (scaleFactor == 1.0) {
|
||||
// Actually draw the markers
|
||||
processDiagramCanvas.drawActivityMarkers((int) graphicInfo.getX(), (int) graphicInfo.getY(), (int) graphicInfo.getWidth(), (int) graphicInfo.getHeight(),
|
||||
multiInstanceSequential, multiInstanceParallel, collapsed);
|
||||
}
|
||||
|
||||
// Draw highlighted activities
|
||||
if (highLightedActivities.contains(flowNode.getId())) {
|
||||
|
||||
if (highLightedActivities.get(highLightedActivities.size() - 1).equals(flowNode.getId())
|
||||
&& !"endenv".equals(flowNode.getId())) {
|
||||
if ((flowNode.getId().contains("Event_"))) {
|
||||
drawHighLightEnd((CustomProcessDiagramCanvas) processDiagramCanvas, bpmnModel.getGraphicInfo(flowNode.getId()));
|
||||
} else {
|
||||
drawHighLightNow((CustomProcessDiagramCanvas) processDiagramCanvas, bpmnModel.getGraphicInfo(flowNode.getId()));
|
||||
}
|
||||
} else {
|
||||
drawHighLight(processDiagramCanvas, bpmnModel.getGraphicInfo(flowNode.getId()));
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
// Outgoing transitions of activity
|
||||
for (SequenceFlow sequenceFlow : flowNode.getOutgoingFlows()) {
|
||||
boolean highLighted = (highLightedFlows.contains(sequenceFlow.getId()));
|
||||
String defaultFlow = null;
|
||||
if (flowNode instanceof Activity) {
|
||||
defaultFlow = ((Activity) flowNode).getDefaultFlow();
|
||||
} else if (flowNode instanceof Gateway) {
|
||||
defaultFlow = ((Gateway) flowNode).getDefaultFlow();
|
||||
}
|
||||
|
||||
boolean isDefault = false;
|
||||
if (defaultFlow != null && defaultFlow.equalsIgnoreCase(sequenceFlow.getId())) {
|
||||
isDefault = true;
|
||||
}
|
||||
boolean drawConditionalIndicator = sequenceFlow.getConditionExpression() != null && !(flowNode instanceof Gateway);
|
||||
|
||||
String sourceRef = sequenceFlow.getSourceRef();
|
||||
String targetRef = sequenceFlow.getTargetRef();
|
||||
FlowElement sourceElement = bpmnModel.getFlowElement(sourceRef);
|
||||
FlowElement targetElement = bpmnModel.getFlowElement(targetRef);
|
||||
List<GraphicInfo> graphicInfoList = bpmnModel.getFlowLocationGraphicInfo(sequenceFlow.getId());
|
||||
if (graphicInfoList != null && graphicInfoList.size() > 0) {
|
||||
graphicInfoList = connectionPerfectionizer(processDiagramCanvas, bpmnModel, sourceElement, targetElement, graphicInfoList);
|
||||
int xPoints[] = new int[graphicInfoList.size()];
|
||||
int yPoints[] = new int[graphicInfoList.size()];
|
||||
|
||||
for (int i = 1; i < graphicInfoList.size(); i++) {
|
||||
GraphicInfo graphicInfo = graphicInfoList.get(i);
|
||||
GraphicInfo previousGraphicInfo = graphicInfoList.get(i - 1);
|
||||
|
||||
if (i == 1) {
|
||||
xPoints[0] = (int) previousGraphicInfo.getX();
|
||||
yPoints[0] = (int) previousGraphicInfo.getY();
|
||||
}
|
||||
xPoints[i] = (int) graphicInfo.getX();
|
||||
yPoints[i] = (int) graphicInfo.getY();
|
||||
|
||||
}
|
||||
|
||||
processDiagramCanvas.drawSequenceflow(xPoints, yPoints, drawConditionalIndicator, isDefault, highLighted, scaleFactor);
|
||||
|
||||
|
||||
// Draw sequenceflow label
|
||||
GraphicInfo labelGraphicInfo = bpmnModel.getLabelGraphicInfo(sequenceFlow.getId());
|
||||
if (labelGraphicInfo != null) {
|
||||
processDiagramCanvas.drawLabel(sequenceFlow.getName(), labelGraphicInfo, false);
|
||||
} else {
|
||||
if (drawSequenceFlowNameWithNoLabelDI) {
|
||||
GraphicInfo lineCenter = getLineCenter(graphicInfoList);
|
||||
processDiagramCanvas.drawLabel(sequenceFlow.getName(), lineCenter, false);
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Nested elements
|
||||
if (flowNode instanceof FlowElementsContainer) {
|
||||
for (FlowElement nestedFlowElement : ((FlowElementsContainer) flowNode).getFlowElements()) {
|
||||
if (nestedFlowElement instanceof FlowNode && !isPartOfCollapsedSubProcess(nestedFlowElement, bpmnModel)) {
|
||||
drawActivity(processDiagramCanvas, bpmnModel, (FlowNode) nestedFlowElement,
|
||||
highLightedActivities, highLightedFlows, scaleFactor, drawSequenceFlowNameWithNoLabelDI);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -0,0 +1,221 @@
|
||||
package com.gear.flowable.flow;
|
||||
|
||||
import com.googlecode.aviator.AviatorEvaluator;
|
||||
import com.googlecode.aviator.Expression;
|
||||
import org.flowable.bpmn.model.Process;
|
||||
import org.flowable.bpmn.model.*;
|
||||
import org.flowable.engine.RepositoryService;
|
||||
import org.flowable.engine.repository.ProcessDefinition;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.Collection;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* @author Xuan xuan
|
||||
* @date 2021/4/19 20:51
|
||||
*/
|
||||
public class FindNextNodeUtil {
|
||||
|
||||
/**
|
||||
* 获取下一步骤的用户任务
|
||||
*
|
||||
* @param repositoryService
|
||||
* @param map
|
||||
* @return
|
||||
*/
|
||||
public static List<UserTask> getNextUserTasks(RepositoryService repositoryService, org.flowable.task.api.Task task, Map<String, Object> map) {
|
||||
List<UserTask> data = new ArrayList<>();
|
||||
ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionId(task.getProcessDefinitionId()).singleResult();
|
||||
BpmnModel bpmnModel = repositoryService.getBpmnModel(processDefinition.getId());
|
||||
Process mainProcess = bpmnModel.getMainProcess();
|
||||
Collection<FlowElement> flowElements = mainProcess.getFlowElements();
|
||||
String key = task.getTaskDefinitionKey();
|
||||
FlowElement flowElement = bpmnModel.getFlowElement(key);
|
||||
next(flowElements, flowElement, map, data);
|
||||
return data;
|
||||
}
|
||||
|
||||
public static void next(Collection<FlowElement> flowElements, FlowElement flowElement, Map<String, Object> map, List<UserTask> nextUser) {
|
||||
//如果是结束节点
|
||||
if (flowElement instanceof EndEvent) {
|
||||
//如果是子任务的结束节点
|
||||
if (getSubProcess(flowElements, flowElement) != null) {
|
||||
flowElement = getSubProcess(flowElements, flowElement);
|
||||
}
|
||||
}
|
||||
//获取Task的出线信息--可以拥有多个
|
||||
List<SequenceFlow> outGoingFlows = null;
|
||||
if (flowElement instanceof Task) {
|
||||
outGoingFlows = ((Task) flowElement).getOutgoingFlows();
|
||||
} else if (flowElement instanceof Gateway) {
|
||||
outGoingFlows = ((Gateway) flowElement).getOutgoingFlows();
|
||||
} else if (flowElement instanceof StartEvent) {
|
||||
outGoingFlows = ((StartEvent) flowElement).getOutgoingFlows();
|
||||
} else if (flowElement instanceof SubProcess) {
|
||||
outGoingFlows = ((SubProcess) flowElement).getOutgoingFlows();
|
||||
} else if (flowElement instanceof CallActivity) {
|
||||
outGoingFlows = ((CallActivity) flowElement).getOutgoingFlows();
|
||||
}
|
||||
if (outGoingFlows != null && outGoingFlows.size() > 0) {
|
||||
//遍历所有的出线--找到可以正确执行的那一条
|
||||
for (SequenceFlow sequenceFlow : outGoingFlows) {
|
||||
//1.有表达式，且为true
|
||||
//2.无表达式
|
||||
String expression = sequenceFlow.getConditionExpression();
|
||||
if (expression == null || expressionResult(map, expression.substring(expression.lastIndexOf("{") + 1, expression.lastIndexOf("}")))) {
|
||||
//出线的下一节点
|
||||
String nextFlowElementID = sequenceFlow.getTargetRef();
|
||||
if (checkSubProcess(nextFlowElementID, flowElements, nextUser)) {
|
||||
continue;
|
||||
}
|
||||
|
||||
//查询下一节点的信息
|
||||
FlowElement nextFlowElement = getFlowElementById(nextFlowElementID, flowElements);
|
||||
//调用流程
|
||||
if (nextFlowElement instanceof CallActivity) {
|
||||
CallActivity ca = (CallActivity) nextFlowElement;
|
||||
if (ca.getLoopCharacteristics() != null) {
|
||||
UserTask userTask = new UserTask();
|
||||
userTask.setId(ca.getId());
|
||||
|
||||
userTask.setId(ca.getId());
|
||||
userTask.setLoopCharacteristics(ca.getLoopCharacteristics());
|
||||
userTask.setName(ca.getName());
|
||||
nextUser.add(userTask);
|
||||
}
|
||||
next(flowElements, nextFlowElement, map, nextUser);
|
||||
}
|
||||
//用户任务
|
||||
if (nextFlowElement instanceof UserTask) {
|
||||
nextUser.add((UserTask) nextFlowElement);
|
||||
}
|
||||
//排他网关
|
||||
else if (nextFlowElement instanceof ExclusiveGateway) {
|
||||
next(flowElements, nextFlowElement, map, nextUser);
|
||||
}
|
||||
//并行网关
|
||||
else if (nextFlowElement instanceof ParallelGateway) {
|
||||
next(flowElements, nextFlowElement, map, nextUser);
|
||||
}
|
||||
//接收任务
|
||||
else if (nextFlowElement instanceof ReceiveTask) {
|
||||
next(flowElements, nextFlowElement, map, nextUser);
|
||||
}
|
||||
//服务任务
|
||||
else if (nextFlowElement instanceof ServiceTask) {
|
||||
next(flowElements, nextFlowElement, map, nextUser);
|
||||
}
|
||||
//子任务的起点
|
||||
else if (nextFlowElement instanceof StartEvent) {
|
||||
next(flowElements, nextFlowElement, map, nextUser);
|
||||
}
|
||||
//结束节点
|
||||
else if (nextFlowElement instanceof EndEvent) {
|
||||
next(flowElements, nextFlowElement, map, nextUser);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 判断是否是多实例子流程并且需要设置集合类型变量
|
||||
*/
|
||||
public static boolean checkSubProcess(String Id, Collection<FlowElement> flowElements, List<UserTask> nextUser) {
|
||||
for (FlowElement flowElement1 : flowElements) {
|
||||
if (flowElement1 instanceof SubProcess && flowElement1.getId().equals(Id)) {
|
||||
|
||||
SubProcess sp = (SubProcess) flowElement1;
|
||||
if (sp.getLoopCharacteristics() != null) {
|
||||
String inputDataItem = sp.getLoopCharacteristics().getInputDataItem();
|
||||
UserTask userTask = new UserTask();
|
||||
userTask.setId(sp.getId());
|
||||
userTask.setLoopCharacteristics(sp.getLoopCharacteristics());
|
||||
userTask.setName(sp.getName());
|
||||
nextUser.add(userTask);
|
||||
return true;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return false;
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* 查询一个节点的是否子任务中的节点，如果是，返回子任务
|
||||
*
|
||||
* @param flowElements 全流程的节点集合
|
||||
* @param flowElement 当前节点
|
||||
* @return
|
||||
*/
|
||||
public static FlowElement getSubProcess(Collection<FlowElement> flowElements, FlowElement flowElement) {
|
||||
for (FlowElement flowElement1 : flowElements) {
|
||||
if (flowElement1 instanceof SubProcess) {
|
||||
for (FlowElement flowElement2 : ((SubProcess) flowElement1).getFlowElements()) {
|
||||
if (flowElement.equals(flowElement2)) {
|
||||
return flowElement1;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 根据ID查询流程节点对象, 如果是子任务，则返回子任务的开始节点
|
||||
*
|
||||
* @param Id 节点ID
|
||||
* @param flowElements 流程节点集合
|
||||
* @return
|
||||
*/
|
||||
public static FlowElement getFlowElementById(String Id, Collection<FlowElement> flowElements) {
|
||||
for (FlowElement flowElement : flowElements) {
|
||||
if (flowElement.getId().equals(Id)) {
|
||||
//如果是子任务，则查询出子任务的开始节点
|
||||
if (flowElement instanceof SubProcess) {
|
||||
return getStartFlowElement(((SubProcess) flowElement).getFlowElements());
|
||||
}
|
||||
return flowElement;
|
||||
}
|
||||
if (flowElement instanceof SubProcess) {
|
||||
FlowElement flowElement1 = getFlowElementById(Id, ((SubProcess) flowElement).getFlowElements());
|
||||
if (flowElement1 != null) {
|
||||
return flowElement1;
|
||||
}
|
||||
}
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
/**
|
||||
* 返回流程的开始节点
|
||||
*
|
||||
* @param flowElements 节点集合
|
||||
* @description:
|
||||
*/
|
||||
public static FlowElement getStartFlowElement(Collection<FlowElement> flowElements) {
|
||||
for (FlowElement flowElement : flowElements) {
|
||||
if (flowElement instanceof StartEvent) {
|
||||
return flowElement;
|
||||
}
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
/**
|
||||
* 校验el表达式
|
||||
*
|
||||
* @param map
|
||||
* @param expression
|
||||
* @return
|
||||
*/
|
||||
public static boolean expressionResult(Map<String, Object> map, String expression) {
|
||||
Expression exp = AviatorEvaluator.compile(expression);
|
||||
final Object execute = exp.execute(map);
|
||||
return Boolean.parseBoolean(String.valueOf(execute));
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,23 @@
|
||||
package com.gear.flowable.flow;
|
||||
|
||||
import org.flowable.spring.SpringProcessEngineConfiguration;
|
||||
import org.flowable.spring.boot.EngineConfigurationConfigurer;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
|
||||
|
||||
/**
|
||||
* @author XuanXuan
|
||||
* @date 2021/4/5 01:32
|
||||
*/
|
||||
@Configuration
|
||||
public class FlowableConfig implements EngineConfigurationConfigurer<SpringProcessEngineConfiguration> {
|
||||
|
||||
@Override
|
||||
public void configure(SpringProcessEngineConfiguration engineConfiguration) {
|
||||
engineConfiguration.setActivityFontName("宋体");
|
||||
engineConfiguration.setLabelFontName("宋体");
|
||||
engineConfiguration.setAnnotationFontName("宋体");
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
@@ -0,0 +1,704 @@
|
||||
package com.gear.flowable.flow;
|
||||
|
||||
import cn.hutool.core.util.ObjectUtil;
|
||||
import com.gear.common.exception.ServiceException;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.flowable.bpmn.model.*;
|
||||
import org.flowable.engine.impl.bpmn.behavior.ParallelMultiInstanceBehavior;
|
||||
import org.flowable.engine.impl.bpmn.behavior.SequentialMultiInstanceBehavior;
|
||||
import org.flowable.task.api.history.HistoricTaskInstance;
|
||||
|
||||
import java.util.*;
|
||||
|
||||
/**
|
||||
* @author XuanXuan
|
||||
* @date 2021-04-03 23:57
|
||||
*/
|
||||
@Slf4j
|
||||
public class FlowableUtils {
|
||||
|
||||
/**
|
||||
* 根据节点，获取入口连线
|
||||
* @param source
|
||||
* @return
|
||||
*/
|
||||
public static List<SequenceFlow> getElementIncomingFlows(FlowElement source) {
|
||||
List<SequenceFlow> sequenceFlows = null;
|
||||
if (source instanceof FlowNode) {
|
||||
sequenceFlows = ((FlowNode) 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 FlowNode) {
|
||||
sequenceFlows = ((FlowNode) 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;
|
||||
}
|
||||
}
|
||||
// 继续迭代
|
||||
userTaskList = iteratorFindParentUserTasks(sequenceFlow.getSourceFlowElement(), hasSequenceFlow, userTaskList);
|
||||
}
|
||||
}
|
||||
return userTaskList;
|
||||
}
|
||||
|
||||
/**
|
||||
* 根据正在运行的任务节点，迭代获取子级任务节点列表，向后找
|
||||
* @param source 起始节点
|
||||
* @param runTaskKeyList 正在运行的任务 Key，用于校验任务节点是否是正在运行的节点
|
||||
* @param hasSequenceFlow 已经经过的连线的 ID，用于判断线路是否重复
|
||||
* @param userTaskList 需要撤回的用户任务列表
|
||||
* @return
|
||||
*/
|
||||
public static List<UserTask> iteratorFindChildUserTasks(FlowElement source, List<String> runTaskKeyList, Set<String> hasSequenceFlow, List<UserTask> userTaskList) {
|
||||
hasSequenceFlow = hasSequenceFlow == null ? new HashSet<>() : hasSequenceFlow;
|
||||
userTaskList = userTaskList == null ? new ArrayList<>() : userTaskList;
|
||||
|
||||
// 如果该节点为开始节点，且存在上级子节点，则顺着上级子节点继续迭代
|
||||
if (source instanceof StartEvent && source.getSubProcess() != null) {
|
||||
userTaskList = iteratorFindChildUserTasks(source.getSubProcess(), runTaskKeyList, hasSequenceFlow, 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 && runTaskKeyList.contains((sequenceFlow.getTargetFlowElement()).getId())) {
|
||||
userTaskList.add((UserTask) sequenceFlow.getTargetFlowElement());
|
||||
continue;
|
||||
}
|
||||
// 如果节点为子流程节点情况，则从节点中的第一个节点开始获取
|
||||
if (sequenceFlow.getTargetFlowElement() instanceof SubProcess) {
|
||||
List<UserTask> childUserTaskList = iteratorFindChildUserTasks((FlowElement) (((SubProcess) sequenceFlow.getTargetFlowElement()).getFlowElements().toArray()[0]), runTaskKeyList, hasSequenceFlow, null);
|
||||
// 如果找到节点，则说明该线路找到节点，不继续向下找，反之继续
|
||||
if (childUserTaskList != null && childUserTaskList.size() > 0) {
|
||||
userTaskList.addAll(childUserTaskList);
|
||||
continue;
|
||||
}
|
||||
}
|
||||
// 继续迭代
|
||||
userTaskList = iteratorFindChildUserTasks(sequenceFlow.getTargetFlowElement(), runTaskKeyList, hasSequenceFlow, userTaskList);
|
||||
}
|
||||
}
|
||||
return userTaskList;
|
||||
}
|
||||
|
||||
/**
|
||||
* 迭代获取子流程用户任务节点
|
||||
* @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;
|
||||
}
|
||||
}
|
||||
// 继续迭代
|
||||
userTaskList = findChildProcessUserTasks(sequenceFlow.getTargetFlowElement(), 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;
|
||||
}
|
||||
}
|
||||
// 继续迭代
|
||||
dirtyRoads = iteratorFindDirtyRoads(sequenceFlow.getSourceFlowElement(), passRoads, 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);
|
||||
}
|
||||
// 继续迭代
|
||||
dirtyRoads = findChildProcessAllDirtyRoad(sequenceFlow.getTargetFlowElement(), 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);
|
||||
}
|
||||
// 继续迭代
|
||||
inChildProcess = dirtyTargetInChildProcess(sequenceFlow.getTargetFlowElement(), 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;
|
||||
}
|
||||
// 否则就继续迭代
|
||||
isSequential = iteratorCheckSequentialReferTarget(sequenceFlow.getSourceFlowElement(), targetKsy, 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());
|
||||
}
|
||||
// 继续迭代
|
||||
roads = findRoad(sequenceFlow.getSourceFlowElement(), passRoads, hasSequenceFlow, roads);
|
||||
}
|
||||
} else {
|
||||
// 添加路线
|
||||
roads.add(passRoads);
|
||||
}
|
||||
return roads;
|
||||
}
|
||||
|
||||
/**
|
||||
* 历史节点数据清洗，清洗掉又回滚导致的脏数据
|
||||
* @param allElements 全部节点信息
|
||||
* @param historicTaskInstanceList 历史任务实例信息，数据采用开始时间升序
|
||||
* @return
|
||||
*/
|
||||
public static List<String> historicTaskInstanceClean(Collection<FlowElement> allElements, List<HistoricTaskInstance> historicTaskInstanceList) {
|
||||
// 会签节点收集
|
||||
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<HistoricTaskInstance> stack = new Stack<>();
|
||||
historicTaskInstanceList.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().getTaskDefinitionKey())) {
|
||||
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().getTaskDefinitionKey())) {
|
||||
dirtyTask = flowElement;
|
||||
}
|
||||
}
|
||||
// 获取脏数据线路
|
||||
Set<String> dirtyDataLine = FlowableUtils.iteratorFindDirtyRoads(dirtyTask, null, null, Arrays.asList(dirtyPoint.split(",")), null);
|
||||
// 自己本身也是脏线路上的点，加进去
|
||||
dirtyDataLine.add(stack.peek().getTaskDefinitionKey());
|
||||
log.info(stack.peek().getTaskDefinitionKey() + "点脏路线集合：" + 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().getTaskDefinitionKey());
|
||||
}
|
||||
// 校验脏线路是否结束
|
||||
for (int i = 0; i < deleteKeyList.size(); i ++) {
|
||||
// 如果发现脏数据属于会签，记录下下标与对应 Key，以备后续比对，会签脏数据范畴开始
|
||||
if (multiKey == null && multiTask.contains(stack.peek().getTaskDefinitionKey())
|
||||
&& deleteKeyList.get(i).contains(stack.peek().getTaskDefinitionKey())) {
|
||||
multiIndex = i;
|
||||
multiKey = new StringBuilder(stack.peek().getTaskDefinitionKey());
|
||||
}
|
||||
// 会签脏数据处理，节点退回会签清空
|
||||
// 如果在会签脏数据范畴中发现 Key改变，说明会签脏数据在上个节点就结束了，可以把会签脏数据删掉
|
||||
if (multiKey != null && !multiKey.toString().equals(stack.peek().getTaskDefinitionKey())) {
|
||||
deleteKeyList.set(multiIndex , deleteKeyList.get(multiIndex).replace(stack.peek().getTaskDefinitionKey() + ",", ""));
|
||||
multiKey = null;
|
||||
// 结束进行下校验删除
|
||||
multiOpera = true;
|
||||
}
|
||||
// 其他脏数据处理
|
||||
// 发现该路线最后一条脏数据，说明这条脏数据线路处理完了，删除脏数据信息
|
||||
// 脏数据产生的新实例中是否包含这条数据
|
||||
if (multiKey == null && deleteKeyList.get(i).contains(stack.peek().getTaskDefinitionKey())) {
|
||||
// 删除匹配到的部分
|
||||
deleteKeyList.set(i , deleteKeyList.get(i).replace(stack.peek().getTaskDefinitionKey() + ",", ""));
|
||||
}
|
||||
// 如果每组中的元素都以匹配过，说明脏数据结束
|
||||
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().getTaskDefinitionKey());
|
||||
}
|
||||
log.info("清洗后的历史节点数据：" + lastHistoricTaskInstanceList);
|
||||
return lastHistoricTaskInstanceList;
|
||||
}
|
||||
|
||||
/**
|
||||
* 深搜递归获取流程未通过的节点
|
||||
* @param bpmnModel 流程模型
|
||||
* @param unfinishedTaskSet 未结束的任务节点
|
||||
* @param finishedSequenceFlowSet 已经完成的连线
|
||||
* @param finishedTaskSet 已完成的任务节点
|
||||
* @return
|
||||
*/
|
||||
public static Set<String> dfsFindRejects(BpmnModel bpmnModel, Set<String> unfinishedTaskSet, Set<String> finishedSequenceFlowSet, Set<String> finishedTaskSet) {
|
||||
if (ObjectUtil.isNull(bpmnModel)) {
|
||||
throw new ServiceException("流程模型不存在");
|
||||
}
|
||||
Collection<FlowElement> allElements = getAllElements(bpmnModel.getMainProcess().getFlowElements(), null);
|
||||
Set<String> rejectedSet = new HashSet<>();
|
||||
for (FlowElement flowElement : allElements) {
|
||||
// 用户节点且未结束元素
|
||||
if (flowElement instanceof UserTask && unfinishedTaskSet.contains(flowElement.getId())) {
|
||||
List<String> hasSequenceFlow = iteratorFindFinishes(flowElement, null);
|
||||
List<String> rejects = iteratorFindRejects(flowElement, finishedSequenceFlowSet, finishedTaskSet, hasSequenceFlow, null);
|
||||
rejectedSet.addAll(rejects);
|
||||
}
|
||||
}
|
||||
return rejectedSet;
|
||||
}
|
||||
|
||||
/**
|
||||
* 迭代获取父级节点列表，向前找
|
||||
* @param source 起始节点
|
||||
* @param hasSequenceFlow 已经经过的连线的ID，用于判断线路是否重复
|
||||
* @return
|
||||
*/
|
||||
public static List<String> iteratorFindFinishes(FlowElement source, List<String> hasSequenceFlow) {
|
||||
hasSequenceFlow = hasSequenceFlow == null ? new ArrayList<>() : hasSequenceFlow;
|
||||
|
||||
// 根据类型，获取入口连线
|
||||
List<SequenceFlow> sequenceFlows = getElementIncomingFlows(source);
|
||||
|
||||
if (sequenceFlows != null) {
|
||||
// 循环找到目标元素
|
||||
for (SequenceFlow sequenceFlow: sequenceFlows) {
|
||||
// 如果发现连线重复，说明循环了，跳过这个循环
|
||||
if (hasSequenceFlow.contains(sequenceFlow.getId())) {
|
||||
continue;
|
||||
}
|
||||
// 添加已经走过的连线
|
||||
hasSequenceFlow.add(sequenceFlow.getId());
|
||||
FlowElement finishedElement = sequenceFlow.getSourceFlowElement();
|
||||
// 类型为子流程，则添加子流程开始节点出口处相连的节点
|
||||
if (finishedElement instanceof SubProcess) {
|
||||
FlowElement firstElement = (StartEvent) ((SubProcess) finishedElement).getFlowElements().toArray()[0];
|
||||
// 获取子流程的连线
|
||||
hasSequenceFlow.addAll(iteratorFindFinishes(firstElement, null));
|
||||
}
|
||||
// 继续迭代
|
||||
hasSequenceFlow = iteratorFindFinishes(finishedElement, hasSequenceFlow);
|
||||
}
|
||||
}
|
||||
return hasSequenceFlow;
|
||||
}
|
||||
|
||||
/**
|
||||
* 根据正在运行的任务节点，迭代获取子级任务节点列表，向后找
|
||||
* @param source 起始节点
|
||||
* @param finishedSequenceFlowSet 已经完成的连线
|
||||
* @param finishedTaskSet 已经完成的任务节点
|
||||
* @param hasSequenceFlow 已经经过的连线的 ID，用于判断线路是否重复
|
||||
* @param rejectedList 未通过的元素
|
||||
* @return
|
||||
*/
|
||||
public static List<String> iteratorFindRejects(FlowElement source, Set<String> finishedSequenceFlowSet, Set<String> finishedTaskSet
|
||||
, List<String> hasSequenceFlow, List<String> rejectedList) {
|
||||
hasSequenceFlow = hasSequenceFlow == null ? new ArrayList<>() : hasSequenceFlow;
|
||||
rejectedList = rejectedList == null ? new ArrayList<>() : rejectedList;
|
||||
|
||||
// 根据类型，获取出口连线
|
||||
List<SequenceFlow> sequenceFlows = getElementOutgoingFlows(source);
|
||||
|
||||
if (sequenceFlows != null) {
|
||||
// 循环找到目标元素
|
||||
for (SequenceFlow sequenceFlow: sequenceFlows) {
|
||||
// 如果发现连线重复，说明循环了，跳过这个循环
|
||||
if (hasSequenceFlow.contains(sequenceFlow.getId())) {
|
||||
continue;
|
||||
}
|
||||
// 添加已经走过的连线
|
||||
hasSequenceFlow.add(sequenceFlow.getId());
|
||||
FlowElement targetElement = sequenceFlow.getTargetFlowElement();
|
||||
// 添加未完成的节点
|
||||
if (finishedTaskSet.contains(targetElement.getId())) {
|
||||
rejectedList.add(targetElement.getId());
|
||||
}
|
||||
// 添加未完成的连线
|
||||
if (finishedSequenceFlowSet.contains(sequenceFlow.getId())) {
|
||||
rejectedList.add(sequenceFlow.getId());
|
||||
}
|
||||
// 如果节点为子流程节点情况，则从节点中的第一个节点开始获取
|
||||
if (targetElement instanceof SubProcess) {
|
||||
FlowElement firstElement = (FlowElement) (((SubProcess) targetElement).getFlowElements().toArray()[0]);
|
||||
List<String> childList = iteratorFindRejects(firstElement, finishedSequenceFlowSet, finishedTaskSet, hasSequenceFlow, null);
|
||||
// 如果找到节点，则说明该线路找到节点，不继续向下找，反之继续
|
||||
if (childList != null && childList.size() > 0) {
|
||||
rejectedList.addAll(childList);
|
||||
continue;
|
||||
}
|
||||
}
|
||||
// 继续迭代
|
||||
rejectedList = iteratorFindRejects(targetElement, finishedSequenceFlowSet, finishedTaskSet, hasSequenceFlow, rejectedList);
|
||||
}
|
||||
}
|
||||
return rejectedList;
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,38 @@
|
||||
package com.gear.flowable.listener;
|
||||
|
||||
import cn.hutool.core.convert.Convert;
|
||||
import cn.hutool.core.util.ObjectUtil;
|
||||
import com.gear.flowable.common.constant.ProcessConstants;
|
||||
import com.gear.flowable.common.enums.ProcessStatus;
|
||||
import org.flowable.common.engine.api.delegate.event.FlowableEngineEntityEvent;
|
||||
import org.flowable.engine.RuntimeService;
|
||||
import org.flowable.engine.delegate.event.AbstractFlowableEngineEventListener;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
/**
|
||||
* Flowable 全局监听器
|
||||
*
|
||||
* @author konbai
|
||||
* @since 2023/3/8 22:45
|
||||
*/
|
||||
@Component
|
||||
public class GlobalEventListener extends AbstractFlowableEngineEventListener {
|
||||
|
||||
@Autowired
|
||||
private RuntimeService runtimeService;
|
||||
|
||||
/**
|
||||
* 流程结束监听器
|
||||
*/
|
||||
@Override
|
||||
protected void processCompleted(FlowableEngineEntityEvent event) {
|
||||
String processInstanceId = event.getProcessInstanceId();
|
||||
Object variable = runtimeService.getVariable(processInstanceId, ProcessConstants.PROCESS_STATUS_KEY);
|
||||
ProcessStatus status = ProcessStatus.getProcessStatus(Convert.toStr(variable));
|
||||
if (ObjectUtil.isNotNull(status) && ProcessStatus.RUNNING == status) {
|
||||
runtimeService.setVariable(processInstanceId, ProcessConstants.PROCESS_STATUS_KEY, ProcessStatus.COMPLETED.getStatus());
|
||||
}
|
||||
super.processCompleted(event);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,27 @@
|
||||
package com.gear.flowable.listener;
|
||||
|
||||
import org.flowable.engine.delegate.TaskListener;
|
||||
import org.flowable.task.service.delegate.DelegateTask;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
/**
|
||||
* 用户任务监听器
|
||||
*
|
||||
* @author KonBAI
|
||||
* @since 2023/5/13
|
||||
*/
|
||||
@Component(value = "userTaskListener")
|
||||
public class UserTaskListener implements TaskListener {
|
||||
|
||||
/**
|
||||
* 注入字段（名称与流程设计时字段名称一致）
|
||||
*/
|
||||
// private FixedValue field;
|
||||
|
||||
@Override
|
||||
public void notify(DelegateTask delegateTask) {
|
||||
//TODO 实现你的任务监听器逻辑
|
||||
System.out.println("执行任务监听器...");
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,373 @@
|
||||
package com.gear.flowable.utils;
|
||||
|
||||
import cn.hutool.core.util.ObjectUtil;
|
||||
import cn.hutool.core.util.StrUtil;
|
||||
import org.flowable.bpmn.converter.BpmnXMLConverter;
|
||||
import org.flowable.bpmn.model.Process;
|
||||
import org.flowable.bpmn.model.*;
|
||||
import org.flowable.common.engine.impl.util.io.StringStreamSource;
|
||||
|
||||
import java.util.*;
|
||||
|
||||
/**
|
||||
* @author KonBAI
|
||||
* @createTime 2022/3/26 19:04
|
||||
*/
|
||||
public class ModelUtils {
|
||||
|
||||
private static final BpmnXMLConverter bpmnXMLConverter = new BpmnXMLConverter();
|
||||
|
||||
/**
|
||||
* xml转bpmnModel对象
|
||||
*
|
||||
* @param xml xml
|
||||
* @return bpmnModel对象
|
||||
*/
|
||||
public static BpmnModel getBpmnModel(String xml) {
|
||||
return bpmnXMLConverter.convertToBpmnModel(new StringStreamSource(xml), false, false);
|
||||
}
|
||||
|
||||
/**
|
||||
* bpmnModel转xml字符串
|
||||
*
|
||||
* @deprecated 存在会丢失 bpmn 连线问题
|
||||
* @param bpmnModel bpmnModel对象
|
||||
* @return xml字符串
|
||||
*/
|
||||
@Deprecated
|
||||
public static String getBpmnXmlStr(BpmnModel bpmnModel) {
|
||||
return StrUtil.utf8Str(getBpmnXml(bpmnModel));
|
||||
}
|
||||
|
||||
/**
|
||||
* bpmnModel转xml对象
|
||||
*
|
||||
* @deprecated 存在丢失 bpmn 连线问题
|
||||
* @param bpmnModel bpmnModel对象
|
||||
* @return xml
|
||||
*/
|
||||
@Deprecated
|
||||
public static byte[] getBpmnXml(BpmnModel bpmnModel) {
|
||||
return bpmnXMLConverter.convertToXML(bpmnModel);
|
||||
}
|
||||
|
||||
/**
|
||||
* 根据节点，获取入口连线
|
||||
*
|
||||
* @param source 起始节点
|
||||
* @return 入口连线列表
|
||||
*/
|
||||
public static List<SequenceFlow> getElementIncomingFlows(FlowElement source) {
|
||||
List<SequenceFlow> sequenceFlows = new ArrayList<>();
|
||||
if (source instanceof FlowNode) {
|
||||
sequenceFlows = ((FlowNode) source).getIncomingFlows();
|
||||
}
|
||||
return sequenceFlows;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 根据节点，获取出口连线
|
||||
*
|
||||
* @param source 起始节点
|
||||
* @return 出口连线列表
|
||||
*/
|
||||
public static List<SequenceFlow> getElementOutgoingFlows(FlowElement source) {
|
||||
List<SequenceFlow> sequenceFlows = new ArrayList<>();
|
||||
if (source instanceof FlowNode) {
|
||||
sequenceFlows = ((FlowNode) source).getOutgoingFlows();
|
||||
}
|
||||
return sequenceFlows;
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取开始节点
|
||||
*
|
||||
* @param model bpmnModel对象
|
||||
* @return 开始节点（未找到开始节点，返回null）
|
||||
*/
|
||||
public static StartEvent getStartEvent(BpmnModel model) {
|
||||
Process process = model.getMainProcess();
|
||||
FlowElement startElement = process.getInitialFlowElement();
|
||||
if (startElement instanceof StartEvent) {
|
||||
return (StartEvent) startElement;
|
||||
}
|
||||
return getStartEvent(process.getFlowElements());
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取开始节点
|
||||
*
|
||||
* @param flowElements 流程元素集合
|
||||
* @return 开始节点（未找到开始节点，返回null）
|
||||
*/
|
||||
public static StartEvent getStartEvent(Collection<FlowElement> flowElements) {
|
||||
for (FlowElement flowElement : flowElements) {
|
||||
if (flowElement instanceof StartEvent) {
|
||||
return (StartEvent) flowElement;
|
||||
}
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取结束节点
|
||||
*
|
||||
* @param model bpmnModel对象
|
||||
* @return 结束节点（未找到开始节点，返回null）
|
||||
*/
|
||||
public static EndEvent getEndEvent(BpmnModel model) {
|
||||
Process process = model.getMainProcess();
|
||||
return getEndEvent(process.getFlowElements());
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取结束节点
|
||||
*
|
||||
* @param flowElements 流程元素集合
|
||||
* @return 结束节点（未找到开始节点，返回null）
|
||||
*/
|
||||
public static EndEvent getEndEvent(Collection<FlowElement> flowElements) {
|
||||
for (FlowElement flowElement : flowElements) {
|
||||
if (flowElement instanceof EndEvent) {
|
||||
return (EndEvent) flowElement;
|
||||
}
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
public static UserTask getUserTaskByKey(BpmnModel model, String taskKey) {
|
||||
Process process = model.getMainProcess();
|
||||
FlowElement flowElement = process.getFlowElement(taskKey);
|
||||
if (flowElement instanceof UserTask) {
|
||||
return (UserTask) flowElement;
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取流程元素信息
|
||||
*
|
||||
* @param model bpmnModel对象
|
||||
* @param flowElementId 元素ID
|
||||
* @return 元素信息
|
||||
*/
|
||||
public static FlowElement getFlowElementById(BpmnModel model, String flowElementId) {
|
||||
Process process = model.getMainProcess();
|
||||
return process.getFlowElement(flowElementId);
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取元素表单Key（限开始节点和用户节点可用）
|
||||
*
|
||||
* @param flowElement 元素
|
||||
* @return 表单Key
|
||||
*/
|
||||
public static String getFormKey(FlowElement flowElement) {
|
||||
if (flowElement != null) {
|
||||
if (flowElement instanceof StartEvent) {
|
||||
return ((StartEvent) flowElement).getFormKey();
|
||||
} else if (flowElement instanceof UserTask) {
|
||||
return ((UserTask) flowElement).getFormKey();
|
||||
}
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取开始节点属性值
|
||||
* @param model bpmnModel对象
|
||||
* @param name 属性名
|
||||
* @return 属性值
|
||||
*/
|
||||
public static String getStartEventAttributeValue(BpmnModel model, String name) {
|
||||
StartEvent startEvent = getStartEvent(model);
|
||||
return getElementAttributeValue(startEvent, name);
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取结束节点属性值
|
||||
* @param model bpmnModel对象
|
||||
* @param name 属性名
|
||||
* @return 属性值
|
||||
*/
|
||||
public static String getEndEventAttributeValue(BpmnModel model, String name) {
|
||||
EndEvent endEvent = getEndEvent(model);
|
||||
return getElementAttributeValue(endEvent, name);
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取用户任务节点属性值
|
||||
* @param model bpmnModel对象
|
||||
* @param taskKey 任务Key
|
||||
* @param name 属性名
|
||||
* @return 属性值
|
||||
*/
|
||||
public static String getUserTaskAttributeValue(BpmnModel model, String taskKey, String name) {
|
||||
UserTask userTask = getUserTaskByKey(model, taskKey);
|
||||
return getElementAttributeValue(userTask, name);
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取元素属性值
|
||||
* @param baseElement 流程元素
|
||||
* @param name 属性名
|
||||
* @return 属性值
|
||||
*/
|
||||
public static String getElementAttributeValue(BaseElement baseElement, String name) {
|
||||
if (baseElement != null) {
|
||||
List<ExtensionAttribute> attributes = baseElement.getAttributes().get(name);
|
||||
if (attributes != null && !attributes.isEmpty()) {
|
||||
attributes.iterator().next().getValue();
|
||||
Iterator<ExtensionAttribute> attrIterator = attributes.iterator();
|
||||
if(attrIterator.hasNext()) {
|
||||
ExtensionAttribute attribute = attrIterator.next();
|
||||
return attribute.getValue();
|
||||
}
|
||||
}
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
public static boolean isMultiInstance(BpmnModel model, String taskKey) {
|
||||
UserTask userTask = getUserTaskByKey(model, taskKey);
|
||||
if (ObjectUtil.isNotNull(userTask)) {
|
||||
return userTask.hasMultiInstanceLoopCharacteristics();
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取所有用户任务节点
|
||||
*
|
||||
* @param model bpmnModel对象
|
||||
* @return 用户任务节点列表
|
||||
*/
|
||||
public static Collection<UserTask> getAllUserTaskEvent(BpmnModel model) {
|
||||
Process process = model.getMainProcess();
|
||||
Collection<FlowElement> flowElements = process.getFlowElements();
|
||||
return getAllUserTaskEvent(flowElements, null);
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取所有用户任务节点
|
||||
* @param flowElements 流程元素集合
|
||||
* @param allElements 所有流程元素集合
|
||||
* @return 用户任务节点列表
|
||||
*/
|
||||
public static Collection<UserTask> getAllUserTaskEvent(Collection<FlowElement> flowElements, Collection<UserTask> allElements) {
|
||||
allElements = allElements == null ? new ArrayList<>() : allElements;
|
||||
for (FlowElement flowElement : flowElements) {
|
||||
if (flowElement instanceof UserTask) {
|
||||
allElements.add((UserTask) flowElement);
|
||||
}
|
||||
if (flowElement instanceof SubProcess) {
|
||||
// 继续深入子流程，进一步获取子流程
|
||||
allElements = getAllUserTaskEvent(((SubProcess) flowElement).getFlowElements(), allElements);
|
||||
}
|
||||
}
|
||||
return allElements;
|
||||
}
|
||||
|
||||
/**
|
||||
* 查找起始节点下一个用户任务列表列表
|
||||
* @param source 起始节点
|
||||
* @return 结果
|
||||
*/
|
||||
public static List<UserTask> findNextUserTasks(FlowElement source) {
|
||||
return findNextUserTasks(source, null, null);
|
||||
}
|
||||
|
||||
/**
|
||||
* 查找起始节点下一个用户任务列表列表
|
||||
* @param source 起始节点
|
||||
* @param hasSequenceFlow 已经经过的连线的 ID，用于判断线路是否重复
|
||||
* @param userTaskList 用户任务列表
|
||||
* @return 结果
|
||||
*/
|
||||
public static List<UserTask> findNextUserTasks(FlowElement source, Set<String> hasSequenceFlow, List<UserTask> userTaskList) {
|
||||
hasSequenceFlow = Optional.ofNullable(hasSequenceFlow).orElse(new HashSet<>());
|
||||
userTaskList = Optional.ofNullable(userTaskList).orElse(new ArrayList<>());
|
||||
// 获取出口连线
|
||||
List<SequenceFlow> sequenceFlows = getElementOutgoingFlows(source);
|
||||
if (!sequenceFlows.isEmpty()) {
|
||||
for (SequenceFlow sequenceFlow : sequenceFlows) {
|
||||
// 如果发现连线重复，说明循环了，跳过这个循环
|
||||
if (hasSequenceFlow.contains(sequenceFlow.getId())) {
|
||||
continue;
|
||||
}
|
||||
// 添加已经走过的连线
|
||||
hasSequenceFlow.add(sequenceFlow.getId());
|
||||
FlowElement targetFlowElement = sequenceFlow.getTargetFlowElement();
|
||||
if (targetFlowElement instanceof UserTask) {
|
||||
// 若节点为用户任务，加入到结果列表中
|
||||
userTaskList.add((UserTask) targetFlowElement);
|
||||
} else {
|
||||
// 若节点非用户任务，继续递归查找下一个节点
|
||||
findNextUserTasks(targetFlowElement, hasSequenceFlow, userTaskList);
|
||||
}
|
||||
}
|
||||
}
|
||||
return userTaskList;
|
||||
}
|
||||
|
||||
/**
|
||||
* 迭代从后向前扫描，判断目标节点相对于当前节点是否是串行
|
||||
* 不存在直接回退到子流程中的情况，但存在从子流程出去到父流程情况
|
||||
* @param source 起始节点
|
||||
* @param target 目标节点
|
||||
* @param visitedElements 已经经过的连线的 ID，用于判断线路是否重复
|
||||
* @return 结果
|
||||
*/
|
||||
public static boolean isSequentialReachable(FlowElement source, FlowElement target, Set<String> visitedElements) {
|
||||
visitedElements = visitedElements == null ? new HashSet<>() : visitedElements;
|
||||
if (source instanceof StartEvent && isInEventSubprocess(source)) {
|
||||
return false;
|
||||
}
|
||||
|
||||
// 根据类型，获取入口连线
|
||||
List<SequenceFlow> sequenceFlows = getElementIncomingFlows(source);
|
||||
if (sequenceFlows != null && sequenceFlows.size() > 0) {
|
||||
// 循环找到目标元素
|
||||
for (SequenceFlow sequenceFlow: sequenceFlows) {
|
||||
// 如果发现连线重复，说明循环了，跳过这个循环
|
||||
if (visitedElements.contains(sequenceFlow.getId())) {
|
||||
continue;
|
||||
}
|
||||
// 添加已经走过的连线
|
||||
visitedElements.add(sequenceFlow.getId());
|
||||
FlowElement sourceFlowElement = sequenceFlow.getSourceFlowElement();
|
||||
// 这条线路存在目标节点，这条线路完成，进入下个线路
|
||||
if (target.getId().equals(sourceFlowElement.getId())) {
|
||||
continue;
|
||||
}
|
||||
// 如果目标节点为并行网关，则不继续
|
||||
if (sourceFlowElement instanceof ParallelGateway) {
|
||||
return false;
|
||||
}
|
||||
// 否则就继续迭代
|
||||
boolean isSequential = isSequentialReachable(sourceFlowElement, target, visitedElements);
|
||||
if (!isSequential) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
protected static boolean isInEventSubprocess(FlowElement flowElement) {
|
||||
FlowElementsContainer flowElementsContainer = flowElement.getParentContainer();
|
||||
while (flowElementsContainer != null) {
|
||||
if (flowElementsContainer instanceof EventSubProcess) {
|
||||
return true;
|
||||
}
|
||||
|
||||
if (flowElementsContainer instanceof FlowElement) {
|
||||
flowElementsContainer = ((FlowElement) flowElementsContainer).getParentContainer();
|
||||
} else {
|
||||
flowElementsContainer = null;
|
||||
}
|
||||
}
|
||||
return false;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,50 @@
|
||||
package com.gear.flowable.utils;
|
||||
|
||||
import cn.hutool.core.convert.Convert;
|
||||
import com.gear.flowable.core.FormConf;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* 流程表单工具类
|
||||
*
|
||||
* @author KonBAI
|
||||
* @createTime 2022/8/7 17:09
|
||||
*/
|
||||
public class ProcessFormUtils {
|
||||
|
||||
private static final String CONFIG = "__config__";
|
||||
private static final String MODEL = "__vModel__";
|
||||
|
||||
/**
|
||||
* 填充表单项内容
|
||||
*
|
||||
* @param formConf 表单配置信息
|
||||
* @param data 表单内容
|
||||
*/
|
||||
public static void fillFormData(FormConf formConf, Map<String, Object> data) {
|
||||
for (Map<String, Object> field : formConf.getFields()) {
|
||||
recursiveFillField(field, data);
|
||||
}
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
private static void recursiveFillField(final Map<String, Object> field, final Map<String, Object> data) {
|
||||
if (!field.containsKey(CONFIG)) {
|
||||
return;
|
||||
}
|
||||
Map<String, Object> configMap = (Map<String, Object>) field.get(CONFIG);
|
||||
if (configMap.containsKey("children")) {
|
||||
List<Map<String, Object>> childrens = (List<Map<String, Object>>) configMap.get("children");
|
||||
for (Map<String, Object> children : childrens) {
|
||||
recursiveFillField(children, data);
|
||||
}
|
||||
}
|
||||
String modelKey = Convert.toStr(field.get(MODEL));
|
||||
Object value = data.get(modelKey);
|
||||
if (value != null) {
|
||||
configMap.put("defaultValue", value);
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,115 @@
|
||||
package com.gear.flowable.utils;
|
||||
|
||||
import com.gear.common.utils.DateUtils;
|
||||
import com.gear.common.utils.StringUtils;
|
||||
import com.gear.flowable.core.domain.ProcessQuery;
|
||||
import org.flowable.common.engine.api.query.Query;
|
||||
import org.flowable.common.engine.impl.db.SuspensionState;
|
||||
import org.flowable.engine.history.HistoricProcessInstanceQuery;
|
||||
import org.flowable.engine.repository.ProcessDefinitionQuery;
|
||||
import org.flowable.task.api.TaskQuery;
|
||||
import org.flowable.task.api.history.HistoricTaskInstanceQuery;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* 流程工具类
|
||||
*
|
||||
* @author konbai
|
||||
* @since 2022/12/11 03:35
|
||||
*/
|
||||
public class ProcessUtils {
|
||||
|
||||
public static void buildProcessSearch(Query<?, ?> query, ProcessQuery process) {
|
||||
if (query instanceof ProcessDefinitionQuery) {
|
||||
buildProcessDefinitionSearch((ProcessDefinitionQuery) query, process);
|
||||
} else if (query instanceof TaskQuery) {
|
||||
buildTaskSearch((TaskQuery) query, process);
|
||||
} else if (query instanceof HistoricTaskInstanceQuery) {
|
||||
buildHistoricTaskInstanceSearch((HistoricTaskInstanceQuery) query, process);
|
||||
} else if (query instanceof HistoricProcessInstanceQuery) {
|
||||
buildHistoricProcessInstanceSearch((HistoricProcessInstanceQuery) query, process);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 构建流程定义搜索
|
||||
*/
|
||||
public static void buildProcessDefinitionSearch(ProcessDefinitionQuery query, ProcessQuery process) {
|
||||
// 流程标识
|
||||
if (StringUtils.isNotBlank(process.getProcessKey())) {
|
||||
query.processDefinitionKeyLike("%" + process.getProcessKey() + "%");
|
||||
}
|
||||
// 流程名称
|
||||
if (StringUtils.isNotBlank(process.getProcessName())) {
|
||||
query.processDefinitionNameLike("%" + process.getProcessName() + "%");
|
||||
}
|
||||
// 流程分类
|
||||
if (StringUtils.isNotBlank(process.getCategory())) {
|
||||
query.processDefinitionCategory(process.getCategory());
|
||||
}
|
||||
// 流程状态
|
||||
if (StringUtils.isNotBlank(process.getState())) {
|
||||
if (SuspensionState.ACTIVE.toString().equals(process.getState())) {
|
||||
query.active();
|
||||
} else if (SuspensionState.SUSPENDED.toString().equals(process.getState())) {
|
||||
query.suspended();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 构建任务搜索
|
||||
*/
|
||||
public static void buildTaskSearch(TaskQuery query, ProcessQuery process) {
|
||||
Map<String, Object> params = process.getParams();
|
||||
if (StringUtils.isNotBlank(process.getProcessKey())) {
|
||||
query.processDefinitionKeyLike("%" + process.getProcessKey() + "%");
|
||||
}
|
||||
if (StringUtils.isNotBlank(process.getProcessName())) {
|
||||
query.processDefinitionNameLike("%" + process.getProcessName() + "%");
|
||||
}
|
||||
if (params.get("beginTime") != null && params.get("endTime") != null) {
|
||||
query.taskCreatedAfter(DateUtils.parseDate(params.get("beginTime")));
|
||||
query.taskCreatedBefore(DateUtils.parseDate(params.get("endTime")));
|
||||
}
|
||||
}
|
||||
|
||||
private static void buildHistoricTaskInstanceSearch(HistoricTaskInstanceQuery query, ProcessQuery process) {
|
||||
Map<String, Object> params = process.getParams();
|
||||
if (StringUtils.isNotBlank(process.getProcessKey())) {
|
||||
query.processDefinitionKeyLike("%" + process.getProcessKey() + "%");
|
||||
}
|
||||
if (StringUtils.isNotBlank(process.getProcessName())) {
|
||||
query.processDefinitionNameLike("%" + process.getProcessName() + "%");
|
||||
}
|
||||
if (params.get("beginTime") != null && params.get("endTime") != null) {
|
||||
query.taskCompletedAfter(DateUtils.parseDate(params.get("beginTime")));
|
||||
query.taskCompletedBefore(DateUtils.parseDate(params.get("endTime")));
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 构建历史流程实例搜索
|
||||
*/
|
||||
public static void buildHistoricProcessInstanceSearch(HistoricProcessInstanceQuery query, ProcessQuery process) {
|
||||
Map<String, Object> params = process.getParams();
|
||||
// 流程标识
|
||||
if (StringUtils.isNotBlank(process.getProcessKey())) {
|
||||
query.processDefinitionKey(process.getProcessKey());
|
||||
}
|
||||
// 流程名称
|
||||
if (StringUtils.isNotBlank(process.getProcessName())) {
|
||||
query.processDefinitionName(process.getProcessName());
|
||||
}
|
||||
// 流程名称
|
||||
if (StringUtils.isNotBlank(process.getCategory())) {
|
||||
query.processDefinitionCategory(process.getCategory());
|
||||
}
|
||||
if (params.get("beginTime") != null && params.get("endTime") != null) {
|
||||
query.startedAfter(DateUtils.parseDate(params.get("beginTime")));
|
||||
query.startedBefore(DateUtils.parseDate(params.get("endTime")));
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,41 @@
|
||||
package com.gear.flowable.utils;
|
||||
|
||||
import cn.hutool.core.util.ObjectUtil;
|
||||
import com.gear.common.core.domain.model.LoginUser;
|
||||
import com.gear.common.helper.LoginHelper;
|
||||
import com.gear.flowable.common.constant.TaskConstants;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 工作流任务工具类
|
||||
*
|
||||
* @author konbai
|
||||
* @createTime 2022/4/24 12:42
|
||||
*/
|
||||
public class TaskUtils {
|
||||
|
||||
public static String getUserId() {
|
||||
return String.valueOf(LoginHelper.getUserId());
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取用户组信息
|
||||
*
|
||||
* @return candidateGroup
|
||||
*/
|
||||
public static List<String> getCandidateGroup() {
|
||||
List<String> list = new ArrayList<>();
|
||||
LoginUser user = LoginHelper.getLoginUser();
|
||||
if (ObjectUtil.isNotNull(user)) {
|
||||
if (ObjectUtil.isNotEmpty(user.getRoles())) {
|
||||
user.getRoles().forEach(role -> list.add(TaskConstants.ROLE_GROUP_PREFIX + role.getRoleId()));
|
||||
}
|
||||
if (ObjectUtil.isNotNull(user.getDeptId())) {
|
||||
list.add(TaskConstants.DEPT_GROUP_PREFIX + user.getDeptId());
|
||||
}
|
||||
}
|
||||
return list;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user