Browse Source

报表定时任务添加睡眠

zhaoxian 3 years ago
parent
commit
efb43e0512
12 changed files with 52 additions and 2 deletions
  1. 1 1
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/IKuaishouAccountBudgetService.java
  2. 5 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/IKuaiShouCommentServiceImpl.java
  3. 1 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaiShouHistoryReportTaskServiceImpl.java
  4. 5 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaiShouReportDailyMaterialServiceImpl.java
  5. 2 1
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaishouAccountBudgetServiceImpl.java
  6. 15 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaishouInterfaceServiceImpl.java
  7. 5 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/EtlKuaiShouGroupDailyReportServiceImpl.java
  8. 1 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/KuaishouAudienceReportDailyServiceImpl.java
  9. 2 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/KuaishouGroupExploreServiceImpl.java
  10. 5 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/KuaishouReportDailyGroupServiceImpl.java
  11. 5 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/KuaishouReportDailyImageServiceImpl.java
  12. 5 0
      module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/KuaishouReportHourlyGroupServiceImpl.java

+ 1 - 1
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/IKuaishouAccountBudgetService.java

@@ -21,7 +21,7 @@ public interface IKuaishouAccountBudgetService extends IService<KuaishouAccountB
      * @param advertiserId
      * @param advertiserId
      * @param accessToken
      * @param accessToken
      */
      */
-    JSONObject getAccountBudget(CtopOauthToken oauthToken);
+    JSONObject getAccountBudget(CtopOauthToken oauthToken) throws InterruptedException;
 
 
     void insertAccountBudget(Long advertiserId, String accessToken);
     void insertAccountBudget(Long advertiserId, String accessToken);
 
 

+ 5 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/IKuaiShouCommentServiceImpl.java

