From bc1350318fc28f23b22a07d2e41c5e00c504ddaa Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Thu, 17 Jun 2021 14:24:08 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java | 8 +++++++- 1 files changed, 7 insertions(+), 1 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 9be6d3d..f21750c 100644 --- a/src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java +++ b/src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java @@ -1,6 +1,8 @@ package com.xcong.excoin.quartz.job; +import com.xcong.excoin.modules.blackchain.service.TrxUsdtUpdateService; import com.xcong.excoin.modules.coin.service.BlockCoinService; +import com.xcong.excoin.rabbit.producer.UsdtUpdateProducer; import com.xcong.excoin.utils.RedisUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; @@ -26,7 +28,11 @@ @Autowired private RedisUtils redisUtils; - private + @Autowired + private TrxUsdtUpdateService trxUsdtUpdateService; + + @Autowired + private UsdtUpdateProducer usdtUpdateProducer; public static ConcurrentLinkedQueue<Long> TRC_BLOCK = new ConcurrentLinkedQueue<>(); -- Gitblit v1.9.1