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 = "5/10 * * * * ? ")
|
public void updateSymbolsKineOneMin() {
|
symbolsService.updateSymbolsKine("1m");
|
}
|
|
/**
|
* 定时更新每5分钟的K线数据
|
*/
|
@Scheduled(cron = "5 0/5 * * * ?")
|
public void updateSymbolsKineFiveMin() {
|
symbolsService.updateSymbolsKine("5m");
|
}
|
|
/**
|
* 定时更新每30分钟的K线数据
|
*/
|
@Scheduled(cron = "10 0/11 * * * ?")
|
public void updateSymbolsKineMin() {
|
symbolsService.updateSymbolsKine("15m");
|
}
|
|
/**
|
* 定时更新每30分钟的K线数据
|
*/
|
@Scheduled(cron = "15 0/13 * * * ?")
|
public void updateSymbolsKineMin30() {
|
symbolsService.updateSymbolsKine("30m");
|
}
|
|
/**
|
* 定时更新1小时的K线数据
|
*/
|
@Scheduled(cron = "20 0/16 * * * ?")
|
public void updateSymbolsKineOneHour() {
|
symbolsService.updateSymbolsKine("1H");
|
}
|
|
/**
|
* 定时更新1小时的K线数据
|
*/
|
@Scheduled(cron = "25 0/19 * * * ?")
|
public void updateSymbolsKineTwoHour() {
|
symbolsService.updateSymbolsKine("2H");
|
}
|
|
/**
|
* 定时更新1小时的K线数据
|
*/
|
@Scheduled(cron = "30 0/21 * * * ?")
|
public void updateSymbolsKinefourHour() {
|
symbolsService.updateSymbolsKine("4H");
|
}
|
|
/**
|
* 定时更新1天的K线数据
|
*/
|
@Scheduled(cron = "35 0/24 * * * ?")
|
public void updateSymbolsKineOneDay() {
|
symbolsService.updateSymbolsKine("1D");
|
}
|
|
/**
|
* 定时更新1天的K线数据
|
*/
|
@Scheduled(cron = "40 0/27 * * * ?")
|
public void updateSymbolsKineOneWeek() {
|
symbolsService.updateSymbolsKine("1W");
|
}
|
|
}
|
