瀏覽代碼

快手定时任务梳理

yangzian 3 年之前
父節點
當前提交
affe120efe
共有 58 個文件被更改,包括 219 次插入4 次删除
  1. 8 0
      module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ByteDanceRefreshTokenJob.java
  2. 3 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/CrowdListQueryJob.java
  3. 1 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/DeleteKuaishouCommentJob.java
  4. 1 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaiShouAlarmRuleJob.java
  5. 1 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaiShouCostGroupJob.java
  6. 6 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaiShouDailyImageReportLoadJob.java
  7. 1 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaiShouDeleteCommentJob.java
  8. 1 1
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaiShouRefreshAgentTokenJob.java
  9. 1 1
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaiShouRefreshTokenJob.java
  10. 1 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaiShouTodayAgentReportJob.java
  11. 1 1
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaiShouYesterdayAgentReportJob.java
  12. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouAccountAudienceReportEtlJob.java
  13. 1 1
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouAccountBidJob.java
  14. 3 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouActionBarTextJob.java
  15. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouBatchCampaignTimeStartJob.java
  16. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouCampaignJob.java
  17. 3 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouCreateCreativeJob.java
  18. 3 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouCreateUnitJob.java
  19. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyAccountAudienceReportJob.java
  20. 5 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyAccountReportLoadEtlJob.java
  21. 8 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyAccountReportLoadJob.java
  22. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyAudienceReportJob.java
  23. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyCampaignReportLoadJob.java
  24. 1 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyCreativeReportLoadJob.java
  25. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyFlowsJob.java
  26. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyGroupReportLoadJob.java
  27. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyLoadFileJob.java
  28. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyReportTaskJob.java
  29. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyZombieJob.java
  30. 11 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDingPanCleanJob.java
  31. 1 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouEffectVideoJob.java
  32. 21 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouEtlVideoJob.java
  33. 1 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouGroupDailyReportJob.java
  34. 1 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouGroupExploreJob.java
  35. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouGroupJob.java
  36. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouHistoryLoadFileJob.java
  37. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouHourlyAccountReportLoadEtlJob.java
  38. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouHourlyAccountReportLoadJob.java
  39. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouHourlyAccountWarningLoadJob.java
  40. 1 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouHourlyCampaignReportLoadJob.java
  41. 2 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouHourlyCreativeReportLoadJob.java
  42. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouHourlyGroupReportLoadJob.java
  43. 3 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouLandpagesJob.java
  44. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouMaterialSyncMd5Job.java
  45. 5 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouMaterialsLoadJob.java
  46. 6 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouNewAccountOperationRecordJob.java
  47. 5 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouNowDateCampaignJob.java
  48. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouNowDateCreativeJob.java
  49. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouNowDateGroupJob.java
  50. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouOperationRecordJob.java
  51. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouProjectVideoGetJob.java
  52. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouReportDailyGroupChannelCodeJob.java
  53. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouVideoRelateCreativesJob.java
  54. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/RuleKuaiShouDataAccountCleanJob.java
  55. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/RuleKuaiShouDataPlanCleanJob.java
  56. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/RuleKuaiShouDataTargetCleanJob.java
  57. 4 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/RuleKuaiShouDataUnitCleanJob.java
  58. 1 0
      module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/WatermarkVideoJob.java

+ 8 - 0
module-job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/ByteDanceRefreshTokenJob.java

@@ -39,4 +39,12 @@ public class ByteDanceRefreshTokenJob {
             });
         }
     }
+    /**
+     * 刷新token
+     * @throws Exception
+     */
+    @XxlJob("qianChuanRefreshTokenJob")
+    public void qianChuanRefresh() throws Exception {
+        refreshTokenService.qianChuanRefresh(null);
+    }
 }

+ 3 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/CrowdListQueryJob.java

