From 170bae19f8b803c4cb480cc97a9290cfd8b238b1 Mon Sep 17 00:00:00 2001 From: dashixiong Date: Wed, 2 Jul 2025 12:26:09 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=AD=A3=E9=83=A8=E5=88=86=E5=8F=82?= =?UTF-8?q?=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ems/service/impl/FXXDataProcessServiceImpl.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/ems-system/src/main/java/com/xzzn/ems/service/impl/FXXDataProcessServiceImpl.java b/ems-system/src/main/java/com/xzzn/ems/service/impl/FXXDataProcessServiceImpl.java index 8afd260..61ac5a1 100644 --- a/ems-system/src/main/java/com/xzzn/ems/service/impl/FXXDataProcessServiceImpl.java +++ b/ems-system/src/main/java/com/xzzn/ems/service/impl/FXXDataProcessServiceImpl.java @@ -146,7 +146,7 @@ public class FXXDataProcessServiceImpl implements IFXXDataProcessService { emsBatteryStackMapper.insertEmsBatteryStack(dataStack); - redisCache.setCacheObject(deviceId + "_DATA", dataStack); + redisCache.setCacheObject("STACK_021_FXX_01_"+deviceId, dataStack); } @@ -227,7 +227,7 @@ public class FXXDataProcessServiceImpl implements IFXXDataProcessService { } emsBatteryClusterMapper.insertEmsBatteryCluster(data); - redisCache.setCacheObject(deviceId + "_DATA", data); + redisCache.setCacheObject("CLUSTER_021_FXX_01_"+deviceId, data); } @@ -265,7 +265,7 @@ public class FXXDataProcessServiceImpl implements IFXXDataProcessService { batteryData.setDataTimestamp(new Date()); // ID字段 - batteryData.setSiteId(("021_FXX_01")); + batteryData.setSiteId("021_FXX_01"); batteryData.setClusterDeviceId(deviceId); list.add(batteryData); @@ -273,7 +273,7 @@ public class FXXDataProcessServiceImpl implements IFXXDataProcessService { if (list.size() > 0 ) { emsBatteryDataMapper.insertEmsBatteryDataList(list); - redisCache.setCacheList(deviceId + "_DATA_LIST", list); + redisCache.setCacheList("BATTERY_021_FXX_01_"+deviceId, list); } } @@ -340,7 +340,7 @@ public class FXXDataProcessServiceImpl implements IFXXDataProcessService { pcsData.setDateDay(DateUtils.getNowDayLong()); emsPcsDataMapper.insertEmsPcsData(pcsData); - redisCache.setCacheObject(deviceId + "_DATA", pcsData); + redisCache.setCacheObject("PCS_021_FXX_01_"+deviceId, pcsData); } @@ -386,7 +386,7 @@ public class FXXDataProcessServiceImpl implements IFXXDataProcessService { if (list.size() > 0 ) { emsPcsBranchDataMapper.insertPcsBranchDataList(list); - redisCache.setCacheObject(deviceId + "_DATA", list); + redisCache.setCacheObject("BRANCH_021_FXX_01_"+deviceId, list); }