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");
|
}
|
|
}
|
