Commit 28a81132 by 段启岩

点赞取消提醒自己

parent 087373a1
...@@ -12,6 +12,7 @@ import cn.meteor.beyondclouds.modules.blog.entity.BlogPraise; ...@@ -12,6 +12,7 @@ import cn.meteor.beyondclouds.modules.blog.entity.BlogPraise;
import cn.meteor.beyondclouds.modules.blog.service.IBlogCommentService; import cn.meteor.beyondclouds.modules.blog.service.IBlogCommentService;
import cn.meteor.beyondclouds.modules.blog.service.IBlogPraiseService; import cn.meteor.beyondclouds.modules.blog.service.IBlogPraiseService;
import cn.meteor.beyondclouds.modules.blog.service.IBlogService; import cn.meteor.beyondclouds.modules.blog.service.IBlogService;
import cn.meteor.beyondclouds.modules.feedback.service.IFeedbackService;
import cn.meteor.beyondclouds.modules.im.server.SocketIOService; import cn.meteor.beyondclouds.modules.im.server.SocketIOService;
import cn.meteor.beyondclouds.modules.message.dto.MessageDTO; import cn.meteor.beyondclouds.modules.message.dto.MessageDTO;
import cn.meteor.beyondclouds.modules.message.entity.Message; import cn.meteor.beyondclouds.modules.message.entity.Message;
...@@ -332,6 +333,7 @@ public class MessageListener implements DataItemChangeListener { ...@@ -332,6 +333,7 @@ public class MessageListener implements DataItemChangeListener {
*/ */
if (itemType.equals(DataItemType.BLOG_PRAISE)) { if (itemType.equals(DataItemType.BLOG_PRAISE)) {
BlogPraise blogPraise = blogPraiseService.getById(itemId); BlogPraise blogPraise = blogPraiseService.getById(itemId);
if (!blogPraise.getUserId().equals(operatorId)) {
msgType = MessageType.BLOG_PRAISE.getType(); msgType = MessageType.BLOG_PRAISE.getType();
Blog blog = blogService.getById(blogPraise.getTargetId()); Blog blog = blogService.getById(blogPraise.getTargetId());
toUserId = blog.getUserId(); toUserId = blog.getUserId();
...@@ -341,12 +343,14 @@ public class MessageListener implements DataItemChangeListener { ...@@ -341,12 +343,14 @@ public class MessageListener implements DataItemChangeListener {
blog.getBlogId(), blog.getBlogId(),
blog.getBlogTitle()); blog.getBlogTitle());
} }
}
/** /**
* 项目点赞 * 项目点赞
*/ */
if (itemType.equals(DataItemType.PROJECT_PRAISE)) { if (itemType.equals(DataItemType.PROJECT_PRAISE)) {
ProjectPraise projectPraise = projectPraiseService.getById(itemId); ProjectPraise projectPraise = projectPraiseService.getById(itemId);
if (!projectPraise.getUserId().equals(operatorId)) {
msgType = MessageType.PROJECT_PRAISE.getType(); msgType = MessageType.PROJECT_PRAISE.getType();
Project project = projectService.getById(projectPraise.getTargetId()); Project project = projectService.getById(projectPraise.getTargetId());
toUserId = project.getUserId(); toUserId = project.getUserId();
...@@ -356,12 +360,14 @@ public class MessageListener implements DataItemChangeListener { ...@@ -356,12 +360,14 @@ public class MessageListener implements DataItemChangeListener {
project.getProjectId(), project.getProjectId(),
project.getProjectName()); project.getProjectName());
} }
}
/** /**
* 问题点赞 * 问题点赞
*/ */
if (itemType.equals(DataItemType.QUESTION_PRAISE)) { if (itemType.equals(DataItemType.QUESTION_PRAISE)) {
QuestionPraise questionPraise = questionPraiseService.getById(itemId); QuestionPraise questionPraise = questionPraiseService.getById(itemId);
if (!questionPraise.getUserId().equals(operatorId)) {
msgType = MessageType.QUESTION_PRAISE.getType(); msgType = MessageType.QUESTION_PRAISE.getType();
Question question = questionService.getById(questionPraise.getTargetId()); Question question = questionService.getById(questionPraise.getTargetId());
toUserId = question.getUserId(); toUserId = question.getUserId();
...@@ -371,12 +377,14 @@ public class MessageListener implements DataItemChangeListener { ...@@ -371,12 +377,14 @@ public class MessageListener implements DataItemChangeListener {
question.getQuestionId(), question.getQuestionId(),
question.getQuestionTitle()); question.getQuestionTitle());
} }
}
/** /**
* 动态点赞 * 动态点赞
*/ */
if (itemType.equals(DataItemType.POST_PRAISE)) { if (itemType.equals(DataItemType.POST_PRAISE)) {
PostPraise postPraise = postPraiseService.getById(itemId); PostPraise postPraise = postPraiseService.getById(itemId);
if (!postPraise.getUserId().equals(operatorId)) {
msgType = MessageType.POST_PRAISE.getType(); msgType = MessageType.POST_PRAISE.getType();
Post post = postService.getById(postPraise.getTargetId()); Post post = postService.getById(postPraise.getTargetId());
toUserId = post.getUserId(); toUserId = post.getUserId();
...@@ -385,6 +393,7 @@ public class MessageListener implements DataItemChangeListener { ...@@ -385,6 +393,7 @@ public class MessageListener implements DataItemChangeListener {
fromUser.getNickName(), fromUser.getNickName(),
post.getContent()); post.getContent());
} }
}
if (null != toUserId) { if (null != toUserId) {
saveAndSendMsg(fromUser, toUserId, msgType, msg); saveAndSendMsg(fromUser, toUserId, msgType, msg);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment