package com.consum.base.cache;
|
|
import com.consum.base.Constants;
|
import com.consum.base.FinOrgCacheProvider;
|
import com.consum.base.service.FinOrgService;
|
import com.consum.model.po.FinSysOrg;
|
import com.walker.support.redis.cache.RedisCacheProvider;
|
|
/**
|
* Redis实现的运维系统机构定义。
|
* @author 时克英
|
* @date 2023-07-05
|
*/
|
public class RedisFinOrgCache extends RedisCacheProvider<FinSysOrg> implements FinOrgCacheProvider {
|
|
public RedisFinOrgCache(){
|
this.setUseRedis(true);
|
this.setLoadPage(false);
|
}
|
|
@Override
|
public FinSysOrg get(String orgCode) {
|
FinSysOrg finSysOrg = this.getCacheData(orgCode);
|
if(finSysOrg == null){
|
finSysOrg = this.finOrgService.queryOneByCode(orgCode);
|
if(finSysOrg == null){
|
logger.warn("从数据库未查询到机构,无法缓存,orgCode = {}", orgCode);
|
return null;
|
}
|
this.putCacheData(orgCode, finSysOrg);
|
}
|
return finSysOrg;
|
}
|
|
@Override
|
public void save(FinSysOrg e) {
|
this.putCacheData(e.getOrgCode(), e);
|
}
|
|
@Override
|
public void update(FinSysOrg e) {
|
this.updateCacheData(e.getOrgCode(), e);
|
}
|
|
@Override
|
public void remove(String orgCode) {
|
this.removeCacheData(orgCode);
|
}
|
|
@Override
|
public String getProviderName() {
|
return Constants.CACHE_NAME_FIN_ORG;
|
}
|
|
@Override
|
public Class<?> getProviderType() {
|
return FinSysOrg.class;
|
}
|
|
public void setFinOrgService(FinOrgService finOrgService) {
|
this.finOrgService = finOrgService;
|
}
|
|
private FinOrgService finOrgService;
|
|
}
|