| | |
| | | import com.xcong.excoin.modules.member.dao.MemberCoinAddressDao; |
| | | import com.xcong.excoin.modules.member.entity.MemberCoinAddressEntity; |
| | | import com.xcong.excoin.utils.RedisUtils; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.collections.CollectionUtils; |
| | | import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; |
| | | import org.springframework.scheduling.annotation.Async; |
| | |
| | | * @author wzy |
| | | * @date 2020-07-02 |
| | | **/ |
| | | @Slf4j |
| | | @Component |
| | | //@ConditionalOnProperty(prefix = "app", name = "block-job", havingValue = "true") |
| | | @ConditionalOnProperty(prefix = "app", name = "block-job", havingValue = "true") |
| | | public class BlockCoinUpdateJob { |
| | | |
| | | @Resource |
| | |
| | | /** |
| | | * TRC20_USDT 同步 |
| | | */ |
| | | @Scheduled(cron = "0/2 * * * * ? ") |
| | | @Scheduled(cron = "0/3 * * * * ? ") |
| | | @Async |
| | | public void usdtTc20Update() { |
| | | // 波场3秒出一个块 |
| | |
| | | if(blocnNum==null){ |
| | | return; |
| | | } |
| | | redisUtils.set("USDT_TRC20_CURRENT_BLOCK_NUM",blocnNum); |
| | | trxUsdtUpdateService.monitorCoinListener(blocnNum); |
| | | } |
| | | |