From fc6a73660fb4c76a2b0479bb8108768b7ff0d146 Mon Sep 17 00:00:00 2001 From: lsh <lsh@163.com> Date: 星期四, 21 八月 2025 16:47:42 +0800 Subject: [PATCH] * --- src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java | 26 ++++++++++++++++---------- 1 files changed, 16 insertions(+), 10 deletions(-) diff --git a/src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java b/src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java index 64a30fd..7e7c635 100644 --- a/src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java +++ b/src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java @@ -24,6 +24,7 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import java.util.Date; import java.util.List; /** @@ -75,21 +76,25 @@ success = true; // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶� if (!orderService.updateSettle(order.getId(), 6L, null)) { - throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳"); + throw new CoolException("涓婃姤瀹屾垚鏇存柊璁㈠崟鐘舵�佸紓甯革紝璇疯仈绯荤鐞嗗憳"); } } else { log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.URL+MesConstant.PAKIN_URL, JSON.toJSONString(pakinParam), response); + order.setUpdateTime(new Date()); + orderService.updateById(order); throw new CoolException("涓婃姤mes绯荤粺澶辫触"); } } catch (Exception e) { log.error("fail", e); // TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); + order.setUpdateTime(new Date()); + orderService.updateById(order); return FAIL.setMsg(e.getMessage()); } finally { try { // 淇濆瓨鎺ュ彛鏃ュ織 apiLogService.save( - "鎴愬搧搴撳叆搴撲笂鎶�", + "鑳舵枡鍏ュ簱涓婃姤鑷矱RP", MesConstant.URL + MesConstant.PAKIN_URL, null, "127.0.0.1", @@ -102,13 +107,14 @@ } // 鍑哄簱瀹屾垚涓婃姤 if (docType.getPakout() == 1) { - if (true) { - return SUCCESS; - } MesPakoutParam pakoutParam = new MesPakoutParam(); - pakoutParam.setPakoutTime(DateUtils.convert(order.getUpdateTime())); // todo:luxiaotao - pakoutParam.setLgortFrom("5008"); // todo:luxiaotao - pakoutParam.setLgortTo("5006"); // todo:luxiaotao + pakoutParam.setTag(!order.getDocType$().equalsIgnoreCase("鎵嬪姩鍑哄簱鍗�")); + pakoutParam.setPakoutTime(DateUtils.convert(order.getUpdateTime())); + pakoutParam.setLgortFrom("5006"); + pakoutParam.setLgortTo("1111"); + if (!pakoutParam.isTag()) { + pakoutParam.setKunnr("C1000"); + } pakoutParam.setOrderNo(order.getOrderNo()); for (OrderDetl orderDetl : orderDetls) { String serial = Cools.isEmpty(orderDetl.getBatch()) ? "" : orderDetl.getBatch(); @@ -119,7 +125,7 @@ try { response = new HttpHandler.Builder() .setUri(MesConstant.URL) - .setPath(MesConstant.PAKOUT_URL) // todo:luxiaotao + .setPath(MesConstant.PAKOUT_URL) .setJson(JSON.toJSONString(pakoutParam)) .build() .doPost(); @@ -128,7 +134,7 @@ success = true; // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶� if (!orderService.updateSettle(order.getId(), 6L, null)) { - throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳"); + throw new CoolException("涓婃姤瀹屾垚鏇存柊璁㈠崟鐘舵�佸紓甯革紝璇疯仈绯荤鐞嗗憳"); } } else { log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.URL+MesConstant.PAKOUT_URL, JSON.toJSONString(pakoutParam), response); -- Gitblit v1.9.1