优化 工作流代码

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));
 

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();