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

运维管理员添加消息推送

Browse Source
This commit is contained in:
xuyang
2023-11-03 14:43:43 +08:00
parent cd80501f59
commit e785007f5c
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -149,15 +149,17 @@ public class SendEventUtils {
users = appUserFeignClient.getAdminInfo().getData(); users = appUserFeignClient.getAdminInfo().getData();
noticeUserDto.setPushClientId(Collections.singletonList(users.get(0).getDevCode())); noticeUserDto.setPushClientId(Collections.singletonList(users.get(0).getDevCode()));
//记录需要通知的用户和事件关系 //记录需要通知的用户和事件关系
users.forEach(item->{
CsEventUserPO csEventUser = new CsEventUserPO(); CsEventUserPO csEventUser = new CsEventUserPO();
csEventUser.setUserId(users.get(0).getId()); csEventUser.setUserId(item.getId());
csEventUser.setStatus(0); csEventUser.setStatus(0);
csEventUser.setEventId(id); csEventUser.setEventId(id);
result.add(csEventUser); result.add(csEventUser);
});
break; break;
case "2": case "2":
case "3": case "3":
//Ⅱ、Ⅲ级告警推送相关用户 //Ⅱ、Ⅲ级告警推送相关用户及业务管理员
users = getEventUser(devId); users = getEventUser(devId);
devCodeList = users.stream().map(User::getDevCode).collect(Collectors.toList()); devCodeList = users.stream().map(User::getDevCode).collect(Collectors.toList());
noticeUserDto.setPushClientId(devCodeList); noticeUserDto.setPushClientId(devCodeList);
@@ -263,6 +265,8 @@ public class SendEventUtils {
if (CollectionUtil.isNotEmpty(list)){ if (CollectionUtil.isNotEmpty(list)){
users = userFeignClient.getUserByIdList(result).getData(); users = userFeignClient.getUserByIdList(result).getData();
} }
List<User> adminUser = appUserFeignClient.getAdminInfo().getData();
users.addAll(adminUser);
return users; return users;
} }