From 57f9825443e9aaffd41655245fee8287f80b52bb Mon Sep 17 00:00:00 2001
From: vincentlu <t1341870251@gmail.com>
Date: 星期五, 26 十二月 2025 16:16:37 +0800
Subject: [PATCH] #
---
zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java | 24 +++++++++++++++++++++---
1 files changed, 21 insertions(+), 3 deletions(-)
diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java
index 554082d..fbf9ac5 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/MainService.java
@@ -2,19 +2,19 @@
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.zy.acs.common.constant.RedisConstant;
import com.zy.acs.common.domain.AgvAction;
import com.zy.acs.common.domain.AgvActionItem;
import com.zy.acs.common.domain.AgvProtocol;
import com.zy.acs.common.domain.BaseResult;
-import com.zy.acs.common.domain.protocol.AGV_11_UP;
-import com.zy.acs.common.domain.protocol.AGV_70_UP;
-import com.zy.acs.common.domain.protocol.IMessageBody;
+import com.zy.acs.common.domain.protocol.*;
import com.zy.acs.common.domain.protocol.action.*;
import com.zy.acs.common.enums.AgvBackpackType;
import com.zy.acs.common.enums.AgvCompleteType;
import com.zy.acs.common.enums.AgvDirectionType;
import com.zy.acs.common.enums.AgvSpeedType;
import com.zy.acs.common.utils.GsonUtils;
+import com.zy.acs.common.utils.RedisSupport;
import com.zy.acs.common.utils.Utils;
import com.zy.acs.framework.common.Cools;
import com.zy.acs.framework.common.SnowflakeIdWorker;
@@ -49,6 +49,8 @@
@Slf4j
@Service("mainService")
public class MainService {
+
+ private final RedisSupport redis = RedisSupport.defaultRedisSupport;
@Autowired
private BusService busService;
@@ -1459,6 +1461,22 @@
}
}
+ // 鍙栨斁璐ц姹傚寘
+ if (msgBody instanceof AGV_06_UP) {
+ AGV_06_UP agv_06_up = (AGV_06_UP) msgBody;
+
+ log.info("Agv [{}] 鍙栨斁璐ц姹傚寘 ===>> {}", protocol.getAgvNo(), JSON.toJSONString(agv_06_up));
+
+ // todo:vincent 鏍￠獙鏄惁鍙互鍙栨斁璐�
+
+ AGV_06_DOWN agv_06_down = new AGV_06_DOWN();
+ agv_06_down.setSerialNo(agv_06_up.getSerialNo());
+ agv_06_down.setActionCode(agv_06_up.getActionCode());
+ agv_06_down.setResult(1);
+
+ redis.push(RedisConstant.AGV_PATH_DOWN_FLAG, AgvProtocol.build(protocol.getAgvNo()).setMessageBody(agv_06_down));
+ }
+
// 鏂欎粨淇℃伅鍖�
if (msgBody instanceof AGV_70_UP) {
AGV_70_UP agv_70_up = (AGV_70_UP) msgBody;
--
Gitblit v1.9.1