From 562c18ed0b3ac91589cf8d23511981675f59fabd Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期一, 18 十二月 2023 16:08:08 +0800
Subject: [PATCH] #

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

diff --git a/src/main/java/com/zy/asrs/controller/SiteController.java b/src/main/java/com/zy/asrs/controller/SiteController.java
index 1305824..45efdff 100644
--- a/src/main/java/com/zy/asrs/controller/SiteController.java
+++ b/src/main/java/com/zy/asrs/controller/SiteController.java
@@ -232,6 +232,94 @@
         }
         return R.error("鏇存柊澶辫触");
     }
+    @PostMapping("/detl/out")
+    @ManagerAuth(memo = "淇敼绔欑偣鏁版嵁")
+    public R siteDetlout(@RequestParam Integer devNo,
+                            @RequestParam Short workNo,
+                            @RequestParam Short staNo,
+                            @RequestParam(required = false) String pakMk,
+                            @RequestParam(required = false) Boolean inEnable,
+                            @RequestParam(required = false) 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 (devNo.equals(entry.getKey())) {
+                    StaProtocol staProtocol = entry.getValue();
+                    if (staProtocol == null) {
+                        continue;
+                    } else {
+                        staProtocol = staProtocol.clone();
+                    }
+                    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");
+                    }
+                    staProtocol.setWorkNo((short) 0);
+                    staProtocol.setStaNo((short) 0);
+                    basDevpService.updateById(basDevp);
+                    boolean result = CommandUtils.offer(SlaveType.Devp, devp.getId(), new Task(3, staProtocol), false);
+                    if (result) {
+                        return R.ok();
+                    } else {
+                        return R.error("涓嬪彂鍛戒护澶辫触");
+                    }
+                }
+            }
+        }
+        return R.error("鏇存柊澶辫触");
+    }
+    @PostMapping("/detl/in")
+    @ManagerAuth(memo = "淇敼绔欑偣鏁版嵁")
+    public R siteDetlint(@RequestParam Integer devNo,
+                         @RequestParam Short workNo,
+                         @RequestParam Short staNo,
+                         @RequestParam(required = false) String pakMk,
+                         @RequestParam(required = false) Boolean inEnable,
+                         @RequestParam(required = false) Boolean outEnable
+    ) {
+        BasDevp basDevp = basDevpService.selectById(devNo);
+        if (basDevp == null) {
+            return R.error("绔欑偣涓嶅瓨鍦�");
+        }
+        for (DevpSlave devp : slaveProperties.getDevp()) {
+            // 閬嶅巻鍏ュ簱鍙�
+            for (DevpSlave.Sta inSta : devp.getInSta()) {
+                if (!devNo.equals(inSta.getBackSta()) ){
+                    continue;
+                }
+                // 鑾峰彇鍏ュ簱绔欎俊鎭�
+                DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
+                StaProtocol staProtocol = devpThread.getStation().get(inSta.getBackSta());
+                if (staProtocol == null) {
+                    continue;
+                } else {
+                    staProtocol = staProtocol.clone();
+                }
+                staProtocol.setWorkNo((short) 9999);
+                staProtocol.setStaNo(inSta.getStaNo().shortValue());
+                boolean result = CommandUtils.offer(SlaveType.Devp, devp.getId(), new Task(3, staProtocol), false);
+                if (result) {
+                    return R.ok();
+                } else {
+                    return R.error("涓嬪彂鍛戒护澶辫触");
+                }
+            }
+        }
+        return R.error("鏇存柊澶辫触");
+    }
 
     public List<PlcErrorTableVo> staPlcErr(Map.Entry<Integer, StaProtocol> entry){
         List<PlcErrorTableVo> list = new ArrayList<>();

--
Gitblit v1.9.1