后台修改

xiaoyong931011

2023-03-24 a4e2632242680c2af350af9ef4498413aa99dd92

后台修改

 src/main/java/cc/mrbird/febs/mall/chain/service/BscUsdtContractEvent.java

@@ -55,10 +55,10 @@

        String address = e.to;
        String hash =  e.log.getTransactionHash();

        Set<Object> addressList = redisUtils.sGet(ChainConstants.REDIS_KEY_SYSTEM_ADDRESS);
        List<String> tdCoinWallets = memberCoinAddressDao.selectAllSymbolAddress(CoinTypeEnum.USDT.toString(),"ERC20");
//        Set<Object> addressList = redisUtils.sGet(ChainConstants.REDIS_KEY_SYSTEM_ADDRESS);
        // 判断对方打款地址是否为源池地址
        if(CollUtil.isNotEmpty(addressList) && addressList.contains(address)){
        if(CollUtil.isNotEmpty(tdCoinWallets) && tdCoinWallets.contains(address)){
            log.info("触发USDT合约监听事件");
//            redisUtils.set(AppContants.REDIS_KEY_BLOCK_ETH_INCREMENT_NUM, e.log.getBlockNumber());
            // hash没有用过

 src/main/java/cc/mrbird/febs/mall/chain/service/ChainService.java

@@ -194,7 +194,7 @@
            try{
                // 等待订阅事件流的线程结束，然后关闭连接和释放资源
                executor.schedule(ws::close, 1, TimeUnit.SECONDS);
                executor.awaitTermination(2, TimeUnit.SECONDS);
                executor.awaitTermination(10, TimeUnit.SECONDS);
                subscribe.dispose();
            } catch (InterruptedException e) {
                e.printStackTrace();

 src/test/java/cc/mrbird/febs/ProfitTest.java

@@ -509,8 +509,8 @@
        } else {
            block = newest;
        }
        ChainService.wssBaseCoinEventListener(block, baseCoinService);
//        ChainService.wssContractEventListener2(block, bscUsdtContractEvent, ChainEnum.BSC_USDT.name());
//        ChainService.wssBaseCoinEventListener(BigInteger.valueOf(26737044), baseCoinService);
        ChainService.wssContractEventListener2(BigInteger.valueOf(26737044), bscUsdtContractEvent, ChainEnum.BSC_USDT.name());
    }
//
//    @Test