From 015b9522a1a70a3e727fccfcc2f56365d82aaaf3 Mon Sep 17 00:00:00 2001 From: pjb <pjb123456> Date: 星期六, 05 七月 2025 17:01:36 +0800 Subject: [PATCH] WCS优化 --- src/main/java/com/zy/service/impl/MainServiceImpl.java | 73 ++++++++++++++++++++++++++++-------- 1 files changed, 56 insertions(+), 17 deletions(-) diff --git a/src/main/java/com/zy/service/impl/MainServiceImpl.java b/src/main/java/com/zy/service/impl/MainServiceImpl.java index a300dec..a69b78a 100644 --- a/src/main/java/com/zy/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/service/impl/MainServiceImpl.java @@ -206,7 +206,7 @@ // back = true; // } // 閫�鍥� - if (back && staProtocol.isInEnable()) { + if (back && staProtocol.isInEnable() && staProtocol.isLoading() && staProtocol.getWorkNo() == 0) { MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(3, errMsg)); if (!staProtocol.isLoading()){ @@ -267,7 +267,7 @@ staProtocol.setStaNo(dto.getStaNo().shortValue()); devpThread.setPakMk(staProtocol.getSiteId(), false); boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); - log.error("杈撻�佺嚎涓嬪彂2锛�"+dto.getWorkNo()+","+dto.getStaNo()); + log.info("杈撻�佺嚎涓嬪彂2锛�"+dto.getWorkNo()+","+dto.getStaNo()); if (!result) { News.error(methodName + ":鏇存柊plc绔欑偣淇℃伅澶辫触"); throw new CoolException("鏇存柊plc绔欑偣淇℃伅澶辫触"); @@ -810,8 +810,9 @@ } // 鍒ゆ柇鍫嗗灈鏈哄嚭搴撶珯鐘舵�� - if (staProtocol.isAutoing() && !staProtocol.isLoading() && staDetl.getCanouting() != null && staDetl.getCanouting().equals("Y") - && staProtocol.getWorkNo() == 0 && staProtocol.isOutEnable()) { + if ((staProtocol.isAutoing() && !staProtocol.isLoading() && staDetl.getCanouting() != null && staDetl.getCanouting().equals("Y") + && staProtocol.getWorkNo() == 0 && staProtocol.isOutEnable()) + || (staProtocol.getSiteId() == 1056 && staProtocol.isAutoing() && staDetl.getCanouting() != null && staDetl.getCanouting().equals("Y"))) { // 鍫嗗灈鏈烘帶鍒惰繃婊� if (!crnProtocol.getStatusType().equals(CrnStatusType.IDLE) || crnProtocol.getTaskNo() != 0) { break; @@ -960,7 +961,7 @@ // 淇敼绌烘《搴撳搴斿簱浣嶄换鍔$姸鎬� if(slave.getId() == 4 && crnStn.getStaNo() == 1056) { String locNo2 = (wrkMast.getSourceLocNo().startsWith("09") ? "10" : "12") + wrkMast.getSourceLocNo().substring(2); - WrkMast wrkMast1 = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("source_loc_no", locNo2)); + WrkMast wrkMast1 = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("source_loc_no", locNo2).eq("wrk_sts",11)); if (wrkMast1 != null) { wrkMast1.setWrkSts(12L); wrkMast1.setCrnStrTime(now); @@ -1105,6 +1106,12 @@ // 浜ゆ崲搴撲綅鍙� String locNo = wrkMast.getLocNo(); wrkMast.setLocNo(wrkMast1.getLocNo()); + // 浜ゆ崲鍏ュ簱鏃堕棿锛屾彁鍙栧簱瀛樻椂鎸夐『搴忓厛娴呭悗娣� + Date ioTime = wrkMast.getIoTime(); + if(locNo.startsWith("10")) { + wrkMast.setIoTime(wrkMast1.getIoTime()); + wrkMast1.setIoTime(ioTime); + } wrkMast1.setLocNo(locNo); wrkMast1.setCrnEndTime(now); wrkMast1.setModiTime(now); @@ -1148,6 +1155,9 @@ } // 鍒ゆ柇鏄笉鏄┖闂蹭笁鍒嗛挓 BasCrnp basCrnp = basCrnpService.selectById(crn.getId()); + if (basCrnp.getWrkNo() != 0) { + continue; + } Date now = new Date(); Date modiTime = basCrnp.getModiTime(); long diffInMillis = now.getTime()-modiTime.getTime(); @@ -1670,14 +1680,50 @@ log.error("鍛煎彨rgv,浠诲姟鍙蜂笉瀛樺湪:{}",staProtocol.getWorkNo()); continue; } + // 1083,1086,1089 澶栧舰妫�娴嬪け璐ワ紝涓嶆槸鍘诲紓甯稿彛鐨� 鍋滃湪鍘熷 +// if (staProtocol.getSiteId() == 1083 || staProtocol.getSiteId() == 1086 || staProtocol.getSiteId() == 1089 && wrkMast.getStaNo() != 1090) { +// boolean back = false; +// String errMsg = ""; +// if (staProtocol.isFrontErr()) { +// errMsg = "鍓嶈秴闄�"; +// back = true; +// } +// if (!back && staProtocol.isBackErr()) { +// errMsg = "鍚庤秴闄�"; +// back = true; +// } +// if (!back && staProtocol.isHighErr()) { +// errMsg = "楂樿秴闄�"; +// back = true; +// } +// if (!back && staProtocol.isLeftErr()) { +// errMsg = "宸﹁秴闄�"; +// back = true; +// } +// if (!back && staProtocol.isRightErr()) { +// errMsg = "鍙宠秴闄�"; +// back = true; +// } +// if (back) { +// log.error("{}绔欑偣锛屽褰㈡娴嬪け璐ワ細{}",site,errMsg); +// continue; +// } +// } if (staProtocol.getSiteId() == 1090 && wrkMast.getStaNo() == 1090) { continue; } if ((wrkMast.getWrkSts() == 2 || wrkMast.getWrkSts() == 15) && (wrkMast.getRgvNo() == null || wrkMast.getRgvDstaNo() == 1090)) { // 鏈�1090鐨勪换鍔¤烦杩噐gv鍒嗛厤 if(wrkMast.getStaNo() == 1090) { - int count = wrkMastService.selectCount(new EntityWrapper<WrkMast>().where("sta_no = 1090 or source_sta_no = 1090 ")); - if (count > 1) { + DevpThread devpThread2 = (DevpThread) SlaveConnection.get(SlaveType.Devp, 2); + StaProtocol staProtocol2 = devpThread2.getStation().get(1090); + if(!staProtocol2.isAutoing() || staProtocol2.isLoading() || staProtocol2.getWorkNo() != 0) { + log.info("鍘诲紓甯稿彛鐩爣绔欑偣锛岄潪鑷姩锛屾湁鐗╋紝宸ヤ綔鍙蜂负锛歿}",staProtocol2.getWorkNo()); + continue; + } + int count = wrkMastService.selectCount(new EntityWrapper<WrkMast>().where("sta_no = 1090 and wrk_sts in (9,10)")); + if (count > 0) { + log.info("鍘诲紓甯稿彛锛屼絾鏄墠闈㈡湁鍘诲紓甯稿彛浠诲姟鏁帮細{}",count); continue; } } @@ -1715,7 +1761,7 @@ continue; } - if(wrkMast.getIoType() == 3 && (wrkMast.getStaNo() == 1024 || wrkMast.getStaNo() == 1016 || wrkMast.getStaNo() == 1043)) { // 鍒�1024鍑哄簱鍙o紝鏀惧埌杈撻�佺嚎鍚庝换鍔″畬鎴� + if(wrkMast.getIoType() == 3 && (wrkMast.getStaNo() == 1024 || wrkMast.getStaNo() == 1031 || wrkMast.getStaNo() == 1016 || wrkMast.getStaNo() == 1043)) { // 鍒�1024鍑哄簱鍙o紝鏀惧埌杈撻�佺嚎鍚庝换鍔″畬鎴� if(wrkMast.getWrkSts() != 2 ){ log.warn("rgv鏀捐揣瀹屾垚3锛宺gv鏈浣�:rgv鍙穥}锛屼换鍔″彿锛歿}锛屼换鍔$姸鎬亄}",wrkMast.getRgvNo(),wrkMast.getWrkNo(),wrkMast.getWrkSts()); continue; @@ -1726,7 +1772,7 @@ // } wrkMast.setModiTime(new Date()); wrkMastService.updateById(wrkMast); - } else if(wrkMast.getIoType() == 101 && (wrkMast.getStaNo() == 1024 || wrkMast.getStaNo() == 1016 || wrkMast.getStaNo() == 1043)) { + } else if(wrkMast.getIoType() == 101 && (wrkMast.getStaNo() == 1024 || wrkMast.getStaNo() == 1031 || wrkMast.getStaNo() == 1016 || wrkMast.getStaNo() == 1043)) { if(wrkMast.getWrkSts() != 2 ) { log.warn("rgv鏀捐揣瀹屾垚101锛宺gv鏈浣�:rgv鍙穥}锛屼换鍔″彿锛歿}锛屼换鍔$姸鎬亄}", wrkMast.getRgvNo(), wrkMast.getWrkNo(), wrkMast.getWrkSts()); continue; @@ -1930,6 +1976,7 @@ // <4 < 2 < 4 int count = wrkMastMapper.selectInGzxCount(wantBucket.getSite()); if (wantBucket.getSite() == 1071 && count <= 2 || wantBucket.getSite() == 1064 && count == 0 || wantBucket.getSite() == 1078 && count <= 2) { + log.info("{}鑷姩琛ョ┖妗讹紝缃愯绾胯妗跺瀷淇℃伅锛歿},姝e湪鎵ц浠诲姟鏁帮細{}",wantBucket.getSite(), wantBucket.getBucketType(),count); // 鍒ゆ柇搴撻噷鏈夋棤绌烘《缁� List<LocDetl> locDetlList = locDetlService.selectListByMatnr(wantBucket.getBucketType()); for (int i = 0; i < locDetlList.size(); i++) { @@ -2060,14 +2107,6 @@ param.setSourceStaNo(site + 2); param.setTbFlag(staProtocol2.isBarcodeErr()); param.setCannedVolume(Math.round(staProtocol.getCannedVolume() * 100.0) / 100.0); -// param.setWrkNo(57); -// param.setMatnr("101"); -// param.setBatch("tt1"); -// param.setManuDate("2025-06-05"); -// param.setWeight(100.0); -// param.setGrossWeight(100.0); -// param.setSourceStaNo(site); -// param.setTbFlag(true); String response = new HttpHandler.Builder() .setUri(wmsUrl) -- Gitblit v1.9.1