通知bug

This commit is contained in:
mx 2024-11-06 17:57:04 +08:00
parent 3972ae9b80
commit cd2e67404a

View File

@ -157,12 +157,15 @@ public class SysNoticeServiceImpl implements ISysNoticeService {
}
baseMapper.insertBatch(insertData);
SysNoticeVo vo = MapstructUtils.convert(MapstructUtils.convert(bo, SysNotice.class), SysNoticeVo.class);
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);
webSocketMessage.setSessionKeys(Arrays.asList(insertDatum.getRecUid()));
WebSocketUtils.publishMessage(webSocketMessage);
}
return 1;