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 e3aa812..319c8ca 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 @@ -56,7 +56,7 @@ public class CcTaskListener { @Async @EventListener - public void onApplicationEvent(CcTaskEvent event) { + public void onApplicationEvent(CcTaskEvent event) throws InterruptedException { log.info("进入抄送人任务 事件监听!{}", JSON.toJSONString(event)); String instCode = event.getInstCode(); String processDefinitionId = event.getProcessDefinitionId(); @@ -75,6 +75,8 @@ public class CcTaskListener { key.setExpire(Duration.ofMinutes(1)); cachePlusOps.set(key, nodeId); + Thread.sleep(3000); + log.info("instCode :{},nodeId :{}",instCode, nodeId); //1.去查找 项目实例关系表 List tasks = ccTasksService.list(Wrappers.lambdaQuery(WflowCcTasks.class)