Ver código fonte

头条定时任务梳理

yangzian 3 anos atrás
pai
commit
58e204ebb4
43 arquivos alterados com 178 adições e 6 exclusões
  1. 2 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BaseReportVideoDailyLoadJob.java
  2. 2 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ByteDanceCheckAccountMonitoringLinkJob.java
  3. 1 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ByteDanceCleanMaterialJob.java
  4. 4 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ByteDanceHourlyAccountWarningLoadJob.java
  5. 5 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ByteDancePlanRuleDataJob.java
  6. 12 4
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ByteDanceRefreshTokenJob.java
  7. 1 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ByteDanceVideoReportJob.java
  8. 1 1
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceAccountBidJob.java
  9. 4 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceAdvertiserDailyReportLoadJob.java
  10. 5 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceAdvertiserHourlyReportLoadJob.java
  11. 4 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceAdvertisingDataLoadJob.java
  12. 5 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceAiCreateJob.java
  13. 4 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceCampaignDailyReportLoadJob.java
  14. 4 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceCampaignHourlyReportLoadJob.java
  15. 10 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceCheckAccountReportJob.java
  16. 5 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceCreativeDailyReportLoadJob.java
  17. 5 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceCreativeHourlyReportLoadJob.java
  18. 5 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceDailyMaterialReportJob.java
  19. 1 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceDailyMaterialReportRetryJob.java
  20. 4 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceDailyPlayableReportJob.java
  21. 4 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceDailyPlayableReportRetryJob.java
  22. 27 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceEtlVideoJob.java
  23. 5 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceFlowFundJob.java
  24. 4 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceMaterialsLoadJob.java
  25. 4 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceMonitoringLinksCheckJob.java
  26. 4 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedancePlanDailyReportLoadJob.java
  27. 3 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedancePlanHourlyReportLoadJob.java
  28. 5 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedancePlanLoadJob.java
  29. 1 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedancePlanRealTimeLoadJob.java
  30. 5 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceRejectReasonJob.java
  31. 5 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceSameDayCreativeLoadJob.java
  32. 4 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceTodayPlaneLoadJob.java
  33. 2 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceVideoDailyReportLoadJob.java
  34. 1 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceVideoETLReportReloadJob.java
  35. 1 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceVideoInfoLoadJob.java
  36. 4 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceVideoReportCleanJob.java
  37. 2 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceYesterdayAdvertiserHourlyLoadJob.java
  38. 1 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/CheckDataStateJob.java
  39. 4 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ETLReportDesignJob.java
  40. 1 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ETLReportVideoCleanJob.java
  41. 5 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/RuleDataAccountCleanJob.java
  42. 1 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/SendDailyUReportJob.java
  43. 1 1
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/SendHourlyMessageJob.java

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