@@ -37,6 +37,9 @@ public class CrowdListQueryJob {
     private IKuaishouPopulationPackageRelService relService;
     static ExecutorService executorService = Executors.newFixedThreadPool(3);
 
+    /**
+     * 定时更新人群包状态
+     */
     @XxlJob("crowdListQueryJob")
     public void execute() {
         List<Integer> list = new ArrayList<>();

+ 1 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/DeleteKuaishouCommentJob.java

@@ -23,6 +23,7 @@ public class DeleteKuaishouCommentJob {
     private IKuaishouWebInterfaceService kuaishouWebInterfaceService;
     static ExecutorService executorService = Executors.newFixedThreadPool(5);
     static CountDownLatch countDownLatch = null;
+    //TODO 待删除
     @XxlJob("deleteKuaishouComment")
     public void deleteKuaishouComment(){
         Long start = System.currentTimeMillis();

+ 1 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaiShouAlarmRuleJob.java

@@ -30,6 +30,7 @@ public class KuaiShouAlarmRuleJob {
      * @throws
      * @author ZHAOXA
      */
+    //TODO 待删除
     @XxlJob("kuaiShoualarmRuleJob")
     public void execute() throws Exception {
         //查询账户绑定过的规则模板

+ 1 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaiShouCostGroupJob.java

@@ -16,6 +16,7 @@ public class KuaiShouCostGroupJob {
      *
      * @throws JobExecutionException
      */
+    //TODO 待删除
     @XxlJob("kuaiShouCostGroupJob")
     public void execute() throws Exception {
         kuaishouCostGroupService.saveInfo();

+ 6 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaiShouDailyImageReportLoadJob.java

@@ -20,6 +20,12 @@ public class KuaiShouDailyImageReportLoadJob {
     @Autowired
     private IKuaishouReportDailyImageService kuaishouReportDailyImageService;
     private static ExecutorService executorService = Executors.newFixedThreadPool(8);
+
+
+    /**
+     * 快手图片消耗报表
+     * @throws Exception
+     */
     @XxlJob("kuaiShouDailyImageReportLoadJob")
     public void execute() throws Exception {
         //增加接口的开始和结束日期

+ 1 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaiShouDeleteCommentJob.java

@@ -25,6 +25,7 @@ public class KuaiShouDeleteCommentJob {
 
     static CountDownLatch countDownLatch = null;
 
+    //TODO 待删除
     @XxlJob("kuaiShouDeleteCommentJob")
     public void kuaiShouDeleteComment(){
         Long start = System.currentTimeMillis();

+ 1 - 1
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaiShouRefreshAgentTokenJob.java

@@ -12,7 +12,7 @@ public class KuaiShouRefreshAgentTokenJob {
     private IRefreshTokenService refreshTokenService;
 
     /**
-     * 刷新token
+     * 代理商刷新token
      * @throws JobExecutionException
      */
     @XxlJob("kuaiShouRefreshAgentTokenJob")

+ 1 - 1
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaiShouRefreshTokenJob.java

@@ -12,7 +12,7 @@ public class KuaiShouRefreshTokenJob {
     private IRefreshTokenService refreshTokenService;
 
     /**
-     * 刷新token
+     * 快手刷新token
      * @throws JobExecutionException
      */
     @XxlJob("kuaiShouRefreshTokenJob")

+ 1 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaiShouTodayAgentReportJob.java

@@ -17,6 +17,7 @@ public class KuaiShouTodayAgentReportJob {
      *
      * @throws JobExecutionException
      */
+    // TODO 待删除
     @XxlJob("kuaiShouTodayAgentReportJob")
     public void execute() throws Exception {
         String nowDate = DateUtils.getNowDate("yyyy-MM-dd");

+ 1 - 1
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaiShouYesterdayAgentReportJob.java

@@ -13,7 +13,7 @@ public class KuaiShouYesterdayAgentReportJob {
     private IKuaiShouDailyAgentService kuaiShouDailyAgentService;
 
     /**
-     * 快手昨日代理商报表
+     * 代理商t-1数据获取
      *
      * @throws JobExecutionException
      */

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouAccountAudienceReportEtlJob.java

@@ -18,6 +18,10 @@ public class KuaishouAccountAudienceReportEtlJob {
     @Autowired
     private IEtlKuaishouAudienceAccountDailyService etlKuaishouAudienceAccountDailyService;
 
+    /**
+     * 清洗盯盘人群——年龄、性别数据
+     * @throws Exception
+     */
     @XxlJob("kuaishouAccountAudienceReportEtlJob")
     public void execute() throws Exception {
         try {

+ 1 - 1
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouAccountBidJob.java

@@ -12,7 +12,7 @@ public class KuaishouAccountBidJob {
     private IKuaishouBidWarningService bidWarningService;
 
     /**
-     * 出价预警
+     * 快手出价预警
      **/
     @XxlJob("kuaishouAccountBidJob")
     public void execute() {

+ 3 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouActionBarTextJob.java

@@ -11,6 +11,9 @@ public class KuaishouActionBarTextJob {
     @Autowired
     private IKuaiShouActionBarTextService actionBarTextService;
 
+    /**
+     * 快手-行动号召按钮定时更新
+     */
     @XxlJob("kuaishouActionBarTextJob")
     public void execute() {
         actionBarTextService.getActionBarText();

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouBatchCampaignTimeStartJob.java

@@ -27,6 +27,10 @@ public class KuaishouBatchCampaignTimeStartJob {
     private IKuaiShouUpdateService kuaiShouUpdateService;
     static ExecutorService executorService = Executors.newFixedThreadPool(5);
 
+    /**
+     * 批量创建——定时启动广告计划
+     * @throws Exception
+     */
     @XxlJob("kuaishouBatchCampaignTimeStartJob")
     public void execute() throws Exception {
         List<KuaishouBatchCampaignPreview> campaignPreviewList = campaignPreviewService.queryListByTime();

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouCampaignJob.java

@@ -19,6 +19,10 @@ public class KuaishouCampaignJob {
     @Autowired
     private IKuaishouInterfaceService kuaishouInterfaceService;
     static ExecutorService executorService = Executors.newFixedThreadPool(5);
+
+    /**
+     * 快手全量计划物料数据
+     */
     @XxlJob("kuaishouCampaignJob")
     public void execute() {
         List<CtopOauthToken> tokens = tokenService.selectKuaiShouToken();

+ 3 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouCreateCreativeJob.java

@@ -21,6 +21,9 @@ public class KuaishouCreateCreativeJob {
     @Autowired
     private ICtopOauthTokenService tokenService;
 
+    /**
+     * 组创建成功-创意待创建
+     */
     @XxlJob("kuaihouCreateCreative")
     public void execute() {
         QueryWrapper<KuaiShouGroupTemplate> templateQueryWrapper = new QueryWrapper<>();

+ 3 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouCreateUnitJob.java

@@ -22,6 +22,9 @@ public class KuaishouCreateUnitJob {
     @Value("${xxl-job.requestUrl}")
     private String jobUrl;
 
+    /**
+     * 快手自动创建组
+     */
     @XxlJob("kuaihouCreateUnit")
     public void execute() {
         String url = jobUrl + "/jeecg-boot/batch/kuaiShouGroupTemplate/createUnit";

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyAccountAudienceReportJob.java

@@ -27,6 +27,10 @@ public class KuaishouDailyAccountAudienceReportJob {
 
     static ExecutorService executorService = Executors.newFixedThreadPool(5);
 
+    /**
+     * 人群分析报表账户级每日数据
+     * @throws Exception
+     */
     @XxlJob("kuaishouAccountAudienceReportJob")
     public void execute() throws Exception {
         //查询两天前数据  策略

+ 5 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyAccountReportLoadEtlJob.java

@@ -29,6 +29,11 @@ public class KuaishouDailyAccountReportLoadEtlJob {
     private EtlKuaishouAccountMaterialReportDailyMapper etlKuaishouAccountMaterialReportDailyMapper;
     @Autowired
     private IEtlKuaishouReportAccountHourlyService hourlyService;
+
+    /**
+     * 清洗账户维度-每日盯盘数据
+     * @throws Exception
+     */
     @XxlJob("kuaishouDailyAccountReportLoadEtl")
     public void execute() throws Exception {
         try {

+ 8 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyAccountReportLoadJob.java

@@ -28,6 +28,10 @@ public class KuaishouDailyAccountReportLoadJob {
     static ExecutorService executorService = Executors.newFixedThreadPool(10);
     static ExecutorService adSceneExecutorService = Executors.newFixedThreadPool(10);
 
+    /**
+     * 快手广告主日报
+     * @throws Exception
+     */
     @XxlJob("kuaishouDailyAccountReport")
     public void execute() throws Exception {
         Date getDate = DateUtils.addDay(new Date(), -1);
@@ -44,6 +48,10 @@ public class KuaishouDailyAccountReportLoadJob {
         }));
     }
 
+    /**
+     * 账户日报-分版位数据
+     * @throws Exception
+     */
     @XxlJob("kuaishouDailyAccountAdSceneReport")
     public void kuaishouDailyAccountAdSceneReport() throws Exception {
         Date getDate = DateUtils.addDay(new Date(), -1);

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyAudienceReportJob.java

@@ -35,6 +35,10 @@ public class KuaishouDailyAudienceReportJob {
 
     static ExecutorService executorService = null;
 
+    /**
+     * 人群分析报表每日组级数据
+     * @throws Exception
+     */
     @XxlJob("kuaishouDailyAudienceReportJob")
     public void execute() throws Exception {
         Thread thread = new Thread() {

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyCampaignReportLoadJob.java

@@ -27,6 +27,10 @@ public class KuaishouDailyCampaignReportLoadJob {
     private IKuaishouInterfaceService kuaishouInterfaceService;
     static ExecutorService executorService = Executors.newFixedThreadPool(3);
 
+    /**
+     * 快手计划日报数据
+     * @throws Exception
+     */
     @XxlJob("kuaishouDailyCampaignReport")
     public void execute() throws Exception {
         Date getDate = DateUtils.addDay(new Date(), -1);

+ 1 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyCreativeReportLoadJob.java

@@ -33,6 +33,7 @@ public class KuaishouDailyCreativeReportLoadJob {
     @Autowired
     private IKuaiShouCampaignService campaignService;
 
+    //TODO 待删除
     @XxlJob("kuaishouDailyCreativeReport")
     public void execute() throws Exception {
         Date getDate = DateUtils.addDay(new Date(), -1);

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyFlowsJob.java

@@ -16,6 +16,10 @@ public class KuaishouDailyFlowsJob {
     private IKuaishouInterfaceService kuaishouInterfaceService;
     @Autowired
     private ICtopOauthTokenService oauthTokenService;
+
+    /**
+     * 快手账户流水信息
+     */
     @XxlJob("kuaishouDailyFlowsJob")
     public void execute() {
         List<CtopOauthToken> tokens = oauthTokenService.selectKuaiShouToken();

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyGroupReportLoadJob.java

@@ -27,6 +27,10 @@ public class KuaishouDailyGroupReportLoadJob {
     private IKuaishouReportDailyGroupService reportDailyGroupService;
     static ExecutorService executorService = Executors.newFixedThreadPool(3);
 
+    /**
+     * 快手广告组日报
+     * @throws Exception
+     */
     @XxlJob("kuaishouDailyGroupReport")
     public void execute() throws Exception {
         Date getDate = DateUtils.addDay(new Date(), -1);

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyLoadFileJob.java

@@ -28,6 +28,10 @@ public class KuaishouDailyLoadFileJob {
     @Autowired
     private IKuaiShouDailyReportTaskService dailyReportTaskService;
 
+    /**
+     * 快手异步文件下载入库
+     * @throws Exception
+     */
     @XxlJob("kuaishouDailyLoadFile")
     public void execute() throws Exception {
         String nowDate = DateUtils.getDate("yyyy-MM-dd");

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyReportTaskJob.java

@@ -20,6 +20,10 @@ public class KuaishouDailyReportTaskJob {
     @Autowired
     private IKuaiShouHistoryReportTaskService reportTaskService;
 
+    /**
+     * 快手异步日报任务创建
+     * @throws Exception
+     */
     @XxlJob("kuaishouDailyReportTask")
     public void execute() throws Exception {
         XxlJobHelper.log("快手获取日报数据任务执行开始");

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDailyZombieJob.java

@@ -16,6 +16,10 @@ public class KuaishouDailyZombieJob {
     @Autowired
     private IKuaishouZombieCreativeService kuaishouZombieCreativeService;
 
+    /**
+     * 更新僵尸计划数据
+     * @throws Exception
+     */
     @XxlJob("kuaishouDailyZombie")
     public void execute() throws Exception {
         XxlJobHelper.log("更新僵尸计划数据 start");

+ 11 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouDingPanCleanJob.java

@@ -31,6 +31,9 @@ public class KuaishouDingPanCleanJob {
     static ExecutorService executorService = Executors.newFixedThreadPool(8);
     static ExecutorService materialExecutorService = Executors.newFixedThreadPool(8);
 
+    /**
+     * 快手盯盘每日上新数据
+     */
     @XxlJob("cleanNewlyData")
     public void cleanNewlyData() {
         String nowDate = DateUtils.getNowDate("yyyy-MM-dd");
@@ -40,6 +43,10 @@ public class KuaishouDingPanCleanJob {
     }
 
 
+    /**
+     * 盯盘组日报数据清洗
+     * @throws Exception
+     */
     @XxlJob("cleanGroupReport")
     public void cleanGroupReport() throws Exception {
         List<CtopOauthToken> tokens = tokenService.selectKuaiShouToken();
@@ -60,6 +67,10 @@ public class KuaishouDingPanCleanJob {
     }
 
 
+    /**
+     * 盯盘素材概览数据
+     * @throws Exception
+     */
     @XxlJob("cleanAccountMaterialOverview")
     public void cleanAccountMaterialOverview() throws Exception {
         String nowDate = DateUtils.getNowDate("yyyy-MM-dd");

+ 1 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouEffectVideoJob.java

@@ -14,6 +14,7 @@ public class KuaishouEffectVideoJob {
     @Autowired
     private IKuaishouVideoEtlInfoService etlInfoService;
 
+    //TODO 待删除
     @XxlJob("kuaishouEffectVideoJob")
     public void execute() throws ParseException {
         Date getDate = DateUtils.addDay(new Date(),-1);

+ 21 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouEtlVideoJob.java

@@ -22,6 +22,10 @@ public class KuaishouEtlVideoJob {
     @Autowired
     private IEtlKuaishouVideoInfoService videoEtlInfoService;
 
+    /**
+     * 快手爆款视频数据清洗
+     * @throws Exception
+     */
     @XxlJob("kuaishouEtlVideoJob")
     public void execute() throws Exception {
         Date startDate = DateUtils.addDay(new Date(), -2);
@@ -31,6 +35,7 @@ public class KuaishouEtlVideoJob {
         }
     }
 
+    //TODO 待删除
     @XxlJob("kuaishouEtlProjectVideoJob")
     public void kuaishouEtlProjectVideoJob() throws Exception {
         Date startDate = DateUtils.addDay(new Date(), -2);
@@ -40,12 +45,20 @@ public class KuaishouEtlVideoJob {
         }
     }
 
+    /**
+     * kuaishou_video_get数据清洗
+     * 表名:ctop_kuaishou_video_get===>快手-获取视频接口
+     * @throws Exception
+     */
     @XxlJob("kuaishouEtlVideoBaseInfoJob")
     public void kuaishouEtlVideoBaseInfoJob() throws Exception {
         String statDate = DateUtils.getStartTime(DateUtils.addDay(new Date(), -1));
         videoGetService.etlVideoBaseInfoByStaDate(statDate);
     }
 
+    /**
+     * 快手视频信息清洗任务
+     */
     @XxlJob("etlFinalKuaishouVideoInfo")
     public void etlKuaishouVideoInfo(){
         Date startDate = DateUtils.addDay(new Date(), -2);
@@ -53,6 +66,10 @@ public class KuaishouEtlVideoJob {
             videoEtlInfoService.etlKuaishouVideoInfo(DateUtils.formatDate(DateUtils.addDay(startDate,i)));
         }
     }
+
+    /**
+     * 快手数据
+     */
     @XxlJob("etlKuaishouAccountMaterialReportInfo")
     public void etlKuaishouAccountMaterialReportInfo(){
         Date startDate = new Date();
@@ -61,12 +78,16 @@ public class KuaishouEtlVideoJob {
         }
     }
 
+    /**
+     * 快手清洗视频公司归属
+     */
     @XxlJob("etlKuaishouReportCompanyInfo")
     public void etlKuaishouReportCompanyInfo(){
         Date date = DateUtils.addDay(new Date(),-1);
         materialReportDailyService.etlKuaishouReportCompanyInfo(DateUtils.formatDate(date));
     }
 
+    //TODO 待删除
     @XxlJob("etlKuaishouVideoReportStateDate")
     public void etlKuaishouVideoReportStateDate(){
         materialReportDailyService.etlKuaishouVideoReportStateDate();

+ 1 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouGroupDailyReportJob.java

@@ -28,6 +28,7 @@ public class KuaishouGroupDailyReportJob {
 
     static ExecutorService executorService = Executors.newFixedThreadPool(5);
 
+    // TODO 待删除
     @XxlJob("kuaishouGroupDailyReportJob")
     public void execute() throws ParseException {
         String date = DateUtils.getDate("yyyy-MM-dd");

+ 1 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouGroupExploreJob.java

@@ -20,6 +20,7 @@ public class KuaishouGroupExploreJob {
     @Autowired
     private IKuaishouGroupExploreService kuaishouGroupExploreService;
     static ExecutorService executorService = Executors.newFixedThreadPool(5);
+    //TODO 待删除
     @XxlJob("kuaishouGroupExploreReportJob")
     public void execute() throws ParseException {
         List<CtopOauthToken> tokens = tokenService.selectKuaiShouToken();

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouGroupJob.java

@@ -21,6 +21,10 @@ public class KuaishouGroupJob {
 
     static ExecutorService executorService = Executors.newFixedThreadPool(3);
 
+    /**
+     * 快手广告组物料
+     * @throws Exception
+     */
     @XxlJob("kuaishouGroup")
     public void execute() throws Exception {
         List<CtopOauthToken> tokens = tokenService.selectKuaiShouToken();

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouHistoryLoadFileJob.java

@@ -15,6 +15,10 @@ public class KuaishouHistoryLoadFileJob {
     @Autowired
     private IKuaiShouHistoryReportTaskService historyReportTaskService;
 
+    /**
+     * 快手历史数据异步文件获取
+     * @throws Exception
+     */
     @XxlJob("kuaishouHistoryLoadFile")
     public void execute() throws Exception {
         historyReportTaskService.getTaskList();

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouHourlyAccountReportLoadEtlJob.java

@@ -18,6 +18,10 @@ public class KuaishouHourlyAccountReportLoadEtlJob {
     @Autowired
     private IEtlKuaishouReportAccountHourlyService hourlyService;
 
+    /**
+     * 清洗账户维度-盯盘小时数据
+     * @throws Exception
+     */
     @XxlJob("kuaishouHourlyAccountReportLoadEtl")
     public void execute() throws Exception {
         try {

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouHourlyAccountReportLoadJob.java

@@ -28,6 +28,10 @@ public class KuaishouHourlyAccountReportLoadJob {
     private IKuaishouInterfaceService kuaishouInterfaceService;
     static ExecutorService executorService = Executors.newFixedThreadPool(5);
 
+    /**
+     * 快手广告主时报
+     * @throws Exception
+     */
     @XxlJob("kuaishouHourlyAccountReport")
     public void execute() throws Exception {
         Date getDate = new Date();

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouHourlyAccountWarningLoadJob.java

@@ -27,6 +27,10 @@ public class KuaishouHourlyAccountWarningLoadJob {
     private IAccountWarningService accountWarningService;
     static ExecutorService executorService = Executors.newFixedThreadPool(3);
 
+    /**
+     * 快手时段消耗预警
+     * @throws Exception
+     */
     @XxlJob("kuaishouHourlyAccountWarning")
     public void execute() throws Exception {
         XxlJobHelper.log("开始时段消耗预警定时任务");

+ 1 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouHourlyCampaignReportLoadJob.java

@@ -29,6 +29,7 @@ public class KuaishouHourlyCampaignReportLoadJob {
 
     static ExecutorService executorService = Executors.newFixedThreadPool(5);
 
+    //TODO 待删除
     @XxlJob("kuaishouHourlyCampaignReport")
     public void execute() throws Exception {
         Date getDate = new Date();

+ 2 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouHourlyCreativeReportLoadJob.java

@@ -27,6 +27,8 @@ public class KuaishouHourlyCreativeReportLoadJob {
     @Autowired
     private IKuaishouInterfaceService kuaishouInterfaceService;
     static ExecutorService executorService = Executors.newFixedThreadPool(3);
+
+    //TODO 待删除
     @XxlJob("kuaishouHourlyCreativeReport")
     public void execute() throws Exception {
         Date getDate = new Date();

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouHourlyGroupReportLoadJob.java

@@ -36,6 +36,10 @@ public class KuaishouHourlyGroupReportLoadJob {
     private IKuaishouReportHourlyGroupService hourlyGroupService;
 
 
+    /**
+     * 广告组时报
+     * @throws Exception
+     */
     @XxlJob("kuaishouHourlyGroupReport")
     public void execute() throws Exception {
         //增加接口的开始和结束日期

+ 3 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouLandpagesJob.java

@@ -19,6 +19,9 @@ public class KuaishouLandpagesJob {
     private IUserAllocationService userAllocationService;
     static ExecutorService executorService = Executors.newFixedThreadPool(3);
 
+    /**
+     * 定时更新账户关联落地页数据
+     */
     @XxlJob("kuaishouLandpagesJob")
     public void execute() {
         //获取快手有效的账户

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouMaterialSyncMd5Job.java

@@ -18,6 +18,10 @@ public class KuaishouMaterialSyncMd5Job {
     @Autowired
     private IKuaiShouHistoryReportTaskService historyReportTaskService;
 
+    /**
+     * 检查前一天报表未获取md5
+     * @throws Exception
+     */
     @XxlJob("kuaishouMaterialSyncMd5Job")
     public void execute() throws Exception {
         String nowDate = DateUtils.getDate("yyyy-MM-dd");

+ 5 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouMaterialsLoadJob.java

@@ -20,6 +20,11 @@ public class KuaishouMaterialsLoadJob {
     @Autowired
     private IKuaishouInterfaceService kuaishouInterfaceService;
     static ExecutorService executorService = Executors.newFixedThreadPool(8);
+
+    /**
+     * 快手物料数据
+     * @throws Exception
+     */
     @XxlJob("kuaishouMaterials")
     public void execute() throws Exception {
         //增加接口的开始和结束日期

+ 6 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouNewAccountOperationRecordJob.java

@@ -26,6 +26,12 @@ public class KuaishouNewAccountOperationRecordJob {
     @Autowired
     private ICtopOauthTokenService tokenService;
     static ExecutorService executorService = Executors.newFixedThreadPool(4);
+
+    /**
+     * 快手操作跑前日新增账户数据
+     * @param param
+     * @throws Exception
+     */
     @XxlJob("kuaishouNewAccountOperationRecord")
     public void execute(String param) throws Exception {
         Date getDate = DateUtils.addDay(new Date(), -1);

+ 5 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouNowDateCampaignJob.java

@@ -22,6 +22,11 @@ public class KuaishouNowDateCampaignJob {
     @Autowired
     private IKuaishouInterfaceService kuaishouInterfaceService;
     static ExecutorService executorService = Executors.newFixedThreadPool(5);
+
+    /**
+     * 快手当日计划物料数据
+     * @throws Exception
+     */
     @XxlJob("kuaishouNowDateCampaign")
     public void execute() throws Exception {
         //1:查询当日数据

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouNowDateCreativeJob.java

@@ -24,6 +24,10 @@ public class KuaishouNowDateCreativeJob {
 
     static ExecutorService executorService = Executors.newFixedThreadPool(5);
 
+    /**
+     * 快手当日创意物料数据
+     * @throws Exception
+     */
     @XxlJob("kuaishouNowDateCreative")
     public void execute() throws Exception {
         Date endDate = new Date();

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouNowDateGroupJob.java

@@ -24,6 +24,10 @@ public class KuaishouNowDateGroupJob {
 
     static ExecutorService executorService = Executors.newFixedThreadPool(5);
 
+    /**
+     * 快手当日广告组物料数据
+     * @throws Exception
+     */
     @XxlJob("kuaishouNowDateGroup")
     public void execute() throws Exception {
         //1:查询当日数据

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouOperationRecordJob.java

@@ -23,6 +23,10 @@ public class KuaishouOperationRecordJob {
 
     static ExecutorService executorService = Executors.newFixedThreadPool(4);
 
+    /**
+     * 快手操作记录定时任务
+     * @throws Exception
+     */
     @XxlJob("kuaishouOperationRecord")
     public void execute() throws Exception {
         Date getDate = DateUtils.addDay(new Date(), -1);

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouProjectVideoGetJob.java

@@ -40,6 +40,10 @@ public class KuaishouProjectVideoGetJob {
 
     static ExecutorService executorService = Executors.newFixedThreadPool(10);
 
+    /**
+     * 清洗项目素材
+     * @throws Exception
+     */
     @XxlJob("kuaishouProjectVideoGetJob")
     public void execute() throws Exception {
         log.info("同步素造素材供应商-------start");

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouReportDailyGroupChannelCodeJob.java

@@ -13,6 +13,10 @@ public class KuaishouReportDailyGroupChannelCodeJob {
     @Autowired
     private IKuaishouReportDailyGroupService groupService;
 
+    /**
+     * 快手广告组日报渠道号截取任务
+     * @throws Exception
+     */
     @XxlJob("kuaishouReportDailyGroupChannelCode")
     public void execute() throws Exception {
         String date = DateUtils.formatDate(DateUtils.addDay(new Date(), -1));

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouVideoRelateCreativesJob.java

@@ -38,6 +38,10 @@ public class KuaishouVideoRelateCreativesJob {
 
     static ExecutorService executorService = Executors.newFixedThreadPool(5);
 
+    /**
+     * 视频库-更新视频关联创意数
+     * @throws Exception
+     */
     @XxlJob("kuaishouVideoRelateCreativesJob")
     public void execute() throws Exception {
         List<CtopOauthToken> tokens = tokenService.selectKuaiShouToken();

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/RuleKuaiShouDataAccountCleanJob.java

@@ -24,6 +24,10 @@ public class RuleKuaiShouDataAccountCleanJob {
 
     private ExecutorService executorService = Executors.newFixedThreadPool(10);
 
+    /**
+     * 快手规则引擎账户数据
+     * @throws Exception
+     */
     @XxlJob("ruleKuaiShouDataAccountCleanJob")
     public void execute() throws Exception {
         XxlJobHelper.log("规则预警账户维度数据开始清洗");

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/RuleKuaiShouDataPlanCleanJob.java

@@ -22,6 +22,10 @@ public class RuleKuaiShouDataPlanCleanJob {
     private IRuleKuaiShouPlanService ruleKuaiShouPlanService;
     private ExecutorService executorService = Executors.newFixedThreadPool(10);
 
+    /**
+     * 快手规则引擎计划数据
+     * @throws Exception
+     */
     @XxlJob("ruleKuaiShouDataPlanCleanJob")
     public void execute() throws Exception {
         XxlJobHelper.log("规则预警计划维度数据开始清洗");

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/RuleKuaiShouDataTargetCleanJob.java

@@ -25,6 +25,10 @@ public class RuleKuaiShouDataTargetCleanJob {
     private IRuleDataTargetKuaishouService ruleDataTargetKuaishouService;
     private ExecutorService executorService = Executors.newFixedThreadPool(10);
 
+    /**
+     * 快手规则引擎定向数据
+     * @throws Exception
+     */
     @XxlJob("ruleKuaiShouDataTargetCleanJob")
     public void execute() throws Exception {
         XxlJobHelper.log("规则预警定向维度数据开始清洗");

+ 4 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/RuleKuaiShouDataUnitCleanJob.java

@@ -27,6 +27,10 @@ public class RuleKuaiShouDataUnitCleanJob {
 
     private ExecutorService executorService = Executors.newFixedThreadPool(10);
 
+    /**
+     * 快手规则引擎组维度数据
+     * @throws Exception
+     */
     @XxlJob("ruleKuaiShouDataUnitCleanJob")
     public void execute() throws Exception {
         XxlJobHelper.log("规则预警组维度数据开始清洗");

+ 1 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/WatermarkVideoJob.java

@@ -23,6 +23,7 @@ public class WatermarkVideoJob {
     @Autowired
     private IMaterialInfoService materialInfoService;
 
+    // TODO 待删除
     @XxlJob("videoWatermarkJob")
     public void execute() throws Exception {
         QueryWrapper<VideoWatermarkTask> queryWrapper = new QueryWrapper<>();