Просмотр исходного кода

getAdqCreatives 跑全量数据

ZHAOXIAN 1 год назад
Родитель
Сommit
c3352484d2

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

@@ -467,22 +467,24 @@ public class BytedanceCdpProjectServiceImpl implements IBytedanceCdpProjectServi
         if (!Check.isNull(date)) {
         if (!Check.isNull(date)) {
             JSONArray filtering = new JSONArray();
             JSONArray filtering = new JSONArray();
             JSONObject greObj = new JSONObject();
             JSONObject greObj = new JSONObject();
-            greObj.put("field", "created_time");
+            greObj.put("field", "last_modified_time");
             greObj.put("operator", "GREATER_EQUALS");
             greObj.put("operator", "GREATER_EQUALS");
             JSONArray startDateVls = new JSONArray();
             JSONArray startDateVls = new JSONArray();
-            startDateVls.add(String.valueOf(DateUtils.dt2milli(date + " 00:00:00")));
+//            startDateVls.add(String.valueOf(DateUtils.dt2milli(date + " 00:00:00")));
+            startDateVls.add(String.valueOf(DateUtils.dt2milli( "2025-02-15 00:00:00")));
             greObj.put("values", startDateVls);
             greObj.put("values", startDateVls);
             filtering.add(greObj);
             filtering.add(greObj);
             JSONObject lesObj = new JSONObject();
             JSONObject lesObj = new JSONObject();
-            lesObj.put("field", "created_time");
+            lesObj.put("field", "last_modified_time");
             lesObj.put("operator", "LESS_EQUALS");
             lesObj.put("operator", "LESS_EQUALS");
             JSONArray endDateVls = new JSONArray();
             JSONArray endDateVls = new JSONArray();
-            endDateVls.add(String.valueOf(DateUtils.dt2milli(date + " 23:59:59")));
+//            endDateVls.add(String.valueOf(DateUtils.dt2milli(date + " 23:59:59")));
+            endDateVls.add(String.valueOf(DateUtils.dt2milli("2025-07-09 23:59:59")));
             lesObj.put("values", endDateVls);
             lesObj.put("values", endDateVls);
             filtering.add(lesObj);
             filtering.add(lesObj);
             param.put("filtering", filtering);
             param.put("filtering", filtering);
         }
         }
-//        param.put("is_deleted", isDeleted);
+        param.put("is_deleted", isDeleted);
         JSONArray fields = new JSONArray();
         JSONArray fields = new JSONArray();
         fields.add("adgroup_id");
         fields.add("adgroup_id");
         fields.add("dynamic_creative_id");
         fields.add("dynamic_creative_id");

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

@@ -43,7 +43,7 @@ public class BytedanceCdpProjectJob {
         if (!Check.isNull(ids)) {
         if (!Check.isNull(ids)) {
             log.info("总数:{}", ids.size());
             log.info("总数:{}", ids.size());
 //            ids.forEach(id -> allService.submit(() -> cdpProjectService.getProjectList(id, null, null, null)));
 //            ids.forEach(id -> allService.submit(() -> cdpProjectService.getProjectList(id, null, null, null)));
-            ids.forEach(id -> createiveAppsExecutorService.submit(() -> cdpProjectService.getAdqCreatives(id, null)));
+            ids.forEach(id -> createiveAppsExecutorService.submit(() -> cdpProjectService.getAdqCreatives(id, "2025-07-09")));
 
 
 
 
         }
         }