|
@@ -1611,7 +1611,7 @@ public class TaskNodeServiceImpl extends SuperServiceImpl<TaskNodeMapper, TaskNo
|
|
|
List<Storge> storgeList = storgeService.list(Wraps.<Storge>lbQ().eq(Storge::getCampId, taskNode.getId()));
|
|
|
List<String> storgePoints = storgeList.stream().map(p -> p.getPointId()).collect(Collectors.toList());
|
|
|
if (CollectionUtil.isNotEmpty(storgeList)) {
|
|
|
- logger.info("节点{}开始释放占用的资源{}", taskNode.getId(),storgePoints.toString());
|
|
|
+ logger.info("节点{}工步{}开始释放占用的资源{}", taskNode.getId(),robotStep,storgePoints.toString());
|
|
|
storgeService.unlockStorgeList(storgeList);
|
|
|
}
|
|
|
}else{
|
|
@@ -1622,7 +1622,7 @@ public class TaskNodeServiceImpl extends SuperServiceImpl<TaskNodeMapper, TaskNo
|
|
|
List<Storge> storgeList = storgeService.list(Wraps.<Storge>lbQ().eq(Storge::getCampId, taskNode.getId()));
|
|
|
List<String> storgePoints = storgeList.stream().map(p -> p.getPointId()).collect(Collectors.toList());
|
|
|
if (CollectionUtil.isNotEmpty(storgeList)) {
|
|
|
- logger.info("节点{}开始释放占用的资源{}", taskNode.getId(),storgePoints.toString());
|
|
|
+ logger.info("节点{}工步{}开始释放占用的资源{}", taskNode.getId(),robotStep,storgePoints.toString());
|
|
|
storgeService.unlockStorgeList(storgeList);
|
|
|
}
|
|
|
}
|
|
@@ -1632,7 +1632,7 @@ public class TaskNodeServiceImpl extends SuperServiceImpl<TaskNodeMapper, TaskNo
|
|
|
List<Storge> storgeList = storgeService.list(Wraps.<Storge>lbQ().eq(Storge::getCampId, taskNode.getId()));
|
|
|
List<String> storgePoints = storgeList.stream().map(p -> p.getPointId()).collect(Collectors.toList());
|
|
|
if (CollectionUtil.isNotEmpty(storgeList)) {
|
|
|
- logger.info("节点{}开始释放占用的资源{}", taskNode.getId(),storgePoints.toString());
|
|
|
+ logger.info("节点{}工步{}开始释放占用的资源{}", taskNode.getId(),robotStep,storgePoints.toString());
|
|
|
storgeService.unlockStorgeList(storgeList);
|
|
|
}
|
|
|
}
|
|
@@ -1649,7 +1649,7 @@ public class TaskNodeServiceImpl extends SuperServiceImpl<TaskNodeMapper, TaskNo
|
|
|
List<Storge> storgeList = storgeService.list(Wraps.<Storge>lbQ().eq(Storge::getCampId, taskNode.getId()));
|
|
|
List<String> storgePoints = storgeList.stream().map(p -> p.getPointId()).collect(Collectors.toList());
|
|
|
if (CollectionUtil.isNotEmpty(storgeList)) {
|
|
|
- logger.info("节点{}开始释放占用的资源{}", taskNode.getId(),storgePoints.toString());
|
|
|
+ logger.info("节点{}工步{}开始释放占用的资源{}", taskNode.getId(),robotStep,storgePoints.toString());
|
|
|
storgeService.unlockStorgeList(storgeList);
|
|
|
}
|
|
|
}
|
|
@@ -1660,7 +1660,7 @@ public class TaskNodeServiceImpl extends SuperServiceImpl<TaskNodeMapper, TaskNo
|
|
|
List<Storge> storgeList = storgeService.list(Wraps.<Storge>lbQ().eq(Storge::getCampId, taskNode.getId()));
|
|
|
List<String> storgePoints = storgeList.stream().map(p -> p.getPointId()).collect(Collectors.toList());
|
|
|
if (CollectionUtil.isNotEmpty(storgeList)) {
|
|
|
- logger.info("节点{}开始释放占用的资源{}", taskNode.getId(),storgePoints.toString());
|
|
|
+ logger.info("节点{}工步{}开始释放占用的资源{}", taskNode.getId(),robotStep,storgePoints.toString());
|
|
|
storgeService.unlockStorgeList(storgeList);
|
|
|
}
|
|
|
}else{
|