From 38d547d91d7eee81ed56ca6ceba7fd393952a082 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Mon, 12 May 2025 16:12:15 +0800
Subject: [PATCH] feat(sign): 增加签到获得会员经验或积分的功能 - 在 ApiSignVo 中添加 mostSignIn 字段，用于区分签到获得的类型 - 在 ScoreFlowTypeEnum 中新增 SIGN_EXPERIENCE 和 SIGN_SCORE 类型 - 修改 ScoreServiceImpl 中的签到逻辑，支持获得会员经验和积分 - 更新 ScoreSettingDto，添加 mostSignIn 字段用于配置签到获得类型 - 在前端设置页面添加签到获得类型的选项
---
src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java | 23 +++++++++++++++++++++++
1 files changed, 23 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 366ac20..e7b9d19 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/consumer/AgentConsumer.java
@@ -1,5 +1,6 @@
package cc.mrbird.febs.rabbit.consumer;
+import cc.mrbird.febs.mall.service.HappyActivityService;
import cc.mrbird.febs.mall.service.IAgentService;
import cc.mrbird.febs.mall.service.IApiMallOrderInfoService;
import cc.mrbird.febs.mall.service.IMemberProfitService;
@@ -29,6 +30,8 @@
private IAgentService agentService;
@Autowired
private IMemberProfitService memberProfitService;
+ @Autowired
+ private HappyActivityService happyActivityService;
@RabbitListener(queues = QueueConstants.QUEUE_DEFAULT)
public void agentReturn(Message message, Channel channel) {
@@ -106,4 +109,24 @@
log.error("会员升级消息异常", e);
}
}
+
+ @RabbitListener(queues = QueueConstants.SALE_LEVEL_UP)
+ public void saleLevelUp(Long orderId) {
+ log.info("收到团长升级:{}", orderId);
+ try {
+ vipCommonService.saleLevelUp(orderId);
+ } catch (Exception e) {
+ log.error("团长升级消息异常", e);
+ }
+ }
+
+ @RabbitListener(queues = QueueConstants.ACTIVITY_ORDER_ITEM_CHECK)
+ public void checkActivityItem(Long orderId) {
+ log.info("收到核销活动门票:{}", orderId);
+ try {
+ happyActivityService.checkActivityItem(orderId);
+ } catch (Exception e) {
+ log.error("核销活动门票异常", e);
+ }
+ }
}
--
Gitblit v1.9.1