新增消息已读接口

picc-admin-server/src/main/java/com/jpsoft/picc/modules/base/controller/MessageController.java

@@ -272,6 +272,42 @@ public class MessageController {
         return msgResult;
     }
 
+
+    @ApiOperation(value="用户所有未读消息设为已读")
+    @PostMapping("allRead")
+    public MessageResult<Integer> allRead(@RequestAttribute String subject){
+        MessageResult<Integer> msgResult = new MessageResult<>();
+
+        try {
+            List<Message> messageList = messageService.findByRecipientId(subject);
+
+            int affectCount = 0;
+
+            for (Message message:messageList) {
+                message.setStatus(true);
+                message.setUpdateBy(subject);
+                message.setUpdateTime(new Date());
+                affectCount += messageService.update(message);
+            }
+
+            if (affectCount > 0) {
+                msgResult.setResult(true);
+                msgResult.setData(affectCount);
+            } else {
+                msgResult.setResult(false);
+                msgResult.setMessage("设为已读失败");
+            }
+        }
+        catch(Exception ex){
+            logger.error(ex.getMessage(),ex);
+
+            msgResult.setResult(false);
+            msgResult.setMessage(ex.getMessage());
+        }
+
+        return msgResult;
+    }
+
     @ApiOperation(value="获取是否有未读消息和消息条数")
     @PostMapping("getMessageCount")
     public MessageResult<Integer> getMessageCount(@RequestAttribute String subject){