From cd2e67404a793b09b88af322595eed9ce54d49b1 Mon Sep 17 00:00:00 2001
From: mx <1289317512@qq.com>
Date: Wed, 6 Nov 2024 17:57:04 +0800
Subject: [PATCH] =?UTF-8?q?=E9=80=9A=E7=9F=A5bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../system/service/impl/SysNoticeServiceImpl.java   | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

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;