zhouzeyu@c-top.com.cn 3 роки тому
батько
коміт
65e34993e1

+ 1 - 1
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/IBytedanceCampaignGetService.java

@@ -13,6 +13,6 @@ import com.baomidou.mybatisplus.extension.service.IService;
  */
 public interface IBytedanceCampaignGetService  {
 
-    void getCampaignData(OauthToken oauthToken, int pageNumber, int PageSize);
+    void getCampaignData(OauthToken oauthToken, String startDate,String endDate,int pageNumber, int PageSize);
 
 }

+ 6 - 3
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/BytedanceCampaignGetServiceImpl.java

@@ -32,14 +32,17 @@ public class BytedanceCampaignGetServiceImpl implements IBytedanceCampaignGetSer
     BytedanceCampaignGetMapper bytedanceCampaignGetMapper;
 
     @Override
-    public void getCampaignData(OauthToken oauthToken, int pageNumber, int pageSize) {
-        log.info("开始获取广告组全量数据 accountIDL{},page:{}",oauthToken.getAccountId(),pageNumber);
+    public void getCampaignData(OauthToken oauthToken, String startDate, String endDate, int pageNumber, int pageSize) {
+        log.info("开始获取广告组全量数据 accountIDL{},page:{}", oauthToken.getAccountId(), pageNumber);
         // 请求地址
         String url = bytedanceApiUrl + BytedanceConstant.BYTEDANCE_V2_CAMPAIGN_GET;
         JSONObject param = new JSONObject();
         param.put("advertiser_id", oauthToken.getAccountId());
         param.put("page", pageNumber);
         param.put("page_size", pageSize);
+        JSONObject param2 = new JSONObject();
+        param2.put("campaign_create_time", startDate);
+        param.put("filtering", param2);
         JSONObject resultObject = HttpUtils.bytedanceGetRequest(oauthToken.getAccessToken(), url, param);
 
         Integer code = resultObject.getInteger("code");
@@ -64,7 +67,7 @@ public class BytedanceCampaignGetServiceImpl implements IBytedanceCampaignGetSer
         pageNumber++;
         int totalPage = resultObject.getJSONObject("data").getJSONObject("page_info").getInteger("total_page");
         if (pageNumber <= totalPage) {
-            getCampaignData(oauthToken, pageNumber, 1000);
+            getCampaignData(oauthToken, startDate, endDate, pageNumber, 1000);
         }
     }
 

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

@@ -57,10 +57,14 @@ public class BytedanceCampaignLoadJob {
             log.error("此账户未获取到相关token,accountId:{}", param);
             return;
         }
+        String nowDate = DateUtils.getNowDate("yyyy-MM-dd");
+        String yesterda = DateUtils.getAnotherDay("yyyy-MM-dd", nowDate, -1);
+        String yesterda2 = DateUtils.getAnotherDay("yyyy-MM-dd", nowDate, -2);
         OauthToken oauthToken = new OauthToken();
         oauthToken.setAccessToken(token);
         oauthToken.setAccountId(Long.parseLong(param));
-        campaignDataService.getCampaignData(oauthToken, 1, 1000);
+        campaignDataService.getCampaignData(oauthToken, yesterda,yesterda,1, 1000);
+        campaignDataService.getCampaignData(oauthToken, yesterda2,yesterda2,1, 1000);
     }
 
     /**