From f3c1bcfe1fe4b432b3f212883b5ab0141393150d Mon Sep 17 00:00:00 2001
From: wangli <274027703@qq.com>
Date: Sun, 8 Oct 2023 18:18:47 +0800
Subject: [PATCH] =?UTF-8?q?update=20-=20=E8=B0=83=E6=95=B4=E5=B7=A5?=
 =?UTF-8?q?=E4=BD=9C=E6=B5=81=E5=86=85=E9=83=A8=E7=9A=84=E4=B8=80=E4=BA=9B?=
 =?UTF-8?q?=E5=85=B3=E4=BA=8E=E4=BA=BA=E7=9A=84=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ...istener.java => SnapshotBpmTaskTaskEventListener.java} | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)
 rename workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/{CustomBpmTaskTaskEventListener.java => SnapshotBpmTaskTaskEventListener.java} (80%)

diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/CustomBpmTaskTaskEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/SnapshotBpmTaskTaskEventListener.java
similarity index 80%
rename from workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/CustomBpmTaskTaskEventListener.java
rename to workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/SnapshotBpmTaskTaskEventListener.java
index ef21db591..9c55123d8 100644
--- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/CustomBpmTaskTaskEventListener.java
+++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/SnapshotBpmTaskTaskEventListener.java
@@ -14,7 +14,7 @@ import static cn.axzo.workflow.common.constant.BpmConstants.INTERNAL_TASK_RELATI
 import static cn.axzo.workflow.common.constant.BpmConstants.INTERNAL_TASK_RELATION_ASSIGNEE_LIST_INFO_SNAPSHOT;
 
 /**
- * 自定义实现的流程监听器, 实现了 Ordered 接口
+ * 任务节点关联的处理人快照保持
  * <p>
  * 注意:Order 值越小,优先级越高
  *
@@ -23,7 +23,7 @@ import static cn.axzo.workflow.common.constant.BpmConstants.INTERNAL_TASK_RELATI
  */
 @Slf4j
 @Component
-public class CustomBpmTaskTaskEventListener implements BpmTaskEventListener {
+public class SnapshotBpmTaskTaskEventListener implements BpmTaskEventListener {
 
     @Override
     public void onAssigned(DelegateTask delegateTask) {
@@ -33,12 +33,10 @@ public class CustomBpmTaskTaskEventListener implements BpmTaskEventListener {
             return;
         }
         // identityId_identityType
-        String assignee = delegateTask.getAssignee();
-        assignerList.stream().filter(i -> Objects.equals(assignee, i.buildAssigneeId())).findFirst().ifPresent(i -> {
+        assignerList.stream().filter(i -> Objects.equals(delegateTask.getAssignee(), i.buildAssigneeId())).findFirst().ifPresent(i -> {
             // 保存每个 taskId 的审批人
             delegateTask.setVariable(INTERNAL_TASK_RELATION_ASSIGNEE_INFO_SNAPSHOT + delegateTask.getId(), i);
         });
-        log.info("task assigned...");
     }
 
     @Override