From 2d90ffa46399dce01b9a70e03fba282ef794cb92 Mon Sep 17 00:00:00 2001 From: zhang <zc857179121@qq.com> Date: 星期三, 09 七月 2025 11:11:53 +0800 Subject: [PATCH] 1 --- src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 27 ++++++++++++++++----------- 1 files changed, 16 insertions(+), 11 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 4c9d443..4f9e135 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -181,17 +181,22 @@ } storageEscalationParam.setBarcode(BoxNo); storageEscalationParam.setMatIdList(staProtocol.getMatIdList()); + storageEscalationParam.setFullPlt(staProtocol.isFullPlt() ? 1 : 0); log.info("缁勬墭鍏ュ簱={}", storageEscalationParam); TaskWrk taskWrk = toWmsService.getLocNoFromWms(storageEscalationParam); if (taskWrk == null) { log.error("鍏ュ簱璇锋眰wms鍒涘缓浠诲姟宸ヤ綔妗d负绌猴細{}", storageEscalationParam); continue; + } else { + if (-1 == taskWrk.getWrkNo()) { + back = true; + } } if (back) { staProtocol.setStaNo(inSta.getBackSta().shortValue()); devpThread.setPakMk(staProtocol.getSiteId(), false); MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); - log.info("缁勬墭鍏ュ簱鎵樼洏閫�鍥炲懡浠ゆ帹閫佽緭閫佺嚎闃熷垪鎴愬姛==>{}锛寋}", BoxNo, errMsg); + log.info("缁勬墭鍏ュ簱鎵樼洏閫�鍥炲懡浠ゆ帹閫佽緭閫佺嚎闃熷垪鎴愬姛==>{}锛寋}锛寋}", BoxNo, errMsg, taskWrk.getWrkNo()); } else { StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>() .eq("crn_no", taskWrk.getCrnNo()).eq("type_no", 1).eq("stn_no", staProtocol.getSiteId())); @@ -354,16 +359,16 @@ continue; } - LocMast locMast = locMastService.selectByLocNo(taskWrk.getTargetPoint()); - if (!locMast.getLocSts().equals("O")) { - if (taskWrk.getWrkSts() == 2) { - log.error("鍏ュ簱WMS鍒嗛厤搴撲綅{}鏈夎锛屽簱浣嶇姸鎬佷负{}", locMast.getLocNo(), locMast.getLocSts()); - taskWrk.setWrkSts(5); - taskWrk.setMemo("WMS鍒嗛厤搴撲綅鏈夎"); - taskWrkService.updateById(taskWrk); - } - continue; - } +// LocMast locMast = locMastService.selectByLocNo(taskWrk.getTargetPoint()); +// if (!locMast.getLocSts().equals("O")) { +// if (taskWrk.getWrkSts() == 2) { +// log.error("鍏ュ簱WMS鍒嗛厤搴撲綅{}鏈夎锛屽簱浣嶇姸鎬佷负{}", locMast.getLocNo(), locMast.getLocSts()); +// taskWrk.setWrkSts(5); +// taskWrk.setMemo("WMS鍒嗛厤搴撲綅鏈夎"); +// taskWrkService.updateById(taskWrk); +// } +// continue; +// } // 鍫嗗灈鏈烘帶鍒惰繃婊� if (!crnProtocol.getStatusType().equals(CrnStatusType.IDLE) || crnProtocol.getTaskNo() != 0) { -- Gitblit v1.9.1