后台修改

xiaoyong931011

2023-03-24 51a8a65cc62def0582ddd488a62227e7ed0f7e45

后台修改

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

@@ -166,7 +166,11 @@
            EthUsdtContract ethUsdtContract = wssContract(chain.getPrivateKey(), chain.getContractAddress(), web3j);
            EthFilter filter = getFilter(startBlock, startBlock, chain.getContractAddress());
            Flowable<EthUsdtContract.TransferEventResponse> eventFlowable = ethUsdtContract.transferEventFlowable(filter);

            // 判断websocket是否连接成功
            if (!webSocketClient.isOpen()) {
                log.error("WebSocket连接失败");
                return;
            }
            // 订阅事件流，将事件编译和处理放到单独的线程中执行
            Disposable subscribe = eventFlowable.observeOn(Schedulers.from(executor))
                    .subscribe(event::compile, error -> {

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

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