| | |
|---|
| | | |
|---|
| | | // 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()); |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | } |
|---|
| | | //生成业绩数 |
|---|
| | | chainProducer.sendAchieveTreeMsg(fundFlow.getMemberId()); |
|---|
| | | //分发手续费给节点 |
|---|
| | | buyNodePerk(amount); |
|---|
| | | //发送推荐规则奖励 |
|---|
| | | chainProducer.sendInvitePerkMsg(fundFlow.getId()); |
|---|
| | | //发送节点投资 |
|---|
| | | chainProducer.sendNodePerkMsg(fundFlow.getId()); |
|---|
| | | // buyNodePerk(amount); |
|---|
| | | |
|---|
| | | }else if(13 == fundFlow.getType()){//认购节点 13 |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | 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{ |
|---|
