Explorar o código

selectdb双写

huangpingkang hai 11 meses
pai
achega
8903a1295f

+ 1 - 0
job-adq/src/main/java/cn/com/ctop/job/adq/data/mapper/AdqCreativeReportMapper.java

@@ -10,6 +10,7 @@ import java.util.List;
 
 public interface AdqCreativeReportMapper {
     void addsHourList(@Param("adds") List<AdqCreativeReportHour> hourList);
+
     @DS("selectdb")
     void addsHourListSD(@Param("adds") List<AdqCreativeReportHour> hourList);
 

+ 4 - 4
job-adq/src/main/java/cn/com/ctop/job/adq/data/service/impl/AdqCreativeCreativeReportServiceImpl.java

@@ -95,9 +95,9 @@ public class AdqCreativeCreativeReportServiceImpl implements IAdqCreativeReportS
                 adqReportMapper.addsHourList(hourList);
                 log.info("新增数据完成account:id:{}", advertiserId);
                 try {
-                //    adqReportMapper.addsHourListSD(hourList);
+                    adqReportMapper.addsHourListSD(hourList);
                 } catch (Exception e) {
-                    log.error("addsHourListSD", e.getMessage());
+                    e.printStackTrace();
                 }
 
             }
@@ -178,9 +178,9 @@ public class AdqCreativeCreativeReportServiceImpl implements IAdqCreativeReportS
             if (!Check.isNull(dailies)) {
                 adqReportMapper.addsDaily(dailies);
                 try {
-                  //  adqReportMapper.addsDailySD(dailies);
+                    adqReportMapper.addsDailySD(dailies);
                 } catch (Exception e) {
-                    log.error("addsDailySD", e);
+                    e.printStackTrace();
                 }
             }
             if (dailies.size() >= 1000) {

+ 5 - 5
job-adq/src/main/resources/application.yml

@@ -87,11 +87,11 @@ spring:
           username: data
           password: hr@2025..
           driver-class-name: com.mysql.jdbc.Driver
-#        selectdb:
-#          url: jdbc:mysql://selectdb-cn-vym4at1qw04.selectdbfe.rds.aliyuncs.com:9030/media_api?characterEncoding=UTF-8&useUnicode=true&useSSL=false
-#          username: data
-#          password: hr@2025..
-#          driver-class-name: com.mysql.jdbc.Driver
+        selectdb:
+          url: jdbc:mysql://selectdb-cn-vym4at1qw04.selectdbfe.rds.aliyuncs.com:9030/media_api?characterEncoding=UTF-8&useUnicode=true&useSSL=false
+          username: data
+          password: hr@2025..
+          driver-class-name: com.mysql.jdbc.Driver
 
   # redis 配置
   redis: