From f5cf516fdec9ae5207a8502505b0567110fe031c Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Mon, 24 Jun 2024 10:15:30 +0800
Subject: [PATCH] 后台矩阵列表
---
src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java | 11 +++++++++++
src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java | 1 +
2 files changed, 12 insertions(+), 0 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 8928afd..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()){
//更新父节点的右节点
diff --git a/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java b/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
index 3e08118..a0521a2 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
@@ -85,6 +85,7 @@
QueryWrapper<DbMemberNode> objectQueryWrapper = new QueryWrapper<>();
objectQueryWrapper.eq("count_fund", 1);
objectQueryWrapper.eq("work_state", 1);
+ objectQueryWrapper.eq("type", 1);
objectQueryWrapper.eq("member_id", id);
List<DbMemberNode> dbMemberNodes = dbMemberNodeMapper.selectList(objectQueryWrapper);
if(CollUtil.isEmpty(dbMemberNodes)){
--
Gitblit v1.9.1