Pārlūkot izejas kodu

adq定时任务

yumeng 15 stundas atpakaļ
vecāks
revīzija
55d3a3e48c

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

@@ -24,6 +24,7 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
     private AdqErrorLogMapper adqErrorLogMapper;
     @Autowired
     private AdqAccountReportMapper accountReportMapper;
+    private String urlPath = "http://192.168.0.85:8765/webhook/adq_advertiser_report";
 
 
     @Override
@@ -91,6 +92,12 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
                 getAdqAccountHour(advertiserId, accessToken, startDate, endDate, page + 1, isLog);
             } else {
                 log.info("请求账户时报完成,account_id:{},日期:{}", advertiserId, startDate);
+                JSONObject param = new JSONObject();
+                param.put("advertiser_id", advertiserId);
+                param.put("start_date", startDate.replace("-", ""));
+                param.put("end_date", endDate.replace("-", ""));
+                param.put("date_type", "hourly");
+                HttpUtils.httpPostRequest(urlPath, param, null);
             }
         } catch (Exception e) {
             e.printStackTrace();
@@ -161,6 +168,12 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
                 getAdqAccountHour(advertiserId, accessToken, startDate, endDate, page + 1, isLog);
             } else {
                 log.info("请求账户日报完成,account_id:{},开始日期:{},开始日期:{}", advertiserId, startDate, endDate);
+                JSONObject param = new JSONObject();
+                param.put("advertiser_id", advertiserId);
+                param.put("start_date", startDate.replace("-", ""));
+                param.put("end_date", endDate.replace("-", ""));
+                param.put("date_type", "daily");
+                HttpUtils.httpPostRequest(urlPath, param, null);
             }
         } catch (Exception e) {
             e.printStackTrace();