From e19a0d582cdee6d13482848002ff17ac61cd4d2b Mon Sep 17 00:00:00 2001
From: hansson <447067298@qq.com>
Date: Fri, 8 Jan 2021 15:04:55 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=90message=E3=80=91=E5=A2=9E=E5=8A=A0?=
 =?UTF-8?q?=E6=89=B9=E9=87=8F=E6=9B=B4=E6=96=B0=E7=B3=BB=E7=BB=9F=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../kernel/message/api/pojo/MessageParam.java | 15 +++++++++++++++
 .../controller/SysMessageController.java      | 19 +++++++++++++++++++
 2 files changed, 34 insertions(+)

diff --git a/kernel-s-message/message-api/src/main/java/cn/stylefeng/roses/kernel/message/api/pojo/MessageParam.java b/kernel-s-message/message-api/src/main/java/cn/stylefeng/roses/kernel/message/api/pojo/MessageParam.java
index 0c38416d2..65512251f 100644
--- a/kernel-s-message/message-api/src/main/java/cn/stylefeng/roses/kernel/message/api/pojo/MessageParam.java
+++ b/kernel-s-message/message-api/src/main/java/cn/stylefeng/roses/kernel/message/api/pojo/MessageParam.java
@@ -4,8 +4,10 @@ import cn.stylefeng.roses.kernel.rule.pojo.request.BaseRequest;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 
+import javax.validation.constraints.NotEmpty;
 import javax.validation.constraints.NotNull;
 import java.util.Date;
+import java.util.List;
 
 /**
  * 系统消息的查询参数
@@ -74,4 +76,17 @@ public class MessageParam extends BaseRequest {
     @NotNull(message = "阅读状态不能为空", groups = {updateStatus.class})
     private Integer readFlag;
 
+    /**
+     * 消息id集合
+     */
+    @NotEmpty(message = "消息id集合不能为空，请检查messageIdList参数", groups = {updateReadFlag.class})
+    private List<Long> messageIdList;
+
+
+    /**
+     * 参数校验分组：修改阅读状态
+     */
+    public @interface updateReadFlag {
+    }
+
 }
diff --git a/kernel-s-message/message-business/src/main/java/cn/stylefeng/roses/kernel/message/modular/manage/controller/SysMessageController.java b/kernel-s-message/message-business/src/main/java/cn/stylefeng/roses/kernel/message/modular/manage/controller/SysMessageController.java
index 13adb1e07..259b667a1 100644
--- a/kernel-s-message/message-business/src/main/java/cn/stylefeng/roses/kernel/message/modular/manage/controller/SysMessageController.java
+++ b/kernel-s-message/message-business/src/main/java/cn/stylefeng/roses/kernel/message/modular/manage/controller/SysMessageController.java
@@ -1,11 +1,14 @@
 package cn.stylefeng.roses.kernel.message.modular.manage.controller;
 
+import cn.hutool.core.util.StrUtil;
 import cn.stylefeng.roses.kernel.message.api.MessageApi;
+import cn.stylefeng.roses.kernel.message.api.enums.MessageReadFlagEnum;
 import cn.stylefeng.roses.kernel.message.api.pojo.MessageParam;
 import cn.stylefeng.roses.kernel.message.api.pojo.MessageSendParam;
 import cn.stylefeng.roses.kernel.resource.api.annotation.ApiResource;
 import cn.stylefeng.roses.kernel.resource.api.annotation.GetResource;
 import cn.stylefeng.roses.kernel.resource.api.annotation.PostResource;
+import cn.stylefeng.roses.kernel.rule.pojo.request.BaseRequest;
 import cn.stylefeng.roses.kernel.rule.pojo.response.ResponseData;
 import cn.stylefeng.roses.kernel.rule.pojo.response.SuccessResponseData;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -13,6 +16,9 @@ import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.List;
+import java.util.Optional;
+
 /**
  * 系统消息控制器
  *
@@ -41,6 +47,19 @@ public class SysMessageController {
         return new SuccessResponseData();
     }
 
+    /**
+     * 批量更新系统消息状态
+     *
+     * @author liuhanqing
+     * @date 2021/1/8 13:50
+     */
+    @PostResource(name = "批量更新系统消息状态", path = "/sysMessage/batchUpdateReadFlag")
+    public ResponseData sendMessage(@RequestBody @Validated(MessageParam.updateReadFlag.class) MessageParam messageParam) {
+        List<Long> messageIdList = messageParam.getMessageIdList();
+        messageApi.batchReadFlagByMessageIds(StrUtil.join(",", messageIdList), MessageReadFlagEnum.READ);
+        return new SuccessResponseData();
+    }
+
     /**
      * 系统消息全部修改已读
      *