From b3e7153def6472a08926d2637fbc8cf389fd1a65 Mon Sep 17 00:00:00 2001
From: fengshuonan <sn93@qq.com>
Date: Sun, 14 Jan 2024 21:25:15 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=908.1.0=E3=80=91=E3=80=90message?=
 =?UTF-8?q?=E3=80=91=E3=80=90=E4=B8=AA=E4=BA=BA=E6=B6=88=E6=81=AF=E3=80=91?=
 =?UTF-8?q?=E6=9B=B4=E6=96=B0=E6=B8=85=E7=A9=BA=E4=B8=AA=E4=BA=BA=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF=E7=9A=84=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/SysMessageController.java        |  1 +
 .../message/service/SysMessageService.java      |  8 ++++++++
 .../service/impl/SysMessageServiceImpl.java     | 17 +++++++++++++++--
 3 files changed, 24 insertions(+), 2 deletions(-)

diff --git a/kernel-s-system/system-business-portal/src/main/java/cn/stylefeng/roses/kernel/sys/modular/message/controller/SysMessageController.java b/kernel-s-system/system-business-portal/src/main/java/cn/stylefeng/roses/kernel/sys/modular/message/controller/SysMessageController.java
index 3b2e1cca6..9c0f9fff9 100644
--- a/kernel-s-system/system-business-portal/src/main/java/cn/stylefeng/roses/kernel/sys/modular/message/controller/SysMessageController.java
+++ b/kernel-s-system/system-business-portal/src/main/java/cn/stylefeng/roses/kernel/sys/modular/message/controller/SysMessageController.java
@@ -60,6 +60,7 @@ public class SysMessageController {
      */
     @PostResource(name = "清空我的消息", path = "/sysMessage/cleanMyMessage")
     public ResponseData<?> cleanMyMessage() {
+        sysMessageService.deleteAllMyMessage();
         return new SuccessResponseData<>();
     }
 
diff --git a/kernel-s-system/system-business-portal/src/main/java/cn/stylefeng/roses/kernel/sys/modular/message/service/SysMessageService.java b/kernel-s-system/system-business-portal/src/main/java/cn/stylefeng/roses/kernel/sys/modular/message/service/SysMessageService.java
index e82148f05..7bc148738 100644
--- a/kernel-s-system/system-business-portal/src/main/java/cn/stylefeng/roses/kernel/sys/modular/message/service/SysMessageService.java
+++ b/kernel-s-system/system-business-portal/src/main/java/cn/stylefeng/roses/kernel/sys/modular/message/service/SysMessageService.java
@@ -41,4 +41,12 @@ public interface SysMessageService extends IService<SysMessage> {
      */
     PageResult<SysMessage> findPage(SysMessageRequest sysMessageRequest);
 
+    /**
+     * 清空我的消息
+     *
+     * @author fengshuonan
+     * @since 2024/1/14 21:23
+     */
+    void deleteAllMyMessage();
+
 }
diff --git a/kernel-s-system/system-business-portal/src/main/java/cn/stylefeng/roses/kernel/sys/modular/message/service/impl/SysMessageServiceImpl.java b/kernel-s-system/system-business-portal/src/main/java/cn/stylefeng/roses/kernel/sys/modular/message/service/impl/SysMessageServiceImpl.java
index 0c447775a..d7da384e5 100644
--- a/kernel-s-system/system-business-portal/src/main/java/cn/stylefeng/roses/kernel/sys/modular/message/service/impl/SysMessageServiceImpl.java
+++ b/kernel-s-system/system-business-portal/src/main/java/cn/stylefeng/roses/kernel/sys/modular/message/service/impl/SysMessageServiceImpl.java
@@ -2,6 +2,7 @@ package cn.stylefeng.roses.kernel.sys.modular.message.service.impl;
 
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
+import cn.stylefeng.roses.kernel.auth.api.context.LoginContext;
 import cn.stylefeng.roses.kernel.db.api.factory.PageFactory;
 import cn.stylefeng.roses.kernel.db.api.factory.PageResultFactory;
 import cn.stylefeng.roses.kernel.db.api.pojo.page.PageResult;
@@ -12,6 +13,7 @@ import cn.stylefeng.roses.kernel.sys.modular.message.mapper.SysMessageMapper;
 import cn.stylefeng.roses.kernel.sys.modular.message.pojo.request.SysMessageRequest;
 import cn.stylefeng.roses.kernel.sys.modular.message.service.SysMessageService;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.stereotype.Service;
@@ -27,8 +29,11 @@ public class SysMessageServiceImpl extends ServiceImpl<SysMessageMapper, SysMess
 
     @Override
     public void del(SysMessageRequest sysMessageRequest) {
-        SysMessage sysMessage = this.querySysMessage(sysMessageRequest);
-        this.removeById(sysMessage.getMessageId());
+        // 只能清空自己的消息
+        LambdaUpdateWrapper<SysMessage> wrapper = new LambdaUpdateWrapper<>();
+        wrapper.eq(SysMessage::getReceiveUserId, LoginContext.me().getLoginUser().getUserId());
+        wrapper.eq(SysMessage::getMessageId, sysMessageRequest.getMessageId());
+        this.remove(wrapper);
     }
 
     @Override
@@ -48,6 +53,14 @@ public class SysMessageServiceImpl extends ServiceImpl<SysMessageMapper, SysMess
         return PageResultFactory.createPageResult(pageList);
     }
 
+    @Override
+    public void deleteAllMyMessage() {
+        // 只能清空自己的消息
+        LambdaUpdateWrapper<SysMessage> wrapper = new LambdaUpdateWrapper<>();
+        wrapper.eq(SysMessage::getReceiveUserId, LoginContext.me().getLoginUser().getUserId());
+        this.remove(wrapper);
+    }
+
     /**
      * 获取信息
      *