From e2a60bc44d6cfac67301dfc35163acac2196e300 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Tue, 31 Dec 2024 15:56:04 +0800
Subject: [PATCH] test(mall): 更新测试账号和邀请码

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java |   13 ++++++++++++-
 1 files changed, 12 insertions(+), 1 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java
index bf84667..e97d254 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java
@@ -16,6 +16,7 @@
 import cc.mrbird.febs.pay.model.BrandWCPayRequestData;
 import cc.mrbird.febs.pay.service.IXcxPayService;
 import cc.mrbird.febs.pay.util.MD5;
+import cc.mrbird.febs.rabbit.producter.AgentProducer;
 import cc.mrbird.febs.vip.VipSettingUnAliveSettingBo;
 import cc.mrbird.febs.vip.entity.MallVipConfig;
 import cc.mrbird.febs.vip.mapper.MallVipConfigMapper;
@@ -70,7 +71,6 @@
     private final MallShopApplyMapper mallShopApplyMapper;
     private final MallRegisterAppealMapper mallRegisterAppealMapper;
     private final MallTeamLeaderMapper mallTeamLeaderMapper;
-    private final SpringContextHolder springContextHolder;
     private final MallAgentRecordMapper mallAgentRecordMapper;
     private final IMallMoneyFlowService mallMoneyFlowService;
     private final IMallMemberCollectionService mallMemberCollectionService;
@@ -88,6 +88,7 @@
     private final MallStoreItemMapper mallStoreItemMapper;
     private final MallStoreMemberMapper mallStoreMemberMapper;
     private final MallMemberWithdrawMapper mallMemberWithdrawMapper;
+    private final AgentProducer agentProducer;
 
 
     @Value("${spring.profiles.active}")
@@ -154,6 +155,8 @@
         mallMember.setAccountStatus(YesOrNoEnum.YES.getValue());
         mallMember.setAccountType(MallMember.ACCOUNT_TYPE_NORMAL);
         mallMember.setSex("男");
+        mallMember.setDirector(YesOrNoEnum.NO.getValue());
+        mallMember.setDirectorTime(DateUtil.date());
         mallMember.setBindPhone(account);
 
         this.baseMapper.insert(mallMember);
@@ -199,6 +202,8 @@
         wallet.setBalance(BigDecimal.ZERO);
         wallet.setMemberId(mallMember.getId());
         mallMemberWalletMapper.insert(wallet);
+
+        agentProducer.sendNodeUpMsg(mallMember.getId());
         return new FebsResponse().success().message("注册成功");
     }
 
@@ -337,6 +342,9 @@
                 new LambdaQueryWrapper<MallMember>()
                         .eq(MallMember::getReferrerId, inviteId)
         );
+        if(CollUtil.isEmpty(directMembers)){
+            return memberIds;
+        }
         memberIds.addAll(directMembers.stream().map(MallMember::getId).collect(Collectors.toSet()));
 
         // 获取团队成员
@@ -344,6 +352,9 @@
                 new LambdaQueryWrapper<MallMember>()
                         .in(MallMember::getReferrerId, directMembers.stream().map(MallMember::getInviteId).collect(Collectors.toSet()))
         );
+        if(CollUtil.isEmpty(teamMembers)){
+            return memberIds;
+        }
         memberIds.addAll(teamMembers.stream().map(MallMember::getId).collect(Collectors.toSet()));
 
         return memberIds;

--
Gitblit v1.9.1