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 filteredList = noticeUserDto.getPushClientId().stream() + //过滤掉null + .filter(Objects::nonNull) + .collect(Collectors.toList()); + noticeUserDto.setPushClientId(filteredList); + sendEventToUser(noticeUserDto); + } //记录推送日志 for (User item : users) { CsEventSendMsg csEventSendMsg = new CsEventSendMsg();