From 617a8c4fc0b81ec4b96db8a013a91f4e666b0b96 Mon Sep 17 00:00:00 2001 From: zhangc <zc@123> Date: 星期三, 08 一月 2025 14:33:45 +0800 Subject: [PATCH] 出现空指针异常 --- src/main/java/com/zy/asrs/task/handler/AutoMoveHandler.java | 136 ++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 132 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/zy/asrs/task/handler/AutoMoveHandler.java b/src/main/java/com/zy/asrs/task/handler/AutoMoveHandler.java index dc7ce58..4ee427c 100644 --- a/src/main/java/com/zy/asrs/task/handler/AutoMoveHandler.java +++ b/src/main/java/com/zy/asrs/task/handler/AutoMoveHandler.java @@ -55,6 +55,12 @@ doHandMove2(agvWrkMast); return SUCCESS; } + + public ReturnT<String> start4(AgvWrkMast agvWrkMast) { + // locType 1. 鑷姩锛� 2. 鎵嬪姩 + doAutoMove3(agvWrkMast); + return SUCCESS; + } //鏍规嵁搴撲綅鐨刲octype鍊煎彂閫佷换鍔�--寮冪敤 private ReturnT<String> doAutoMove(AgvLocMast agvLocMast) { Date now = new Date(); @@ -87,6 +93,7 @@ mast.setAppeTime(now); mast.setModiUser(9527L); mast.setModiTime(now); + mast.setLogErrMemo("doAutoMove"); if (!agvWrkMastService.insertByIncrease(mast)) { throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�"); } @@ -184,16 +191,49 @@ //妫�绱㈠簱浣嶏紝閫夋嫨鍚堥�傜殑搴撲綅 AgvLocMast locMast = agvCommonService.getLocNo(3,agvWrkMast.getCrnNo(),false,true); if (Cools.isEmpty(locMast)) { - throw new CoolException("鏆傛棤搴撲綅"); + log.info("鏆傛棤搴撲綅"); + return FAIL; + //throw new CoolException("鏆傛棤搴撲綅"); + } + AgvWrkMast workingMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", locMast.getLocNo())); + if (!Cools.isEmpty(workingMast)) { + log.info("褰撳墠搴撲綅姝e湪杩涜鍏ュ簱锛岃繘琛屼笅涓�娆¤疆璇�"); + return FAIL; + //throw new CoolException("褰撳墠搴撲綅姝e湪杩涜鍏ュ簱锛岃繘琛屼笅涓�娆¤疆璇�"); + } + agvWrkMast.setWrkSts(201L); + agvWrkMast.setModiTime(new Date()); + agvWrkMast.setLocNo(locMast.getLocNo()); + agvWrkMast.setLogErrMemo("start2-doAutoMove2"); + agvWrkMastService.updateById(agvWrkMast); + //鏇存柊鐩爣搴撲綅鐘舵�� + updateAgvLocMast(locMast,"S"); + AgvLocMast locMast1 = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", locMast.getLocNo())); + log.info("鑷姩璋冩嫧浠诲姟 ==> 婧愬簱浣嶏細{}锛岀洰鏍囧簱浣嶏細{},搴撲綅鐘舵�亄}",agvWrkMast.getSourceLocNo(),agvWrkMast.getLocNo(),locMast1.getLocSts()); + + return SUCCESS; + } + + private ReturnT<String> doAutoMove3(AgvWrkMast agvWrkMast) { + Date now = new Date(); + //妫�绱㈠簱浣嶏紝閫夋嫨鍚堥�傜殑搴撲綅 + AgvLocMast locMast = agvCommonService.getLocNo(3,agvWrkMast.getCrnNo(),false,false); + if (Cools.isEmpty(locMast)) { + log.info("鏆傛棤搴撲綅"); + return FAIL; + //throw new CoolException("鏆傛棤搴撲綅"); } agvWrkMast.setWrkSts(201L); agvWrkMast.setLocNo(locMast.getLocNo()); + agvWrkMast.setLogErrMemo("start2-doAutoMove2"); + agvWrkMast.setModiTime(new Date()); agvWrkMastService.updateById(agvWrkMast); //鏇存柊鐩爣搴撲綅鐘舵�� updateAgvLocMast(locMast,"S"); return SUCCESS; } + private ReturnT<String> doHandMove2(AgvWrkMast agvWrkMast) { Date now = new Date(); String lev1 = agvWrkMast.getSourceLocNo().substring(agvWrkMast.getSourceLocNo().length() - 4).substring(0, 2); @@ -201,15 +241,20 @@ if ("01".equals(lev1)) { devpNo = agvCommonService.getDevpNo(3, 1, "Y", "Y"); } else { - devpNo = agvCommonService.getDevpNo(3, 5, "Y", "Y"); + devpNo = agvCommonService.getDevpNo(3, 4, "Y", "Y"); } if (Cools.isEmpty(devpNo)) { - throw new CoolException("鏆傛棤绌洪棽鎺ラ┏浣�"); + log.info("鏆傛棤绌洪棽鎺ラ┏浣�"); + return FAIL; + //throw new CoolException("鏆傛棤绌洪棽鎺ラ┏浣�"); } agvWrkMast.setWrkSts(201L); agvWrkMast.setLocNo(devpNo.getDevNo()); + agvWrkMast.setModiTime(new Date()); + agvWrkMast.setLogErrMemo("start3-doHandMove2"); agvWrkMastService.updateById(agvWrkMast); + agvWrkMast.setModiTime(new Date()); updateAgvBasDevp(devpNo,"S",null,agvWrkMast.getBarcode()); return SUCCESS; } @@ -268,6 +313,7 @@ mast.setAppeTime(now); mast.setModiUser(9527L); mast.setModiTime(now); + mast.setLogErrMemo("autoEmptyBack"); if (!agvWrkMastService.insertByIncrease(mast)) { throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�"); } @@ -277,6 +323,7 @@ updateAgvBasDevp(devpNo,"S",agvLocMast.getLocType2(),agvLocMast.getBarcode()); return SUCCESS; } + public ReturnT<String> autoEmptyBack3(AgvWrkMast agvWrkMast) { Date now = new Date(); AgvBasDevp agvBasDevp = agvBasDevpService.selectByDevNo(agvWrkMast.getSourceLocNo()); @@ -290,6 +337,7 @@ agvWrkMast.setLocNo(locMast.getLocNo()); agvWrkMast.setModiUser(9527L); agvWrkMast.setModiTime(now); + agvWrkMast.setLogErrMemo("autoEmptyBack3"); if (!agvWrkMastService.updateById(agvWrkMast)) { throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�"); } @@ -298,6 +346,7 @@ updateAgvBasDevp(agvBasDevp,"R"); return SUCCESS; } + public ReturnT<String> autoEmptyBack2(AgvLocMast agvLocMast) { Date now = new Date(); //鏌ヨ宸ヤ綔妗� @@ -329,6 +378,7 @@ mast.setAppeTime(now); mast.setModiUser(9527L); mast.setModiTime(now); + mast.setLogErrMemo("autoEmptyBack2"); if (!agvWrkMastService.insertByIncrease(mast)) { throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�"); } @@ -358,7 +408,9 @@ } List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("io_type", 109).like("source_loc_no", floor).or().eq("io_type", 113)); if (agvWrkMasts.size() >= 5) { - throw new CoolException("鏆傚仠鍥炴祦"); + log.error("鏆傚仠鍥炴祦"); + return FAIL; + //throw new CoolException("鏆傚仠鍥炴祦"); } //妫�绱㈢┖闂插彲鍏ユ帴椹充綅 娌℃湁绌洪棽鍙叆鎺ラ┏浣� 鐩存帴鎵惧簱浣� AgvBasDevp devpNo = agvCommonService.getDevpNo(3, agvLocMast.getFloor(),"Y","Y"); @@ -396,6 +448,7 @@ mast.setAppeTime(now); mast.setModiUser(9527L); mast.setModiTime(now); + mast.setLogErrMemo("autoEmptyBack4"); if (!agvWrkMastService.insertByIncrease(mast)) { throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�"); } @@ -434,6 +487,7 @@ mast.setAppeTime(now); mast.setModiUser(9527L); mast.setModiTime(now); + mast.setLogErrMemo("autoEmptyBack5"); // 鍒ゆ柇 鎺ラ┏鐐规槸鍚﹁嚜鍔� if ("Y".equals(agvBasDevp.getAutoing())) { //宸ヤ綔鐘舵�� @@ -490,6 +544,7 @@ mast.setAppeTime(now); mast.setModiUser(9527L); mast.setModiTime(now); + mast.setLogErrMemo("autoEmptyBack6"); if (!agvWrkMastService.insertByIncrease(mast)) { throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�"); } @@ -499,4 +554,77 @@ return SUCCESS; } + + public ReturnT<String> autoTransfers(AgvLocMast agvLocMast,Integer maxTansk) { + Date now = new Date(); + List<AgvLocDetl> locDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", agvLocMast.getLocNo())); + locDetls.forEach(agvLocDetl -> { + if (agvLocDetl.getProcessSts().equals(1)) { + throw new CoolException("褰撳墠搴撲綅鏈夊簱瀛樻湭鍔犲伐"); + } + }); + //鏌ヨ宸ヤ綔妗� + AgvWrkMast agvWrkMast = agvWrkMastService.selectByContainerCode(agvLocMast.getBarcode()); + if(!Cools.isEmpty(agvWrkMast)){ + throw new CoolException("褰撳墠"+agvLocMast.getBarcode()+"璐ф灦鐮佸凡鍦ㄥ伐浣滄。涓�"); + } + //妫�绱㈠簱浣嶏紝閫夋嫨鍚堥�傜殑搴撲綅 + AgvLocMast LocMast = agvCommonService.getLocNo(3,1,false,false); + if (LocMast.getLev1() != 2) { + throw new CoolException("鐩爣妤煎眰涓嶆槸鍚稿浜屾ゼ"); + } + List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().like("loc_no", "02F1").like("source_loc_no", "F1").eq("io_type", 12)); + if (agvWrkMasts.size() >= maxTansk) { + throw new CoolException("鑷姩绉诲簱浠诲姟宸插埌璁惧畾鏈�澶у�硷細" + maxTansk); + } + //鐢熸垚宸ヤ綔妗� + AgvWrkMast mast = new AgvWrkMast(); + //宸ヤ綔鐘舵�� + mast.setWrkSts(201L); + //鍏ュ嚭搴撶被鍨� + mast.setIoType(12); + mast.setIoTime(now); + //浼樺厛绾� + mast.setIoPri(300.0); + //婧愮珯鐐� + mast.setSourceLocNo(agvLocMast.getLocNo()); + //鐩爣绔欑偣 + mast.setLocNo(LocMast.getLocNo()); + //璐ф灦缂栫爜 + mast.setBarcode(agvLocMast.getBarcode()); + //璐ф灦绫诲瀷 + mast.setWhsType(30); + + mast.setAppeUser(9527L); + mast.setAppeTime(now); + mast.setModiUser(9527L); + mast.setModiTime(now); + mast.setLogErrMemo("doAutoMove"); + if (!agvWrkMastService.insertByIncrease(mast)) { + throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�"); + } + + AgvWrkMast mast1 = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", LocMast.getLocNo()).eq("source_loc_no",agvLocMast.getLocNo())); + //鐢熸垚宸ヤ綔妗f槑缁� + List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", agvLocMast.getLocNo())); + agvLocDetls.forEach(agvLocDetl -> { + AgvWrkDetl wrkDetl = new AgvWrkDetl(); + wrkDetl.setWrkNo(mast1.getWrkNo()); + wrkDetl.sync(agvLocDetl); + wrkDetl.setSuppCode(agvLocDetl.getSuppCode()); + wrkDetl.setIoTime(now); + wrkDetl.setAppeUser(9527L); + wrkDetl.setAppeTime(now); + wrkDetl.setModiUser(9527L); + wrkDetl.setModiTime(now); + if (!agvWrkDetlService.insert(wrkDetl)) { + throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏澶辫触"); + } + }); + //鏇存柊鐩爣搴撲綅鐘舵�� + updateAgvLocMast(agvLocMast,"R"); + updateAgvLocMast(LocMast,"S"); + + return SUCCESS; + } } -- Gitblit v1.9.1