From 5cef428c0019b6455e35807a617f648840e9c65d Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期二, 22 四月 2025 10:41:53 +0800
Subject: [PATCH] #

---
 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/TaskTimer.java |   36 ++++++++++++++++++++++++++++++++++++
 1 files changed, 36 insertions(+), 0 deletions(-)

diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/TaskTimer.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/TaskTimer.java
index bfed83f..5041bed 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/TaskTimer.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/TaskTimer.java
@@ -81,8 +81,11 @@
                 continue;
             }
             if (task.getTaskNo().equals(basConveyorSta.getTaskNo().toString())) {
+                //缁戝畾鎵樼洏鐮�
+                boolean httpRequest1 = agvBindBarcodeHttpRequest("", "", task);
                 AgvTaskCreateParam agvTaskCreateParam = new AgvTaskCreateParam();
                 getOutRequestParam(agvTaskCreateParam,task);
+                //鍙戦�佸嚭搴撲换鍔�
                 boolean httpRequest = doHttpRequest(agvTaskCreateParam, "172.18.16.248:443", "/rcs/rtas/api/robot/controller/task/submit");
                 if (httpRequest){
                     task.setTaskSts(1000L);
@@ -114,6 +117,39 @@
         agvTaskCreateParam.setCarrierInfo(carrierInfoParam);
 
     }
+    private boolean agvBindBarcodeHttpRequest(String url, String path,Task task){
+        String response = "";
+        boolean success = false;
+        Map<String, Object> headers = new HashMap<>();
+        headers.put("Content-Type", "application/json;charset=UTF-8");
+        headers.put("X-lr-request-id", task.getWmsTaskNo());
+        headers.put("X-lr-version", 4.1);
+        headers.put("X-lr-trace-id", "{{$guid}}");
+
+        Map<String, Object> map = new HashMap<>();
+        map.put("carrierCode",task.getZpallet());
+        map.put("siteCode","06YZ0001");
+        map.put("extra",null);
+        try {
+            response = new HttpHandler.Builder()
+                    .setHeaders(headers)
+                    .setUri("172.18.16.248:443")
+                    .setHttps(true)
+                    .setPath("/rcs/rtas/api/robot/controller/carrier/bind")
+                    .setJson(JSONObject.toJSONString(map))
+                    .build()
+                    .doPost();
+            JSONObject jsonObject = JSON.parseObject(response);
+            String code = jsonObject.get("code").toString();
+            log.info("agv缁戝畾绠卞彿,璇锋眰浣�:"+JSONObject.toJSONString(map)+",杩斿洖:"+response);
+            if(code.equals("SUCCESS")){
+                success = true;
+            }
+        }catch (Exception e){
+            log.info("agv缁戝畾绠卞彿璇锋眰鎶ラ敊"+e.getMessage());
+        }
+        return success;
+    }
 
     private boolean doHttpRequest(AgvTaskCreateParam requestParam, String url, String path){
         String response = "";

--
Gitblit v1.9.1