From 0ead0c3a16ddad69b12557a64bb06245d8b62f67 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 17 Jan 2023 20:45:55 +0800
Subject: [PATCH] 20221227 充值归集
---
src/main/java/cc/mrbird/febs/mall/chain/service/ChainService.java | 68 ++++++++++++++-------------------
1 files changed, 29 insertions(+), 39 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/mall/chain/service/ChainService.java b/src/main/java/cc/mrbird/febs/mall/chain/service/ChainService.java
index 5e50cc6..deacdd9 100644
--- a/src/main/java/cc/mrbird/febs/mall/chain/service/ChainService.java
+++ b/src/main/java/cc/mrbird/febs/mall/chain/service/ChainService.java
@@ -85,41 +85,42 @@
Web3j web3j = null;
ChainEnum chain = ChainEnum.getValueByName(type);
+// try {
+// webSocketClient = new WebSocketClient(new URI("wss://bsc-mainnet.nodereal.io/ws/v1/78074065950e4915aef4f12b6f357d16"));
+// ws = new WebSocketService(webSocketClient, true);
+// ws.connect();
+// } catch (Exception e) {
+// try {
+// ws.close();
+// //TODO
+// if(ObjectUtil.isEmpty(webSocketClient)){
+// webSocketClient = new WebSocketClient(new URI("wss://bsc-mainnet.nodereal.io/ws/v1/78074065950e4915aef4f12b6f357d16"));
+// ws = new WebSocketService(webSocketClient, true);
+// ws.connect();
+// }
+// WebSocket.READYSTATE readyState = webSocketClient.getReadyState();
+// if((WebSocket.READYSTATE.OPEN != readyState
+// && WebSocket.READYSTATE.CONNECTING != readyState)){
+// webSocketClient = new WebSocketClient(new URI("wss://bsc-mainnet.nodereal.io/ws/v1/78074065950e4915aef4f12b6f357d16"));
+// ws = new WebSocketService(webSocketClient, true);
+// ws.connect();
+// }
+// } catch (Exception connectException) {
+// connectException.printStackTrace();
+// }
+// }
+
+
try {
webSocketClient = new WebSocketClient(new URI("wss://bsc-mainnet.nodereal.io/ws/v1/78074065950e4915aef4f12b6f357d16"));
ws = new WebSocketService(webSocketClient, true);
ws.connect();
- } catch (Exception e) {
- try {
- ws.close();
- //TODO
- if(ObjectUtil.isEmpty(webSocketClient)){
- webSocketClient = new WebSocketClient(new URI("wss://bsc-mainnet.nodereal.io/ws/v1/78074065950e4915aef4f12b6f357d16"));
- ws = new WebSocketService(webSocketClient, true);
- ws.connect();
- }
- WebSocket.READYSTATE readyState = webSocketClient.getReadyState();
- if((WebSocket.READYSTATE.OPEN != readyState
- && WebSocket.READYSTATE.CONNECTING != readyState)){
- webSocketClient = new WebSocketClient(new URI("wss://bsc-mainnet.nodereal.io/ws/v1/78074065950e4915aef4f12b6f357d16"));
- ws = new WebSocketService(webSocketClient, true);
- ws.connect();
- }
- } catch (Exception connectException) {
- connectException.printStackTrace();
- }
- }
-
-
- try {
web3j = Web3j.build(ws);
assert chain != null;
try{
EthUsdtContract ethUsdtContract = wssContract(chain.getPrivateKey(), chain.getContractAddress(), web3j);
EthFilter filter = getFilter(startBlock, startBlock, chain.getContractAddress());
-
-
Flowable<EthUsdtContract.TransferEventResponse> eventFlowable = ethUsdtContract.transferEventFlowable(filter);
Disposable subscribe = eventFlowable.subscribe(event::compile, error -> {
log.error("币安监听异常", error);
@@ -127,24 +128,13 @@
});
}catch(WebsocketNotConnectedException e){
ws.close();
- if(ObjectUtil.isEmpty(webSocketClient)){
- webSocketClient = new WebSocketClient(new URI("wss://bsc-mainnet.nodereal.io/ws/v1/78074065950e4915aef4f12b6f357d16"));
- ws = new WebSocketService(webSocketClient, true);
- ws.connect();
- }
- WebSocket.READYSTATE readyState = webSocketClient.getReadyState();
- if((WebSocket.READYSTATE.OPEN != readyState
- && WebSocket.READYSTATE.CONNECTING != readyState)){
- webSocketClient = new WebSocketClient(new URI("wss://bsc-mainnet.nodereal.io/ws/v1/78074065950e4915aef4f12b6f357d16"));
- ws = new WebSocketService(webSocketClient, true);
- ws.connect();
- }
+ webSocketClient = new WebSocketClient(new URI("wss://bsc-mainnet.nodereal.io/ws/v1/78074065950e4915aef4f12b6f357d16"));
+ ws = new WebSocketService(webSocketClient, true);
+ ws.connect();
web3j = Web3j.build(ws);
assert chain != null;
EthUsdtContract ethUsdtContract = wssContract(chain.getPrivateKey(), chain.getContractAddress(), web3j);
EthFilter filter = getFilter(startBlock, startBlock, chain.getContractAddress());
-
-
Flowable<EthUsdtContract.TransferEventResponse> eventFlowable = ethUsdtContract.transferEventFlowable(filter);
Disposable subscribe = eventFlowable.subscribe(event::compile, error -> {
log.error("币安监听异常", error);
--
Gitblit v1.9.1