From adb2c7b01d61cac2289c8ca31e5976a642a780f5 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Wed, 12 May 2021 10:04:49 +0800
Subject: [PATCH] modify
---
src/main/java/com/xcong/excoin/modules/blackchain/service/TrxUsdtUpdateService.java | 15 +++++++++++----
1 files changed, 11 insertions(+), 4 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 78c4c3d..7393792 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
@@ -14,6 +14,7 @@
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.http.*;
+import org.springframework.http.client.SimpleClientHttpRequestFactory;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import org.tron.common.utils.ByteArray;
@@ -194,7 +195,10 @@
* @return
*/
private static ResponseEntity<String> postForEntity(String url, String param) {
- RestTemplate restTemplate = new RestTemplate();
+ SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
+ factory.setConnectTimeout(20000);
+ factory.setReadTimeout(20000);
+ RestTemplate restTemplate = new RestTemplate(factory);
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
headers.set("TRON-PRO-API-KEY", Trc20Service.API_KEY);
@@ -255,13 +259,13 @@
}
for (String address : addressList) {
if (address.equals(to_address)) {
- System.out.println("存在本地的地址：" + address);
+ log.info("存在本地的地址：" + address);
// 金额
// 发送消息队列
EthUsdtChargeDto dto = new EthUsdtChargeDto(address, txId, amount);
dto.setSymbol(EthUsdtChargeDto.Symbol.USDT_TRC20);
usdtUpdateProducer.sendMsg(JSONObject.toJSONString(dto));
- System.out.println("===to_address:" + to_address + "===amount:" + amount);
+ log.info("===to_address:" + to_address + "===amount:" + amount);
}
}
@@ -352,7 +356,10 @@
public Long getnowblockFromTronScan() {
String roundNum = Math.random() + "";
String url = "https://apiasia.tronscan.io:5566/api/block/statistic?randomNum=" + roundNum;
- RestTemplate restTemplate = new RestTemplate();
+ SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
+ factory.setConnectTimeout(20000);
+ factory.setReadTimeout(20000);
+ RestTemplate restTemplate = new RestTemplate(factory);
String forObject = restTemplate.getForObject(url, String.class);
String wholeBlockCount = JSON.parseObject(forObject).getString("whole_block_count");
return Long.valueOf(wholeBlockCount);
--
Gitblit v1.9.1