Browse Source

优化代理商数据清洗

zhaoxian 1 year ago
parent
commit
dda328bb8e

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

@@ -385,7 +385,7 @@ public class ByteDanceAdvertiserDataServiceImpl implements IByteDanceAdvertiserD
         config.propertyNamingStrategy = PropertyNamingStrategy.SnakeCase;
         JSONObject jsonObject = JSONObject.parseObject(JSON.toJSONString(conditions, config));
         JSONObject getObject = getAdvertiserStat(token, jsonObject);
-        System.out.println("返回结果:" + getObject);
+//        System.out.println("返回结果:" + getObject);
         if (null == getObject) {
             XxlJobHelper.log("头条广告主数据获取异常");
             log.error("头条广告主数据获取信息为空==》accountId:{}", token.getAccountId());

+ 5 - 2
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceAdvertiseLoadJob.java

@@ -77,8 +77,11 @@ public class BytedanceAdvertiseLoadJob {
                 OauthToken oauthToken = new OauthToken();
                 oauthToken.setAccessToken(token);
                 oauthToken.setAccountId(Long.valueOf(String.valueOf(accountId)));
-
-                advertiserDataService.getAdvertiserReport(oauthToken, key.replaceAll("ADVERTISER", ""), key.replaceAll("ADVERTISER", ""), CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY);
+                String time = key.replaceAll("ADVERTISER", "");
+                if(Check.isNull(time)){
+                    continue;
+                }
+                advertiserDataService.getAdvertiserReport(oauthToken, time, time, CtopAdConstant.BYTEDANCE_REPORT_TYPE_DAILY);
 
                 adAccountList = redisUtil.getList(key, null);