TuringsMachine/zfipc
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

解决规则缓存重复存储报错问题

Browse Source
This commit is contained in:
zhangjunwen 2024-04-22 11:13:03 +08:00
parent 5baec55fe7
commit 47286e93c3
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
zfipc-server/zfipc-system/src/main/java/com/inspur/industrial/service/impl/IpcAlarmRulesServiceImpl.java
View File

@ -46,8 +46,10 @@ public class IpcAlarmRulesServiceImpl implements IIpcAlarmRulesService
public void init(){ public void init(){
List<IpcEquipInfo> equips = ipcEquipInfoService.selectIpcEquipInfoList(null); List<IpcEquipInfo> equips = ipcEquipInfoService.selectIpcEquipInfoList(null);
for (IpcEquipInfo equip : equips) { for (IpcEquipInfo equip : equips) {
if(!redisCache.hasKey((CacheConstants.IPC_RULES_KEY+equip.getId()))) {
List<IpcAlarmRules> rulesByEquipId = selectIpcAlarmRulesByEquipId(equip.getId()); List<IpcAlarmRules> rulesByEquipId = selectIpcAlarmRulesByEquipId(equip.getId());
redisCache.setCacheList((CacheConstants.IPC_RULES_KEY+equip.getId()),rulesByEquipId); redisCache.setCacheList((CacheConstants.IPC_RULES_KEY + equip.getId()), rulesByEquipId);
}
} }
} }
@ -169,6 +171,7 @@ public class IpcAlarmRulesServiceImpl implements IIpcAlarmRulesService
*/ */
@Override @Override
public List<IpcAlarmRules> selectIpcAlarmRulesConfigListByCache(String equipId){ public List<IpcAlarmRules> selectIpcAlarmRulesConfigListByCache(String equipId){
List<IpcAlarmRules> rules = redisCache.getCacheList(CacheConstants.IPC_RULES_KEY + equipId); List<IpcAlarmRules> rules = redisCache.getCacheList(CacheConstants.IPC_RULES_KEY + equipId);
if (rules == null || rules.size() == 0){ if (rules == null || rules.size() == 0){
List<IpcAlarmRules> rulesList = selectIpcAlarmRulesByEquipId(equipId); List<IpcAlarmRules> rulesList = selectIpcAlarmRulesByEquipId(equipId);