From 4efdfa79008cb12e1fbb7120cd68198cd0d0677c Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期三, 13 十二月 2023 16:47:10 +0800
Subject: [PATCH] #

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

diff --git a/src/main/java/com/zy/asrs/controller/SiteController.java b/src/main/java/com/zy/asrs/controller/SiteController.java
index 9c28099..1305824 100644
--- a/src/main/java/com/zy/asrs/controller/SiteController.java
+++ b/src/main/java/com/zy/asrs/controller/SiteController.java
@@ -8,6 +8,7 @@
 import com.zy.asrs.domain.vo.SiteTableVo;
 import com.zy.asrs.entity.BasDevp;
 import com.zy.asrs.service.BasDevpService;
+import com.zy.asrs.utils.CommandUtils;
 import com.zy.core.cache.MessageQueue;
 import com.zy.core.cache.OutputQueue;
 import com.zy.core.cache.SlaveConnection;
@@ -35,6 +36,7 @@
     private SlaveProperties slaveProperties;
     @Autowired
     private BasDevpService basDevpService;
+
 
     @GetMapping("/io/mode/info/site")
     @ManagerAuth(memo = "鍏ュ嚭搴撴ā寮�")
@@ -124,29 +126,12 @@
             Map<Integer, StaProtocol> station = devpThread.getStation();
 
             for(Map.Entry<Integer, StaProtocol> entry : station.entrySet()) {
-                StaProtocol staProtocol = entry.getValue();
-//                if (staProtocol) {
-//                    PlcErrorTableVo vo = new PlcErrorTableVo();
-//                    vo.setNo(entry.getKey());   //  搴忓彿
-//
-//                    vo.setPlcDesc("");  //  todo:luxiaotao plc閿欒鎻忚堪
-//                    vo.setError("");    //  todo:luxiaotao 寮傚父淇℃伅
-//                    list.add(vo);
-//                }
-            }
+                if (!Cools.isEmpty(staPlcErr(entry))){
+                    list.add(staPlcErr(entry).get(0)) ;
+                }
 
+            }
         }
-
-        list.sort((o1, o2) -> {
-            if (o1.getNo().compareTo(o2.getNo()) > 0){
-                return 1;
-            }else if (o1.getNo().compareTo(o2.getNo()) < 0){
-                return 0;
-            }else{
-                return -1;
-            }
-
-        });
         return R.ok().add(list);
     }
 
@@ -186,6 +171,7 @@
                     vo.setEmptyMk(staProtocol.isEmptyMk()?"Y":"N");     // 绌烘澘淇″彿
                     vo.setStaNo(staProtocol.getStaNo());                // 鐩爣绔�
                     vo.setLocType1(staProtocol.isHigh() != staProtocol.isLow() && staProtocol.isLow() ? "浣�" : "楂�");     //楂樹綆搴撲綅
+                    vo.setCar(staProtocol.isCar() ? "鏈�": "鏃�");
                     return R.ok().add(vo);
                 }
             }
@@ -198,9 +184,9 @@
     public R siteDetlUpdate(@RequestParam Integer devNo,
                             @RequestParam Short workNo,
                             @RequestParam Short staNo,
-                            @RequestParam String pakMk,
-                            @RequestParam Boolean inEnable,
-                            @RequestParam Boolean outEnable
+                            @RequestParam(required = false) String pakMk,
+                            @RequestParam(required = false) Boolean inEnable,
+                            @RequestParam(required = false) Boolean outEnable
     ) {
         BasDevp basDevp = basDevpService.selectById(devNo);
         if (basDevp == null) {
@@ -235,7 +221,7 @@
                         basDevp.setOutEnable(outEnable ? "Y" : "N");
                     }
                     basDevpService.updateById(basDevp);
-                    boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
+                    boolean result = CommandUtils.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol), false);
                     if (result) {
                         return R.ok();
                     } else {
@@ -247,5 +233,116 @@
         return R.error("鏇存柊澶辫触");
     }
 
