From 32a905fbf1daeac74cbd573e5b841709c44955c2 Mon Sep 17 00:00:00 2001 From: ZY <zc857179121@qq.com> Date: 星期四, 08 五月 2025 17:01:27 +0800 Subject: [PATCH] 代码编写 --- src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java | 321 ++++++++++++++++++++++++++-------------------------- 1 files changed, 160 insertions(+), 161 deletions(-) diff --git a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java index c401b70..2e85903 100644 --- a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java @@ -13,7 +13,6 @@ import com.zy.asrs.service.*; import com.zy.asrs.utils.MatUtils; import com.zy.asrs.utils.OrderInAndOutUtil; -import com.zy.common.constant.MesConstant; import com.zy.common.entity.Parameter; import com.zy.common.model.DetlDto; import com.zy.common.model.MesCombParam; @@ -805,167 +804,167 @@ @Override @Transactional public void packComb(CombParam param, Long userId) { - if (Cools.isEmpty(param.getBarcode(), param.getCombMats())) { - throw new CoolException(BaseRes.PARAM); - } - // 鍒ゆ柇鏄惁鏈夌浉鍚屾潯鐮佺殑鏁版嵁 - if (waitPakinService.selectCount(new EntityWrapper<WaitPakin>(). - eq("zpallet", param.getBarcode()).eq("io_status", "N")) > 0) { - throw new CoolException(param.getBarcode() + "鏁版嵁姝e湪杩涜鍏ュ簱"); - } - Date now = new Date(); - - boolean packDown = Parameter.get().getPackDown().equals("true"); - - // 鏃犲崟缁勬墭 - if (Cools.isEmpty(param.getOrderNo())) { - - // 鐢熸垚鍏ュ簱閫氱煡妗� - List<DetlDto> detlDtos = new ArrayList<>(); - param.getCombMats().forEach(elem -> { - // 鎵撳寘涓婄嚎鏁版嵁鏍¢獙 - if (packDown) { - Pack pack = packService.selectByBarcode(elem.getMatnr()); - if (pack == null) { - throw new CoolException(elem.getMatnr() + "鏉$爜鍐椾綑锛岃妫�鏌ワ紒"); - } - if (pack.getSettle() != 1) { - throw new CoolException(elem.getMatnr() + "鏉$爜宸蹭笅绾匡紝璇锋鏌ワ紒"); - } - } - Mat analyse = MatUtils.analyseMat(elem.getMatnr()); - // 鏉$爜銆佺墿鏂欎唬鐮併�佸簭鍒楀彿銆佹暟閲� - DetlDto detlDto = new DetlDto(elem.getMatnr(), elem.getBatch(),analyse.getBrand(),elem.getStandby1(),elem.getStandby2(),elem.getStandby3(), - elem.getBoxType1(),elem.getBoxType2(),elem.getBoxType3(), elem.getAnfme()); - -// DetlDto detlDto = new DetlDto(elem.getMatnr(), analyse.getMatnr(), analyse.getBarcode(), elem.getAnfme()); -// DetlDto detlDto = new DetlDto(elem.getMatnr(), elem.getBatch(), elem.getAnfme()); - if (DetlDto.has(detlDtos, detlDto)) { - DetlDto one = DetlDto.findDto(detlDtos, detlDto); - assert one != null; - one.setAnfme(one.getAnfme() + detlDto.getAnfme()); - } else { - detlDtos.add(detlDto); - } - }); - - if (packDown) { - MesCombParam mesCombParam = new MesCombParam(); - mesCombParam.setZpallet(param.getBarcode()); - mesCombParam.setPakinTime(DateUtils.convert(now)); - mesCombParam.setLgort("5008"); - mesCombParam.setPlantCode("5000"); - mesCombParam.setFromCode("5012-20"); - mesCombParam.setStationCode("JJQ-PFZPDB-XX"); - for (DetlDto detlDto : detlDtos) { - mesCombParam.getList().add(new MesCombParam.Detl(detlDto.getOrderNo(), detlDto.getAnfme())); - } - String response = ""; - boolean success = false; - try { - response = new HttpHandler.Builder() - .setUri(MesConstant.URL) - .setPath(MesConstant.PACK_DOWN_URL) - .setJson(JSON.toJSONString(mesCombParam)) - .build() - .doPost(); - JSONObject jsonObject = JSON.parseObject(response); - if (jsonObject.getInteger("code").equals(200)) { - success = true; - } else if (jsonObject.getInteger("code").equals(500)) { - log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.URL+MesConstant.PACK_DOWN_URL, JSON.toJSONString(mesCombParam), response); - throw new CoolException(jsonObject.getString("msg")); - } else { - log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.URL+MesConstant.PACK_DOWN_URL, JSON.toJSONString(mesCombParam), response); - throw new CoolException("涓婃姤mes绯荤粺澶辫触"); - } - } catch (Exception e) { - log.error("fail", e); - throw new CoolException(e.getMessage()); - } finally { - try { - // 淇濆瓨鎺ュ彛鏃ュ織 - apiLogService.save( - "鎵撳寘涓嬬嚎甯墭涓婃姤", - MesConstant.URL + MesConstant.PACK_DOWN_URL, - null, - "127.0.0.1", - JSON.toJSONString(mesCombParam), - response, - success - ); - } catch (Exception e) { log.error("", e); } - } - - } - - // 鐢熸垚鍏ュ簱鍗曟嵁 - String orderNo = "PACK" + snowflakeIdWorker.nextId(); - OpenOrderPakinParam openParam = new OpenOrderPakinParam(); - openParam.setOrderNo(orderNo); - openParam.setOrderTime(DateUtils.convert(now)); - openParam.setOrderType("鎵撳寘鍏ュ簱鍗�"); - openParam.setOrderDetails(detlDtos); - openService.pakinOrderCreate(openParam); -// Order order = orderService.selectByNo(orderNo); - Order order = OrderInAndOutUtil.selectByNo(Boolean.TRUE, param.getOrderNo()); - - if (null == order) { - throw new CoolException("鐢熸垚鍗曟嵁澶辫触"); - } -// if (!orderService.updateSettle(order.getId(), 2L, userId)) { -// throw new CoolException("淇敼鍗曟嵁鐘舵�佸け璐�"); -// } - OrderInAndOutUtil.updateOrder(Boolean.TRUE, order.getId(), 2L, userId); - - // 鐢熸垚鍏ュ簱閫氱煡妗� - for (DetlDto detlDto : detlDtos) { - - // 淇敼浣滀笟鏁伴噺 ---------------------------------------- - // 璁㈠崟鏄庣粏鏁伴噺鏍¢獙 -// OrderDetl orderDetl = orderDetlService.selectItem(order.getId(), detlDto.getMatnr(), detlDto.getBatch()); - OrderDetl orderDetl = OrderInAndOutUtil.selectItem(Boolean.TRUE, order.getId(), detlDto.getMatnr(), detlDto.getBatch(),detlDto.getBrand(),detlDto.getStandby1(),detlDto.getStandby2(),detlDto.getStandby3() - ,detlDto.getBoxType1(),detlDto.getBoxType2(),detlDto.getBoxType3()); - if (detlDto.getAnfme() > orderDetl.getEnableQty()) { - throw new CoolException(orderDetl.getMatnr() + "鍏ュ簱鏁伴噺涓嶅悎娉�"); - } - // 淇敼璁㈠崟浣滀笟鏁伴噺 -// if (!orderDetlService.increaseWorkQty(order.getId(), detlDto.getMatnr(), detlDto.getBatch(), detlDto.getAnfme())) { -// throw new CoolException("淇敼鍗曟嵁浣滀笟鏁伴噺澶辫触"); +// if (Cools.isEmpty(param.getBarcode(), param.getCombMats())) { +// throw new CoolException(BaseRes.PARAM); +// } +// // 鍒ゆ柇鏄惁鏈夌浉鍚屾潯鐮佺殑鏁版嵁 +// if (waitPakinService.selectCount(new EntityWrapper<WaitPakin>(). +// eq("zpallet", param.getBarcode()).eq("io_status", "N")) > 0) { +// throw new CoolException(param.getBarcode() + "鏁版嵁姝e湪杩涜鍏ュ簱"); +// } +// Date now = new Date(); +// +// boolean packDown = Parameter.get().getPackDown().equals("true"); +// +// // 鏃犲崟缁勬墭 +// if (Cools.isEmpty(param.getOrderNo())) { +// +// // 鐢熸垚鍏ュ簱閫氱煡妗� +// List<DetlDto> detlDtos = new ArrayList<>(); +// param.getCombMats().forEach(elem -> { +// // 鎵撳寘涓婄嚎鏁版嵁鏍¢獙 +// if (packDown) { +// Pack pack = packService.selectByBarcode(elem.getMatnr()); +// if (pack == null) { +// throw new CoolException(elem.getMatnr() + "鏉$爜鍐椾綑锛岃妫�鏌ワ紒"); +// } +// if (pack.getSettle() != 1) { +// throw new CoolException(elem.getMatnr() + "鏉$爜宸蹭笅绾匡紝璇锋鏌ワ紒"); +// } // } - OrderInAndOutUtil.increaseWorkQty(Boolean.TRUE,order.getId(), detlDto.getMatnr(), detlDto.getBatch(),detlDto.getBrand(),detlDto.getStandby1(),detlDto.getStandby2(),detlDto.getStandby3() - ,detlDto.getBoxType1(),detlDto.getBoxType2(),detlDto.getBoxType3(), detlDto.getAnfme()); - // 淇濆瓨鍏ュ簱閫氱煡妗� - Mat mat = matService.selectByMatnr(detlDto.getMatnr()); - if (Cools.isEmpty(mat)) { - throw new CoolException(detlDto.getMatnr() + "鍟嗗搧妗f涓嶅瓨鍦�"); - } - WaitPakin waitPakin = new WaitPakin(); - waitPakin.sync(mat); - waitPakin.setOrderNo(orderNo); - waitPakin.setBatch(detlDto.getBatch()); - waitPakin.setZpallet(param.getBarcode()); // 鎵樼洏鐮� - waitPakin.setIoStatus("N"); // 鍏ュ嚭鐘舵�� - waitPakin.setAnfme(detlDto.getAnfme()); // 鏁伴噺 - waitPakin.setStatus("Y"); // 鐘舵�� - waitPakin.setAppeUser(userId); - waitPakin.setAppeTime(now); - waitPakin.setModiUser(userId); - waitPakin.setModiTime(now); - if (!waitPakinService.insert(waitPakin)) { - throw new CoolException("淇濆瓨鍏ュ簱閫氱煡妗eけ璐�"); - } - // 淇敼鎵撳寘鏁版嵁鐘舵�� - Pack pack = packService.selectByBarcode(detlDto.getOrderNo()); - pack.setSettle(2L); - pack.setUpdateTime(now); - pack.setUpdateBy(userId); - if (!packService.updateById(pack)) { - throw new CoolException("淇敼鎵撳寘鏁版嵁寮傚父"); - } - } - - } +// Mat analyse = MatUtils.analyseMat(elem.getMatnr()); +// // 鏉$爜銆佺墿鏂欎唬鐮併�佸簭鍒楀彿銆佹暟閲� +// DetlDto detlDto = new DetlDto(elem.getMatnr(), elem.getBatch(),analyse.getBrand(),elem.getStandby1(),elem.getStandby2(),elem.getStandby3(), +// elem.getBoxType1(),elem.getBoxType2(),elem.getBoxType3(), elem.getAnfme()); +// +//// DetlDto detlDto = new DetlDto(elem.getMatnr(), analyse.getMatnr(), analyse.getBarcode(), elem.getAnfme()); +//// DetlDto detlDto = new DetlDto(elem.getMatnr(), elem.getBatch(), elem.getAnfme()); +// if (DetlDto.has(detlDtos, detlDto)) { +// DetlDto one = DetlDto.findDto(detlDtos, detlDto); +// assert one != null; +// one.setAnfme(one.getAnfme() + detlDto.getAnfme()); +// } else { +// detlDtos.add(detlDto); +// } +// }); +// +// if (packDown) { +// MesCombParam mesCombParam = new MesCombParam(); +// mesCombParam.setZpallet(param.getBarcode()); +// mesCombParam.setPakinTime(DateUtils.convert(now)); +// mesCombParam.setLgort("5008"); +// mesCombParam.setPlantCode("5000"); +// mesCombParam.setFromCode("5012-20"); +// mesCombParam.setStationCode("JJQ-PFZPDB-XX"); +// for (DetlDto detlDto : detlDtos) { +// mesCombParam.getList().add(new MesCombParam.Detl(detlDto.getOrderNo(), detlDto.getAnfme())); +// } +// String response = ""; +// boolean success = false; +// try { +// response = new HttpHandler.Builder() +// .setUri(MesConstant.URL) +// .setPath(MesConstant.PACK_DOWN_URL) +// .setJson(JSON.toJSONString(mesCombParam)) +// .build() +// .doPost(); +// JSONObject jsonObject = JSON.parseObject(response); +// if (jsonObject.getInteger("code").equals(200)) { +// success = true; +// } else if (jsonObject.getInteger("code").equals(500)) { +// log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.URL+MesConstant.PACK_DOWN_URL, JSON.toJSONString(mesCombParam), response); +// throw new CoolException(jsonObject.getString("msg")); +// } else { +// log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.URL+MesConstant.PACK_DOWN_URL, JSON.toJSONString(mesCombParam), response); +// throw new CoolException("涓婃姤mes绯荤粺澶辫触"); +// } +// } catch (Exception e) { +// log.error("fail", e); +// throw new CoolException(e.getMessage()); +// } finally { +// try { +// // 淇濆瓨鎺ュ彛鏃ュ織 +// apiLogService.save( +// "鎵撳寘涓嬬嚎甯墭涓婃姤", +// MesConstant.URL + MesConstant.PACK_DOWN_URL, +// null, +// "127.0.0.1", +// JSON.toJSONString(mesCombParam), +// response, +// success +// ); +// } catch (Exception e) { log.error("", e); } +// } +// +// } +// +// // 鐢熸垚鍏ュ簱鍗曟嵁 +// String orderNo = "PACK" + snowflakeIdWorker.nextId(); +// OpenOrderPakinParam openParam = new OpenOrderPakinParam(); +// openParam.setOrderNo(orderNo); +// openParam.setOrderTime(DateUtils.convert(now)); +// openParam.setOrderType("鎵撳寘鍏ュ簱鍗�"); +// openParam.setOrderDetails(detlDtos); +// openService.pakinOrderCreate(openParam); +//// Order order = orderService.selectByNo(orderNo); +// Order order = OrderInAndOutUtil.selectByNo(Boolean.TRUE, param.getOrderNo()); +// +// if (null == order) { +// throw new CoolException("鐢熸垚鍗曟嵁澶辫触"); +// } +//// if (!orderService.updateSettle(order.getId(), 2L, userId)) { +//// throw new CoolException("淇敼鍗曟嵁鐘舵�佸け璐�"); +//// } +// OrderInAndOutUtil.updateOrder(Boolean.TRUE, order.getId(), 2L, userId); +// +// // 鐢熸垚鍏ュ簱閫氱煡妗� +// for (DetlDto detlDto : detlDtos) { +// +// // 淇敼浣滀笟鏁伴噺 ---------------------------------------- +// // 璁㈠崟鏄庣粏鏁伴噺鏍¢獙 +//// OrderDetl orderDetl = orderDetlService.selectItem(order.getId(), detlDto.getMatnr(), detlDto.getBatch()); +// OrderDetl orderDetl = OrderInAndOutUtil.selectItem(Boolean.TRUE, order.getId(), detlDto.getMatnr(), detlDto.getBatch(),detlDto.getBrand(),detlDto.getStandby1(),detlDto.getStandby2(),detlDto.getStandby3() +// ,detlDto.getBoxType1(),detlDto.getBoxType2(),detlDto.getBoxType3()); +// if (detlDto.getAnfme() > orderDetl.getEnableQty()) { +// throw new CoolException(orderDetl.getMatnr() + "鍏ュ簱鏁伴噺涓嶅悎娉�"); +// } +// // 淇敼璁㈠崟浣滀笟鏁伴噺 +//// if (!orderDetlService.increaseWorkQty(order.getId(), detlDto.getMatnr(), detlDto.getBatch(), detlDto.getAnfme())) { +//// throw new CoolException("淇敼鍗曟嵁浣滀笟鏁伴噺澶辫触"); +//// } +// OrderInAndOutUtil.increaseWorkQty(Boolean.TRUE,order.getId(), detlDto.getMatnr(), detlDto.getBatch(),detlDto.getBrand(),detlDto.getStandby1(),detlDto.getStandby2(),detlDto.getStandby3() +// ,detlDto.getBoxType1(),detlDto.getBoxType2(),detlDto.getBoxType3(), detlDto.getAnfme()); +// // 淇濆瓨鍏ュ簱閫氱煡妗� +// Mat mat = matService.selectByMatnr(detlDto.getMatnr()); +// if (Cools.isEmpty(mat)) { +// throw new CoolException(detlDto.getMatnr() + "鍟嗗搧妗f涓嶅瓨鍦�"); +// } +// WaitPakin waitPakin = new WaitPakin(); +// waitPakin.sync(mat); +// waitPakin.setOrderNo(orderNo); +// waitPakin.setBatch(detlDto.getBatch()); +// waitPakin.setZpallet(param.getBarcode()); // 鎵樼洏鐮� +// waitPakin.setIoStatus("N"); // 鍏ュ嚭鐘舵�� +// waitPakin.setAnfme(detlDto.getAnfme()); // 鏁伴噺 +// waitPakin.setStatus("Y"); // 鐘舵�� +// waitPakin.setAppeUser(userId); +// waitPakin.setAppeTime(now); +// waitPakin.setModiUser(userId); +// waitPakin.setModiTime(now); +// if (!waitPakinService.insert(waitPakin)) { +// throw new CoolException("淇濆瓨鍏ュ簱閫氱煡妗eけ璐�"); +// } +// // 淇敼鎵撳寘鏁版嵁鐘舵�� +// Pack pack = packService.selectByBarcode(detlDto.getOrderNo()); +// pack.setSettle(2L); +// pack.setUpdateTime(now); +// pack.setUpdateBy(userId); +// if (!packService.updateById(pack)) { +// throw new CoolException("淇敼鎵撳寘鏁版嵁寮傚父"); +// } +// } +// +// } } @Override -- Gitblit v1.9.1