package com.yami.trading.huobi.task;
|
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import cn.hutool.core.thread.ThreadUtil;
|
import com.google.common.collect.Lists;
|
import com.yami.trading.bean.data.domain.Depth;
|
import com.yami.trading.bean.data.domain.Kline;
|
import com.yami.trading.bean.item.domain.Item;
|
import com.yami.trading.huobi.data.DataCache;
|
import com.yami.trading.huobi.data.internal.DepthTimeObject;
|
import com.yami.trading.huobi.data.internal.KlineInitService;
|
import com.yami.trading.huobi.data.internal.KlineService;
|
import com.yami.trading.huobi.hobi.internal.XueQiuDataServiceImpl;
|
import com.yami.trading.service.MarketOpenChecker;
|
import com.yami.trading.service.data.DataService;
|
import com.yami.trading.service.item.ItemService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Qualifier;
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Date;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
|
/**
|
* @哪吒出海 初始化K线方法弃用， (采用接口 + 缓存制)
|
*/
|
|
@Component
|
@Lazy(value = false)
|
@Slf4j
|
public class KlineBlankRepairTask {
|
@Autowired
|
private KlineService klineService;
|
|
@Autowired
|
private ItemService itemService;
|
@Autowired
|
@Qualifier("dataService")
|
private DataService dataService;
|
@Autowired
|
private KlineInitService klineInitService;
|
@Autowired
|
private KlineContext klineContext;
|
|
@Autowired
|
private XueQiuDataServiceImpl xueQiuDataService;
|
|
//虚拟货币10分钟检查下虚拟货币，外汇，股票的k线图是否为空， 每3秒更新一次K线缓存
|
//@Scheduled(cron = "0 0/7 * ? * *")
|
@Scheduled(fixedRate= 10000)
|
@Async
|
public void doTask() throws InterruptedException {
|
List<String> cryptosPeriod = Lists.newArrayList(Kline.PERIOD_1MIN, Kline.PERIOD_5MIN, Kline.PERIOD_15MIN, Kline.PERIOD_30MIN, Kline.PERIOD_60MIN,
|
Kline.PERIOD_4HOUR, Kline.PERIOD_1DAY, Kline.PERIOD_1WEEK, Kline.PERIOD_1MON
|
);
|
List<Item> cryptos = itemService.findByType(Item.cryptos);
|
checkTask(cryptosPeriod, cryptos);
|
}
|
|
|
/**
|
* 每小时初始化雪球cookies
|
*
|
* @throws InterruptedException
|
*/
|
//@Scheduled(cron = "0 0/30 * ? * *")
|
//@Async
|
//public void initXueQiuCookies() {
|
// xueQiuDataService.initXueQiuCookies();
|
//}
|
|
/**
|
* 马来西亚股票
|
*
|
* @throws InterruptedException
|
*/
|
//@Async
|
//@Scheduled(cron = "0 0/15 * ? * *")
|
////@Scheduled(fixedRate= 3000)
|
//public void doMyTask() throws InterruptedException {
|
// List<String> stockPeriod = Lists.newArrayList(Kline.PERIOD_1MIN, Kline.PERIOD_5MIN, Kline.PERIOD_15MIN, Kline.PERIOD_30MIN, Kline.PERIOD_60MIN,
|
// Kline.PERIOD_2HOUR, Kline.PERIOD_1DAY, Kline.PERIOD_5DAY, Kline.PERIOD_1WEEK, Kline.PERIOD_1MON, Kline.PERIOD_QUARTER, Kline.PERIOD_YEAR
|
// );
|
// List<Item> stocks = itemService.findByType(Item.MY_STOCKS);
|
//
|
// //开盘了 再采集
|
// checkTask(stockPeriod, stocks);
|
//}
|
|
|
//@Scheduled(cron = "0 0/6 * ? * *")
|
//@Scheduled(fixedRate= 10000)
|
//@Async
|
//public void doForexTask() throws InterruptedException {
|
// List<String> forexPeriod = Lists.newArrayList(Kline.PERIOD_1MIN, Kline.PERIOD_5MIN, Kline.PERIOD_15MIN, Kline.PERIOD_30MIN, Kline.PERIOD_60MIN,
|
// Kline.PERIOD_2HOUR, Kline.PERIOD_1DAY, Kline.PERIOD_5DAY, Kline.PERIOD_1WEEK, Kline.PERIOD_1MON
|
// );
|
// List<Item> forexs = itemService.findByType(Item.forex);
|
// checkTask(forexPeriod, forexs);
|
//}
|
|
//@Async
|
////@Scheduled(cron = "0 0/5 * ? * *")
|
//@Scheduled(fixedRate= 3000)
|
//public void doHkTask() throws InterruptedException {
|
// List<String> stockPeriod = Lists.newArrayList(Kline.PERIOD_1MIN, Kline.PERIOD_5MIN, Kline.PERIOD_15MIN, Kline.PERIOD_30MIN, Kline.PERIOD_60MIN,
|
// Kline.PERIOD_2HOUR, Kline.PERIOD_1DAY, Kline.PERIOD_5DAY, Kline.PERIOD_1WEEK, Kline.PERIOD_1MON, Kline.PERIOD_QUARTER, Kline.PERIOD_YEAR
|
// );
|
// List<Item> stocks = itemService.findByType(Item.HK_STOCKS);
|
// checkTask(stockPeriod, stocks);
|
//}
|
|
//@Async
|
////@Scheduled(cron = "0 0/5 * ? * *")
|
//@Scheduled(fixedRate= 3000)
|
//public void doTWTask() throws InterruptedException {
|
// List<String> stockPeriod = Lists.newArrayList(Kline.PERIOD_1MIN, Kline.PERIOD_5MIN, Kline.PERIOD_15MIN, Kline.PERIOD_30MIN, Kline.PERIOD_60MIN,
|
// Kline.PERIOD_2HOUR, Kline.PERIOD_1DAY, Kline.PERIOD_5DAY, Kline.PERIOD_1WEEK, Kline.PERIOD_1MON, Kline.PERIOD_QUARTER, Kline.PERIOD_YEAR
|
// );
|
// List<Item> stocks = itemService.findByType(Item.TW_STOCKS);
|
// checkTask(stockPeriod, stocks);
|
//}
|
|
//@Async
|
////@Scheduled(cron = "0 0/5 * ? * *")
|
//@Scheduled(fixedRate= 3000)
|
//public void doATask() throws InterruptedException {
|
// List<String> stockPeriod = Lists.newArrayList(Kline.PERIOD_1MIN, Kline.PERIOD_5MIN, Kline.PERIOD_15MIN, Kline.PERIOD_30MIN, Kline.PERIOD_60MIN,
|
// Kline.PERIOD_2HOUR, Kline.PERIOD_1DAY, Kline.PERIOD_5DAY, Kline.PERIOD_1WEEK, Kline.PERIOD_1MON, Kline.PERIOD_QUARTER, Kline.PERIOD_YEAR
|
// );
|
// List<Item> stocks = itemService.findByType(Item.A_STOCKS);
|
// checkTask(stockPeriod, stocks);
|
//}
|
|
//@Async
|
//@Scheduled(cron = "0 0/5 * ? * *")
|
//public void doInvestTask() throws InterruptedException {
|
// List<String> stockPeriod = Lists.newArrayList(Kline.PERIOD_1MIN, Kline.PERIOD_5MIN, Kline.PERIOD_15MIN, Kline.PERIOD_30MIN, Kline.PERIOD_60MIN,
|
// Kline.PERIOD_2HOUR, Kline.PERIOD_1DAY, Kline.PERIOD_5DAY, Kline.PERIOD_1WEEK, Kline.PERIOD_1MON, Kline.PERIOD_QUARTER, Kline.PERIOD_YEAR
|
// );
|
// List<Item> stocks = itemService.findByType(Item.JP_STOCKS);
|
// stocks.addAll(itemService.findByType(Item.INDIA_STOCKS));
|
// stocks.addAll(itemService.findByType(Item.UK_STOCKS));
|
// stocks.addAll(itemService.findByType(Item.DE_STOCKS));
|
// stocks.addAll(itemService.findByType(Item.BZ_STOCKS));
|
// stocks.addAll(itemService.findByType(Item.CAD_STOCKS));
|
// stocks.addAll(itemService.findByType(Item.FR_STOCKS));
|
// stocks.addAll(itemService.findByType(Item.SG_STOCKS));
|
// checkTask(stockPeriod, stocks);
|
//}
|
|
//@Async
|
////@Scheduled(cron = "0 0/5 * ? * *")
|
//@Scheduled(fixedRate= 3000)
|
//public void doUSTask() throws InterruptedException {
|
// List<String> stockPeriod = Lists.newArrayList(Kline.PERIOD_1MIN, Kline.PERIOD_5MIN, Kline.PERIOD_15MIN, Kline.PERIOD_30MIN, Kline.PERIOD_60MIN,
|
// Kline.PERIOD_2HOUR, Kline.PERIOD_1DAY, Kline.PERIOD_5DAY, Kline.PERIOD_1WEEK, Kline.PERIOD_1MON, Kline.PERIOD_QUARTER, Kline.PERIOD_YEAR
|
// );
|
// List<Item> stocks = itemService.findByType(Item.US_STOCKS);
|
// checkTask(stockPeriod, stocks);
|
//}
|
//
|
//@Async
|
////@Scheduled(cron = "0 0/5 * ? * *")
|
//@Scheduled(fixedRate= 3000)
|
//public void doETFTask() throws InterruptedException {
|
// List<String> stockPeriod = Lists.newArrayList(Kline.PERIOD_1MIN, Kline.PERIOD_5MIN, Kline.PERIOD_15MIN, Kline.PERIOD_30MIN, Kline.PERIOD_60MIN,
|
// Kline.PERIOD_2HOUR, Kline.PERIOD_1DAY, Kline.PERIOD_5DAY, Kline.PERIOD_1WEEK, Kline.PERIOD_1MON, Kline.PERIOD_QUARTER, Kline.PERIOD_YEAR
|
// );
|
// List<Item> stocks = itemService.findByType(Item.indices);
|
// checkTask(stockPeriod, stocks);
|
//}
|
|
public void checkTask(List<String> periods, List<Item> items) {
|
ThreadUtil.execAsync(() -> {
|
for (Item item : items) {
|
if (!item.isActive()) {
|
continue;
|
}
|
if (!klineContext.isInitSuccess(item.getSymbol())) {
|
continue;
|
}
|
if (klineContext.isManualIniting(item.getSymbol())) {
|
continue;
|
}
|
boolean needInit = false;
|
for (String period : periods) {
|
// 数据处理
|
List<Kline> data = this.dataService.kline(item.getSymbol(), period);
|
if (CollectionUtil.isEmpty(data)) {
|
// 规避有问题的
|
// if(item.getSymbol().equalsIgnoreCase("00941") || item.getSymbol().equalsIgnoreCase("IYW")){
|
// break;
|
// }
|
// log.info(" {} -> {} k线图为空，正在重新初始化", item.getSymbol(), period);
|
needInit = true;
|
break;
|
}
|
|
}
|
if (needInit) {
|
klineInitService.klineInit(item.getSymbol());
|
}
|
//每个产品增加一秒延迟，防止接口频繁
|
//ThreadUtil.sleep(1000);
|
}
|
});
|
|
}
|
|
|
}
|
