From 7f0a7c7643b41cf862061e23900046d7aa78ca11 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Sat, 22 Jun 2024 17:45:06 +0800
Subject: [PATCH] 后台矩阵列表

---
 src/test/java/cc/mrbird/febs/TreeTest.java |  208 ++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 163 insertions(+), 45 deletions(-)

diff --git a/src/test/java/cc/mrbird/febs/TreeTest.java b/src/test/java/cc/mrbird/febs/TreeTest.java
index 12a0ec3..b4d3aa6 100644
--- a/src/test/java/cc/mrbird/febs/TreeTest.java
+++ b/src/test/java/cc/mrbird/febs/TreeTest.java
@@ -1,12 +1,5 @@
 package cc.mrbird.febs;
 
-import cc.mrbird.febs.dapp.mapper.DappAchieveMemberTreeDao;
-import cc.mrbird.febs.dapp.service.DappSystemService;
-import cc.mrbird.febs.tree.MatrixTree;
-import cc.mrbird.febs.tree.MemberNode;
-import cn.hutool.core.util.RandomUtil;
-import org.junit.jupiter.api.Test;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 
 /**
@@ -15,42 +8,167 @@
  **/
 @SpringBootTest
 public class TreeTest {
-
-    @Test
-    public void matrixTest() {
-        MatrixTree matrixTree = MatrixTree.getInstance();
-
-
-        String refererId = null;
-        for (int i = 0; i < 11; i++) {
-            String inviteId = RandomUtil.randomString(6);
-            if (i == 2) {
-                refererId = inviteId;
-            }
-            MemberNode memberNode = new MemberNode();
-            memberNode.setMemberId(Long.parseLong(i + 1 + ""));
-            memberNode.setInviteId(inviteId);
-            memberNode.setAddress(RandomUtil.randomString(14));
-            memberNode.setRefererId(refererId);
-            matrixTree.addNode(memberNode);
-        }
-        System.out.println(System.currentTimeMillis());
-    }
-
-    @Autowired
-    private DappSystemService dappSystemService;
-
-    @Autowired
-    private DappAchieveMemberTreeDao dappAchieveMemberTreeDao;
-
-    @Test
-    public void resetMatrix() {
-        dappSystemService.resetMatrix();
-//        dappAchieveMemberTreeDao.emptyTable();
-    }
-
-    @Test
-    public void limitResetProfitTest() {
-        dappSystemService.putIntoProfit(60L, 1);
-    }
+//
+//    @Autowired
+//    DappSystemService dappSystemService;
+//    @Autowired
+//    DbMemberNodeMapper dbMemberNodeMapper;
+//
+//    @Test
+//    public void matrixTest() {
+//        DbMemberNode dbMemberNode = dbMemberNodeMapper.selectById(171L);
+//
+//        dappSystemService.memberNodeNext(dbMemberNode);
+//    }
+//
+//    @Autowired
+//    private DappSystemService dappSystemService;
+//    @Autowired
+//    private DbMemberNodeMapper dbMemberNodeMapper;
+//
+//    @Autowired
+//    private DappAchieveMemberTreeDao dappAchieveMemberTreeDao;
+//
+//    @Autowired
+//    private DappMemberDao dappMemberDao;
+//
+//    @Autowired
+//    private DappFundFlowDao dappFundFlowDao;
+//
+////    @Test
+////    public void resetMatrixV3() {
+////        Long memberId = 136L;
+////        QueryWrapper<DappFundFlowEntity> objectQueryWrappers = new QueryWrapper<>();
+////        objectQueryWrappers.eq("member_id", memberId);
+////        objectQueryWrappers.orderByDesc("create_time");
+////        List<DappFundFlowEntity> dappFundFlowEntitiess = dappFundFlowDao.selectList(objectQueryWrappers);
+////        if(ObjectUtil.isNotEmpty(dappFundFlowEntitiess)){
+////            DappAchieveMemberTreeEntity topNode = dappAchieveMemberTreeDao.selectNodeByDeep(dappFundFlowEntitiess.get(0).getId(), 1);
+////            if (ObjectUtil.isNotEmpty(topNode)) {
+////                TeamListVo teamListVo = buildTeamMatrix(topNode);
+////                System.out.println(JSONUtil.parseObj(teamListVo));
+////            }
+////        }
+////    }
+//
+//    @Test
+//    public void resetMatrixV2() {
+//        dappSystemService.achieveTreeV2(136L);
+//    }
+//
+//    @Test
+//    public void resetMatrix() {
+//        Long withoutId = 1L;
+//        BigDecimal amount = new BigDecimal(30);
+//        String nodeType = "1";
+//        QueryWrapper<DappMemberEntity> objectQueryWrapper = new QueryWrapper<>();
+//        objectQueryWrapper.orderByAsc("create_time");
+//        List<DappMemberEntity> dappMemberEntities = dappMemberDao.selectList(objectQueryWrapper);
+//        for(DappMemberEntity member : dappMemberEntities){
+//            System.out.println(member.getId());
+//            if(withoutId != member.getId()){
+//                DappFundFlowEntity fundFlow = new DappFundFlowEntity(
+//                        member.getId(),
+//                        amount,
+//                        18,
+//                        2,
+//                        BigDecimal.ZERO,
+//                        null);
+//                fundFlow.setToHash(nodeType);
+//                dappFundFlowDao.insert(fundFlow);
+//                dappSystemService.achieveTreeV2(fundFlow.getId());
+//            }
+//        }
+//    }
+//
+//    @Test
+//    public void resetMatrixV4() {
+//        Long memberId = 141L;
+//        BigDecimal amount = new BigDecimal(30);
+//        String nodeType = "1";
+//        DappFundFlowEntity fundFlow = new DappFundFlowEntity(
+//                memberId,
+//                amount,
+//                18,
+//                2,
+//                BigDecimal.ZERO,
+//                null);
+//        fundFlow.setToHash(nodeType);
+//        dappFundFlowDao.insert(fundFlow);
+//        dappSystemService.achieveTreeV2(fundFlow.getId());
+//
+//        Long memberIds = 136L;
+//        Integer type = 1;
+//
+//        DappMemberEntity member = dappMemberDao.selectById(memberIds);
+//
+//        QueryWrapper<DbMemberNode> objectQueryWrapper = new QueryWrapper<>();
+//        objectQueryWrapper.eq("member_id",member.getId());
+//        objectQueryWrapper.eq("type", type);
+//        objectQueryWrapper.eq("work_state", DbMemberNode.STATE_ONE);
+//        DbMemberNode dbMemberNode = dbMemberNodeMapper.selectOne(objectQueryWrapper);
+//        if(ObjectUtil.isEmpty(dbMemberNode)){
+//            return;
+//        }
+//        MemberNodeVo memberNodeVo = buildTeamMatrix(dbMemberNode);
+//        System.out.println(JSONUtil.parseObj(memberNodeVo));
+//    }
+//    @Test
+//    public void resetMatrixV5() {
+//        Long memberId = 136L;
+//        Integer type = 1;
+//
+//        DappMemberEntity member = dappMemberDao.selectById(memberId);
+//
+//        QueryWrapper<DbMemberNode> objectQueryWrapper = new QueryWrapper<>();
+//        objectQueryWrapper.eq("member_id",member.getId());
+//        objectQueryWrapper.eq("type", type);
+//        objectQueryWrapper.eq("work_state", DbMemberNode.STATE_ONE);
+//        DbMemberNode dbMemberNode = dbMemberNodeMapper.selectOne(objectQueryWrapper);
+//        if(ObjectUtil.isEmpty(dbMemberNode)){
+//            return;
+//        }
+//        MemberNodeVo memberNodeVo = buildTeamMatrix(dbMemberNode);
+//        System.out.println(JSONUtil.parseObj(memberNodeVo));
+//    }
+//
+//    public MemberNodeVo buildTeamMatrix(DbMemberNode dbMemberNode) {
+//        Long id = dbMemberNode.getId();
+//
+//        MemberNodeVo memberNodeVo = new MemberNodeVo();
+//        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());
+//
+//        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){
+//        DbMemberNode dbMemberNode = dbMemberNodeMapper.selectById(memberNodeId);
+//        Long memberId = dbMemberNode.getMemberId();
+//        DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
+//        return dappMemberEntity.getInviteId();
+//    }
+//
+//    @Test
+//    public void limitResetProfitTest() {
+//        dappSystemService.putIntoProfit(59L, 1);
+//    }
 }

--
Gitblit v1.9.1