From 5e802e25e196adaf64487bd06103126b5e51187d Mon Sep 17 00:00:00 2001
From: zhangc <zc@123>
Date: 星期五, 03 一月 2025 10:00:50 +0800
Subject: [PATCH] 添加MES库存同步功能及配置

---
 src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java |   40 ++++++++++++++++++++++------------------
 1 files changed, 22 insertions(+), 18 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java b/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java
index b5ff538..4adb66f 100644
--- a/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java
@@ -145,13 +145,15 @@
                     }
                 }
                 if (!Cools.isEmpty(agvWrkMast.getSourceLocNo())) {
-                    agvLocMast = agvLocMastService.selectById(agvWrkMast.getLocNo());
+                    agvLocMast = agvLocMastService.selectById(agvWrkMast.getSourceLocNo());
                     if (agvLocMast != null) {
                         pltType = agvLocMast.getPltType();
                     }
                 }
-                agvWrkMast.setPltType(pltType);
-                log.info("浠撳簱缂栫爜锛歿}",agvWrkMast.getPltType());
+                if (pltType != null) {
+                    agvWrkMast.setPltType(pltType);
+                }
+                log.info("宸ヤ綔鍙�--{},浠撳簱缂栫爜锛歿}", agvWrkMast.getWrkNo(), agvWrkMast.getPltType());
             }
             agvWrkMast.setModiTime(new Date());
             //淇敼宸ヤ綔妗g姸鎬佷负207.搴撳瓨鏇存柊瀹屾垚
@@ -428,7 +430,7 @@
                     //璐ф灦绫诲瀷
                     wrkMast.setWhsType(Integer.valueOf(agvWrkMast.getBarcode().substring(0, 2)));
 
-                    wrkMast.setAppeUser(9527L);
+                    wrkMast.setAppeUser(agvWrkMast.getAppeUser());
                     wrkMast.setAppeTime(now);
                     wrkMast.setModiUser(9527L);
                     wrkMast.setModiTime(now);
@@ -736,12 +738,12 @@
             if (IN_TYPE_LIST.contains(agvWrkMast.getIoType())) {
                 reportMesPakinOrder(agvWrkMast, data);
             }
-            if (OUT_TYPE_List.contains(agvWrkMast.getIoType())) {
-                reportMesPakoutOrder(agvWrkMast, data);
-            }
-            if (MOVE_TYPE_List.contains(agvWrkMast.getIoType())) {
-                generateMesParam(agvWrkMast, data);
-            }
+//            if (OUT_TYPE_List.contains(agvWrkMast.getIoType())) {
+//                reportMesPakoutOrder(agvWrkMast, data);
+//            }
+//            if (MOVE_TYPE_List.contains(agvWrkMast.getIoType())) {
+//                generateMesParam(agvWrkMast, data);
+//            }
         }
 
     }
@@ -771,7 +773,7 @@
                 iteam.setLineNo(orderDetl.getItemNum());
                 iteam.setSupplierCode(order.getSalesman());
                 iteam.setUnit(agvWrkDetl.getUnit());
-
+                iteam.setRemark(agvWrkDetl.getThreeCode());
                 iteams.add(iteam);
 
                 mesBuyPakinReportParam.setCode(orderNo);
@@ -818,11 +820,11 @@
         MesOrderReportParam param = new MesOrderReportParam();
 
         List<MesOrderReportParam.TransferOrderItem> transferOrderItems = new ArrayList<>();
-        List<MesOrderReportParam.TransferOrderItem.InventoryDetail> inventoryDetails = new ArrayList<>();
-        List<MesOrderReportParam.RecordCustomFieldBaseCO.CustomField> customFields = new ArrayList<>();
+
+        //MesOrderReportParam.RecordCustomFieldBaseCO.CustomField customFields = new MesOrderReportParam.RecordCustomFieldBaseCO.CustomField();
 
         MesOrderReportParam.RecordCustomFieldBaseCO recordCustomFieldBaseCO = new MesOrderReportParam.RecordCustomFieldBaseCO();
-        recordCustomFieldBaseCO.setCustomFields(customFields);
+        //recordCustomFieldBaseCO.setCustomFields(customFields);
         param.setRecordCustomFieldBaseCO(recordCustomFieldBaseCO);
 
         //娣诲姞transferOrderItem灞炴��
@@ -837,11 +839,12 @@
             transferOrderItem.setTargetLocationCode(getTargetLocationByFloor(floor));
         }
         transferOrderItems.add(transferOrderItem);
-        transferOrderItem.setInventoryDetails(inventoryDetails);
+
 
         param.setTransferOrderItems(transferOrderItems);
 
         for (AgvWrkDetl agvWrkDetl : agvWrkDetls) {
+            List<MesOrderReportParam.TransferOrderItem.InventoryDetail> inventoryDetails = new ArrayList<>();
             MesOrderReportParam.TransferOrderItem.InventoryDetail inventoryDetail = new MesOrderReportParam.TransferOrderItem.InventoryDetail();
             //娣诲姞amount灞炴��
             MesOrderReportParam.TransferOrderItem.InventoryDetail.Amount amount = new MesOrderReportParam.TransferOrderItem.InventoryDetail.Amount(agvWrkDetl.getAnfme(), agvWrkDetl.getUnit(), null);
@@ -855,12 +858,13 @@
             inventoryDetail.setQcStatus(1);
             inventoryDetail.setStorageStatus(1);
             inventoryDetails.add(inventoryDetail);
+            transferOrderItem.setInventoryDetails(inventoryDetails);
             //娣诲姞閿�鍞鍗曞彿
             MesOrderReportParam.RecordCustomFieldBaseCO.CustomField customField = new MesOrderReportParam.RecordCustomFieldBaseCO.CustomField("workOrderCode__c", agvWrkDetl.getThreeCode().trim());
-            customFields.add(customField);
+            //customFields.add(customField);
+            recordCustomFieldBaseCO.setCustomFields(customField);
+            doHttpRequest(param, getMesTokenInfo(), "涓婃姤mes璋冩嫧淇℃伅", url, orderReportPath, null, "127.0.0.1");
         }
-
-        doHttpRequest(param, getMesTokenInfo(), "涓婃姤mes璋冩嫧淇℃伅", url, orderReportPath, null, "127.0.0.1");
 
     }
 

--
Gitblit v1.9.1