From a03ee8622350bc0bc50cd8b9236852ef81d062bb Mon Sep 17 00:00:00 2001 From: Achilles Date: Thu, 11 Jan 2024 09:45:11 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../market/infrastructure/job/Scraper.java | 23 +++++++++++-------- 1 file changed, 13 insertions(+), 10 deletions(-) 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 数据的