From 7686ae7d1efc5dac4204ab66560bc140c3eac573 Mon Sep 17 00:00:00 2001 From: tianfeng <769204422@qq.com> Date: Thu, 29 Jan 2026 19:58:53 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=BE=E6=8A=A5=E6=B6=88=E6=81=AF=E9=80=BB?= =?UTF-8?q?=E8=BE=91=E5=8E=BB=E9=99=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ApprovalDynamicReportStrategy.java | 18 +++++++++--------- ...ApprovalDynamicReportClientServiceImpl.java | 10 +++++----- 2 files changed, 14 insertions(+), 14 deletions(-) diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/strategy/ApprovalDynamicReportStrategy.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/strategy/ApprovalDynamicReportStrategy.java index 1049d330..60a16292 100644 --- a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/strategy/ApprovalDynamicReportStrategy.java +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/strategy/ApprovalDynamicReportStrategy.java @@ -41,17 +41,17 @@ public class ApprovalDynamicReportStrategy implements ApprovalStrategy { Set userIds = getUserIds(param); //保存数据 - dynamicMessageService.saveBatch(dto.getContent(), dto.getContentId(), userIds, dto.getTags()); +// dynamicMessageService.saveBatch(dto.getContent(), dto.getContentId(), userIds, dto.getTags()); //发送消息标记 - dynamicMessageService.mapByUserIdsByContentId(userIds) - .forEach((key, list) -> newsletterClient - .send(new NewsletterResultCmd() - .setUserIds(List.of(key)) - .setEvent(NewsletterEvent.DYNAMIC_MESSAGE_QUANTITY) - .setData(list.size()) - ) - ); +// dynamicMessageService.mapByUserIdsByContentId(userIds) +// .forEach((key, list) -> newsletterClient +// .send(new NewsletterResultCmd() +// .setUserIds(List.of(key)) +// .setEvent(NewsletterEvent.DYNAMIC_MESSAGE_QUANTITY) +// .setData(list.size()) +// ) +// ); } diff --git a/rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/service/approval/impl/ApprovalDynamicReportClientServiceImpl.java b/rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/service/approval/impl/ApprovalDynamicReportClientServiceImpl.java index 40295218..9ed260f1 100644 --- a/rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/service/approval/impl/ApprovalDynamicReportClientServiceImpl.java +++ b/rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/service/approval/impl/ApprovalDynamicReportClientServiceImpl.java @@ -128,11 +128,11 @@ public class ApprovalDynamicReportClientServiceImpl implements ApprovalDynamicRe DynamicMessageEnum.DYNAMIC_VIOLATION); //发送消息给被举报人 - newsletterClient.send( - new NewsletterResultCmd() - .setUserIds(List.of(content.getCreateUser())) - .setEvent(NewsletterEvent.DYNAMIC_MESSAGE_QUANTITY) - .setData(1)); +// newsletterClient.send( +// new NewsletterResultCmd() +// .setUserIds(List.of(content.getCreateUser())) +// .setEvent(NewsletterEvent.DYNAMIC_MESSAGE_QUANTITY) +// .setData(1)); //发送消息给举报人 sendMq(cmd.getApprovalUserId(), content, complaints, DynamicMessageEnum.REPORT_SUCCESS,