【add】数据字典模块刷新缓存的服务层接口

This commit is contained in:
mzc5649
2021-04-08 09:11:57 +08:00
parent 312fdfcd79
commit 2bc988c1f9
4 changed files with 1021 additions and 1001 deletions
@@ -360,6 +360,7 @@ public class OnlCgformHeadServiceImpl extends ServiceImpl<OnlCgformHeadMapper, O
} }
} }
@Override
public void deleteRecordAndTable(String id) throws DBException, SQLException { public void deleteRecordAndTable(String id) throws DBException, SQLException {
OnlCgformHead var2 = (OnlCgformHead)this.getById(id); OnlCgformHead var2 = (OnlCgformHead)this.getById(id);
if (var2 == null) { if (var2 == null) {
@@ -406,24 +406,13 @@ public class SysDictController {
/** /**
* @功能:刷新缓存 * @功能:刷新缓存
* @date 修改时间 2021.4.8
* @return * @return
*/ */
@RequestMapping(value = "/refleshCache") @RequestMapping(value = "/refleshCache")
public Result<?> refleshCache() { public Result<?> refleshCache() {
Result<?> result = new Result<SysDict>(); Result<?> result = new Result<SysDict>();
//清空字典缓存 sysDictService.refreshCache();
Set keys = redisTemplate.keys(CacheConstant.SYS_DICT_CACHE + "*");
Set keys2 = redisTemplate.keys(CacheConstant.SYS_DICT_TABLE_CACHE + "*");
Set keys3 = redisTemplate.keys(CacheConstant.SYS_DEPARTS_CACHE + "*");
Set keys4 = redisTemplate.keys(CacheConstant.SYS_DEPART_IDS_CACHE + "*");
Set keys5 = redisTemplate.keys( "jmreport:cache:dict*");
Set keys6 = redisTemplate.keys( "jmreport:cache:dictTable*");
redisTemplate.delete(keys);
redisTemplate.delete(keys2);
redisTemplate.delete(keys3);
redisTemplate.delete(keys4);
redisTemplate.delete(keys5);
redisTemplate.delete(keys6);
return result; return result;
} }
@@ -135,4 +135,11 @@ public interface ISysDictService extends IService<SysDict> {
@Deprecated @Deprecated
public List<DictModel> queryDictTablePageList(DictQuery query,int pageSize, int pageNo); public List<DictModel> queryDictTablePageList(DictQuery query,int pageSize, int pageNo);
/**
* 刷新dict缓存
* @date 2021/4/8 9:06
* @return void
*/
void refreshCache();
} }
@@ -20,13 +20,12 @@ import com.jero.modules.system.service.ISysDictService;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.Cacheable; import org.springframework.cache.annotation.Cacheable;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import java.util.ArrayList; import javax.annotation.Resource;
import java.util.HashMap; import java.util.*;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors; import java.util.stream.Collectors;
/** /**
@@ -45,6 +44,8 @@ public class SysDictServiceImpl extends ServiceImpl<SysDictMapper, SysDict> impl
private SysDictMapper sysDictMapper; private SysDictMapper sysDictMapper;
@Autowired @Autowired
private SysDictItemMapper sysDictItemMapper; private SysDictItemMapper sysDictItemMapper;
@Resource
private RedisTemplate<String, Object> redisTemplate;
/** /**
* 通过查询指定code 获取字典 * 通过查询指定code 获取字典
@@ -287,4 +288,26 @@ public class SysDictServiceImpl extends ServiceImpl<SysDictMapper, SysDict> impl
Page<DictModel> pageList = baseMapper.queryDictTablePageList(page, query); Page<DictModel> pageList = baseMapper.queryDictTablePageList(page, query);
return pageList.getRecords(); return pageList.getRecords();
} }
/**
* 刷新dict缓存
* @date 2021/4/8 9:07
* @param
* @return void
*/
@Override
public void refreshCache() {
//清空字典缓存
Set keys = redisTemplate.keys(CacheConstant.SYS_DICT_CACHE + "*");
Set keys2 = redisTemplate.keys(CacheConstant.SYS_DICT_TABLE_CACHE + "*");
Set keys3 = redisTemplate.keys(CacheConstant.SYS_DEPARTS_CACHE + "*");
Set keys4 = redisTemplate.keys(CacheConstant.SYS_DEPART_IDS_CACHE + "*");
Set keys5 = redisTemplate.keys( "jmreport:cache:dict*");
Set keys6 = redisTemplate.keys( "jmreport:cache:dictTable*");
redisTemplate.delete(keys);
redisTemplate.delete(keys2);
redisTemplate.delete(keys3);
redisTemplate.delete(keys4);
redisTemplate.delete(keys5);
redisTemplate.delete(keys6);
}
} }