From 16ed2580b1c43e2cb6cc902fdb1cf1b847e5ddb7 Mon Sep 17 00:00:00 2001
From: javami888 <53815784+javami888@users.noreply.github.com>
Date: Thu, 30 Apr 2026 16:17:09 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0agv=E7=8A=B6=E6=80=81?=
 =?UTF-8?q?=E5=9B=9E=E4=BC=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/KitToAcsServiceImpl.java     | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

diff --git a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/extInterface/agvKit/service/impl/KitToAcsServiceImpl.java b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/extInterface/agvKit/service/impl/KitToAcsServiceImpl.java
index 9e53a27..5294468 100644
--- a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/extInterface/agvKit/service/impl/KitToAcsServiceImpl.java
+++ b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/extInterface/agvKit/service/impl/KitToAcsServiceImpl.java
@@ -19,6 +19,7 @@ import org.nl.extInterface.agvKit.service.KitToAcsService;
 import org.nl.extInterface.agvKit.service.enums.MsgTypeEnum;
 import org.nl.extInterface.agvKit.service.enums.TaskPhaseEnum;
 import org.nl.extInterface.agvKit.service.enums.TaskStateEnum;
+import org.nl.extInterface.wms.service.AcsToWmsService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -32,6 +33,8 @@ public class KitToAcsServiceImpl implements KitToAcsService {
     private StorageCellService storageCellService;
     @Autowired
     private DeviceAppService deviceAppService;
+    @Autowired
+    private AcsToWmsService acsToWmsService;
 
     @Override
     public JSONObject agvCallback(JSONObject requestParam) throws Exception{
@@ -176,6 +179,22 @@ public class KitToAcsServiceImpl implements KitToAcsService {
             log.info("---kit响应请求---{}", resp);
             return resp;
         } else if (MsgTypeEnum.AGV_STATE_RPT.getValue().equals(type)){
+            String deviceCode = StrUtil.blankToDefault(params.getString("deviceCode"), params.getString("agvId"));
+            Integer status = params.getInteger("status");
+            String statusDescription = params.getString("statusDescription");
+            if (StrUtil.isEmpty(deviceCode) || status == null) {
+                resp.put("code", "400");
+                resp.put("message", "AGV状态上报参数异常");
+                log.info("---kit响应请求---{}", resp);
+                return resp;
+            }
+            boolean success = acsToWmsService.deviceStatusUpdate(deviceCode, status, statusDescription);
+            if (!success) {
+                resp.put("code", "400");
+                resp.put("message", "回馈WMS设备状态失败");
+                log.info("---kit响应请求---{}", resp);
+                return resp;
+            }
             resp.put("code", "200");
             resp.put("message", "更新指令执行中成功");
             log.info("---kit响应请求---{}", resp);