[fix]修改回复评论的通知

This commit is contained in:
wangqx 2025-10-11 10:50:24 +08:00
parent e1d24e1ae7
commit 093758afe9
2 changed files with 3 additions and 3 deletions

View File

@ -406,7 +406,6 @@ public class CommentServiceImpl extends ServiceImpl<CommentMapper, Comment> impl
LoginUser loginUser = LoginHelper.getLoginUser();
MQMessage mqMessage = new MQMessage();
mqMessage.setTag(MessageActionEnum.INTERACTION_COMMENT.name());
mqMessage.setMessageType(MQMessageType.IM.name());
if (bo.getFatherCommentId() == 0L) {
// 评论视频通知视频作者
@ -422,6 +421,7 @@ public class CommentServiceImpl extends ServiceImpl<CommentMapper, Comment> impl
}else{
return null;
}
mqMessage.setTag(MessageActionEnum.INTERACTION_COMMENT.name());
} else {
// 回复评论通知父评论作者
@ -440,6 +440,8 @@ public class CommentServiceImpl extends ServiceImpl<CommentMapper, Comment> impl
}else{
return null;
}
mqMessage.setTag(MessageActionEnum.INTERACTION_REPLY.name());
}
mqMessage.setData(params);
return mqMessage;

View File

@ -110,8 +110,6 @@ docker run -d \
server --address ':9000' --console-address ':9001' /data
rocket-mq
# 创建自定义网络
docker network create rocketmq-single-network
docker run -d --name rocketmq-namesrv \