From 093758afe90dcaba20b3dbfc95649dd8c9b1ffcb Mon Sep 17 00:00:00 2001 From: wangqx Date: Sat, 11 Oct 2025 10:50:24 +0800 Subject: [PATCH] =?UTF-8?q?[fix]=E4=BF=AE=E6=94=B9=E5=9B=9E=E5=A4=8D?= =?UTF-8?q?=E8=AF=84=E8=AE=BA=E7=9A=84=E9=80=9A=E7=9F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../wzj/soopin/content/service/impl/CommentServiceImpl.java | 4 +++- script/docker/docker.txt | 2 -- 2 files changed, 3 insertions(+), 3 deletions(-) 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 \