diff --git a/src/main/java/cn/stock/market/infrastructure/job/Scraper.java b/src/main/java/cn/stock/market/infrastructure/job/Scraper.java index dc54bcf..23dfa4e 100644 --- a/src/main/java/cn/stock/market/infrastructure/job/Scraper.java +++ b/src/main/java/cn/stock/market/infrastructure/job/Scraper.java @@ -175,20 +175,23 @@ public class Scraper { // stockIpoRepository.saveAll(listStockIpoList); List scIdList = Lists.transform(listStockIpoList, StockIpo::getStockCode); - List existStockIpoList = stockIpoRepository.findAll(QStockIpoPO.stockIpoPO.stockCode.in(scIdList)); - List existingStockScIds = existStockIpoList.stream() - .map(StockIpo::getStockCode) - .collect(Collectors.toList()); + if(CollectionUtil.isNotEmpty(scIdList)){ + List existStockIpoList = stockIpoRepository.findAll(QStockIpoPO.stockIpoPO.stockCode.in(scIdList)); + List existingStockScIds = existStockIpoList.stream() + .map(StockIpo::getStockCode) + .collect(Collectors.toList()); - listStockIpoList = listStockIpoList.stream() - .filter(stockIpos -> !existingStockScIds.contains(stockIpos.getStockCode())) - .collect(Collectors.toList()); + listStockIpoList = listStockIpoList.stream() + .filter(stockIpos -> !existingStockScIds.contains(stockIpos.getStockCode())) + .collect(Collectors.toList()); - //保存全部的新股 - if(CollectionUtil.isNotEmpty(listStockIpoList)){ - stockIpoRepository.saveAll(listStockIpoList); + //保存全部的新股 + if(CollectionUtil.isNotEmpty(listStockIpoList)){ + stockIpoRepository.saveAll(listStockIpoList); + } } + // 输出整个 JSON 数据 } else { log.info("未找到包含 JSON 数据的