Ver Fonte

adq定时任务

yumeng há 15 horas atrás
pai
commit
b35655f0e2

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

@@ -73,15 +73,6 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
                     }
                 } else {
                     log.error("请求账户时报失败,account_id:{},返回信息:{}", advertiserId, jsonObject);
-                    if (isLog == 1) {
-                        AdqErrorLog errorInfo = new AdqErrorLog();
-                        errorInfo.setAdvertiserId(advertiserId);
-                        errorInfo.setStartDate(startDate);
-                        errorInfo.setEndDate(endDate);
-                        errorInfo.setDataDimension("account");
-                        errorInfo.setDataType("hour");
-                        adqErrorLogMapper.replaceErrorInfo(errorInfo);
-                    }
                     return;
                 }
             }
@@ -98,6 +89,7 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
                 param.put("end_date", endDate.replace("-", ""));
                 param.put("date_type", "hourly");
                 HttpUtils.httpPostRequest(urlPath, param, null);
+                log.info("请求数据清洗任务完成,account_id:{},startDate:{},endDate:{},date_type:{}", advertiserId, startDate, endDate, "hourly");
             }
         } catch (Exception e) {
             e.printStackTrace();
@@ -149,15 +141,6 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
                     }
                 } else {
                     log.error("请求账户日报失败,account_id:{},返回信息:{}", advertiserId, jsonObject);
-                    if (isLog == 1) {
-                        AdqErrorLog errorInfo = new AdqErrorLog();
-                        errorInfo.setAdvertiserId(advertiserId);
-                        errorInfo.setStartDate(startDate);
-                        errorInfo.setEndDate(endDate);
-                        errorInfo.setDataDimension("account");
-                        errorInfo.setDataType("daily");
-                        adqErrorLogMapper.replaceErrorInfo(errorInfo);
-                    }
                     return;
                 }
             }
@@ -174,6 +157,7 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
                 param.put("end_date", endDate.replace("-", ""));
                 param.put("date_type", "daily");
                 HttpUtils.httpPostRequest(urlPath, param, null);
+                log.info("请求数据清洗任务完成,account_id:{},startDate:{},endDate:{},date_type:{}", advertiserId, startDate, endDate, "daily");
             }
         } catch (Exception e) {
             e.printStackTrace();