Bläddra i källkod

定时任务日报增加前一日

zhouzeyu@c-top.com.cn 4 år sedan
förälder
incheckning
30c61dd945

+ 3 - 3
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/BytedanceCreativeReportDailyServiceImpl.java

@@ -17,7 +17,7 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 /**
- * 获取定向包
+ * 广告创意
  *
  * @author jeecg-boot
  * 2021-10-22
@@ -52,7 +52,7 @@ public class BytedanceCreativeReportDailyServiceImpl extends ServiceImpl<Bytedan
 
         Integer code = resultObject.getInteger("code");
         if (null == code || !code.equals(0)) {
-            log.error("获取广告计划接口异常==》accountId:{},message:{}", oauthToken.getAccountId(), resultObject.getString("message"));
+            log.error("获取广告创意接口异常==》accountId:{},message:{}", oauthToken.getAccountId(), resultObject.getString("message"));
             return;
         }
         JSONArray data = resultObject.getJSONObject("data").getJSONArray("list");
@@ -74,7 +74,7 @@ public class BytedanceCreativeReportDailyServiceImpl extends ServiceImpl<Bytedan
                         .eq("campaign_id", report.getCampaignId())
                         .eq("ad_id", report.getAdId())
                         .eq("creative_id", report.getCreativeId())
-                        .eq("stat_datetime", report.getCampaignId());
+                        .eq("stat_datetime", report.getStatDatetime());
                 this.update(report, updateWrapper);
             } else {
                 this.save(report);

+ 3 - 3
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/BytedanceCreativeReportHourlyServiceImpl.java

@@ -17,7 +17,7 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 /**
- * 获取定向包
+ * 广告创意
  *
  * @author jeecg-boot
  * 2021-10-22
@@ -52,7 +52,7 @@ public class BytedanceCreativeReportHourlyServiceImpl extends ServiceImpl<Byteda
 
         Integer code = resultObject.getInteger("code");
         if (null == code || !code.equals(0)) {
-            log.error("获取广告计划接口异常==》accountId:{},message:{}", oauthToken.getAccountId(), resultObject.getString("message"));
+            log.error("获取广告创意接口异常==》accountId:{},message:{}", oauthToken.getAccountId(), resultObject.getString("message"));
             return;
         }
         JSONArray data = resultObject.getJSONObject("data").getJSONArray("list");
@@ -76,7 +76,7 @@ public class BytedanceCreativeReportHourlyServiceImpl extends ServiceImpl<Byteda
                         .eq("ad_id", report.getAdId())
                         .eq("creative_id", report.getCreativeId())
                         .eq("hour", report.getHour())
-                        .eq("stat_datetime", report.getCampaignId());
+                        .eq("stat_datetime", report.getStatDatetime());
                 this.update(report, updateWrapper);
             } else {
                 this.save(report);

+ 3 - 2
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceAdvertiseLoadJob.java

@@ -34,7 +34,6 @@ public class BytedanceAdvertiseLoadJob {
     private IByteDanceAdvertiserDataService advertiserDataService;
 
 
-
     /**
      * 广告主日报
      *
@@ -57,12 +56,14 @@ public class BytedanceAdvertiseLoadJob {
         oauthToken.setAccountId(Long.parseLong(param));
         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);
         dailyExecutorService.submit(
                 new Runnable() {
                     @Override
                     public void run() {
                         advertiserDataService.getAdvertiserReport(oauthToken, yesterda, yesterda, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY);
-                   }
+                        advertiserDataService.getAdvertiserReport(oauthToken, yesterda2, yesterda2, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY);
+                    }
                 });
     }
 

+ 2 - 4
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceAgentLoadJob.java

@@ -4,9 +4,7 @@ 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.IByteDanceAdvertiserDataService;
 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;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -46,6 +44,7 @@ public class BytedanceAgentLoadJob {
         List<Long> agentByTouTiao = tokenService.getAgentByTouTiao();
         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);
         for (Long aLong : agentByTouTiao) {
             String token = tokenService.getByAccountId(Long.valueOf(aLong));
             OauthToken oauthToken = new OauthToken();
@@ -56,6 +55,7 @@ public class BytedanceAgentLoadJob {
                         @Override
                         public void run() {
                             advertiserDataService.getAgentReport(oauthToken, yesterda, yesterda, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY);
+                            advertiserDataService.getAgentReport(oauthToken, yesterda2, yesterda2, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY);
                         }
                     });
         }
@@ -90,7 +90,5 @@ public class BytedanceAgentLoadJob {
         }
 
 
-
-
     }
 }

+ 11 - 5
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceCampaignLoadJob.java

@@ -2,7 +2,10 @@ 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.*;
+import cn.com.ctop.job.bytedance.data.service.IBytedanceCampaignGetService;
+import cn.com.ctop.job.bytedance.data.service.IBytedanceCampaignReportDailyService;
+import cn.com.ctop.job.bytedance.data.service.IBytedanceCampaignReportHourlyService;
+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;
@@ -35,6 +38,7 @@ public class BytedanceCampaignLoadJob {
     IBytedanceCampaignReportDailyService campaignReportDailyService;
     @Autowired
     IBytedanceCampaignReportHourlyService campaignReportHourlyService;
+
     /**
      * 获取广告计划列表信息
      *
@@ -56,7 +60,7 @@ public class BytedanceCampaignLoadJob {
         OauthToken oauthToken = new OauthToken();
         oauthToken.setAccessToken(token);
         oauthToken.setAccountId(Long.parseLong(param));
-        campaignDataService.getCampaignData(oauthToken,1,1000);
+        campaignDataService.getCampaignData(oauthToken, 1, 1000);
     }
 
     /**
@@ -81,11 +85,13 @@ public class BytedanceCampaignLoadJob {
         oauthToken.setAccountId(Long.parseLong(param));
         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);
         dailyExecutorService.submit(
                 new Runnable() {
                     @Override
                     public void run() {
-                        campaignReportDailyService.getCampaignDailyReport(oauthToken, yesterda, yesterda, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY,1,1000);
+                        campaignReportDailyService.getCampaignDailyReport(oauthToken, yesterda, yesterda, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY, 1, 1000);
+                        campaignReportDailyService.getCampaignDailyReport(oauthToken, yesterda2, yesterda2, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY, 1, 1000);
                     }
                 });
     }
@@ -122,9 +128,9 @@ public class BytedanceCampaignLoadJob {
                     @Override
                     public void run() {
                         if ("00".equals(hour)) {
-                            campaignReportHourlyService.getCampaignHourlyReport(oauthToken, yesterda, yesterda, CtopAdConstant.BYTEDANCE_REPORT_TYPE_HOURLY,1,1000);
+                            campaignReportHourlyService.getCampaignHourlyReport(oauthToken, yesterda, yesterda, CtopAdConstant.BYTEDANCE_REPORT_TYPE_HOURLY, 1, 1000);
                         }
-                        campaignReportHourlyService.getCampaignHourlyReport(oauthToken, nowDate, nowDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_HOURLY,1,1000);
+                        campaignReportHourlyService.getCampaignHourlyReport(oauthToken, nowDate, nowDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_HOURLY, 1, 1000);
                     }
                 });
     }

+ 14 - 8
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceCreativeLoadJob.java

@@ -2,7 +2,10 @@ 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.*;
+import cn.com.ctop.job.bytedance.data.service.IBytedanceCreativeGetService;
+import cn.com.ctop.job.bytedance.data.service.IBytedanceCreativeReportDailyService;
+import cn.com.ctop.job.bytedance.data.service.IBytedanceCreativeReportHourlyService;
+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;
@@ -35,8 +38,9 @@ public class BytedanceCreativeLoadJob {
     IBytedanceCreativeReportDailyService creativeReportDailyService;
     @Autowired
     IBytedanceCreativeReportHourlyService creativeReportHourlyService;
+
     /**
-     * 获取广告计划列表信息
+     * 获取广告创意列表信息
      *
      * @throws Exception
      */
