From b60666a3fe9822277efd717380e619f08ac3ad9f Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Thu, 13 Jun 2024 11:42:23 +0800
Subject: [PATCH] 星级矩阵
---
src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java | 37 +++++++++++++++++++++++++++++--------
1 files changed, 29 insertions(+), 8 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
index 696d9db..c03d789 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
@@ -164,7 +164,7 @@
DappFundFlowEntity fundFlow = new DappFundFlowEntity(member.getId(), transferDto.getAmount().negate(), 1, 2, transferDto.getFee(), transferDto.getTxHash());
dappFundFlowDao.insert(fundFlow);
- chainProducer.sendAchieveTreeMsg(member.getId());
+// chainProducer.sendAchieveTreeMsg(member.getId());
} else {
int type = 1;
// 1-认购 2-充值tfc
@@ -467,7 +467,7 @@
}
@Override
- public FebsResponse memberNode(MemberNodeDto memberNodeDto) {
+ public MemberNodeVo memberNode(MemberNodeDto memberNodeDto) {
DappMemberEntity member = LoginUserUtil.getAppUser();
Integer type = memberNodeDto.getType();
@@ -479,18 +479,39 @@
if(ObjectUtil.isEmpty(dbMemberNode)){
return null;
}
- if(ObjectUtil.isNotEmpty(dbMemberNode.getLeftNode())){
- }
+ return buildTeamMatrix(dbMemberNode);
+ }
+
+ public MemberNodeVo buildTeamMatrix(DbMemberNode dbMemberNode) {
+ Long id = dbMemberNode.getId();
+
MemberNodeVo memberNodeVo = new MemberNodeVo();
- memberNodeVo.setLeftNode(getInviteId(dbMemberNode.getLeftNode()));
- memberNodeVo.setRightNode(getInviteId(dbMemberNode.getRightNode()));
+ memberNodeVo.setInviteId(getInviteId(id));
+ memberNodeVo.setId(id);
+ memberNodeVo.setParentNode(ObjectUtil.isEmpty(dbMemberNode.getParentNode()) ? 0L : dbMemberNode.getParentNode());
+ memberNodeVo.setLeftNode(ObjectUtil.isEmpty(dbMemberNode.getLeftNode()) ? 0L : dbMemberNode.getLeftNode());
+ memberNodeVo.setRightNode(ObjectUtil.isEmpty(dbMemberNode.getRightNode()) ? 0L : dbMemberNode.getRightNode());
+ memberNodeVo.setLeftRight(ObjectUtil.isEmpty(dbMemberNode.getLeftRight()) ? 0 : dbMemberNode.getLeftRight());
- return null;
+ QueryWrapper<DbMemberNode> childQuery = new QueryWrapper<>();
+ childQuery.eq("parent_node",id);
+ childQuery.eq("type", dbMemberNode.getType());
+ childQuery.eq("work_state", DbMemberNode.STATE_ONE);
+ List<DbMemberNode> childrenNode = dbMemberNodeMapper.selectList(childQuery);
+ if(CollUtil.isEmpty(childrenNode)){
+ return memberNodeVo;
+ }
+
+ List<MemberNodeVo> list = new ArrayList<>();
+ for (DbMemberNode childNode : childrenNode) {
+ list.add(buildTeamMatrix(childNode));
+ }
+ memberNodeVo.setChildren(list);
+ return memberNodeVo;
}
public String getInviteId(Long memberNodeId){
- MemberNodeVo memberNodeVo = new MemberNodeVo();
DbMemberNode dbMemberNode = dbMemberNodeMapper.selectById(memberNodeId);
Long memberId = dbMemberNode.getMemberId();
DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
--
Gitblit v1.9.1