| | |
| | | try { |
| | | List<Item> list = itemService.list().stream().filter(i -> "0".equalsIgnoreCase(i.getFake())).collect(Collectors.toList()); |
| | | // etf 和A股开盘时间是一样的 |
| | | String aStocSymbols = list.stream().filter(item -> item.getOpenCloseType() != null && item.getOpenCloseType().equalsIgnoreCase(Item.A_STOCKS)).map(Item::getSymbol).collect(Collectors.joining(",")); |
| | | String hkStocSymbols = list.stream().filter(item -> item.getOpenCloseType() != null && item.getOpenCloseType().equalsIgnoreCase(Item.HK_STOCKS)).map(Item::getSymbol).collect(Collectors.joining(",")); |
| | | // String aStocSymbols = list.stream().filter(item -> item.getOpenCloseType() != null && item.getOpenCloseType().equalsIgnoreCase(Item.A_STOCKS)).map(Item::getSymbol).collect(Collectors.joining(",")); |
| | | // String hkStocSymbols = list.stream().filter(item -> item.getOpenCloseType() != null && item.getOpenCloseType().equalsIgnoreCase(Item.HK_STOCKS)).map(Item::getSymbol).collect(Collectors.joining(",")); |
| | | String usStocSymbols = list.stream().filter(item -> item.getOpenCloseType() != null && item.getOpenCloseType().equalsIgnoreCase(Item.US_STOCKS)).map(Item::getSymbol).collect(Collectors.joining(",")); |
| | | String symbols = aStocSymbols + "," + hkStocSymbols + "," + usStocSymbols; |
| | | String symbols = usStocSymbols; |
| | | List<StockMarket> markets = xueQiuDataService.getMarkets(symbols); |
| | | markets.forEach(m -> DataCache.putMarket(m.getSymbol(), m)); |
| | | |