Pārlūkot izejas kodu

adq产品报表

huangpingkang 1 gadu atpakaļ
vecāks
revīzija
94ef29b506

+ 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);
                     }