消息完成

src/main/java/cn/meteor/beyondclouds/core/queue/message/DataItemType.java

@@ -2,11 +2,15 @@ package cn.meteor.beyondclouds.core.queue.message;
 
 import cn.meteor.beyondclouds.modules.blog.entity.Blog;
 import cn.meteor.beyondclouds.modules.blog.entity.BlogComment;
+import cn.meteor.beyondclouds.modules.blog.entity.BlogPraise;
 import cn.meteor.beyondclouds.modules.post.entity.Post;
 import cn.meteor.beyondclouds.modules.post.entity.PostComment;
+import cn.meteor.beyondclouds.modules.post.entity.PostPraise;
 import cn.meteor.beyondclouds.modules.project.entity.Project;
 import cn.meteor.beyondclouds.modules.project.entity.ProjectComment;
+import cn.meteor.beyondclouds.modules.project.entity.ProjectPraise;
 import cn.meteor.beyondclouds.modules.question.entity.Question;
+import cn.meteor.beyondclouds.modules.question.entity.QuestionPraise;
 import cn.meteor.beyondclouds.modules.question.entity.QuestionReply;
 import cn.meteor.beyondclouds.modules.question.entity.QuestionReplyComment;
 import cn.meteor.beyondclouds.modules.user.entity.User;
@@ -94,7 +98,27 @@ public enum DataItemType {
     /**
      * 用户关注
      */
-    USER_FOLLOW(UserFollow .class);
+    USER_FOLLOW(UserFollow .class),
+
+    /**
+     * 博客点赞
+     */
+    BLOG_PRAISE(BlogPraise.class),
+
+    /**
+     * 项目点赞
+     */
+    PROJECT_PRAISE(ProjectPraise.class),
+
+    /**
+     * 动态点赞
+     */
+    POST_PRAISE(PostPraise.class),
+
+    /**
+     * 问题点赞
+     */
+    QUESTION_PRAISE(QuestionPraise.class);
 
     private Class<?> classOfItem;
 

src/main/java/cn/meteor/beyondclouds/modules/blog/service/impl/BlogPraiseServiceImpl.java

 package cn.meteor.beyondclouds.modules.blog.service.impl;
 
+import cn.meteor.beyondclouds.core.queue.message.DataItemChangeMessage;
+import cn.meteor.beyondclouds.core.queue.message.DataItemType;
 import cn.meteor.beyondclouds.modules.blog.entity.Blog;
 import cn.meteor.beyondclouds.modules.blog.entity.BlogComment;
 import cn.meteor.beyondclouds.modules.blog.entity.BlogPraise;
@@ -14,6 +16,7 @@ import cn.meteor.beyondclouds.modules.blog.mapper.BlogPraiseMapper;
 import cn.meteor.beyondclouds.modules.blog.service.IBlogCommentService;
 import cn.meteor.beyondclouds.modules.blog.service.IBlogPraiseService;
 import cn.meteor.beyondclouds.modules.blog.service.IBlogService;
+import cn.meteor.beyondclouds.modules.queue.service.IMessageQueueService;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -34,6 +37,8 @@ public class BlogPraiseServiceImpl extends ServiceImpl<BlogPraiseMapper, BlogPra
 
     private IBlogCommentService blogCommentService;
 
+    private IMessageQueueService messageQueueService;
+
     @Autowired
     public void setBlogService(IBlogService blogService) {
         this.blogService = blogService;
@@ -44,6 +49,11 @@ public class BlogPraiseServiceImpl extends ServiceImpl<BlogPraiseMapper, BlogPra
         this.blogCommentService = blogCommentService;
     }
 
+    @Autowired
+    public void setMessageQueueService(IMessageQueueService messageQueueService) {
+        this.messageQueueService = messageQueueService;
+    }
+
     @Override
     public void praiseBlog(String userId, String blogId) throws BlogPraiseServiceException {
         // 1.判断博客是否存在
@@ -73,6 +83,8 @@ public class BlogPraiseServiceImpl extends ServiceImpl<BlogPraiseMapper, BlogPra
         // 4.更新博客获赞数量
         blog.setPraiseNum(blog.getPraiseNum() + 1);
         blogService.updateById(blog);
+
+        messageQueueService.sendDataItemChangeMessage(DataItemChangeMessage.addMessage(DataItemType.BLOG_PRAISE, blogPraise.getPraiseId()));
     }
 
     @Override

src/main/java/cn/meteor/beyondclouds/modules/im/server/SocketIOServiceImpl.java

@@ -93,7 +93,7 @@ public class SocketIOServiceImpl implements SocketIOService {
             if (null != token) {
                 String userId = tokenManager.getUserId(token);
                 if (null != userId) {
-//                    CLIENT_MAP.remove(userId);
+                    CLIENT_MAP.remove(userId);
                 }
             }
         });

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

