From d04e6ff0df71d36c341cae9dde49def1a9f4bd92 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Tue, 25 Jun 2024 11:16:38 +0800
Subject: [PATCH] 后台矩阵列表
---
src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java | 24 +++++++++++++++++++++++-
1 files changed, 23 insertions(+), 1 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
index 5ad72f5..6a484ee 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
@@ -10,6 +10,7 @@
import cc.mrbird.febs.dapp.mapper.*;
import cc.mrbird.febs.dapp.service.DappSystemService;
import cc.mrbird.febs.dapp.service.DappWalletService;
+import cc.mrbird.febs.rabbit.producer.ChainProducer;
import cc.mrbird.febs.tree.MatrixTree;
import cc.mrbird.febs.tree.MemberNode;
import cc.mrbird.febs.tree.TreeConstants;
@@ -50,6 +51,7 @@
private final DataDictionaryCustomMapper dataDictionaryCustomMapper;
private final DbMemberNodeMapper dbMemberNodeMapper;
+ private final ChainProducer chainProducer;
@Override
@@ -217,6 +219,15 @@
dbMemberNode.setWorkState(1);
dbMemberNodeMapper.insert(dbMemberNode);
+ /**
+ * 判断你的上级是否满足复投条件
+ */
+ DappMemberEntity dappMemberEntityDirect = dappMemberDao.selectMemberInfoByInviteId(member.getRefererId());
+ if(ObjectUtil.isNotEmpty(dappMemberEntityDirect)){
+ Long id = dappMemberEntityDirect.getId();
+ chainProducer.sendNodeMsgLong(id);
+ }
+
//如果添加的为右节点，那么进入判断
if(DbMemberNode.STATE_TWO == dbMemberNode.getLeftRight()){
//更新父节点的右节点
@@ -304,10 +315,21 @@
perkSevenTeen(memberId,add,countFund);
return;
+ }else if(10 < countFund){
+ return;
}else{
//复投
Integer type = dbMemberNodeRoot.getType();
- futouSixTeen(memberId,dbMemberNodeRoot.getAmount(),type,countFund+1);
+ Integer countFundNext = countFund + 1;
+ QueryWrapper<DbMemberNode> nodeQueryWrapper = new QueryWrapper<>();
+ nodeQueryWrapper.eq("member_id",memberId);
+ nodeQueryWrapper.eq("type", type);
+ nodeQueryWrapper.eq("count_fund", countFundNext);
+ DbMemberNode dbMemberNode = dbMemberNodeMapper.selectOne(nodeQueryWrapper);
+ if(ObjectUtil.isNotEmpty(dbMemberNode)){
+ return;
+ }
+ futouSixTeen(memberId,dbMemberNodeRoot.getAmount(),type,countFundNext);
//产生收益
perkSevenTeen(memberId,perkAmount,countFund);
return;
--
Gitblit v1.9.1