微小 添加path

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

@@ -18,7 +18,9 @@ public interface BytedanceCdpProjectMapper {
 
     void insertErrorAdvertiserId(@Param("advertiserId") Long advertiserId, @Param("type") String type);
 
-    List<Long> getAllAdverIdList(@Param("type") String type);
+    List<Long> queryAllAdverIdList(@Param("mediaType") String mediaType);
+
+    List<Long> queryErrApps(@Param("type") String type);
 
     boolean delErrApps(@Param("type") String type);
 

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

@@ -91,7 +91,8 @@
         advertiser_id,
         app_name,
         user_nme,
-        instance_id
+        instance_id,
+        `path`
         )
         values
         <foreach collection="list" item="item" separator=",">
@@ -99,7 +100,8 @@
             #{advertiserId},
             #{item.name},
             #{item.user_name},
-            #{item.instance_id}
+            #{item.instance_id},
+            #{item.path}
             )
         </foreach>
     </insert>
@@ -113,7 +115,13 @@
         )
     </insert>
 
-    <select id="getAllAdverIdList" resultType="Long">
+    <select id="queryAllAdverIdList" resultType="Long">
+        SELECT DISTINCT advertiser_id
+        FROM media_api.bytedance_cdp_project_list
+        where micro_promotion_type = #{mediaType}
+    </select>
+
+    <select id="queryErrApps" resultType="Long">
         SELECT advertiser_id
         FROM media_api.error_advertiser
         where type = #{type}
@@ -123,7 +131,7 @@
     <delete id="delErrApps">
         DELETE
         FROM media_api.error_advertiser
-        WHERE type =#{type}
+        WHERE type = #{type}
     </delete>
 
 

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

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

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

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

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

@@ -36,21 +36,29 @@ public class BytedanceCdpProjectJob {
     @XxlJob("getAll")
     public void getAll() {
         log.info("[getAll] 任务启动...");
-        List<Long> ttList = cdpProjectService.getAllAdverIdList("tt");
+        List<Long> wxlist = cdpProjectService.queryAllAdverIdList("WECHAT_APP");
+        if (!Check.isNull(wxlist)) {
+            wxlist.forEach(id -> allwxService.submit(() -> cdpProjectService.getWxAppInfo(id)));
+        }
+    }
+
+    @XxlJob("errAppAgain")
+    public void errAppAgain() {
+        log.info("[errAppAgain] 任务启动...");
+        List<Long> ttList = cdpProjectService.queryAllAdverIdList("tt");
         if (!Check.isNull(ttList)) {
             if (cdpProjectService.delErrApps("tt"))
-                log.info("[getAll] ---移除抖小失败记录");
+                log.info("[errAppAgain] ---移除抖小失败记录");
             ttList.forEach(id -> allttService.submit(() -> cdpProjectService.getByteAppInfo(id)));
         }
-        List<Long> wxlist = cdpProjectService.getAllAdverIdList("wx");
+        List<Long> wxlist = cdpProjectService.queryAllAdverIdList("wx");
         if (!Check.isNull(wxlist)) {
             if (cdpProjectService.delErrApps("wx"))
-                log.info("[getAll] ---移除微小失败记录");
+                log.info("[errAppAgain] ---移除微小失败记录");
             wxlist.forEach(id -> allwxService.submit(() -> cdpProjectService.getWxAppInfo(id)));
         }
     }
 
-
     @XxlJob("nowProjects")
     public void nowProjects() {
         log.info("[nowProjects] 任务启动...");