From d1f96003619fdabff6abf53e15c05af791bb2a1a Mon Sep 17 00:00:00 2001 From: vpckiet Date: Thu, 22 May 2025 14:32:35 +0700 Subject: [PATCH] update money ipo check --- .../java/cn/stock/market/infrastructure/job/Scraper.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 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 2c7d9f0..de781c2 100644 --- a/src/main/java/cn/stock/market/infrastructure/job/Scraper.java +++ b/src/main/java/cn/stock/market/infrastructure/job/Scraper.java @@ -528,22 +528,23 @@ public class Scraper { public List convertToMoneyStock(List stockIpoList) { // Lấy danh sách tất cả stockCode và exchangeType từ stockIpoList Set stockCodes = stockIpoList.stream().map(StockIpo::getStockCode).collect(Collectors.toSet()); - Set exchangeTypes = stockIpoList.stream().map(StockIpo::getExchangeType).collect(Collectors.toSet()); +// Set exchangeTypes = stockIpoList.stream().map(StockIpo::getExchangeType).collect(Collectors.toSet()); + Set exchangeTypes = stockIpoList.stream().map(stockIpo -> stockIpo.getExchangeType().toUpperCase()).collect(Collectors.toSet()); // Lấy tất cả các MoneyStock tồn tại trong database với stockCode và exchangeType trong stockIpoList List existingMoneyStocks = moneyStockRepository.findAll( QMoneyStockPO.moneyStockPO.moneyScId.in(stockCodes) - .and(QMoneyStockPO.moneyStockPO.stockType.in(exchangeTypes)) + .and(QMoneyStockPO.moneyStockPO.stockType.upper().in(exchangeTypes)) ); // Lưu các stockCode và exchangeType đã tồn tại Set existingKeys = existingMoneyStocks.stream() - .map(ms -> ms.getMoneyScId() + ms.getStockType()) + .map(ms -> ms.getMoneyScId() + ms.getStockType().toUpperCase()) .collect(Collectors.toSet()); // Chỉ giữ những StockIpo chưa tồn tại return stockIpoList.stream() - .filter(stockIpo -> !existingKeys.contains(stockIpo.getStockCode() + stockIpo.getExchangeType())) + .filter(stockIpo -> !existingKeys.contains(stockIpo.getStockCode() + stockIpo.getExchangeType().toUpperCase())) .map(this::convert) .collect(Collectors.toList()); }