From e609c7adf42ef6eea053ff33a8e59abaf0767df6 Mon Sep 17 00:00:00 2001 From: zhangc <zc@123> Date: 星期五, 17 一月 2025 08:54:52 +0800 Subject: [PATCH] 1 --- src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java | 28 +++++++++++++++++----------- 1 files changed, 17 insertions(+), 11 deletions(-) diff --git a/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java index 955aa3b..3ee5b12 100644 --- a/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java @@ -11,6 +11,7 @@ import com.zy.asrs.entity.param.LocDetlAdjustParam; import com.zy.asrs.entity.param.StockOutParam; import com.zy.asrs.service.*; +import com.zy.asrs.utils.OrderUtils; import com.zy.asrs.utils.Utils; import com.zy.common.model.LocDto; import com.zy.common.model.OrderDto; @@ -31,6 +32,7 @@ import java.util.Iterator; import java.util.List; import java.util.concurrent.atomic.AtomicBoolean; +import java.util.concurrent.atomic.AtomicReference; /** * Created by vincent on 2020/6/11 @@ -103,7 +105,7 @@ List<AgvWaitPakin> agvWaitPakinList = agvWaitPakinService.selectList(new EntityWrapper<AgvWaitPakin>().eq("supp_code", agvBasDevp.getBarcode())); //妫�绱㈠簱浣嶏紝閫夋嫨鍚堥�傜殑搴撲綅 - AgvLocMast agvLocMast = agvCommonService.getLocNo(agvBasDevp.getLocType1(), agvBasDevp.getFloor(), false, false,null); + AgvLocMast agvLocMast = agvCommonService.getLocNo(agvBasDevp.getLocType1(), agvBasDevp.getFloor(), false, false); //鐢熸垚宸ヤ綔妗� AgvWrkMast wrkMast = createWrkMast(1, 201L, agvBasDevp.getDevNo(), agvLocMast.getLocNo(), agvBasDevp.getBarcode(), now, userId, agvBasDevp.getLocType2(), agvLocMast.getPltType()); //鏍囪鏄惁涓鸿緭閫佺嚎鍏ュ簱 @@ -480,7 +482,7 @@ 鍏ュ簱 */ @Transactional - public String emptyPlateIn(String station, String containerCode, Short containerType, Long userId, boolean emptyAutoIn,String factory) { + public String emptyPlateIn(String station, String containerCode, Short containerType, Long userId, boolean emptyAutoIn) { Date now = new Date(); @@ -520,6 +522,7 @@ if (agvBasDevp.getLocType1() != br) { throw new CoolException("绔欑偣绫诲瀷鍜岃揣鏋剁被鍨嬩笉绗︼紒"); } + AtomicReference<String> factory = new AtomicReference<>(); if (containerType == 40) { locType = 5; } else if (containerType == 21 && agvBasDevp.getFloor() == 3) { @@ -528,9 +531,9 @@ locType = 2; } else if (containerType == 30) { locType = 3; - } else if (containerType == 31) { + } else if (containerType == 31) { locType = 6; - }else { + } else { locType = agvBasDevp.getLocType1(); } @@ -558,6 +561,7 @@ if (!Cools.isEmpty(agvWaitPakinList)) { AtomicBoolean isCurrLev = new AtomicBoolean(false); agvWaitPakinList.forEach(agvWaitPakin -> { + factory.set(OrderUtils.getFactory(agvWaitPakin.getThreeCode())); if (!Cools.isEmpty(agvWaitPakin.getProcessSts())) { if (agvWaitPakin.getProcessSts() == 1) { isCurrLev.set(true); @@ -569,19 +573,19 @@ Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "elevatorTasks")); if (Cools.isEmpty(config)) { if (isCurrLev.get()) { - agvLocMast = agvCommonService.getLocNo(locType, agvBasDevp.getFloor(), false, true,factory); + agvLocMast = agvCommonService.getLocNo(locType, agvBasDevp.getFloor(), false, true); } else { - agvLocMast = agvCommonService.getLocNo(locType, agvBasDevp.getFloor(), false, false,factory); + agvLocMast = agvCommonService.getLocNo(locType, agvBasDevp.getFloor(), false, false); } } else { List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().like("loc_no", "02F1").like("source_loc_no", "F1")); if (Integer.parseInt(config.getValue()) <= agvWrkMasts.size()) { - agvLocMast = agvCommonService.getLocNo(locType, agvBasDevp.getFloor(), false, true,factory); + agvLocMast = agvCommonService.getLocNo(locType, agvBasDevp.getFloor(), false, true); } else { if (isCurrLev.get()) { - agvLocMast = agvCommonService.getLocNo(locType, agvBasDevp.getFloor(), false, true,factory); + agvLocMast = agvCommonService.getLocNo(locType, agvBasDevp.getFloor(), false, true); } else { - agvLocMast = agvCommonService.getLocNo(locType, agvBasDevp.getFloor(), false, false,factory); + agvLocMast = agvCommonService.getLocNo(locType, agvBasDevp.getFloor(), false, false); } //agvLocMast = agvCommonService.getLocNo(locType,agvBasDevp.getFloor(),false,false); } @@ -628,6 +632,9 @@ // 绔欑偣妫�娴� AgvBasDevp agvBasDevp = agvBasDevpService.selectById(station); + if (Cools.isEmpty(agvBasDevp)) { + throw new CoolException("绔欑偣淇℃伅涓嶅瓨鍦�"); + } if (!agvBasDevp.getLocSts().equals("O")) { throw new CoolException("褰撳墠宸ヤ綔浣嶇姸鎬佷负" + agvBasDevp.getLocSts() + ",鏃犳硶杩涜绌烘澘鍑哄簱"); } @@ -645,8 +652,7 @@ } if (Cools.isEmpty(agvLocMast)) { - log.info("鏆傛棤褰撳墠鍑哄簱绔欑偣绫诲瀷鐨勭┖璐ф灦锛�"); - return; + throw new CoolException("鏆傛棤褰撳墠鍑哄簱绔欑偣绫诲瀷鐨勭┖璐ф灦锛�"); } //鐢熸垚宸ヤ綔妗� createWrkMast(110, 21L, agvLocMast.getLocNo(), agvBasDevp.getDevNo(), agvLocMast.getBarcode(), now, userId, containerType, agvLocMast.getPltType()); -- Gitblit v1.9.1