| | |
|---|
| | | @Autowired |
|---|
| | | private CryptosKlineService cryptosKlineService; |
|---|
| | | |
|---|
| | | @Scheduled(cron = "0 0/5 * ? * *") |
|---|
| | | @Scheduled(cron = "10 0/5 * ? * *") |
|---|
| | | public void taskJob() { |
|---|
| | | StopWatch stopWatch = new StopWatch(); |
|---|
| | | log.info("Kline5MinuteJob start ... "); |
|---|
| | |
|---|
| | | List<Item> item_list = itemService.list(); |
|---|
| | | for (int i = 0; i < item_list.size(); i++) { |
|---|
| | | Item item = item_list.get(i); |
|---|
| | | if (MarketOpenChecker.isMarketOpenByItemCloseType(item.getOpenCloseType())) { |
|---|
| | | if (MarketOpenChecker.isMarketOpenByItemCloseType(item.getOpenCloseType()) && item.getType().equals("cryptos")) { |
|---|
| | | if (Item.cryptos.equalsIgnoreCase(item.getType())) { |
|---|
| | | cryptosKlineService.saveOne(item.getSymbol(), Kline.PERIOD_5MIN); |
|---|
| | | } else { |
|---|
