From 8e922888f525bd66d684e81ed525c78961cb0afc Mon Sep 17 00:00:00 2001 From: "USER-20220102CG\\noblelift" <546428999@qq.com> Date: Wed, 7 Jun 2023 09:16:02 +0800 Subject: [PATCH 1/5] =?UTF-8?q?fix=20=E4=BC=98=E5=8C=96ndc=E4=BA=A4?= =?UTF-8?q?=E4=BA=92?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../acs/auto/run/TwoNDCSocketConnectionAutoRun.java | 11 ++++++++--- .../acs/ext/wms/service/impl/WmsToAcsServiceImpl.java | 4 ++-- 2 files changed, 10 insertions(+), 5 deletions(-) diff --git a/acs/nladmin-system/src/main/java/org/nl/acs/auto/run/TwoNDCSocketConnectionAutoRun.java b/acs/nladmin-system/src/main/java/org/nl/acs/auto/run/TwoNDCSocketConnectionAutoRun.java index 6ca2e9736..804100ff7 100644 --- a/acs/nladmin-system/src/main/java/org/nl/acs/auto/run/TwoNDCSocketConnectionAutoRun.java +++ b/acs/nladmin-system/src/main/java/org/nl/acs/auto/run/TwoNDCSocketConnectionAutoRun.java @@ -248,10 +248,15 @@ public class TwoNDCSocketConnectionAutoRun extends AbstractAutoRunnable { } else { device = deviceAppService.findDeviceByCode(Integer.toString(arr[20])); } - if (device.getDeviceDriver() instanceof AgvNdcTwoDeviceDriver) { - agvNdcTwoDeviceDriver = (AgvNdcTwoDeviceDriver) device.getDeviceDriver(); - agvNdcTwoDeviceDriver.processSocket(arr); + if(ObjectUtil.isNotEmpty(device)){ + if (device.getDeviceDriver() instanceof AgvNdcTwoDeviceDriver) { + agvNdcTwoDeviceDriver = (AgvNdcTwoDeviceDriver) device.getDeviceDriver(); + agvNdcTwoDeviceDriver.processSocket(arr); + } + } else { + log.info("当前phase："+ phase +"未找到对应设备"); } + } if (!ObjectUtil.isEmpty(data)) { write(data); diff --git a/acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java b/acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java index 7aafdf6db..94b9d1233 100644 --- a/acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java +++ b/acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java @@ -667,7 +667,7 @@ public class WmsToAcsServiceImpl implements WmsToAcsService { JSONObject json = new JSONObject(); json.put("task_code", task_code); json.put("ext_task_id", ext_task_id); - json.put("message", "已存在任务id为"+taskDto.getTask_id()+"相同的任务号:" + task_code); + json.put("message", "存在相同的任务号:" + task_code); errArr.add(json); continue; } @@ -677,7 +677,7 @@ public class WmsToAcsServiceImpl implements WmsToAcsService { JSONObject json = new JSONObject(); json.put("task_code", task_code); json.put("ext_task_id", ext_task_id); - json.put("message", "已存在任务id为"+vehicle_dto.getTask_id()+"托盘号:" + vehicle_code); + json.put("message", "已存在任务编号为"+vehicle_dto.getTask_code()+"托盘号:" + vehicle_code); errArr.add(json); continue; } From 32fea123557492a61aee6f73cc3bbcaa1824980c Mon Sep 17 00:00:00 2001 From: pangshenghao Date: Wed, 7 Jun 2023 17:06:18 +0800 Subject: [PATCH 2/5] =?UTF-8?q?=E9=A1=B5=E9=9D=A2=E8=BF=94=E5=9B=9E?= =?UTF-8?q?=E5=A2=9E=E5=8A=A0isError=E5=8F=8AhasGoods?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../device_status/DeviceStatusDeviceDriver.java | 5 +++++ .../nl/modules/quartz/task/QueryLKDeviceStatus.java | 10 ++++++++++ 2 files changed, 15 insertions(+) diff --git a/acs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/device_status/DeviceStatusDeviceDriver.java b/acs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/device_status/DeviceStatusDeviceDriver.java index e3545def1..d949b9a23 100644 --- a/acs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/device_status/DeviceStatusDeviceDriver.java +++ b/acs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/device_status/DeviceStatusDeviceDriver.java @@ -75,6 +75,9 @@ public class DeviceStatusDeviceDriver extends AbstractOpcDeviceDriver implements String alarm = ""; String task_id = ""; + Boolean iserror = false; + Boolean hasGoods = false; + @Override public void setDeviceStatus(JSONObject data) { String flag = data.getString("option"); @@ -108,6 +111,8 @@ public class DeviceStatusDeviceDriver extends AbstractOpcDeviceDriver implements jo.put("alarm", alarm); jo.put("task_id", task_id); jo.put("isOnline", this.getIsonline()); + jo.put("isError",this.getIserror()); + jo.put("hasGoods", this.getHasGoods()); return jo; } } 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 9a356571f..7bc6e200d 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 @@ -71,6 +71,16 @@ public class QueryLKDeviceStatus { deviceStatusDeviceDriver.setAlarm(deviceStatusData.getAlarm()); deviceStatusDeviceDriver.setTask_id(deviceStatusData.getTaskId()); deviceStatusDeviceDriver.setIsonline(true); + if(!"0".equals(deviceStatusData.getAlarm())) { + deviceStatusDeviceDriver.setIserror(true); + }else{ + deviceStatusDeviceDriver.setIserror(false); + } + if(!"0".equals(deviceStatusData.getLoad())) { + deviceStatusDeviceDriver.setHasGoods(true); + }else{ + deviceStatusDeviceDriver.setHasGoods(false); + } } } } From f82cdee8fbe12aa22c230aafbaf10a5e8130917d Mon Sep 17 00:00:00 2001 From: pangshenghao Date: Wed, 7 Jun 2023 17:35:08 +0800 Subject: [PATCH 3/5] =?UTF-8?q?=E6=8F=90=E5=8D=87=E6=9C=BA=E7=BC=BA?= =?UTF-8?q?=E5=B0=91floor?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../basedriver/device_status/DeviceStatusDeviceDriver.java | 2 ++ .../java/org/nl/acs/ext/wms/liKuData/DeviceStatusData.java | 3 +++ .../java/org/nl/modules/quartz/task/QueryLKDeviceStatus.java | 1 + acs/nladmin-ui/src/views/system/monitor/device/index.vue | 3 +++ 4 files changed, 9 insertions(+) diff --git a/acs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/device_status/DeviceStatusDeviceDriver.java b/acs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/device_status/DeviceStatusDeviceDriver.java index d949b9a23..0623f635b 100644 --- a/acs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/device_status/DeviceStatusDeviceDriver.java +++ b/acs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/device_status/DeviceStatusDeviceDriver.java @@ -74,6 +74,7 @@ public class DeviceStatusDeviceDriver extends AbstractOpcDeviceDriver implements String load = ""; String alarm = ""; String task_id = ""; + String floor =""; Boolean iserror = false; Boolean hasGoods = false; @@ -110,6 +111,7 @@ public class DeviceStatusDeviceDriver extends AbstractOpcDeviceDriver implements jo.put("load", load); jo.put("alarm", alarm); jo.put("task_id", task_id); + jo.put("floor",floor); jo.put("isOnline", this.getIsonline()); jo.put("isError",this.getIserror()); jo.put("hasGoods", this.getHasGoods()); diff --git a/acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/liKuData/DeviceStatusData.java b/acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/liKuData/DeviceStatusData.java index a2b5c3471..4f8f125a3 100644 --- a/acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/liKuData/DeviceStatusData.java +++ b/acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/liKuData/DeviceStatusData.java @@ -29,4 +29,7 @@ public class DeviceStatusData { //任务号 String taskId; + //楼层 + String floor; + } 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 7bc6e200d..e323b34e4 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 @@ -70,6 +70,7 @@ public class QueryLKDeviceStatus { deviceStatusDeviceDriver.setLoad(deviceStatusData.getLoad()); deviceStatusDeviceDriver.setAlarm(deviceStatusData.getAlarm()); deviceStatusDeviceDriver.setTask_id(deviceStatusData.getTaskId()); + deviceStatusDeviceDriver.setFloor(deviceStatusData.getFloor()); deviceStatusDeviceDriver.setIsonline(true); if(!"0".equals(deviceStatusData.getAlarm())) { deviceStatusDeviceDriver.setIserror(true); diff --git a/acs/nladmin-ui/src/views/system/monitor/device/index.vue b/acs/nladmin-ui/src/views/system/monitor/device/index.vue index d74a42600..1d62cbcbb 100644 --- a/acs/nladmin-ui/src/views/system/monitor/device/index.vue +++ b/acs/nladmin-ui/src/views/system/monitor/device/index.vue @@ -608,6 +608,9 @@ export default { } else if (val === 'task_id') { const obj = { name: '任务号', value: data[val] } this.arr.push(obj) + } else if (val === 'floor') { + const obj = { name: '楼层', value: data[val] } + this.arr.push(obj) } } } From a66792724e5b1b18fa228c3ddfe4778cc20093d3 Mon Sep 17 00:00:00 2001 From: pangshenghao Date: Wed, 7 Jun 2023 17:55:20 +0800 Subject: [PATCH 4/5] fix --- .../device_status/DeviceStatusDeviceDriver.java | 2 -- .../nl/modules/quartz/task/QueryLKDeviceStatus.java | 10 ++++++++-- .../src/views/system/monitor/device/index.vue | 3 --- 3 files changed, 8 insertions(+), 7 deletions(-) diff --git a/acs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/device_status/DeviceStatusDeviceDriver.java b/acs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/device_status/DeviceStatusDeviceDriver.java index 0623f635b..d949b9a23 100644 --- a/acs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/device_status/DeviceStatusDeviceDriver.java +++ b/acs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/device_status/DeviceStatusDeviceDriver.java @@ -74,7 +74,6 @@ public class DeviceStatusDeviceDriver extends AbstractOpcDeviceDriver implements String load = ""; String alarm = ""; String task_id = ""; - String floor =""; Boolean iserror = false; Boolean hasGoods = false; @@ -111,7 +110,6 @@ public class DeviceStatusDeviceDriver extends AbstractOpcDeviceDriver implements jo.put("load", load); jo.put("alarm", alarm); jo.put("task_id", task_id); - jo.put("floor",floor); jo.put("isOnline", this.getIsonline()); jo.put("isError",this.getIserror()); jo.put("hasGoods", this.getHasGoods()); 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 e323b34e4..30d5003d1 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,5 +1,6 @@ package org.nl.modules.quartz.task; +import cn.hutool.core.util.ObjectUtil; import com.alibaba.fastjson.JSONArray; import lombok.extern.slf4j.Slf4j; import org.nl.acs.device_driver.basedriver.device_status.DeviceStatusDeviceDriver; @@ -10,6 +11,7 @@ import org.nl.acs.ext.wms.liKuData.Resp; import org.nl.acs.ext.wms.service.AcsToLiKuService; import org.nl.acs.opc.Device; import org.nl.acs.opc.DeviceAppService; +import org.nl.modules.common.utils.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -46,6 +48,7 @@ public class QueryLKDeviceStatus { DeviceStatusData deviceStatusData=deviceStatusDataList.get(i); String deviceId="LK" + deviceStatusData.getDeviceId(); PackageDriver(deviceStatusData, deviceId); + } //提升机 Resp tsjResp = acsToLiKuService.queryTsjDeviceStatus(deviceStatusRequest); @@ -64,13 +67,16 @@ public class QueryLKDeviceStatus { deviceStatusDeviceDriver.setDevice_id(deviceId); deviceStatusDeviceDriver.setX(deviceStatusData.getX()); deviceStatusDeviceDriver.setY(deviceStatusData.getY()); - deviceStatusDeviceDriver.setMap_id(deviceStatusData.getMapId()); + if(!ObjectUtil.isEmpty(deviceStatusData.getMapId())) { + deviceStatusDeviceDriver.setMap_id(deviceStatusData.getMapId()); + }else if (!ObjectUtil.isEmpty(deviceStatusData.getFloor())){ + deviceStatusDeviceDriver.setMap_id(deviceStatusData.getFloor()); + } deviceStatusDeviceDriver.setPower(deviceStatusData.getPower()); deviceStatusDeviceDriver.setPallet(deviceStatusData.getPallet()); deviceStatusDeviceDriver.setLoad(deviceStatusData.getLoad()); deviceStatusDeviceDriver.setAlarm(deviceStatusData.getAlarm()); deviceStatusDeviceDriver.setTask_id(deviceStatusData.getTaskId()); - deviceStatusDeviceDriver.setFloor(deviceStatusData.getFloor()); deviceStatusDeviceDriver.setIsonline(true); if(!"0".equals(deviceStatusData.getAlarm())) { deviceStatusDeviceDriver.setIserror(true); diff --git a/acs/nladmin-ui/src/views/system/monitor/device/index.vue b/acs/nladmin-ui/src/views/system/monitor/device/index.vue index 1d62cbcbb..d74a42600 100644 --- a/acs/nladmin-ui/src/views/system/monitor/device/index.vue +++ b/acs/nladmin-ui/src/views/system/monitor/device/index.vue @@ -608,9 +608,6 @@ export default { } else if (val === 'task_id') { const obj = { name: '任务号', value: data[val] } this.arr.push(obj) - } else if (val === 'floor') { - const obj = { name: '楼层', value: data[val] } - this.arr.push(obj) } } } From 0725fae4ebff60331110392f7d061eecb5471295 Mon Sep 17 00:00:00 2001 From: "USER-20220102CG\\noblelift" <546428999@qq.com> Date: Wed, 7 Jun 2023 18:41:20 +0800 Subject: [PATCH 5/5] fix opc --- .../org/nl/acs/opc/OpcServerServiceImpl.java | 30 +++++++++++-------- 1 file changed, 17 insertions(+), 13 deletions(-) diff --git a/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcServerServiceImpl.java b/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcServerServiceImpl.java index 1034152a5..f81e56b59 100644 --- a/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcServerServiceImpl.java +++ b/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcServerServiceImpl.java @@ -89,20 +89,24 @@ public class OpcServerServiceImpl implements OpcServerService, ApplicationAutoIn // } // } - Server server = (Server)this.servers.get(code); - boolean needcreate = false; - String groupName = code; - if (server == null) { - needcreate = true; - } else { - try { - group = server.findGroup(groupName); - } catch (UnknownHostException | JIException | UnknownGroupException | NotConnectedException | IllegalArgumentException var13) { - log.error(code, var13); - needcreate = true; - } - } +// Server server = (Server)this.servers.get(code); +// boolean needcreate = false; +// String groupName = code; +// if (server == null) { +// needcreate = true; +// } else { +// try { +// group = server.findGroup(groupName); +// } catch (UnknownHostException | JIException | UnknownGroupException | NotConnectedException | IllegalArgumentException var13) { +// log.error(code, var13); +// needcreate = true; +// } +// } + boolean needcreate = false; + needcreate = true; + String groupName = code; + Server server = null; if (needcreate) { OpcServerManageDto dto = (OpcServerManageDto)this.opcServerManageDtos.get(code); if (dto == null) {