消息类型增加

src/main/java/cn/meteor/beyondclouds/modules/message/enums/MessageType.java

+package cn.meteor.beyondclouds.modules.message.enums;
+
+import lombok.Getter;
+
+/**
+ * @author meteor
+ */
+@Getter
+public enum MessageType {
+
+    /**
+     * 关注
+     */
+    FOLLOW(1),
+
+    /**
+     * 博客评论
+     */
+    BLOG_COMMENT(2),
+
+    /**
+     * 项目评论
+     */
+    PROJECT_COMMENT(3),
+
+    /**
+     * 问题回复
+     */
+    QUESTION_REPLY(4),
+
+    /**
+     * 回答采纳
+     */
+    QUESTION_REPLY_ACCEPTED(5),
+
+    /**
+     * 动态评论
+     */
+    POST_COMMENT(6)
+    ;
+    private Integer type;
+
+    MessageType(Integer type) {
+        this.type = type;
+    }
+}

src/main/java/cn/meteor/beyondclouds/modules/message/listener/MessageListener.java

@@ -8,6 +8,7 @@ import cn.meteor.beyondclouds.modules.blog.entity.BlogComment;
 import cn.meteor.beyondclouds.modules.blog.service.IBlogCommentService;
 import cn.meteor.beyondclouds.modules.blog.service.IBlogService;
 import cn.meteor.beyondclouds.modules.message.entity.Message;
+import cn.meteor.beyondclouds.modules.message.enums.MessageType;
 import cn.meteor.beyondclouds.modules.message.service.IMessageService;
 import cn.meteor.beyondclouds.modules.post.entity.Post;
 import cn.meteor.beyondclouds.modules.post.entity.PostComment;
@@ -124,7 +125,7 @@ public class MessageListener implements DataItemChangeListener {
 
             Message message = new Message();
             message.setUserId(followedUserId);
-            message.setMsgType(1);
+            message.setMsgType(MessageType.FOLLOW.getType());
             message.setMscContent(String.format("用户%s关注了你", followerUser.getNickName()));
             messageService.save(message);
         }
@@ -148,6 +149,7 @@ public class MessageListener implements DataItemChangeListener {
             // 给博主发消息
             if (!operatorId.equals(blog.getUserId())) {
                 Message messageToAuthor = new Message();
+                messageToAuthor.setMsgType(MessageType.BLOG_COMMENT.getType());
                 messageToAuthor.setUserId(blog.getUserId());
                 messageToAuthor.setMscContent(String.format("用户%s对您的博客%s进行了评论！", blogComment.getUserNick(), blog.getBlogTitle()));
                 messageService.save(messageToAuthor);
@@ -155,6 +157,7 @@ public class MessageListener implements DataItemChangeListener {
             // 给父评论的用户发消息
             if (null != parentComment && !operatorId.equals(parentComment.getUserId())) {
                 Message messageToParentCommenter = new Message();
+                messageToParentCommenter.setMsgType(MessageType.BLOG_COMMENT.getType());
                 messageToParentCommenter.setUserId(parentComment.getUserId());
                 messageToParentCommenter.setMscContent(String.format("用户%s对您在博客%s下的评论进行了回复", blogComment.getUserNick(), blog.getBlogTitle()));
             }
@@ -180,6 +183,7 @@ public class MessageListener implements DataItemChangeListener {
             // 给博主发消息
             if (!operatorId.equals(project.getUserId())) {
                 Message messageToAuthor = new Message();
+                messageToAuthor.setMsgType(MessageType.PROJECT_COMMENT.getType());
                 messageToAuthor.setUserId(project.getUserId());
                 messageToAuthor.setMscContent(String.format("用户%s对您的项目%s进行了评论！", comment.getUserNick(), project.getProjectName()));
                 messageService.save(messageToAuthor);
@@ -187,6 +191,7 @@ public class MessageListener implements DataItemChangeListener {
             // 给父评论的用户发消息
             if (null != parentComment && !operatorId.equals(parentComment.getUserId())) {
                 Message messageToParentCommenter = new Message();
+                messageToParentCommenter.setMsgType(MessageType.PROJECT_COMMENT.getType());
                 messageToParentCommenter.setUserId(parentComment.getUserId());
                 messageToParentCommenter.setMscContent(String.format("用户%s对您在项目%s下的评论进行了回复", comment.getUserNick(), project.getProjectName()));
             }
@@ -211,6 +216,7 @@ public class MessageListener implements DataItemChangeListener {
             // 给博主发消息
             if (!operatorId.equals(post.getUserId())) {
                 Message messageToAuthor = new Message();
+                messageToAuthor.setMsgType(MessageType.POST_COMMENT.getType());
                 messageToAuthor.setUserId(post.getUserId());
                 messageToAuthor.setMscContent(String.format("用户%s对您的动态%s进行了评论！", comment.getUserNick(), post.getContent()));
                 messageService.save(messageToAuthor);
@@ -218,6 +224,7 @@ public class MessageListener implements DataItemChangeListener {
             // 给父评论的用户发消息
             if (null != parentComment && !parentComment.getUserId().equals(operatorId)) {
                 Message messageToParentCommenter = new Message();
+                messageToParentCommenter.setMsgType(MessageType.POST_COMMENT.getType());
                 messageToParentCommenter.setUserId(parentComment.getUserId());
                 messageToParentCommenter.setMscContent(String.format("用户%s对您在动态%s下的评论进行了回复", comment.getUserNick(), post.getContent()));
             }
@@ -235,6 +242,7 @@ public class MessageListener implements DataItemChangeListener {
             // 给问题提出者发消息
             if (!operatorId.equals(question.getUserId())) {
                 Message messageToAuthor = new Message();
+                messageToAuthor.setMsgType(MessageType.QUESTION_REPLY.getType());
                 messageToAuthor.setUserId(question.getUserId());
                 messageToAuthor.setMscContent(String.format("用户%s对您的问题%s进行了回答！", questionReply.getUserNick(), question.getQuestionTitle()));
                 messageService.save(messageToAuthor);
@@ -253,6 +261,7 @@ public class MessageListener implements DataItemChangeListener {
             // 给问题提出者发消息
             if (!questionReply.getUserId().equals(operatorId) && question.getUserId().equals(operatorId)) {
                 Message messageToAuthor = new Message();
+                messageToAuthor.setMsgType(MessageType.QUESTION_REPLY_ACCEPTED.getType());
                 messageToAuthor.setUserId(questionReply.getUserId());
                 messageToAuthor.setMscContent(String.format("您在问题%s的回答被采纳了！", question.getQuestionTitle()));
                 messageService.save(messageToAuthor);