From 0c68494f50d375a046e6a9d07321860984a7f805 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Thu, 13 Jun 2024 15:49:43 +0800
Subject: [PATCH] 星级矩阵

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java |   16 +++++++++++-----
 1 files changed, 11 insertions(+), 5 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java
index 755e2e8..1e180dd 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java
@@ -209,10 +209,14 @@
                         DappFundFlowEntity fundFlowPerk = new DappFundFlowEntity(parent.getId(), directProfit, 3, 2, null, null);
                         dappFundFlowDao.insert(fundFlowPerk);
                     }
-                    //生成业绩数
-                    chainProducer.sendAchieveTreeMsg(fundFlow.getMemberId());
-                    //分发手续费给节点
-                    buyNodePerk(amount);
+                    //复投
+//                    chainProducer.sendAchieveTreeMsg(fundFlow.getMemberId());
+                    chainProducer.sendNodeMsg(fundFlow.getMemberId());
+                    //发送推荐规则奖励
+                    chainProducer.sendInvitePerkMsg(fundFlow.getId());
+                    //发送节点投资
+                    chainProducer.sendNodePerkMsg(fundFlow.getId());
+//                    buyNodePerk(amount);
 
                 }else if(13 == fundFlow.getType()){//认购节点 13
 
@@ -224,7 +228,9 @@
 
                     Long memberId = fundFlow.getMemberId();
                     DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
-                    dappMemberEntity.setBuyNode(1);
+                    Integer buyNode = dappMemberEntity.getBuyNode();
+                    buyNode = buyNode + 1;
+                    dappMemberEntity.setBuyNode(buyNode);
                     dappMemberDao.updateById(dappMemberEntity);
                 }
             }else{

--
Gitblit v1.9.1