yumeng 2 месяцев назад
Родитель
Сommit
3d59f2240e

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

@@ -61,7 +61,7 @@ public class BytedanceProjectServiceImpl implements IBytedanceProjectService {
             param.put("page", page);
             param.put("page_size", 100);
             JSONObject filtering = new JSONObject();
-            filtering.put("project_modify_time", startDate);
+            // filtering.put("project_modify_time", startDate);
             filtering.put("project_create_time", startDate);
             param.put("filtering", filtering);
 

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

@@ -84,7 +84,7 @@ public class BytedancePromotionListServiceImpl implements IBytedancePromotionLis
         pageNumber++;
         int totalPage = resultObject.getJSONObject("data").getJSONObject("page_info").getInteger("total_page");
         if (pageNumber <= totalPage) {
-            getPromotionList(oauthToken, startDate, endDate, pageNumber, 10);
+            getPromotionList(oauthToken, startDate, endDate, pageNumber , pageSize);
         }
     }
 

+ 34 - 5
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceProjectJob.java

@@ -34,8 +34,8 @@ public class BytedanceProjectJob {
     /**
      * 获取项目列表
      */
-    @XxlJob("getV3Project")
-    public void getV3Project() throws Exception {
+    @XxlJob("getNowDateV3Project")
+    public void getNowDateV3Project() throws Exception {
         String param = XxlJobHelper.getJobParam(); // 执行参数
         if (Check.isNull(param)) {
             log.error("入参为空");
@@ -51,21 +51,50 @@ public class BytedanceProjectJob {
         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() {
                         projectService.getProjectList(oauthToken, nowDate, nowDate, 1);
+
+                    }
+                });
+    }
+
+
+
+    @XxlJob("getYesDateV3Project")
+    public void getYesDateV3Project() throws Exception {
+        String param = XxlJobHelper.getJobParam(); // 执行参数
+        if (Check.isNull(param)) {
+            log.error("入参为空");
+            return;
+        }
+        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));
+
+        String nowDate = DateUtils.getNowDate("yyyy-MM-dd");
+        String yesterda = DateUtils.getAnotherDay("yyyy-MM-dd", nowDate, -1);
+
+        dailyExecutorService.submit(
+                new Runnable() {
+                    @Override
+                    public void run() {
                         projectService.getProjectList(oauthToken, yesterda, yesterda, 1);
-                        projectService.getProjectList(oauthToken, yesterda2, yesterda2, 1);
+
                     }
                 });
 
 
     }
 
+
     /**
      * 计划转化目标、转化出价预警
      *

+ 33 - 7
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedancePromotionJob.java

@@ -41,8 +41,8 @@ public class BytedancePromotionJob {
      *
      * @throws Exception
      */
-    @XxlJob("getPromotionList")
-    public void getPromotionList() throws Exception {
+    @XxlJob("getNowDatePromotionList")
+    public void getNowDatePromotionList() throws Exception {
         String param = XxlJobHelper.getJobParam(); // 执行参数
         if (Check.isNull(param)) {
             log.error("入参为空");
@@ -60,18 +60,44 @@ public class BytedancePromotionJob {
         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);
+
         dailyExecutorService.submit(
                 new Runnable() {
                     @Override
                     public void run() {
-                        promotionListService.getPromotionList(oauthToken, yesterda, yesterda, 1,10);
-                        promotionListService.getPromotionList(oauthToken, yesterda2, yesterda2, 1,10);
-                        promotionListService.getPromotionList(oauthToken, yesterda3, yesterda3, 1,10);
+                        promotionListService.getPromotionList(oauthToken, nowDate, nowDate, 1,20);
                     }
                 });
+    }
 
 
-    }
 
+    @XxlJob("getYesDatePromotionList")
+    public void getYesDatePromotionList() throws Exception {
+        String param = XxlJobHelper.getJobParam(); // 执行参数
+        if (Check.isNull(param)) {
+            log.error("入参为空");
+            return;
+        }
+        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));
+
+        String nowDate = DateUtils.getNowDate("yyyy-MM-dd");
+        String yesterda = DateUtils.getAnotherDay("yyyy-MM-dd", nowDate, -1);
+
+
+        dailyExecutorService.submit(
+                new Runnable() {
+                    @Override
+                    public void run() {
+                        promotionListService.getPromotionList(oauthToken, yesterda, yesterda, 1,20);
+                    }
+                });
+    }
 }