diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/configuration/DataSeparatorSystemInit.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/configuration/DataSeparatorSystemInit.java new file mode 100644 index 0000000..c36ea27 --- /dev/null +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/configuration/DataSeparatorSystemInit.java @@ -0,0 +1,38 @@ +package cn.estsh.i3plus.core.apiservice.configuration; + +import cn.estsh.i3plus.core.api.iservice.base.ICoreDataSourceService; +import cn.estsh.i3plus.core.api.iservice.base.IDataSeparatorService; +import cn.estsh.impp.framework.boot.init.IAppStartSystemInit; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression; +import org.springframework.stereotype.Component; + +/** + * @Description : + * @Reference : + * @Author : Castle + * @CreateDate : 2022/1/17 16:03 + * @Modify: + **/ +@Component +@Slf4j +@ConditionalOnExpression("'${impp.aspect.data.separation:false}' == 'true'") +public class DataSeparatorSystemInit implements IAppStartSystemInit { + @Autowired + private IDataSeparatorService dataSeparatorService; + + @Autowired + private ICoreDataSourceService iCoreDataSourceService; + + @Override + public void systemInit() { + log.info("【通用数据冷热分离初始化开始...】"); + dataSeparatorService.separatorRedisInit(); + log.info("【通用数据冷热分离初始化结束...】"); + + log.info("【通用数据冷热分离初始化数据源开始...】"); + iCoreDataSourceService.initCoreDataSource(); + log.info("【通用数据冷热分离初始化数据源结束...】"); + } +} diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/base/SystemInitService.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/base/SystemInitService.java index fbcb7f6..070f8ee 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/base/SystemInitService.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/base/SystemInitService.java @@ -78,11 +78,7 @@ public class SystemInitService implements ISystemInitService { @Autowired private ISysSmsSendRecordService sysSmsSendRecordService; - @Autowired - private IDataSeparatorService dataSeparatorService; - @Autowired - private ICoreDataSourceService iCoreDataSourceService; @Resource(name= CommonConstWords.IMPP_REDIS_RES) private ImppRedis redisRes; @@ -128,13 +124,7 @@ public class SystemInitService implements ISystemInitService { createSmsSyncThread(); LOGGER.info("创建 短信同步线程 完成"); - LOGGER.info("【通用数据冷热分离初始化开始...】"); - dataSeparatorService.separatorRedisInit(); - LOGGER.info("【通用数据冷热分离初始化结束...】"); - LOGGER.info("【通用数据冷热分离初始化数据源开始...】"); - iCoreDataSourceService.initCoreDataSource(); - LOGGER.info("【通用数据冷热分离初始化数据源结束...】"); }catch (Exception e){ e.printStackTrace(); }