From 575411c3f1abc10184ee2c1b416241246f943226 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Fri, 03 Jan 2025 10:35:58 +0800
Subject: [PATCH] refactor(mall): 修改购买 VIP 接口名称
---
src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java | 29 ++++++++++++++++++++++++-----
1 files changed, 24 insertions(+), 5 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..2aea39f 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
@@ -4,10 +4,7 @@
import cc.mrbird.febs.common.enumerates.RunVipDataDictionaryEnum;
import cc.mrbird.febs.common.enumerates.YesOrNoEnum;
import cc.mrbird.febs.mall.dto.ApiMemberChargeFailDto;
-import cc.mrbird.febs.mall.entity.AgentInfo;
-import cc.mrbird.febs.mall.entity.DataDictionaryCustom;
-import cc.mrbird.febs.mall.entity.MallCharge;
-import cc.mrbird.febs.mall.entity.MallMember;
+import cc.mrbird.febs.mall.entity.*;
import cc.mrbird.febs.mall.mapper.DataDictionaryCustomMapper;
import cc.mrbird.febs.mall.mapper.MallChargeMapper;
import cc.mrbird.febs.mall.mapper.MallMemberMapper;
@@ -15,6 +12,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;
@@ -27,7 +25,9 @@
import org.springframework.transaction.annotation.Transactional;
import java.math.BigDecimal;
+import java.util.Comparator;
import java.util.List;
+import java.util.Optional;
import java.util.Set;
import java.util.stream.Collectors;
@@ -46,6 +46,7 @@
private final RunVipMapper runVipMapper;
private final IApiMallMemberWalletService walletService;
private final IApiMallMemberService mallMemberService;
+ private final AgentProducer agentProducer;
@Override
@Transactional(rollbackFor = Exception.class)
@@ -209,11 +210,23 @@
// 获取会员信息
MallMember mallMember = mallMemberMapper.selectById(memberId);
if (mallMember == null) {
- throw new IllegalArgumentException("会员不存在");
+ log.info("会员不存在");
+ return;
}
// 已经是节点则跳过
if (YesOrNoEnum.YES.getValue() == mallMember.getDirector()) {
+ return;
+ }
+
+ //节点不是最高等级不升级节点
+ Optional<RunVip> max = runVipMapper.selectList(null).stream().max(Comparator.comparing(RunVip::getOrderNumber));
+ RunVip maxRunVip = max.orElse(null);
+ if (maxRunVip == null) {
+ log.info("会员等级不存在");
+ return;
+ }
+ if (!maxRunVip.getVipCode().equals(mallMember.getLevel())) {
return;
}
@@ -282,6 +295,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