From 2a08feb00e3da1aacf1427751788fa37346dd2a2 Mon Sep 17 00:00:00 2001 From: zhangc <zc@123> Date: 星期六, 15 三月 2025 14:12:00 +0800 Subject: [PATCH] 四期 --- src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java | 66 ++++++++++++++++++++++++++------ 1 files changed, 53 insertions(+), 13 deletions(-) diff --git a/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java b/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java index 2aae096..648ab24 100644 --- a/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java +++ b/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java @@ -7,6 +7,7 @@ import com.core.common.Cools; import com.core.common.SnowflakeIdWorker; import com.core.exception.CoolException; +import com.zy.asrs.constant.AsrsConstants; import com.zy.asrs.entity.*; import com.zy.asrs.entity.param.MesBuyPakinReportParam; import com.zy.asrs.entity.param.MesOrderReportParam; @@ -26,6 +27,8 @@ import java.io.IOException; import java.util.*; import java.util.stream.Collectors; + +import static org.reflections.Reflections.log; @Slf4j @Service @@ -187,11 +190,24 @@ break; case 10: agvLocMastService.updateLocStsByLocNo(agvWrkMast.getLocNo(), "D", agvWrkMast.getBarcode(), agvWrkMast.getWhsType().shortValue()); - agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getSourceLocNo(), "O", "", (short) 0); + AgvBasDevp byDevNo = agvBasDevpService.getByDevNo(agvWrkMast.getSourceLocNo()); + if (byDevNo != null) { + if ("S".equals(byDevNo.getLocSts()) || "F".equals(byDevNo.getLocSts())) { + + } else { + agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getSourceLocNo(), "O", "", agvWrkMast.getWhsType().shortValue()); + } + } + //agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getSourceLocNo(), "O", "", (short) 0); break; case 11: case 12: - agvLocMastService.updateLocStsByLocNo(agvWrkMast.getLocNo(), "F", agvWrkMast.getBarcode(), agvWrkMast.getWhsType().shortValue()); + AgvLocDetl agvLocDetl1 = agvLocDetlService.selectByLocNo(agvWrkMast.getSourceLocNo()); + if (agvLocDetl1 == null) { + agvLocMastService.updateLocStsByLocNo(agvWrkMast.getLocNo(), "D", agvWrkMast.getBarcode(), agvWrkMast.getWhsType().shortValue()); + } else { + agvLocMastService.updateLocStsByLocNo(agvWrkMast.getLocNo(), "F", agvWrkMast.getBarcode(), agvWrkMast.getWhsType().shortValue()); + } //鏇存柊搴撳瓨鏄庣粏 agvLocDetlService.updateStock(agvWrkMast.getSourceLocNo(), agvWrkMast.getLocNo()); //淇敼婧愬簱浣嶇姸鎬佷负O @@ -240,7 +256,14 @@ }); agvLocMastService.updateLocStsByLocNo(agvWrkMast.getLocNo(), "F", agvWrkMast.getBarcode(), agvWrkMast.getWhsType().shortValue()); - agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getSourceLocNo(), "O", "", agvWrkMast.getWhsType().shortValue()); + byDevNo = agvBasDevpService.getByDevNo(agvWrkMast.getSourceLocNo()); + if (byDevNo != null) { + if ("S".equals(byDevNo.getLocSts()) || "F".equals(byDevNo.getLocSts())) { + + } else { + agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getSourceLocNo(), "O", "", agvWrkMast.getWhsType().shortValue()); + } + } break; case 57: // 鏇存柊搴撳瓨鏄庣粏 @@ -257,7 +280,14 @@ } }); // 鏇存柊绔欑偣 + 搴撲綅鐘舵�� 婧愬簱浣嶆槸绔欑偣 - agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getSourceLocNo(), "O", "", agvWrkMast.getWhsType().shortValue()); + byDevNo = agvBasDevpService.getByDevNo(agvWrkMast.getSourceLocNo()); + if (byDevNo != null) { + if ("S".equals(byDevNo.getLocSts()) || "F".equals(byDevNo.getLocSts())) { + + } else { + agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getSourceLocNo(), "O", "", agvWrkMast.getWhsType().shortValue()); + } + } agvLocMastService.updateLocStsByLocNo(agvWrkMast.getLocNo(), "F", agvWrkMast.getBarcode(), agvWrkMast.getWhsType().shortValue(), agvWrkMast.getCtnNo()); break; case 58: @@ -267,10 +297,10 @@ case 108: case 114: agvLocMastService.updateLocStsByLocNo(agvWrkMast.getLocNo(), "F", agvWrkMast.getBarcode(), agvWrkMast.getWhsType().shortValue()); - //鏇存柊搴撳瓨鏄庣粏 - agvLocDetlService.updateStock(agvWrkMast.getSourceLocNo(), agvWrkMast.getLocNo()); - //淇敼婧愬簱浣嶇姸鎬佷负O - agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(), "O", "", agvWrkMast.getWhsType().shortValue(), "", (short) 0); +// //鏇存柊搴撳瓨鏄庣粏 +// agvLocDetlService.updateStock(agvWrkMast.getSourceLocNo(), agvWrkMast.getLocNo()); +// //淇敼婧愬簱浣嶇姸鎬佷负O +// agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(), "O", "", agvWrkMast.getWhsType().shortValue(), "", (short) 0); break; case 109: // 搴撲綅 -- 鎺ラ┏浣� / 搴撲綅 @@ -286,7 +316,7 @@ // 搴撲綅 -- 鎺ラ┏浣� / 搴撲綅 } else { //淇敼婧愬簱浣嶇姸鎬佷负O - agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(), "O", "", agvWrkMast.getWhsType().shortValue(), "", (short) 0); + //agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(), "O", "", agvWrkMast.getWhsType().shortValue(), "", (short) 0); } break; case 111: @@ -432,8 +462,18 @@ //鐩爣绔欑偣 if (agvWrkMast.getLocNo().startsWith("QO") && agvWrkMast.getLocNo().endsWith("F4") && Integer.valueOf(agvWrkMast.getBarcode().substring(0, 2)) == 30) { if (!agvWrkMast.getSourceLocNo().endsWith("02F1")) { - AgvLocMast locByFloor = agvCommonService.getLocByFloor(3, 1); - if (locByFloor != null) { + AgvLocMast locByFloor = null; + try { + locByFloor = agvCommonService.getLocByLocRule(3, 1, AsrsConstants.ERCHANG, true); + } catch (Exception e) { + + } + if (locByFloor != null && locByFloor.getLocNo().endsWith("02F1")) { + AgvLocMast agvLocMast = agvLocMastService.selectById(agvWrkMast.getSourceLocNo()); + agvLocMast.setLocSts("O"); + agvLocMast.setModiTime(now); + agvLocMast.setBarcode(""); + agvLocMastService.updateById(agvLocMast); wrkMast.setLocNo(locByFloor.getLocNo()); } else { wrkMast.setLocNo(agvWrkMast.getSourceLocNo()); @@ -444,7 +484,7 @@ } else { wrkMast.setLocNo(agvWrkMast.getSourceLocNo()); } - + //wrkMast.setLocNo(agvWrkMast.getSourceLocNo()); //璐ф灦缂栫爜 wrkMast.setBarcode(agvWrkMast.getBarcode()); @@ -460,7 +500,7 @@ if (!agvWrkMastService.insertByIncrease(wrkMast)) { throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�"); } - AgvLocMast agvLocMast = agvLocMastService.selectById(agvWrkMast.getSourceLocNo()); + AgvLocMast agvLocMast = agvLocMastService.selectById(wrkMast.getLocNo()); agvLocMast.setLocSts("S"); agvLocMast.setModiTime(now); agvLocMastService.updateById(agvLocMast); -- Gitblit v1.9.1