举报消息逻辑去除

This commit is contained in:
tianfeng 2026-01-29 19:58:53 +08:00
parent 8cc77bc227
commit 7686ae7d1e
2 changed files with 14 additions and 14 deletions

View File

@ -41,17 +41,17 @@ public class ApprovalDynamicReportStrategy implements ApprovalStrategy {
Set<Long> 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())
// )
// );
}

View File

@ -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,