@@ -146,6 +146,11 @@ public class IKuaiShouCommentServiceImpl implements IKuaiShouCommentService {
         params.put("advertiser_id", accountId);
         params.put("advertiser_id", accountId);
         params.put("shield_list", comments);
         params.put("shield_list", comments);
         String result = HttpUtils.httpPostRequest(url, params, header);
         String result = HttpUtils.httpPostRequest(url, params, header);
+        try {
+            Thread.sleep(500);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
         JSONObject resultJson = JSONObject.parseObject(result);
         JSONObject resultJson = JSONObject.parseObject(result);
         if (!Check.isNull(resultJson)) {
         if (!Check.isNull(resultJson)) {
             Integer code = resultJson.getInteger("code");
             Integer code = resultJson.getInteger("code");

+ 1 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaiShouHistoryReportTaskServiceImpl.java

@@ -101,6 +101,7 @@ public class KuaiShouHistoryReportTaskServiceImpl extends ServiceImpl<KuaiShouHi
                     param.put("task_params", taskParams);
                     param.put("task_params", taskParams);
 
 
                     String result = HttpUtils.kuaiShouhttpPostRequest(url, param.toJSONString(), headers);
                     String result = HttpUtils.kuaiShouhttpPostRequest(url, param.toJSONString(), headers);
+                    Thread.sleep(500);
                     JSONObject resultJson = JSONObject.parseObject(result);
                     JSONObject resultJson = JSONObject.parseObject(result);
                     if (!Check.isNull(resultJson)) {
                     if (!Check.isNull(resultJson)) {
                         Integer code = resultJson.getInteger("code");
                         Integer code = resultJson.getInteger("code");

+ 5 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaiShouReportDailyMaterialServiceImpl.java

@@ -66,6 +66,11 @@ public class KuaiShouReportDailyMaterialServiceImpl extends ServiceImpl<KuaiShou
         param.put("page_size", 2000);
         param.put("page_size", 2000);
         param.put("page", page);
         param.put("page", page);
         String result = HttpUtils.httpPostRequest(url, param, headers);
         String result = HttpUtils.httpPostRequest(url, param, headers);
+        try {
+            Thread.sleep(500);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
         JSONObject resultJson = JSONObject.parseObject(result);
         JSONObject resultJson = JSONObject.parseObject(result);
         if (Check.isNull(resultJson)) {
         if (Check.isNull(resultJson)) {
             return;
             return;

+ 2 - 1
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaishouAccountBudgetServiceImpl.java

@@ -86,7 +86,7 @@ public class KuaishouAccountBudgetServiceImpl extends ServiceImpl<KuaishouAccoun
     }
     }
 
 
     @Override
     @Override
-    public JSONObject getAccountBudget(CtopOauthToken oauthToken) {
+    public JSONObject getAccountBudget(CtopOauthToken oauthToken) throws InterruptedException {
         String url = PropertiesUtils.getConfig("kuaishou_api_url") + KuaishouInterfaceConstant.ACCOUNT_BUDGET;
         String url = PropertiesUtils.getConfig("kuaishou_api_url") + KuaishouInterfaceConstant.ACCOUNT_BUDGET;
         Map<String, String> headers = new HashMap<>();
         Map<String, String> headers = new HashMap<>();
         headers.put("Access-Token", oauthToken.getAccessToken());
         headers.put("Access-Token", oauthToken.getAccessToken());
@@ -94,6 +94,7 @@ public class KuaishouAccountBudgetServiceImpl extends ServiceImpl<KuaishouAccoun
         JSONObject json = new JSONObject();
         JSONObject json = new JSONObject();
         json.put("advertiser_id", oauthToken.getAccountId());
         json.put("advertiser_id", oauthToken.getAccountId());
         String result = HttpUtils.kuaiShouhttpPostRequest(url, json.toJSONString(), headers);
         String result = HttpUtils.kuaiShouhttpPostRequest(url, json.toJSONString(), headers);
+        Thread.sleep(500);
         JSONObject resultJson = JSONObject.parseObject(result);
         JSONObject resultJson = JSONObject.parseObject(result);
         if (!Check.isNull(resultJson)) {
         if (!Check.isNull(resultJson)) {
             Integer code = resultJson.getInteger("code");
             Integer code = resultJson.getInteger("code");

+ 15 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaishouInterfaceServiceImpl.java

@@ -210,6 +210,11 @@ public class KuaishouInterfaceServiceImpl implements IKuaishouInterfaceService {
         param.put("page_size", 2000);
         param.put("page_size", 2000);
         param.put("page", page);
         param.put("page", page);
         String result = HttpUtils.httpPostRequest(url, param, headers);
         String result = HttpUtils.httpPostRequest(url, param, headers);
+        try {
+            Thread.sleep(500);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
         JSONObject resultJson = JSONObject.parseObject(result);
         JSONObject resultJson = JSONObject.parseObject(result);
         Integer code = resultJson.getInteger("code");
         Integer code = resultJson.getInteger("code");
         String message = resultJson.getString("message");
         String message = resultJson.getString("message");
@@ -384,6 +389,11 @@ public class KuaishouInterfaceServiceImpl implements IKuaishouInterfaceService {
         param.put("page_size", 2000);
         param.put("page_size", 2000);
         param.put("page", page);
         param.put("page", page);
         String result = HttpUtils.httpPostRequest(url, param, headers);
         String result = HttpUtils.httpPostRequest(url, param, headers);
+        try {
+            Thread.sleep(500);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
         JSONObject resultJson = JSONObject.parseObject(result);
         JSONObject resultJson = JSONObject.parseObject(result);
         Integer code = resultJson.getInteger("code");
         Integer code = resultJson.getInteger("code");
         String message = resultJson.getString("message");
         String message = resultJson.getString("message");
@@ -441,6 +451,11 @@ public class KuaishouInterfaceServiceImpl implements IKuaishouInterfaceService {
         param.put("page", page);
         param.put("page", page);
 
 
         String result = HttpUtils.httpPostRequest(url, param, headers);
         String result = HttpUtils.httpPostRequest(url, param, headers);
+        try {
+            Thread.sleep(500);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
         JSONObject resultJson = JSONObject.parseObject(result);
         JSONObject resultJson = JSONObject.parseObject(result);
         Integer code = resultJson.getInteger("code");
         Integer code = resultJson.getInteger("code");
         String message = resultJson.getString("message");
         String message = resultJson.getString("message");

+ 5 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/EtlKuaiShouGroupDailyReportServiceImpl.java

@@ -58,6 +58,11 @@ public class EtlKuaiShouGroupDailyReportServiceImpl extends ServiceImpl<EtlKuaiS
         param.put("page_size", 2000);
         param.put("page_size", 2000);
         param.put("page", page);
         param.put("page", page);
         String result = HttpUtils.httpPostRequest(url, param, headers);
         String result = HttpUtils.httpPostRequest(url, param, headers);
+        try {
+            Thread.sleep(500);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
         JSONObject resultJson = JSONObject.parseObject(result);
         JSONObject resultJson = JSONObject.parseObject(result);
         Integer code = resultJson.getInteger("code");
         Integer code = resultJson.getInteger("code");
         String message = resultJson.getString("message");
         String message = resultJson.getString("message");

+ 1 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/KuaishouAudienceReportDailyServiceImpl.java

@@ -124,6 +124,7 @@ public class KuaishouAudienceReportDailyServiceImpl extends ServiceImpl<Kuaishou
                 requestJson.put("unit_ids", units);
                 requestJson.put("unit_ids", units);
             }
             }
             String result = HttpUtils.kuaiShouhttpPostRequest(url, requestJson.toJSONString(), headers);
             String result = HttpUtils.kuaiShouhttpPostRequest(url, requestJson.toJSONString(), headers);
+            Thread.sleep(500);
             JSONObject resultJson = JSONObject.parseObject(result);
             JSONObject resultJson = JSONObject.parseObject(result);
             if (!Check.isNull(resultJson)) {
             if (!Check.isNull(resultJson)) {
                 Integer code = resultJson.getInteger("code");
                 Integer code = resultJson.getInteger("code");

+ 2 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/KuaishouGroupExploreServiceImpl.java

@@ -71,6 +71,7 @@ public class KuaishouGroupExploreServiceImpl extends ServiceImpl<KuaishouGroupEx
             params.put("advertiser_id", accountId);
             params.put("advertiser_id", accountId);
             params.put("unit_id", unitId);
             params.put("unit_id", unitId);
             String result = HttpUtils.httpPostRequest(url, params, header);
             String result = HttpUtils.httpPostRequest(url, params, header);
+            Thread.sleep(500);
             JSONObject resultJson = JSONObject.parseObject(result);
             JSONObject resultJson = JSONObject.parseObject(result);
             if (!Check.isNull(resultJson)) {
             if (!Check.isNull(resultJson)) {
                 Integer code = resultJson.getInteger("code");
                 Integer code = resultJson.getInteger("code");
@@ -201,6 +202,7 @@ public class KuaishouGroupExploreServiceImpl extends ServiceImpl<KuaishouGroupEx
             params.put("advertiser_id", accountId);
             params.put("advertiser_id", accountId);
             params.put("unit_id", unitId);
             params.put("unit_id", unitId);
             String result = HttpUtils.httpPostRequest(url, params, header);
             String result = HttpUtils.httpPostRequest(url, params, header);
+            Thread.sleep(500);
             JSONObject resultJson = JSONObject.parseObject(result);
             JSONObject resultJson = JSONObject.parseObject(result);
             if (!Check.isNull(resultJson)) {
             if (!Check.isNull(resultJson)) {
                 Integer code = resultJson.getInteger("code");
                 Integer code = resultJson.getInteger("code");

+ 5 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/KuaishouReportDailyGroupServiceImpl.java

@@ -55,6 +55,11 @@ public class KuaishouReportDailyGroupServiceImpl extends ServiceImpl<KuaishouRep
         param.put("page_size", 2000);
         param.put("page_size", 2000);
         param.put("page", page);
         param.put("page", page);
         String result = HttpUtils.httpPostRequest(url, param, headers);
         String result = HttpUtils.httpPostRequest(url, param, headers);
+        try {
+            Thread.sleep(500);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
         JSONObject resultJson = JSONObject.parseObject(result);
         JSONObject resultJson = JSONObject.parseObject(result);
         Integer code = resultJson.getInteger("code");
         Integer code = resultJson.getInteger("code");
         String message = resultJson.getString("message");
         String message = resultJson.getString("message");

+ 5 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/KuaishouReportDailyImageServiceImpl.java

@@ -51,6 +51,11 @@ public class KuaishouReportDailyImageServiceImpl extends ServiceImpl<KuaishouRep
         param.put("page", page);
         param.put("page", page);
 
 
         JSONObject resultJson = JSONObject.parseObject(HttpUtils.kuaiShouhttpPostRequest("https://ad.e.kuaishou.com/rest/openapi/v1/report/material_report", param.toJSONString(), headers));
         JSONObject resultJson = JSONObject.parseObject(HttpUtils.kuaiShouhttpPostRequest("https://ad.e.kuaishou.com/rest/openapi/v1/report/material_report", param.toJSONString(), headers));
+        try {
+            Thread.sleep(500);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
         if (Check.isNull(resultJson)) {
         if (Check.isNull(resultJson)) {
             log.error("获取素材图片报表返回结果为空,advertiserId:{}", accountId);
             log.error("获取素材图片报表返回结果为空,advertiserId:{}", accountId);
             return;
             return;

+ 5 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/report/service/impl/KuaishouReportHourlyGroupServiceImpl.java

@@ -42,6 +42,11 @@ public class KuaishouReportHourlyGroupServiceImpl extends ServiceImpl<KuaishouRe
         param.put("page", page);
         param.put("page", page);
 
 
         String result = HttpUtils.httpPostRequest(url, param, headers);
         String result = HttpUtils.httpPostRequest(url, param, headers);
+        try {
+            Thread.sleep(500);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
         JSONObject resultJson = JSONObject.parseObject(result);
         JSONObject resultJson = JSONObject.parseObject(result);
         Integer code = resultJson.getInteger("code");
         Integer code = resultJson.getInteger("code");
         String message = resultJson.getString("message");
         String message = resultJson.getString("message");