@@ -56,11 +60,11 @@ public class BytedanceCreativeLoadJob {
         OauthToken oauthToken = new OauthToken();
         oauthToken.setAccessToken(token);
         oauthToken.setAccountId(Long.parseLong(param));
-        creativeGetService.getCreativeData(oauthToken,1,1000);
+        creativeGetService.getCreativeData(oauthToken, 1, 1000);
     }
 
     /**
-     * 广告日报
+     * 广告创意日报
      *
      * @throws Exception
      */
@@ -81,17 +85,19 @@ public class BytedanceCreativeLoadJob {
         oauthToken.setAccountId(Long.parseLong(param));
         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);
         dailyExecutorService.submit(
                 new Runnable() {
                     @Override
                     public void run() {
-                        creativeReportDailyService.getCreativeDailyReport(oauthToken, yesterda, yesterda, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY,1,1000);
+                        creativeReportDailyService.getCreativeDailyReport(oauthToken, yesterda, yesterda, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY, 1, 1000);
+                        creativeReportDailyService.getCreativeDailyReport(oauthToken, yesterda2, yesterda2, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY, 1, 1000);
                     }
                 });
     }
 
     /**
-     * 广告时报
+     * 广告创意时报
      *
      * @throws Exception
      */
@@ -122,9 +128,9 @@ public class BytedanceCreativeLoadJob {
                     @Override
                     public void run() {
                         if ("00".equals(hour)) {
-                            creativeReportHourlyService.getCampaignHourlyReport(oauthToken, yesterda, yesterda, CtopAdConstant.BYTEDANCE_REPORT_TYPE_HOURLY,1,1000);
+                            creativeReportHourlyService.getCampaignHourlyReport(oauthToken, yesterda, yesterda, CtopAdConstant.BYTEDANCE_REPORT_TYPE_HOURLY, 1, 1000);
                         }
-                        creativeReportHourlyService.getCampaignHourlyReport(oauthToken, nowDate, nowDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_HOURLY,1,1000);
+                        creativeReportHourlyService.getCampaignHourlyReport(oauthToken, nowDate, nowDate, CtopAdConstant.BYTEDANCE_REPORT_TYPE_HOURLY, 1, 1000);
                     }
                 });
     }