From da94dad97114298b267a7ee4c9b457fb91087d3a Mon Sep 17 00:00:00 2001
From: "castle.zang" <loveCode1314>
Date: Mon, 17 Jan 2022 16:10:20 +0800
Subject: [PATCH] =?UTF-8?q?=E5=86=B7=E7=83=AD=E6=95=B0=E6=8D=AE=E5=88=86?=
 =?UTF-8?q?=E7=A6=BB=E9=9C=80=E8=A6=81=E5=8D=95=E7=8B=AC=E5=BC=80=E5=90=AF?=
 =?UTF-8?q?=EF=BC=8C=E5=B9=B3=E5=8F=B0=E5=BC=80=E5=90=AF=EF=BC=8C=E8=BF=98?=
 =?UTF-8?q?=E9=9C=80=E8=A6=81=E7=89=B9=E5=AE=9A=E6=9C=8D=E5=8A=A1=E5=BC=80?=
 =?UTF-8?q?=E5=90=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../configuration/DataSeparatorSystemInit.java     | 38 ++++++++++++++++++++++
 .../serviceimpl/base/SystemInitService.java        | 10 ------
 2 files changed, 38 insertions(+), 10 deletions(-)
 create mode 100644 modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/configuration/DataSeparatorSystemInit.java

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