diff --git a/pusong-modules/pusong-system/src/main/java/com/pusong/system/service/impl/SysNoticeServiceImpl.java b/pusong-modules/pusong-system/src/main/java/com/pusong/system/service/impl/SysNoticeServiceImpl.java index e5d852b..b76ab0a 100644 --- a/pusong-modules/pusong-system/src/main/java/com/pusong/system/service/impl/SysNoticeServiceImpl.java +++ b/pusong-modules/pusong-system/src/main/java/com/pusong/system/service/impl/SysNoticeServiceImpl.java @@ -157,12 +157,15 @@ public class SysNoticeServiceImpl implements ISysNoticeService { } baseMapper.insertBatch(insertData); - SysNoticeVo vo = MapstructUtils.convert(MapstructUtils.convert(bo, SysNotice.class), SysNoticeVo.class); - WebSocketMessageDto webSocketMessage = new WebSocketMessageDto(); + for (SysNotice insertDatum : insertData) { + SysNoticeVo vo = MapstructUtils.convert(insertDatum, SysNoticeVo.class); + WebSocketMessageDto webSocketMessage = new WebSocketMessageDto(); // webSocketMessage.setMessage(bo.getNoticeContent()); - webSocketMessage.setMessage(JsonUtils.toJsonString(vo)); - webSocketMessage.setSessionKeys(uids); - WebSocketUtils.publishMessage(webSocketMessage); + webSocketMessage.setMessage(JsonUtils.toJsonString(vo)); + webSocketMessage.setSessionKeys(Arrays.asList(insertDatum.getRecUid())); + WebSocketUtils.publishMessage(webSocketMessage); + } + return 1;