From 664184af3e070dee665ee736caffa0297804975f Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Tue, 18 Mar 2025 11:46:02 +0800 Subject: [PATCH] perf(mall): 移除会员利润计算中的异步执行 --- src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java | 16 ++++++++++++++++ 1 files changed, 16 insertions(+), 0 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java b/src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java index 99a93d4..b21716d 100644 --- a/src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java +++ b/src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java @@ -67,4 +67,20 @@ RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE.getRoute(), id); } + + public void sendChargeSuccessMsg(Long id) { + log.info("发送充值成功消息:{}",id); + rabbitTemplate.convertAndSend( + RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE_BALANCE.getExchange(), + RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE_BALANCE.getRoute(), + id); + } + + public void sendNodeUpMsg(Long memberId) { + log.info("发送节点升级消息:{}",memberId); + rabbitTemplate.convertAndSend( + RabbitQueueEnum.RUN_VIP_NODE_UP.getExchange(), + RabbitQueueEnum.RUN_VIP_NODE_UP.getRoute(), + memberId); + } } -- Gitblit v1.9.1