| | |
| | | |
| | | @Override |
| | | public void memberLevelUp() { |
| | | log.info("会员等级升级"); |
| | | /** |
| | | * 获取当前所有的已完成、未转换的买单的用户 |
| | | */ |
| | |
| | | String levelType = MemberLevelNewEnum.ZERO_LEVEL.getLevelType(levelCode - 1); |
| | | List<MallMember> mallMembersDirects = memberMapper.selectByRefererId(mallMemberRef.getInviteId()); |
| | | for(MallMember memberDirect : mallMembersDirects){ |
| | | List<MallMember> mallMembers1 = memberMapper.selectMemberWithLevelAndMemberId(levelType, memberDirect.getInviteId()); |
| | | List<MallMember> mallMembers1 = memberMapper.selectMemberWithLevelAndMemberIdNew(levelType, memberDirect.getInviteId()); |
| | | if(CollUtil.isEmpty(mallMembers1)){ |
| | | continue; |
| | | } |
| | |
| | | Set<Long> collectAll = mallMembersAll.stream().map(MallMember::getId).collect(Collectors.toSet()); |
| | | Collection<Long> intersection1 = CollUtil.intersection(collectAll, collect); |
| | | if(teamCnt <= (CollUtil.isEmpty(intersection1) ? 0 : intersection1.size())){ |
| | | if(!MemberLevelNewEnum.ZERO_LEVEL.getType().equals(level)){ |
| | | log.info("{},有效人数为:{},升级成为:{},由于:{}",mallMemberRef.getAccountLogin(),intersection1,level,mallMember.getAccountLogin()); |
| | | } |
| | | mallMemberRef.setLevel(level); |
| | | memberMapper.updateById(mallMemberRef); |
| | | |