From 09235ed9bdf9afe142f2083c083f39a71a2c6809 Mon Sep 17 00:00:00 2001 From: AprilWind <2100166581@qq.com> Date: Tue, 3 Dec 2024 09:42:03 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E6=8F=90=E4=BA=A4=E7=AD=89=E5=BE=85?= =?UTF-8?q?=E6=96=B0=E7=89=88=E6=9C=AC=E5=BE=85=E4=BC=98=E5=8C=96=E7=9A=84?= =?UTF-8?q?=E5=BC=80=E5=A7=8B=E7=9B=91=E5=90=AC=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../workflow/listener/WorkflowStartListener.java | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/listener/WorkflowStartListener.java b/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/listener/WorkflowStartListener.java index f2b303193..8171c1f59 100644 --- a/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/listener/WorkflowStartListener.java +++ b/ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/listener/WorkflowStartListener.java @@ -2,14 +2,16 @@ package org.dromara.workflow.listener; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; +import org.dromara.common.core.domain.event.ProcessTaskEvent; import org.dromara.common.core.service.DeptService; +import org.dromara.common.core.utils.SpringUtils; import org.dromara.common.satoken.utils.LoginHelper; import org.dromara.warm.flow.core.dto.FlowParams; +import org.dromara.warm.flow.core.entity.Task; import org.dromara.warm.flow.core.listener.Listener; import org.dromara.warm.flow.core.listener.ListenerVariable; import org.springframework.stereotype.Component; -import java.util.HashMap; import java.util.Map; /** @@ -43,10 +45,16 @@ public class WorkflowStartListener implements Listener { log.info("流程启动监听器"); FlowParams flowParams = listenerVariable.getFlowParams(); // 获取当前部门的负责人 - Map variable = new HashMap<>(); Long leader = deptService.selectDeptLeaderById(LoginHelper.getDeptId()); - variable.put("deptLeader", leader); - flowParams.variable(variable); + flowParams.variable(Map.of("deptLeader", leader)); + Task task = listenerVariable.getTask(); + // 办理任务监听，记录任务执行信息 + ProcessTaskEvent processTaskEvent = new ProcessTaskEvent(); + processTaskEvent.setFlowCode(listenerVariable.getDefinition().getFlowCode()); + processTaskEvent.setNodeCode(task.getNodeCode()); + processTaskEvent.setTaskId(task.getId().toString()); + processTaskEvent.setBusinessKey(listenerVariable.getInstance().getBusinessId()); + SpringUtils.context().publishEvent(processTaskEvent); log.info("流程启动监听器结束;{}", "开启流程完成"); }