| | |
|---|
| | | DateTime endTime = DateUtil.date(); |
|---|
| | | records.forEach(item -> { |
|---|
| | | CompletableFuture<Void> uCompletableFuture = CompletableFuture.runAsync(() -> { |
|---|
| | | //获取直推 |
|---|
| | | Set<String> directInviteIds = mallMemberMapper.selectList( |
|---|
| | | List<MallMember> directMembers = mallMemberMapper.selectList( |
|---|
| | | new LambdaQueryWrapper<MallMember>() |
|---|
| | | .eq(MallMember::getReferrerId, item.getInviteId()) |
|---|
| | | ).stream() |
|---|
| | | ); |
|---|
| | | //获取直推 |
|---|
| | | Set<String> directInviteIds = directMembers.stream() |
|---|
| | | .map(MallMember::getInviteId) |
|---|
| | | .collect(Collectors.toSet()); |
|---|
| | | Set<String> directCntAvailableInviteIds = directMembers.stream() |
|---|
| | | .filter(member -> !"YOUKE".equals(member.getLevel())) |
|---|
| | | .map(MallMember::getInviteId) |
|---|
| | | .collect(Collectors.toSet()); |
|---|
| | | if(CollUtil.isNotEmpty(directInviteIds)){ |
|---|
| | | item.setDirectCnt(directInviteIds.size()); |
|---|
| | | item.setDirectCntAvailable(directCntAvailableInviteIds.size()); |
|---|
| | | //获取团队 |
|---|
| | | List<MallMember> allMembers = mallMemberMapper.selectList( |
|---|
| | | new LambdaQueryWrapper<MallMember>() |
|---|
