Merge pull request #238 from FunD-StockProject/refactor/sector-paging-korea

Refactor: 섹터별 국내 종목 추천 페이징으로 여러 개 리턴하도록 변경

Author: MuuiGong

src/main/java/com/fund/stockProject/stock/controller/StockController.java

@@ -5,9 +5,7 @@
 import com.fund.stockProject.stock.domain.DomesticSector;
 import com.fund.stockProject.stock.domain.OverseasSector;
 import com.fund.stockProject.stock.dto.response.*;
-import com.fund.stockProject.stock.entity.Stock;
 import com.fund.stockProject.stock.service.StockService;
-import com.fund.stockProject.stock.service.SecurityService;
 import com.fund.stockProject.shortview.dto.ShortViewResponse;
 import com.fund.stockProject.common.dto.PageResponse;
 
@@ -39,7 +37,6 @@
 public class StockController {
 
     private final StockService stockService;
-    private final SecurityService securityService;
 
     @GetMapping("/search/{searchKeyword}/{country}")
     @Operation(summary = "주식 종목 검색 API", description = "주식 종목 및 인간지표 데이터 검색")
@@ -116,10 +113,12 @@ ResponseEntity<Mono<List<String>>> getSummarys(@PathVariable("symbol") String sy
     }
 
     @GetMapping("/sector/domestic/{sector}/recommend")
-    @Operation(summary = "국내 섹터별 주식 추천", description = "특정 국내 섹터의 주식을 점수 기반으로 추천합니다. 실시간 시세 조회 실패 시 가격 필드는 null로 반환됩니다.")
-    public ResponseEntity<ShortViewResponse> getRecommendationByDomesticSector(
+    @Operation(summary = "국내 섹터별 주식 추천 (페이징)", description = "특정 국내 섹터의 주식을 점수 기반으로 추천합니다. 기본 정렬은 인간지표(score) 내림차순이며, 각 항목의 가격은 가능하면 실시간으로 조회해 포함하고 실패 시 null로 반환됩니다.")
+    public ResponseEntity<PageResponse<ShortViewResponse>> getRecommendationByDomesticSector(
             @io.swagger.v3.oas.annotations.Parameter(description = "추천할 국내 섹터", example = "RETAIL", required = true)
-            @PathVariable String sector
+            @PathVariable String sector,
+            @RequestParam(required = false, defaultValue = "0") int page,
+            @RequestParam(required = false, defaultValue = "20") int size
     ) {
         try {
             // DomesticSector enum으로 변환
@@ -131,25 +130,13 @@ public ResponseEntity<ShortViewResponse> getRecommendationByDomesticSector(
                 return ResponseEntity.badRequest().build();
             }
 
-            log.info("DomesticSector({})별 추천을 요청했습니다.", sectorEnum);
-
-            Stock recommendedStock = stockService.getRecommendedStockByDomesticSector(sectorEnum);
-            if (recommendedStock != null) {
-                log.info("DomesticSector({})에서 주식({})을 추천했습니다.", sectorEnum, recommendedStock.getSymbolName());
-                
-                // 실시간 가격 정보를 동기적으로 가져오기
-                try {
-                    var stockInfo = securityService.getRealTimeStockPrice(recommendedStock).block();
-                    return ResponseEntity.ok(ShortViewResponse.fromEntityWithPrice(recommendedStock, stockInfo));
-                } catch (Exception e) {
-                    log.warn("실시간 가격 조회 실패, 기본 정보로 응답합니다. stock_id: {}, error: {}", 
-                            recommendedStock.getId(), e.getMessage());
-                    return ResponseEntity.ok(ShortViewResponse.fromEntity(recommendedStock));
-                }
-            } else {
-                log.warn("DomesticSector({})에 대한 추천 주식을 찾을 수 없습니다. (유효한 주식이 없거나 점수가 없음)", sectorEnum);
-                return ResponseEntity.noContent().build();
-            }
+            log.info("DomesticSector({})별 추천(paged) 요청: page={}, size={}", sectorEnum, page, size);
+
+            int safeSize = Math.max(1, Math.min(size, 100));
+            int safePage = Math.max(0, page);
+
+            var pageResp = stockService.getRecommendedStocksByDomesticSectorPaged(sectorEnum, safePage, safeSize);
+            return ResponseEntity.ok(pageResp);
         } catch (Exception e) {
             log.error("DomesticSector별 추천 중 오류 발생: {}", sector, e);
             return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();

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

@@ -1024,6 +1024,88 @@ public Stock getRecommendedStockByDomesticSector(DomesticSector sector) {
         return selectWeightedRandom(stocksWithWeight, random);
     }
 
+    /**
+     * 국내 섹터 추천을 페이징으로 제공합니다. 정렬 기준은 인간지표(점수) 내림차순입니다.
+     * 가격은 가능하면 실시간으로 조회해 포함하고 실패 시 null로 반환됩니다.
+     */
+    public PageResponse<ShortViewResponse> getRecommendedStocksByDomesticSectorPaged(
+        DomesticSector sector, int page, int size) {
+        if (sector == null || sector == DomesticSector.UNKNOWN) {
+            return PageResponse.<ShortViewResponse>builder()
+                .items(java.util.List.of())
+                .page(page)
+                .size(size)
+                .totalElements(0)
+                .totalPages(0)
+                .build();
+        }
+
+        List<Stock> validStocks = stockRepository.findValidStocksByDomesticSector(sector);
+        if (validStocks.isEmpty()) {
+            return PageResponse.<ShortViewResponse>builder()
+                .items(java.util.List.of())
+                .page(page)
+                .size(size)
+                .totalElements(0)
+                .totalPages(0)
+                .build();
+        }
+
+        List<Integer> candidateStockIds = validStocks.stream().map(Stock::getId).toList();
+        LocalDate today = LocalDate.now();
+        List<Score> todayScores = scoreRepository.findTodayScoresByStockIds(candidateStockIds, today);
+        List<Score> latestScores = scoreRepository.findLatestScoresByStockIds(candidateStockIds);
+
+        Map<Integer, Score> scoreMap = new HashMap<>();
+        todayScores.forEach(s -> scoreMap.put(s.getStockId(), s));
+        latestScores.forEach(s -> scoreMap.putIfAbsent(s.getStockId(), s));
+
+        // Filter stocks with valid score (not 9999)
+        List<Stock> stocksWithScore = validStocks.stream()
+            .filter(stock -> {
+                Score sc = scoreMap.get(stock.getId());
+                if (sc == null) return false;
+                int val = getScoreByCountry(sc, stock.getExchangeNum());
+                return val != 9999;
+            })
+            .toList();
+
+        // sort by score desc
+        List<Stock> sorted = stocksWithScore.stream()
+            .sorted((a, b) -> {
+                int sa = getScoreByCountry(scoreMap.get(a.getId()), a.getExchangeNum());
+                int sb = getScoreByCountry(scoreMap.get(b.getId()), b.getExchangeNum());
+                return Integer.compare(sb, sa);
+            })
+            .toList();
+
+        final int total = sorted.size();
+        final int totalPages = (int) Math.ceil((double) total / size);
+        final int from = Math.min(page * size, total);
+        final int to = Math.min(from + size, total);
+
+        List<ShortViewResponse> items = sorted.subList(from, to).stream()
+            .map(stock -> {
+                try {
+                    var stockInfo = securityService.getRealTimeStockPrice(stock).block();
+                    if (stockInfo != null && stockInfo.getPrice() != null) {
+                        return ShortViewResponse.fromEntityWithPrice(stock, stockInfo);
+                    }
+                } catch (Exception e) {
+                    log.debug("실시간 가격 조회 실패(무시). stockId={}, error={}", stock.getId(), e.getMessage());
+                }
+                return ShortViewResponse.fromEntity(stock);
+            })
+            .toList();
+        return PageResponse.<ShortViewResponse>builder()
+                .items(items)
+                .page(page)
+                .size(size)
+                .totalElements(total)
+                .totalPages(totalPages)
+                .build();
+    }
+
     /**
      * 특정 OverseasSector의 주식을 추천합니다.
      * 점수 기반 가중치 랜덤 추천을 사용합니다.