From e081193a764667cb091390b034795ee05a36b4fb Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Tue, 31 Dec 2024 15:20:32 +0800
Subject: [PATCH] feat(rabbitmq): 新增节点升级消息功能
---
src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java | 8 ++++++++
1 files changed, 8 insertions(+), 0 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java
index 9091b6b..a939650 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java
@@ -15,6 +15,7 @@
import cc.mrbird.febs.mall.service.IAgentService;
import cc.mrbird.febs.mall.service.IApiMallMemberService;
import cc.mrbird.febs.mall.service.IApiMallMemberWalletService;
+import cc.mrbird.febs.rabbit.producter.AgentProducer;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil;
@@ -46,6 +47,7 @@
private final RunVipMapper runVipMapper;
private final IApiMallMemberWalletService walletService;
private final IApiMallMemberService mallMemberService;
+ private final AgentProducer agentProducer;
@Override
@Transactional(rollbackFor = Exception.class)
@@ -282,6 +284,12 @@
Long memberId = mallCharge.getMemberId();
String vipCode = mallCharge.getVipCode();
mallMemberMapper.updateVipLevelTimeAndLevel(memberId,DateUtil.date(),vipCode);
+
+ agentProducer.sendNodeUpMsg(memberId);
+ }
+
+ @Override
+ public void nodeUpMsg(Long memberId) {
DataDictionaryCustom directCntDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
RunVipDataDictionaryEnum.NODE_DIRECT_CNT.getType(),
RunVipDataDictionaryEnum.NODE_DIRECT_CNT.getCode());
--
Gitblit v1.9.1