package com.ishop.merchant.cache; import com.ishop.merchant.Constants; import com.ishop.merchant.LevelCache; import com.ishop.merchant.service.LevelServiceImpl; import com.ishop.model.po.EbLevel; import com.walker.cache.Cache; import com.walker.infrastructure.utils.StringUtils; import com.walker.support.redis.cache.RedisCacheProvider; import java.util.List; public class RedisLevelCache extends RedisCacheProvider implements LevelCache { public RedisLevelCache(){ this.setUseRedis(true); this.setLoadPage(false); } @Override protected int loadDataToCache(Cache cache) { List hosts = this.levelService.selectAll(new EbLevel()); if(!StringUtils.isEmptyList(hosts)){ // ------------------------- 切换成普通缓存步骤:3 if(this.isUseRedis()){ // 如果redis中缓存数量和数据库中不一致(少),则清空redis缓存,重新加载数据库数据到缓存中。 long totalCache = cache.getPersistentSize(); if(totalCache != hosts.size()){ logger.info("redis缓存中用户数量小于实际用户,需要清空缓存重新加载! cache = " + totalCache + ", db = " + hosts.size()); cache.clear(); for(EbLevel h : hosts){ cache.put(String.valueOf(h.getId()), h); } } }//------------------------------------------ return hosts.size(); } return 0; } @Override public EbLevel get(int id) { return this.getCacheData(String.valueOf(id)); } @Override public void save(EbLevel category) { this.putCacheData(String.valueOf(category.getId()), category); } @Override public void update(EbLevel category) { this.updateCacheData(String.valueOf(category.getId()), category); } @Override public void remove(int id) { this.removeCacheData(String.valueOf(id)); } @Override public String getProviderName() { return Constants.CACHE_NAME_LEVEL; } @Override public Class getProviderType() { return EbLevel.class; } public void setLevelService(LevelServiceImpl levelService) { this.levelService = levelService; } private LevelServiceImpl levelService; }