From a85a8d0c33d4a821a98a0ff6789298a23a180006 Mon Sep 17 00:00:00 2001 From: pang.jiabao <pang_jiabao@163.com> Date: 星期一, 28 四月 2025 14:39:45 +0800 Subject: [PATCH] 拣货单出库完成,但是库存没减,日志埋点 --- src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java | 43 ++++++++++++++++++++++++++----------------- 1 files changed, 26 insertions(+), 17 deletions(-) diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java index b75acf9..080b2f9 100644 --- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java @@ -34,6 +34,7 @@ import java.util.Date; import java.util.List; import java.util.Map; +import java.util.concurrent.TimeUnit; /** * Created by vincent on 2022/4/9 @@ -51,6 +52,8 @@ @Autowired private OrderService orderService; + @Autowired + private OrderLogService orderLogService; @Autowired private OrderDetlService orderDetlService; @Autowired @@ -211,6 +214,11 @@ } orderService.remove(order.getId()); } + OrderLog orderLog = orderLogService.selectByNo(param.getCCode()); + if (!Cools.isEmpty(orderLog)) { + throw new CoolException(param.getCCode() + "鍗曟嵁宸茬粡瀹屾垚锛屼笉闇�瑕佸啀浼犻��"); + } + DocType docType = docTypeService.selectOrAdd(param.getType(), Boolean.FALSE); Date now = new Date(); @@ -417,7 +425,7 @@ //鍒犻櫎瀛樿揣妗f if (param.deleteFlag == 1) { for (MatSyncParam.MatParam matParam : param.getMatDetails()) { - matService.deleteById(matParam.getMatnr()); + matService.delete(new EntityWrapper<Mat>().eq("matnr", matParam.getMatnr())); } return; @@ -583,7 +591,7 @@ Pla pla = plaService.selectByBatchAndPackageNo(batch, packageNo, brand); Mat mat = matService.selectByMaktx(pla.getBrand()); //褰撶敓浜у崟鍙蜂笉涓�鑷存椂锛岄渶瑕佹柊寤轰竴涓猵aram - if (list.size() == 0 || checkOrder(list, pla.getProOrderNo()) == null) { + if (list.isEmpty() || (!Cools.isEmpty(pla.getProOrderNo()) && checkOrder(list, pla.getProOrderNo()) == null)) { OpenOrderPakoutParam param = new OpenOrderPakoutParam(); param.setcMaker(json.get("user").toString()); String type = Cools.isEmpty(pla.getProOrderNo()) ? "璋冩嫧鍏ュ簱鍗�" : "浜ф垚鍝佸叆搴�"; @@ -596,7 +604,8 @@ OpenOrderPakoutParam.Body body = new OpenOrderPakoutParam.Body(); body.setcInvCode(mat.getMatnr()); body.setiQuantity(pla.getWeightAnfme()); - body.setcBatch(""); + body.setcBatch(pla.getBatch()); + body.setCPackage(pla.getPackageNo()+""); body.setCbMemo(pla.getMemo()); bodyList.add(body); @@ -612,10 +621,14 @@ body = new OpenOrderPakoutParam.Body(); body.setcInvCode(mat.getMatnr()); body.setiQuantity(pla.getWeightAnfme()); + body.setcBatch(pla.getBatch()); + body.setCPackage(pla.getPackageNo()+""); body.setCbMemo(pla.getMemo()); bodyList.add(body); } else { body.setiQuantity(body.getIQuantity() + pla.getWeightAnfme()); + body.setcBatch(pla.getBatch()); + body.setCPackage(pla.getPackageNo()+""); } } } @@ -624,12 +637,11 @@ doHttpRequest(param, "鍏ュ簱鍗曚笂鎶�", url, orderReportPath, null, "127.0.0.1"); } - return 200; - //return doHttpRequest(list, "鍏ュ簱鍗曚笂鎶�", url, orderReportPath, null, "127.0.0.1"); - } + + @Override public List<Order> selectOrderInformation(Map<String, String> param) { @@ -690,26 +702,24 @@ boolean success = false; try { + log.info("璇锋眰鍙傛暟锛歿}", requestParam); response = new HttpHandler.Builder() .setUri(url) + .setTimeout(30, TimeUnit.SECONDS) .setPath(path) .setJson(JSONObject.toJSONString(requestParam)) .build() .doPost(); - - response = response.replace("\\", ""); - response = response.substring(1, response.length() - 1); + log.info("鍏ュ簱鍗曚笂鎶ヨ姹傝繑鍥炴姤鏂囷細{}", response); JSONObject jsonObject = JSON.parseObject(response); - JSONArray jsonArray = (JSONArray) jsonObject.get(""); - JSONObject jsonResult = (JSONObject) jsonArray.get(0); - if (Cools.isEmpty(jsonResult.get("ErrorCode"))) { - throw new CoolException(jsonResult.get("errorMsg").toString()); + if (Cools.isEmpty(jsonObject.get("ErrorCode"))) { + throw new CoolException(jsonObject.get("ErrorMsg").toString()); } - int code = Integer.parseInt(jsonResult.get("ErrorCode").toString()); - if (code != 1) { - throw new CoolException(jsonResult.get("ErrorMsg").toString()); + int code = Integer.parseInt(jsonObject.get("ErrorCode").toString()); + if (code == 0) { + throw new CoolException(jsonObject.get("ErrorMsg").toString()); } success = true; return code; @@ -729,7 +739,6 @@ } } - } -- Gitblit v1.9.1