From 9af06296f6e320cdff90dbf32d554a7108760ec9 Mon Sep 17 00:00:00 2001 From: gong <1157756119@qq.com> Date: Wed, 10 Dec 2025 09:37:52 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E6=B6=88=E6=81=AF=E5=88=97?= =?UTF-8?q?=E8=A1=A8=E5=8D=B3=E6=9B=B4=E6=96=B0=E6=9C=AA=E8=AF=BB=E7=8A=B6?= =?UTF-8?q?=E6=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../account/service/impl/AcUserMsgServiceImpl.java | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) 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 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