TRC20版本提交

zainali5120

2021-02-20 4e44897b61f831d9e49f66bb35f74a877b1966fe

TRC20版本提交

 pom.xml

@@ -224,11 +224,11 @@
            <version>${netty.version}</version>
        </dependency>

        <dependency>
            <groupId>com.squareup.okhttp3</groupId>
            <artifactId>okhttp</artifactId>
            <version>${okhttp.version}</version>
        </dependency>
        <!--<dependency>-->
            <!--<groupId>com.squareup.okhttp3</groupId>-->
            <!--<artifactId>okhttp</artifactId>-->
            <!--<version>${okhttp.version}</version>-->
        <!--</dependency>-->

        <dependency>
            <groupId>com.aliyun.oss</groupId>

 src/main/java/com/xcong/excoin/modules/blackchain/service/TrxUsdtUpdateService.java

@@ -51,14 +51,18 @@
                });
            }
        }
        if (CollectionUtils.isEmpty(addressList)) {
            return;
        }
        Object trc20BlockNum = redisUtils.get("USDT_TRC20_BLOCK_NUM");
        if(trc20BlockNum==null){
            trc20BlockNum = 27805917L;

        }
        Long blockNum = Long.valueOf(trc20BlockNum.toString());
        redisUtils.set("USDT_TRC20_BLOCK_NUM",blockNum);
        if (CollectionUtils.isEmpty(addressList)) {
            return;
        }


        // http 请求
        // httpTransactionInfo(addressList, 26599313L);
        //httpTransactionInfo(addressList, 26603621L);

 src/main/java/com/xcong/excoin/modules/blackchain/service/UsdtErc20UpdateService.java

@@ -35,7 +35,7 @@

    public final static List<String> ALL_ADDRESS_LIST = new ArrayList<>();

    public final static String USDT_BLOCK_NUM_GOLDEN = "USDT_BLOCK_NUM_GOLDEN";
    public final static String ETH_USDT_BLOCK_NUM = "ETH_USDT_BLOCK_NUM";

    private final static BigDecimal DIVIDE_USDT = new BigDecimal("1000000");

@@ -83,9 +83,9 @@
            ALL_ADDRESS_LIST.addAll(tdCoinWallets);
        }
        // 获取最新区块
        String string = redisUtils.getString(USDT_BLOCK_NUM_GOLDEN);
        String string = redisUtils.getString(ETH_USDT_BLOCK_NUM);
        if(string==null){
            string = "11014249";
            string = "11892420";
        }
        BigInteger blockNum = new BigInteger(string);
        Credentials credentials = Credentials.create(privateKey);
@@ -109,7 +109,7 @@
                    usdtUpdateProducer.sendMsg(JSONObject.toJSONString(dto));
                }
                if(map.get("blockNum").compareTo(blockNumber1)!=0){
                    redisUtils.set(USDT_BLOCK_NUM_GOLDEN,blockNumber1.toString());
                    redisUtils.set(ETH_USDT_BLOCK_NUM,blockNumber1.toString());
                    map.put("blockNum",blockNumber1);
                }
            }

 src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java

@@ -30,12 +30,26 @@
    @Resource
    private TrxUsdtUpdateService trxUsdtUpdateService;

    @Resource
    RedisUtils redisUtils;
    /**
     * ETH_USDT 同步
     */
    @Scheduled(cron = "0/3 * * * * ? ")
    public void usdtTc20Update() {
        trxUsdtUpdateService.monitorCoinListener();
        // 需要加锁
        boolean lock = redisUtils.setNotExist("USDT_TRC20_UPDATE", 1, 30);
        if(lock){
            try{
                trxUsdtUpdateService.monitorCoinListener();
            } catch (Exception e){
                e.printStackTrace();
            }finally {
                // 若异常 需要删除
                redisUtils.del("USDT_TRC20_UPDATE");
            }
        }

    }

    /**

 src/main/resources/application.yml

@@ -5,7 +5,7 @@

spring:
  profiles:
    active: dev
    active: test
  datasource:
#    url: jdbc:mysql://rm-bp151tw8er79ig9kb5o.mysql.rds.aliyuncs.com:3306/db_biue?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2b8
#    username: ctcoin_data