#19 feat: 주가조회 날짜별로 정렬 추가

src/main/java/com/stockport/server/application/scheduler/indexData/IndexDataScheduler.java

@@ -13,15 +13,15 @@
 public class IndexDataScheduler {
     private final IndexDataService indexDataService;
 
-//    @Scheduled(cron = "0 0/5 9-18 * * MON-FRI", zone = "Asia/Seoul") // todo: 공휴일/휴장일 스케쥴러 처리 필요.
-//    public void updateKospi() {
-//        indexDataService.updateCurrentIndexData(MarketType.KOSPI);
-//        log.info("[Scheduler] 코스피 데이터 업데이트 완료");
-//    }
-//
-//    @Scheduled(cron = "0 0/5 9-18 * * MON-FRI", zone = "Asia/Seoul") // todo: 공휴일/휴장일 스케쥴러 처리 필요.
-//    public void updateKosdaq() {
-//        indexDataService.updateCurrentIndexData(MarketType.KOSPI);
-//        log.info("[Scheduler] 코스닥 데이터 업데이트 완료");
-//    }
+    @Scheduled(cron = "0 0/5 9-18 * * MON-FRI", zone = "Asia/Seoul") // todo: 공휴일/휴장일 스케쥴러 처리 필요.
+    public void updateKospi() {
+        indexDataService.updateCurrentIndexData(MarketType.KOSPI);
+        log.info("[Scheduler] 코스피 데이터 업데이트 완료");
+    }
+
+    @Scheduled(cron = "0 0/5 9-18 * * MON-FRI", zone = "Asia/Seoul") // todo: 공휴일/휴장일 스케쥴러 처리 필요.
+    public void updateKosdaq() {
+        indexDataService.updateCurrentIndexData(MarketType.KOSPI);
+        log.info("[Scheduler] 코스닥 데이터 업데이트 완료");
+    }
 }

src/main/java/com/stockport/server/application/scheduler/stock/StockScheduler.java

@@ -12,15 +12,15 @@
 public class StockScheduler {
     private final StockService stockService;
 
-//    @Scheduled(cron = "0 5 18 * * MON-FRI", zone = "Asia/Seoul") // todo: 공휴일/휴장일 스케쥴러 처리 필요.
-//    public void saveDailyStockData() {
-//        stockService.saveDailyStockData();
-//        log.info("[Scheduler] 일별 주가 데이터 업데이트 완료");
-//    }
-//
-//    @Scheduled(cron = "0 0/5 9-18 * * MON-FRI", zone = "Asia/Seoul") // todo: 공휴일/휴장일 스케쥴러 처리 필요.
-//    public void updateStockData() {
-//        stockService.updateCurrentStockData();
-//        log.info("[Scheduler] 주가 데이터 업데이트 완료");
-//    }
+    @Scheduled(cron = "0 5 18 * * MON-FRI", zone = "Asia/Seoul") // todo: 공휴일/휴장일 스케쥴러 처리 필요.
+    public void saveDailyStockData() {
+        stockService.saveDailyStockData();
+        log.info("[Scheduler] 일별 주가 데이터 업데이트 완료");
+    }
+
+    @Scheduled(cron = "0 0/5 9-18 * * MON-FRI", zone = "Asia/Seoul") // todo: 공휴일/휴장일 스케쥴러 처리 필요.
+    public void updateStockData() {
+        stockService.updateCurrentStockData();
+        log.info("[Scheduler] 주가 데이터 업데이트 완료");
+    }
 }

src/main/java/com/stockport/server/application/service/stock/StockServiceImpl.java

@@ -27,8 +27,11 @@
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDate;
+import java.util.ArrayList;
 import java.util.List;
+import java.util.Set;
 import java.util.concurrent.atomic.AtomicInteger;
+import java.util.stream.Collectors;
 
 @Service
 @Slf4j
@@ -58,7 +61,7 @@ public Page<StockRankResponse> getStocksByMarketCap(Pageable pageable) {
     public StockInfoResponse getStockInfo(String stockCode, LocalDate startDate, LocalDate endDate) {
         Stock stock = stockRepository.findByStockCd(stockCode)
                 .orElseThrow(() -> new GeneralException(ErrorStatus.STOCK_NOT_FOUND));
-        List<StockPriceResponse> stockPriceResponseList = stockPriceRepository.findByStockAndBaseDateBetween(stock, startDate, endDate)
+        List<StockPriceResponse> stockPriceResponseList = stockPriceRepository.findByStockAndBaseDateBetweenOrderByBaseDateDesc(stock, startDate, endDate)
                 .stream().map(StockPriceResponse::of).toList();
         return StockInfoResponse.of(stock, stockPriceResponseList);
     }
@@ -113,13 +116,22 @@ public void updatePeriodicStockData(LocalDate startDate, LocalDate endDate) {
     @Override
     @Transactional
     public void saveDailyStockData() {
+        LocalDate today = LocalDate.now();
+
+        Set<String> savedId = stockPriceRepository.findAllByBaseDate(today).stream()
+                .map(sp -> sp.getStock().getStockCd())
+                .collect(Collectors.toSet());
         List<Stock> stockList = stockRepository.findAll();
+
+        List<StockPrice> savePriceList = new ArrayList<>();
         for (Stock stock : stockList) {
-            if (stockPriceRepository.existsByStockAndBaseDate(stock, LocalDate.now()))
+            if (savedId.contains(stock.getStockCd()))
                 continue;
             StockPrice stockPrice = stock.getCurrentPriceInfo().toStockPriceEntity();
             stockPrice.updateStock(stock);
-            stockPriceRepository.save(stockPrice);
+
+            savePriceList.add(stockPrice);
         }
+        stockPriceRepository.saveAll(savePriceList);
     }
 }

src/main/java/com/stockport/server/domain/stock/repository/StockPriceRepository.java

@@ -11,9 +11,7 @@
 import java.util.List;
 
 public interface StockPriceRepository extends JpaRepository<StockPrice, Long> {
-    List<StockPrice> findByStockAndBaseDateBetween(Stock stock, LocalDate startDate, LocalDate endDate);
-
-    boolean existsByStockAndBaseDate(Stock stock, LocalDate baseDate);
+    List<StockPrice> findByStockAndBaseDateBetweenOrderByBaseDateDesc(Stock stock, LocalDate startDate, LocalDate endDate);
 
     @Query("""
     select sp.baseDate
@@ -26,4 +24,6 @@ List<LocalDate> findAllBaseDatesByStockAndDateRange(
             @Param("start") LocalDate start,
             @Param("end") LocalDate end
     );
+
+    List<StockPrice> findAllByBaseDate(LocalDate today);
 }