From 70b8b5feba16d3ef11441c3ee9878420df3fdf37 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Tue, 25 Mar 2025 19:23:19 +0800
Subject: [PATCH] perf(mall): 移除会员利润计算中的异步执行
---
src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java | 11 ++++++++++-
1 files changed, 10 insertions(+), 1 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 bcdb7d9..0e1edcf 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java
@@ -4,7 +4,6 @@
import cc.mrbird.febs.mall.service.IApiMallOrderInfoService;
import cc.mrbird.febs.mall.service.IMemberProfitService;
import cc.mrbird.febs.rabbit.constants.QueueConstants;
-import cc.mrbird.febs.rabbit.enumerates.RabbitQueueEnum;
import com.rabbitmq.client.Channel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
@@ -112,4 +111,14 @@
log.error("支付后同意验证:", e);
}
}
+
+ @RabbitListener(queues = QueueConstants.YWG_ROLL_SEND)
+ public void rollSendMsg(Long orderId) {
+ log.info("支付后生成我的课程或者我的民宿卷:{}", orderId);
+ try {
+ agentService.rollSendMsg(orderId);
+ } catch (Exception e) {
+ log.error("支付后生成我的课程或者我的民宿卷:", e);
+ }
+ }
}
--
Gitblit v1.9.1