lyf
/
fxkh-txl-service
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

给渗流设备接口增加redis key

master
李一帆 2022-12-03 10:03:50 +08:00
parent 2466d6c469
commit a167b6bd38
2 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/main/java/com/whdc/zhdbaqapi/constant/Constants.java
View File

@ -9,5 +9,6 @@ public class Constants {
public static final String CACHE_NAME = "DeviceInfoListAll"; public static final String CACHE_NAME = "DeviceInfoListAll";
public static final String CACHE_NAME_SL = "DeviceSLInfoListAll";
} }

18
src/main/java/com/whdc/zhdbaqapi/service/impl/DeviceSLInfoServiceimpl.java
View File

@ -56,7 +56,7 @@ public class DeviceSLInfoServiceimpl extends ServiceImpl<DeviceSLInfoMapper, Dev
} }
@Override @Override
@CacheEvict(Constants.CACHE_NAME) @CacheEvict(Constants.CACHE_NAME_SL)
public boolean save(DeviceSLInfo entity) { public boolean save(DeviceSLInfo entity) {
if (baseMapper.checkValidStationCode(entity.getStationCode()) != null) { if (baseMapper.checkValidStationCode(entity.getStationCode()) != null) {
throw new MyException("stationCode=" + entity.getStationCode() + " 已被其他有效数据使用，不能恢复"); throw new MyException("stationCode=" + entity.getStationCode() + " 已被其他有效数据使用，不能恢复");
@ -67,7 +67,7 @@ public class DeviceSLInfoServiceimpl extends ServiceImpl<DeviceSLInfoMapper, Dev
} }
@Override @Override
@CacheEvict(Constants.CACHE_NAME) @CacheEvict(Constants.CACHE_NAME_SL)
public boolean updateById(DeviceSLInfo entity) { public boolean updateById(DeviceSLInfo entity) {
DeviceSLInfo old = baseMapper.checkValidStationCode(entity.getStationCode()); DeviceSLInfo old = baseMapper.checkValidStationCode(entity.getStationCode());
if (old == null) { if (old == null) {
@ -89,24 +89,24 @@ public class DeviceSLInfoServiceimpl extends ServiceImpl<DeviceSLInfoMapper, Dev
entity.setLatestReportingTime(new Date(defaultTimeStamp)); entity.setLatestReportingTime(new Date(defaultTimeStamp));
deviceDataMapper.clearByDeviceId(entity.getDeviceId(), entity.getChannelNum()); deviceDataMapper.clearByDeviceId(entity.getDeviceId(), entity.getChannelNum());
} }
redisTemplate.delete(Constants.CACHE_NAME); redisTemplate.delete(Constants.CACHE_NAME_SL);
return super.updateById(entity); return super.updateById(entity);
} }
@Override @Override
@CacheEvict(Constants.CACHE_NAME) @CacheEvict(Constants.CACHE_NAME_SL)
public boolean updateByIdInternal(DeviceSLInfo entity) { public boolean updateByIdInternal(DeviceSLInfo entity) {
DeviceSLInfo old = baseMapper.checkValidStationCode(entity.getStationCode()); DeviceSLInfo old = baseMapper.checkValidStationCode(entity.getStationCode());
if (old != null && !old.getId().equals(entity.getId())) { if (old != null && !old.getId().equals(entity.getId())) {
throw new MyException("stationCode=" + entity.getStationCode() + " 已被其他有效数据使用，不能恢复"); throw new MyException("stationCode=" + entity.getStationCode() + " 已被其他有效数据使用，不能恢复");
} }
entity.setModificationTime(new Date()); entity.setModificationTime(new Date());
redisTemplate.delete(Constants.CACHE_NAME); redisTemplate.delete(Constants.CACHE_NAME_SL);
return super.updateById(entity); return super.updateById(entity);
} }
@Override @Override
@CacheEvict(Constants.CACHE_NAME) @CacheEvict(Constants.CACHE_NAME_SL)
public boolean removeById(Serializable id) { public boolean removeById(Serializable id) {
DeviceSLInfo entity = baseMapper.selectById(id); DeviceSLInfo entity = baseMapper.selectById(id);
entity.setDel(1); entity.setDel(1);
@ -114,7 +114,7 @@ public class DeviceSLInfoServiceimpl extends ServiceImpl<DeviceSLInfoMapper, Dev
} }
@Override @Override
@CacheEvict(Constants.CACHE_NAME) @CacheEvict(Constants.CACHE_NAME_SL)
public boolean restore(Integer id) { public boolean restore(Integer id) {
DeviceSLInfo entity = baseMapper.selectById(id); DeviceSLInfo entity = baseMapper.selectById(id);
@ -136,7 +136,7 @@ public class DeviceSLInfoServiceimpl extends ServiceImpl<DeviceSLInfoMapper, Dev
} }
@Override @Override
@Cacheable(Constants.CACHE_NAME) @Cacheable(Constants.CACHE_NAME_SL)
public List<DeviceSLInfo> listAll() { public List<DeviceSLInfo> listAll() {
return baseMapper.listAll(); return baseMapper.listAll();
} }
@ -222,7 +222,7 @@ public class DeviceSLInfoServiceimpl extends ServiceImpl<DeviceSLInfoMapper, Dev
@Override @Override
public void clearCache() { public void clearCache() {
Set<String> keys = redisTemplate.keys(Constants.CACHE_NAME + "*"); Set<String> keys = redisTemplate.keys(Constants.CACHE_NAME_SL + "*");
for (String k : keys) { for (String k : keys) {
redisTemplate.delete(k); redisTemplate.delete(k);
} }