拉取小程序，all 补失败

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

@@ -18,7 +18,7 @@ public interface BytedanceCdpProjectMapper {
 
     void insertErrorAdvertiserId(@Param("advertiserId") Long advertiserId, @Param("type") String type);
 
-    List<Long> getAllAdverIdList();
+    List<Long> getAllAdverIdList(@Param("type") String type);
 
     List<Long> queryAdvertiserIds(@Param("db") String db, @Param("date") String date);
 

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

@@ -116,6 +116,7 @@
     <select id="getAllAdverIdList" resultType="Long">
         SELECT advertiser_id
         FROM media_api.error_advertiser
+        where type = #{type}
         order by create_time
     </select>
 

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

@@ -11,7 +11,7 @@ import java.util.List;
 public interface IBytedanceCdpProjectService {
     void getProjectList(Long advertiserId, String date);
 
-    List<Long> getAllAdverIdList();
+    List<Long> getAllAdverIdList(String type);
 
     List<Long> queryAdvertiserIds(String db, String date);
 

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

@@ -39,8 +39,8 @@ public class BytedanceCdpProjectServiceImpl implements IBytedanceCdpProjectServi
     private BytedanceRefreshTokenMapper tokenMapper;
 
     @Override
-    public List<Long> getAllAdverIdList() {
-        return bytedanceCdpProjectMapper.getAllAdverIdList();
+    public List<Long> getAllAdverIdList(String type) {
+        return bytedanceCdpProjectMapper.getAllAdverIdList(type);
     }
 
     @Override

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

@@ -36,13 +36,13 @@ public class BytedanceCdpProjectJob {
     public void getAll() {
         log.info("[getAll] 任务启动...");
         //BYTE_APP 字节小程序， WECHAT_APP：微信小程序
-        List<Long> ttList = cdpProjectService.queryMediaAdverIds(null, "BYTE_APP");
+        List<Long> ttList = cdpProjectService.getAllAdverIdList("tt");
         if (!Check.isNull(ttList)) {
             ttList.forEach(id -> allService.submit(() -> {
                 cdpProjectService.getByteAppInfo(id);
             }));
         }
-        List<Long> wxlist = cdpProjectService.queryMediaAdverIds(null, "WECHAT_APP");
+        List<Long> wxlist = cdpProjectService.getAllAdverIdList("wx");
         if (!Check.isNull(wxlist)) {
             wxlist.forEach(id -> allService2.submit(() -> {
                 cdpProjectService.getWxAppInfo(id);