| | |
| | | // 1. 定义需要处理的所有股票类型(集中管理,新增类型只需添加到列表) |
| | | List<EStockType> stockTypes = Arrays.asList( |
| | | EStockType.US, |
| | | EStockType.HK, |
| | | EStockType.IN, |
| | | EStockType.TW |
| | | EStockType.JP |
| | | ); |
| | | |
| | | // 2. 批量创建所有异步任务 |
| | |
| | | return; |
| | | } |
| | | List<String> stockCodeList = list.stream().map(DataStockBean::getId).collect(Collectors.toList()); |
| | | List<Stock> stockList = stockMapper.selectList(new QueryWrapper<Stock>().in("stock_code", stockCodeList)); |
| | | List<Stock> stockList = stockMapper.selectList(new QueryWrapper<Stock>().in("stock_code", stockCodeList).ne("is_show", 0)); |
| | | |
| | | List<Stock> updateStockList = new ArrayList<>(); |
| | | for (DataStockBean o : list) { |
| | |
| | | return; |
| | | } |
| | | List<String> stockCodeList = list.stream().map(DataStockBean::getId).collect(Collectors.toList()); |
| | | List<Stock> stockList = stockMapper.selectList(new QueryWrapper<Stock>().in("stock_code", stockCodeList)); |
| | | List<Stock> stockList = stockMapper.selectList(new QueryWrapper<Stock>().in("stock_code", stockCodeList).ne("is_show", 0)); |
| | | List<Stock> updateStockList = new ArrayList<>(); |
| | | for (DataStockBean o : list) { |
| | | //Stock stock = stockMapper.findStockByCode(o.getId()); |