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