diff --git a/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/AcUserMsgServiceImpl.java b/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/AcUserMsgServiceImpl.java
index f067ff095..a9338cec4 100644
--- a/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/AcUserMsgServiceImpl.java
+++ b/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/AcUserMsgServiceImpl.java
@@ -1,5 +1,6 @@
 package com.czg.service.account.service.impl;
 
+import cn.hutool.core.thread.ThreadUtil;
 import com.czg.account.dto.AcUserMsgDTO;
 import com.czg.account.entity.AcUserMsg;
 import com.czg.account.service.AcUserMsgService;
@@ -34,8 +35,19 @@ public class AcUserMsgServiceImpl extends ServiceImpl<AcUserMsgMapper, AcUserMsg
 
     @Override
     public Page<AcUserMsgDTO> getUserMsgPage() {
+        long userId = StpKit.USER.getLoginIdAsLong();
+        ThreadUtil.execAsync(() -> {
+//            AcUserMsg msg = new AcUserMsg();
+//            msg.setReadStatus(1);
+//            update(msg, QueryWrapper.create().eq(AcUserMsg::getUserId, userId).eq(AcUserMsg::getReadStatus, 0));
+//
+            updateChain().set(AcUserMsg::getReadStatus, 1)
+                    .eq(AcUserMsg::getUserId, userId)
+                    .eq(AcUserMsg::getReadStatus, 0)
+                    .update();
+        });
         return pageAs(PageUtil.buildPage(), QueryWrapper.create().eq(AcUserMsg::getUserId,
-                StpKit.USER.getLoginIdAsLong()).orderBy(AcUserMsg::getCreateTime, false), AcUserMsgDTO.class);
+                userId).orderBy(AcUserMsg::getCreateTime, false), AcUserMsgDTO.class);
     }
 
     @Override