From d0f89b791706f4d0e37415c818e29934a2354b1e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=86=B7=E5=86=B7?= Date: Tue, 29 Apr 2025 20:23:21 +0800 Subject: [PATCH] =?UTF-8?q?feat(flow-engine):=20=E5=AE=8C=E5=96=84Approval?= =?UTF-8?q?CreateListener=E4=BB=A3=E7=A0=81=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../listeners/ApprovalCreateListener.java | 70 ++++++++++++------- 1 file changed, 43 insertions(+), 27 deletions(-) diff --git a/pigx-flow/pigx-flow-engine/pigx-flow-engine-biz/src/main/java/com/pig4cloud/pigx/flow/engine/listeners/ApprovalCreateListener.java b/pigx-flow/pigx-flow-engine/pigx-flow-engine-biz/src/main/java/com/pig4cloud/pigx/flow/engine/listeners/ApprovalCreateListener.java index 5fbdc3989..54f076e8c 100644 --- a/pigx-flow/pigx-flow-engine/pigx-flow-engine-biz/src/main/java/com/pig4cloud/pigx/flow/engine/listeners/ApprovalCreateListener.java +++ b/pigx-flow/pigx-flow-engine/pigx-flow-engine-biz/src/main/java/com/pig4cloud/pigx/flow/engine/listeners/ApprovalCreateListener.java @@ -18,74 +18,90 @@ import org.flowable.task.service.impl.persistence.entity.TaskEntityImpl; /** * 审批创建监听器 + * 用于处理任务创建时的逻辑，特别是针对没有指定执行人的任务进行自动处理 + * 根据节点配置的"无人处理策略"执行不同的操作：自动通过、指派给管理员、指派给特定用户或自动拒绝 */ @Slf4j public class ApprovalCreateListener implements TaskListener { /** - * 当任务被触发时，执行该方法 - * @param delegateTask 委派的任务对象 + * 当任务被创建时触发该方法 + * 根据任务的配置和状态决定如何处理无人执行的任务 + * + * @param delegateTask 委派的任务对象，包含任务的所有信息 */ @Override public void notify(DelegateTask delegateTask) { - log.debug(delegateTask.getClass().getCanonicalName()); + log.debug("任务类型: {}", delegateTask.getClass().getCanonicalName()); TaskService taskService = SpringUtil.getBean(TaskService.class); - String assignee = delegateTask.getAssignee(); - String name = delegateTask.getName(); - log.debug("任务{}-执行人:{}", name, assignee); - TaskEntityImpl taskEntity = (TaskEntityImpl) delegateTask; - String nodeId = taskEntity.getTaskDefinitionKey(); - String processDefinitionId = taskEntity.getProcessDefinitionId(); + // 获取任务的基本信息 + String assignee = delegateTask.getAssignee(); // 执行人 + String name = delegateTask.getName(); // 任务名称 + log.debug("任务创建事件 - 任务名称:{}, 执行人:{}", name, assignee); - // 获取流程id + // 转换为TaskEntity以获取更多信息 + TaskEntityImpl taskEntity = (TaskEntityImpl) delegateTask; + String nodeId = taskEntity.getTaskDefinitionKey(); // 节点ID + String processDefinitionId = taskEntity.getProcessDefinitionId(); // 流程定义ID + + // 从流程定义ID中提取流程ID String flowId = NodeUtil.getFlowId(processDefinitionId); + // 判断任务是否没有分配执行人或执行人为空标记 + // 如果没有执行人，需要根据无人处理策略决定下一步操作 if (StrUtil.isBlank(assignee) || StrUtil.equals(ProcessInstanceConstant.DEFAULT_EMPTY_ASSIGN.toString(), assignee)) { + log.debug("任务无执行人，开始处理无人执行策略"); RemoteFlowTaskService remoteFlowTaskService = SpringUtil.getBean(RemoteFlowTaskService.class); - // 查询节点原始数据 + // 查询节点原始配置数据，获取无人处理策略 Node node = remoteFlowTaskService.queryNodeOriData(flowId, nodeId).getData(); + Nobody nobody = node.getNobody(); // 获取无人处理配置 + String handler = nobody.getHandler(); // 获取无人处理的处理方式 - Nobody nobody = node.getNobody(); - - String handler = nobody.getHandler(); - + // 根据无人处理策略执行不同操作 + // 策略1: 自动通过任务 if (StrUtil.equals(handler, ProcessInstanceConstant.USER_TASK_NOBODY_HANDLER_TO_PASS)) { - // 直接通过 + log.info("无人处理策略: 自动通过 - 任务ID: {}", taskEntity.getId()); + // 设置条件变量为true并完成任务，让流程继续执行 Dict param = Dict.create().set(StrUtil.format("{}_approve_condition", nodeId), true); taskService.complete(taskEntity.getId(), param); } + // 策略2: 指派给管理员 if (StrUtil.equals(handler, ProcessInstanceConstant.USER_TASK_NOBODY_HANDLER_TO_ADMIN)) { - // 指派给管理员 - + log.info("无人处理策略: 指派给管理员 - 任务ID: {}", taskEntity.getId()); + // 查询流程的管理员ID R longR = remoteFlowTaskService.queryProcessAdmin(flowId); - Long adminId = longR.getData(); + // 将任务分配给管理员 taskService.setAssignee(taskEntity.getId(), String.valueOf(adminId)); + log.debug("任务已指派给管理员, 管理员ID: {}", adminId); } + // 策略3: 指派给特定用户 if (StrUtil.equals(handler, ProcessInstanceConstant.USER_TASK_NOBODY_HANDLER_TO_USER)) { - // 指定用户 - + log.info("无人处理策略: 指派给特定用户 - 任务ID: {}", taskEntity.getId()); + // 获取配置中指定的用户 NodeUser nodeUser = nobody.getAssignedUser().get(0); + // 将任务分配给指定用户 taskService.setAssignee(taskEntity.getId(), nodeUser.getId().toString()); + log.debug("任务已指派给特定用户, 用户ID: {}", nodeUser.getId()); } + // 策略4: 自动拒绝任务 if (StrUtil.equals(handler, ProcessInstanceConstant.USER_TASK_NOBODY_HANDLER_TO_REFUSE)) { - // 结束 + log.info("无人处理策略: 自动拒绝 - 任务ID: {}", taskEntity.getId()); + // 设置条件变量为false并完成任务，通常会导致流程走向拒绝分支 Dict param = Dict.create().set(StrUtil.format("{}_approve_condition", nodeId), false); taskService.complete(taskEntity.getId(), param); - } - + } else { + log.debug("任务已有执行人，无需处理无人执行策略"); } - } - -} +} \ No newline at end of file