瀏覽代碼

Merge #3 into master from pingkang

adq产品报表

* pingkang: (2 commits)
  adq产品报表
  adq产品报表

Signed-off-by: 1129979389@qq.com <accounts_6361eaad7b63b44dd7833e63@mail.teambition.com>
Merged-by: 1129979389@qq.com <accounts_6361eaad7b63b44dd7833e63@mail.teambition.com>

CR-link: https://codeup.aliyun.com/60c06368dbbed34fe0f0c263/job/hr_job-adq/change/3
huangpingkang 1 年之前
父節點
當前提交
0442069bbb

+ 9 - 6
job-adq/src/main/java/cn/com/ctop/job/adq/data/service/impl/AdqAssetReportServiceImpl.java

@@ -64,10 +64,13 @@ public class AdqAssetReportServiceImpl implements IAdqAssetReportService {
                                 report.setStatTimeDay(Integer.valueOf(dataJson.getString("date").replace("-", "")));
                                 dailies.add(report);
 
-                                String marketingTargetType = report.getMarketingTargetType();
-                                Set<String> orDefault = assetIdsMap.getOrDefault(marketingTargetType, new HashSet<>());
-                                orDefault.add(report.getMarketingAssetId().toString());
-                                assetIdsMap.put(marketingTargetType, orDefault);
+                                Long marketingAssetId = report.getMarketingAssetId();
+                                if (!Check.isNull(marketingAssetId)) {
+                                    String marketingTargetType = report.getMarketingTargetType();
+                                    Set<String> orDefault = assetIdsMap.getOrDefault(marketingTargetType, new HashSet<>());
+                                    orDefault.add(marketingAssetId.toString());
+                                    assetIdsMap.put(marketingTargetType, orDefault);
+                                }
                             }
                         }
                     }
@@ -90,7 +93,7 @@ public class AdqAssetReportServiceImpl implements IAdqAssetReportService {
             if (page < totalPage) {
                 getAdqAssetDailyReport(advertiserId, accessToken, startDate, endDate, page + 1, isLog, errId, isSend);
             } else {
-                log.error("请求产品日报完成,account_id:{},日期:{}{}", advertiserId, startDate, endDate);
+                log.info("请求产品日报完成,account_id:{},日期:{}~{}", advertiserId, startDate, endDate);
                 if (errId != null) {
                     adqErrorLogMapper.deleteInfoByErrorId(errId);
                 }
@@ -208,7 +211,7 @@ public class AdqAssetReportServiceImpl implements IAdqAssetReportService {
                 }
 
                 if (page == totalPage) {
-                    log.error("请求产品信息列表完成,account_id:{}, assetIds:{} ", advertiserId, assetIds);
+                    log.info("请求产品信息列表完成,account_id:{}, assetIds:{} ", advertiserId, assetIds);
                     if (errId != null) {
                         adqErrorLogMapper.deleteInfoByErrorId(errId);
                     }