modify

Helius

2021-05-13 1b44a9a25a51324dba8e8640cb405440f2cf7d48

 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);