From 7fab02dbb0c200f54bda5d124dc69c4df1f89869 Mon Sep 17 00:00:00 2001
From: wangli <274027703@qq.com>
Date: Tue, 5 Mar 2024 11:31:11 +0800
Subject: [PATCH] =?UTF-8?q?update=20-=20=E4=B8=9A=E5=8A=A1=E8=8A=82?=
 =?UTF-8?q?=E7=82=B9=E4=BA=8B=E4=BB=B6=E7=8A=B6=E6=80=81=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../event/ReceiveTaskExtInstCreateEvent.java  |  4 +--
 ...a => ReceiveTaskExtInstEventListener.java} | 27 ++++++++++---------
 2 files changed, 17 insertions(+), 14 deletions(-)
 rename workflow-engine-core/src/main/java/cn/axzo/workflow/core/listener/impl/{ReceiveTaskExtInstventListener.java => ReceiveTaskExtInstEventListener.java} (72%)

diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/event/ReceiveTaskExtInstCreateEvent.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/event/ReceiveTaskExtInstCreateEvent.java
index 67e4e4c9f..37cfe6fe3 100644
--- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/event/ReceiveTaskExtInstCreateEvent.java
+++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/event/ReceiveTaskExtInstCreateEvent.java
@@ -3,7 +3,7 @@ package cn.axzo.workflow.core.engine.event;
 import cn.axzo.workflow.common.enums.BpmnProcessInstanceResultEnum;
 import org.flowable.common.engine.api.delegate.event.FlowableEventType;
 
-import static cn.axzo.workflow.core.engine.event.ReceiveTaskEventType.COMPLETE;
+import static cn.axzo.workflow.core.engine.event.ReceiveTaskEventType.CREATE;
 
 /**
  * 接收任务的扩展任务记录表创建的事件实现
@@ -44,7 +44,7 @@ public class ReceiveTaskExtInstCreateEvent implements ReceiveTaskExtInstEvent {
 
     @Override
     public FlowableEventType getType() {
-        return COMPLETE;
+        return CREATE;
     }
 
 }
diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/listener/impl/ReceiveTaskExtInstventListener.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/listener/impl/ReceiveTaskExtInstEventListener.java
similarity index 72%
rename from workflow-engine-core/src/main/java/cn/axzo/workflow/core/listener/impl/ReceiveTaskExtInstventListener.java
rename to workflow-engine-core/src/main/java/cn/axzo/workflow/core/listener/impl/ReceiveTaskExtInstEventListener.java
index 995d086bc..48d8ae30e 100644
--- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/listener/impl/ReceiveTaskExtInstventListener.java
+++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/listener/impl/ReceiveTaskExtInstEventListener.java
@@ -2,6 +2,7 @@ package cn.axzo.workflow.core.listener.impl;
 
 import cn.axzo.workflow.core.engine.event.ReceiveTaskEventType;
 import cn.axzo.workflow.core.engine.event.ReceiveTaskExtInstCreateEvent;
+import cn.axzo.workflow.core.engine.event.ReceiveTaskExtInstEvent;
 import cn.axzo.workflow.core.repository.entity.ExtAxHiTaskInst;
 import cn.axzo.workflow.core.service.ExtAxHiTaskInstService;
 import com.google.common.collect.ImmutableSet;
@@ -26,7 +27,7 @@ import static cn.axzo.workflow.core.engine.event.ReceiveTaskEventType.CREATE;
 @AllArgsConstructor
 @Component
 @Slf4j
-public class ReceiveTaskExtInstventListener extends AbstractFlowableEventListener {
+public class ReceiveTaskExtInstEventListener extends AbstractFlowableEventListener {
     private final ExtAxHiTaskInstService extAxHiTaskInstService;
     public static final Set<ReceiveTaskEventType> SUPPORT_EVENTS =
             ImmutableSet.<ReceiveTaskEventType>builder()
@@ -36,17 +37,19 @@ public class ReceiveTaskExtInstventListener extends AbstractFlowableEventListene
 
     @Override
     public void onEvent(FlowableEvent flowableEvent) {
-        if (flowableEvent instanceof ReceiveTaskExtInstCreateEvent) {
-            ReceiveTaskExtInstCreateEvent event = (ReceiveTaskExtInstCreateEvent) flowableEvent;
-            ReceiveTaskEventType type = (ReceiveTaskEventType) event.getType();
-            switch (type) {
-                case CREATE:
-                    saveExtTaskInst(event);
-                    break;
-                case COMPLETE:
-                    updateExtTaskInst(event);
-                    break;
-                default:
+        if (flowableEvent instanceof ReceiveTaskExtInstEvent) {
+            ReceiveTaskExtInstEvent event = (ReceiveTaskExtInstEvent) flowableEvent;
+            ReceiveTaskEventType eventType = (ReceiveTaskEventType) flowableEvent.getType();
+            if (SUPPORT_EVENTS.contains(eventType)) {
+                switch (eventType) {
+                    case CREATE:
+                        saveExtTaskInst((ReceiveTaskExtInstCreateEvent) event);
+                        break;
+                    case COMPLETE:
+                        updateExtTaskInst((ReceiveTaskExtInstCreateEvent) event);
+                        break;
+                    default:
+                }
             }
         }
     }