From 13b7e8e4bc0a4c4b0fa2801e729243c3bf032c26 Mon Sep 17 00:00:00 2001
From: zhangzq <zhangzhiqiang@yoycol.com>
Date: Tue, 30 Dec 2025 13:06:11 +0800
Subject: [PATCH] =?UTF-8?q?opt:=E5=A2=9E=E5=8A=A0=E4=BB=BB=E5=8A=A1?=
 =?UTF-8?q?=E7=B1=BB=E5=9E=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ext/wms/service/AcsToZDWmsService.java    |  32 +++++
 .../service/impl/AcsToZDWmsServiceImpl.java   | 112 ++++++++++++++++++
 2 files changed, 144 insertions(+)
 create mode 100644 acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/AcsToZDWmsService.java
 create mode 100644 acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/AcsToZDWmsServiceImpl.java

diff --git a/acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/AcsToZDWmsService.java b/acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/AcsToZDWmsService.java
new file mode 100644
index 0000000..ab374cb
--- /dev/null
+++ b/acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/AcsToZDWmsService.java
@@ -0,0 +1,32 @@
+package org.nl.acs.ext.wms.service;
+
+import cn.hutool.http.HttpResponse;
+import com.alibaba.fastjson.JSONObject;
+
+public interface AcsToZDWmsService {
+
+
+    /**
+     * 任务反馈
+     *
+     *
+     *
+     */
+    HttpResponse taskFeedback(JSONObject whereJson);
+
+    /**
+     * 任务取消
+     *
+     *
+     *
+     */
+    HttpResponse taskDeprecate(JSONObject whereJson);
+
+    /**
+     * 设备状态上传
+     *
+     *
+     * @return Map<String, Object>
+     */
+    HttpResponse deviceStatusUpdate(JSONObject whereJson);
+}
diff --git a/acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/AcsToZDWmsServiceImpl.java b/acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/AcsToZDWmsServiceImpl.java
new file mode 100644
index 0000000..b743088
--- /dev/null
+++ b/acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/AcsToZDWmsServiceImpl.java
@@ -0,0 +1,112 @@
+package org.nl.acs.ext.wms.service.impl;
+
+import cn.hutool.http.HttpRequest;
+import cn.hutool.http.HttpResponse;
+import com.alibaba.fastjson.JSONObject;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.nl.acs.device.address.service.AddressService;
+import org.nl.acs.device.address.service.dto.AddressDto;
+import org.nl.acs.device.service.DeviceService;
+import org.nl.acs.ext.wms.service.AcsToMesService;
+import org.nl.acs.ext.wms.service.AcsToZDWmsService;
+import org.nl.acs.opc.DeviceAppService;
+import org.nl.config.server.AcsConfigService;
+import org.nl.modules.logging.service.LogService;
+import org.nl.modules.system.service.ParamService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class AcsToZDWmsServiceImpl implements AcsToZDWmsService {
+
+    private final DeviceAppService deviceAppService;
+    @Autowired
+    ParamService paramService;
+
+    @Autowired
+    DeviceService deviceService;
+
+    @Autowired
+    AddressService addressService;
+    @Autowired
+    AcsConfigService acsConfigService;
+
+    @Autowired
+    LogService logServer;
+
+    //@Value("${acsTowms.token}")
+    public String token;
+    private String log_file_type="log_file_type";
+    private String log_type="ACS请求LMS";
+
+    @Override
+    public HttpResponse taskFeedback(JSONObject whereJson) {
+        //TODO:改成中鼎
+        String wmsUrl = null;
+        AddressDto addressDto = addressService.findByCode("feedAgvTaskStatus");
+        String methods_url = addressDto.getMethods_url();
+        String url = wmsUrl + methods_url;
+        HttpResponse result = null;
+        log.info("feedAgvTaskStatus----请求参数{}", whereJson);
+        try {
+            result = HttpRequest.post(url)
+                    .body(String.valueOf(whereJson))
+                    .execute();
+            System.out.println(result);
+            log.info("feedAgvTaskStatus----返回参数{}", result);
+        } catch (Exception e) {
+            String msg = e.getMessage();
+            //网络不通
+            log.info("错误原因{}",msg);
+        }
+        return result;
+    }
+
+    @Override
+    public HttpResponse taskDeprecate(JSONObject whereJson) {
+        String wmsUrl = "10.10.188.151:8098";
+        AddressDto addressDto = addressService.findByCode("acsCancelBack");
+        String methods_url = addressDto.getMethods_url();
+        String url = wmsUrl + methods_url;
+        HttpResponse result = null;
+        log.info("deprecateWmsTask----请求参数{}", whereJson);
+        try {
+            result = HttpRequest.post(url)
+                    .body(String.valueOf(whereJson))
+                    .execute();
+            System.out.println(result);
+            log.info("deprecateWmsTask----返回参数{}", result);
+        } catch (Exception e) {
+            String msg = e.getMessage();
+            //网络不通
+            //System.out.println(msg);
+        }
+        return result;
+    }
+
+    @Override
+    public HttpResponse deviceStatusUpdate(JSONObject whereJson) {
+        String wmsUrl = "10.10.188.151:8098";
+        AddressDto addressDto = addressService.findByCode("deviceStatusUpdate");
+        String methods_url = addressDto.getMethods_url();
+        String url = wmsUrl + methods_url;
+        HttpResponse result = null;
+        log.info("deviceStatusUpdate", whereJson);
+        try {
+            result = HttpRequest.post(url)
+                    .body(String.valueOf(whereJson))
+                    .execute();
+            System.out.println(result);
+            log.info("deviceStatusUpdate----返回参数{}", result);
+        } catch (Exception e) {
+            String msg = e.getMessage();
+            //网络不通
+            //System.out.println(msg);
+        }
+        return result;
+    }
+
+}