package com.vci.web.initTask;
|
|
import com.vci.client.mw.ClientContextVariable;
|
import com.vci.client.mw.LaunchModeEnum;
|
import com.vci.constant.FrameWorkBtmTypeConstant;
|
import com.vci.corba.common.PLException;
|
import com.vci.corba.framework.FrameworkServicePrx;
|
import com.vci.corba.omd.data.AttributeValue;
|
import com.vci.starter.web.annotation.config.VciConfigField;
|
import com.vci.starter.web.annotation.config.VciConfigModule;
|
import com.vci.starter.web.enumpck.SessionStorageTypeEnum;
|
import com.vci.starter.web.enumpck.UserSecretEnum;
|
import com.vci.starter.web.pagemodel.SessionInfo;
|
import com.vci.starter.web.properties.VciSessionProperties;
|
import com.vci.starter.web.util.ApplicationContextProvider;
|
import com.vci.starter.web.wrapper.VciQueryWrapperForDO;
|
import com.vci.web.properties.VciFramworkCompatibilityProperties;
|
import com.vci.web.properties.WebProperties;
|
import com.vci.web.util.PlatformClientUtil;
|
import com.vci.web.util.WebUtil;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.boot.ApplicationArguments;
|
import org.springframework.boot.ApplicationRunner;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.CollectionUtils;
|
|
import java.lang.reflect.Field;
|
import java.lang.reflect.InvocationTargetException;
|
import java.lang.reflect.Method;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
|
/**
|
* 服务初始化
|
* @author weidy
|
* @date 2019/12/13
|
*/
|
@Component
|
public class VciWebInitTaskComponent implements ApplicationRunner {
|
|
/**
|
* 日志对象
|
*/
|
private Logger logger = LoggerFactory.getLogger(getClass());
|
|
/**
|
* 配置对象
|
*/
|
@Autowired
|
private WebProperties webProperties;
|
|
/**
|
* 平台调用客户端
|
*/
|
@Autowired
|
private PlatformClientUtil platformClientUtil;
|
|
/**
|
* 会话的配置
|
*/
|
@Autowired(required = false)
|
private VciSessionProperties sessionProperties;
|
|
/**
|
* 引入兼容的配置
|
*/
|
@Autowired(required = false)
|
private VciFramworkCompatibilityProperties compatibilityProperties;
|
|
/**
|
* 执行初始化
|
* @param args 启动的参数
|
*/
|
@Override
|
public void run(ApplicationArguments args) {
|
initCompatibility();
|
initSysadmin();
|
initClearSession();
|
initSetting();
|
}
|
|
|
|
/**
|
* 清除会话的信息内容
|
*/
|
public void initClearSession(){
|
if((sessionProperties != null && sessionProperties.isClearSessionOnStart() )&&
|
SessionStorageTypeEnum.DATABASE.equals(SessionStorageTypeEnum.forValue(sessionProperties.getSessionInfoStorageType()))){
|
try {
|
platformClientUtil.getBOFactoryService().executeUpdateSqlByParams(" delete from VCI_SESSIONINFO ",new AttributeValue[0]);
|
}catch (Throwable e) {
|
if (logger.isErrorEnabled()) {
|
logger.error("清除会话信息", e);
|
}
|
}
|
}
|
}
|
|
|
/**
|
* 初始化兼容的内容
|
*/
|
public void initCompatibility(){
|
//设置兼容性的表格
|
VciQueryWrapperForDO.USER_TABLE_COMPATIBILITY = true;
|
String userBtmType = FrameWorkBtmTypeConstant.SM_USER_BTM_TYPE.toLowerCase();
|
String roleBtmType = FrameWorkBtmTypeConstant.SM_ROLE_BTM_TYPE.toLowerCase();
|
String deptBtmType = FrameWorkBtmTypeConstant.ORG_DEPARTMENT_BTM_TYPE.toLowerCase();
|
String functionBtmType = FrameWorkBtmTypeConstant.SM_FUNCTION_BTM_TYPE.toLowerCase();
|
VciQueryWrapperForDO.USER_TABLE_COMPATIBILITY_BTM_MAP.put(userBtmType, "pluser");
|
VciQueryWrapperForDO.USER_TABLE_COMPATIBILITY_BTM_MAP.put(roleBtmType, "plrole");
|
VciQueryWrapperForDO.USER_TABLE_COMPATIBILITY_BTM_MAP.put(deptBtmType, "pldept");
|
VciQueryWrapperForDO.USER_TABLE_COMPATIBILITY_BTM_MAP.put(functionBtmType, "plfunction");
|
//读取表格映射的字段
|
if (!CollectionUtils.isEmpty(compatibilityProperties.getUserTableFieldMap())) {
|
compatibilityProperties.getUserTableFieldMap().forEach((k, v) -> {
|
String key = userBtmType + VciQueryWrapperForDO.USER_TABLE_COMPATIBILITY_FIELD_SEP + k.toLowerCase();
|
VciQueryWrapperForDO.USER_TABLE_COMPATIBILITY_FIELD_MAP.put(key, v);
|
});
|
}
|
if (!CollectionUtils.isEmpty(compatibilityProperties.getRoleTableFieldMap())) {
|
compatibilityProperties.getRoleTableFieldMap().forEach((k, v) -> {
|
String key = roleBtmType + VciQueryWrapperForDO.USER_TABLE_COMPATIBILITY_FIELD_SEP + k.toLowerCase();
|
VciQueryWrapperForDO.USER_TABLE_COMPATIBILITY_FIELD_MAP.put(key, v);
|
});
|
}
|
if (!CollectionUtils.isEmpty(compatibilityProperties.getDeptTableFieldMap())) {
|
compatibilityProperties.getDeptTableFieldMap().forEach((k, v) -> {
|
String key = deptBtmType + VciQueryWrapperForDO.USER_TABLE_COMPATIBILITY_FIELD_SEP + k.toLowerCase();
|
VciQueryWrapperForDO.USER_TABLE_COMPATIBILITY_FIELD_MAP.put(key, v);
|
});
|
}
|
if (!CollectionUtils.isEmpty(compatibilityProperties.getFunctionTableFieldMap())) {
|
compatibilityProperties.getFunctionTableFieldMap().forEach((k, v) -> {
|
String key = functionBtmType + VciQueryWrapperForDO.USER_TABLE_COMPATIBILITY_FIELD_SEP + k.toLowerCase();
|
VciQueryWrapperForDO.USER_TABLE_COMPATIBILITY_FIELD_MAP.put(key, v);
|
});
|
}
|
}
|
|
/**
|
* 初始化用户
|
*/
|
public void initSysadmin(){
|
SessionInfo sessionInfo = new SessionInfo();
|
sessionInfo.setUserId("sysAdmin");
|
sessionInfo.setUserName("系统管理员");
|
sessionInfo.setIp(WebUtil.getLocalIp());
|
sessionInfo.setUserOid("193C026F-7DB8-27B4-F383-4E8BE083FB07");
|
sessionInfo.setUserSecret(UserSecretEnum.PRIVACY.getValue()+"");
|
WebUtil.setSessionInfo(sessionInfo);
|
}
|
/**
|
* 初始化相关的配置信息
|
*/
|
public void initSetting() {
|
System.out.println("----初始化用于查询配置的用户----");
|
ClientContextVariable.setClientLanuchMode(LaunchModeEnum.WebApp);
|
System.out.println("----初始化用于查询配置的用户完成----");
|
System.out.println("----开始扫描有VciConfigModule注解的类----");
|
String[] namesForAnnotation = ApplicationContextProvider.getApplicationContext().getBeanNamesForAnnotation(VciConfigModule.class);
|
if(namesForAnnotation!=null && namesForAnnotation.length > 0){
|
for(String beanName : namesForAnnotation){
|
Object bean = ApplicationContextProvider.getApplicationContext().getBean(beanName);
|
List<Field> fields = WebUtil.getAllFieldForObj(bean.getClass());
|
Map<String,Field> configFieldMap = new HashMap<>();
|
List<Field> hasConfigFields = fields.stream().filter(s -> {
|
s.setAccessible(true);
|
return s.isAnnotationPresent(VciConfigField.class);
|
}).collect(Collectors.toList());
|
if(!CollectionUtils.isEmpty(hasConfigFields)){
|
hasConfigFields.stream().forEach(field -> {
|
field.setAccessible(true);
|
VciConfigField vciConfigField = field.getAnnotation(VciConfigField.class);
|
if(vciConfigField == null){
|
vciConfigField = field.getDeclaredAnnotation(VciConfigField.class);
|
}
|
configFieldMap.put(vciConfigField.value(),field);
|
});
|
FrameworkServicePrx frameworkServicePrx = platformClientUtil.getFrameworkService();
|
configFieldMap.forEach((configField,field)->{
|
String configValue = null;
|
try {
|
configValue = frameworkServicePrx.getConfigValue(configField);
|
} catch (PLException vciError) {
|
if(logger.isErrorEnabled()){
|
logger.error(vciError.code,vciError);
|
}
|
}
|
Class<?> fieldType = field.getType();
|
Method method = WebUtil.getSetmethod(bean.getClass(), field);
|
Object value = null;
|
if(fieldType.equals(Boolean.class) || fieldType.equals(boolean.class)){
|
value = ("on".equalsIgnoreCase(configValue) || "true".equalsIgnoreCase(configValue))?true:false;
|
}else if(fieldType.equals(Double.class) || fieldType.equals(double.class)){
|
value = WebUtil.getDouble(configValue);
|
}else if(fieldType.equals(Long.class) || fieldType.equals(long.class)){
|
value = WebUtil.getLong(configValue);
|
}else if(fieldType.equals(Float.class) || fieldType.equals(float.class)){
|
value = WebUtil.getFloat(configValue);
|
}else if(fieldType.equals(Integer.class) || fieldType.equals(int.class)){
|
value = WebUtil.getInt(configValue);
|
}else{
|
value = configValue;
|
}
|
try {
|
method.invoke(bean,value);
|
} catch (IllegalAccessException e) {
|
if(logger.isErrorEnabled()){
|
logger.error(e.getMessage(),e);
|
}
|
} catch (InvocationTargetException e) {
|
if(logger.isErrorEnabled()){
|
logger.error(e.getMessage(),e);
|
}
|
}
|
});
|
}
|
}
|
}
|
//只有当数据密级控制开启的情况下，才会控制流程发起时的密级
|
webProperties.setCheckSecretOnProcessStart(webProperties.isCheckClientSessionTimeout()&&webProperties.isSecretRight());
|
System.out.println("---读取服务端的配置文件完成---");
|
}
|
}
|
