From 9126e6315288e1ea50e74c70b099974522d6b172 Mon Sep 17 00:00:00 2001
From: 1 <1>
Date: 星期一, 08 十二月 2025 09:17:11 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/jshdasrs' into jshdasrs

---
 src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java |   56 +++++++++++++++++---------------------------------------
 1 files changed, 17 insertions(+), 39 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 651a4e5..4d5d086 100644
--- a/src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java
@@ -58,10 +58,10 @@
         if (!Cools.isEmpty(order1)){
             return FAIL.setMsg("璇风瓑寰�...璁㈠崟鎵ц妗f姝e湪杞巻鍙叉。妗堬紒锛侊紒");
         }
-        List<OrderDetl> orderDetls = OrderInAndOutUtil.selectByOrderId(order.getPakinPakoutStatus$(), order.getId());
-        if (!Cools.isEmpty(orderDetls) || !orderDetls.isEmpty()) {
-            return FAIL.setMsg("璇风瓑寰�...璁㈠崟鎵ц鏄庣粏妗f姝e湪杞巻鍙叉。妗堬紒锛侊紒");
-        }
+//        List<OrderDetl> orderDetls = OrderInAndOutUtil.selectByOrderId(order.getPakinPakoutStatus$(), order.getId());
+//        if (!Cools.isEmpty(orderDetls) || !orderDetls.isEmpty()) {
+//            return FAIL.setMsg("璇风瓑寰�...璁㈠崟鎵ц鏄庣粏妗f姝e湪杞巻鍙叉。妗堬紒锛侊紒");
+//        }
 
         // 鍗曟嵁鏄庣粏妗�
         List<OrderDetl> orderDetlList = orderDetlService.selectByOrderId(order.getId());
@@ -101,17 +101,19 @@
             if (detail.getAnfme().equals(0D)){
                 continue;
             }
-            DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(),detail.getBrand(),detail.getStandby1(),detail.getStandby2(),detail.getStandby3(),
+            DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(),detail.getBrand(),detail.getStandby1(),detail.getStandby2(),detail.getStandby3(),detail.getLineNumber(),
                     detail.getBoxType1(),detail.getBoxType2(),detail.getBoxType3(), detail.getAnfme());
             if (DetlDto.has(list, dto)) {
                 DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch(),dto.getBrand(),dto.getStandby1(),dto.getStandby2(),dto.getStandby3(),dto.getBoxType1(),dto.getBoxType2(),dto.getBoxType3());
                 assert detlDto != null;
                 detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme());
+                detlDto.setErpAnfme(detlDto.getErpAnfme() + detail.getErpAnfme());
 
                 OrderDetl orderDetl = OrderDetl.find(orderDetlList, dto.getMatnr(), dto.getBatch(),dto.getBrand(),dto.getStandby1(),dto.getStandby2(),dto.getStandby3(),dto.getBoxType1(),dto.getBoxType2(),dto.getBoxType3());
                 assert orderDetl != null;
                 orderDetl.setAnfme(orderDetl.getAnfme() + detail.getAnfme());
             } else {
+                dto.setErpAnfme(detail.getErpAnfme());
                 list.add(dto);
                 orderDetlList.add(detail);
             }
@@ -200,58 +202,34 @@
                     continue;
                 }
                 if (!orderDetl.getQty().equals(orderDetl.getAnfme())){
-                    settle = 99L;//浜屾鐢熸垚鍗曟嵁
+                    settle = 98L;//浜屾鐢熸垚鍗曟嵁鍓嶇疆  鎵嬪姩鐢熸垚
                 }
                 String serial = Cools.isEmpty(orderDetl.getBatch()) ? "" : orderDetl.getBatch();
                 pakinParam.getList().add(new MesPakinParam.Detl(orderDetl.getMatnr() + (Cools.isEmpty(serial) ? "" : "-" + serial), orderDetl.getQty()));
             }
-
-            String response = "";
-            boolean success = false;
+//
+//            String response = "";
+//            boolean success = false;
             try {
                 if (pakinParam.getList().size()==0){
-                    success = true;
-                    // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
+                    // 淇敼璁㈠崟鐘舵�� 8鏂板鎻愪氦瀹℃牳瀹屾垚 ===>> 6.宸蹭笂鎶�
                     if (!orderService.updateSettle(order.getId(), settle, null)) {
                         throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
                     }
                 } else {
-//                response = new HttpHandler.Builder()
-//                        .setUri(MesConstant.URL)
-//                        .setPath(MesConstant.PAKIN_URL)
-//                        .setJson(JSON.toJSONString(pakinParam))
-//                        .build()
-//                        .doPost();
-//                JSONObject jsonObject = JSON.parseObject(response);
-//                if (jsonObject.getInteger("code").equals(200)) {
-                    if (true) {
-                        success = true;
-                        // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
+                    if (order.getSettle() == 8L) {
+                        // 淇敼璁㈠崟鐘舵�� 8鏂板鎻愪氦瀹℃牳瀹屾垚 ===>> 6.宸蹭笂鎶�
                         if (!orderService.updateSettle(order.getId(), settle, null)) {
                             throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
                         }
                     } else {
-                        log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.URL+MesConstant.PAKIN_URL, JSON.toJSONString(pakinParam), response);
-                        throw new CoolException("涓婃姤mes绯荤粺澶辫触");
+                        log.error("8杞�6澶辫触璇锋煡鐪嬫祦绋嬩腑鏄惁瀛樺湪寮傚父");
+                        throw new CoolException("8杞�6澶辫触");
                     }
                 }
             } catch (Exception e) {
                 log.error("fail", e);
-//            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                 return FAIL.setMsg(e.getMessage());
-            } finally {
-                try {
-                    // 淇濆瓨鎺ュ彛鏃ュ織
-                    apiLogService.save(
-                            "鎴愬搧搴撳叆搴撲笂鎶�",
-                            MesConstant.URL + MesConstant.PAKIN_URL,
-                            null,
-                            "127.0.0.1",
-                            JSON.toJSONString(pakinParam),
-                            response,
-                            success
-                    );
-                } catch (Exception e) { log.error("", e); }
             }
         }
         // 鍑哄簱瀹屾垚涓婃姤
@@ -301,7 +279,7 @@
                 try {
                     // 淇濆瓨鎺ュ彛鏃ュ織
                     apiLogService.save(
-                            "鎴愬搧搴撳嚭搴撲笂鎶�",
+                            "鍑哄簱涓婃姤",
                             MesConstant.URL + MesConstant.PAKOUT_URL,
                             null,
                             "127.0.0.1",

--
Gitblit v1.9.1