wangyunpeng 2 months ago
parent
commit
3309b64605

+ 1 - 0
api-module/src/main/java/com/tzld/piaoquan/api/job/ContentPlatformDatastatJob.java

@@ -614,6 +614,7 @@ public class ContentPlatformDatastatJob {
             List<String> channels = saveList.stream().map(ContentPlatformQwDataStatTotal::getChannel).distinct().collect(Collectors.toList());
             List<ContentPlatformQwDataStatTotal> channelScoreList = dataStatMapperExt.getQwTotalDatastatScoreList(dt, channels);
             Map<String, Double> channelScoreMap = channelScoreList.stream()
+                    .filter(o -> Objects.nonNull(o.getChannel()) && Objects.nonNull(o.getScore()))
                     .collect(Collectors.toMap(ContentPlatformQwDataStatTotal::getChannel, ContentPlatformQwDataStatTotal::getScore, (a, b) -> a));
             for (ContentPlatformQwDataStatTotal item : saveList) {
                 item.setScore(channelScoreMap.get(item.getChannel()));