|
|
@@ -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<WflowCcTasks> tasks = ccTasksService.list(Wrappers.lambdaQuery(WflowCcTasks.class) |
|
|
|