mjava-ounuo/src/main/java/com/malk/tuosi/event/McTbEventImpl.java

@@ -21,7 +21,7 @@ public class McTbEventImpl implements TBEvent {
     @Autowired
     private TBClient tbClient;
 
-//    @Async
+    @Async
     @Override
     public void callBackTask(JSONObject eventJson) {
         String event = eventJson.getString("event");
@@ -41,6 +41,11 @@ public class McTbEventImpl implements TBEvent {
 //            }
             log.info("XXXXXX 进入节点更新流程，节点ID：{}，状态：{}，任务ID：{}",nodeId,status,taskId);
             if(status.equals("finish")){
+                try {
+                    Thread.sleep(3000);
+                }catch (InterruptedException e){
+                    e.printStackTrace();
+                }
                 List<Map> list=tbClient.queryNodeList(taskId);
                 Map node = _getNodeDetail(list,nodeId);
                 if(String.valueOf(node.get("name")).contains("接单")){
@@ -60,6 +65,11 @@ public class McTbEventImpl implements TBEvent {
                     return;
                 }
                 log.info("XXXXXX 接单开始，清空后续节点数据");
+                try {
+                    Thread.sleep(3000);
+                }catch (InterruptedException e){
+                    e.printStackTrace();
+                }
                 List<Map> list=tbClient.queryNodeList(taskId);
 //                Map node = _getNodeDetail(list,nodeId);
 //                if(String.valueOf(node.get("name")).contains("接单")){