| | |
| | | return; |
| | | } |
| | | |
| | | // 检查直推人数 |
| | | // 检查直推人数(有效的直推人数) |
| | | long directCount = allMembers.stream() |
| | | .filter(member -> mallMember.getInviteId().equals(member.getReferrerId())) |
| | | .filter(member -> mallMember.getInviteId().equals(member.getReferrerId()) |
| | | && !"YOUKE".equals(member.getLevel())) |
| | | .count(); |
| | | if (directCount < directCnt) { |
| | | return; |
| | | } |
| | | |
| | | // 检查团队人数 |
| | | if (allMembers.size() < teamCnt) { |
| | | // 检查团队人数(有效的团队人数) |
| | | long allMembersCount = allMembers.stream() |
| | | .filter(member -> !"YOUKE".equals(member.getLevel())) |
| | | .count(); |
| | | if (allMembersCount < teamCnt) { |
| | | return; |
| | | } |
| | | |
| | |
| | | //更新会员的等级和会员升级的时间 |
| | | mallMemberMapper.updateVipLevelTimeAndLevel(memberId,DateUtil.date(),vipCode); |
| | | |
| | | //直推权益 |
| | | asyncService.directCoin(mallCharge.getAmount(),memberId); |
| | | |
| | | agentProducer.sendNodeUpMsg(memberId); |
| | | } |
| | | |