|
@@ -2,14 +2,12 @@ package com.ruoyi.ams.agv.ndc.service.impl;
|
|
|
|
|
|
import cn.hutool.json.JSONUtil;
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
-import com.google.common.collect.Lists;
|
|
|
import com.ruoyi.ams.agv.ndc.common.Aci;
|
|
|
import com.ruoyi.ams.agv.ndc.common.ByteUtil;
|
|
|
import com.ruoyi.ams.agv.ndc.domain.AmsNdcEvent;
|
|
|
import com.ruoyi.ams.agv.ndc.domain.AmsTask;
|
|
|
import com.ruoyi.ams.agv.ndc.entity.Order;
|
|
|
import com.ruoyi.ams.agv.ndc.service.*;
|
|
|
-import com.ruoyi.common.core.domain.BaseEntity;
|
|
|
import com.ruoyi.common.core.redis.RedisCache;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
@@ -268,12 +266,12 @@ public class SocketBufferServiceImpl implements SocketBufferService {
|
|
|
|
|
|
}
|
|
|
break;
|
|
|
- case 126:
|
|
|
+ case 126:
|
|
|
log.info("the open request of belt gate is begining, the event info is: {}", JSONUtil.toJsonStr(event));
|
|
|
executorService.execute(() -> {
|
|
|
statusUpdateService.openBeltGate(event);
|
|
|
});
|
|
|
- case 127:
|
|
|
+ case 127:
|
|
|
log.info("the close request of belt gate is begining, the event info is: {}", JSONUtil.toJsonStr(event));
|
|
|
executorService.execute(() -> {
|
|
|
statusUpdateService.closeBeltGate(event);
|