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 *