Преглед на файлове

重启再次调用时debug问题修改

yejian преди 3 години
родител
ревизия
e6f484f9d2
променени са 1 файла, в които са добавени 2 реда и са изтрити 1 реда
  1. 2 1
      imcs-admin-boot/imcs-business-biz/src/main/java/com/github/zuihou/business/mq/TaskWorkNode.java

+ 2 - 1
imcs-admin-boot/imcs-business-biz/src/main/java/com/github/zuihou/business/mq/TaskWorkNode.java

@@ -166,7 +166,7 @@ public class TaskWorkNode {
         BaseContextHandler.setTenant("0000");
 
         TaskNode taskNode = taskNodeService.getById(taskNodeId);
-        TaskNode beforTaskNode = taskNodeService.getNextNTaskNode(taskNode,-1);
+//
         if (taskNode == null || taskNode.getTaskId()== null) {
             throw new InterruptedException("当前任务节点为空");
         }
@@ -236,6 +236,7 @@ public class TaskWorkNode {
                 Map conMap = checkCon(taskNode, tTask, queryMap);
 
                 if("03".equals(taskNode.getInterfaceType())){
+                    TaskNode beforTaskNode = taskNodeService.getNextNTaskNode(taskNode,-1);
                     // agv搬运
                     Map agvData = new HashMap();
                     agvData.put("start",beforTaskNode.getTargetResourceId());