| | |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.util.List; |
| | | import java.util.stream.Collectors; |
| | | |
| | | /** |
| | | * 加密货币 定时器 |
| | |
| | | * 深度数据、近期交易记录 火币采集任务 |
| | | */ |
| | | @Async |
| | | @Scheduled(cron = "*/3 * * * * ?") |
| | | @Scheduled(cron = "*/4 * * * * ?") |
| | | public void DepthTradeCollectionTask() { |
| | | try { |
| | | List<Item> items = itemService.findByType(Item.cryptos); |
| | | items = items.stream().filter(item -> item.getDelFlag() == 0).collect(Collectors.toList()); |
| | | for (Item item : items) { |
| | | // 暂不使用 |
| | | // boolean isOpen = MarketOpenChecker.isMarketOpenByItemCloseType(item.getOpenCloseType()); |