From dae1f739ea6e0de4a171efb79c0510d59c8f448b Mon Sep 17 00:00:00 2001
From: pangshenghao <pangshenghao@erayt.com>
Date: Mon, 5 Jun 2023 09:35:58 +0800
Subject: [PATCH] =?UTF-8?q?=E7=AB=8B=E5=BA=93=E8=AE=BE=E5=A4=87=E7=8A=B6?=
 =?UTF-8?q?=E6=80=81=E5=90=8C=E6=AD=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../quartz/task/QueryLKDeviceStatus.java      | 56 +++++++++++++++----
 1 file changed, 44 insertions(+), 12 deletions(-)

diff --git a/acs/nladmin-system/src/main/java/org/nl/modules/quartz/task/QueryLKDeviceStatus.java b/acs/nladmin-system/src/main/java/org/nl/modules/quartz/task/QueryLKDeviceStatus.java
index 98b5a5f8b..9a356571f 100644
--- a/acs/nladmin-system/src/main/java/org/nl/modules/quartz/task/QueryLKDeviceStatus.java
+++ b/acs/nladmin-system/src/main/java/org/nl/modules/quartz/task/QueryLKDeviceStatus.java
@@ -1,20 +1,15 @@
 package org.nl.modules.quartz.task;
 
-import cn.hutool.core.map.MapUtil;
-import cn.hutool.core.util.ObjectUtil;
-import cn.hutool.core.util.StrUtil;
-import cn.hutool.http.HttpResponse;
 import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
 import lombok.extern.slf4j.Slf4j;
-import org.nl.acs.agv.server.AgvService;
-import org.nl.acs.agv.server.ZheDaAgvService;
+import org.nl.acs.device_driver.basedriver.device_status.DeviceStatusDeviceDriver;
+import org.nl.acs.ext.wms.liKuData.DeviceStatusData;
 import org.nl.acs.ext.wms.liKuData.DeviceStatusRequest;
 import org.nl.acs.ext.wms.liKuData.DeviceStatusResponse;
 import org.nl.acs.ext.wms.liKuData.Resp;
 import org.nl.acs.ext.wms.service.AcsToLiKuService;
-import org.nl.acs.instruction.service.InstructionService;
-import org.nl.acs.instruction.service.dto.Instruction;
+import org.nl.acs.opc.Device;
+import org.nl.acs.opc.DeviceAppService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -30,15 +25,52 @@ public class QueryLKDeviceStatus {
     @Autowired
     AcsToLiKuService acsToLiKuService;
 
+    @Autowired
+    DeviceAppService deviceAppService;
 
     public void run() throws Exception {
             DeviceStatusRequest deviceStatusRequest = new DeviceStatusRequest();
             deviceStatusRequest.setDeviceId("0");
+            //车
             Resp<DeviceStatusResponse> carResp  = acsToLiKuService.queryCarDeviceStatus(deviceStatusRequest);
+            List<DeviceStatusData> deviceStatusDataList= JSONArray.parseArray(String.valueOf(carResp.getData()),DeviceStatusData.class);
+            for(int i=0;i<deviceStatusDataList.size();i++){
+                DeviceStatusData deviceStatusData=deviceStatusDataList.get(i);
+                String deviceId="RGV" + deviceStatusData.getDeviceId();
+                PackageDriver(deviceStatusData, deviceId);
+            }
+            //输送线
             Resp<DeviceStatusResponse> ssxResp  = acsToLiKuService.querySsxDeviceStatus(deviceStatusRequest);
+            deviceStatusDataList= JSONArray.parseArray(String.valueOf(ssxResp.getData()),DeviceStatusData.class);
+            for(int i=0;i<deviceStatusDataList.size();i++){
+                DeviceStatusData deviceStatusData=deviceStatusDataList.get(i);
+                String deviceId="LK" + deviceStatusData.getDeviceId();
+                PackageDriver(deviceStatusData, deviceId);
+            }
+            //提升机
             Resp<DeviceStatusResponse> tsjResp  = acsToLiKuService.queryTsjDeviceStatus(deviceStatusRequest);
-
-
-
+            deviceStatusDataList= JSONArray.parseArray(String.valueOf(tsjResp.getData()),DeviceStatusData.class);
+            for(int i=0;i<deviceStatusDataList.size();i++){
+                DeviceStatusData deviceStatusData=deviceStatusDataList.get(i);
+                String deviceId=deviceStatusData.getDeviceId();
+                PackageDriver(deviceStatusData, deviceId);
+            }
         }
+
+    private void PackageDriver(DeviceStatusData deviceStatusData, String deviceId) {
+        Device device = deviceAppService.findDeviceByCode(deviceId);
+        if (device!=null&&device.getDeviceDriver() instanceof DeviceStatusDeviceDriver){
+            DeviceStatusDeviceDriver deviceStatusDeviceDriver=(DeviceStatusDeviceDriver)device.getDeviceDriver();
+            deviceStatusDeviceDriver.setDevice_id(deviceId);
+            deviceStatusDeviceDriver.setX(deviceStatusData.getX());
+            deviceStatusDeviceDriver.setY(deviceStatusData.getY());
+            deviceStatusDeviceDriver.setMap_id(deviceStatusData.getMapId());
+            deviceStatusDeviceDriver.setPower(deviceStatusData.getPower());
+            deviceStatusDeviceDriver.setPallet(deviceStatusData.getPallet());
+            deviceStatusDeviceDriver.setLoad(deviceStatusData.getLoad());
+            deviceStatusDeviceDriver.setAlarm(deviceStatusData.getAlarm());
+            deviceStatusDeviceDriver.setTask_id(deviceStatusData.getTaskId());
+            deviceStatusDeviceDriver.setIsonline(true);
+        }
+    }
 }