From 1ed4ff7a93f0a4628dd86a8644e17d8c5fa79cbc Mon Sep 17 00:00:00 2001
From: PoffyZhang <99775271@qq.com>
Date: Mon, 3 Jul 2023 08:55:39 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=20=E5=B7=A5=E4=BD=9C?=
 =?UTF-8?q?=E6=B5=81=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/ningdatech/pmapi/scheduler/listener/CcTaskListener.java  | 4 +++-
 .../com/ningdatech/pmapi/scheduler/listener/ProcessStartListener.java | 1 +
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/pmapi/src/main/java/com/ningdatech/pmapi/scheduler/listener/CcTaskListener.java b/pmapi/src/main/java/com/ningdatech/pmapi/scheduler/listener/CcTaskListener.java
index 319c8ca..988b307 100644
--- a/pmapi/src/main/java/com/ningdatech/pmapi/scheduler/listener/CcTaskListener.java
+++ b/pmapi/src/main/java/com/ningdatech/pmapi/scheduler/listener/CcTaskListener.java
@@ -29,7 +29,7 @@ import java.util.Objects;
 import static com.ningdatech.pmapi.todocenter.constant.WorkNoticeContant.CC_MSG_TEMPLATE;
 
 /**
- * 工作流开始 事件监听
+ * 抄送事件 事件监听
  *
  * @author ZPF
  * @return
@@ -75,6 +75,7 @@ public class CcTaskListener {
         key.setExpire(Duration.ofMinutes(1));
         cachePlusOps.set(key, nodeId);
 
+        //睡3秒 让数据库 生成抄送数据先
         Thread.sleep(3000);
 
         log.info("instCode :{},nodeId :{}",instCode, nodeId);
@@ -89,6 +90,7 @@ public class CcTaskListener {
 
         log.info("tasks :{}",tasks.size());
 
+        //有可能 一个节点 有多个用户抄送
         tasks.stream().forEach(task -> {
             log.info("cc tasks :{}",JSON.toJSONString(tasks));
 
diff --git a/pmapi/src/main/java/com/ningdatech/pmapi/scheduler/listener/ProcessStartListener.java b/pmapi/src/main/java/com/ningdatech/pmapi/scheduler/listener/ProcessStartListener.java
index 4847e67..dc72110 100644
--- a/pmapi/src/main/java/com/ningdatech/pmapi/scheduler/listener/ProcessStartListener.java
+++ b/pmapi/src/main/java/com/ningdatech/pmapi/scheduler/listener/ProcessStartListener.java
@@ -76,6 +76,7 @@ public class ProcessStartListener {
                 .finished()
                 .list();
 
+        //如果 是没有审批任务的话 就需要 去调用状态机 进入下一个阶段
         if (CollUtil.isEmpty(tasks) && CollUtil.isEmpty(historyTasks)) {
             //如果真的没有实时任务和历史任务 那么说明 该项目没有人审批 需要去调用状态机
             Long projectId = projectInst.getProjectId();