From cb864222bc6c94a39cc7186fc981df212c4818c3 Mon Sep 17 00:00:00 2001
From: wangli <274027703@qq.com>
Date: Mon, 20 Jan 2025 15:40:48 +0800
Subject: [PATCH] =?UTF-8?q?feat(REQ-3340)=20-=20=E8=B0=83=E6=95=B4=20Start?=
 =?UTF-8?q?er=20=E4=B8=AD=E5=85=B3=E4=BA=8E=E5=B9=BF=E6=92=AD=E4=BA=8B?=
 =?UTF-8?q?=E4=BB=B6=E7=9B=91=E5=90=AC=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../workflow/starter/handler/ProcessTaskEventHandler.java   | 6 ++++++
 .../mq/broadcast/consumer/InnerTaskEventListener.java       | 3 +++
 2 files changed, 9 insertions(+)

diff --git a/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/handler/ProcessTaskEventHandler.java b/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/handler/ProcessTaskEventHandler.java
index 9acdf7970..aa2db9e57 100644
--- a/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/handler/ProcessTaskEventHandler.java
+++ b/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/handler/ProcessTaskEventHandler.java
@@ -56,4 +56,10 @@ public interface ProcessTaskEventHandler extends Ordered {
      */
     default void onDeleted(ProcessTaskDTO dto) {
     }
+
+    /**
+     * 用户任务已转交
+     * @param dto
+     */
+    default void onTransfer(ProcessTaskDTO dto) {}
 }
diff --git a/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/mq/broadcast/consumer/InnerTaskEventListener.java b/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/mq/broadcast/consumer/InnerTaskEventListener.java
index 8b71e5c19..da5834898 100644
--- a/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/mq/broadcast/consumer/InnerTaskEventListener.java
+++ b/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/mq/broadcast/consumer/InnerTaskEventListener.java
@@ -57,6 +57,9 @@ public class InnerTaskEventListener extends AbstractInnerWorkflowListener<Proces
                 case PROCESS_TASK_DELETED:
                     consumer = taskListener::onDeleted;
                     break;
+                case PROCESS_TASK_TRANSFER:
+                    consumer = taskListener::onTransfer;
+                    break;
                 default:
                     log.warn("unknown task event type: {}", type);
             }