From c7b7210b10bb3bafe4b6d55e62de20f35ad29857 Mon Sep 17 00:00:00 2001
From: zhangchao <zc857179121@qq.com>
Date: 星期四, 21 十一月 2024 16:42:41 +0800
Subject: [PATCH] mes的单据同步

---
 src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java |   19 ++++++++++++++-----
 1 files changed, 14 insertions(+), 5 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 15b23ec..42f7ef1 100644
--- a/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java
@@ -26,6 +26,7 @@
 
 import java.io.IOException;
 import java.util.*;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 @Slf4j
@@ -48,7 +49,7 @@
         add(101);
         add(12);
         add(53);
-        add(101);
+        add(103);
         add(108);
         add(111);
         add(112);
@@ -59,6 +60,8 @@
 
     @Value("${agvBasDev.maxWorkNum}")
     private int maxWrokNum;
+    @Value("${mes.report}")
+    private Boolean flag;
     @Value("${mes.url}")
     private String url;
     @Value("${mes.getTokenUrl}")
@@ -688,13 +691,19 @@
     }
 
     private void reportMes(AgvWrkMast agvWrkMast, List<AgvWrkDetl> agvWrkDetls) {
+        if (!flag) {
+            return;
+        }
         if (Cools.isEmpty(agvWrkDetls)) {
             return;
         }
         //鍖哄垎涓嶅悓浠诲姟绫诲瀷鐨勪笂鎶ユ柟寮�
 
         if (IN_TYPE_LIST.contains(agvWrkMast.getIoType())) {
-            reportMesPakinOrder(agvWrkMast, agvWrkDetls);
+            String barcode = agvWrkMast.getBarcode();
+            if (barcode.startsWith("20") || barcode.startsWith("21") || barcode.startsWith("40")) {
+                reportMesPakinOrder(agvWrkMast, agvWrkDetls);
+            }
         }
         if (OUT_TYPE_List.contains(agvWrkMast.getIoType())) {
             reportMesPakoutOrder(agvWrkMast, agvWrkDetls);
@@ -738,9 +747,9 @@
 
             } else {
                 MesPakinReportParam mesPakinReportParam = new MesPakinReportParam();
-                mesPakinReportParam.setInboundOrderCode(agvWrkDetl.getOrderNo());
+                //mesPakinReportParam.setInboundOrderCode(agvWrkDetl.getOrderNo());
                 mesPakinReportParam.setBizType("0");
-                mesPakinReportParam.setInventoryAttr(new MesPakinReportParam.InventoryAttr(agvWrkDetl.getThreeCode().trim(), agvWrkDetl.getMatnr(), agvWrkMast.getLocNo()));
+                mesPakinReportParam.setInventoryAttr(new MesPakinReportParam.InventoryAttr(null, agvWrkDetl.getMatnr(), agvWrkMast.getLocNo()));
                 mesPakinReportParam.setNoQrCodeExecAmount(new MesPakinReportParam.NoQrCodeExecAmount(agvWrkDetl.getAnfme(), agvWrkDetl.getUnit(), null));
 
                 doHttpRequest(mesPakinReportParam, getMesTokenInfo(), "涓婃姤mes鍏ュ簱淇℃伅", url, pakinReportPath, null, "127.0.0.1");
@@ -860,7 +869,7 @@
         boolean success = false;
 
         try {
-            response = new HttpHandler.Builder().setUri(url).setPath(path).setHeaders(headParam).setJson(JSONObject.toJSONString(requestParam)).setHttps(true).build().doPost();
+            response = new HttpHandler.Builder().setUri(url).setPath(path).setTimeout(30, TimeUnit.SECONDS).setHeaders(headParam).setJson(JSONObject.toJSONString(requestParam)).setHttps(true).build().doPost();
             JSONObject jsonObject = JSON.parseObject(response);
 
             if (Cools.isEmpty(jsonObject.get("code")) || Integer.parseInt(jsonObject.get("code").toString()) != 200) {

--
Gitblit v1.9.1