From 7fba108547c985f3a9e1736b32dc028bad3b63a1 Mon Sep 17 00:00:00 2001
From: zhangc <zc@123>
Date: 星期二, 21 一月 2025 16:12:57 +0800
Subject: [PATCH] 页面优化

---
 src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java |   95 +++++++++++++++++++++++++++++------------------
 1 files changed, 59 insertions(+), 36 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 7de6ce3..2d41bc7 100644
--- a/src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java
+++ b/src/main/java/com/zy/asrs/task/handler/OrderSyncHandler.java
@@ -3,17 +3,13 @@
 import cn.hutool.core.util.NumberUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.core.common.Cools;
 import com.core.common.DateUtils;
 import com.core.exception.CoolException;
-import com.zy.asrs.entity.DocType;
-import com.zy.asrs.entity.Order;
-import com.zy.asrs.entity.OrderDetl;
+import com.zy.asrs.entity.*;
 import com.zy.asrs.entity.param.ReportErpParam;
-import com.zy.asrs.service.ApiLogService;
-import com.zy.asrs.service.DocTypeService;
-import com.zy.asrs.service.OrderDetlService;
-import com.zy.asrs.service.OrderService;
+import com.zy.asrs.service.*;
 import com.zy.asrs.task.AbstractHandler;
 import com.zy.asrs.task.core.ReturnT;
 import com.zy.common.utils.HttpHandler;
@@ -46,6 +42,15 @@
     @Autowired
     private DocTypeService docTypeService;
 
+    @Autowired
+    private AgvWrkDetlLogService agvWrkDetlLogService;
+
+    @Autowired
+    private AgvWrkMastLogService agvWrkMastLogService;
+
+    @Autowired
+    private AgvLocMastService agvLocMastService;
+
     @Value("${spring.profiles.active}")
     private String active;
 
@@ -58,9 +63,10 @@
     @Value("${u8.orderReportPath}")
     private String orderReportPath;
 
