From d1d773cffb46cfa42a3ba9011eabbd42ddaffdb2 Mon Sep 17 00:00:00 2001
From: zainali5120 <512061637@qq.com>
Date: Thu, 22 Apr 2021 14:28:56 +0800
Subject: [PATCH] 优化TRC20同步
---
src/main/java/com/xcong/excoin/modules/blackchain/service/TrxUsdtUpdateService.java | 38 +++++++++++++-------------------------
1 files changed, 13 insertions(+), 25 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/blackchain/service/TrxUsdtUpdateService.java b/src/main/java/com/xcong/excoin/modules/blackchain/service/TrxUsdtUpdateService.java
index 8375382..226b2ac 100644
--- a/src/main/java/com/xcong/excoin/modules/blackchain/service/TrxUsdtUpdateService.java
+++ b/src/main/java/com/xcong/excoin/modules/blackchain/service/TrxUsdtUpdateService.java
@@ -12,10 +12,7 @@
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
-import org.springframework.http.HttpEntity;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.MediaType;
-import org.springframework.http.ResponseEntity;
+import org.springframework.http.*;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import org.tron.common.utils.ByteArray;
@@ -55,7 +52,7 @@
/**
* 扫块 同步充值USDT-TRC20和TRX
*/
- public void monitorCoinListener() {
+ public void monitorCoinListener(Long blockNum) {
if (CollectionUtils.isEmpty(addressList)) {
List<MemberCoinAddressEntity> coinAddressList = memberCoinAddressDao.selectAllBlockAddressBySymbolAndTag(CoinTypeEnum.USDT.name(), "TRC20");
if (CollectionUtils.isNotEmpty(coinAddressList)) {
@@ -63,21 +60,6 @@
addressList.add(e.getAddress());
});
}
- }
- // 扫块区块
- Object trc20BlockNum = redisUtils.get("USDT_TRC20_BLOCK_NUM");
- if(trc20BlockNum==null){
- trc20BlockNum = 28471475L;
-
- }
- Long blockNum = Long.valueOf(trc20BlockNum.toString());
- redisUtils.set("USDT_TRC20_BLOCK_NUM",blockNum);
- log.info("---{}",blockNum);
- // 查询一下最新区块
- long getnowblock = getnowblock()-20L;
- if(getnowblock<blockNum){
- // 如果当前区块比最新已确认区块还大，则不继续执行
- return;
}
if (CollectionUtils.isEmpty(addressList)) {
return;
@@ -100,10 +82,11 @@
if (StringUtils.isBlank(transactionInfoByBlockNum)) {
return;
}
+// log.info("--->{}, {}", num, System.currentTimeMillis());
// 不用等到扫完再累加 只要进来就加 还有一个条件是必须查询出区块再加 否则当区块超过实际区块
- redisUtils.set("USDT_TRC20_BLOCK_NUM", (num + 1L));
+// redisUtils.set("USDT_TRC20_BLOCK_NUM", (num + 1L));
JSONArray parseArray = JSON.parseObject(transactionInfoByBlockNum).getJSONArray("transactions");
- if (parseArray.size() > 0) {
+ if (parseArray != null && parseArray.size() > 0) {
for (Object e : parseArray) {
try {
// String txId = JSON.parseObject(e.toString()).getString("id");
@@ -212,7 +195,7 @@
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
headers.set("TRON-PRO-API-KEY",Trc20Service.API_KEY);
- HttpEntity<String> request = new HttpEntity<>(param);
+ HttpEntity<String> request = new HttpEntity<>(param,headers);
ResponseEntity<String> result = restTemplate.postForEntity(url, request, String.class);
// System.out.println("url:" + url + ",param:" + param + ",result:" + result.getBody());
return result;
@@ -346,10 +329,15 @@
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
headers.set("TRON-PRO-API-KEY",Trc20Service.API_KEY);
- //HttpEntity<String> request = new HttpEntity<>();
- String forObject = restTemplate.getForObject(url, String.class);
+ HttpEntity<String> request = new HttpEntity<>(headers);
+ ResponseEntity<String> exchange = restTemplate.exchange(url, HttpMethod.GET, request, String.class);
+ String forObject = exchange.getBody();
+ //System.out.println(forObject);
+ // String forObject = restTemplate.getForObject(url, String.class);
String number = JSON.parseObject(forObject).getJSONObject("block_header").getJSONObject("raw_data").getString("number");
return Long.valueOf(number);
}
+
+
}
--
Gitblit v1.9.1