添加字节广告列表

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

@@ -93,10 +93,10 @@ public class BytedanceCdpProjectServiceImpl implements IBytedanceCdpProjectServi
             Map<String, Object> params = new HashMap<>();
             params.put("advertiser_id", advertiserId);
             JSONObject filtering = new JSONObject();
-//            filtering.put("promotion_modify_time", date);
-//            params.put("filtering", filtering);
+            filtering.put("promotion_modify_time", date);
+            params.put("filtering", filtering);
             params.put("page", page);
-            params.put("page_size", 20);//最大100
+            params.put("page_size", 20);//最大20
             String url = "https://api.oceanengine.com/open_api/v3.0/promotion/list/";
             String results = HttpUtils.httpGet(url, params, HttpUtils.postMHeaders(accessToken));
             JSONObject obj = JSONObject.parseObject(results);
@@ -215,7 +215,6 @@ public class BytedanceCdpProjectServiceImpl implements IBytedanceCdpProjectServi
     public void getByteAppInfo(Long advertiserId) {
         this.getByteAppInfoVo(advertiserId, "CREATE_ONLY", 1, 1);
         this.getByteAppInfoVo(advertiserId, "SHARE_ONLY", 1, 1);
-        this.getByteAppLinkInfo(advertiserId);
     }
 
     private void getByteAppInfoVo(Long advertiserId, String searchType, Integer page, int count) {

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

@@ -30,6 +30,7 @@ public class BytedanceCdpProjectJob {
     private static ExecutorService allt2Service = Executors.newFixedThreadPool(2);
 
     private static ExecutorService projectExecutorService = Executors.newFixedThreadPool(3);
+    private static ExecutorService promExecutorService = Executors.newFixedThreadPool(3);
     private static ExecutorService ttAppsExecutorService = Executors.newFixedThreadPool(3);
     private static ExecutorService wxAppsExecutorService = Executors.newFixedThreadPool(3);
     private static ExecutorService createiveAppsExecutorService = Executors.newFixedThreadPool(3);
@@ -61,13 +62,6 @@ public class BytedanceCdpProjectJob {
                 log.info("[errAppAgain] ---移除微小失败记录");
             wxlist.forEach(id -> allwxService.submit(() -> cdpProjectService.getWxAppInfo(id)));
         }
-
-        List<Long> tt2list = cdpProjectService.queryTTErrApps();
-        if (!Check.isNull(tt2list)) {
-            if (cdpProjectService.delTTErrApps())
-                log.info("[errAppAgain] ---移除抖小详情失败记录");
-            tt2list.forEach(id -> allt2Service.submit(() -> cdpProjectService.getByteAppLinkInfo(id)));
-        }
     }
 
     @XxlJob("nowProjects")
@@ -79,6 +73,7 @@ public class BytedanceCdpProjectJob {
             List<Long> nowAdIds = cdpProjectService.queryAdvertiserIds("bytedance_advertiser_report_hour", DateUtils.getYYMMDDTime(today));
             if (!Check.isNull(nowAdIds)) {
                 nowAdIds.forEach(id -> projectExecutorService.submit(() -> cdpProjectService.getProjectList(id, today)));
+                nowAdIds.forEach(id -> promExecutorService.submit(() -> cdpProjectService.getpromotionList(id, today)));
             }
         } catch (Exception e) {
             e.printStackTrace();
@@ -95,12 +90,14 @@ public class BytedanceCdpProjectJob {
             List<Long> adIds = cdpProjectService.queryAdvertiserIds("bytedance_advertiser_report_daily", DateUtils.getYYMMDDTime(yesterday));
             if (!Check.isNull(adIds)) {
                 adIds.forEach(id -> projectExecutorService.submit(() -> cdpProjectService.getProjectList(id, yesterday)));
+                adIds.forEach(id -> promExecutorService.submit(() -> cdpProjectService.getpromotionList(id, yesterday)));
             }
             //拉取前天数据
             String yesterday2 = DateUtils.getNowAddDate("yyyy-MM-dd", -2);
             List<Long> adIds2 = cdpProjectService.queryAdvertiserIds("bytedance_advertiser_report_daily", DateUtils.getYYMMDDTime(yesterday2));
             if (!Check.isNull(adIds2)) {
                 adIds2.forEach(id -> projectExecutorService.submit(() -> cdpProjectService.getProjectList(id, yesterday2)));
+                adIds2.forEach(id -> promExecutorService.submit(() -> cdpProjectService.getpromotionList(id, yesterday2)));
             }
         } catch (Exception e) {
             e.printStackTrace();