From 1b5b9596f385c2538ac7d6605ae0e487bb62b094 Mon Sep 17 00:00:00 2001 From: fengshuonan Date: Fri, 12 Jan 2024 00:03:20 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=908.1.0=E3=80=91=E3=80=90message?= =?UTF-8?q?=E3=80=91=E5=88=A0=E9=99=A4=E6=B2=A1=E7=94=A8=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../roses/kernel/message/db/MessageDbServiceImpl.java | 11 +++-------- 1 file changed, 3 insertions(+), 8 deletions(-) diff --git a/kernel-s-message/message-sdk-db/src/main/java/cn/stylefeng/roses/kernel/message/db/MessageDbServiceImpl.java b/kernel-s-message/message-sdk-db/src/main/java/cn/stylefeng/roses/kernel/message/db/MessageDbServiceImpl.java index ca2d4f949..2b793e694 100644 --- a/kernel-s-message/message-sdk-db/src/main/java/cn/stylefeng/roses/kernel/message/db/MessageDbServiceImpl.java +++ b/kernel-s-message/message-sdk-db/src/main/java/cn/stylefeng/roses/kernel/message/db/MessageDbServiceImpl.java @@ -41,7 +41,6 @@ import cn.stylefeng.roses.kernel.message.api.pojo.response.MessageResponse; import cn.stylefeng.roses.kernel.message.db.entity.SysMessage; import cn.stylefeng.roses.kernel.message.db.service.SysMessageService; import cn.stylefeng.roses.kernel.rule.enums.YesOrNotEnum; -import cn.stylefeng.roses.kernel.socket.api.exception.SocketException; import cn.stylefeng.roses.kernel.sys.api.SysUserServiceApi; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import lombok.extern.slf4j.Slf4j; @@ -120,12 +119,6 @@ public class MessageDbServiceImpl implements MessageApi { // 给用户发送通知 for (SysMessage item : sendMsgList) { - try { -// socketOperatorApi.sendMsgOfUserSession(ServerMessageTypeEnum.SYS_NOTICE_MSG_TYPE.getCode(), item.getReceiveUserId().toString(), item); - } catch (SocketException socketException) { - // 该用户不在线 - - } } } @@ -147,7 +140,9 @@ public class MessageDbServiceImpl implements MessageApi { LoginUser loginUser = LoginContext.me().getLoginUser(); Long userId = loginUser.getUserId(); LambdaUpdateWrapper updateWrapper = new LambdaUpdateWrapper<>(); - updateWrapper.set(SysMessage::getReadFlag, MessageReadFlagEnum.READ.getCode()).eq(SysMessage::getReadFlag, MessageReadFlagEnum.UNREAD.getCode()).eq(SysMessage::getReceiveUserId, userId).set(SysMessage::getDelFlag, YesOrNotEnum.N.getCode()); + updateWrapper.set(SysMessage::getReadFlag, MessageReadFlagEnum.READ.getCode()) + .eq(SysMessage::getReadFlag, MessageReadFlagEnum.UNREAD.getCode()).eq(SysMessage::getReceiveUserId, userId) + .set(SysMessage::getDelFlag, YesOrNotEnum.N.getCode()); sysMessageService.update(updateWrapper); }