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;
|
import java.util.List;
|
|
/**
|
* @author wzy
|
* @date 2022-08-26
|
**/
|
@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.selectTreeListV2();
|
|
MatrixTree instance = MatrixTree.getInstance();
|
for (DappAchieveTreeEntity treeNode : tree) {
|
Long memberId = treeNode.getMemberId();
|
DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
|
|
|
MemberNode node = new MemberNode();
|
node.setAddress(dappMemberEntity.getAddress());
|
node.setInviteId(dappMemberEntity.getInviteId());
|
node.setRefererId(dappMemberEntity.getRefererId());
|
node.setMemberId(treeNode.getMemberId());
|
node.setFundId(treeNode.getFundId());
|
instance.addNode(node);
|
}
|
}
|
}
|
