From abf16ade315ba2626339713e798d87eba336c37f Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Wed, 01 Jun 2022 18:30:18 +0800
Subject: [PATCH] fix prd to test chain
---
src/main/java/cc/mrbird/febs/job/ChainListenerJob.java | 25 +++++++++++++++++++++++--
1 files changed, 23 insertions(+), 2 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/job/ChainListenerJob.java b/src/main/java/cc/mrbird/febs/job/ChainListenerJob.java
index 6c64330..04c0bbb 100644
--- a/src/main/java/cc/mrbird/febs/job/ChainListenerJob.java
+++ b/src/main/java/cc/mrbird/febs/job/ChainListenerJob.java
@@ -1,5 +1,7 @@
package cc.mrbird.febs.job;
+import cc.mrbird.febs.common.contants.AppContants;
+import cc.mrbird.febs.common.utils.RedisUtils;
import cc.mrbird.febs.dapp.chain.ChainEnum;
import cc.mrbird.febs.dapp.chain.ChainService;
import cc.mrbird.febs.dapp.chain.ContractEventService;
@@ -20,10 +22,29 @@
@Autowired
private ContractEventService bscUsdtContractEvent;
+ @Autowired
+ private RedisUtils redisUtils;
+
@PostConstruct
public void chainListenerJob() {
log.info("监听打开");
-// ChainService.contractEventListener(new BigInteger("18097238"), bscUsdtContractEvent, ChainEnum.BSC_USDT.name());
-// ChainService.contractEventListener(new BigInteger("18097238"), bscCoinContractEvent, ChainEnum.BSC_TFC.name());
+ BigInteger usdtBlock;
+ BigInteger coinBlock;
+ Object usdt = redisUtils.get(AppContants.REDIS_KEY_BLOCK_USDT_NUM);
+ if (usdt == null) {
+ usdtBlock = new BigInteger("19811973");
+ } else {
+ usdtBlock = (BigInteger) usdt;
+ }
+
+ Object coin = redisUtils.get(AppContants.REDIS_KEY_BLOCK_COIN_NUM);
+ if (coin == null) {
+ coinBlock = new BigInteger("19811973");
+ } else {
+ coinBlock = (BigInteger) coin;
+ }
+
+ ChainService.contractEventListener(usdtBlock, bscUsdtContractEvent, ChainEnum.BSC_USDT.name());
+ ChainService.contractEventListener(coinBlock, bscCoinContractEvent, ChainEnum.BSC_TFC.name());
}
}
--
Gitblit v1.9.1