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.AbstractCacheProvider;
|
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 java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 基于内存实现的可变参数管理器实现。
|
* @author 时克英
|
* @date 2022-11-29
|
*/
|
public class DatabaseArgumentsManager extends AbstractCacheProvider<Variable> 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;
|
}
|
|
@Override
|
protected int loadDataToCache(Cache cache) {
|
List<S_config> hosts = this.configArgumentService.selectAll(new S_config());
|
if(!StringUtils.isEmptyList(hosts)){
|
Variable variable = null;
|
List<Variable> groupList = null;
|
for(S_config h : hosts){
|
// cache.put(String.valueOf(h.getId()), h);
|
variable = ArgumentsManagerUtils.toVariable(h.getConfig_key(), h.getConfig_value(), h.getData_type());
|
cache.put(String.valueOf(h.getConfig_key()), variable);
|
|
// 2023-05-16
|
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 hosts.size();
|
}
|
return 0;
|
}
|
|
@Override
|
public String getProviderName() {
|
return Constants.CACHE_NAME_ARGUMENTS;
|
}
|
|
@Override
|
public Class<?> getProviderType() {
|
return Variable.class;
|
}
|
|
@Override
|
public Variable getVariable(String id) {
|
return this.getCacheData(id);
|
}
|
|
@Override
|
public void persist(String variableId, Object value) {
|
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) {
|
|
}
|
}
|
