平阴生产多数据源

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/constant/DataSourceConstant.java

@@ -17,4 +17,8 @@ public interface DataSourceConstant {
     String EPMET_HEART="epmetHeart";
     String EPMET_POINT = "epmetPoint";
     String OPER_CUSTOMIZE="operCustomize";
+    /**
+     * 济南的中间数据库
+     */
+    String JI_NAN = "jinan";
 }

epmet-module/open-data-worker/open-data-worker-server/pom.xml

@@ -85,6 +85,12 @@
             <version>2.0.0</version>
             <scope>compile</scope>
         </dependency>
+        <dependency>
+            <groupId>com.epmet</groupId>
+            <artifactId>epmet-commons-dynamic-datasource</artifactId>
+            <version>2.0.0</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
 
     <build>
@@ -273,10 +279,18 @@
 
                 <!-- 数据库配置-->
                 <spring.datasource.druid.url>
-                    <![CDATA[jdbc:mysql://172.20.92.220:3306/district_grid_record?allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai]]>
+                    <![CDATA[jdbc:mysql://172.22.76.30:3306/epmet_open_data?allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai]]>
                 </spring.datasource.druid.url>
-                <spring.datasource.druid.username>sync_gridinfo_pingyin</spring.datasource.druid.username>
+                <spring.datasource.druid.username>epmet_open_data_user</spring.datasource.druid.username>
-                <spring.datasource.druid.password>xvfuz2lz</spring.datasource.druid.password>
+                <spring.datasource.druid.password>EpmEtOpEndAtArw_)$</spring.datasource.druid.password>
+
+                <!--JN datanbase-->
+                <spring.datasource.jinan.druid.url>
+                    <![CDATA[jdbc:mysql://172.20.92.220:3306/district_grid_record?allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai]]>
+                </spring.datasource.jinan.druid.url>
+                <spring.datasource.jinan.druid.username>sync_gridinfo_pingyin</spring.datasource.jinan.druid.username>
+                <spring.datasource.jinan.druid.password>xvfuz2lz</spring.datasource.jinan.druid.password>
+
                 <!-- redis配置 -->
                 <spring.redis.index>0</spring.redis.index>
                 <spring.redis.cluster.nodes>172.22.76.1:6379,172.22.76.20:6379,172.22.76.36:6379,172.22.76.1:6389,172.22.76.20:6389,172.22.76.36:6389</spring.redis.cluster.nodes>

epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/EventreportPingyinServiceImpl.java

@@ -1,11 +1,13 @@
 package com.epmet.opendata.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.epmet.commons.dynamic.datasource.annotation.DataSource;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
 import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.exception.RenException;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.commons.tools.utils.StrUtil;
+import com.epmet.constant.DataSourceConstant;
 import com.epmet.dto.basereport.form.EventInfoFormDTO;
 import com.epmet.dto.basereport.result.EventInfoResultDTO;
 import com.epmet.feign.DataStatisticalOpenFeignClient;
@@ -32,6 +34,7 @@ import java.util.stream.Collectors;
  */
 @Slf4j
 @Service
+@DataSource(DataSourceConstant.JI_NAN)
 public class EventreportPingyinServiceImpl extends BaseServiceImpl<EventreportPingyinDao, EventreportPingyinEntity> implements EventreportPingyinService {
     @Resource
     private DataStatisticalOpenFeignClient dataStatisticalOpenFeignClient;

epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/GridInfoPingyinServiceImpl.java

@@ -1,11 +1,13 @@
 package com.epmet.opendata.service.impl;
 
+import com.epmet.commons.dynamic.datasource.annotation.DataSource;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
 import com.epmet.commons.tools.constant.Constant;
 import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.exception.RenException;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.utils.Result;
+import com.epmet.constant.DataSourceConstant;
 import com.epmet.constant.IndexCalConstant;
 import com.epmet.dto.org.result.CustomerAgencyDTO;
 import com.epmet.dto.org.result.CustomerGridDTO;
@@ -33,6 +35,7 @@ import java.util.List;
  * @since v1.0.0 2022-07-22
  */
 @Service
+@DataSource(DataSourceConstant.JI_NAN)
 public class GridInfoPingyinServiceImpl extends BaseServiceImpl<GridInfoPingyinDao, GridInfoPingyinEntity> implements GridInfoPingyinService {
     @Autowired
     private DataStatisticalOpenFeignClient dataStatisticalOpenFeignClient;

epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/service/impl/GridstaffInfoPingyinServiceImpl.java

@@ -1,9 +1,11 @@
 package com.epmet.opendata.service.impl;
 
+import com.epmet.commons.dynamic.datasource.annotation.DataSource;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
 import com.epmet.commons.tools.exception.RenException;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.utils.Result;
+import com.epmet.constant.DataSourceConstant;
 import com.epmet.dto.form.CustomerGridStaffListFormDTO;
 import com.epmet.dto.form.GridStaffUploadtFormDTO;
 import com.epmet.dto.result.CustomerGridStaffListResultDTO;
@@ -36,6 +38,7 @@ import java.util.stream.Collectors;
  */
 @Service
 @Slf4j
+@DataSource(DataSourceConstant.JI_NAN)
 public class GridstaffInfoPingyinServiceImpl extends BaseServiceImpl<GridstaffInfoPingyinDao, GridstaffInfoPingyinEntity> implements GridstaffInfoPingyinService {
 
     @Autowired

epmet-module/open-data-worker/open-data-worker-server/src/main/resources/bootstrap.yml

@@ -72,6 +72,13 @@ spring:
     baseline-on-migrate: true
     baseline-version: 0
 
+dynamic:
+  datasource:
+    jinan:
+      driver-class-name: com.mysql.cj.jdbc.Driver
+      url: @datasource.druid.org.url@
+      username: @datasource.druid.org.username@
+      password: @datasource.druid.org.password@
 
 management:
   endpoints: