From ecb93482982b82008b37de0ec67d2afa9cb60b13 Mon Sep 17 00:00:00 2001
From: pjb <123456>
Date: 星期三, 26 六月 2024 16:58:41 +0800
Subject: [PATCH] 而且回退修改,led显示

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   61 +++++++++++++++++-------------
 1 files changed, 34 insertions(+), 27 deletions(-)

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 ea80e68..6b6667f 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -162,19 +162,19 @@
                     back = true;
                 }
 
-                if (!back && devp.getId() == 2) {
-                    if(staProtocol.getWorkNo() == 9907 && '5' != barcode.charAt(0)){
-                        errMsg = "鏉$爜5鍙兘鍏�7鎺�";
-                        back = true;
-                    }
-                    if(staProtocol.getWorkNo() == 9906 && '5' == barcode.charAt(0)){
-                        errMsg = "鏉$爜5涓嶈兘鍏�6鎺�";
-                        back = true;
-                    }
-                }
+//                if (!back && devp.getId() == 2) {
+//                    if(staProtocol.getWorkNo() == 9907 && '5' != barcode.charAt(0)){
+//                        errMsg = "鏉$爜5鍙兘鍏�7鎺�";
+//                        back = true;
+//                    }
+//                    if(staProtocol.getWorkNo() == 9906 && '5' == barcode.charAt(0)){
+//                        errMsg = "鏉$爜5涓嶈兘鍏�6鎺�";
+//                        back = true;
+//                    }
+//                }
 
                 // 閫�鍥�
-                if (back) {
+                if (back && devp.getId() == 2) {
 //                    News.warn("鎵爜鍏ュ簱澶辫触锛寋}鍏ュ簱绔欏洜{}寮傚父锛屾墭鐩樺凡琚��鍥�", inSta.getStaNo(), errMsg);
 //                    if(!staProtocol.isOutEnable()){
 //                        continue;
@@ -206,7 +206,7 @@
                             continue;
                         }
                     }
-                    if (wrkMast != null) {
+                    if (wrkMast != null && devp.getId() == 2) {
                         News.warn(""+mark+" - 4"+" - 宸ヤ綔妗d腑宸插瓨鍦ㄨ绔欑姸鎬佷负锛� 2.璁惧涓婅蛋 锛夌殑鏁版嵁,宸ヤ綔鍙�={}", wrkMast.getWrkNo());
                         staProtocol.setWorkNo((short)9999);
                         staProtocol.setStaNo(inSta.getBackSta().shortValue());
@@ -262,18 +262,21 @@
                                 ledCommand.setTitle("鍏ㄦ澘鍏ュ簱");
                                 ledCommand.setLocNo(dto.getLocNo());
                                 ledCommand.setStaNo(dto.getStaNo());
+                                ledCommand.setBarcode(barcode);
                                 commands.add(ledCommand);
                                 MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(3, commands));
 //                                ledThread.errorReset();
                             }
                         } else {
                             News.error(""+mark+" - 5"+" - 璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", wmsUrl + "/rpc/pakin/loc/v1", JSON.toJSONString(param), response);
-                            staProtocol.setWorkNo((short)9999);
-                            staProtocol.setStaNo(inSta.getBackSta().shortValue());
-                            devpThread.setPakMk(staProtocol.getSiteId(), false);
-                            boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
-                            if (!result) {
-                                throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触");
+                            if(devp.getId() == 2) {
+                                staProtocol.setWorkNo((short)9999);
+                                staProtocol.setStaNo(inSta.getBackSta().shortValue());
+                                devpThread.setPakMk(staProtocol.getSiteId(), false);
+                                boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
+                                if (!result) {
+                                    throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触");
+                                }
                             }
 
                             // led 寮傚父鏄剧ず
@@ -823,8 +826,17 @@
                     News.error(""+mark+" - 1"+" - 2"+" - 鍏ュ簱 ===>> 鍫嗗灈鏈虹珯鐐瑰湪鏁版嵁搴撲笉瀛樺湪, 绔欑偣缂栧彿={}", crnStn.getStaNo());
                     continue;
                 }
+                // 鑾峰彇宸ヤ綔鐘舵�佷负2锛堣澶囦笂璧帮級鐨勫叆搴撳伐浣滄。
+                WrkMast wrkMast = wrkMastMapper.selectPakInStep2(slave.getId(), staProtocol.getWorkNo().intValue(), crnStn.getStaNo());
+                if (null == wrkMast) {
+                    News.infoNoLog(""+mark+" - 1"+" - 4"+" - 鏌ヨ鏃犲緟鍏ュ簱鏁版嵁--wrk_sts=2, 宸ヤ綔鍙�={}", staProtocol.getWorkNo());
+//                log.error("鏌ヨ鏃犲緟鍏ュ簱鏁版嵁--wrk_sts=2, 宸ヤ綔鍙�={}", staProtocol.getWorkNo());
+                    continue;
+                }
 
-                if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.getWorkNo() <= 9000 && staProtocol.isInEnable()
+                if (staProtocol.isAutoing() && staProtocol.isLoading() &&
+                        (staProtocol.getWorkNo() <= 9000 || (slave.getId() == 1 && (wrkMast.getIoType() == 53 || wrkMast.getIoType() == 57)))
+                        && staProtocol.isInEnable()
                         && staDetl.getCanining() != null && staDetl.getCanining().equals("Y")) {
                     flag = true;
                 }
@@ -835,13 +847,7 @@
                             +"鑳藉叆淇″彿锛坵ms璁剧疆锛�.equals(\"Y\")"+staDetl.getCanining());
                     continue;
                 }
-                // 鑾峰彇宸ヤ綔鐘舵�佷负2锛堣澶囦笂璧帮級鐨勫叆搴撳伐浣滄。
-                WrkMast wrkMast = wrkMastMapper.selectPakInStep2(slave.getId(), staProtocol.getWorkNo().intValue(), crnStn.getStaNo());
-                if (null == wrkMast) {
-                    News.infoNoLog(""+mark+" - 1"+" - 4"+" - 鏌ヨ鏃犲緟鍏ュ簱鏁版嵁--wrk_sts=2, 宸ヤ綔鍙�={}", staProtocol.getWorkNo());
-//                log.error("鏌ヨ鏃犲緟鍏ュ簱鏁版嵁--wrk_sts=2, 宸ヤ綔鍙�={}", staProtocol.getWorkNo());
-                    continue;
-                }
+
                 // 鑾峰彇搴撲綅淇℃伅
                 LocMast locMast = locMastService.selectById(wrkMast.getLocNo());
                 if (locMast == null) {
@@ -1644,10 +1650,11 @@
                 ledCommand.setSourceLocNo(wrkMast.getSourceLocNo());
                 ledCommand.setLocNo(wrkMast.getLocNo());
                 ledCommand.setStaNo(wrkMast.getStaNo());
+                ledCommand.setBarcode(wrkMast.getBarcode());
 //                ledCommand.setSourceStaNo(wrkMast.getSourceStaNo());
                 if (wrkMast.getIoType() != 110 && wrkMast.getIoType() != 10) {
                     List<WrkDetl> wrkDetls = wrkDetlService.findByWorkNo(wrkMast.getWrkNo());
-                    wrkDetls.forEach(wrkDetl -> ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getAnfme(),wrkDetl.getSpecs())));
+                    wrkDetls.forEach(wrkDetl -> ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getAnfme(),wrkDetl.getSpecs(),wrkDetl.getBatch(),wrkDetl.getMemo())));
                 }
                 commands.add(ledCommand);
             }

--
Gitblit v1.9.1