Browse Source

selectdb双写

huangpingkang 11 tháng trước cách đây
mục cha
commit
85bb6a7391

+ 10 - 2
job-adq/src/main/java/cn/com/ctop/job/adq/data/service/impl/AdqAccountReportServiceImpl.java

@@ -91,7 +91,11 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
             }
             if (!Check.isNull(hourList)) {
                 accountReportMapper.addAccountHourList(hourList);
-                accountReportMapper.addAccountHourListSD(hourList);
+                try {
+                    accountReportMapper.addAccountHourListSD(hourList);
+                }catch (Exception e){
+                    log.error("addAccountHourListSD",e);
+                }
             }
             if (hourList.size() >= 1000) {
                 getAdqAccountHour(advertiserId, accessToken, startDate, endDate, page + 1, isLog);
@@ -162,7 +166,11 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
             }
             if (!Check.isNull(dailyList)) {
                 accountReportMapper.addAccountDailyList(dailyList);
-                accountReportMapper.addAccountDailyListSD(dailyList);
+                try {
+                    accountReportMapper.addAccountDailyListSD(dailyList);
+                }catch (Exception e){
+                    log.error("addAccountDailyListSD",e);
+                }
             }
             if (dailyList.size() >= 1000) {
                 getAdqAccountHour(advertiserId, accessToken, startDate, endDate, page + 1, isLog);

+ 11 - 2
job-adq/src/main/java/cn/com/ctop/job/adq/data/service/impl/AdqAdIncomeServiceImpl.java

@@ -101,7 +101,11 @@ public class AdqAdIncomeServiceImpl implements IAdqAdIncomeService {
             }
             if (!Check.isNull(reports)) {
                 adqAdIncomeMapper.insertAdqAdIncome(reports);
-                adqAdIncomeMapper.insertAdqAdIncomeSD(reports);
+                try{
+                    adqAdIncomeMapper.insertAdqAdIncomeSD(reports);
+                }catch (Exception e){
+                    log.error("insertAdqAdIncomeSD",e);
+                }
             }
 
             if (totalPage > page) {
@@ -180,7 +184,12 @@ public class AdqAdIncomeServiceImpl implements IAdqAdIncomeService {
             }
             if (!Check.isNull(reports)) {
                 adqAdIncomeMapper.insertAdqAdIncome(reports);
-                adqAdIncomeMapper.insertAdqAdIncomeSD(reports);
+                try {
+                    adqAdIncomeMapper.insertAdqAdIncomeSD(reports);
+                }catch (Exception e) {
+                    log.error("insertAdqAdIncomeSD",e);
+                }
+
             }
 
             if (totalPage > page) {

+ 11 - 2
job-adq/src/main/java/cn/com/ctop/job/adq/data/service/impl/AdqAssetReportServiceImpl.java

@@ -88,7 +88,11 @@ public class AdqAssetReportServiceImpl implements IAdqAssetReportService {
             }
             if (!Check.isNull(dailies)) {
                 adqAssetReportMapper.insertAdqAssetReportDaily(dailies);
-                adqAssetReportMapper.insertAdqAssetReportDailySD(dailies);
+                try {
+                    adqAssetReportMapper.insertAdqAssetReportDailySD(dailies);
+                }catch (Exception e) {
+                    log.error("insertAdqAssetReportDailySD",e);
+                }
             }
             if (!Check.isNullMap(assetIdsMap)) {
                 getAdqAssetInfo(assetIdsMap, advertiserId, accessToken, 1, null, null);
@@ -212,7 +216,12 @@ public class AdqAssetReportServiceImpl implements IAdqAssetReportService {
                 }
                 if (!Check.isNull(infos)) {
                     adqAssetReportMapper.insertAdqAssetInfo(infos);
-                    adqAssetReportMapper.insertAdqAssetInfoSD(infos);
+                    try {
+                        adqAssetReportMapper.insertAdqAssetInfoSD(infos);
+                    }catch (Exception e) {
+                        log.error("insertAdqAssetInfoSD",e);
+                    }
+
                 }
 
                 if (page == totalPage) {

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

@@ -91,7 +91,12 @@ public class AdqCreativeCreativeReportServiceImpl implements IAdqCreativeReportS
             }
             if (!Check.isNull(hourList)) {
                 adqReportMapper.addsHourList(hourList);
-                adqReportMapper.addsHourListSD(hourList);
+                try {
+                    adqReportMapper.addsHourListSD(hourList);
+                }catch (Exception e) {
+                    log.error("addsHourListSD",e);
+                }
+
             }
             if (hourList.size() >= 1000) {
                 getAdqCreativeHour(advertiserId, accessToken, startDate, endDate, page + 1, isLog);
@@ -169,7 +174,11 @@ public class AdqCreativeCreativeReportServiceImpl implements IAdqCreativeReportS
             }
             if (!Check.isNull(dailies)) {
                 adqReportMapper.addsDaily(dailies);
-                adqReportMapper.addsDailySD(dailies);
+                try {
+                    adqReportMapper.addsDailySD(dailies);
+                }catch (Exception e) {
+                    log.error("addsDailySD",e);
+                }
             }
             if (dailies.size() >= 1000) {
                 getAdqCreativeDaily(advertiserId, accessToken, startDate, endDate, page + 1, isLog);

+ 5 - 1
job-adq/src/main/java/cn/com/ctop/job/adq/data/service/impl/AdqFlowDetailsReportServiceImpl.java

@@ -114,7 +114,11 @@ public class AdqFlowDetailsReportServiceImpl implements IAdqFlowDetailsReportSer
                             dailyList = buildFlowDetailsReportDaily(dailyList);
 
                             adqFlowDetailsReportDailyMapper.replaceFlowDetailsReportDailies(dailyList);
-                            adqFlowDetailsReportDailyMapper.replaceFlowDetailsReportDailiesSD(dailyList);
+                            try {
+                                adqFlowDetailsReportDailyMapper.replaceFlowDetailsReportDailiesSD(dailyList);
+                            }catch (Exception e) {
+                                log.error("replaceFlowDetailsReportDailiesSD",e);
+                            }
                         }
                     }
                 }

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

@@ -84,7 +84,12 @@ public class AdqRetryReportServiceImpl implements IAdqRetryReportService {
         }
         if (!Check.isNull(hourList)) {
             adqReportMapper.addsHourList(hourList);
-            adqReportMapper.addsHourListSD(hourList);
+            try {
+                adqReportMapper.addsHourListSD(hourList);
+            }catch (Exception e) {
+                log.error("addsHourListSD",e);
+            }
+
         }
         if (hourList.size() >= 1000) {
             getCreativeHourRetry(errorId, advertiserId, accessToken, startDate, endDate, page + 1, isSend);
@@ -149,7 +154,12 @@ public class AdqRetryReportServiceImpl implements IAdqRetryReportService {
             }
             if (!Check.isNull(dailies)) {
                 adqReportMapper.addsDaily(dailies);
-                adqReportMapper.addsDailySD(dailies);
+                try {
+                    adqReportMapper.addsDailySD(dailies);
+                }catch (Exception e) {
+                    log.error("addsDailySD",e);
+                }
+
             }
             if (dailies.size() >= 1000) {
                 getCreativeDailyRetry(errorId, advertiserId, accessToken, startDate, endDate, page + 1, isSend);
@@ -215,7 +225,11 @@ public class AdqRetryReportServiceImpl implements IAdqRetryReportService {
             }
             if (!Check.isNull(hourList)) {
                 accountReportMapper.addAccountHourList(hourList);
-                accountReportMapper.addAccountHourListSD(hourList);
+                try {
+                    accountReportMapper.addAccountHourListSD(hourList);
+                }catch (Exception e){
+                    log.error("addAccountHourList",e);
+                }
             }
             if (hourList.size() >= 1000) {
                 getAccountHourRetry(errorId, advertiserId, accessToken, startDate, endDate, page + 1, isSend);
@@ -280,7 +294,11 @@ public class AdqRetryReportServiceImpl implements IAdqRetryReportService {
             }
             if (!Check.isNull(dailyList)) {
                 accountReportMapper.addAccountDailyList(dailyList);
-                accountReportMapper.addAccountDailyListSD(dailyList);
+                try {
+                    accountReportMapper.addAccountDailyListSD(dailyList);
+                }catch (Exception e){
+                    log.error("addAccountDailyListSD",e);
+                }
             }
             if (dailyList.size() >= 1000) {
                 getAccountDailyRetry(errorId, advertiserId, accessToken, startDate, endDate, page + 1, isSend);