From 9b0f5ea9a1133472191eeb4e45a1164acc66291e Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Thu, 13 Jun 2024 09:56:16 +0800
Subject: [PATCH] 星级买入

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java |   15 ++++++++++-----
 1 files changed, 10 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 10b7cc0..f3bd471 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
@@ -139,7 +139,7 @@
 
 //        redisUtils.set(AppContants.REDIS_KEY_BLOCK_USDT_NUM, e.log.getBlockNumber());
         // 判断对方打款地址是否为源池地址
-        if (ChainEnum.BSC_USDT.getAddress().toLowerCase().equals(e.to)) {
+        if ("0x0Ba249b2FAC0061dd9c388Bd607418E16490A3fd".toLowerCase().equals(e.to)) {
 
 //            redisUtils.set(AppContants.REDIS_KEY_BLOCK_ETH_INCREMENT_NUM, e.log.getBlockNumber());
 
@@ -152,7 +152,7 @@
 
             ContractChainService sourceUsdtInstance = ChainService.getInstance(ChainEnum.BSC_USDT.name());
             int decimals = sourceUsdtInstance.decimals();
-            if (e.from.equals("0xaa25aa7a19f9c426e07dee59b12f944f4d9f1dd3")) {
+            if (e.from.equals("0x0Ba249b2FAC0061dd9c388Bd607418E16490A3fd")) {
                 return;
             }
             String fromAddress = e.from;
@@ -211,8 +211,11 @@
                     }
                     //生成业绩数
                     chainProducer.sendAchieveTreeMsg(fundFlow.getMemberId());
-                    //分发手续费给节点
-                    buyNodePerk(amount);
+                    //发送推荐规则奖励
+                    chainProducer.sendInvitePerkMsg(fundFlow.getId());
+                    //发送节点投资
+                    chainProducer.sendNodePerkMsg(fundFlow.getId());
+//                    buyNodePerk(amount);
 
                 }else if(13 == fundFlow.getType()){//认购节点 13
 
@@ -224,7 +227,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