From db637cf894917d0de7ae27c44f973a8112cdc044 Mon Sep 17 00:00:00 2001
From: wujingtao <wujingtao_t@126.com>
Date: Wed, 15 Feb 2023 10:07:06 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=B7=B2=E7=9F=A5bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/baiye/task/ReportSync.java            | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/ad-platform-services/ad-platform-source/src/main/java/com/baiye/task/ReportSync.java b/ad-platform-services/ad-platform-source/src/main/java/com/baiye/task/ReportSync.java
index 370df03a..ab6a8240 100644
--- a/ad-platform-services/ad-platform-source/src/main/java/com/baiye/task/ReportSync.java
+++ b/ad-platform-services/ad-platform-source/src/main/java/com/baiye/task/ReportSync.java
@@ -6,7 +6,6 @@ import cn.hutool.core.util.NumberUtil;
 import com.baiye.constant.DefaultNumberConstants;
 import com.baiye.constant.SourceLabelConstants;
 import com.baiye.feign.UserClient;
-import com.baiye.model.dto.HomePageReportDTO;
 import com.baiye.module.dao.ClueJpa;
 import com.baiye.module.dao.ClueTalkRepository;
 import com.baiye.module.dao.ReportTokerCallRepository;
@@ -60,7 +59,10 @@ public class ReportSync {
     public List<ReportToker> dealData(List<ClueTalk> clueTalks) {
         List<ReportToker> list = new ArrayList<>();
         //按人员id分组
-        HashMap<Long, List<ClueTalk>> mapByUserId = new HashMap<>(clueTalks.stream().collect(Collectors.groupingBy(ClueTalk::getMemberId, Collectors.toList())));
+//        HashMap<Long, List<ClueTalk>> mapByUserId = new HashMap<>(clueTalks.stream().collect(Collectors.groupingBy(ClueTalk::getMemberId, Collectors.toList())));
+
+        HashMap<Long, List<ClueTalk>> mapByUserId = new HashMap<>(clueTalks.stream()
+                .filter(item -> item.getMemberId() != null).collect(Collectors.groupingBy(ClueTalk::getMemberId)));
         Set<Long> userIds = mapByUserId.keySet();
         Map<Long, String> userNameList = userClient.findById(userIds);
         for (Long memberId : mapByUserId.keySet()) {