@@ -40,7 +40,27 @@ public enum MessageType {
     /**
      * 动态评论
      */
-    POST_COMMENT(6)
+    POST_COMMENT(6),
+
+    /**
+     * 博客点赞
+     */
+    BLOG_PRAISE(7),
+
+    /**
+     * 项目点赞
+     */
+    PROJECT_PRAISE(8),
+
+    /**
+     * 动态点赞
+     */
+    POST_PRAISE(9),
+
+    /**
+     * 问题点赞
+     */
+    QUESTION_PRAISE(10),
     ;
     private Integer type;
 

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

@@ -57,7 +57,7 @@ public class MessageServiceImpl extends ServiceImpl<MessageMapper, Message> impl
                     messageQueryWrapper.in("msg_type", List.of(2, 3, 4, 5, 6));
                     break;
                 case "PRAISE":
-                    messageQueryWrapper.in("msg_type", List.of(7));
+                    messageQueryWrapper.in("msg_type", List.of(7, 8, 9, 10));
                     break;
                 case "FOLLOW":
                     messageQueryWrapper.eq("msg_type", 1);

src/main/java/cn/meteor/beyondclouds/modules/post/service/impl/PostPraiseServiceImpl.java

 package cn.meteor.beyondclouds.modules.post.service.impl;
 
+import cn.meteor.beyondclouds.core.queue.message.DataItemChangeMessage;
+import cn.meteor.beyondclouds.core.queue.message.DataItemType;
 import cn.meteor.beyondclouds.modules.post.entity.Post;
 import cn.meteor.beyondclouds.modules.post.entity.PostPraise;
 import cn.meteor.beyondclouds.modules.post.enums.PostErrorCode;
@@ -9,6 +11,7 @@ import cn.meteor.beyondclouds.modules.post.mapper.PostPraiseMapper;
 import cn.meteor.beyondclouds.modules.post.service.IPostCommentService;
 import cn.meteor.beyondclouds.modules.post.service.IPostPraiseService;
 import cn.meteor.beyondclouds.modules.post.service.IPostService;
+import cn.meteor.beyondclouds.modules.queue.service.IMessageQueueService;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -26,7 +29,7 @@ import org.springframework.stereotype.Service;
 public class PostPraiseServiceImpl extends ServiceImpl<PostPraiseMapper, PostPraise> implements IPostPraiseService {
 
     private IPostService postService;
-    private IPostCommentService postCommentService;
+    private IMessageQueueService messageQueueService;
 
     @Autowired
     public void setPostService(IPostService postService) {
@@ -34,8 +37,8 @@ public class PostPraiseServiceImpl extends ServiceImpl<PostPraiseMapper, PostPra
     }
 
     @Autowired
-    public void setPostCommentService(IPostCommentService postCommentService) {
-        this.postCommentService = postCommentService;
+    public void setMessageQueueService(IMessageQueueService messageQueueService) {
+        this.messageQueueService = messageQueueService;
     }
 
     @Override
@@ -70,6 +73,8 @@ public class PostPraiseServiceImpl extends ServiceImpl<PostPraiseMapper, PostPra
         // 更新获赞数量
         post.setPraiseNum(post.getPraiseNum() + 1);
         postService.updateById(post);
+
+        messageQueueService.sendDataItemChangeMessage(DataItemChangeMessage.addMessage(DataItemType.POST_PRAISE, postPraise.getPraiseId()));
     }
 
     @Override

src/main/java/cn/meteor/beyondclouds/modules/project/service/impl/ProjectPraiseServiceImpl.java

 package cn.meteor.beyondclouds.modules.project.service.impl;
 
 import cn.meteor.beyondclouds.common.enums.ErrorCode;
+import cn.meteor.beyondclouds.core.queue.message.DataItemChangeMessage;
+import cn.meteor.beyondclouds.core.queue.message.DataItemType;
 import cn.meteor.beyondclouds.modules.post.service.IPostCommentService;
 import cn.meteor.beyondclouds.modules.project.entity.Project;
 import cn.meteor.beyondclouds.modules.project.entity.ProjectComment;
@@ -14,6 +16,7 @@ import cn.meteor.beyondclouds.modules.project.mapper.ProjectPraiseMapper;
 import cn.meteor.beyondclouds.modules.project.service.IProjectCommentService;
 import cn.meteor.beyondclouds.modules.project.service.IProjectPraiseService;
 import cn.meteor.beyondclouds.modules.project.service.IProjectService;
+import cn.meteor.beyondclouds.modules.queue.service.IMessageQueueService;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -32,6 +35,7 @@ public class ProjectPraiseServiceImpl extends ServiceImpl<ProjectPraiseMapper, P
 
     private IProjectService projectService;
     private IProjectCommentService projectCommentService;
+    private IMessageQueueService messageQueueService;
 
     @Autowired
     public void setProjectService(IProjectService projectService) {
@@ -43,6 +47,11 @@ public class ProjectPraiseServiceImpl extends ServiceImpl<ProjectPraiseMapper, P
         this.projectCommentService = projectCommentService;
     }
 
+    @Autowired
+    public void setMessageQueueService(IMessageQueueService messageQueueService) {
+        this.messageQueueService = messageQueueService;
+    }
+
     @Override
     public void praiseProject(String currentUserId, String projectId) throws ProjectServiceException {
 
@@ -73,6 +82,9 @@ public class ProjectPraiseServiceImpl extends ServiceImpl<ProjectPraiseMapper, P
         // 更新获赞数量
         project.setPraiseNum(project.getPraiseNum() + 1);
         projectService.updateById(project);
+
+        messageQueueService.sendDataItemChangeMessage(DataItemChangeMessage.addMessage(DataItemType.PROJECT_PRAISE, projectPraise.getPraiseId()));
+
     }
 
     @Override

src/main/java/cn/meteor/beyondclouds/modules/question/service/impl/QuestionPraiseServiceImpl.java

 package cn.meteor.beyondclouds.modules.question.service.impl;
 
+import cn.meteor.beyondclouds.core.queue.message.DataItemChangeMessage;
+import cn.meteor.beyondclouds.core.queue.message.DataItemType;
 import cn.meteor.beyondclouds.modules.question.entity.Question;
 import cn.meteor.beyondclouds.modules.question.entity.QuestionPraise;
 import cn.meteor.beyondclouds.modules.question.entity.QuestionReply;
@@ -10,6 +12,7 @@ import cn.meteor.beyondclouds.modules.question.mapper.QuestionPraiseMapper;
 import cn.meteor.beyondclouds.modules.question.service.IQuestionPraiseService;
 import cn.meteor.beyondclouds.modules.question.service.IQuestionReplyService;
 import cn.meteor.beyondclouds.modules.question.service.IQuestionService;
+import cn.meteor.beyondclouds.modules.queue.service.IMessageQueueService;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -28,6 +31,7 @@ public class QuestionPraiseServiceImpl extends ServiceImpl<QuestionPraiseMapper,
 
     private IQuestionService questionService;
     private IQuestionReplyService questionReplyService;
+    private IMessageQueueService messageQueueService;
 
     @Autowired
     public void setQuestionService(IQuestionService questionService) {
@@ -39,6 +43,11 @@ public class QuestionPraiseServiceImpl extends ServiceImpl<QuestionPraiseMapper,
         this.questionReplyService = questionReplyService;
     }
 
+    @Autowired
+    public void setMessageQueueService(IMessageQueueService messageQueueService) {
+        this.messageQueueService = messageQueueService;
+    }
+
     @Override
     public void questionPraise(String currentUserId, String questionId) throws QuestionServiceException {
         //1.查找问题是否存在
@@ -68,6 +77,8 @@ public class QuestionPraiseServiceImpl extends ServiceImpl<QuestionPraiseMapper,
         // 更新获赞数量
         question.setPraiseNum(question.getPraiseNum() + 1);
         questionService.updateById(question);
+
+        messageQueueService.sendDataItemChangeMessage(DataItemChangeMessage.addMessage(DataItemType.QUESTION_PRAISE, questionPraise.getPraiseId()));
     }
 
     @Override