冷热数据分离需要单独开启，平台开启，还需要特定服务开启

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("【通用数据冷热分离初始化数据源结束...】");
+    }
+}

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();
         }