Parcourir la source

修改定时任务

zhouzeyu@c-top.com.cn il y a 3 ans
Parent
commit
5fded4db61

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

@@ -12,5 +12,5 @@ import com.baomidou.mybatisplus.extension.service.IService;
  */
 public interface IBytedanceCreativeGetService  {
 
-    void getCreativeData(OauthToken oauthToken, int page, int pageSize);
+    void getCreativeData(OauthToken oauthToken, String startDate,String endDate,int page, int pageSize);
 }

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

@@ -32,7 +32,7 @@ public class BytedanceCreativeGetServiceImpl implements IBytedanceCreativeGetSer
     BytedanceCreativeGetMapper bytedanceCreativeGetMapper;
 
     @Override
-    public void getCreativeData(OauthToken oauthToken, int page, int pageSize) {
+    public void getCreativeData(OauthToken oauthToken, String startDate, String endDate, int page, int pageSize) {
         log.info("开始获取创意数据 accountID:{},page:{}", oauthToken.getAccountId(), page);
         // 请求地址
         String url = bytedanceApiUrl + BytedanceConstant.BYTEDANCE_V2_CREATIVE_GET;
@@ -40,6 +40,10 @@ public class BytedanceCreativeGetServiceImpl implements IBytedanceCreativeGetSer
         param.put("advertiser_id", oauthToken.getAccountId());
         param.put("page", page);
         param.put("page_size", pageSize);
+        JSONObject param2 = new JSONObject();
+        param2.put("creative_modify_time", startDate);
+        param.put("filtering", param2);
+
         JSONObject resultObject = HttpUtils.bytedanceGetRequest(oauthToken.getAccessToken(), url, param);
 
         Integer code = resultObject.getInteger("code");
@@ -61,7 +65,7 @@ public class BytedanceCreativeGetServiceImpl implements IBytedanceCreativeGetSer
         page++;
         int totalPage = resultObject.getJSONObject("data").getJSONObject("page_info").getInteger("total_page");
         if (page <= totalPage) {
-            getCreativeData(oauthToken, page, 1000);
+            getCreativeData(oauthToken, startDate, endDate, page, 1000);
         }
 
     }

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

@@ -57,10 +57,14 @@ public class BytedanceCreativeLoadJob {
             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));
-        creativeGetService.getCreativeData(oauthToken, 1, 1000);
+        creativeGetService.getCreativeData(oauthToken, yesterda, yesterda, 1, 1000);
+        creativeGetService.getCreativeData(oauthToken, yesterda2, yesterda2, 1, 1000);
     }
 
     /**