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