From 070b1e9cc8fccd36e7b65720a778ac46e118c792 Mon Sep 17 00:00:00 2001
From: vince <757871790@qq.com>
Date: 星期一, 04 三月 2024 09:13:04 +0800
Subject: [PATCH] 增加西山油罐协议
---
src/main/java/com/fzzy/gateway/service/GatewayDeviceService.java | 48 ++++++++++++++++++++++++++++++++++++++----------
1 files changed, 38 insertions(+), 10 deletions(-)
diff --git a/src/main/java/com/fzzy/gateway/service/GatewayDeviceService.java b/src/main/java/com/fzzy/gateway/service/GatewayDeviceService.java
index 4f68178..7b7b5f4 100644
--- a/src/main/java/com/fzzy/gateway/service/GatewayDeviceService.java
+++ b/src/main/java/com/fzzy/gateway/service/GatewayDeviceService.java
@@ -5,6 +5,8 @@
import com.bstek.dorado.annotation.Expose;
import com.fzzy.api.Constant;
import com.fzzy.api.data.ApiCommonDevice;
+import com.fzzy.api.data.DepotType;
+import com.fzzy.api.data.GatewayDeviceType;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.gateway.GatewayUtils;
import com.fzzy.gateway.entity.GatewayDevice;
@@ -42,15 +44,14 @@
List<GatewayDevice> result = new ArrayList<>();
- GatewayDevice cacheDevice;
+ ApiCommonDevice commonDevice;
for (GatewayDevice device : list) {
- device.setStatus(Constant.YN_Y);
- cacheDevice = GatewayUtils.getCacheByDeviceId(device.getDeviceId());
- if (null != cacheDevice) {
- device.setIp(cacheDevice.getIp());
- device.setPort(cacheDevice.getPort());
- device.setStatus(cacheDevice.getStatus());
- device.setOnlineTime(cacheDevice.getOnlineTime());
+ commonDevice = Constant.getCommonDeviceCache(device.getDeviceSn());
+ if (null != commonDevice) {
+ device.setIp(commonDevice.getIp());
+ device.setPort(commonDevice.getPort());
+ device.setStatus(commonDevice.getStatus());
+ device.setOnlineTime(commonDevice.getOnlineTime());
}
result.add(device);
}
@@ -67,12 +68,26 @@
GatewayDevice data2 = new GatewayDevice();
BeanUtils.copyProperties(data, data2);
+
+ if (null == data2.getStatus()) {
+ data.setStatus(Constant.YN_Y);
+
+ if (GatewayDeviceType.TYPE_07.equals(data2.getType())) {
+ data.setStatus(Constant.YN_N);
+ }
+
+ }
+
if (null == data2.getDeviceSn()) {
if (null != data2.getIp()) {
data.setDeviceSn(data2.getIp());
} else {
data.setDeviceSn(data2.getDeviceId());
}
+ }
+
+ if (null == data2.getDepotType()) {
+ data2.setDepotType(DepotType.TYPE_01.getCode());
}
if (null == data2.getId()) {
@@ -83,6 +98,15 @@
}
flushCache();
}
+
+ public void updateData(GatewayDevice device) {
+ device.setStatus(Constant.YN_Y);
+
+ gatewayDeviceRep.save(device);
+
+ flushCacheOne(device);
+ }
+
/**
* gatewayDeviceService#delData
@@ -107,6 +131,10 @@
for (GatewayDevice device : list) {
GatewayUtils.add2Cache(device);
}
+ }
+
+ private void flushCacheOne(GatewayDevice device) {
+ GatewayUtils.add2Cache(device);
}
@@ -142,10 +170,10 @@
for (GatewayDevice device : list) {
device.setIp(commonDevice.getIp());
device.setPort(commonDevice.getPort());
- //device.setOnlineTime(new Date());
device.setStatus(Constant.YN_N);
-
GatewayUtils.add2Cache(device);
}
}
+
+
}
--
Gitblit v1.9.3