소스 검색

代理商数据

yumeng 1 년 전
부모
커밋
86dd996775

+ 9 - 28
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/controller/BytedanceController.java

@@ -226,37 +226,18 @@ public class BytedanceController {
     @GetMapping(value = "/getReports")
     public void getReports() {
         List<JSONObject> tokens = tokenService.getAgentTokens();
-        //获取两个时间的每一天
-        List<String> perDay = DateUtils.getPerDay("2024-06-01", "2024-06-25");
-        for (String date : perDay) {
-            for (JSONObject obj : tokens) {
-                dailyExecutorService.submit(
-                        new Runnable() {
-                            @Override
-                            public void run() {
-                                advertiserDataService.getAgentReport(obj, date, date);
-                            }
-                        });
-            }
-//        String nowDate = DateUtils.getNowDate("yyyy-MM-dd");
-//        String yesterda = DateUtils.getAnotherDay("yyyy-MM-dd", nowDate, -1);
-//        String yesterda2 = DateUtils.getAnotherDay("yyyy-MM-dd", nowDate, -2);
-//        String yesterda3 = DateUtils.getAnotherDay("yyyy-MM-dd", nowDate, -3);
-//        for (JSONObject obj : tokens) {
-//            advertiserDataService.getAgentReport(obj, yesterda, yesterda);
-      /*      advertiserDataService.getAgentReport(obj, yesterda2, yesterda2);
+        String nowDate = DateUtils.getNowDate("yyyy-MM-dd");
+        String yesterda = DateUtils.getAnotherDay("yyyy-MM-dd", nowDate, -1);
+      /*  String yesterda2 = DateUtils.getAnotherDay("yyyy-MM-dd", nowDate, -2);
+        String yesterda3 = DateUtils.getAnotherDay("yyyy-MM-dd", nowDate, -3);*/
+        for (JSONObject obj : tokens) {
+            advertiserDataService.getAgentReport(obj, yesterda, yesterda);
+          /*  advertiserDataService.getAgentReport(obj, yesterda2, yesterda2);
             advertiserDataService.getAgentReport(obj, yesterda3, yesterda3);*/
-        String param = "1757332980444167";
-        String token = tokenService.getByAccountId(Long.valueOf(param));
-        if (Check.isNull(token)) {
-            log.error("此账户未获取到相关token,accountId:{}", param);
-            return;
+
         }
-        OauthToken oauthToken = new OauthToken();
-        oauthToken.setAccessToken(token);
-        oauthToken.setAccountId(Long.parseLong(param));
 
         }
-    }
+
 
 }

+ 1 - 0
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/ByteDanceAdvertiserDataServiceImpl.java

@@ -688,6 +688,7 @@ public class ByteDanceAdvertiserDataServiceImpl implements IByteDanceAdvertiserD
                     }
                     if (dailyList.size() > 0) {
                         bytedanceAgentReportDailyMapper.insert(dailyList);
+                        log.info("头条代理商信息入库完成,数据量:{}", dailyList.size());
                     }
                 } catch (Exception e) {
                     e.printStackTrace();

+ 0 - 2
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceFundJob.java

@@ -1,11 +1,9 @@
 package cn.com.ctop.job.bytedance.handler;
 
-import cn.com.ctop.job.bytedance.data.constant.CtopAdConstant;
 import cn.com.ctop.job.bytedance.data.entity.OauthToken;
 import cn.com.ctop.job.bytedance.data.service.IBytedanceFundService;
 import cn.com.ctop.job.bytedance.data.service.IOauthTokenService;
 import cn.com.ctop.job.bytedance.data.utils.Check;
-import cn.com.ctop.job.bytedance.data.utils.DateUtils;
 import com.xxl.job.core.context.XxlJobHelper;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import lombok.extern.slf4j.Slf4j;