From 581e2ea0be32a78c23f18db85e27bd130041f0f3 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Fri, 05 Jul 2024 17:10:04 +0800
Subject: [PATCH] 逻辑
---
src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java | 142 ++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 133 insertions(+), 9 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java
index 1350b7f..9492d52 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java
@@ -14,10 +14,13 @@
import cc.mrbird.febs.dapp.dto.PriceSettingDto;
import cc.mrbird.febs.dapp.entity.*;
import cc.mrbird.febs.dapp.enumerate.DataDictionaryEnum;
+import cc.mrbird.febs.dapp.enumerate.MemberLevelEnum;
import cc.mrbird.febs.dapp.mapper.*;
import cc.mrbird.febs.dapp.service.DappMemberService;
import cc.mrbird.febs.dapp.vo.AdminSystemFeeVo;
+import cc.mrbird.febs.dapp.vo.TeamDownVo;
import cc.mrbird.febs.dapp.vo.TeamListVo;
+import cc.mrbird.febs.dapp.vo.TeamUpVo;
import cc.mrbird.febs.system.entity.User;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjectUtil;
@@ -36,6 +39,7 @@
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import java.util.stream.Collectors;
/**
* @author
@@ -54,6 +58,8 @@
private final DappAchieveMemberTreeDao dappAchieveMemberTreeDao;
private final DataDictionaryCustomMapper dataDictionaryCustomMapper;
private final DappFundFlowDao dappFundFlowDao;
+ private final DbMemberNodeMapper dbMemberNodeMapper;
+ private final DappStorageMapper dappStorageMapper;
@Override
@Transactional(rollbackFor = Exception.class)
@@ -135,11 +141,6 @@
if (parent == null) {
throw new FebsException("recommender is not exist");
}
-
-// List<DappMemberEntity> child = dappMemberDao.selectChildMemberDirectOrNot(connectDto.getInviteId(), 1, null);
-// if (child.size() == 6) {
-// throw new FebsException("Invite Code is Invalid");
-// }
} else {
connectDto.setInviteId(null);
}
@@ -287,16 +288,14 @@
member.setChainType(chainType);
member.setAccountType(accountType);
member.setActiveStatus(2);
+ member.setNodeType(2);
+ member.setLevel(MemberLevelEnum.DAO_0.getCode());
dappMemberDao.insert(member);
DappWalletCoinEntity walletCoin = new DappWalletCoinEntity();
walletCoin.setMemberId(member.getId());
dappWalletCoinDao.insert(walletCoin);
-
- DappWalletMineEntity walletMine = new DappWalletMineEntity();
- walletMine.setMemberId(member.getId());
- dappWalletMineDao.insert(walletMine);
if (StrUtil.isEmpty(refererId)) {
refererId = "0";
@@ -383,6 +382,131 @@
dataDictionaryCustomMapper.updateById(symbolPriceDic);
}
+ @Override
+ public IPage<DbMemberNode> memberNodeList(DbMemberNode dbMemberNode, QueryRequest request) {
+ Page<DbMemberNode> page = new Page<>(request.getPageNum(), request.getPageSize());
+ return dbMemberNodeMapper.selectListInPage(dbMemberNode, page);
+ }
+
+ @Override
+ public TeamUpVo teamUp() {
+ Long memberId = LoginUserUtil.getAppUser().getId();
+ TeamUpVo teamUpVo = new TeamUpVo();
+
+ DappMemberEntity memberEntity = dappMemberDao.selectById(memberId);
+ List<DappMemberEntity> directMembers = dappMemberDao.selectChildMemberDirectOrNot(memberEntity.getInviteId(), 1, null);
+ if(CollUtil.isEmpty(directMembers)){
+ teamUpVo.setTeamCnt(0);
+ teamUpVo.setTeamCntAva(0);
+ teamUpVo.setTeamAchieve(BigDecimal.ZERO);
+ teamUpVo.setDirectCnt(0);
+ teamUpVo.setDirectCntAva(0);
+ teamUpVo.setDirectAchieve(BigDecimal.ZERO);
+ }else{
+ teamUpVo.setDirectCnt(CollUtil.isEmpty(directMembers) ? 0 : directMembers.size());
+ List<DappMemberEntity> directCntAva = directMembers.stream().filter(dappMemberEntity -> dappMemberEntity.getActiveStatus() == 1).collect(Collectors.toList());
+ teamUpVo.setDirectCntAva(CollUtil.isEmpty(directCntAva) ? 0 : directCntAva.size());
+ if(CollUtil.isNotEmpty(directCntAva)){
+ List<Long> collectDirect = directCntAva.stream().map(DappMemberEntity::getId).collect(Collectors.toList());
+ QueryWrapper<DappStorage> storageQueryWrapper = new QueryWrapper<>();
+ storageQueryWrapper.in("member_id",collectDirect);
+ storageQueryWrapper.eq("state",1);
+ List<DappStorage> dappStoragesDirect = dappStorageMapper.selectList(storageQueryWrapper);
+ BigDecimal directAchieve = dappStoragesDirect.stream()
+ .map(DappStorage::getAmount) // 映射amount到流中
+ .reduce(BigDecimal.ZERO, BigDecimal::add);
+ teamUpVo.setDirectAchieve(directAchieve);
+ }else{
+ teamUpVo.setDirectAchieve(BigDecimal.ZERO);
+ }
+
+ List<DappMemberEntity> teamMembers = dappMemberDao.selectChildMemberDirectOrNot(memberEntity.getInviteId(), 2, null);
+ teamUpVo.setTeamCnt(CollUtil.isEmpty(teamMembers) ? 0 : teamMembers.size());
+ List<DappMemberEntity> teamCntAva = teamMembers.stream().filter(dappMemberEntity -> dappMemberEntity.getActiveStatus() == 1).collect(Collectors.toList());
+ teamUpVo.setTeamCntAva(CollUtil.isEmpty(teamCntAva) ? 0 : teamCntAva.size());
+
+ if(CollUtil.isNotEmpty(teamCntAva)){
+ List<Long> collectTeam = teamCntAva.stream().map(DappMemberEntity::getId).collect(Collectors.toList());
+ QueryWrapper<DappStorage> collectTeamWrapper = new QueryWrapper<>();
+ collectTeamWrapper.in("member_id",collectTeam);
+ collectTeamWrapper.eq("state",1);
+ List<DappStorage> dappStoragesTeam = dappStorageMapper.selectList(collectTeamWrapper);
+ BigDecimal teamAchieve = dappStoragesTeam.stream()
+ .map(DappStorage::getAmount) // 映射amount到流中
+ .reduce(BigDecimal.ZERO, BigDecimal::add);
+ teamUpVo.setTeamAchieve(teamAchieve);
+ }else{
+ teamUpVo.setTeamAchieve(BigDecimal.ZERO);
+ }
+ }
+ return teamUpVo;
+ }
+
+ @Override
+ public List<TeamDownVo> teamDown() {
+ Long memberId = LoginUserUtil.getAppUser().getId();
+ List<TeamDownVo> objects = new ArrayList<>();
+
+ DappMemberEntity memberEntity = dappMemberDao.selectById(memberId);
+ List<DappMemberEntity> directMembers = dappMemberDao.selectChildMemberDirectOrNot(memberEntity.getInviteId(), 1, null);
+ directMembers.add(memberEntity);
+
+ if(CollUtil.isNotEmpty(directMembers)){
+
+ for(DappMemberEntity directMember : directMembers){
+ TeamDownVo teamDownVo = new TeamDownVo();
+
+
+
+ teamDownVo.setAddress(directMember.getAddress());
+ List<DappMemberEntity> teamMembers = dappMemberDao.selectChildMemberDirectOrNot(directMember.getInviteId(), 2, null);
+ if(CollUtil.isEmpty(teamMembers)){
+ teamDownVo.setActiveCnt(0);
+ teamDownVo.setActiveAchieve(BigDecimal.ZERO);
+ }else{
+ List<DappMemberEntity> teamCntAva = teamMembers.stream().filter(dappMemberEntity -> dappMemberEntity.getActiveStatus() == 1).collect(Collectors.toList());
+ List<Long> collectTeam = teamCntAva.stream().map(DappMemberEntity::getId).collect(Collectors.toList());
+
+ if(CollUtil.isNotEmpty(collectTeam)){
+ QueryWrapper<DappStorage> collectTeamWrapper = new QueryWrapper<>();
+ collectTeamWrapper.in("member_id",collectTeam);
+ collectTeamWrapper.eq("state",1);
+ List<DappStorage> dappStoragesTeam = dappStorageMapper.selectList(collectTeamWrapper);
+ BigDecimal teamAchieve = dappStoragesTeam.stream()
+ .map(DappStorage::getAmount) // 映射amount到流中
+ .reduce(BigDecimal.ZERO, BigDecimal::add);
+
+ teamDownVo.setActiveCnt(teamCntAva.size());
+ teamDownVo.setActiveAchieve(teamAchieve);
+ }else{
+ teamDownVo.setActiveCnt(0);
+ teamDownVo.setActiveAchieve(BigDecimal.ZERO);
+ }
+ }
+
+ objects.add(teamDownVo);
+ }
+ }
+ return objects;
+ }
+
+ @Override
+ public IPage<DappStorage> storageList(DappStorage dappStorage, QueryRequest request) {
+ Page<DappStorage> page = new Page<>(request.getPageNum(), request.getPageSize());
+ return dappStorageMapper.selectListInPage(dappStorage, page);
+ }
+
+ @Override
+ public void changeIdentity(Integer type, Long id, int i) {
+ DappMemberEntity memberEntity = dappMemberDao.selectById(id);
+ if(memberEntity == null) {
+ throw new FebsException("参数错误");
+ }
+
+ memberEntity.setNodeType(i);
+ dappMemberDao.updateById(memberEntity);
+ }
+
public TeamListVo buildTeamMatrix(DappAchieveMemberTreeEntity node) {
List<DappAchieveMemberTreeEntity> childNodes = dappAchieveMemberTreeDao.selectMatrixChildNode(node.getTopNode(), node.getTreeNode());
--
Gitblit v1.9.1