From f08dd93e49e8461f362c8f45f17fe10e0fbdebec Mon Sep 17 00:00:00 2001
From: lty <876263681@qq.com>
Date: 星期一, 12 一月 2026 18:54:58 +0800
Subject: [PATCH] #新增和得码入库流程,渝程进仓后续下发货主转换

---
 src/main/java/com/zy/asrs/task/kingdee/handler/ReviewOrderSyncHandler.java |  104 ++++++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 97 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/kingdee/handler/ReviewOrderSyncHandler.java b/src/main/java/com/zy/asrs/task/kingdee/handler/ReviewOrderSyncHandler.java
index 6505238..9a15295 100644
--- a/src/main/java/com/zy/asrs/task/kingdee/handler/ReviewOrderSyncHandler.java
+++ b/src/main/java/com/zy/asrs/task/kingdee/handler/ReviewOrderSyncHandler.java
@@ -26,6 +26,7 @@
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.Set;
+import java.util.concurrent.TimeUnit;
 
 /**
  * Created by vincent on 2023/10/21
@@ -40,7 +41,35 @@
     @Value("${erp.address.imPurinbillBatchAudit}")
     //瀹℃牳鍦板潃
     private String imPurinbillBatchAudit;
+    @Value("${erp.address.imSaloutbillReport}")
+    //閿�鍞嚭搴撳崟瀹℃牳鍦板潃
+    private String imSaloutbillReport;
+    @Value("${erp.address.scpSalreturnReport}")
+    //閿�鍞��璐у崟瀹℃牳鍦板潃
+    private String scpSalreturnReport;
 
+    @Value("${erp.address.imMdcMftproorderReport}")
+    //鐢熶骇棰嗘枡鍗曚笂鎶�
+    private String imMdcMftproorderReport;
+    @Value("${erp.address.imMdcMftreturnorderReport}")
+    //鐢熶骇閫�鏂欏崟涓婃姤
+    private String imMdcMftreturnorderReport;
+    @Value("${erp.address.imMdcMftfeedorderReport}")
+    //鐢熶骇琛ユ枡鍗曚笂鎶�
+    private String imMdcMftfeedorderReport;
+    @Value("${erp.address.imProductinbillBatchAudit}")
+    //鐢熶骇姹囨姤鍗曚笂鎶�
+    private String imProductinbillBatchAudit;
+    @Value("${erp.address.imOtheroutbillAudi}")
+    //鍏朵粬鍑哄簱瀹℃牳涓婃姤
+    private String imOtheroutbillAudi;
+    @Value("${erp.address.imOtherinbillAudit}")
+    //鍏朵粬鍏ュ簱瀹℃牳涓婃姤
+    private String imOtherinbillAudit;
+
+    @Value("${erp.address.imMdcOmprdinbillBatchAudit}")
+    //鍏朵粬鍏ュ簱瀹℃牳涓婃姤
+    private String imMdcOmprdinbillBatchAudit;
     @Autowired
     private OrderService orderService;
     @Autowired
@@ -81,15 +110,67 @@
 
     private JSONObject buildRequestParams(Order order, KingDeeUtilType kingDeeUtilType,
                                           SimpleDateFormat sdf1, SimpleDateFormat sdf2) {
-        switch (kingDeeUtilType.formId) {
+        JSONArray idArray = new JSONArray();
+        JSONObject dataObj = new JSONObject();
+        if(kingDeeUtilType == null){
+            return null;
+        }
+        switch(kingDeeUtilType.formId) {
             case "PUR_RECEIVEBIll": // 杩涗粨閫氱煡鍗曟彁浜�
                 path = imPurinbillBatchAudit;
-                JSONArray idArray = new JSONArray();
                 idArray.add(order.getNumber());
-                JSONObject dataObj = new JSONObject();
                 dataObj.fluentPut("id", idArray);
                 return new JSONObject().fluentPut("data", dataObj);
+            case "SAL_OUTSTOCK"://閿�鍞嚭搴撲笂鎶�
+                path = imSaloutbillReport;
+                idArray.add(order.getOrderNo());
+                dataObj.fluentPut("billno", idArray);
+                return new JSONObject().fluentPut("data", dataObj);
+            case "STK_imSaloutbill":
+                path = imSaloutbillReport;
+                idArray.add(order.getShipCode());
+                dataObj.fluentPut("billno", idArray);
+                return new JSONObject().fluentPut("data", dataObj);
+            case "OUI_RECEIVEBIll":
+                path = imMdcOmprdinbillBatchAudit;
+                idArray.add(order.getShipCode());
+                dataObj.fluentPut("billno", idArray);
+                return new JSONObject().fluentPut("data", dataObj);
+            case "SAL_RETURNSTOCK"://閿�鍞��鏂欏崟
+                path = scpSalreturnReport;
+                dataObj.fluentPut("billno", order.getOrderNo());
+                return new JSONObject().fluentPut("data", dataObj);
+            case "PRD_PickMtrl"://鐢熶骇棰嗘枡鍗曚笂鎶�
+                path = imMdcMftproorderReport;
+                idArray.add(order.getNumber());
+                dataObj.fluentPut("ids", idArray);
+                return new JSONObject().fluentPut("data", dataObj);
+            case "PRD_ReturnMtrl"://鐢熶骇閫�鏂欏崟涓婃姤
+                path = imMdcMftreturnorderReport;
+                idArray.add(order.getNumber());
+                dataObj.fluentPut("id", idArray);
+                return new JSONObject().fluentPut("data", dataObj);
+            case "PRD_FeedMtrl": //鐢熶骇琛ユ枡鍗�
+                path = imMdcMftfeedorderReport;
+                idArray.add(order.getNumber());
+                dataObj.fluentPut("id", idArray);
+                return new JSONObject().fluentPut("data", dataObj);
+            case "PRD_MORPT"://鐢熶骇姹囨姤鍗�
+                path = imProductinbillBatchAudit;
+                idArray.add(order.getNumber());
+                dataObj.fluentPut("ids", idArray);
+                return new JSONObject().fluentPut("data", dataObj);
 
+            case "STK_MISCELLANEOUS"://鍏朵粬鍏ュ簱鍗�
+                path = imOtheroutbillAudi;
+                idArray.add(order.getId());
+                dataObj.fluentPut("id", idArray);
+                return new JSONObject().fluentPut("data", dataObj);
+            case "STK_MisDelivery"://鍏朵粬鍑哄簱鍗�
+                path = imOtherinbillAudit;
+                idArray.add(order.getId());
+                dataObj.fluentPut("id", idArray);
+                return new JSONObject().fluentPut("data", dataObj);
             default:
                 throw new IllegalArgumentException("Unsupported formId: " + kingDeeUtilType.formId);
         }
@@ -109,6 +190,7 @@
                     .setUri(URL)
                     .setPath(path)
                     .setJson(add.toJSONString()) // 灏� JSONObject 杞崲涓� String
+                    .setTimeout(30, TimeUnit.SECONDS)
                     .build()
                     .doPost();
 
@@ -128,14 +210,14 @@
                         .setUri(URL)
                         .setPath(path)
                         .setJson(add.toJSONString()) // 灏� JSONObject 杞崲涓� String
+                        .setTimeout(30, TimeUnit.SECONDS)
                         .build()
                         .doPost();
             }
             // 瑙f瀽杩斿洖鐨勫搷搴�
             JSONObject data = jsonResponse.getJSONObject("data");
-            String errorCode = jsonResponse.getString("errorCode");
             boolean status = jsonResponse.getBooleanValue("status");
-            if ("0".equals(errorCode) && status) {
+            if (status) {
                 // 鑾峰彇鎴愬姛涓庡け璐ョ殑鏁伴噺
                 int successCount = data.getInteger("successCount");
                 int failCount = data.getInteger("failCount");
@@ -159,8 +241,16 @@
                         }
                     }
                 }
-
-                order.setSettle(8L); // 鏇存柊鐘舵�佷负宸蹭笂鎶ュ鏍� 9->8
+                if((order.getDocType() == 16L || order.getDocType() == 24L || order.getDocType() == 3) && order.getCstmrName().equals("鍜屽緱绉戞妧")){
+                    order.setDocType(23L);
+                    order.setSettle(4L);//杞负鍑哄簱鍗曟嵁涓婃姤
+                }else{
+                    if(order.getDocType() == 23L){
+                        Order order1 = orderService.selectOne(new EntityWrapper<Order>().eq("salesman",order.getOrderNo()));
+                        orderService.updateOrderStatus4(order1.getOrderNo());
+                    }
+                    order.setSettle(8L); // 鏇存柊鐘舵�佷负宸蹭笂鎶ュ鏍� 9->8
+                }
                 orderService.updateById(order);
             } else {
                 log.error("鎺ュ彛璋冪敤澶辫触锛岄敊璇俊鎭�: {}", jsonResponse.getString("message"));

--
Gitblit v1.9.1