将所有消息标记为已读

src/main/java/cn/meteor/beyondclouds/modules/message/api/MessageApi.java

@@ -40,6 +40,14 @@ public class MessageApi {
         return Response.success();
     }
 
+    @ApiOperation("标记所有信息为已读")
+    @PutMapping("/messages/read")
+    public Response readMessages(@CurrentSubject Subject subject){
+        messageService.readMessages(String.valueOf(subject.getId()));
+        return Response.success();
+    }
+
+
 
 }
 

src/main/java/cn/meteor/beyondclouds/modules/message/service/IMessageService.java

@@ -4,6 +4,8 @@ import cn.meteor.beyondclouds.core.exception.ServiceException;
 import cn.meteor.beyondclouds.modules.message.entity.Message;
 import com.baomidou.mybatisplus.extension.service.IService;
 
+import java.io.Serializable;
+
 /**
  * <p>
  *  服务类
@@ -20,4 +22,9 @@ public interface IMessageService extends IService<Message> {
      */
     void readMessage(String messageId) throws ServiceException;
 
+    /**
+     * 将所有消息标记为已读
+     * @param userId
+     */
+    void readMessages(String userId);
 }

src/main/java/cn/meteor/beyondclouds/modules/message/service/impl/MessageServiceImpl.java

@@ -31,4 +31,12 @@ public class MessageServiceImpl extends ServiceImpl<MessageMapper, Message> impl
         updateById(message);
 
     }
+
+    @Override
+    public void readMessages(String userId) {
+        UpdateWrapper updateWrapper = new UpdateWrapper();
+        updateWrapper.eq("user_id", userId);
+        updateWrapper.set("status", 1);
+        update(updateWrapper);
+    }
 }