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); }