package com.xcong.excoin.quartz.job; import com.xcong.excoin.modules.symbols.service.SymbolsService; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import javax.annotation.Resource; /** * k线数据更新任务 * * @author wzy * @date 2020-05-26 **/ @Component @ConditionalOnProperty(prefix = "app", name = "kline-update-job", havingValue = "true") public class KlineDataUpdateJob { @Resource private SymbolsService symbolsService; /** * 定时更新每一分钟的K线数据 */ @Scheduled(cron = "0/10 * * * * ? ") public void updateSymbolsKineOneMin() { symbolsService.updateSymbolsKine("1m"); } /** * 定时更新每5分钟的K线数据 */ @Scheduled(cron = "0 0/5 * * * ?") public void updateSymbolsKineFiveMin() { symbolsService.updateSymbolsKine("5m"); } /** * 定时更新每30分钟的K线数据 */ @Scheduled(cron = "0 0/15 * * * ?") public void updateSymbolsKineMin() { symbolsService.updateSymbolsKine("15m"); } /** * 定时更新每30分钟的K线数据 */ @Scheduled(cron = "0 0/30 * * * ?") public void updateSymbolsKineMin30() { symbolsService.updateSymbolsKine("30m"); } /** * 定时更新1小时的K线数据 */ @Scheduled(cron = "0 0 * * * ?") public void updateSymbolsKineOneHour() { symbolsService.updateSymbolsKine("1H"); } /** * 定时更新1小时的K线数据 */ @Scheduled(cron = "0 0 * * * ?") public void updateSymbolsKineTwoHour() { symbolsService.updateSymbolsKine("2H"); } /** * 定时更新1小时的K线数据 */ @Scheduled(cron = "0 0 * * * ?") public void updateSymbolsKinefourHour() { symbolsService.updateSymbolsKine("4H"); } /** * 定时更新1天的K线数据 */ @Scheduled(cron = "0 0 * * * ?") public void updateSymbolsKineOneDay() { symbolsService.updateSymbolsKine("1D"); } /** * 定时更新1天的K线数据 */ @Scheduled(cron = "0 0 * * * ?") public void updateSymbolsKineOneWeek() { symbolsService.updateSymbolsKine("1W"); } }