From 16a0ee15923907df48db2266e8c2e80d10c7f2b9 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Thu, 22 Apr 2021 11:02:56 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/modules/blackchain/service/TrxUsdtUpdateService.java | 5 +++-- 1 files changed, 3 insertions(+), 2 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 af17c60..1324df6 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 @@ -71,7 +71,6 @@ } Long blockNum = Long.valueOf(trc20BlockNum.toString()); - redisUtils.set("USDT_TRC20_BLOCK_NUM",blockNum + 1L); // log.info("---{}",blockNum); // 查询一下最新区块 long getnowblock = getnowblock()-20L; @@ -80,6 +79,8 @@ // 如果当前区块比最新已确认区块还大,则不继续执行 return; } + + redisUtils.set("USDT_TRC20_BLOCK_NUM",blockNum + 1L); if (CollectionUtils.isEmpty(addressList)) { return; } @@ -105,7 +106,7 @@ // 不用等到扫完再累加 只要进来就加 还有一个条件是必须查询出区块再加 否则当区块超过实际区块 // 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"); -- Gitblit v1.9.1