Microservice/iot
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

消息推送过滤null值

Browse Source
This commit is contained in:
xy
2024-09-03 20:19:58 +08:00
parent 63c293d813
commit 9c95d740d2
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/utils/SendEventUtils.java
View File

@@ -222,7 +222,14 @@ public class SendEventUtils {
payload.setPath("/pages/message/message?type="+payload.getType()); payload.setPath("/pages/message/message?type="+payload.getType());
noticeUserDto.setPayload(payload); noticeUserDto.setPayload(payload);
} }
if (CollectionUtil.isNotEmpty(noticeUserDto.getPushClientId())) {
List<String> filteredList = noticeUserDto.getPushClientId().stream()
//过滤掉null
.filter(Objects::nonNull)
.collect(Collectors.toList());
noticeUserDto.setPushClientId(filteredList);
sendEventToUser(noticeUserDto); sendEventToUser(noticeUserDto);
}
//记录推送日志 //记录推送日志
for (User item : users) { for (User item : users) {
CsEventSendMsg csEventSendMsg = new CsEventSendMsg(); CsEventSendMsg csEventSendMsg = new CsEventSendMsg();