@@ -24,6 +24,8 @@ public class BaseReportVideoDailyLoadJob {
     IBytedanceVideoReportService bytedanceVideoReportService;
     private ExecutorService executorService = Executors.newFixedThreadPool(10);
     private CountDownLatch countDownLatch;
+
+    //TODO 待删除
     @XxlJob("baseReportVideoDailyLoadJob")
     public void execute() throws Exception {
         List<CtopOauthToken> tokens = oauthTokenService.selectToutiaoToken();

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

@@ -30,6 +30,8 @@ public class ByteDanceCheckAccountMonitoringLinkJob {
     @Autowired
     private ICtopOauthTokenService oauthTokenService;
 
+
+    //TODO 待删除
     @XxlJob("byteDanceCheckAccountMonitoringLinkJob")
     public void execute() throws Exception{
 

+ 1 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ByteDanceCleanMaterialJob.java

@@ -22,6 +22,7 @@ public class ByteDanceCleanMaterialJob {
     private IBytedanceCreativeDailyReportService creativeDailyReportService;
     static ExecutorService executorService = Executors.newFixedThreadPool(3);
 
+    //TODO 待删除
     @XxlJob("byteDanceCleanMaterial")
     public void execute() throws Exception {
         List<String> signatureList = creativeDailyReportService.getSignatureList();

+ 4 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ByteDanceHourlyAccountWarningLoadJob.java

@@ -26,6 +26,10 @@ public class ByteDanceHourlyAccountWarningLoadJob {
     private IByteDanceHourlyAccountWarningService byteDanceHourlyAccountWarningService;
     static ExecutorService executorService = Executors.newFixedThreadPool(3);
 
+    /**
+     * 头条时段消耗预警
+     * @throws Exception
+     */
     @XxlJob("byteDanceHourlyAccountWarning")
     public void execute() throws Exception {
         XxlJobHelper.log("开始时段消耗预警定时任务");

+ 5 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ByteDancePlanRuleDataJob.java

@@ -31,6 +31,11 @@ public class ByteDancePlanRuleDataJob {
     @Autowired
     private IRuleDataTargetService ruleDataTargetService;
     private ExecutorService executorService = Executors.newFixedThreadPool(10);
+
+    /**
+     * 规则引擎计划数据任务
+     * @throws Exception
+     */
     @XxlJob("bytedancePlanRuleLoadJob")
     public void execute() throws Exception {
         Date date = new Date();

+ 12 - 4
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ByteDanceRefreshTokenJob.java

@@ -29,6 +29,10 @@ public class ByteDanceRefreshTokenJob {
     @Autowired
     private IUserAllocationService userAllocationService;
 
+    /**
+     * 刷新账户名称
+     * @throws Exception
+     */
     @XxlJob("refreshAuthName")
     public void refreshAuthName() throws Exception {
         List<UserAllocation> userAllocationList = userAllocationService.listByMediaId(null,0);
@@ -39,12 +43,16 @@ public class ByteDanceRefreshTokenJob {
             });
         }
     }
+
+
     /**
-     * 刷新token
-     * @throws Exception
+     * 刷新token  千川
+     * 待上线
      */
-    @XxlJob("qianChuanRefreshTokenJob")
+   /* @XxlJob("qianChuanRefreshTokenJob")
     public void qianChuanRefresh() throws Exception {
         refreshTokenService.qianChuanRefresh(null);
-    }
+    }*/
+
+
 }

+ 1 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ByteDanceVideoReportJob.java

@@ -19,6 +19,7 @@ public class ByteDanceVideoReportJob {
     @Autowired
     private IByteDanceVideoReportDailyService byteDanceVideoReportDailyService;
 
+    // TODO 待删除
     @XxlJob("byteDanceVideoReport")
     public void execute() throws Exception {
         String getDate2 = DateUtils.formatDate(DateUtils.addDay(new Date(), -2));

+ 1 - 1
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceAccountBidJob.java

@@ -12,7 +12,7 @@ public class BytedanceAccountBidJob {
     private IBytedanceBidWarningService bidWarningService;
 
     /**
-     * 出价预警
+     * 头条出价预警
      */
     @XxlJob("bytedanceAccountBidJob")
     public void execute() throws Exception {

+ 4 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceAdvertiserDailyReportLoadJob.java

@@ -29,6 +29,10 @@ public class BytedanceAdvertiserDailyReportLoadJob {
     private IReportService reportService;
     static ExecutorService executorService = Executors.newFixedThreadPool(5);;
 
+    /**
+     * 头条广告主日报
+     * @throws Exception
+     */
     @XxlJob("bytedanceAdvertiserDailyReport")
     public void execute() throws Exception {
         XxlJobHelper.log("头条广告主日报获取任务执行开始");

+ 5 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceAdvertiserHourlyReportLoadJob.java

@@ -26,6 +26,11 @@ public class BytedanceAdvertiserHourlyReportLoadJob {
     @Autowired
     private IReportService reportService;
     static ExecutorService executorService = Executors.newFixedThreadPool(4);
+
+    /**
+     * 头条广告主时报
+     * @throws Exception
+     */
     @XxlJob("bytedanceAdvertiserHourlyReport")
     public void execute() throws Exception {
         XxlJobHelper.log("头条时报数据获取开始");

+ 4 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceAdvertisingDataLoadJob.java

@@ -32,6 +32,10 @@ public class BytedanceAdvertisingDataLoadJob {
     @Autowired
     private IByteDanceCreativeService creativeService;
 
+    /**
+     * 组、计划、创意
+     * @throws Exception
+     */
     @XxlJob("bytedanceAdvertisingData")
     public void execute() throws Exception {
         Date getDate = new Date();

+ 5 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceAiCreateJob.java

@@ -10,6 +10,11 @@ import java.util.Date;
 @Component
 public class BytedanceAiCreateJob {
     private static final String URLPREFIX = "http://118.24.244.213:8080/bytedance-api/advertiser/aiBytedanceAdvertiserStrategy/autoCreateCreative?hour=";
+
+    /**
+     * 头条自动投放创建任务
+     * @throws Exception
+     */
     @XxlJob("bytedanceAutoCreateJob")
     public void execute() throws Exception {
         String hour = DateUtils.getNowHour(new Date());

+ 4 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceCampaignDailyReportLoadJob.java

@@ -24,6 +24,10 @@ public class BytedanceCampaignDailyReportLoadJob {
     static ExecutorService executorService = Executors.newFixedThreadPool(5);
 
 
+    /**
+     * 广告组日报
+     * @throws Exception
+     */
     @XxlJob("bytedanceCampaignDailyReport")
     public void execute() throws Exception {
         XxlJobHelper.log("头条广告组日报获取任务执行开始");

+ 4 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceCampaignHourlyReportLoadJob.java

@@ -23,6 +23,10 @@ public class BytedanceCampaignHourlyReportLoadJob {
     private IReportService reportService;
     static ExecutorService executorService = Executors.newFixedThreadPool(4);
 
+    /**
+     * 广告组时报
+     * @throws Exception
+     */
     @XxlJob("bytedanceCampaignHourlyReport")
     public void execute() throws Exception {
         XxlJobHelper.log("头条广告组时报数据获取开始");

+ 10 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceCheckAccountReportJob.java

@@ -21,6 +21,12 @@ public class BytedanceCheckAccountReportJob {
     private CountDownLatch countDownLatch;
     @Autowired
     private IBytedanceCheckReportTaskInfoService checkReportTaskInfoService;
+
+
+    /**
+     * 头条数据检查任务
+     * @throws Exception
+     */
     @XxlJob("initCheckReportJob")
     public void initCheckReportJob() throws Exception {
         String date = DateUtils.addDay(DateUtils.formatDate(),-1);
@@ -46,6 +52,10 @@ public class BytedanceCheckAccountReportJob {
         }
     }
 
+    /**
+     * 头条数据重试
+     * @throws Exception
+     */
     @XxlJob("refreshCheckReportJob")
     public void refreshCheckReportJob() throws Exception {
         //1:查询异常任务数据

+ 5 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceCreativeDailyReportLoadJob.java

@@ -27,6 +27,11 @@ public class BytedanceCreativeDailyReportLoadJob {
     @Autowired
     private IReportService reportService;
     static ExecutorService executorService = Executors.newFixedThreadPool(5);
+
+    /**
+     * 头条创意日报
+     * @throws Exception
+     */
     @XxlJob("bytedanceCreativeDailyReport")
     public void execute() throws Exception {
         Date getDate = DateUtils.addDay(new Date(), -1);

+ 5 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceCreativeHourlyReportLoadJob.java

@@ -26,6 +26,11 @@ public class BytedanceCreativeHourlyReportLoadJob {
     @Autowired
     private IReportService reportService;
     static ExecutorService executorService = Executors.newFixedThreadPool(4);
+
+    /**
+     * 头条创意时报
+     * @throws Exception
+     */
     @XxlJob("bytedanceCreativeHourlyReport")
     public void execute() throws Exception {
         XxlJobHelper.log("头条时报数据获取开始");

+ 5 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceDailyMaterialReportJob.java

@@ -28,6 +28,11 @@ public class BytedanceDailyMaterialReportJob {
     private IBytedanceReportService bytedanceReportService;
     @Resource
     private BytedanceReportMaterialDailyMapper bytedanceReportMaterialDailyMapper;
+
+    /**
+     * 头条获取素材报表数据任务
+     * @throws Exception
+     */
     @XxlJob("bytedanceDailyMaterialReportJob")
     public void execute() throws Exception {
         Date getDate2 = DateUtils.addDay(new Date(), -2);

+ 1 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceDailyMaterialReportRetryJob.java

@@ -25,6 +25,7 @@ public class BytedanceDailyMaterialReportRetryJob {
     @Autowired
     private IByteDanceVideoReportDailyService byteDanceVideoReportDailyService;
 
+    //TODO 待删除
     @XxlJob("bytedanceDailyMaterialReportRetryJob")
     public void execute() throws Exception {
         XxlJobHelper.log("头条素材报表重试定时任务开始");

+ 4 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceDailyPlayableReportJob.java

@@ -22,6 +22,10 @@ public class BytedanceDailyPlayableReportJob {
     @Autowired
     private IBytedanceInterfaceService bytedanceInterfaceService;
 
+    /**
+     * 试玩报表定时任务
+     * @throws Exception
+     */
     @XxlJob("bytedanceDailyPlayableReportJob")
     public void execute() throws Exception {
         Date getDate2 = DateUtils.addDay(new Date(), -2);

+ 4 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceDailyPlayableReportRetryJob.java

@@ -23,6 +23,10 @@ public class BytedanceDailyPlayableReportRetryJob {
     private IBytedanceInterfaceService bytedanceInterfaceService;
 
 
+    /**
+     * 试玩报表重试任务
+     * @throws Exception
+     */
     @XxlJob("bytedanceDailyPlayableReportRetryJob")
     public void execute() throws Exception {
         XxlJobHelper.log("头条试玩报表重试定时任务开始");

+ 27 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceEtlVideoJob.java

@@ -19,6 +19,11 @@ public class BytedanceEtlVideoJob {
     @Autowired
     private IEtlBytedanceReportVideoDailyService etlBytedanceReportVideoDailyService;
 
+
+    /**
+     * 头条爆款视频数据清洗
+     * @throws Exception
+     */
     @XxlJob("bytedanceEtlVideoJob")
     public void execute() throws Exception {
         Date startDate = DateUtils.addDay(new Date(),-2);
@@ -28,6 +33,7 @@ public class BytedanceEtlVideoJob {
         }
     }
 
+    //TODO 待删除
     @XxlJob("bytedanceEtlVideoProjectJob")
     public void bytedanceEtlVideoProjectJob() throws Exception {
         Date startDate = DateUtils.addDay(new Date(),-2);
@@ -38,6 +44,10 @@ public class BytedanceEtlVideoJob {
     }
 
 
+    /**
+     * 头条视频报表url异常
+     * @throws Exception
+     */
     @XxlJob("updBytedanceVideoJob")
     public void updBytedanceVideoJob() throws Exception {
         etlBytedanceReportVideoDailyService.updBytedanceVideo();
@@ -45,21 +55,38 @@ public class BytedanceEtlVideoJob {
 
     @Autowired
     private IETLReportBytedanceVideoService etlReportBytedanceVideoService;
+
+    /**
+     * 清洗头条剪辑
+     * @throws Exception
+     */
     @XxlJob("etlBytedanceVideoClipInfoJob")
     public void etlBytedanceVideoClipInfoJob() throws Exception {
         etlReportBytedanceVideoService.etlBytedanceVideoClipIdJob();
     }
 
+    /**
+     * 清新头条视频报表编导数据
+     * @throws Exception
+     */
     @XxlJob("etlBytedanceVideoPlanInfoJob")
     public void etlBytedanceVideoPlanInfoJob() throws Exception {
         etlReportBytedanceVideoService.etlBytedanceVideoPlanInfoJob();
     }
 
+    /**
+     * 清洗头条拍摄
+     * @throws Exception
+     */
     @XxlJob("etlBytedanceVideoShotInfoJob")
     public void etlBytedanceVideoShotInfoJob() throws Exception {
         etlReportBytedanceVideoService.etlBytedanceVideoShotInfoJob();
     }
 
+    /**
+     * 头条视频报表数据任务
+     * @throws Exception
+     */
     @XxlJob("formatBytedance")
     public void etlBytedanceVideoJob() throws Exception {
         etlBytedanceReportVideoDailyService.etlBytedanceVideo();

+ 5 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceFlowFundJob.java

@@ -21,6 +21,11 @@ public class BytedanceFlowFundJob {
     @Autowired
     private IBytedanceFundDailyService bytedanceFundDailyService;
     static ExecutorService executorService = Executors.newFixedThreadPool(4);
+
+    /**
+     * 头条账户流水
+     * @throws Exception
+     */
     @XxlJob("bytedanceFlowFund")
     public void execute() throws Exception {
         XxlJobHelper.log("头条账户流水数据获取开始");

+ 4 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceMaterialsLoadJob.java

@@ -29,6 +29,10 @@ public class BytedanceMaterialsLoadJob {
     @Autowired
     private IBytedanceImageInfoService imageInfoService;
 
+    /**
+     * 头条素材数据获取
+     * @throws Exception
+     */
     @XxlJob("bytedanceMaterialsLoadJob")
     public void execute() throws Exception{
         List<CtopOauthToken> tokens = tokenService.selectToutiaoToken();

+ 4 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceMonitoringLinksCheckJob.java

@@ -36,6 +36,10 @@ public class BytedanceMonitoringLinksCheckJob {
     @Autowired
     private ICtopOauthTokenService tokenService;
 
+    /**
+     * 头条内广监测链接检查
+     * @throws Exception
+     */
     @XxlJob("bytedanceMonitoringLinksCheckJob")
     public void execute() throws Exception{
         List<Project> projects = projectService.listByMediaType(3,1);

+ 4 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedancePlanDailyReportLoadJob.java

@@ -34,6 +34,10 @@ public class BytedancePlanDailyReportLoadJob {
     private IBytedancePlanDailyReportService planDailyReportService;
 
 
+    /**
+     * 头条计划日报
+     * @throws Exception
+     */
     @XxlJob("bytedancePlanDailyReport")
     public void execute() throws Exception {
         Date getDate = DateUtils.addDay(new Date(), -1);

+ 3 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedancePlanHourlyReportLoadJob.java

@@ -35,6 +35,9 @@ public class BytedancePlanHourlyReportLoadJob {
     static CountDownLatch countDownLatch = null;
 
 
+    /**
+     * 头条计划时报
+     */
     @XxlJob("bytedancePlanHourlyReport")
     public void execute() {
         XxlJobHelper.log("头条时报数据获取开始");

+ 5 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedancePlanLoadJob.java

@@ -19,6 +19,11 @@ public class BytedancePlanLoadJob {
     @Autowired
     private IByteDanceAdvertiserDataService advertiserDataService;
     static ExecutorService executorService = Executors.newFixedThreadPool(4);
+
+    /**
+     * 头条全量计划数据
+     * @throws Exception
+     */
     @XxlJob("bytedancePlanLoadJob")
     public void execute() throws Exception {
         //1:查询当日数据

+ 1 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedancePlanRealTimeLoadJob.java

@@ -26,6 +26,7 @@ public class BytedancePlanRealTimeLoadJob {
     @Autowired
     private IByteDanceAdvertiserDataService advertiserDataService;
 
+    //TODO 待删除
     @XxlJob("bytedanceRealTimePlanInfo")
     public void execute() throws Exception {
         //1:查询当日数据

+ 5 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceRejectReasonJob.java

@@ -10,6 +10,11 @@ import java.util.Date;
 @Component
 public class BytedanceRejectReasonJob {
     private static final String URLPREFIX = "http://118.24.244.213:8808/bytedance-api/ctop/bytedanceRejectReason/getReasonInRecentHours?hour=";
+
+    /**
+     * 头条优化审核建议
+     * @throws Exception
+     */
     @XxlJob("bytedanceRejectReasonJob")
     public void execute() throws Exception {
 

+ 5 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceSameDayCreativeLoadJob.java

@@ -21,6 +21,11 @@ public class BytedanceSameDayCreativeLoadJob {
     static ExecutorService executorService = Executors.newFixedThreadPool(6);
     @Autowired
     private IByteDanceCreativeService byteDanceCreativeService;
+
+    /**
+     * 头条当日实时创意数据
+     * @throws Exception
+     */
     @XxlJob("bytedanceSameDayCreative")
     public void execute() throws Exception {
         List<CtopOauthToken> tokens = tokenService.getTokenListByType(CtopAdConstant.PLATFORM_TYPE_BYTEDANCE);

+ 4 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceTodayPlaneLoadJob.java

@@ -27,6 +27,10 @@ public class BytedanceTodayPlaneLoadJob {
     private IByteDanceAdvertiserDataService advertiserDataService;
     static ExecutorService executorService = Executors.newFixedThreadPool(15);
 
+    /**
+     * 获取今天头条计划数据
+     * @throws Exception
+     */
     @XxlJob("bytedanceTodayPlaneLoadJob")
     public void execute() throws Exception {
         Date getDate = new Date();

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

@@ -10,6 +10,8 @@ import java.util.Date;
 
 @Component
 public class BytedanceVideoDailyReportLoadJob {
+
+    //TODO 待删除
     @XxlJob("bytedanceVideoDailyReportLoadJob")
     public void execute() throws Exception {
         for(int i=0;i<3;i++){

+ 1 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceVideoETLReportReloadJob.java

@@ -19,6 +19,7 @@ public class BytedanceVideoETLReportReloadJob {
     @Autowired
     private IEtlBytedanceVideoInfoService iEtlBytedanceVideoInfoService;
 
+    //TODO 待删除
     @XxlJob("bytedanceETLReportData")
     public void execute() throws Exception {
         //查询素材归属表所有的信息md5,clip_id,clip_name,shot_id,shot_name,plan_id,plan_name

+ 1 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceVideoInfoLoadJob.java

@@ -20,6 +20,7 @@ public class BytedanceVideoInfoLoadJob {
     @Autowired
     private IByteDanceAdvertiserDataService advertiserDataService;
 
+    //TODO 待删除
     @XxlJob("bytedanceVideoInfo")
     public void execute() throws Exception {
         List<CtopOauthToken> tokens = tokenService.getTokenListByType(CtopAdConstant.PLATFORM_TYPE_BYTEDANCE);

+ 4 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceVideoReportCleanJob.java

@@ -13,6 +13,10 @@ public class BytedanceVideoReportCleanJob {
     @Autowired
     private IByteDanceVideoReportDailyService videoReportDailyService;
 
+    /**
+     * 头条视频数据清洗
+     * @throws Exception
+     */
     @XxlJob("bytedanceVideoReportCleanJob")
     public void execute() throws Exception {
         for(int i=0;i<2;i++){

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

@@ -23,6 +23,8 @@ public class BytedanceYesterdayAdvertiserHourlyLoadJob {
     @Autowired
     private IReportService reportService;
     private ExecutorService executorService = Executors.newFixedThreadPool(5);
+
+    //TODO 待删除
     @XxlJob("byteDanceAdvertiserHourlyReport")
     public void execute() throws Exception {
         //查询需要拉取数据的账户token

+ 1 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/CheckDataStateJob.java

@@ -22,6 +22,7 @@ public class CheckDataStateJob {
 
     /**
      * 检查任务执行结果
+     * 检查数据结果
      */
     @XxlJob(jobName)
     public void execute() throws Exception {

+ 4 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ETLReportDesignJob.java

@@ -13,6 +13,10 @@ public class ETLReportDesignJob {
     @Autowired
     IEtlDesignDailyReportService etlDesignDailyReportService;
 
+    /**
+     * 设计人员消耗数据清洗
+     * @throws Exception
+     */
     @XxlJob("ETLReportDesignJob")
     public void execute() throws Exception {
         String statDate = DateUtils.formatDate(DateUtils.addDay(new Date(), -1));

+ 1 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ETLReportVideoCleanJob.java

@@ -15,6 +15,7 @@ public class ETLReportVideoCleanJob {
     @Autowired
     IETLReportBytedanceVideoService etlReportBytedanceVideoService;
 
+    //TODO 待删除
     @XxlJob("ETLReportVideoCleanJob")
     public void execute() throws Exception {
         String statDate = DateUtils.formatDate(DateUtils.addDay(new Date(), -1));

+ 5 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/RuleDataAccountCleanJob.java

@@ -25,6 +25,11 @@ public class RuleDataAccountCleanJob {
     @Autowired
     private IRuleByteDanceAccountService ruleByteDanceAccountService;
     private ExecutorService executorService = Executors.newFixedThreadPool(10);
+
+    /**
+     * 规则引擎账户数据
+     * @throws Exception
+     */
     @XxlJob("ruleDataAccountCleanJob")
     public void execute() throws Exception {
         XxlJobHelper.log("规则预警账户维度数据开始清洗");

+ 1 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/SendDailyUReportJob.java

@@ -27,6 +27,7 @@ public class SendDailyUReportJob {
     /**
      * 检查任务执行结果
      */
+    //TODO 待删除
     @XxlJob("sendDailyUReportJob")
     public void execute() throws Exception {
         uReportService.uReportList().forEach(uReport->{

+ 1 - 1
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/SendHourlyMessageJob.java

@@ -11,7 +11,7 @@ public class SendHourlyMessageJob {
     private IAppchatCreateService appchatCreateService;
 
     /**
-     *
+     *发送时报提醒任务
      **/
     @XxlJob("sendHourlyMessageJob")
     public void execute() {