package com.ld.igds.common.impl;
|
|
import com.ld.igds.common.CoreThreeService;
|
import com.ld.igds.common.mapper.CommonMapper;
|
import com.ld.igds.constant.Constant;
|
import com.ld.igds.constant.RedisConst;
|
import com.ld.igds.models.ThreeConf;
|
import com.ld.igds.util.RedisUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Set;
|
|
@Slf4j
|
@Service(CoreThreeService.BEAN_ID)
|
public class CoreThreeServiceImpl implements CoreThreeService {
|
|
@Autowired
|
private RedisUtil redisUtil;
|
@Autowired
|
private CommonMapper commonMapper;
|
|
|
@Override
|
public List<ThreeConf> getCacheThreeAll(String companyId) {
|
|
String patten = Constant.APP_NAME + ":" + companyId + ":" + RedisConst.KEY_THREE_CONF;
|
Set<String> keys = redisUtil.keys(patten);
|
List<ThreeConf> threeList = new ArrayList<>();
|
ThreeConf threeConf;
|
for (String key : keys) {
|
threeConf = (ThreeConf) redisUtil.get(key);
|
|
if(null != threeConf){
|
threeList.add(threeConf);
|
}
|
}
|
|
if (threeList.size() == 0) {
|
//从数据库获取并存入缓存
|
threeList = commonMapper.getAllThreeConf(companyId);
|
if (threeList.size() == 0) {
|
log.error("没有获取到三维配置");
|
return null;
|
}
|
}
|
|
return threeList;
|
}
|
|
@Override
|
public ThreeConf getCacheThreeConfById(String companyId, String threeId) {
|
|
String key = RedisConst.buildKey(companyId, RedisConst.KEY_THREE_CONF, threeId);
|
|
ThreeConf threeConf = (ThreeConf) redisUtil.get(key);
|
if(threeConf == null){
|
threeConf = commonMapper.getThreeConfByUid(companyId, threeId);
|
}
|
|
return threeConf;
|
}
|
|
}
|
