package com.iplatform.base.support;
|
|
import com.iplatform.base.Constants;
|
import com.iplatform.base.service.ConfigArgumentServiceImpl;
|
import com.iplatform.base.util.ArgumentsManagerUtils;
|
import com.iplatform.core.SimpleVariable;
|
import com.iplatform.model.po.S_config;
|
import com.walker.cache.Cache;
|
import com.walker.infrastructure.arguments.ArgumentsManager;
|
import com.walker.infrastructure.arguments.Group;
|
import com.walker.infrastructure.arguments.Variable;
|
import com.walker.infrastructure.arguments.VariableType;
|
import com.walker.infrastructure.utils.StringUtils;
|
import com.walker.security.SystemLogMan;
|
import com.walker.support.redis.cache.RedisCacheProvider;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 基于 Redis 实现的系统可变参数管理器，负责初始化并获取配置参数。
|
* @author 时克英
|
* @date 2022-11-29
|
*/
|
public class RedisArgumentsManager extends RedisCacheProvider<SimpleVariable> implements ArgumentsManager {
|
|
private ConfigArgumentServiceImpl configArgumentService = null;
|
|
// 2023-05-16，按照formId分组配置集合
|
private Map<String, List<Variable>> formGroupReference = new HashMap<>();
|
|
public void setConfigArgumentService(ConfigArgumentServiceImpl configArgumentService) {
|
this.configArgumentService = configArgumentService;
|
SystemLogMan.getInstance().checkMan();
|
}
|
|
public RedisArgumentsManager(){
|
SystemLogMan.getInstance().checkMan();
|
this.setUseRedis(true);
|
this.setLoadPage(false);
|
}
|
|
@Override
|
protected int loadDataToCache(Cache cache) {
|
List<S_config> data = this.configArgumentService.selectAll(new S_config());
|
// logger.info("+++++++++++++ 开始加载 argument");
|
if(!StringUtils.isEmptyList(data)){
|
if(this.isUseRedis()){
|
// 如果redis中缓存数量和数据库中不一致（少），则清空redis缓存，重新加载数据库数据到缓存中。
|
long totalCache = cache.getPersistentSize();
|
if(totalCache != data.size()){
|
logger.info("redis缓存中【S_config】数量小于实际数据库中，需要清空缓存重新加载! cache = " + totalCache + ", db = " + data.size());
|
cache.clear();
|
for(S_config h : data){
|
cache.put(String.valueOf(h.getConfig_key()), ArgumentsManagerUtils.toVariable(h.getConfig_key(), h.getConfig_value(), h.getData_type()));
|
}
|
}
|
}
|
|
// 2023-05-16，对于redis来说，只要系统启动，就需要重新加载分组信息，因为分组没有放入redis，而是在本机内存
|
// 这在集群环境下，需要重新加载缓存对象，如：缓存管理中。
|
//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
Variable variable = null;
|
List<Variable> groupList = null;
|
for(S_config h : data){
|
variable = ArgumentsManagerUtils.toVariable(h.getConfig_key(), h.getConfig_value(), h.getData_type());
|
groupList = this.formGroupReference.get(String.valueOf(h.getForm_id()));
|
if(groupList == null){
|
groupList = new ArrayList<>(8);
|
this.formGroupReference.put(String.valueOf(h.getForm_id()), groupList);
|
}
|
groupList.add(variable);
|
}
|
//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
|
return data.size();
|
}
|
return 0;
|
}
|
|
// private SimpleVariable toVariable(String key , String value, String dataType){
|
// SimpleVariable variable = new SimpleVariable();
|
// variable.setId(key);
|
// variable.setStringValue(value);
|
// variable.setDataType(dataType);
|
// return variable;
|
// }
|
|
@Override
|
public SimpleVariable getVariable(String id) {
|
return this.getCacheData(id);
|
}
|
|
@Override
|
public void persist(String variableId, Object value) {
|
// logger.warn("这些方法暂时不需要实现，因为后续配置参数管理后台不会使用:ArgumentsManager,直接读取数据库，业务也只需要使用获取方法!");
|
SimpleVariable variable = ArgumentsManagerUtils.toVariable(variableId, value.toString(), VariableType.DEF_STRING);
|
this.updateCacheData(variableId, variable);
|
}
|
|
@Override
|
public void persist(String groupId, String variableId, Object value) {
|
this.persist(variableId, value);
|
}
|
|
@Override
|
public void persist(List<Object[]> changedList) {
|
throw new UnsupportedOperationException("未实现代码");
|
}
|
|
@Override
|
public void insert(List<Object[]> insertList) {
|
throw new UnsupportedOperationException("未实现代码");
|
}
|
|
@Override
|
public List<Group> getGroupList() {
|
throw new UnsupportedOperationException("未实现代码");
|
}
|
|
@Override
|
public List<Variable> getVariableList(String groupId) {
|
// List<S_config> configList = this.configArgumentService.queryGroupConfigList(groupId);
|
// return ArgumentsManagerUtils.acquireGroupVariableList(configList);
|
// 使用新机制，根据formId返回分组参数集合。
|
return this.formGroupReference.get(groupId);
|
}
|
|
@Override
|
public void setSource(Object source) {
|
}
|
|
@Override
|
public void destroy() throws Exception {
|
|
}
|
|
@Override
|
public void afterPropertiesSet() throws Exception {
|
// ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
// ~ 一定要调用父对象方法，2022-11-29
|
// ~ 因为 RedisCacheProvider 和 ArgumentsManager 都有这个方法实现，否则初始load方法不会被加载!
|
// ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
super.afterPropertiesSet();
|
}
|
|
@Override
|
public String getProviderName() {
|
return Constants.CACHE_NAME_ARGUMENTS;
|
}
|
|
@Override
|
public Class<?> getProviderType() {
|
return SimpleVariable.class;
|
}
|
}
|
