Merge pull request #203 from FunD-StockProject/refactor/cron-tue-to-thu

Refactor: 종목 데이터 업데이트 요일을 화요일에서 목요일로 변경

Author: MuuiGong

scripts/import_stocks.py

@@ -49,7 +49,8 @@ def map_overseas_exchange(exchange_id, exchange_code):
 
 def process_korea_stocks():
     """국내 주식 종목 데이터 처리"""
-    base_dir = os.path.join(os.path.dirname(__file__), '..', 'open-trading-api', 'stocks_info')
+    # stocks_info 디렉토리를 base_dir로 사용
+    base_dir = os.path.join(os.path.dirname(__file__), 'stocks_info')
     os.makedirs(base_dir, exist_ok=True)
 
     stocks = []
@@ -130,7 +131,8 @@ def process_korea_stocks():
 
 def process_overseas_stocks():
     """해외 주식 종목 데이터 처리"""
-    base_dir = os.path.join(os.path.dirname(__file__), '..', 'open-trading-api', 'stocks_info')
+    # stocks_info 디렉토리를 base_dir로 사용
+    base_dir = os.path.join(os.path.dirname(__file__), 'stocks_info')
     os.makedirs(base_dir, exist_ok=True)
 
     stocks = []

scripts/stocks_info/kis_kospi_code_mst.py

@@ -13,7 +13,6 @@ def kospi_master_download(base_dir, verbose=False):
     if (verbose): print(f"current directory is {cwd}")
     ssl._create_default_https_context = ssl._create_unverified_context
 
-    import os
     urllib.request.urlretrieve("https://new.real.download.dws.co.kr/common/master/kospi_code.mst.zip",
                                os.path.join(base_dir, "kospi_code.zip"))
 

src/main/java/com/fund/stockProject/global/scheduler/StockUpdateScheduler.java

@@ -18,10 +18,10 @@ public class StockUpdateScheduler {
     private final StockImportService stockImportService;
 
     /**
-     * 매주 화요일 새벽 3시에 종목 마스터 데이터 업데이트
+     * 매주 목요일 새벽 3시에 종목 마스터 데이터 업데이트
      * Python 스크립트를 실행하여 최신 종목 데이터를 수집하고 DB에 반영합니다.
      */
-    @Scheduled(cron = "0 0 3 * * TUE", zone = "Asia/Seoul") // 매주 화요일 3시 실행
+    @Scheduled(cron = "0 0 3 * * THU", zone = "Asia/Seoul") // 매주 목요일 3시 실행
     public void updateStockMaster() {
         log.info("Starting weekly stock master update scheduler");
 

src/main/java/com/fund/stockProject/stock/service/StockImportService.java

@@ -62,7 +62,12 @@ public void importStocksFromJson(String jsonFilePath) {
             int invalidated = 0;
             int preserved = 0;
 
+            // 기존 종목들을 symbol로 조회하여 Map으로 변환 (성능 최적화)
+            Map<String, Stock> existingStocksMap = stockRepository.findAll().stream()
+                .collect(Collectors.toMap(Stock::getSymbol, stock -> stock, (existing, replacement) -> existing));
+
             // 1. 종목 마스터에 있는 종목 처리 (추가/업데이트)
+            List<Stock> stocksToSave = new ArrayList<>();
             for (Map<String, Object> stockData : stocksData) {
                 try {
                     String symbol = (String) stockData.get("symbol");
@@ -86,63 +91,38 @@ public void importStocksFromJson(String jsonFilePath) {
                         continue;
                     }
 
-                    // 섹터 코드 매핑 (KIS 업종 코드 → DomesticSector 또는 OverseasSector)
-                    // KIS에서 제공하는 공식 업종 코드를 그대로 사용합니다.
-                    if (sectorCodeStr != null && !sectorCodeStr.isEmpty() && !sectorCodeStr.equals("nan")) {
-                        if (exchangeNum == EXCHANGENUM.KOSPI || exchangeNum == EXCHANGENUM.KOSDAQ) {
-                            // 국내 주식: DomesticSector 사용
-                            DomesticSector domesticSector = DomesticSector.fromCode(sectorCodeStr, exchangeNum);
-                            if (domesticSector == DomesticSector.UNKNOWN) {
-                                log.debug("Domestic sector mapping failed: code={}, exchange={}, stock={}. Using UNKNOWN.", 
-                                    sectorCodeStr, exchangeNum, symbol);
-                            } else {
-                                log.trace("Mapped KIS sector code: {} -> DomesticSector: {} for stock: {}", 
-                                    sectorCodeStr, domesticSector, symbol);
-                            }
-                        } else if (exchangeNum == EXCHANGENUM.NAS || exchangeNum == EXCHANGENUM.NYS || exchangeNum == EXCHANGENUM.AMS) {
-                            // 해외 주식: OverseasSector 사용
-                            OverseasSector overseasSector = OverseasSector.fromCode(sectorCodeStr);
-                            if (overseasSector == OverseasSector.UNKNOWN) {
-                                log.debug("Overseas sector mapping failed: code={}, exchange={}, stock={}. Using UNKNOWN.", 
-                                    sectorCodeStr, exchangeNum, symbol);
-                            } else {
-                                log.trace("Mapped KIS sector code: {} -> OverseasSector: {} for stock: {}", 
-                                    sectorCodeStr, overseasSector, symbol);
-                            }
-                        }
-                    }
-
+                    Stock stock;
                     // 기존 종목 확인
-                    Optional<Stock> existingStock = stockRepository.findBySymbol(symbol);
-                    
-                    if (existingStock.isPresent()) {
+                    if (existingStocksMap.containsKey(symbol)) {
                         // 기존 종목 업데이트
-                        Stock stock = existingStock.get();
+                        stock = existingStocksMap.get(symbol);
                         stock.updateSymbolNameIfNull(symbolName);
                         // 종목 마스터에 있으므로 valid = true로 설정
                         setStockValid(stock, true);
-                        // 섹터 업데이트
-                        if (sectorCodeStr != null && !sectorCodeStr.isEmpty() && !sectorCodeStr.equals("nan")) {
-                            stock.setSectorByExchange(sectorCodeStr, exchangeNum);
-                        }
-                        stockRepository.save(stock);
                         updated++;
                     } else {
                         // 새 종목 생성
-                        Stock stock = createStock(symbol, symbolName, securityName, exchangeNum, true);
-                        // 섹터 설정
-                        if (sectorCodeStr != null && !sectorCodeStr.isEmpty() && !sectorCodeStr.equals("nan")) {
-                            stock.setSectorByExchange(sectorCodeStr, exchangeNum);
-                        }
-                        stockRepository.save(stock);
+                        stock = createStock(symbol, symbolName, securityName, exchangeNum, true);
                         saved++;
                     }
+                    
+                    // 섹터 업데이트
+                    if (sectorCodeStr != null && !sectorCodeStr.isEmpty() && !sectorCodeStr.equals("nan")) {
+                        stock.setSectorByExchange(sectorCodeStr, exchangeNum);
+                    }
+                    
+                    stocksToSave.add(stock);
 
                 } catch (Exception e) {
                     log.error("Error processing stock: {}", stockData, e);
                     skipped++;
                 }
             }
+            
+            // 배치로 저장
+            if (!stocksToSave.isEmpty()) {
+                stockRepository.saveAll(stocksToSave);
+            }
 
             // 2. 종목 마스터에 없는 종목 찾기
             List<Stock> allStocks = stockRepository.findAll();