|
@@ -170,7 +170,7 @@ public class SocketBufferServiceImpl implements SocketBufferService {
|
|
case 90://user event Order Complete 任务完成
|
|
case 90://user event Order Complete 任务完成
|
|
case 91://user event Loaded 取货完成
|
|
case 91://user event Loaded 取货完成
|
|
case 92://user event Delivered 卸货完成
|
|
case 92://user event Delivered 卸货完成
|
|
-// case 93://user event Redirect message for FETCH
|
|
|
|
|
|
+ case 93://user event Redirect message for FETCH
|
|
case 94://user event Redirect message for DELIVER
|
|
case 94://user event Redirect message for DELIVER
|
|
case 113://user event Fetch Empty
|
|
case 113://user event Fetch Empty
|
|
log.info("----event:" + eventId + ":" + JSON.toJSONString(event));
|
|
log.info("----event:" + eventId + ":" + JSON.toJSONString(event));
|
|
@@ -249,17 +249,6 @@ public class SocketBufferServiceImpl implements SocketBufferService {
|
|
log.error("车辆暂停反馈错误", e);
|
|
log.error("车辆暂停反馈错误", e);
|
|
}
|
|
}
|
|
break;
|
|
break;
|
|
- case 93:// 544
|
|
|
|
- log.info("申请空托!" + "-" + JSON.toJSONString(event));
|
|
|
|
- Integer index93 = Integer.parseInt(event.getLp1());
|
|
|
|
- AmsTask task93 = amsTaskService.selectAmsTaskByModel(index93);
|
|
|
|
- if (task93 != null) {
|
|
|
|
- executorService.execute(() -> {
|
|
|
|
- statusUpdateService.confirmAnalysis(task93.getTaskNo(), index93, icarNo
|
|
|
|
- , "09", "0001");
|
|
|
|
- });
|
|
|
|
- }
|
|
|
|
- break;
|
|
|
|
case 123: // 594
|
|
case 123: // 594
|
|
log.info("申请称重机!" + "-" + JSON.toJSONString(event));
|
|
log.info("申请称重机!" + "-" + JSON.toJSONString(event));
|
|
Integer index123 = Integer.parseInt(event.getLp1());
|
|
Integer index123 = Integer.parseInt(event.getLp1());
|