From df62c25e629099d9791f1fb52591cd1d690de093 Mon Sep 17 00:00:00 2001
From: lfdMem <1>
Date: 星期三, 16 四月 2025 14:00:39 +0800
Subject: [PATCH] 电视显示新增工序

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   57 ++++++++++++++++++++++++---------------------------------
 1 files changed, 24 insertions(+), 33 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 dd6e2f0..60130ae 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -145,7 +145,8 @@
                     }
                 }
                 if (staProtocol.isAutoing() && staProtocol.isInEnable()
-                        && !staProtocol.isEmptyMk() && (staProtocol.getWorkNo() == 0 || staProtocol.getWorkNo() > 9990)
+                        && !staProtocol.isEmptyMk() && staProtocol.getWorkNo() > 9990
+                        && staProtocol.getWorkNo()!=9999 && staProtocol.getWorkNo()!=9992 && staProtocol.getWorkNo()!=0
                         && staProtocol.isPakMk() && staProtocol.getStamp()>=2 && staProtocol.getStamp()!=3) {// && !Cools.isEmpty(barcode)) {
                     News.warnNoLog(""+mark+" - 0"+" - 寮�濮嬫墽琛�");
 //                    try {
@@ -156,7 +157,7 @@
                     if(!Cools.isEmpty(barcode)) {
                         News.info(""+mark+" - 1"+" - {}鍙锋潯鐮佹壂鎻忓櫒妫�娴嬫潯鐮佷俊鎭細{}", inSta.getBarcode(), barcode);
                         if("NG".endsWith(barcode) || "NoRead".equals(barcode) || "empty".equals(barcode)) {
-                            staProtocol.setWorkNo((short) 9999);
+                            staProtocol.setWorkNo((short) 9992);
                             staProtocol.setStaNo(inSta.getBackSta().shortValue());
                             devpThread.setPakMk(staProtocol.getSiteId(), false);
                             MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
@@ -170,7 +171,7 @@
                             continue;
                         }
                     } else {
-                        staProtocol.setWorkNo((short) 9999);
+                        staProtocol.setWorkNo((short) 9992);
                         staProtocol.setStaNo(inSta.getBackSta().shortValue());
                         devpThread.setPakMk(staProtocol.getSiteId(), false);
                         MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
@@ -195,7 +196,7 @@
                     }
                     if (wrkMast != null) {
                         News.error(""+mark+" - 4"+" - 宸ヤ綔妗d腑宸插瓨鍦ㄨ绔欑姸鎬佷负锛� 2.璁惧涓婅蛋 锛夌殑鏁版嵁,宸ヤ綔鍙�={}", wrkMast.getWrkNo());
-                        staProtocol.setWorkNo((short)9999);
+                        staProtocol.setWorkNo((short)9992);
                         staProtocol.setStaNo(inSta.getBackSta().shortValue());
                         devpThread.setPakMk(staProtocol.getSiteId(), false);
                         boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
@@ -255,7 +256,7 @@
                             }
                         } else {
                             News.error(""+mark+" - 5"+" - 璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", wmsUrl + "/rpc/pakin/loc/v1", JSON.toJSONString(param), response);
-                            staProtocol.setWorkNo((short)9999);
+                            staProtocol.setWorkNo((short)9992);
                             staProtocol.setStaNo(inSta.getBackSta().shortValue());
                             devpThread.setPakMk(staProtocol.getSiteId(), false);
                             boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
@@ -1511,7 +1512,7 @@
 //                                ledThread.errorReset();
                             }
                         } else {
-                            staProtocol.setWorkNo((short)9999);
+                            staProtocol.setWorkNo((short)9992);
                             staProtocol.setStaNo(emptyInSta.getBackSta().shortValue());
                             devpThread.setPakMk(staProtocol.getSiteId(), false);
                             boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
@@ -1632,7 +1633,7 @@
                     }catch (Exception e){
                         log.error("宸ヤ綔妗f鏄庣粏杈撳叆鐢佃鏈哄け璐�1锛氬紓甯镐俊鎭�==銆�"+e);
                     }
-                    wrkDetls.forEach(wrkDetl -> ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getAnfme(),wrkDetl.getWeight(),wrkDetl.getSpecs())));
+                    wrkDetls.forEach(wrkDetl -> ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getAnfme(),wrkDetl.getWeight(),wrkDetl.getSpecs(),wrkDetl.getSku())));
                 }
                 commands.add(ledCommand);
             }
@@ -1875,7 +1876,8 @@
                     wrkMast.setCrnNo(crn.getId());
                     wrkMast.setSourceLocNo(shallowLoc.getLocNo()); // 婧愬簱浣�
                     wrkMast.setLocNo(loc.getLocNo()); // 鐩爣搴撲綅
-                    wrkMast.setFullPlt(shallowLoc.getFullPlt()); // 婊℃澘
+//                    wrkMast.setFullPlt(shallowLoc.getFullPlt()); // 婊℃澘
+                    wrkMast.setFullPlt(shallowLoc.getLocSts().equals("D") ? "N" : "Y"); // 婊℃澘
                     wrkMast.setPicking("N"); // 鎷f枡
                     wrkMast.setExitMk("N"); // 閫�鍑�
                     wrkMast.setEmptyMk(shallowLoc.getLocSts().equals("D") ? "Y" : "N"); // 绌烘澘
@@ -1886,11 +1888,13 @@
                     int res = wrkMastMapper.insert(wrkMast);
                     if (res == 0) {
                         News.errorNoLog(""+mark+"moveLocForDeepLoc"+" - 2"+" - 淇濆瓨宸ヤ綔妗eけ璐�");
-                        throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�");
+//                        throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�");
+                        return true;
                     }
                     // 宸ヤ綔妗f槑缁嗕繚瀛�
                     if (shallowLoc.getLocSts().equals("F")) {
                         List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", shallowLoc.getLocNo()));
+
                         for (LocDetl locDetl : locDetls) {
                             WrkDetl wrkDetl = new WrkDetl();
                             wrkDetl.setWrkNo(workNo);
@@ -1901,7 +1905,8 @@
                             wrkDetl.setModiTime(new Date());
                             if (!wrkDetlService.insert(wrkDetl)) {
                                 News.errorNoLog(""+mark+"moveLocForDeepLoc"+" - 3"+" - 淇濆瓨宸ヤ綔妗f槑缁嗗け璐�");
-                                throw new CoolException("淇濆瓨宸ヤ綔妗f槑缁嗗け璐�");
+//                                throw new CoolException("淇濆瓨宸ヤ綔妗f槑缁嗗け璐�");
+                                return true;
                             }
                         }
                     }
@@ -1911,11 +1916,13 @@
                         shallowLoc.setModiTime(new Date());
                         if (!locMastService.updateById(shallowLoc)) {
                             News.errorNoLog(""+mark+"moveLocForDeepLoc"+" - 4"+" - 鏇存柊婧愬簱浣嶇姸鎬佸け璐�");
-                            throw new CoolException("鏇存柊婧愬簱浣嶇姸鎬佸け璐�");
+//                            throw new CoolException("鏇存柊婧愬簱浣嶇姸鎬佸け璐�");
+                            return true;
                         }
                     } else {
                         News.errorNoLog(""+mark+"moveLocForDeepLoc"+" - 5"+" - 婧愬簱浣嶅嚭搴撳け璐�");
-                        throw new CoolException("婧愬簱浣嶅嚭搴撳け璐�");
+//                        throw new CoolException("婧愬簱浣嶅嚭搴撳け璐�");
+                        return true;
                     }
                     // 淇敼鐩爣搴撲綅鐘舵��
                     if (loc.getLocSts().equals("O")) {
@@ -1923,11 +1930,13 @@
                         loc.setModiTime(new Date());
                         if (!locMastService.updateById(loc)) {
                             News.errorNoLog(""+mark+"moveLocForDeepLoc"+" - 6"+" - 鏇存柊鐩爣搴撲綅鐘舵�佸け璐�");
-                            throw new CoolException("鏇存柊鐩爣搴撲綅鐘舵�佸け璐�");
+//                            throw new CoolException("鏇存柊鐩爣搴撲綅鐘舵�佸け璐�");
+                            return true;
                         }
                     } else {
                         News.errorNoLog(""+mark+"moveLocForDeepLoc"+" - 7"+" - 绉昏浆澶辫触");
-                        throw new CoolException("绉昏浆澶辫触");
+//                        throw new CoolException("绉昏浆澶辫触");
+                        return true;
                     }
                 } catch (Exception e){
                     News.error(""+mark+"moveLocForDeepLoc"+" - 8"+" - 鍙屾繁搴撲綅闃诲锛屽娴呭簱浣嶈繘琛岀Щ杞け璐�", e);
@@ -2109,7 +2118,7 @@
                     }
                     WrkMast pakout = wrkMastMapper.selectWorkingPakout(inSta.getStaNo());
                     switch (inSta.getStaNo()) {
-                        case 203://1F
+                        case 101://1F
                             if (pakout != null) {
                                 if (devpThread.ioModeOf2F != IoModeType.PAKOUT_MODE) {
                                     // 鍑哄簱鍒囨崲涓�
@@ -2125,24 +2134,6 @@
                             } else {
                                 // 鍏ュ簱妯″紡
                                 devpThread.ioModeOf2F = IoModeType.PAKIN_MODE;
-                            }
-                            break;
-                        case 401://1F
-                            if (pakout != null) {
-                                if (devpThread.ioModeOf4F != IoModeType.PAKOUT_MODE) {
-                                    // 鍑哄簱鍒囨崲涓�
-                                    devpThread.ioModeOf4F = IoModeType.PAKOUT_BOOTING;
-                                    WrkMast pakin = wrkMastMapper.selectWorkingPakin(inSta.getStaNo());
-                                    if (pakin == null && !devpThread.getStation().get(inSta.getStaNo()).isLoading()
-                                            && !devpThread.getStation().get(inSta.getStaNo() + 1).isLoading()
-                                            && devpThread.getStation().get(inSta.getStaNo() + 1).getWorkNo() == 0) {
-                                        // 鍑哄簱妯″紡
-                                        devpThread.ioModeOf4F = IoModeType.PAKOUT_MODE;
-                                    }
-                                }
-                            } else {
-                                // 鍏ュ簱妯″紡
-                                devpThread.ioModeOf4F = IoModeType.PAKIN_MODE;
                             }
                             break;
                     }

--
Gitblit v1.9.1