+
     @Transactional
     public ReturnT<String> start(Order order) {
-        List<String> docNames = new ArrayList<>(Arrays.asList("閾跺骇閲囪喘鍏ュ簱鍗�", "閾跺骇濮斿鏉愭枡鍑哄簱鍗�", "閾跺骇鐢熶骇鏉愭枡鍑哄簱鍗�"));
+        List<String> docNames = new ArrayList<>(Arrays.asList("閾跺骇閲囪喘鍏ュ簱鍗�"));
 
         DocType docType = docTypeService.selectById(order.getDocType());
         if (!docNames.contains(docType.getDocName())) {
@@ -90,42 +96,59 @@
         if (!report) {
             return;
         }
+        if (order == null) {
+            return;
+        }
+        //List<String> docNames = new ArrayList<>(Arrays.asList("閾跺骇閲囪喘鍏ュ簱鍗�"));
+        //List<String> docNames = new ArrayList<>(Arrays.asList("閾跺骇閲囪喘鍏ュ簱鍗�", "閾跺骇濮斿鏉愭枡鍑哄簱鍗�", "閾跺骇鐢熶骇鏉愭枡鍑哄簱鍗�"));
 
-        List<String> docNames = new ArrayList<>(Arrays.asList("閾跺骇閲囪喘鍏ュ簱鍗�", "閾跺骇濮斿鏉愭枡鍑哄簱鍗�", "閾跺骇鐢熶骇鏉愭枡鍑哄簱鍗�"));
 
-        DocType docType = docTypeService.selectById(order.getDocType());
-        if (docNames.contains(docType.getDocName())) {
-            List<OrderDetl> orderDetlList = orderDetlService.selectByOrderId(order.getId());
-            List<OrderDetl> report = new ArrayList<>();
-            for (OrderDetl orderDetl : orderDetlList) {
-                if (orderDetl.getQty() > 0 && orderDetl.getQty() > (orderDetl.getReportQty() == null ? 0D : orderDetl.getReportQty())) {
-                    report.add(orderDetl);
+        //if (docNames.contains(docType.getDocName())) {
+        List<OrderDetl> orderDetlList = orderDetlService.selectByOrderId(order.getId());
+        List<OrderDetl> report = new ArrayList<>();
+        for (OrderDetl orderDetl : orderDetlList) {
+            if (orderDetl.getQty() > 0 && orderDetl.getQty() > (orderDetl.getReportQty() == null ? 0D : orderDetl.getReportQty())) {
+                report.add(orderDetl);
+            }
+        }
+        if (Cools.isEmpty(order.getPltType())) {
+            List<AgvWrkDetlLog> agvWrkDetlLogs = agvWrkDetlLogService.selectList(new EntityWrapper<AgvWrkDetlLog>().eq("order_no", order.getOrderNo()).orderBy("appe_time", false));
+            if (!Cools.isEmpty(agvWrkDetlLogs)) {
+                AgvWrkDetlLog agvWrkDetlLog = agvWrkDetlLogs.get(0);
+                List<AgvWrkMastLog> agvWrkMastLogs = agvWrkMastLogService.selectList(new EntityWrapper<AgvWrkMastLog>().eq("wrk_no", agvWrkDetlLog.getWrkNo()).eq("io_type", 1).orderBy("appe_time", false));
+                if (!Cools.isEmpty(agvWrkMastLogs)) {
+                    AgvLocMast agvLocMast = agvLocMastService.selectById(agvWrkMastLogs.get(0).getLocNo());
+                    if (agvLocMast != null) {
+                        log.info("琛ュ厖閫昏緫鐢熸晥锛歿}", order.getOrderNo());
+                        order.setPltType(agvLocMast.getPltType());
+                    }
                 }
             }
             if (Cools.isEmpty(order.getPltType())) {
                 return;
             }
-            if (Cools.isEmpty(order.getInTime())) {
-                order.setInTime(DateUtils.convert(new Date(), DateUtils.yyyyMMddHHmmsssss_F));
-            }
-            if (!Cools.isEmpty(report)) {
-                ReportErpParam param = new ReportErpParam();
-                mappingParam(order, param);
-                mappingParamChildren(report, param);
-                log.info(JSON.toJSONString(param));
-                int code = doHttpRequest(param, "鍗曟嵁瀹℃牳", url, orderReportPath, null, "127.0.0.1");
-                if (code == 0) {
-                    Date date = new Date();
-                    order.setInTime(DateUtils.convert(date, DateUtils.yyyyMMddHHmmsssss_F));
-                    orderService.updateById(order);
-                    for (OrderDetl orderDetl : report) {
-                        log.info("{}鍗曟嵁瀹℃牳涓婃姤浜嗭細{}", order.getOrderNo(), orderDetl.getQty() - (orderDetl.getReportQty() == null ? 0D : orderDetl.getReportQty()));
-                        orderDetl.setReportQty(orderDetl.getQty());
-                        orderDetl.setUpdateTime(date);
-                        orderDetlService.updateById(orderDetl);
-                    }
+        }
+        if (Cools.isEmpty(order.getInTime())) {
+            order.setInTime(DateUtils.convert(new Date(), DateUtils.yyyyMMddHHmmsssss_F));
+        }
+        if (!Cools.isEmpty(report)) {
+            ReportErpParam param = new ReportErpParam();
+            mappingParam(order, param);
+            mappingParamChildren(report, param);
+            log.info(JSON.toJSONString(param));
+            int code = doHttpRequest(param, "鍗曟嵁瀹℃牳", url, orderReportPath, null, "127.0.0.1");
+            if (code == 0) {
+                Date date = new Date();
+                order.setInTime(DateUtils.convert(date, DateUtils.yyyyMMddHHmmsssss_F));
+                orderService.updateById(order);
+                for (OrderDetl orderDetl : report) {
+                    log.info("{}鍗曟嵁瀹℃牳涓婃姤浜嗭細{}", order.getOrderNo(), orderDetl.getQty() - (orderDetl.getReportQty() == null ? 0D : orderDetl.getReportQty()));
+                    orderDetl.setReportQty(orderDetl.getQty());
+                    orderDetl.setUpdateTime(date);
+                    orderDetlService.updateById(orderDetl);
                 }
             }
+            // }
 
         }
     }
@@ -140,7 +163,7 @@
         }
         param.set鎿嶄綔鍗曟嵁(order.getDocType$());
         param.set鎿嶄綔绫诲瀷("add");
-        param.setDdate(order.getInTime());
+        param.setDdate(DateUtils.convert(new Date(), DateUtils.yyyyMMdd_F));
         param.setCWhCode(Cools.isEmpty(order.getPltType()) ? "" : order.getPltType() + "");
         param.setCDepCode("YZ");
         param.setCOrderCode(order.getOrderNo());

--
Gitblit v1.9.1