From 9c95d740d203e53d7d141cbcfbe45e780920e391 Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Tue, 3 Sep 2024 20:19:58 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E6=81=AF=E6=8E=A8=E9=80=81=E8=BF=87?=
 =?UTF-8?q?=E6=BB=A4null=E5=80=BC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/njcn/zlevent/utils/SendEventUtils.java | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/utils/SendEventUtils.java b/iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/utils/SendEventUtils.java
index fe41e74..089c7c4 100644
--- a/iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/utils/SendEventUtils.java
+++ b/iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/utils/SendEventUtils.java
@@ -222,7 +222,14 @@ public class SendEventUtils {
             payload.setPath("/pages/message/message?type="+payload.getType());
             noticeUserDto.setPayload(payload);
         }
-        sendEventToUser(noticeUserDto);
+        if (CollectionUtil.isNotEmpty(noticeUserDto.getPushClientId())) {
+            List<String> filteredList = noticeUserDto.getPushClientId().stream()
+                    //过滤掉null
+                    .filter(Objects::nonNull)
+                    .collect(Collectors.toList());
+            noticeUserDto.setPushClientId(filteredList);
+            sendEventToUser(noticeUserDto);
+        }
         //记录推送日志
         for (User item : users) {
             CsEventSendMsg csEventSendMsg = new CsEventSendMsg();