From 7338052ad16f1f2f5dc338f6c20643ebbc836f00 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Fri, 14 Mar 2025 11:42:16 +0800 Subject: [PATCH] feat(mallMember): 添加邀请码查询功能 --- 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