From adf71f92c6a16231d08d47a80826f7a37e3ce047 Mon Sep 17 00:00:00 2001
From: 野心家 <1051256694@qq.com>
Date: 星期三, 20 九月 2023 08:56:10 +0800
Subject: [PATCH] 优化移深库位,自动移浅库位

---
 src/main/java/com/zy/asrs/controller/SiteController.java |   52 ++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 50 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/SiteController.java b/src/main/java/com/zy/asrs/controller/SiteController.java
index 30500f8..165174a 100644
--- a/src/main/java/com/zy/asrs/controller/SiteController.java
+++ b/src/main/java/com/zy/asrs/controller/SiteController.java
@@ -15,7 +15,8 @@
 import com.zy.core.model.Task;
 import com.zy.core.model.protocol.StaProtocol;
 import com.zy.core.properties.SlaveProperties;
-import com.zy.core.thread.DevpThread;
+import com.zy.core.DevpThread;
+import com.zy.core.thread.SiemensDevpThread;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
@@ -36,6 +37,41 @@
     private SlaveProperties slaveProperties;
     @Autowired
     private BasDevpService basDevpService;
+
+    @GetMapping("/io/mode/info/site")
+    @ManagerAuth(memo = "鍏ュ嚭搴撴ā寮�")
+    public R ioMode(){
+        List<Map<String, Object>> res = new ArrayList<>();
+        for (DevpSlave devp : slaveProperties.getDevp()) {
+            SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
+            if (devp.getId() == 1) {
+                Map<String, Object> map1 = new HashMap<>();
+                map1.put("floor", 1);
+                map1.put("modeVal", devpThread.ioModeOf1F.id);
+                map1.put("modeDesc", devpThread.ioModeOf1F.desc);
+                res.add(map1);
+
+                Map<String, Object> map2 = new HashMap<>();
+                map2.put("floor", 2);
+                map2.put("modeVal", devpThread.ioModeOf2F.id);
+                map2.put("modeDesc", devpThread.ioModeOf2F.desc);
+                res.add(map2);
+
+                Map<String, Object> map3 = new HashMap<>();
+                map3.put("floor", 3);
+                map3.put("modeVal", devpThread.ioModeOf3F.id);
+                map3.put("modeDesc", devpThread.ioModeOf3F.desc);
+                res.add(map3);
+
+                Map<String, Object> map4 = new HashMap<>();
+                map4.put("floor", 4);
+                map4.put("modeVal", devpThread.ioModeOf4F.id);
+                map4.put("modeDesc", devpThread.ioModeOf4F.desc);
+                res.add(map4);
+            }
+        }
+        return R.ok().add(res);
+    }
 
     @PostMapping("/table/site")
     @ManagerAuth(memo = "绔欑偣淇℃伅琛�")
@@ -63,6 +99,8 @@
             vo.setPakMk(staProtocol.isPakMk()?"Y":"N");       // 鍏ュ簱鏍囪
             vo.setEmptyMk(staProtocol.isEmptyMk()?"Y":"N");     // 绌烘澘淇″彿
             vo.setStaNo(staProtocol.getStaNo());                // 鐩爣绔�
+//            vo.setLocType1(staProtocol.isHigh() != staProtocol.isLow() && staProtocol.isLow() ? "浣�" : "楂�");     //楂樹綆搴撲綅
+            vo.setLocType1(devp.getDevNo()==102 ? "楂�" : "浣�");
         }
         return R.ok().add(list);
     }
@@ -137,6 +175,7 @@
                     vo.setPakMk(staProtocol.isPakMk()?"Y":"N");       // 闇�姹�1
                     vo.setEmptyMk(staProtocol.isEmptyMk()?"Y":"N");     // 绌烘澘淇″彿
                     vo.setStaNo(staProtocol.getStaNo());                // 鐩爣绔�
+                    vo.setLocType1(staProtocol.isHigh() != staProtocol.isLow() && staProtocol.isLow() ? "浣�" : "楂�");     //楂樹綆搴撲綅
                     return R.ok().add(vo);
                 }
             }
@@ -148,19 +187,28 @@
     @ManagerAuth(memo = "淇敼绔欑偣鏁版嵁")
     public R siteDetlUpdate(@RequestParam Integer siteId,
                             @RequestParam Short workNo,
-                            @RequestParam Short staNo){
+                            @RequestParam Short staNo,
+                            @RequestParam String pakMk){
         for (DevpSlave devp : slaveProperties.getDevp()) {
             DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
             Map<Integer, StaProtocol> station = devpThread.getStation();
             for (Map.Entry<Integer, StaProtocol> entry : station.entrySet()) {
                 if (siteId.equals(entry.getKey())) {
                     StaProtocol staProtocol = entry.getValue();
+                    if (staProtocol == null) {
+                        continue;
+                    } else {
+                        staProtocol = staProtocol.clone();
+                    }
                     if (workNo != null) {
                         staProtocol.setWorkNo(workNo);
                     }
                     if (staNo != null) {
                         staProtocol.setStaNo(staNo);
                     }
+                    if (pakMk != null) {
+                        staProtocol.setPakMk(pakMk.equals("Y"));
+                    }
                     boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                     if (result) {
                         return R.ok();

--
Gitblit v1.9.1