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