【8.1.0】【message】【个人消息】更新清空个人消息的接口

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<>();
     }
 

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();
+
 }

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);
+    }
+
     /**
      * 获取信息
      *