From 3756a61f9e70fe5d2ca2398a3a35ae65e82a569c Mon Sep 17 00:00:00 2001
From: xiaohuo <14141624+dsgfhrh@user.noreply.gitee.com>
Date: Thu, 6 Nov 2025 21:08:57 +0800
Subject: [PATCH] =?UTF-8?q?11.6=E7=AB=99=E5=86=85=E4=BF=A1list=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/alops/system/mapper/InternalMessageMapper.java | 5 ++++-
 .../system/service/impl/InternalMessageServiceImpl.java     | 1 +
 .../main/resources/mapper/system/InternalMessageMapper.xml  | 6 ++++++
 3 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/ALOps_sys_backend/alops-system/src/main/java/com/alops/system/mapper/InternalMessageMapper.java b/ALOps_sys_backend/alops-system/src/main/java/com/alops/system/mapper/InternalMessageMapper.java
index b845f2cb..f7ae5df0 100644
--- a/ALOps_sys_backend/alops-system/src/main/java/com/alops/system/mapper/InternalMessageMapper.java
+++ b/ALOps_sys_backend/alops-system/src/main/java/com/alops/system/mapper/InternalMessageMapper.java
@@ -16,7 +16,10 @@ import java.util.List;
 public interface InternalMessageMapper 
         {
 
-
+            /**
+             * 根据用户ID将所有消息状态更新为已读
+             */
+            int updateMessagesToReadByUserId(@Param("userId") Long userId);
             /**
              * 查询指定用户的所有消息，按时间倒序
              */
diff --git a/ALOps_sys_backend/alops-system/src/main/java/com/alops/system/service/impl/InternalMessageServiceImpl.java b/ALOps_sys_backend/alops-system/src/main/java/com/alops/system/service/impl/InternalMessageServiceImpl.java
index f2c46ac6..f47d81f5 100644
--- a/ALOps_sys_backend/alops-system/src/main/java/com/alops/system/service/impl/InternalMessageServiceImpl.java
+++ b/ALOps_sys_backend/alops-system/src/main/java/com/alops/system/service/impl/InternalMessageServiceImpl.java
@@ -29,6 +29,7 @@ public class InternalMessageServiceImpl implements IInternalMessageService
         if (userId == null) {
             return Collections.emptyList();
         }
+        internalMessageMapper.updateMessagesToReadByUserId(userId);
         return internalMessageMapper.selectMessagesByUserId(userId);
     }
     @Override
diff --git a/ALOps_sys_backend/alops-system/src/main/resources/mapper/system/InternalMessageMapper.xml b/ALOps_sys_backend/alops-system/src/main/resources/mapper/system/InternalMessageMapper.xml
index 0c4a20f6..bf659d5b 100644
--- a/ALOps_sys_backend/alops-system/src/main/resources/mapper/system/InternalMessageMapper.xml
+++ b/ALOps_sys_backend/alops-system/src/main/resources/mapper/system/InternalMessageMapper.xml
@@ -14,6 +14,12 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 
     </resultMap>
 
+    <!-- 根据用户ID将所有消息状态更新为已读 -->
+    <update id="updateMessagesToReadByUserId">
+        UPDATE internal_message
+        SET status = 'read'  <!-- 假设1表示已读状态，请根据您的实际状态值调整 -->
+        WHERE user_id = #{userId}
+    </update>
 
     <select id="selectMessagesByUserId" resultMap="InternalMessageResult">
         SELECT *