From 7c1af4c63e66754f0868c1a501f4895f9cbc9213 Mon Sep 17 00:00:00 2001 From: zhangchao <zc857179121@qq.com> Date: 星期五, 15 十一月 2024 09:29:12 +0800 Subject: [PATCH] 双单位 --- src/main/java/com/zy/asrs/service/impl/AgvMobileServiceImpl.java | 223 ++++++++++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 185 insertions(+), 38 deletions(-) diff --git a/src/main/java/com/zy/asrs/service/impl/AgvMobileServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/AgvMobileServiceImpl.java index 0a596ab..af0be84 100644 --- a/src/main/java/com/zy/asrs/service/impl/AgvMobileServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/AgvMobileServiceImpl.java @@ -150,7 +150,9 @@ agvWrkDetlService.insert(wrkDetl); } else { Double anfme = agvWrkDetl.getAnfme() + pick.getCount(); + agvWrkDetl.setIoTime(agvWrkMast.getIoTime()); agvWrkDetl.setAnfme(anfme); + agvWrkDetl.setModiTime(now); agvWrkDetlService.update(agvWrkDetl,new EntityWrapper<AgvWrkDetl>().eq("matnr",agvWrkDetl.getMatnr()).eq("three_code",agvWrkDetl.getThreeCode()).eq("supp_code",pick.getSuppCode())); } @@ -162,27 +164,32 @@ if (!orderDetlService.update(orderDetl,new EntityWrapper<OrderDetl>().eq("order_no", pick.getOrderNo()).eq("matnr", pick.getMatnr()).eq("three_code",pick.getThreeCode()))){ throw new CoolException("淇敼璁㈠崟鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�"+pick.getOrderNo()+pick.getMatnr()); } - } - // 纭鏄惁鍏ㄩ儴鍑哄簱 - int sameNumber = 0; - List<AgvWrkDetl> agvWrkDetls = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", pickParams.getWrkNo())); - for (AgvLocDetl agvLocDetl : agvLocDetls) { - for (AgvWrkDetl agvWrkDetl : agvWrkDetls) { - if (agvLocDetl.getMatnr().equals(agvWrkDetl.getMatnr()) - && agvLocDetl.getThreeCode().equals(agvWrkDetl.getThreeCode()) - && agvLocDetl.getSuppCode().equals(agvWrkDetl.getSuppCode()) - && agvLocDetl.getAnfme().equals(agvWrkDetl.getAnfme())) { - sameNumber++; + Order order = orderService.selectByNo(orderDetl.getOrderNo()); + if (order.getSettle() == 1) { + if (!orderService.updateSettle(order.getId(), 2L, userId)) { + throw new CoolException("鍐嶆鎷f枡锛氭洿鏂拌鍗曠姸鎬佸け璐ワ紒"); } } } - if (agvLocDetls.size() == sameNumber) { + // 纭鏄惁鍏ㄩ儴鍑哄簱 + double totleWrkdetl = 0.0; + double totleLocdetl = 0.0; + List<AgvWrkDetl> agvWrkDetls = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", pickParams.getWrkNo())); + for (AgvLocDetl agvLocDetl : agvLocDetls) { + totleLocdetl = totleLocdetl + agvLocDetl.getAnfme(); + } + for (AgvWrkDetl agvWrkDetl : agvWrkDetls) { + totleWrkdetl = totleWrkdetl + agvWrkDetl.getAnfme(); + } + if (totleWrkdetl >= totleLocdetl) { agvWrkMast.setIoType(101); agvWrkMastService.update(agvWrkMast,new EntityWrapper<AgvWrkMast>().eq("wrk_no", pickParams.getWrkNo())); + } +// agvLocDetls.size() == 1 - return "缁勬墭鎴愬姛锛岀粦瀹氱珯鐐规垚鍔�"; + return "鎷f枡鎴愬姛"; } /* @@ -277,8 +284,13 @@ if (Cools.isEmpty(mat)) { throw new CoolException(detlDto.getMatnr() + "鍟嗗搧妗f涓嶅瓨鍦�"); } + OrderDetl orderDetl = orderDetlService.selectItem(orderNo, mat.getMatnr(), detlDto.getBatch(), detlDto.getCsocode()); AgvWaitPakin waitPakin = new AgvWaitPakin(); waitPakin.sync(mat); + if (orderDetl != null) { + waitPakin.setWeight(orderDetl.getWeight()); + waitPakin.setVolume(orderDetl.getVolume()); + } waitPakin.setOrderNo(orderNo); // 鍗曟嵁缂栧彿 waitPakin.setBatch(detlDto.getBatch()); // 搴忓垪鐮� //waitPakin.setZpallet(zpallet); // 璐ф灦鐮� @@ -388,6 +400,20 @@ public String handControlLocMove(LocMoveParam param, Long userId) { String fl = String.valueOf(param.getFloor()); short floor =(short)Integer.parseInt(fl.substring(0, 1)); + switch (param.getFloor()) { + case "1F01": + floor = 1; + break; + case "1F02": + floor = 4; + break; + case "2F": + floor = 2; + break; + case "3F": + floor = 3; + break; + } Integer ioType = 0; AgvLocMast agvLocMast = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", param.getLocNo())); if (Cools.isEmpty(agvLocMast)) { @@ -405,17 +431,23 @@ } } else { if (agvLocMast.getFloor() != floor) { -// if (floor==1 && agvLocMast.getFloor()!=1){ -// ioType = 121; -// }else { - if (agvLocMast.getFloor() == 1) { - throw new CoolException("褰撳墠搴撲綅璇烽�夋嫨璋冩嫧鍗曡皟鎷紒"); + if (agvLocMast.getFloor() == 1 && (floor == 2 || floor == 3)) { + throw new CoolException("褰撳墠搴撲綅璇烽�夋嫨璋冩嫧鍗曡皟鎷紒"); + } else if ((agvLocMast.getFloor() == 2 || agvLocMast.getFloor() == 3) && (floor == 1 || floor == 4)) { + throw new CoolException("褰撳墠搴撲綅璇烽�夋嫨璋冩嫧鍥炴祦鍗曞洖閫�锛�"); + } else { + ioType = 12; + } + } else { + if (agvLocMast.getFloor() == 1) { + if (agvLocMast.getLev1() == 1 && floor == 1) { + ioType = 11; } else { ioType = 12; } -// } - } else { - ioType = 11; + } else { + ioType = 11; + } } } Date now = new Date(); @@ -425,7 +457,21 @@ throw new CoolException("褰撳墠"+agvLocMast.getBarcode()+"璐ф灦鐮佸凡鍦ㄥ伐浣滄。涓�"); } //妫�绱㈠簱浣嶏紝閫夋嫨鍚堥�傜殑搴撲綅 - AgvLocMast locMast = agvCommonService.getLocNo(agvLocMast.getLocType1(),floor,false,true); + AgvLocMast locMast = null; + if (floor == 1) { + locMast = agvCommonService.getLocNo(agvLocMast.getLocType1(),floor,true,false); + } else { + locMast = agvCommonService.getLocNo(agvLocMast.getLocType1(),floor,false,false); + } + + // 鐩爣妤煎眰鍘� 鍚稿2妤� + if (floor == 4) { + if (locMast.getLev1() == 1) { + throw new CoolException("鍚稿涓�妤兼病鏈夌┖搴撲綅鍙互绉诲簱锛�"); + } + + } + if (Cools.isEmpty(locMast)) { throw new CoolException("褰撳墠妤煎眰娌℃湁绌哄簱浣�"); } @@ -455,6 +501,7 @@ mast.setAppeTime(now); mast.setModiUser(userId); mast.setModiTime(now); + mast.setLogErrMemo("handControlLocMove"); if (!agvWrkMastService.insertByIncrease(mast)) { throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�"); } @@ -478,17 +525,29 @@ }); } - // 濡傛灉褰撳墠浠诲姟鏄澹充簩涓夋ゼ鍥為��涓�妤肩殑 鍥炴粴璋冩嫧鍗� - if (ioType == 12 && locMast.getFloor() == 1) { - List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", agvLocMast.getLocNo())); - for (AgvLocDetl agvLocDetl : agvLocDetls) { - OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("three_code", agvLocDetl.getThreeCode()).eq("matnr", agvLocDetl.getMatnr()).eq("order_no", "DB" + agvLocDetl.getOrderNo())); - orderDetl.setQty(orderDetl.getQty() - agvLocDetl.getAnfme()); - if (!orderDetlService.updateById(orderDetl)) { - throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏澶辫触"); - } - } - } +// // 濡傛灉褰撳墠浠诲姟鏄澹充簩涓夋ゼ鍥為��涓�妤肩殑 鍥炴粴璋冩嫧鍗� +// if (ioType == 12 && locMast.getFloor() == 1 && floor != 4 && agvLocMast.getFloor() != 1) { +// List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(new EntityWrapper<AgvLocDetl>().eq("loc_no", agvLocMast.getLocNo())); +// for (AgvLocDetl agvLocDetl : agvLocDetls) { +// OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("three_code", agvLocDetl.getThreeCode()).eq("matnr", agvLocDetl.getMatnr()).eq("source", 33)); +// if (Cools.isEmpty(orderDetl)) { +// throw new CoolException("褰撳墠鐗╂枡鐨勮皟鎷ㄥ崟涓嶅瓨鍦紒"); +// } +// Order order = orderService.selectByNo(orderDetl.getOrderNo()); +// if (Cools.isEmpty(order)) { +// throw new CoolException("褰撳墠鐗╂枡鐨勮皟鎷ㄥ崟涓嶅瓨鍦紒"); +// } +// if (order.getSettle() == 4L) { +// if (!orderService.updateSettle(order.getId(),2L,userId)) { +// throw new CoolException("璋冩嫧鍗曞洖婊氬紓甯�!"); +// } +// } +// orderDetl.setQty(orderDetl.getQty() - agvLocDetl.getAnfme()); +// if (!orderDetlService.updateById(orderDetl)) { +// throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏澶辫触"); +// } +// } +// } //鏇存柊鐩爣搴撲綅鐘舵�� updateAgvLocMast(agvLocMast,"P"); updateAgvLocMast(locMast,"Q"); @@ -514,8 +573,28 @@ if (!agvWrkMast.getBarcode().equals(param.getBarcode())) { throw new CoolException("褰撳墠璐ф灦鐮佷笌浠诲姟涓嶅尮閰�"); } - if (!agvWrkMast.getWrkSts().equals(207L)) { - throw new CoolException("宸ヤ綔鐘舵�佷笉绗﹀悎绂诲満鏉′欢"); + if (!agvWrkMast.getWrkSts().equals(207L) && !agvWrkMast.getWrkSts().equals(205L)) { + throw new CoolException("褰撳墠宸ヤ綔鐘舵��:" + agvWrkMast.getWrkSts$() +"涓嶇鍚堢鍦烘潯浠�"); + } + if (agvWrkMast.getWrkSts().equals(205L)) { + // 搴撲綅 -- 鎺ラ┏浣� / 搴撲綅 + if (agvWrkMast.getLocNo().substring(0,2).equals("DB")) { + agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getLocNo(),"F",agvWrkMast.getBarcode(),agvWrkMast.getWhsType().shortValue()); + // 鎺ラ┏浣� -- 搴撲綅 + } else { + agvLocMastService.updateLocStsByLocNo(agvWrkMast.getLocNo(),"D",agvWrkMast.getBarcode(),agvWrkMast.getWhsType().shortValue()); + } + + // 鎺ラ┏浣� -- 搴撲綅 + if (agvWrkMast.getSourceLocNo().substring(0,2).equals("DB")) { + agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getSourceLocNo(),"O","",(short)0); + // 搴撲綅 -- 鎺ラ┏浣� / 搴撲綅 + } else { + //淇敼婧愬簱浣嶇姸鎬佷负O + agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(),"O","",agvWrkMast.getWhsType().shortValue(),"",(short)0); + //鏇存柊鐩爣搴撲綅鏄庣粏 101.鍑哄簱 鍒犻櫎婧愬簱浣嶅簱瀛樻槑缁� + agvLocDetlService.delete(new EntityWrapper<AgvLocDetl>().eq("loc_no",agvWrkMast.getSourceLocNo())); + } } //鐢熸垚AGV宸ヤ綔鍘嗗彶妗� + 鐢熸垚AGV宸ヤ綔鏄庣粏鍘嗗彶妗� @@ -533,12 +612,13 @@ agvWrkDetl.setWrkNo(wrkMast.getWrkNo()); agvWrkDetl.setModiUser(userId); agvWrkDetl.setModiTime(now); + agvWrkDetl.setIoTime(now); if (!agvWrkDetlService.insert(agvWrkDetl)) { throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏澶辫触"); } } // 鏇存柊绔欑偣鐘舵�� - agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(),"O","",null); +// agvLocMastService.updateLocStsByLocNo(agvWrkMast.getSourceLocNo(),"O","",null); // 鏇存柊婧愬簱浣嶇姸鎬� agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getLocNo(),"O","",agvWrkMast.getWhsType().shortValue()); @@ -607,6 +687,7 @@ if (!agvWrkMast.getBarcode().equals(param.getBarcode())) { throw new CoolException("褰撳墠璐ф灦鐮佷笌浠诲姟涓嶅尮閰�"); } + agvWrkMast.setModiTime(new Date()); agvWrkMast.setWrkSts(213L); agvWrkMast.setSourceLocNo(""); if (!agvWrkMastService.update(agvWrkMast,new EntityWrapper<AgvWrkMast>().eq("wrk_no",agvWrkMast.getWrkNo()))) { @@ -635,6 +716,7 @@ throw new CoolException("褰撳墠宸ヤ綔绫诲瀷涓嶈兘绌烘灦杩涘満"); } agvWrkMast.setWrkSts(214L); + agvWrkMast.setModiTime(new Date()); agvWrkMast.setSourceLocNo(param.getDevNo()); if (!agvWrkMastService.update(agvWrkMast,new EntityWrapper<AgvWrkMast>().eq("wrk_no",agvWrkMast.getWrkNo()))) { throw new CoolException("鏇存柊宸ヤ綔妗eけ璐�"); @@ -644,7 +726,7 @@ return "ok"; } /* - * 绔欑偣鍥為�� + * 杞墜鍔ㄥ洖娴� */ @Override @Transactional @@ -659,6 +741,70 @@ } return "ok"; } + + /* + * 纭鍔犲伐瀹屾垚 + */ + @Override + @Transactional + public String processed(AgvMobileStartPakin param, Long userId) { + Date now = new Date(); + AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("barcode", param.getBarcode()).eq("loc_no", param.getDevNo())); + if (Cools.isEmpty(agvWrkMast)) { + throw new CoolException("鏆傛棤褰撳墠璐ф灦鐨勫伐浣滄。"); + } + if (agvWrkMast.getWrkSts() != 205) { + throw new CoolException("褰撳墠浠诲姟鏈畬鎴愶紝璇风‘璁�"); + } + //鐢熸垚AGV宸ヤ綔鍘嗗彶妗� + 鐢熸垚AGV宸ヤ綔鏄庣粏鍘嗗彶妗� + agvWrkMastLogService.save(agvWrkMast); + agvWrkDetlLogService.save(agvWrkMast.getWrkNo()); + String sourceLocNo = agvWrkMast.getSourceLocNo(); + AgvLocMast newLocMast = agvCommonService.getLocNo(3, 1,false,false); + agvWrkMast.setSourceLocNo(agvWrkMast.getLocNo()); + agvWrkMast.setLocNo(newLocMast.getLocNo()); + agvWrkMast.setIoType(57); + agvWrkMast.setWrkSts(201L); + agvWrkMast.setModiUser(userId); + agvWrkMast.setModiTime(now); + agvWrkMast.setIoTime(now); + + + + if (!agvWrkMastService.update(agvWrkMast,new EntityWrapper<AgvWrkMast>().eq("wrk_no",agvWrkMast.getWrkNo()))) { + throw new CoolException("鏇存柊宸ヤ綔妗eけ璐�"); + } + + // 鏇存柊婧愮珯鐐� + 鐩爣搴撲綅鐘舵�� + 鍘嗗彶婧愬簱浣� + agvBasDevpService.updateLocStsAndBarcodeByDevNo(param.getDevNo(),"R",param.getBarcode(),agvWrkMast.getWhsType().shortValue()); + agvLocMastService.updateLocStsByLocNo(newLocMast.getLocNo(),"S",agvWrkMast.getBarcode(),agvWrkMast.getWhsType().shortValue()); + agvLocMastService.updateLocStsByLocNo(sourceLocNo,"O","",(short)30); + agvLocDetlService.delete(new EntityWrapper<AgvLocDetl>().eq("loc_no",sourceLocNo)); + + List<AgvWrkDetl> agvWrkDetls = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("supp_code",param.getBarcode())); + agvWrkDetls.forEach(agvWrkDetl -> { + for (AgvWrkDetl wrkDetl : param.getWrkDetls()) { + if (wrkDetl.getMatnr().equals(agvWrkDetl.getMatnr()) && wrkDetl.getThreeCode().equals(agvWrkDetl.getThreeCode())) { + agvWrkDetl.setAnfme(wrkDetl.getAnfme()); + break; + } + } + agvWrkDetl.setProcessSts(2); + agvWrkDetl.setOrderNo(agvWrkDetl.getOrderNo().substring(2)); + agvWrkDetl.setModiUser(userId); + agvWrkDetl.setModiTime(now); + agvWrkDetl.setIoTime(now); + if (!agvWrkDetlService.update(agvWrkDetl,new EntityWrapper<AgvWrkDetl>() + .eq("matnr",agvWrkDetl.getMatnr()) + .eq("three_code",agvWrkDetl.getThreeCode()) + .eq("supp_code",param.getBarcode()))) { + throw new CoolException("鏇存柊宸ヤ綔鏄庣粏澶辫触"); + } + }); + return "ok"; + } + + /* * 绔欑偣鍥為�� @@ -696,6 +842,7 @@ agvWrkDetl.setWrkNo(wrkMast.getWrkNo()); // 淇濇寔宸ヤ綔妗f槑缁� agvWrkDetl.setWrkNo(wrkMast.getWrkNo()); + agvWrkDetl.setIoTime(now); agvWrkDetl.setModiUser(userId); agvWrkDetl.setModiTime(now); if (!agvWrkDetlService.insert(agvWrkDetl)) { @@ -753,7 +900,7 @@ wrkMast.setAppeTime(now); wrkMast.setModiUser(userId); wrkMast.setModiTime(now); - + wrkMast.setLogErrMemo("doBack"); if (!agvWrkMastService.insertByIncrease(wrkMast)) { throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�"); } -- Gitblit v1.9.1