+ * 定义流程实例执行过程中使用的各种常量，包括： - 无执行人处理策略 - 拒绝处理策略 - 多人审批模式 - 任务分配类型 - 表单权限 + *
+ * + * @author pigx + */ +public class ProcessInstanceConstant { + + /** + * 空执行人默认ID 当节点没有找到合适的执行人时使用该默认值 + */ + public static final Long DEFAULT_EMPTY_ASSIGN = -99999999L; + + /** + * 无执行人处理策略：自动通过 当任务节点没有找到执行人时，自动通过该节点 + */ + public static final String USER_TASK_NOBODY_HANDLER_TO_PASS = "TO_PASS"; + + /** + * 无执行人处理策略：转交给管理员 当任务节点没有找到执行人时，将任务转交给流程管理员处理 + */ + public static final String USER_TASK_NOBODY_HANDLER_TO_ADMIN = "TO_ADMIN"; + + /** + * 无执行人处理策略：指定人员 当任务节点没有找到执行人时，转交给预先指定的人员处理 + */ + public static final String USER_TASK_NOBODY_HANDLER_TO_USER = "TO_USER"; + + /** + * 无执行人处理策略：结束流程 当任务节点没有找到执行人时，直接结束整个流程 + */ + public static final String USER_TASK_NOBODY_HANDLER_TO_END = "TO_END"; + + /** + * 无执行人处理策略：拒绝 当任务节点没有找到执行人时，自动拒绝该任务 + */ + public static final String USER_TASK_NOBODY_HANDLER_TO_REFUSE = "TO_REFUSE"; + + /** + * 拒绝处理策略：结束流程 审批人拒绝后，直接结束整个流程 + */ + public static final String USER_TASK_REFUSE_TYPE_TO_END = "TO_END"; + + /** + * 拒绝处理策略：跳转到指定节点 审批人拒绝后，流程跳转到指定的节点继续执行 + */ + public static final String USER_TASK_REFUSE_TYPE_TO_NODE = "TO_NODE"; + + /** + * 多人审批模式：会签 所有审批人都必须同意才能通过，任何一人拒绝则不通过 + */ + public static final int MULTIPLE_MODE_AL_SAME = 1; + + /** + * 多人审批模式：或签 只要有一个人同意即可通过，无需等待其他人审批 + */ + public static final int MULTIPLE_MODE_ONE = 2; + + /** + * 多人审批模式：顺签 按照指定顺序依次审批，前一人通过后才能轮到下一人 + */ + public static final int MULTIPLE_MODE_ALL_SORT = 3; + + /** + * 任务分配类型 定义审批节点的执行人分配方式 + */ + public static class AssignedTypeClass { + + /** + * 指定用户 直接指定具体的用户作为执行人 + */ + public static final int USER = 1; + + /** + * 部门主管 根据发起人或上一节点执行人的部门，找到对应的部门主管作为执行人 + */ + public static final int LEADER = 2; + + /** + * 发起人自己 由流程发起人自己处理该节点 + */ + public static final int SELF = 5; + + /** + * 表单人员 从表单中的用户选择字段获取执行人 + */ + public static final int FORM_USER = 8; + + /** + * 发起人自选 发起流程时由发起人手动选择该节点的执行人 + */ + public static final int SELF_SELECT = 4; + + /** + * 角色 指定拥有特定角色的所有用户作为执行人 + */ + public static final int ROLE = 3; + + /** 表达式常量值 */ + public static final int EXPRESSION = 10; + + } + + /** + * 表单权限类型 定义节点对表单字段的操作权限 + */ + public static class FormPermClass { + + /** + * 隐藏 该字段对当前节点执行人不可见 + */ + public static final String HIDE = "H"; + + /** + * 只读 该字段对当前节点执行人可见但不可编辑 + */ + public static final String READ = "R"; + + /** + * 编辑 该字段对当前节点执行人可见且可编辑 + */ + public static final String EDIT = "E"; + + } + +} diff --git a/pigx-flow/pigx-flow-api/src/main/java/com/pig4cloud/pigx/flow/dto/Node.java b/pigx-flow/pigx-flow-api/src/main/java/com/pig4cloud/pigx/flow/dto/Node.java new file mode 100644 index 000000000..1e9eb72d9 --- /dev/null +++ b/pigx-flow/pigx-flow-api/src/main/java/com/pig4cloud/pigx/flow/dto/Node.java @@ -0,0 +1,144 @@ +package com.pig4cloud.pigx.flow.dto; + +import com.fasterxml.jackson.annotation.JsonProperty; +import lombok.Data; + +import java.util.List; +import java.util.Map; + +/** + * 流程节点数据传输对象 + *+ * 用于流程定义的节点配置信息传输。该对象包含了节点的所有配置信息， 包括节点类型、审批人配置、表单权限、条件配置等。 + * 支持嵌套结构，可以表示复杂的流程结构（如条件分支、并行分支）。 + *
+ * + * @author pigx + */ +@Data +public class Node { + + /** + * 节点唯一标识 + */ + private String id; + + /** + * 父节点ID 用于构建节点的层级关系 + */ + private String parentId; + + /** + * 头节点ID 用于条件分支和并行分支的开始节点标识 + */ + private String headId; + + /** + * 尾节点ID 用于条件分支和并行分支的结束节点标识 + */ + private String tailId; + + /** + * 占位符文本 用于流程设计器中的显示 + */ + private String placeHolder; + + /** + * 节点类型 对应NodeTypeEnum中的值 + */ + private Integer type; + + /** + * 节点名称 节点的显示名称 + */ + @JsonProperty(value = "nodeName") + private String name; + + /** + * 错误标识 标识节点配置是否有错误 + */ + private Boolean error; + + /** + * 子节点 当前节点的下一个节点，用于构建节点链 + */ + @JsonProperty("childNode") + private Node children; + + /** + * 事件配置 JSON格式存储节点事件配置（如超时提醒、自动审批等） + */ + private String eventConfig; + + /** + * 执行人分配类型 对应AssignedTypeClass中的常量（指定用户、部门主管、角色等） + */ + private Integer assignedType; + + /** + * 是否多人审批 true=多人审批，false=单人审批 + */ + private Boolean multiple; + + /** + * 多人审批模式 1=会签（所有人都同意），2=或签（一人同意即可），3=顺签（依次审批） + */ + private Integer multipleMode; + + /** + * 部门主管级别 当assignedType为LEADER时，指定查找第几级主管 + */ + private Integer deptLeaderLevel; + + /** 分配规则名称 */ + private String assignExpressName; + + /** 分配表达式 */ + private String assignExpress; + + /** + * 表单用户字段ID 当assignedType为FORM_USER时，指定从哪个表单字段获取用户 + */ + private String formUserId; + + /** + * 表单用户字段名称 用于显示 + */ + private String formUserName; + + /** + * 节点执行人列表 当assignedType为USER或ROLE时，存储具体的用户或角色信息 + */ + private List+ * 提供流程节点的可视化格式化功能，将流程定义节点转换为前端展示所需的数据结构。 该工具类负责处理节点状态、执行人信息、分支结构等显示逻辑。 + *
+ * 主要功能： 1. 格式化流程节点为可视化数据结构 2. 处理节点的执行状态（未开始、进行中、已完成） 3. 获取并展示节点的执行人信息 4. 处理条件分支和并行分支的嵌套结构 + * 5. 支持发起人自选、指定用户、表单人员等多种执行人类型 + *
+ * 使用场景： - 流程图可视化展示 - 流程进度跟踪 - 流程历史查看 + * + * @author pigx + */ +public class NodeFormatUtil { + + /** + * 格式化流程节点为可视化展示结构 + *
+ * 递归处理流程节点树，生成包含节点状态、执行人信息的展示数据。 支持处理各种节点类型，包括审批节点、抄送节点、网关节点等。
+ * @param node 当前处理的节点对象
+ * @param completeNodeSet 已完成的节点ID集合
+ * @param continueNodeSet 进行中的节点ID集合
+ * @param processInstanceId 流程实例ID，用于查询历史数据，可为null
+ * @param paramMap 流程变量Map，包含表单数据和执行人选择信息
+ * @return 格式化后的节点展示对象列表
+ */
+ @SneakyThrows
+ public static List
+ * 查询流程实例记录，获取发起人的用户ID，并构建用户展示对象。 主要用于展示流程的发起人信息。
+ * @param processInstanceId 流程实例ID
+ * @return 发起人的用户展示对象
+ */
+ private static UserVo buildRootUser(String processInstanceId) {
+
+ IProcessInstanceRecordService processInstanceRecordService = SpringUtil
+ .getBean(IProcessInstanceRecordService.class);
+ ProcessInstanceRecord processInstanceRecord = processInstanceRecordService.lambdaQuery()
+ .eq(ProcessInstanceRecord::getProcessInstanceId, processInstanceId)
+ .one();
+ Long userId = processInstanceRecord.getUserId();
+ return buildUser(userId);
+ }
+
+ /**
+ * 根据用户ID构建用户展示信息
+ *
+ * 通过远程服务获取用户详细信息，并构建用户展示对象。 如果用户不存在或为空执行人ID，返回特殊处理的对象。
+ * @param userId 用户ID
+ * @return 用户展示对象，如果用户不存在则返回null
+ */
+ private static UserVo buildUser(long userId) {
+ if (ProcessInstanceConstant.DEFAULT_EMPTY_ASSIGN == userId) {
+ return UserVo.builder().id(userId).build();
+ }
+
+ RemoteUserService userService = SpringUtil.getBean(RemoteUserService.class);
+ SysUser user = RetOps.of(userService.getUserById(CollUtil.newArrayList(userId)))
+ .getData()
+ .map(sysUsers -> sysUsers.isEmpty() ? null : sysUsers.get(0))
+ .orElse(null);
+ if (user == null) {
+ return null;
+ }
+
+ return UserVo.builder().id(userId).name(user.getName()).avatar(user.getAvatar()).build();
+ }
+
+ /**
+ * 批量构建用户展示信息
+ *
+ * 根据节点用户配置列表，批量获取用户信息并构建展示对象。 支持处理用户类型和部门类型： - 用户类型：直接获取用户信息 - 部门类型：获取部门下的所有用户
+ * @param nodeUserList 节点用户配置列表，包含用户ID和部门ID
+ * @return 用户展示对象列表
+ */
+ private static List
+ * 处理Flowable多实例任务（会签、或签、顺序签等）的核心组件。 主要功能包括： 1. 解析多实例任务的执行人列表 2. 判断多实例任务的完成条件
+ *
+ * 支持的多实例模式： - 会签：所有人都必须处理，任何人拒绝则任务结束 - 或签：任何一人处理即可完成 - 顺序签：按顺序逐个处理
+ *
+ * 该类在流程定义中通过${multiInstanceHandler.resolveAssignee(execution)}方式调用
+ *
+ * @author pigx
+ */
@Slf4j
@RequiredArgsConstructor
@Component("multiInstanceHandler")
public class MultiInstanceHandler {
- private final RemoteFlowTaskService remoteFlowTaskService;
+ private final IProcessNodeDataService processNodeDataService;
private final Map
+ * 根据节点配置的用户分配策略，动态计算该多实例任务应该分配给哪些用户。 如果节点没有配置或找不到执行人，会尝试从流程变量中获取默认值。
+ * 如果最终没有找到任何执行人，会返回一个特殊的空标记。
+ * @param execution 流程执行对象，包含流程实例信息和变量
+ * @return 执行人ID列表，如果没有执行人则返回包含空标记的列表
+ * @throws Exception 当JSON解析失败时抛出异常
*/
@SneakyThrows
public List
+ * 检查多实例任务是否满足完成条件，支持以下模式： 1. 会签（全部同意）：所有人都必须同意，任何人拒绝则立即结束 2. 或签（一人同意）：任何一人同意即可完成 3.
+ * 顺序签：按顺序处理，任何人拒绝则立即结束
+ *
+ * 该方法在流程定义中作为completionCondition表达式被调用
+ * @param execution 流程执行对象，包含多实例的执行信息
+ * @return true表示满足完成条件，多实例任务结束；false表示继续执行
*/
public boolean completionCondition(DelegateExecution execution) {
ExecutionEntityImpl entity = (ExecutionEntityImpl) execution;
String processDefinitionKey = entity.getProcessDefinitionKey();
String nodeId = execution.getCurrentActivityId();
- Node node = remoteFlowTaskService.queryNodeOriData(processDefinitionKey, nodeId).getData();
+ Node node = processNodeDataService.getNodeData(processDefinitionKey, nodeId).getData();
Integer multipleMode = node.getMultipleMode();
BigDecimal modePercentage = BigDecimal.valueOf(100);
diff --git a/pigx-flow/pigx-flow-engine/pigx-flow-engine-biz/src/main/java/com/pig4cloud/pigx/flow/engine/node/impl/AssignExpressStrategyImpl.java b/pigx-flow/pigx-flow-engine/pigx-flow-engine-biz/src/main/java/com/pig4cloud/pigx/flow/engine/node/impl/AssignExpressStrategyImpl.java
new file mode 100644
index 000000000..d94002bdc
--- /dev/null
+++ b/pigx-flow/pigx-flow-engine/pigx-flow-engine-biz/src/main/java/com/pig4cloud/pigx/flow/engine/node/impl/AssignExpressStrategyImpl.java
@@ -0,0 +1,90 @@
+package com.pig4cloud.pigx.flow.support.node.impl;
+
+import cn.hutool.core.convert.Convert;
+import cn.hutool.extra.spring.SpringUtil;
+import com.pig4cloud.pigx.flow.constant.ProcessInstanceConstant;
+import com.pig4cloud.pigx.flow.dto.Node;
+import com.pig4cloud.pigx.flow.dto.NodeUser;
+import com.pig4cloud.pigx.flow.support.node.AssignUserStrategy;
+import org.flowable.common.engine.api.delegate.Expression;
+import org.flowable.common.engine.api.variable.VariableContainer;
+import org.flowable.common.engine.impl.el.ExpressionManager;
+import org.flowable.common.engine.impl.variable.MapDelegateVariableContainer;
+import org.flowable.engine.ManagementService;
+import org.flowable.engine.impl.cfg.ProcessEngineConfigurationImpl;
+import org.flowable.engine.impl.util.CommandContextUtil;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 表达式分配用户策略实现类：将任务分配给流程发起人本人
+ *
+ * @author lengleng
+ * @date 2025/08/07
+ */
+@Component(ProcessInstanceConstant.AssignedTypeClass.EXPRESSION + "AssignUserStrategy")
+public class AssignExpressStrategyImpl implements AssignUserStrategy {
+
+ /**
+ * 处理发起人分配逻辑
+ *
+ * 直接返回流程发起人的用户ID，任务将分配给发起人本人。
+ * @param node 节点配置对象（本策略中未使用）
+ * @param rootUser 流程发起人信息，包含发起人的用户ID
+ * @param variables 流程变量（本策略中未使用）
+ * @return 包含发起人用户ID的列表
+ */
+ @Override
+ public List