Просмотр исходного кода

定制代码——获取年龄人群月数据

zhaoxian 4 лет назад
Родитель
Сommit
7d294d3edc

+ 18 - 19
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyAudienceReportJob.java

@@ -95,27 +95,27 @@ public class KuaishouDailyAudienceReportJob {
             String dat = DateUtils.getLastDay(DateUtils.date2Str(), i);
             dates.add(dat);
         }
-        List<CtopOauthToken> tokens = tokenService.selectKuaiShouToken();
+//        List<CtopOauthToken> tokens = tokenService.selectKuaiShouToken();
         //筛选出有效账户,获取该账户的组级人群报表数据
-        List<CtopOauthToken> activeTokens = new ArrayList<>();
-        List<Long> accountIds = new ArrayList<>();
-        accountIds.add(9556344L);
-        accountIds.add(9743727L);
-        accountIds.add(9743738L);
-        accountIds.add(9812668L);
-        accountIds.add(9901966L);
-        accountIds.add(9767034L);
-        for (Long accountId : accountIds) {
-            for (CtopOauthToken token : tokens) {
-                if (token.getAccountId() - accountId == 0) {
-                    activeTokens.add(token);
-                }
-            }
-        }
+//        List<CtopOauthToken> activeTokens = new ArrayList<>();
+//        List<Long> accountIds = new ArrayList<>();
+//        accountIds.add(9556344L);
+//        accountIds.add(9743727L);
+//        accountIds.add(9743738L);
+//        accountIds.add(9901966L);
+//        accountIds.add(9767034L);
+//        accountIds.add(9812668L);
+//        for (Long accountId : accountIds) {
+//            for (CtopOauthToken token : tokens) {
+//                if (token.getAccountId() - accountId == 0) {
+//                    activeTokens.add(token);
+//                }
+//            }
+//        }
 
+        CtopOauthToken token = tokenService.getTokenByAccountId(9556344L);
         int page = 1;
         int pageSize = 2000;
-        for (CtopOauthToken token : activeTokens) {
             List<KuaiShouGroup> kuaiShouGroups = kuaiShouGroupService.queryUnitInfoByAccountId(token.getAccountId());
             dates.forEach(date -> executorService.submit(() -> {
                 getAudienceReportData(kuaiShouGroups, token, date, "ageSegment", page, pageSize);
@@ -125,14 +125,13 @@ public class KuaishouDailyAudienceReportJob {
                 //            getAudienceReportData(token, date, "clientId", page, pageSize);
                 //            getAudienceReportData(token, date, "province", page, pageSize);
             }));
-        }
     }
 
     private void getAudienceReportData(List<KuaiShouGroup> kuaiShouGroups, CtopOauthToken token, String date, String type, Integer page, Integer pageSize) {
         try {
             for (KuaiShouGroup kuaiShouGroup : kuaiShouGroups) {
                 kuaishouAudienceReportDailyService.crowdAnalysisReport(token, date, type, kuaiShouGroup.getCampaignId(), kuaiShouGroup.getUnitId(), page, pageSize);
-                Thread.sleep(600);
+                Thread.sleep(500);
             }
         } catch (Exception e) {
             XxlJobHelper.log("定时获取人群分析报表数据异常", e);