From 93860dbc9e47ef9886c1347ce0bf14e9f0438b2a Mon Sep 17 00:00:00 2001
From: IZCD4L12RTSW0VZ\Administrator <skyouc>
Date: 星期一, 05 一月 2026 17:20:14 +0800
Subject: [PATCH] 备货派工单优化 库存调整反馈优化

---
 src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java |   82 +++++++++++++++++++++++++++++-----------
 1 files changed, 59 insertions(+), 23 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 3ebadce..00029b3 100644
--- a/src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java
@@ -14,11 +14,11 @@
 import com.zy.api.entity.StockAdjustParams;
 import com.zy.api.entity.StockUpOrderParams;
 import com.zy.api.entity.dto.XSR;
+import com.zy.api.enums.MatLocType;
 import com.zy.api.service.KopenApiService;
 import com.zy.asrs.entity.*;
 import com.zy.asrs.enums.OrderTypeEnum;
 import com.zy.asrs.service.*;
-import com.zy.asrs.service.impl.CheckOrderDetlServiceImpl;
 import com.zy.asrs.task.AbstractHandler;
 import com.zy.asrs.task.core.ReturnT;
 import com.zy.asrs.utils.OrderInAndOutUtil;
@@ -47,8 +47,6 @@
 @Service
 public class OrderSyncHandler extends AbstractHandler<String> {
 
-    private final CheckOrderDetlServiceImpl checkOrderDetlService;
-
     @Autowired
     private JdbcTemplate jdbcTemplate;
     @Autowired
@@ -67,10 +65,11 @@
     private KopenApiService kopenApiService;
     @Autowired
     private MatService matService;
+    @Autowired
+    private LocDetlService locDetlService;
+    @Autowired
+    CheckOrderDetlService checkOrderDetlService;
 
-    OrderSyncHandler(CheckOrderDetlServiceImpl checkOrderDetlService) {
-        this.checkOrderDetlService = checkOrderDetlService;
-    }
 
     @Transactional
     public ReturnT<String> startOrderIssuedOnceMore(Order order) {
@@ -256,12 +255,13 @@
             ReportOrderParam orderParam = new ReportOrderParam();
             orderParam.setCompany_id(order.getCstmrName())
                     .setWms_id(order.getId() + "")
-                    .setOrder_no(order.getOrderNo())
+//                    .setOrder_no(order.getOrderNo())
+                    .setDispatch_no(order.getOrderNo())
                     .setType(order.getDocType() + "")
                     .setInv_no(order.getNumber())
                     .setPm_tktid(order.getItemName())
                     .setUpdate_time(Utils.dateToStr(new Date(), "yyyy-MM-dd HH:mm:ss"))
-                    .setTarget_location("");
+                    .setTarget_location("1");
 
             List<ReportOrderParams> reportOrderParams = new ArrayList<>();
             orderDetls.forEach(detl -> {
@@ -270,6 +270,15 @@
                     throw new CoolException("鐗╂枡涓嶅瓨鍦�");
                 }
                 ReportOrderParams itemParam = new ReportOrderParams();
+
+                LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>()
+                        .eq("matnr", detl.getMatnr())
+                        .eq("supp_code", detl.getSuppCode())
+                        .eq("order_no", detl.getOrderNo()));
+                if (Objects.isNull(locDetl)) {
+                    throw new CoolException("搴撳瓨鏄庣粏涓嶅瓨鍦� 锛岃妫�鏌ュ崟鎹槸鍚﹀畬鎴愶紒锛�");
+                }
+
                 // BS Code
                 itemParam.setTotal_serial(detl.getThreeCode())
                         // 涓婃姤鏃讹紝榛樿浜у搧绫诲瀷鏄痭ull
@@ -278,14 +287,11 @@
                         .setPro_komcode(detl.getMatnr())
                         // 涓婃姤鏃讹紝榛樿浜у搧id鏄緵搴斿晢缂栫爜
                         .setPro_id(detl.getSuppCode())
-                        // 涓婃姤鏃讹紝榛樿鏉ユ簮浣嶇疆鏄痭ull
-                        .setLocation_no(null)
-                        // 涓婃姤鏃讹紝榛樿鐩爣浣嶇疆鏄痭ull
-                        .setLocation_type(null)
+                        .setLocation_no(locDetl.getZpallet())
+                        .setSj_emp(locDetl.getModiUser$())
+                        .setLocation_type(MatLocType.getMatTag(material.getTagId()  + ""))
                         // 涓婃姤鏃讹紝榛樿涓婃姤鏃堕棿鏄洿鏂版椂闂�
-                        .setSj_date(order.getUpdateBy().toString())
-                        // 涓婃姤鏃讹紝榛樿涓婃姤浜烘槸鏇存柊浜�
-                        .setSj_emp(order.getUpdateBy$())
+                        .setSj_date(Utils.dateToStr(order.getUpdateTime(), "yyyy-MM-dd HH:mm:ss") )
                         // 涓婃姤鏃讹紝榛樿涓婃姤鏁伴噺鏄鍗曟暟閲�
                         .setPick_qty(detl.getQty().intValue())
                         // 涓婃姤鏃讹紝榛樿鎹熷潖鏁伴噺鏄�0
@@ -303,8 +309,11 @@
             try {
                 List<ReportOrderParam> orderParams = new ArrayList<>();
                 orderParams.add(orderParam);
-                response = kopenApiService.getInDispatchResult(orderParams);
-
+                if (order.getReportOnce() < 4) {
+                    response = kopenApiService.getInDispatchResult(orderParams, order);
+                } else {
+                    return FAIL;
+                }
                 // if (true) {
                 // success = true;
                 // // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
@@ -385,6 +394,13 @@
             XSR response = null;
             boolean success = false;
             try {
+//                List<ReportOrderParam> orderParams = new ArrayList<>();
+//                orderParams.add(orderParam);
+//                if (order.getReportOnce() < 4) {
+//                    response = kopenApiService.getOutDetailsResult(orderParams, order);
+//                } else {
+//                    return FAIL;
+//                }
                 // response = new HttpHandler.Builder()
                 // .setUri(MesConstant.URL)
                 // .setPath(MesConstant.PAKOUT_URL)
@@ -449,7 +465,8 @@
                 itemParam.setPro_komcode(material.getMatnr());
                 // 涓婃姤鏃讹紝榛樿浜у搧id鏄緵搴斿晢缂栫爜
                 itemParam.setPro_id(detl.getSuppCode());
-
+                //todo 鍙拌溅缂栫爜
+                itemParam.setTruck_no("TC310080014");
                 // 涓婃姤鏃讹紝榛樿涓婃姤鏃堕棿鏄洿鏂版椂闂�
                 itemParam.setPick_qty(detl.getQty().intValue());
                 reportOrderParams.add(itemParam);
@@ -460,7 +477,7 @@
             pubOrderParamsList.add(pubOrderParams);
             // 璁剧疆娲惧伐鍗曟槑缁�
             stockUpOrderParams.setDetails(pubOrderParamsList);
-            stockUpOrderParams.setUpdate_time(order.getUpdateBy$());
+            stockUpOrderParams.setUpdate_time(order.getUpdateTime$());
 
             XSR response = null;
             boolean success = false;
@@ -473,7 +490,16 @@
                 // .doPost();
                 // JSONObject jsonObject = JSON.parseObject(response);
                 // if (jsonObject.getInteger("code").equals(200)) {
-                if (true) {
+
+                List<StockUpOrderParams> orderParams = new ArrayList<>();
+                orderParams.add(stockUpOrderParams);
+                if (order.getReportOnce() < 4) {
+                    response = kopenApiService.getOutDetailsResult(orderParams, order);
+                } else {
+                    return FAIL;
+                }
+
+                if (response.getSuccess()) {
                     success = true;
                     // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
                     if (!orderService.updateSettle(order.getId(), settle, null)) {
@@ -523,10 +549,11 @@
         adjustParam.setCompany_id(order.getCstmrName())
                 .setWms_id(order.getId() + "")
                 .setType(0 + "")
-                .setCompany_id(order.getCstmrName());
+                .setUpdate_time(order.getUpdateTime$());
+//                .setKopen_id(order.getDefNumber());
 
-        adjustParam.setBsby_no(order.getNumber())
-                .setResason("")
+        adjustParam.setBsby_no(order.getOrderNo())
+                .setReason("")
                 .setReason_name("");
         List<CheckOrderDetl> detls = checkOrderDetlService
                 .selectList(new EntityWrapper<CheckOrderDetl>().eq("order_id", order.getId()));
@@ -550,6 +577,15 @@
 
         adjustParams.add(adjustParam);
 
+        if (order.getReportOnce() < 3) {
+            XSR response = kopenApiService.reportCheckOrder(adjustParams, order);
+            if (response.getSuccess()) {
+                return SUCCESS;
+            } else {
+                return  FAIL;
+            }
+        }
+
         return SUCCESS;
         // TODO Auto-generated method stub
 

--
Gitblit v1.9.1