From f0ab92438b752f1896d8c1cb71a186fd7824e2bc Mon Sep 17 00:00:00 2001
From: wzy <wzy19931122ai@163.com>
Date: Wed, 03 Mar 2021 14:04:07 +0800
Subject: [PATCH] modify
---
src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java | 31 +++++++++++++++++++++++--------
1 files changed, 23 insertions(+), 8 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java b/src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java
index 8693651..a0a266a 100644
--- a/src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java
+++ b/src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java
@@ -30,18 +30,33 @@
@Resource
private TrxUsdtUpdateService trxUsdtUpdateService;
+ @Resource
+ RedisUtils redisUtils;
/**
- * ETH_USDT 同步
+ * TRC20_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");
+ }
+ }
+
}
/**
- * ETH_USDT 同步
+ * ETH_USDT 同步 使用扫块 废弃这个定时任务
*/
- @Scheduled(cron = "0 0/10 * * * ? ")
+ //@Scheduled(cron = "0 0/10 * * * ? ")
+ @Deprecated
public void ethUsdtUpdate() {
blockCoinService.updateEthUsdt();
}
@@ -57,22 +72,22 @@
/**
* BTC_USDT 同步
*/
- @Scheduled(cron = "0 2/10 * * * ? ")
+// @Scheduled(cron = "0 2/10 * * * ? ")
public void btcUsdtUpdate() {
blockCoinService.updateBtcUsdt();
}
- @Scheduled(cron = "0 3/20 * * * ? ")
+// @Scheduled(cron = "0 3/20 * * * ? ")
public void btcUpdate() {
blockCoinService.updateBtc();
}
- @Scheduled(cron = "0 4/20 * * * ? ")
+// @Scheduled(cron = "0 4/20 * * * ? ")
public void eosUpdate() {
blockCoinService.updateEos();
}
- @Scheduled(cron = "0 6/20 * * * ? ")
+// @Scheduled(cron = "0 6/20 * * * ? ")
public void xrpUpdate() {
blockCoinService.updateXrp();
}
--
Gitblit v1.9.1