+    public List<PlcErrorTableVo> staPlcErr(Map.Entry<Integer, StaProtocol> entry){
+        List<PlcErrorTableVo> list = new ArrayList<>();
+        StaProtocol staProtocol = entry.getValue();
+        if (staProtocol.getBreakerErr()){
+            PlcErrorTableVo vo = new PlcErrorTableVo();
+            vo.setNo(entry.getKey());   //  搴忓彿
+            vo.setPlcDesc("鏂矾鍣ㄦ晠闅�");
+            vo.setError("鏂矾鍣ㄦ晠闅�");
+            list.add(vo);
+        }
+        if (staProtocol.getInfraredErr()){
+            PlcErrorTableVo vo = new PlcErrorTableVo();
+            vo.setNo(entry.getKey());   //  搴忓彿
+            vo.setPlcDesc("鍏夌數寮傚父");
+            vo.setError("鍏夌數寮傚父");
+            list.add(vo);
+        }
+        if (staProtocol.getOutTimeErr()){
+            PlcErrorTableVo vo = new PlcErrorTableVo();
+            vo.setNo(entry.getKey());   //  搴忓彿
+
+            vo.setPlcDesc("杩愯瓒呮椂");
+            vo.setError("杩愯瓒呮椂");
+            list.add(vo);
+        }
+        if (staProtocol.getSeizeSeatErr()){
+            PlcErrorTableVo vo = new PlcErrorTableVo();
+            vo.setNo(entry.getKey());   //  搴忓彿
+
+            vo.setPlcDesc("鍗犱綅瓒呮椂");
+            vo.setError("鍗犱綅瓒呮椂");
+            list.add(vo);
+        }
+        if (staProtocol.getWrkYgoodsN()){
+            PlcErrorTableVo vo = new PlcErrorTableVo();
+            vo.setNo(entry.getKey());   //  搴忓彿
+
+            vo.setPlcDesc("鏈変换鍔℃棤璐ф晠闅�");
+            vo.setError("鏈変换鍔℃棤璐ф晠闅�");
+            list.add(vo);
+        }
+        if (staProtocol.getInverterErr()){
+            PlcErrorTableVo vo = new PlcErrorTableVo();
+            vo.setNo(entry.getKey());   //  搴忓彿
+
+            vo.setPlcDesc("鍙橀鍣ㄦ晠闅�");
+            vo.setError("鍙橀鍣ㄦ晠闅�");
+            list.add(vo);
+        }
+        if (staProtocol.getContactErr()){
+            PlcErrorTableVo vo = new PlcErrorTableVo();
+            vo.setNo(entry.getKey());   //  搴忓彿
+
+            vo.setPlcDesc("鐢垫満鎺ヨЕ鍣ㄦ晠闅�");
+            vo.setError("鐢垫満鎺ヨЕ鍣ㄦ晠闅�");
+            list.add(vo);
+        }
+        if (staProtocol.getUpcontactErr()){
+            PlcErrorTableVo vo = new PlcErrorTableVo();
+            vo.setNo(entry.getKey());   //  搴忓彿
+
+            vo.setPlcDesc("椤跺崌鐢垫満鎺ヨЕ鍣ㄦ晠闅�");
+            vo.setError("椤跺崌鐢垫満鎺ヨЕ鍣ㄦ晠闅�");
+            list.add(vo);
+        }
+        if (staProtocol.isFrontErr()){
+            PlcErrorTableVo vo = new PlcErrorTableVo();
+            vo.setNo(entry.getKey());   //  搴忓彿
+            vo.setPlcDesc("鍓嶈秴闄�");
+            vo.setError("鍓嶈秴闄�");
+            list.add(vo);
+        }
+        if (staProtocol.isBackErr()){
+            PlcErrorTableVo vo = new PlcErrorTableVo();
+            vo.setNo(entry.getKey());   //  搴忓彿
+            vo.setPlcDesc("鍚庤秴闄�");
+            vo.setError("鍚庤秴闄�");
+            list.add(vo);
+        }
+        if (staProtocol.isHighErr()){
+            PlcErrorTableVo vo = new PlcErrorTableVo();
+            vo.setNo(entry.getKey());   //  搴忓彿
+            vo.setPlcDesc("楂樿秴闄�");
+            vo.setError("楂樿秴闄�");
+            list.add(vo);
+        }
+        if (staProtocol.isLeftErr()){
+            PlcErrorTableVo vo = new PlcErrorTableVo();
+            vo.setNo(entry.getKey());   //  搴忓彿
+            vo.setPlcDesc("宸﹁秴闄�");
+            vo.setError("宸﹁秴闄�");
+            list.add(vo);
+        }
+        if (staProtocol.isRightErr()){
+            PlcErrorTableVo vo = new PlcErrorTableVo();
+            vo.setNo(entry.getKey());   //  搴忓彿
+            vo.setPlcDesc("鍙宠秴闄�");
+            vo.setError("鍙宠秴闄�");
+            list.add(vo);
+        }
+        if (staProtocol.isBarcodeErr()){
+            PlcErrorTableVo vo = new PlcErrorTableVo();
+            vo.setNo(entry.getKey());   //  搴忓彿
+            vo.setPlcDesc("鎵爜澶辫触");
+            vo.setError("鎵爜澶辫触");
+            list.add(vo);
+        }
+
+
+        return list;
+    }
 
 }

--
Gitblit v1.9.1