后台修改

xiaoyong931011

2023-03-24 90473aa33326df65173da7672aa869ae18fbb4ab

后台修改

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

@@ -166,11 +166,6 @@

            EthUsdtContract ethUsdtContract = wssContract(chain.getPrivateKey(), chain.getContractAddress(), web3j);


            while (!webSocketClient.getReadyState().equals(ReadyState.OPEN)) {
                log.info("连接中···请稍后");
            }

            EthFilter filter = getFilter(startBlock, startBlock, chain.getContractAddress());
            Flowable<EthUsdtContract.TransferEventResponse> eventFlowable = ethUsdtContract.transferEventFlowable(filter);
            while (!webSocketClient.getReadyState().equals(ReadyState.OPEN)) {

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

@@ -510,7 +510,7 @@
            block = newest;
        }
//        ChainService.wssBaseCoinEventListener(BigInteger.valueOf(26737044), baseCoinService);
        ChainService.wssContractEventListener2(BigInteger.valueOf(26738831), bscUsdtContractEvent, ChainEnum.BSC_USDT.name());
        ChainService.wssContractEventListener2(BigInteger.valueOf(26739725), bscUsdtContractEvent, ChainEnum.BSC_USDT.name());
    }
//
//    @Test