Parcourir la source

adq-账户报表

yumeng il y a 1 an
Parent
commit
96ebfc879a

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

@@ -53,7 +53,6 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
             paramsMap.put("group_by", group_by);
             JSONArray fieldsList = FieldsConfig.getAccountHourFieldsList();
             paramsMap.put("fields", fieldsList);
-            Integer totalNumber = 0;
             List<AdqAdvertiserReportHour> hourList = new ArrayList<>();
             String s = HttpUtils.httpGet("https://api.e.qq.com/v3.0/hourly_reports/get", paramsMap, null);
             JSONObject jsonObject = JSONObject.parseObject(s);
@@ -62,10 +61,7 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
                 if (code == 0) {
                     JSONObject data = jsonObject.getJSONObject("data");
                     if (!Check.isNull(data)) {
-                        JSONObject pageInfo = data.getJSONObject("page_info");
-                        if (!Check.isNull(pageInfo)) {
-                            totalNumber = pageInfo.getInteger("total_number");
-                        }
+
                         JSONArray list = data.getJSONArray("list");
                         if (!Check.isNull(list)) {
                             for (int i = 0; i < list.size(); i++) {
@@ -94,7 +90,7 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
             if (!Check.isNull(hourList)) {
                 accountReportMapper.addAccountHourList(hourList);
             }
-            if (totalNumber >= 1000) {
+            if (hourList.size() >= 1000) {
                 getAdqAccountHour(advertiserId, accessToken, startDate, endDate, page + 1, isLog);
             } else {
                 log.error("请求账户时报完成,account_id:{},日期:{}", advertiserId, startDate);
@@ -125,7 +121,6 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
             paramsMap.put("group_by", group_by);
             JSONArray fieldsList = FieldsConfig.getAccountDailyFieldsList();
             paramsMap.put("fields", fieldsList);
-            Integer totalNumber = 0;
             List<AdqAdvertiserReportDaily> dailyList = new ArrayList<>();
             String s = HttpUtils.httpGet("https://api.e.qq.com/v3.0/daily_reports/get", paramsMap, null);
             JSONObject jsonObject = JSONObject.parseObject(s);
@@ -134,10 +129,7 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
                 if (code == 0) {
                     JSONObject data = jsonObject.getJSONObject("data");
                     if (!Check.isNull(data)) {
-                        JSONObject pageInfo = data.getJSONObject("page_info");
-                        if (!Check.isNull(pageInfo)) {
-                            totalNumber = pageInfo.getInteger("total_number");
-                        }
+
                         JSONArray list = data.getJSONArray("list");
                         if (!Check.isNull(list)) {
                             for (int i = 0; i < list.size(); i++) {
@@ -166,7 +158,7 @@ public class AdqAccountReportServiceImpl implements IAdqAccountReportService {
             if (!Check.isNull(dailyList)) {
                 accountReportMapper.addAccountDailyList(dailyList);
             }
-            if (totalNumber >= 1000) {
+            if (dailyList.size() >= 1000) {
                 getAdqAccountHour(advertiserId, accessToken, startDate, endDate, page + 1, isLog);
             } else {
                 log.error("请求账户日报完成,account_id:{},日期:{}", advertiserId, startDate);

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

@@ -54,7 +54,6 @@ public class AdqCreativeCreativeReportServiceImpl implements IAdqCreativeReportS
             paramsMap.put("group_by", group_by);
             JSONArray fieldsList = FieldsConfig.getCreativeHourFieldsList();
             paramsMap.put("fields", fieldsList);
-            Integer totalNumber = 0;
             List<AdqCreativeReportHour> hourList = new ArrayList<>();
             String s = HttpUtils.httpGet("https://api.e.qq.com/v3.0/hourly_reports/get", paramsMap, null);
             JSONObject jsonObject = JSONObject.parseObject(s);
@@ -63,10 +62,6 @@ public class AdqCreativeCreativeReportServiceImpl implements IAdqCreativeReportS
                 if (code == 0) {
                     JSONObject data = jsonObject.getJSONObject("data");
                     if (!Check.isNull(data)) {
-                        JSONObject pageInfo = data.getJSONObject("page_info");
-                        if (!Check.isNull(pageInfo)) {
-                            totalNumber = pageInfo.getInteger("total_number");
-                        }
                         JSONArray list = data.getJSONArray("list");
                         if (!Check.isNull(list)) {
                             for (int i = 0; i < list.size(); i++) {
@@ -95,7 +90,7 @@ public class AdqCreativeCreativeReportServiceImpl implements IAdqCreativeReportS
             if (!Check.isNull(hourList)) {
                 adqReportMapper.addsHourList(hourList);
             }
-            if (totalNumber >= 1000) {
+            if (hourList.size() >= 1000) {
                 getAdqCreativeHour(advertiserId, accessToken, startDate, endDate, page + 1, isLog);
             } else {
                 log.error("请求创意时报完成,account_id:{},日期:{}", advertiserId, startDate);
@@ -134,7 +129,6 @@ public class AdqCreativeCreativeReportServiceImpl implements IAdqCreativeReportS
             paramsMap.put("group_by", group_by);
             JSONArray fieldsList = FieldsConfig.getCreativeDailyFieldsList();
             paramsMap.put("fields", fieldsList);
-            Integer totalNumber = 0;
             List<AdqCreativeReportDaily> dailies = new ArrayList<>();
             String s = HttpUtils.httpGet("https://api.e.qq.com/v3.0/daily_reports/get", paramsMap, null);
             JSONObject jsonObject = JSONObject.parseObject(s);
@@ -143,10 +137,6 @@ public class AdqCreativeCreativeReportServiceImpl implements IAdqCreativeReportS
                 if (code == 0) {
                     JSONObject data = jsonObject.getJSONObject("data");
                     if (!Check.isNull(data)) {
-                        JSONObject pageInfo = data.getJSONObject("page_info");
-                        if (!Check.isNull(pageInfo)) {
-                            totalNumber = pageInfo.getInteger("total_number");
-                        }
                         JSONArray list = data.getJSONArray("list");
                         if (!Check.isNull(list)) {
                             for (int i = 0; i < list.size(); i++) {
@@ -175,7 +165,7 @@ public class AdqCreativeCreativeReportServiceImpl implements IAdqCreativeReportS
             if (!Check.isNull(dailies)) {
                 adqReportMapper.addsDaily(dailies);
             }
-            if (totalNumber >= 1000) {
+            if (dailies.size() >= 1000) {
                 getAdqCreativeDaily(advertiserId, accessToken, startDate, endDate, page + 1, isLog);
             } else {
                 log.error("请求创意日报完成,account_id:{},日期:{}", advertiserId, startDate);

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

@@ -53,7 +53,6 @@ public class AdqRetryReportServiceImpl implements IAdqRetryReportService {
         paramsMap.put("group_by", group_by);
         JSONArray fieldsList = FieldsConfig.getCreativeHourFieldsList();
         paramsMap.put("fields", fieldsList);
-        Integer totalNumber = 0;
         List<AdqCreativeReportHour> hourList = new ArrayList<>();
         String s = HttpUtils.httpGet("https://api.e.qq.com/v3.0/hourly_reports/get", paramsMap, null);
         JSONObject jsonObject = JSONObject.parseObject(s);
@@ -62,10 +61,7 @@ public class AdqRetryReportServiceImpl implements IAdqRetryReportService {
             if (code == 0) {
                 JSONObject data = jsonObject.getJSONObject("data");
                 if (!Check.isNull(data)) {
-                    JSONObject pageInfo = data.getJSONObject("page_info");
-                    if (!Check.isNull(pageInfo)) {
-                        totalNumber = pageInfo.getInteger("total_number");
-                    }
+
                     JSONArray list = data.getJSONArray("list");
                     if (!Check.isNull(list)) {
                         for (int i = 0; i < list.size(); i++) {
@@ -85,7 +81,7 @@ public class AdqRetryReportServiceImpl implements IAdqRetryReportService {
         if (!Check.isNull(hourList)) {
             adqReportMapper.addsHourList(hourList);
         }
-        if (totalNumber >= 1000) {
+        if (hourList.size() >= 1000) {
             getCreativeHourRetry(errorId, advertiserId, accessToken, startDate, endDate, page + 1, isSend);
         } else {
             log.error("请求创意时报完成,account_id:{},日期:{}", advertiserId, startDate);
@@ -120,7 +116,6 @@ public class AdqRetryReportServiceImpl implements IAdqRetryReportService {
             paramsMap.put("group_by", group_by);
             JSONArray fieldsList = FieldsConfig.getCreativeDailyFieldsList();
             paramsMap.put("fields", fieldsList);
-            Integer totalNumber = 0;
             List<AdqCreativeReportDaily> dailies = new ArrayList<>();
             String s = HttpUtils.httpGet("https://api.e.qq.com/v3.0/daily_reports/get", paramsMap, null);
             JSONObject jsonObject = JSONObject.parseObject(s);
@@ -129,10 +124,6 @@ public class AdqRetryReportServiceImpl implements IAdqRetryReportService {
                 if (code == 0) {
                     JSONObject data = jsonObject.getJSONObject("data");
                     if (!Check.isNull(data)) {
-                        JSONObject pageInfo = data.getJSONObject("page_info");
-                        if (!Check.isNull(pageInfo)) {
-                            totalNumber = pageInfo.getInteger("total_number");
-                        }
                         JSONArray list = data.getJSONArray("list");
                         if (!Check.isNull(list)) {
                             for (int i = 0; i < list.size(); i++) {
@@ -152,7 +143,7 @@ public class AdqRetryReportServiceImpl implements IAdqRetryReportService {
             if (!Check.isNull(dailies)) {
                 adqReportMapper.addsDaily(dailies);
             }
-            if (totalNumber >= 1000) {
+            if (dailies.size() >= 1000) {
                 getCreativeDailyRetry(errorId, advertiserId, accessToken, startDate, endDate, page + 1, isSend);
             } else {
                 log.error("请求创意日报完成,account_id:{},日期:{}", advertiserId, startDate);