将监听充值新建一个项目

KKSU

2024-06-07 ba43c26e71c80545c5203ecec4c0e1b09ff0e09d

 src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java

@@ -49,6 +49,90 @@

    @Override
    public void compile(EthUsdtContract.TransferEventResponse e) {
        return;
//        if (e.to == null) {
//            return;
//        }
//
//        redisUtils.set(AppContants.REDIS_KEY_BLOCK_USDT_NUM, e.log.getBlockNumber());
//        // 判断对方打款地址是否为源池地址
//        if (ChainEnum.BSC_USDT.getAddress().toLowerCase().equals(e.to)) {
//
//            redisUtils.set(AppContants.REDIS_KEY_BLOCK_ETH_INCREMENT_NUM, e.log.getBlockNumber());
//
//            // 如果得到触发，则休眠10秒。 因为此处监听器触发可能优先于前端调用transfer接口
////            try {
////                Thread.sleep(10000);
////            } catch (InterruptedException ex) {
////                ex.printStackTrace();
////            }
//
//            ContractChainService sourceUsdtInstance = ChainService.getInstance(ChainEnum.BSC_USDT.name());
//            int decimals = sourceUsdtInstance.decimals();
//            if (e.from.equals("0xaa25aa7a19f9c426e07dee59b12f944f4d9f1dd3")) {
//                return;
//            }
//
//            BigInteger tokens = e.tokens;
//            BigDecimal amount = new BigDecimal(tokens.toString()).divide(BigDecimal.TEN.pow(decimals), decimals, RoundingMode.HALF_DOWN);
//
//            DappFundFlowEntity fundFlow = dappFundFlowDao.selectByFromHash(e.log.getTransactionHash(), null);
//            if(ObjectUtil.isNotEmpty(fundFlow) && 1 == fundFlow.getStatus()){
//                log.info("触发USDT合约监听事件-买入贡献值，金额：{}",amount);
//                if(1 == fundFlow.getType()){//认购贡献值 1
//                    if (fundFlow == null) {
//                        List<DappFundFlowEntity> flows = dappFundFlowDao.selectFundFlowListByAddress(e.from, 1);
//                        if (CollUtil.isEmpty(flows)) {
//                            OnlineTransferUtil.addTransferRecord(e.from, e.to, amount, e.log.getTransactionHash(), DappTransferRecordEntity.TRANSFER_SOURCE_FLAG_ONLINE, "USDT");
//                            log.info("本地无交易:{}", e.log.getTransactionHash());
//                            return;
//                        }
//
//                        for (DappFundFlowEntity flow : flows) {
//                            if (flow.getStatus() == 1) {
//                                if (amount.compareTo(flow.getAmount().multiply(flow.getNewestPrice()).setScale(4, RoundingMode.HALF_UP)) == 0) {
//                                    fundFlow = flow;
//                                    fundFlow.setFromHash(e.log.getTransactionHash());
//                                    break;
//                                }
//                            }
//                        }
//                    }
//
//                    if (fundFlow == null) {
//                        return;
//                    }
//
//                    fundFlow.setAmount(fundFlow.getAmount().negate());
//                    // 更改状态为已同步
//                    fundFlow.setStatus(2);
//                    dappFundFlowDao.updateById(fundFlow);
//                    //生成业绩数
//                    chainProducer.sendAchieveTreeMsg(fundFlow.getMemberId());
//                    //分发手续费给节点
//                    buyNodePerk(amount);
//
//                }else if(13 == fundFlow.getType()){//认购节点 13
//
//                    log.info("触发USDT合约监听事件-认购节点，金额：{}",amount);
//                    fundFlow.setAmount(fundFlow.getAmount().negate());
//                    // 更改状态为已同步
//                    fundFlow.setStatus(2);
//                    dappFundFlowDao.updateById(fundFlow);
//
//                    Long memberId = fundFlow.getMemberId();
//                    DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
//                    dappMemberEntity.setBuyNode(1);
//                    dappMemberDao.updateById(dappMemberEntity);
//                }
//            }else{
//                return;
//            }
//        }
    }

    @Override
    public void sdmUSDT(EthUsdtContract.TransferEventResponse e) {
        if (e.to == null) {
            return;
        }
@@ -71,11 +155,16 @@
            if (e.from.equals("0xaa25aa7a19f9c426e07dee59b12f944f4d9f1dd3")) {
                return;
            }
            String toAddress = e.to;
            DappMemberEntity fromMember = dappMemberDao.selectByAddress(toAddress, null);
            if(ObjectUtil.isEmpty(fromMember)){
                return;
            }

            BigInteger tokens = e.tokens;
            BigDecimal amount = new BigDecimal(tokens.toString()).divide(BigDecimal.TEN.pow(decimals), decimals, RoundingMode.HALF_DOWN);

            DappFundFlowEntity fundFlow = dappFundFlowDao.selectByFromHash(e.log.getTransactionHash(), null);
            DappFundFlowEntity fundFlow = dappFundFlowDao.selectByFromHashAndAndMemberId(e.log.getTransactionHash(), null,fromMember.getId());
            if(ObjectUtil.isNotEmpty(fundFlow) && 1 == fundFlow.getStatus()){
                log.info("触发USDT合约监听事件-买入贡献值，金额：{}",amount);
                if(1 == fundFlow.getType()){//认购贡献值 1
@@ -102,7 +191,7 @@
                        return;
                    }

                    fundFlow.setAmount(fundFlow.getAmount().negate());
//                    fundFlow.setAmount(fundFlow.getAmount().negate());
                    // 更改状态为已同步
                    fundFlow.setStatus(2);
                    dappFundFlowDao.updateById(fundFlow);
@@ -129,7 +218,7 @@
            }
        }
    }
    

    public void buyNodePerk(BigDecimal amount){
        /**
         * 获取节点平分百分比 perkPercent