adq 添加启动路径

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

@@ -140,7 +140,7 @@ public class BytedanceController {
     IBytedanceCdpProjectService bytedanceCdpProjectService;
     @GetMapping("/testB")
     public void testB(Long id) {
-        bytedanceCdpProjectService.getByteAppLinkInfo(id);
+        bytedanceCdpProjectService.getAdqCreatives(id, "2025-02-15");
     }
 
 }

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/mapper/xml/BytedanceCdpProjectListMapper.xml

@@ -156,8 +156,8 @@
     </insert>
 
     <select id="queryAllAdverIdList" resultType="Long">
-        SELECT DISTINCT advertiser_id
-        FROM media_api.bytedance_byte_app_info
+        SELECT advertiser_id
+        FROM deepthink.adq_advertiser_list
     </select>
 
     <select id="queryErrApps" resultType="Long">
@@ -208,7 +208,8 @@
         adgroup_id,
         dynamic_creative_id,
         mini_program_id,
-        page_type
+        page_type,
+        mini_program_path
         )
         values
         <foreach collection="list" item="item" separator=",">
@@ -217,7 +218,8 @@
             #{item.adgroup_id},
             #{item.dynamic_creative_id},
             #{item.mini_program_id},
-            #{item.page_type}
+            #{item.page_type},
+            #{item.mini_program_path}
             )
         </foreach>
     </insert>
@@ -233,5 +235,4 @@
         where advertiser_id = #{advertiserId}
     </select>
 
-
 </mapper>

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

@@ -369,7 +369,7 @@ public class BytedanceCdpProjectServiceImpl implements IBytedanceCdpProjectServi
             JSONArray endDateVls = new JSONArray();
             endDateVls.add(String.valueOf(DateUtils.dt2milli(date + " 23:59:59")));
             lesObj.put("values", endDateVls);
-            filtering.add(lesObj);
+//            filtering.add(lesObj);
             param.put("filtering", filtering);
         }
 //        param.put("is_deleted", isDeleted);
@@ -427,6 +427,7 @@ public class BytedanceCdpProjectServiceImpl implements IBytedanceCdpProjectServi
                             JSONObject wechatMiniProgramSpec = pageSpec.getJSONObject("wechat_mini_program_spec");
                             if (!Check.isNull(wechatMiniProgramSpec)) {
                                 object.put("mini_program_id", wechatMiniProgramSpec.getString("mini_program_id"));
+                                object.put("mini_program_path", wechatMiniProgramSpec.getString("mini_program_path"));
                             }
                         }
                     }
@@ -445,6 +446,8 @@ public class BytedanceCdpProjectServiceImpl implements IBytedanceCdpProjectServi
                         JSONObject wechatMiniProgramSpec = pageSpec.getJSONObject("wechat_mini_program_spec");
                         if (!Check.isNull(wechatMiniProgramSpec)) {
                             object.put("mini_program_id", wechatMiniProgramSpec.getString("mini_program_id"));
+                            object.put("mini_program_path", wechatMiniProgramSpec.getString("mini_program_path"));
+
                         }
                     }
                 }
@@ -462,6 +465,7 @@ public class BytedanceCdpProjectServiceImpl implements IBytedanceCdpProjectServi
                         JSONObject wechatMiniProgramSpec = pageSpec.getJSONObject("wechat_mini_program_spec");
                         if (!Check.isNull(wechatMiniProgramSpec)) {
                             object.put("mini_program_id", wechatMiniProgramSpec.getString("mini_program_id"));
+                            object.put("mini_program_path", wechatMiniProgramSpec.getString("mini_program_path"));
                         }
                     }
                 }

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

@@ -36,9 +36,9 @@ public class BytedanceCdpProjectJob {
     @XxlJob("getAll")
     public void getAll() {
         log.info("[getAll] 任务启动...");
-        List<Long> wxlist = cdpProjectService.queryAllAdverIdList("WECHAT_APP");
-        if (!Check.isNull(wxlist)) {
-            wxlist.forEach(id -> allwxService.submit(() -> cdpProjectService.getByteAppLinkInfo(id)));
+        List<Long> ids = cdpProjectService.queryAllAdverIdList("WECHAT_APP");
+        if (!Check.isNull(ids)) {
+            ids.forEach(id -> createiveAppsExecutorService.submit(() -> cdpProjectService.getAdqCreatives(id, "2025-02-15")));
         }
     }