From 0bdf2da5b1407d7d0dbb90ba11a6ba0f18856ac0 Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期五, 09 五月 2025 16:55:17 +0800
Subject: [PATCH] 单机调试完成

---
 src/main/java/com/zy/asrs/service/impl/ToWmsServiceImpl.java |   43 ++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 40 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/ToWmsServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/ToWmsServiceImpl.java
index 1ea9d75..78d5074 100644
--- a/src/main/java/com/zy/asrs/service/impl/ToWmsServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/ToWmsServiceImpl.java
@@ -60,6 +60,9 @@
     @Value("${wms.taskStatusFeedbackPath}")
     private String taskStatusFeedbackPath;
 
+    @Value("${wms.executionStatusReport}")
+    private String executionStatusReport;
+
     @Value("${wms.code}")
     private String code;
 
@@ -110,7 +113,7 @@
                     .doPost();
             if (!Cools.isEmpty(response)) {
                 JSONObject jsonObject = JSON.parseObject(response);
-                if (!Cools.isEmpty(jsonObject.get(code)) && jsonObject.get(code).equals(successCode)) {
+                if (successCode.equals(jsonObject.get(code).toString())) {
                     WmsResult result = JSON.parseObject(jsonObject.get(data).toString(), WmsResult.class);
                     return createInTask(result, wmsParam.getBarcode(), wmsParam.getStationCode());
                 }
@@ -124,9 +127,42 @@
         return null;
     }
 
+    @Override
+    public void executionStatusReport(String taskNo, Integer wrkSts) {
+        String response = "";
+        boolean bool = false;
+        JSONObject param = new JSONObject();
+        try {
+            log.info("浠诲姟鎵ц鐘舵�佷笂鎶ワ紝浠诲姟鍙凤細{}锛屾墽琛岀姸鎬侊細{}", taskNo,wrkSts);
+            param.put("taskNo",taskNo);
+            param.put("wrkSts",wrkSts);
+            response = new HttpHandler.Builder()
+                    // .setHeaders(headParam)
+                    .setUri(wmsUrl)
+                    .setPath(executionStatusReport)
+                    .setJson(param.toJSONString())
+                    .build()
+                    .doPost();
+            if (!Cools.isEmpty(response)) {
+                bool = true;
+            }
+
+        } catch (Exception e) {
+            log.error("浠诲姟鎵ц鐘舵�佷笂鎶ュ紓甯�" +  e);
+        } finally {
+            apiLogService.save("浠诲姟鐘舵�佷笂鎶�"
+                    , wmsUrl + executionStatusReport
+                    , null
+                    , "127.0.0.1"
+                    , param.toJSONString()
+                    , response
+                    , bool
+            );
+        }
+    }
+
 
     private TaskWrk createInTask(WmsResult result, String barcode, Integer startPoint) {
-        //String locNo = Utils.Fusion(result.getRow(), result.getFloor(), result.getColumn());
         String locNo = result.getLocNo();
         Date now = new Date();
         TaskWrk taskWrk = new TaskWrk();
@@ -142,13 +178,14 @@
         taskWrk.setCrnNo(locMast.getCrnNo());
         taskWrk.setTargetPoint(locNo);
         taskWrk.setStartPoint(startPoint + "");
-        taskWrk.setCrnNo(result.getCrnNo());
+        taskWrk.setCrnNo(locMast.getCrnNo());
         if (taskWrk.getIoType() == 1) {
             taskWrk.setWrkSts(2);
             if (!Cools.isEmpty(taskWrk.getTargetPoint())) {
                 taskWrk.setOriginTargetPoint(taskWrk.getTargetPoint());
             }
         }
+        taskWrkService.insert(taskWrk);
         return taskWrk;
     }
 

--
Gitblit v1.9.1