From a4d40121018b268d406710e26bfa47b3342b14d1 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期四, 03 八月 2023 14:29:34 +0800
Subject: [PATCH] 堆垛机、输送站点设备

---
 src/main/java/com/zy/asrs/controller/SiteController.java |   30 ++++++++++++++++++++++--------
 1 files changed, 22 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/SiteController.java b/src/main/java/com/zy/asrs/controller/SiteController.java
index 1370c6e..9c28099 100644
--- a/src/main/java/com/zy/asrs/controller/SiteController.java
+++ b/src/main/java/com/zy/asrs/controller/SiteController.java
@@ -2,6 +2,7 @@
 
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.core.annotations.ManagerAuth;
+import com.core.common.Cools;
 import com.core.common.R;
 import com.zy.asrs.domain.vo.PlcErrorTableVo;
 import com.zy.asrs.domain.vo.SiteTableVo;
@@ -20,10 +21,7 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 /**
  * 杈撻�佽澶囨帴鍙�
@@ -197,15 +195,22 @@
 
     @PostMapping("/detl/update")
     @ManagerAuth(memo = "淇敼绔欑偣鏁版嵁")
-    public R siteDetlUpdate(@RequestParam Integer siteId,
+    public R siteDetlUpdate(@RequestParam Integer devNo,
                             @RequestParam Short workNo,
                             @RequestParam Short staNo,
-                            @RequestParam String pakMk){
+                            @RequestParam String pakMk,
+                            @RequestParam Boolean inEnable,
+                            @RequestParam Boolean outEnable
+    ) {
+        BasDevp basDevp = basDevpService.selectById(devNo);
+        if (basDevp == null) {
+            return R.error("绔欑偣涓嶅瓨鍦�");
+        }
         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())) {
+                if (devNo.equals(entry.getKey())) {
                     StaProtocol staProtocol = entry.getValue();
                     if (staProtocol == null) {
                         continue;
@@ -221,6 +226,15 @@
                     if (pakMk != null) {
                         staProtocol.setPakMk(pakMk.equals("Y"));
                     }
+                    if (inEnable != null) {
+                        staProtocol.setInEnable(inEnable);
+                        basDevp.setInEnable(inEnable ? "Y" : "N");
+                    }
+                    if (outEnable != null) {
+                        staProtocol.setOutEnable(outEnable);
+                        basDevp.setOutEnable(outEnable ? "Y" : "N");
+                    }
+                    basDevpService.updateById(basDevp);
                     boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                     if (result) {
                         return R.ok();
@@ -230,7 +244,7 @@
                 }
             }
         }
-        return R.error("plc宸叉帀绾�");
+        return R.error("鏇存柊澶辫触");
     }
 
 

--
Gitblit v1.9.1