getAdqCreatives

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

@@ -192,14 +192,14 @@ public class BytedanceController {
     }
 
     @RequestMapping("/adq/creatives")
-    public void adqCreatives(Long accountId) {
-        cdpProjectService.getAdqCreatives(accountId, null);
+    public void adqCreatives(Long accountId,String startDate,String endDate) {
+        cdpProjectService.getAdqCreatives(accountId, startDate, endDate);
     }
 
 
     @GetMapping("/testB")
     public void testB(Long id) {
-        cdpProjectService.getAdqCreatives(id, "2025-02-15");
+        cdpProjectService.getAdqCreatives(id, "2025-02-15", "2025-02-15");
     }
 
     @GetMapping("/adqWechatPages")

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/IBytedanceCdpProjectService.java

@@ -37,7 +37,7 @@ public interface IBytedanceCdpProjectService {
 
     List<Long> queryADQAdverIds(String date);
 
-    void getAdqCreatives(Long advertiserId, String date);
+    void getAdqCreatives(Long advertiserId, String startDate,String endDate);
 
     void getAdqWechatPages(Long advertiserId,Long pageId);
 

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/BytedanceCdpProjectServiceImpl.java

@@ -435,14 +435,14 @@ public class BytedanceCdpProjectServiceImpl implements IBytedanceCdpProjectServi
     }
 
     @Override
-    public void getAdqCreatives(Long advertiserId, String date) {
+    public void getAdqCreatives(Long advertiserId, String startDate,String endDate) {
         try {
             String accessToken = tokenMapper.onlyGetADQToken(advertiserId);
             if (Check.isNull(accessToken)) {
                 log.error("账户（{}）accessToken is null", advertiserId);
                 return;
             }
-            this.rebackadqCreativesVo(advertiserId, accessToken, date, 1, true, 1);
+            this.rebackadqCreativesVo(advertiserId, accessToken, startDate, endDate, 1, true, 1);
         } catch (Exception e) {
             e.printStackTrace();
             log.error("账户（{}）获取动态创意异常", e.getMessage());
@@ -450,7 +450,7 @@ public class BytedanceCdpProjectServiceImpl implements IBytedanceCdpProjectServi
     }
 
 
-    private void rebackadqCreativesVo(Long accountId, String accessToken, String date, Integer page, Boolean isDeleted, int count) throws Exception {
+    private void rebackadqCreativesVo(Long accountId, String accessToken, String startDate, String endDate, Integer page, Boolean isDeleted, int count) throws Exception {
         boolean nextPage = false;
         JSONObject returnJson = new JSONObject();
         Map<String, Object> param = new HashMap<>();
@@ -461,13 +461,13 @@ public class BytedanceCdpProjectServiceImpl implements IBytedanceCdpProjectServi
         param.put("account_id", accountId);
         param.put("page", page);
         param.put("page_size", 100);
-        if (!Check.isNull(date)) {
+        if (!Check.isNull(startDate) && !Check.isNull(endDate)) {
             JSONArray filtering = new JSONArray();
             JSONObject greObj = new JSONObject();
             greObj.put("field", "last_modified_time");
             greObj.put("operator", "GREATER_EQUALS");
             JSONArray startDateVls = new JSONArray();
-            startDateVls.add(String.valueOf(DateUtils.dt2milli(date + " 00:00:00")));
+            startDateVls.add(String.valueOf(DateUtils.dt2milli(startDate + " 00:00:00")));
 //            startDateVls.add(String.valueOf(DateUtils.dt2milli( "2025-02-15 00:00:00")));
             greObj.put("values", startDateVls);
             filtering.add(greObj);
@@ -475,7 +475,7 @@ public class BytedanceCdpProjectServiceImpl implements IBytedanceCdpProjectServi
             lesObj.put("field", "last_modified_time");
             lesObj.put("operator", "LESS_EQUALS");
             JSONArray endDateVls = new JSONArray();
-            endDateVls.add(String.valueOf(DateUtils.dt2milli(date + " 23:59:59")));
+            endDateVls.add(String.valueOf(DateUtils.dt2milli(endDate + " 23:59:59")));
 //            endDateVls.add(String.valueOf(DateUtils.dt2milli("2025-07-09 23:59:59")));
             lesObj.put("values", endDateVls);
             filtering.add(lesObj);
@@ -517,14 +517,14 @@ public class BytedanceCdpProjectServiceImpl implements IBytedanceCdpProjectServi
             } else {
                 if (count <= 4) {
                     Thread.sleep(500);
-                    rebackadqCreativesVo(accountId, accessToken, date, page, isDeleted, count + 1);
+                    rebackadqCreativesVo(accountId, accessToken, startDate, endDate, page, isDeleted, count + 1);
                 } else {
                     log.error("账户（{}）获取动态创意失败，入参：{}\n，结果：{}", accountId, JSONObject.toJSONString(param), obj);
                 }
             }
         }
         if (nextPage) {
-            rebackadqCreativesVo(accountId, accessToken, date, page + 1, isDeleted, 1);
+            rebackadqCreativesVo(accountId, accessToken, startDate ,endDate, page + 1, isDeleted, 1);
         }
     }
 

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceCdpProjectJob.java

@@ -44,7 +44,7 @@ public class BytedanceCdpProjectJob {
         if (!Check.isNull(ids)) {
             log.info("总数：{}", ids.size());
 //            ids.forEach(id -> allService.submit(() -> cdpProjectService.getProjectList(id, null, null, null)));
-            ids.forEach(id -> createiveAppsExecutorService.submit(() -> cdpProjectService.getAdqCreatives(id, "2025-07-09")));
+            ids.forEach(id -> createiveAppsExecutorService.submit(() -> cdpProjectService.getAdqCreatives(id, "2025-07-09", "2025-07-09")));
 
 
         }
@@ -159,7 +159,7 @@ public class BytedanceCdpProjectJob {
             String today = DateUtils.getNowDate("yyyy-MM-dd");
             List<Long> ids = cdpProjectService.queryAdvertiserIds("adq_advertiser_report_hour", DateUtils.getYYMMDDTime(today));
             if (!Check.isNull(ids)) {
-                ids.forEach(id -> createiveAppsExecutorService.submit(() -> cdpProjectService.getAdqCreatives(id, today)));
+                ids.forEach(id -> createiveAppsExecutorService.submit(() -> cdpProjectService.getAdqCreatives(id, today, today)));
             }
 
             List<JSONObject> iids = cdpProjectService.queryPageAdvertiserIds();
@@ -184,13 +184,13 @@ public class BytedanceCdpProjectJob {
             String yesterday = DateUtils.getNowAddDate("yyyy-MM-dd", -1);
             List<Long> ids = cdpProjectService.queryAdvertiserIds("adq_advertiser_report_daily", DateUtils.getYYMMDDTime(yesterday));
             if (!Check.isNull(ids)) {
-                ids.forEach(id -> createiveAppsExecutorService.submit(() -> cdpProjectService.getAdqCreatives(id, yesterday)));
+                ids.forEach(id -> createiveAppsExecutorService.submit(() -> cdpProjectService.getAdqCreatives(id, yesterday, yesterday)));
             }
             //拉取前天数据
             String yesterday2 = DateUtils.getNowAddDate("yyyy-MM-dd", -2);
             List<Long> ids2 = cdpProjectService.queryAdvertiserIds("adq_advertiser_report_daily", DateUtils.getYYMMDDTime(yesterday2));
             if (!Check.isNull(ids2)) {
-                ids2.forEach(id -> createiveAppsExecutorService.submit(() -> cdpProjectService.getAdqCreatives(id, yesterday2)));
+                ids2.forEach(id -> createiveAppsExecutorService.submit(() -> cdpProjectService.getAdqCreatives(id, yesterday2, yesterday2)));
             }
         } catch (Exception e) {
             e.printStackTrace();