From 3db09c59e1d4ac4ca1834c55254441692988efd5 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 05 Jan 2023 16:21:49 +0800
Subject: [PATCH] 20221227 充值归集
---
src/main/java/cc/mrbird/febs/mall/chain/service/UsdtErc20UpdateService.java | 29 ++++++++++++++++++++++++++---
1 files changed, 26 insertions(+), 3 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/mall/chain/service/UsdtErc20UpdateService.java b/src/main/java/cc/mrbird/febs/mall/chain/service/UsdtErc20UpdateService.java
index b075f5e..c7af807 100644
--- a/src/main/java/cc/mrbird/febs/mall/chain/service/UsdtErc20UpdateService.java
+++ b/src/main/java/cc/mrbird/febs/mall/chain/service/UsdtErc20UpdateService.java
@@ -10,6 +10,7 @@
import org.springframework.stereotype.Service;
import org.web3j.crypto.Credentials;
import org.web3j.protocol.Web3j;
+import org.web3j.protocol.core.DefaultBlockParameter;
import org.web3j.protocol.core.DefaultBlockParameterName;
import org.web3j.protocol.core.DefaultBlockParameterNumber;
import org.web3j.protocol.core.methods.request.EthFilter;
@@ -63,7 +64,7 @@
}
//private static String blockchainNode = "http://114.55.250.231:8545";
- private static String blockchainNode = "http://120.55.86.146:8545";
+ private static String blockchainNode = "https://bsc-dataseed1.ninicoin.io";
// private static String contractAddr = "0xdac17f958d2ee523a2206206994597c13d831ec7";
@@ -83,14 +84,17 @@
ALL_ADDRESS_LIST.addAll(tdCoinWallets);
}
// 获取最新区块
- String string = redisUtils.getString(ETH_USDT_BLOCK_NUM);
+// String string = redisUtils.getString(ETH_USDT_BLOCK_NUM);
+ String string = "24317595";
if(string==null){
string = "24317595";
}
BigInteger blockNum = new BigInteger(string);
Credentials credentials = Credentials.create(privateKey);
EthUsdtContract contract = EthUsdtContract.load(contractAddr, getInstance(), credentials, getStaticGasProvider());
- EthFilter filter = getFilter(blockNum);
+
+ EthFilter filter = getFilter(blockNum,blockNum,contractAddr);
+
Map<String,BigInteger> map = new HashMap<String,BigInteger>();
map.put("blockNum",blockNum);
contract.transferEventFlowable(filter).subscribe(e->{
@@ -127,6 +131,25 @@
return new EthFilter(DefaultBlockParameterName.EARLIEST,
DefaultBlockParameterName.LATEST, contractAddr);
}
+
+ }
+
+ private static EthFilter getFilter(BigInteger startBlock, BigInteger endBlock, String contractAddress) {
+ DefaultBlockParameter startParameterName = null;
+ DefaultBlockParameter endParameterName = null;
+ if (startBlock != null) {
+ startParameterName = new DefaultBlockParameterNumber(startBlock);
+ } else {
+ startParameterName = DefaultBlockParameterName.EARLIEST;
+ }
+
+ if (endBlock != null) {
+ endParameterName = new DefaultBlockParameterNumber(endBlock);
+ } else {
+ endParameterName = DefaultBlockParameterName.LATEST;
+ }
+
+ return new EthFilter(startParameterName, endParameterName, contractAddress);
}
}
--
Gitblit v1.9.1