From ba652ffedfc63a6d0d3c48b02d67ca2235b41d92 Mon Sep 17 00:00:00 2001
From: yangwei <867012372@qq.com>
Date: Sat, 1 Mar 2025 17:28:10 +0800
Subject: [PATCH] =?UTF-8?q?[feat]=201=E3=80=81=E4=BF=AE=E5=A4=8D=E5=B7=A5?=
 =?UTF-8?q?=E4=BD=9C=E6=B5=81=E6=97=A0=E6=B3=95=E6=8E=A8=E9=80=81=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../org/dromara/common/sse/listener/SseTopicListener.java   | 2 ++
 .../java/org/dromara/workflow/handler/FlwAlertHandler.java  | 6 +++---
 .../dromara/workflow/service/impl/TestLeaveServiceImpl.java | 6 +++---
 3 files changed, 8 insertions(+), 6 deletions(-)

diff --git a/dk-common/common-sse/src/main/java/org/dromara/common/sse/listener/SseTopicListener.java b/dk-common/common-sse/src/main/java/org/dromara/common/sse/listener/SseTopicListener.java
index 7a4dff1..9adf1a1 100644
--- a/dk-common/common-sse/src/main/java/org/dromara/common/sse/listener/SseTopicListener.java
+++ b/dk-common/common-sse/src/main/java/org/dromara/common/sse/listener/SseTopicListener.java
@@ -7,6 +7,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.ApplicationArguments;
 import org.springframework.boot.ApplicationRunner;
 import org.springframework.core.Ordered;
+import org.springframework.stereotype.Component;
 
 /**
  * SSE 主题订阅监听器
@@ -14,6 +15,7 @@ import org.springframework.core.Ordered;
  * @author Lion Li
  */
 @Slf4j
+@Component
 public class SseTopicListener implements ApplicationRunner, Ordered {
 
     @Autowired
diff --git a/dk-modules/workflow/src/main/java/org/dromara/workflow/handler/FlwAlertHandler.java b/dk-modules/workflow/src/main/java/org/dromara/workflow/handler/FlwAlertHandler.java
index 2fb3921..0e4dfbc 100644
--- a/dk-modules/workflow/src/main/java/org/dromara/workflow/handler/FlwAlertHandler.java
+++ b/dk-modules/workflow/src/main/java/org/dromara/workflow/handler/FlwAlertHandler.java
@@ -28,7 +28,7 @@ public class FlwAlertHandler implements FlwCommonHandler {
      *
      * @param processEvent 参数
      */
-    @EventListener(condition = "#processEvent.flowCode.startsWith('leave')")
+    @EventListener(condition = "#processEvent.flowCode.startsWith('alert')")
     @Override
     public void processHandler(ProcessEvent processEvent) {
         alertService.updateAlertStatus(processEvent.getBusinessId(),processEvent.getStatus());
@@ -40,7 +40,7 @@ public class FlwAlertHandler implements FlwCommonHandler {
      *
      * @param processCreateTaskEvent 参数
      */
-    @EventListener(condition = "#processCreateTaskEvent.flowCode.startsWith('leave')")
+    @EventListener(condition = "#processCreateTaskEvent.flowCode.startsWith('alert')")
     @Override
     public void processCreateTaskHandler(ProcessCreateTaskEvent processCreateTaskEvent) {
         alertService.updateAlertStatus(processCreateTaskEvent.getBusinessId(), BusinessStatusEnum.WAITING.getStatus());
@@ -52,7 +52,7 @@ public class FlwAlertHandler implements FlwCommonHandler {
      *
      * @param processDeleteEvent 参数
      */
-    @EventListener(condition = "#processDeleteEvent.flowCode.startsWith('leave')")
+    @EventListener(condition = "#processDeleteEvent.flowCode.startsWith('alert')")
     @Override
     public void processDeleteHandler(ProcessDeleteEvent processDeleteEvent) {
 
diff --git a/dk-modules/workflow/src/main/java/org/dromara/workflow/service/impl/TestLeaveServiceImpl.java b/dk-modules/workflow/src/main/java/org/dromara/workflow/service/impl/TestLeaveServiceImpl.java
index 03b21c3..858f7c2 100644
--- a/dk-modules/workflow/src/main/java/org/dromara/workflow/service/impl/TestLeaveServiceImpl.java
+++ b/dk-modules/workflow/src/main/java/org/dromara/workflow/service/impl/TestLeaveServiceImpl.java
@@ -130,7 +130,7 @@ public class TestLeaveServiceImpl implements ITestLeaveService {
      *
      * @param processEvent 参数
      */
-//    @EventListener(condition = "#processEvent.flowCode.startsWith('leave')")
+    @EventListener(condition = "#processEvent.flowCode.startsWith('leave')")
     public void processHandler(ProcessEvent processEvent) {
         TenantHelper.dynamic(processEvent.getTenantId(), () -> {
             log.info("当前任务执行了{}", processEvent.toString());
@@ -163,7 +163,7 @@ public class TestLeaveServiceImpl implements ITestLeaveService {
      *
      * @param processCreateTaskEvent 参数
      */
-//    @EventListener(condition = "#processCreateTaskEvent.flowCode.startsWith('leave')")
+    @EventListener(condition = "#processCreateTaskEvent.flowCode.startsWith('leave')")
     public void processCreateTaskHandler(ProcessCreateTaskEvent processCreateTaskEvent) {
         TenantHelper.dynamic(processCreateTaskEvent.getTenantId(), () -> {
             log.info("当前任务创建了{}", processCreateTaskEvent.toString());
@@ -180,7 +180,7 @@ public class TestLeaveServiceImpl implements ITestLeaveService {
      *
      * @param processDeleteEvent 参数
      */
-//    @EventListener(condition = "#processDeleteEvent.flowCode.startsWith('leave')")
+    @EventListener(condition = "#processDeleteEvent.flowCode.startsWith('leave')")
     public void processDeleteHandler(ProcessDeleteEvent processDeleteEvent) {
         TenantHelper.dynamic(processDeleteEvent.getTenantId(), () -> {
             log.info("监听删除流程事件，当前任务执行了{}", processDeleteEvent.toString());