From 40101e1766a04cc82076556783ada6e1a7711b93 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期日, 06 七月 2025 16:55:49 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/ShuttleController.java |   29 +++++++++++++++++++----------
 1 files changed, 19 insertions(+), 10 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/ShuttleController.java b/src/main/java/com/zy/asrs/controller/ShuttleController.java
index ae43aa2..f9b68ff 100644
--- a/src/main/java/com/zy/asrs/controller/ShuttleController.java
+++ b/src/main/java/com/zy/asrs/controller/ShuttleController.java
@@ -2,6 +2,7 @@
 
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.core.annotations.ManagerAuth;
 import com.core.common.BaseRes;
 import com.core.common.Cools;
@@ -10,8 +11,10 @@
 import com.zy.asrs.domain.param.ShuttleOperatorParam;
 import com.zy.asrs.domain.vo.*;
 import com.zy.asrs.entity.BasShuttle;
+import com.zy.asrs.entity.DeviceConfig;
 import com.zy.asrs.entity.WrkMast;
 import com.zy.asrs.service.BasShuttleService;
+import com.zy.asrs.service.DeviceConfigService;
 import com.zy.asrs.service.LocMastService;
 import com.zy.asrs.service.WrkMastService;
 import com.zy.asrs.utils.Utils;
@@ -51,8 +54,6 @@
 public class ShuttleController {
 
     @Autowired
-    private SlaveProperties slaveProperties;
-    @Autowired
     private BasShuttleService basShuttleService;
     @Autowired
     private WrkMastService wrkMastService;
@@ -70,18 +71,23 @@
     private ShuttleAction shuttleAction;
     @Autowired
     private NavigateMapUtils navigateMapUtils;
+    @Autowired
+    private DeviceConfigService deviceConfigService;
 
     @PostMapping("/table/shuttle/state")
     @ManagerAuth(memo = "鍥涘悜绌挎杞︿俊鎭〃")
     public R shuttleStateTable(){
         ArrayList<JSONObject> list = new ArrayList<>();
-        for (ShuttleSlave slave : slaveProperties.getShuttle()) {
+
+        List<DeviceConfig> shuttleList = deviceConfigService.selectList(new EntityWrapper<DeviceConfig>()
+                .eq("device_type", String.valueOf(SlaveType.Shuttle)));
+        for (DeviceConfig deviceConfig : shuttleList) {
             // 琛ㄦ牸琛�
             JSONObject baseObj = new JSONObject();
-            baseObj.put("shuttleNo", slave.getId());
+            baseObj.put("shuttleNo", deviceConfig.getDeviceNo());
             list.add(baseObj);
             // 鑾峰彇鍥涘悜绌挎杞︿俊鎭�
-            ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, slave.getId());
+            ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, deviceConfig.getDeviceNo());
             if (shuttleThread == null) {
                 continue;
             }
@@ -104,7 +110,7 @@
                 }
             }
 
-            Integer chargeLine = basShuttleService.selectById(slave.getId()).getChargeLine();
+            Integer chargeLine = basShuttleService.selectById(deviceConfig.getDeviceNo()).getChargeLine();
             String lowerPower = "N";
             if (chargeLine != null && shuttleProtocol.getBatteryPower() != null) {
                 lowerPower = Integer.parseInt(shuttleProtocol.getBatteryPower()) <= chargeLine ? "Y" : "N";
@@ -119,13 +125,16 @@
     @ManagerAuth(memo = "鍥涘悜绌挎杞︽暟鎹〃")
     public R steMsgTable(){
         List<ShuttleMsgTableVo> list = new ArrayList<>();
-        for (ShuttleSlave slave : slaveProperties.getShuttle()) {
+
+        List<DeviceConfig> shuttleList = deviceConfigService.selectList(new EntityWrapper<DeviceConfig>()
+                .eq("device_type", String.valueOf(SlaveType.Shuttle)));
+        for (DeviceConfig deviceConfig : shuttleList) {
             // 琛ㄦ牸琛�
             ShuttleMsgTableVo vo = new ShuttleMsgTableVo();
-            vo.setShuttleNo(slave.getId());   //  鍥涘悜绌挎杞﹀彿
+            vo.setShuttleNo(deviceConfig.getDeviceNo());   //  鍥涘悜绌挎杞﹀彿
             list.add(vo);
             // 鑾峰彇绌挎杞︿俊鎭�
-            ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, slave.getId());
+            ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, deviceConfig.getDeviceNo());
             if (shuttleThread == null) {
                 continue;
             }
@@ -152,7 +161,7 @@
             vo.setLocNo(shuttleProtocol.getLocNo());//鍥涘悜绌挎杞﹀綋鍓嶅簱浣嶅彿
             vo.setLev(shuttleProtocol.getLocNo() == null ? 0 : Utils.getLev(shuttleProtocol.getLocNo()));//鍥涘悜绌挎杞﹀綋鍓嶅眰楂�
 
-            BasShuttle basShuttle = basShuttleService.selectById(slave.getId());
+            BasShuttle basShuttle = basShuttleService.selectById(deviceConfig.getDeviceNo());
             if (basShuttle != null) {
                 vo.setChargeLine(basShuttle.getChargeLine());//鍏呯數闃堝��
             }

--
Gitblit v1.9.1