diff --git a/ruoyi-modules/ruoyi-content/src/main/java/com/wzj/soopin/content/service/impl/CommentServiceImpl.java b/ruoyi-modules/ruoyi-content/src/main/java/com/wzj/soopin/content/service/impl/CommentServiceImpl.java index 2d72fe639..0fb81a942 100644 --- a/ruoyi-modules/ruoyi-content/src/main/java/com/wzj/soopin/content/service/impl/CommentServiceImpl.java +++ b/ruoyi-modules/ruoyi-content/src/main/java/com/wzj/soopin/content/service/impl/CommentServiceImpl.java @@ -406,7 +406,6 @@ public class CommentServiceImpl extends ServiceImpl 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 impl }else{ return null; } + mqMessage.setTag(MessageActionEnum.INTERACTION_COMMENT.name()); } else { // 回复评论,通知父评论作者 @@ -440,6 +440,8 @@ public class CommentServiceImpl extends ServiceImpl impl }else{ return null; } + mqMessage.setTag(MessageActionEnum.INTERACTION_REPLY.name()); + } mqMessage.setData(params); return mqMessage; diff --git a/script/docker/docker.txt b/script/docker/docker.txt index 9ade5160f..90bf0f87f 100644 --- a/script/docker/docker.txt +++ b/script/docker/docker.txt @@ -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 \