From 583d4f35a6c3ab9a760ce603e1d000687628603c Mon Sep 17 00:00:00 2001 From: PoffyZhang <99775271@qq.com> Date: Fri, 30 Jun 2023 17:34:34 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=9D=E5=AE=A1=E4=BA=BA=E5=91=98=20?= =?UTF-8?q?=E5=92=8C=20=E8=87=AA=E5=8A=A8=E4=B8=8B=E4=B8=80=E7=8A=B6?= =?UTF-8?q?=E6=80=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 +++- 1 file changed, 3 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 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)