From 09fcc4ec56a1ce6c0fcb308348d8dd5e2c08d336 Mon Sep 17 00:00:00 2001
From: fyxc <fyxc@qq.com>
Date: 星期四, 22 五月 2025 14:33:06 +0800
Subject: [PATCH] server commit files

---
 src/main/java/com/zy/asrs/service/WrkMastService.java          |    4 +
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java    |   93 +++++++++++++++++++++++++++++-
 src/main/java/com/zy/asrs/service/impl/WrkMastServiceImpl.java |   45 +++++++++++++++
 src/main/java/com/zy/core/enums/RedisKeyType.java              |    1 
 4 files changed, 138 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/WrkMastService.java b/src/main/java/com/zy/asrs/service/WrkMastService.java
index ff34a8d..31d2b2b 100644
--- a/src/main/java/com/zy/asrs/service/WrkMastService.java
+++ b/src/main/java/com/zy/asrs/service/WrkMastService.java
@@ -45,4 +45,8 @@
     WrkMast selectWorkingPakout(Integer staNo);
 
     WrkMast selectWorkingPakin(Integer staNo);
+
+    boolean checkTransferWrkMast();//妫�娴嬫槸鍚﹀瓨鍦ㄨ皟鎷ㄤ换鍔�
+
+    boolean checkNoTransferWorking();//妫�娴嬫槸鍚﹀瓨鍦ㄩ潪璋冩嫧浠诲姟
 }
diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index 8904c2d..627c8a8 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -163,6 +163,13 @@
      */
     public synchronized void generateInboundWrk() {
         try {
+//            //妫�娴嬫槸鍚﹀瓨鍦ㄨ皟鎷ㄤ换鍔★紝涓嶆墽琛屽叆搴�
+//            boolean checkTransferWrkMast = wrkMastService.checkTransferWrkMast();
+//            if (checkTransferWrkMast) {
+//                News.error("瀛樺湪璋冩嫧浠诲姟锛屼笉鎵ц鍏ュ簱");
+//                return;
+//            }
+
             // 閬嶅巻鍏ュ簱鍙�
             for (DevpSlave.Sta inSta : slaveProperties.getDevp().get(0).getInSta()) {
                 if (inSta.getStaNo() == 1014 || inSta.getStaNo() == 1025) {
@@ -223,7 +230,12 @@
                                 .in("sta_no", 1024, 1013)
                                 .eq("io_type", 101));
                         if (!wrkMastOutList.isEmpty()) {
-                            MessageQueue.offer(SlaveType.Devp, 1, new Task(3, staProtocol.getSiteId()));
+                            Object o = redisUtil.get(RedisKeyType.DEVP_ERROR_FLAG.key + staProtocol.getSiteId());
+                            if (o == null) {
+                                redisUtil.set(RedisKeyType.DEVP_ERROR_FLAG.key + staProtocol.getSiteId(), "lock", 15);
+                                MessageQueue.offer(SlaveType.Devp, 1, new Task(3, staProtocol.getSiteId()));
+                                setLedErrorData(staProtocol.getSiteId(), "浠诲姟鍐茬獊");
+                            }
                             News.error("绔欑偣瀛樺湪鍑哄簱浠诲姟,绂佹鍏ュ簱,绔欑偣={}", staProtocol.getSiteId());
                             continue;
                         }
@@ -363,7 +375,12 @@
                                 .in("sta_no", 1011, 1021)
                                 .eq("io_type", 101));
                         if (!wrkMastOutList.isEmpty()) {
-                            MessageQueue.offer(SlaveType.Devp, 1, new Task(3, staProtocol.getSiteId()));
+                            Object o = redisUtil.get(RedisKeyType.DEVP_ERROR_FLAG.key + staProtocol.getSiteId());
+                            if (o == null) {
+                                redisUtil.set(RedisKeyType.DEVP_ERROR_FLAG.key + staProtocol.getSiteId(), "lock", 15);
+                                MessageQueue.offer(SlaveType.Devp, 1, new Task(3, staProtocol.getSiteId()));
+                                setLedErrorData(staProtocol.getSiteId(), "浠诲姟鍐茬獊");
+                            }
                             News.error("绔欑偣瀛樺湪鍑哄簱浠诲姟,绂佹鍏ュ簱,绔欑偣={}", staProtocol.getSiteId());
                             continue;
                         }
@@ -492,6 +509,13 @@
 
 
     public void outFirst() {
+//        //妫�娴嬫槸鍚﹀瓨鍦ㄨ皟鎷ㄤ换鍔★紝瀛樺湪涓嶆墽琛屽嚭搴�
+//        boolean checkTransferWrkMast = wrkMastService.checkTransferWrkMast();
+//        if (checkTransferWrkMast) {
+//            News.error("瀛樺湪璋冩嫧浠诲姟锛屼笉鎵ц鍑哄簱");
+//            return;
+//        }
+
         DevpSlave devpSlave = slaveProperties.getDevp().get(0);
         // 閬嶅巻鍫嗗灈鏈哄嚭搴撶珯
         Date now = new Date();
@@ -515,7 +539,12 @@
                     .eq("source_sta_no", checkInSourceStaNo)
                     .eq("io_type", 1));
             if (!wrkMastInList.isEmpty()) {
-                MessageQueue.offer(SlaveType.Devp, 1, new Task(3, wrkMast.getStaNo()));
+                Object o = redisUtil.get(RedisKeyType.DEVP_ERROR_FLAG.key + wrkMast.getStaNo());
+                if (o == null) {
+                    redisUtil.set(RedisKeyType.DEVP_ERROR_FLAG.key + wrkMast.getStaNo(), "lock", 15);
+                    MessageQueue.offer(SlaveType.Devp, 1, new Task(3, wrkMast.getStaNo()));
+                    setLedErrorData(wrkMast.getStaNo(), "浠诲姟鍐茬獊");
+                }
                 News.error("绔欑偣瀛樺湪鍏ュ簱浠诲姟,绂佹鍑哄簱,绔欑偣={}", wrkMast.getStaNo());
                 continue;
             }
@@ -661,6 +690,33 @@
                 log.info("鐢佃鏈烘暟鎹缃細{},{}", staNo, data);
             } else {
                 log.info("鐢佃鏈烘暟鎹缃紓甯革細{},{}", wrkNo, response);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    private void setLedErrorData(Integer staNo, String msg) {
+        try {
+            HashMap<String, String> hashMap = new HashMap<>();
+            hashMap.put("msg", msg);
+            hashMap.put("sta", String.valueOf(staNo));
+            String response = null;
+            response = new HttpHandler.Builder()
+                    .setUri(wmsUrl)
+                    .setPath("/rpc/led/getError")
+                    .setJson(JSON.toJSONString(hashMap))
+                    .build()
+                    .doPost();
+            JSONObject jsonObject = JSON.parseObject(response);
+            Integer code = jsonObject.getInteger("code");
+            if (code.equals(200)) {
+                String data = jsonObject.getString("data");
+                List<LedCommand> wrkDetls = JSONArray.parseArray(data, LedCommand.class);
+                redisUtil.set("LED_" + staNo, wrkDetls, 30);
+                log.info("鐢佃鏈烘暟鎹缃細{},{}", staNo, data);
+            } else {
+                log.info("鐢佃鏈烘暟鎹缃紓甯革細{},{}", staNo, response);
             }
         } catch (Exception e) {
             e.printStackTrace();
@@ -1037,7 +1093,7 @@
                 led = 3;
             } else if (wrkMast.getSourceStaNo() == 1031) {
                 //宸ヤ綔鍙蜂竴鑷村垽鏂�
-                if (!staProtocol.getFinishWorkNo().equals(wrkMast.getWmsWrkNo2())) {
+                if (!String.valueOf(staProtocol.getFinishWorkNo()).equals(wrkMast.getWmsWrkNo2())) {
                     News.taskInfo(wrkMast.getWrkNo(), "{}宸ヤ綔鍙�1锛寋}宸ヤ綔鍙�2锛�1135杩囨潵鐨勬墭鐩橈紝涓哄皢宸ヤ綔鍙峰啓鍒拌嚦1031", staProtocol.getFinishWorkNo(), wrkMast.getWmsWrkNo2());
                     return false;
                 }
@@ -1220,6 +1276,14 @@
                     News.taskInfo(wrkMast.getWrkNo(), "{}浠诲姟锛寋}绔欑偣锛屼换鍔″彿涓嶄竴鑷�", wrkMast.getWrkNo(), staProtocol.getSiteId());
                     return false;
                 }
+
+                //璋冩嫧浠诲姟鎵ц鏃讹紝涓嶅厑璁告湁鍏朵粬鍏ュ嚭搴撲换鍔″伐浣�
+                boolean checkNoTransferWorking = wrkMastService.checkNoTransferWorking();
+                if (checkNoTransferWorking) {
+                    News.error("璋冩嫧浠诲姟鎵ц鏃讹紝涓嶅厑璁告湁鍏朵粬鍏ュ嚭搴撲换鍔″伐浣�");
+                    return false;
+                }
+
             }
 
             //鍒ゆ柇鎻愬崌鏈烘槸鍚︽湁鍏朵粬浠诲姟(璇ヤ换鍔¢渶瑕佹崲灞傚繀椤绘彁鍓嶇嫭鍗犳彁鍗囨満)
@@ -1353,7 +1417,12 @@
                             .eq("source_sta_no", checkInSourceStaNo)
                             .eq("io_type", 1));
                     if (!wrkMastInList.isEmpty()) {
-                        MessageQueue.offer(SlaveType.Devp, 1, new Task(3, wrkMast.getStaNo()));
+                        Object o = redisUtil.get(RedisKeyType.DEVP_ERROR_FLAG.key + wrkMast.getStaNo());
+                        if (o == null) {
+                            redisUtil.set(RedisKeyType.DEVP_ERROR_FLAG.key + wrkMast.getStaNo(), "lock", 15);
+                            MessageQueue.offer(SlaveType.Devp, 1, new Task(3, wrkMast.getStaNo()));
+                            setLedErrorData(wrkMast.getStaNo(), "浠诲姟鍐茬獊");
+                        }
                         News.error("绔欑偣瀛樺湪鍏ュ簱浠诲姟,绂佹鍑哄簱,绔欑偣={}", wrkMast.getStaNo());
                         continue;
                     }
@@ -1394,11 +1463,25 @@
             }
             if (wrkMast.getStaNo() == 1031) {
 
+                //璋冩嫧浠诲姟鎵ц鏃讹紝涓嶅厑璁告湁鍏朵粬鍏ュ嚭搴撲换鍔″伐浣�
+                boolean checkNoTransferWorking = wrkMastService.checkNoTransferWorking();
+                if (checkNoTransferWorking) {
+                    News.error("璋冩嫧浠诲姟鎵ц鏃讹紝涓嶅厑璁告湁鍏朵粬鍏ュ嚭搴撲换鍔″伐浣�-鍑哄簱");
+                    return false;
+                }
+
             } else {
                 if (!isOutEnable(devpThread, wrkMast.getStaNo())) {
                     News.taskInfo(wrkMast.getWrkNo(), "{}浠诲姟锛寋}绔欑偣锛屾病鏈夊彲鍑轰俊鍙�", wrkMast.getWrkNo(), staProtocol.getSiteId());
                     return false;
                 }
+
+//                //妫�娴嬫槸鍚﹀瓨鍦ㄨ皟鎷ㄤ换鍔★紝瀛樺湪涓嶆墽琛屽嚭搴�
+//                boolean checkTransferWrkMast = wrkMastService.checkTransferWrkMast();
+//                if (checkTransferWrkMast) {
+//                    News.error("瀛樺湪璋冩嫧浠诲姟锛屼笉鎵ц鍑哄簱");
+//                    return false;
+//                }
             }
 
             String locNo = "0200305";
diff --git a/src/main/java/com/zy/asrs/service/impl/WrkMastServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/WrkMastServiceImpl.java
index 4bc0d00..0267600 100644
--- a/src/main/java/com/zy/asrs/service/impl/WrkMastServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/WrkMastServiceImpl.java
@@ -155,4 +155,49 @@
     public WrkMast selectWorkingPakin(Integer staNo) {
         return this.baseMapper.selectWorkingPakin(staNo);
     }
+
+    @Override
+    public boolean checkTransferWrkMast() {
+        List<WrkMast> wrkMastListIn = this.selectList(new EntityWrapper<WrkMast>()
+                .eq("io_type", 1)
+                .eq("source_sta_no", 1031)
+        );
+        if (!wrkMastListIn.isEmpty()) {
+            return true;
+        }
+
+        List<WrkMast> wrkMastListOut = this.selectList(new EntityWrapper<WrkMast>()
+                .eq("io_type", 101)
+                .eq("sta_no", 1031)
+        );
+        if (!wrkMastListOut.isEmpty()) {
+            return true;
+        }
+
+        return false;
+    }
+
+    @Override
+    public boolean checkNoTransferWorking() {
+        //璋冩嫧浠诲姟鎵ц鏃讹紝涓嶅厑璁告湁鍏朵粬鍏ュ嚭搴撲换鍔″伐浣�
+        List<WrkMast> wrkMastListIn = this.selectList(new EntityWrapper<WrkMast>()
+                .in("io_type", 1)
+                .notIn("source_sta_no", 1031)
+        );
+
+        if (!wrkMastListIn.isEmpty()) {
+            return true;
+        }
+
+        List<WrkMast> wrkMastListOut = this.selectList(new EntityWrapper<WrkMast>()
+                .in("io_type", 101)
+                .notIn("sta_no", 1031)
+        );
+
+        if (!wrkMastListOut.isEmpty()) {
+            return true;
+        }
+
+        return false;
+    }
 }
diff --git a/src/main/java/com/zy/core/enums/RedisKeyType.java b/src/main/java/com/zy/core/enums/RedisKeyType.java
index 3800b70..38f0dcd 100644
--- a/src/main/java/com/zy/core/enums/RedisKeyType.java
+++ b/src/main/java/com/zy/core/enums/RedisKeyType.java
@@ -13,6 +13,7 @@
     QUEUE_SHUTTLE("queue_shuttle_"),
     QUEUE_FORK_LIFT("queue_fork_lift_"),
     QUEUE_TASK("queue_task_"),
+    DEVP_ERROR_FLAG("devp_error_flag_"),
     ;
 
     public String key;

--
Gitblit v1.9.1