From 391be926e4d98387ed92fa80b2b5a218264073d2 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Thu, 13 Jun 2024 10:35:38 +0800
Subject: [PATCH] 星级矩阵
---
src/main/java/cc/mrbird/febs/job/MatrixTreeInit.java | 23 +++++++++++++++++------
1 files changed, 17 insertions(+), 6 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/job/MatrixTreeInit.java b/src/main/java/cc/mrbird/febs/job/MatrixTreeInit.java
index 69991c6..c4ee5f2 100644
--- a/src/main/java/cc/mrbird/febs/job/MatrixTreeInit.java
+++ b/src/main/java/cc/mrbird/febs/job/MatrixTreeInit.java
@@ -1,11 +1,14 @@
package cc.mrbird.febs.job;
import cc.mrbird.febs.dapp.entity.DappAchieveTreeEntity;
+import cc.mrbird.febs.dapp.entity.DappMemberEntity;
import cc.mrbird.febs.dapp.mapper.DappAchieveTreeDao;
+import cc.mrbird.febs.dapp.mapper.DappMemberDao;
import cc.mrbird.febs.tree.MatrixTree;
import cc.mrbird.febs.tree.MemberNode;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
@@ -17,25 +20,33 @@
**/
@Slf4j
@Component
+@ConditionalOnProperty(prefix = "system", name = "chain-listener", havingValue = "true")
public class MatrixTreeInit {
@Autowired
private DappAchieveTreeDao dappAchieveTreeDao;
+ @Autowired
+ private DappMemberDao dappMemberDao;
+
@PostConstruct
public void init() {
- List<DappAchieveTreeEntity> tree = dappAchieveTreeDao.selectTreeList();
+// List<DappAchieveTreeEntity> tree = dappAchieveTreeDao.selectTreeList();
+ List<DappAchieveTreeEntity> tree = dappAchieveTreeDao.selectTreeListV2();
MatrixTree instance = MatrixTree.getInstance();
for (DappAchieveTreeEntity treeNode : tree) {
+ Long memberId = treeNode.getMemberId();
+ DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
+
MemberNode node = new MemberNode();
- node.setAddress(treeNode.getAddress());
- node.setInviteId(treeNode.getInviteId());
- node.setRefererId(treeNode.getRefererId());
- node.setMemberId(treeNode.getMidNode());
+ node.setAddress(dappMemberEntity.getAddress());
+ node.setInviteId(dappMemberEntity.getInviteId());
+ node.setRefererId(dappMemberEntity.getRefererId());
+ node.setMemberId(treeNode.getMemberId());
+ node.setFundId(treeNode.getFundId());
instance.addNode(node);
}
- System.out.println(11);
}
}
--
Gitblit v1.9.1