From 442ae6e4bf9b78944c8382869d07787ba880decf Mon Sep 17 00:00:00 2001 From: wangshilong Date: Wed, 27 Nov 2024 14:34:49 +0800 Subject: [PATCH] Online Device status cache --- .../com/isu/gaswellwatch/modbus/data/PersistenceHandler.java | 1 + .../gaswellwatch/modbus/data/Redis2DBPersistenceService.java | 2 ++ 2 files changed, 3 insertions(+) diff --git a/src/main/java/com/isu/gaswellwatch/modbus/data/PersistenceHandler.java b/src/main/java/com/isu/gaswellwatch/modbus/data/PersistenceHandler.java index 32501eb..79cc964 100644 --- a/src/main/java/com/isu/gaswellwatch/modbus/data/PersistenceHandler.java +++ b/src/main/java/com/isu/gaswellwatch/modbus/data/PersistenceHandler.java @@ -16,6 +16,7 @@ public interface PersistenceHandler { String DEVICE_INFO_CACHE = "info:device:"; String DEVICE_DATA_CACHE = "data:device:"; + String ONLINE_DEVICE_CACHE = "data:device:online"; void createTable(String tableName, Long deviceId); diff --git a/src/main/java/com/isu/gaswellwatch/modbus/data/Redis2DBPersistenceService.java b/src/main/java/com/isu/gaswellwatch/modbus/data/Redis2DBPersistenceService.java index 25e5da9..752dc7b 100644 --- a/src/main/java/com/isu/gaswellwatch/modbus/data/Redis2DBPersistenceService.java +++ b/src/main/java/com/isu/gaswellwatch/modbus/data/Redis2DBPersistenceService.java @@ -74,6 +74,8 @@ public class Redis2DBPersistenceService { if (Objects.nonNull(idGatewayMappingMap)) { operations.put(PersistenceHandler.DEVICE_DATA_CACHE + deviceId, "online", String.valueOf(idGatewayMappingMap.containsKey(deviceId))); + operations.put(PersistenceHandler.ONLINE_DEVICE_CACHE, String.valueOf(deviceId), + String.valueOf(idGatewayMappingMap.containsKey(deviceId))); } String modbusDeviceProductCode = (String) operations.get( PersistenceHandler.DEVICE_INFO_CACHE + deviceId, "modbus_device_product_code");