From 05c40a68b5664c5ed41dbaa57ba30f0c73757b26 Mon Sep 17 00:00:00 2001 From: Hentua <wangdoubleone@gmail.com> Date: Tue, 25 Apr 2023 11:10:48 +0800 Subject: [PATCH] fix --- src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java | 10 ++++++++++ 1 files changed, 10 insertions(+), 0 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java b/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java index 8ab7948..3f74175 100644 --- a/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java +++ b/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java @@ -58,4 +58,14 @@ } } + @RabbitListener(queues = QueueConstants.ORDER_BONUS) + public void calOrderBonus(String orderId) { + log.info("收到订单分红消息:{}", orderId); + try { + memberProfitService.orderBonus(Long.parseLong(orderId)); + } catch (Exception e) { + log.error("订单分红消息异常:", e); + } + } + } -- Gitblit v1.9.1