修正部分参数

This commit is contained in:
2025-07-02 12:26:09 +08:00
parent 37fd07b0c8
commit 170bae19f8

View File

@ -146,7 +146,7 @@ public class FXXDataProcessServiceImpl implements IFXXDataProcessService {
emsBatteryStackMapper.insertEmsBatteryStack(dataStack); 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); 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()); batteryData.setDataTimestamp(new Date());
// ID字段 // ID字段
batteryData.setSiteId(("021_FXX_01")); batteryData.setSiteId("021_FXX_01");
batteryData.setClusterDeviceId(deviceId); batteryData.setClusterDeviceId(deviceId);
list.add(batteryData); list.add(batteryData);
@ -273,7 +273,7 @@ public class FXXDataProcessServiceImpl implements IFXXDataProcessService {
if (list.size() > 0 ) { if (list.size() > 0 ) {
emsBatteryDataMapper.insertEmsBatteryDataList(list); 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()); pcsData.setDateDay(DateUtils.getNowDayLong());
emsPcsDataMapper.insertEmsPcsData(pcsData); 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 ) { if (list.size() > 0 ) {
emsPcsBranchDataMapper.insertPcsBranchDataList(list); emsPcsBranchDataMapper.insertPcsBranchDataList(list);
redisCache.setCacheObject(deviceId + "_DATA", list); redisCache.setCacheObject("BRANCH_021_FXX_01_"+deviceId, list);
} }