cdoerabbit 피드백 반영

* 트랜젝션 어노테이션 추가

* 랭킹 대상 항목이 100개 미만일 때의 배치 에외 처리

* @StepScope를 적용하여 Step 실행마다 새 인스턴스를 생성

* 랭크 계산 후 싱글톤 인스턴스 내의 필드 초기화하여 데이터 오염 및 메모리 누수 문제 방지

* 배치 실행 파라미터에서 발생할 수 있는 null pointer exeception 수정

* n+1 쿼리 개선

Author: 이건영

apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingService.java

@@ -417,8 +417,10 @@ private RankingsResponse getRankingsFromMaterializedView(
         Map<Long, Brand> brandMap = brandService.getBrands(brandIds).stream()
             .collect(Collectors.toMap(Brand::getId, brand -> brand));
 
-        // 랭킹 항목 생성
+        // 랭킹 항목 생성 (순위 재계산: 누락된 항목 제외 후 연속 순위 부여)
         List<RankingItem> rankingItems = new ArrayList<>();
+        long currentRank = start + 1; // 1-based 순위 (페이지 시작 순위)
+        
         for (com.loopers.domain.rank.ProductRank rank : pagedRanks) {
             Long productId = rank.getProductId();
             Product product = productMap.get(productId);
@@ -445,7 +447,7 @@ private RankingsResponse getRankingsFromMaterializedView(
             double score = calculateScore(rank.getLikeCount(), rank.getSalesCount(), rank.getViewCount());
 
             rankingItems.add(new RankingItem(
-                rank.getRank().longValue(),
+                currentRank++, // 연속 순위 부여
                 score,
                 productDetail
             ));

apps/commerce-api/src/main/java/com/loopers/domain/rank/ProductRank.java

@@ -16,8 +16,9 @@
  * <p>
  * <b>Materialized View 설계:</b>
  * <ul>
- *   <li>주간 랭킹: `mv_product_rank_weekly` (period_type = WEEKLY)</li>
- *   <li>월간 랭킹: `mv_product_rank_monthly` (period_type = MONTHLY)</li>
+ *   <li>테이블: `mv_product_rank` (단일 테이블)</li>
+ *   <li>주간 랭킹: period_type = WEEKLY</li>
+ *   <li>월간 랭킹: period_type = MONTHLY</li>
  *   <li>TOP 100만 저장하여 조회 성능 최적화</li>
  * </ul>
  * </p>

apps/commerce-api/src/main/java/com/loopers/infrastructure/rank/ProductRankRepositoryImpl.java

@@ -6,6 +6,7 @@
 import jakarta.persistence.PersistenceContext;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Repository;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.time.LocalDate;
 import java.util.List;
@@ -19,6 +20,7 @@
  */
 @Slf4j
 @Repository
+@Transactional(readOnly = true)
 public class ProductRankRepositoryImpl implements ProductRankRepository {
 
     @PersistenceContext

apps/commerce-batch/src/main/java/com/loopers/domain/metrics/ProductMetricsRepository.java

@@ -54,9 +54,18 @@ public interface ProductMetricsRepository {
      * Spring Batch의 JpaPagingItemReader에서 사용됩니다.
      * updated_at 필드를 기준으로 해당 날짜의 데이터만 조회합니다.
      * </p>
+     * <p>
+     * <b>주의:</b> 쿼리는 {@code updatedAt >= :startDateTime AND updatedAt < :endDateTime} 조건을 사용하므로,
+     * endDateTime은 exclusive end입니다. 예를 들어, 2024-12-15의 데이터를 조회하려면:
+     * <ul>
+     *   <li>startDateTime: 2024-12-15 00:00:00</li>
+     *   <li>endDateTime: 2024-12-16 00:00:00 (다음 날 00:00:00)</li>
+     * </ul>
+     * 또는 {@code date.atTime(LocalTime.MAX)}를 사용할 수도 있습니다.
+     * </p>
      *
-     * @param startDateTime 조회 시작 시각 (해당 날짜의 00:00:00)
-     * @param endDateTime 조회 종료 시각 (해당 날짜의 23:59:59.999999999)
+     * @param startDateTime 조회 시작 시각 (해당 날짜의 00:00:00, inclusive)
+     * @param endDateTime 조회 종료 시각 (다음 날 00:00:00 또는 해당 날짜의 23:59:59.999999999, exclusive)
      * @param pageable 페이징 정보
      * @return 조회된 메트릭 페이지
      */
@@ -80,7 +89,6 @@ Page<ProductMetrics> findByUpdatedAtBetween(
      *
      * @return PagingAndSortingRepository를 구현한 JPA Repository
      */
-    @SuppressWarnings("rawtypes")
     org.springframework.data.repository.PagingAndSortingRepository<ProductMetrics, Long> getJpaRepository();
 }
 

apps/commerce-batch/src/main/java/com/loopers/domain/rank/ProductRank.java

@@ -16,8 +16,9 @@
  * <p>
  * <b>Materialized View 설계:</b>
  * <ul>
- *   <li>주간 랭킹: `mv_product_rank_weekly` (period_type = WEEKLY)</li>
- *   <li>월간 랭킹: `mv_product_rank_monthly` (period_type = MONTHLY)</li>
+ *   <li>테이블: `mv_product_rank` (단일 테이블)</li>
+ *   <li>주간 랭킹: period_type = WEEKLY</li>
+ *   <li>월간 랭킹: period_type = MONTHLY</li>
  *   <li>TOP 100만 저장하여 조회 성능 최적화</li>
  * </ul>
  * </p>

apps/commerce-batch/src/main/java/com/loopers/domain/rank/ProductRankScoreRepository.java

@@ -2,6 +2,7 @@
 
 import java.util.List;
 import java.util.Optional;
+import java.util.Set;
 
 /**
  * ProductRankScore 도메인 Repository 인터페이스.
@@ -39,6 +40,17 @@ public interface ProductRankScoreRepository {
      */
     Optional<ProductRankScore> findByProductId(Long productId);
 
+    /**
+     * 여러 product_id로 ProductRankScore를 일괄 조회합니다.
+     * <p>
+     * N+1 쿼리 문제를 방지하기 위해 사용합니다.
+     * </p>
+     *
+     * @param productIds 상품 ID 집합
+     * @return ProductRankScore 리스트
+     */
+    List<ProductRankScore> findAllByProductIdIn(Set<Long> productIds);
+
     /**
      * 모든 ProductRankScore를 점수 내림차순으로 조회합니다.
      * <p>

apps/commerce-batch/src/main/java/com/loopers/infrastructure/batch/rank/ProductRankAggregationReader.java

@@ -50,18 +50,33 @@ public class ProductRankAggregationReader {
      * @return RepositoryItemReader 인스턴스
      */
     public RepositoryItemReader<ProductMetrics> createWeeklyReader(LocalDate targetDate) {
+        DateRange weekRange = calculateWeeklyRange(targetDate);
+        
+        log.info("ProductRank 주간 Reader 초기화: targetDate={}, weekStart={}, weekEnd={}",
+            targetDate, weekRange.startDate(), weekRange.endDate());
+
+        return createReader(weekRange.startDateTime(), weekRange.endDateTime(), "weeklyReader");
+    }
+
+    /**
+     * 주간 범위를 계산합니다.
+     * <p>
+     * 테스트 가능성을 위해 별도 메서드로 분리했습니다.
+     * </p>
+     *
+     * @param targetDate 기준 날짜 (해당 주의 어느 날짜든 가능)
+     * @return 주간 범위 (시작일, 종료일)
+     */
+    DateRange calculateWeeklyRange(LocalDate targetDate) {
         // 주간 시작일 계산 (월요일)
         LocalDate weekStart = targetDate.with(java.time.DayOfWeek.MONDAY);
         LocalDateTime startDateTime = weekStart.atStartOfDay();
 
         // 주간 종료일 계산 (다음 주 월요일 00:00:00)
         LocalDate weekEnd = weekStart.plusWeeks(1);
         LocalDateTime endDateTime = weekEnd.atStartOfDay();
-
-        log.info("ProductRank 주간 Reader 초기화: targetDate={}, weekStart={}, weekEnd={}",
-            targetDate, weekStart, weekEnd);
-
-        return createReader(startDateTime, endDateTime, "weeklyReader");
+        
+        return new DateRange(weekStart, weekEnd, startDateTime, endDateTime);
     }
 
     /**
@@ -74,18 +89,33 @@ public RepositoryItemReader<ProductMetrics> createWeeklyReader(LocalDate targetD
      * @return RepositoryItemReader 인스턴스
      */
     public RepositoryItemReader<ProductMetrics> createMonthlyReader(LocalDate targetDate) {
+        DateRange monthRange = calculateMonthlyRange(targetDate);
+        
+        log.info("ProductRank 월간 Reader 초기화: targetDate={}, monthStart={}, monthEnd={}",
+            targetDate, monthRange.startDate(), monthRange.endDate());
+
+        return createReader(monthRange.startDateTime(), monthRange.endDateTime(), "monthlyReader");
+    }
+
+    /**
+     * 월간 범위를 계산합니다.
+     * <p>
+     * 테스트 가능성을 위해 별도 메서드로 분리했습니다.
+     * </p>
+     *
+     * @param targetDate 기준 날짜 (해당 월의 어느 날짜든 가능)
+     * @return 월간 범위 (시작일, 종료일)
+     */
+    DateRange calculateMonthlyRange(LocalDate targetDate) {
         // 월간 시작일 계산 (1일)
         LocalDate monthStart = targetDate.with(TemporalAdjusters.firstDayOfMonth());
         LocalDateTime startDateTime = monthStart.atStartOfDay();
 
         // 월간 종료일 계산 (다음 달 1일 00:00:00)
         LocalDate monthEnd = targetDate.with(TemporalAdjusters.firstDayOfNextMonth());
         LocalDateTime endDateTime = monthEnd.atStartOfDay();
-
-        log.info("ProductRank 월간 Reader 초기화: targetDate={}, monthStart={}, monthEnd={}",
-            targetDate, monthStart, monthEnd);
-
-        return createReader(startDateTime, endDateTime, "monthlyReader");
+        
+        return new DateRange(monthStart, monthEnd, startDateTime, endDateTime);
     }
 
     /**
@@ -119,5 +149,24 @@ private RepositoryItemReader<ProductMetrics> createReader(
             .sorts(sorts)
             .build();
     }
+
+    /**
+     * 날짜 범위를 담는 레코드.
+     * <p>
+     * 테스트 가능성을 위해 내부 클래스로 정의했습니다.
+     * </p>
+     *
+     * @param startDate 시작일
+     * @param endDate 종료일 (exclusive)
+     * @param startDateTime 시작 시각
+     * @param endDateTime 종료 시각 (exclusive)
+     */
+    record DateRange(
+        LocalDate startDate,
+        LocalDate endDate,
+        LocalDateTime startDateTime,
+        LocalDateTime endDateTime
+    ) {
+    }
 }
 

apps/commerce-batch/src/main/java/com/loopers/infrastructure/batch/rank/ProductRankCalculationProcessor.java

@@ -4,6 +4,7 @@
 import com.loopers.domain.rank.ProductRankScore;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.batch.core.configuration.annotation.StepScope;
 import org.springframework.batch.item.ItemProcessor;
 import org.springframework.stereotype.Component;
 
@@ -29,11 +30,12 @@
  */
 @Slf4j
 @Component
+@StepScope
 @RequiredArgsConstructor
 public class ProductRankCalculationProcessor implements ItemProcessor<ProductRankScore, ProductRank> {
 
     private final ProductRankAggregationProcessor productRankAggregationProcessor;
-    private final ThreadLocal<Integer> currentRank = ThreadLocal.withInitial(() -> 0);
+    private int currentRank = 0;
     private static final int TOP_RANK_LIMIT = 100;
 
     /**
@@ -48,8 +50,7 @@ public class ProductRankCalculationProcessor implements ItemProcessor<ProductRan
      */
     @Override
     public ProductRank process(ProductRankScore score) throws Exception {
-        int rank = currentRank.get() + 1;
-        currentRank.set(rank);
+        int rank = ++currentRank;
 
         // TOP 100에 포함되지 않으면 null 반환 (필터링)
         if (rank > TOP_RANK_LIMIT) {
@@ -76,11 +77,6 @@ public ProductRank process(ProductRankScore score) throws Exception {
             score.getViewCount()
         );
 
-        // Step 완료 후 ThreadLocal 정리 (마지막 항목 처리 시)
-        if (rank == TOP_RANK_LIMIT) {
-            currentRank.remove();
-        }
-
         return productRank;
     }
 }

apps/commerce-batch/src/main/java/com/loopers/infrastructure/batch/rank/ProductRankCalculationReader.java

@@ -4,6 +4,7 @@
 import com.loopers.domain.rank.ProductRankScoreRepository;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.batch.core.configuration.annotation.StepScope;
 import org.springframework.batch.item.ItemReader;
 import org.springframework.batch.item.NonTransientResourceException;
 import org.springframework.batch.item.ParseException;
@@ -33,6 +34,7 @@
  */
 @Slf4j
 @Component
+@StepScope
 @RequiredArgsConstructor
 public class ProductRankCalculationReader implements ItemReader<ProductRankScore> {
 

apps/commerce-batch/src/main/java/com/loopers/infrastructure/batch/rank/ProductRankCalculationWriter.java

@@ -4,6 +4,7 @@
 import com.loopers.domain.rank.ProductRankRepository;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.batch.core.configuration.annotation.StepScope;
 import org.springframework.batch.item.Chunk;
 import org.springframework.batch.item.ItemWriter;
 import org.springframework.stereotype.Component;
@@ -32,6 +33,7 @@
  */
 @Slf4j
 @Component
+@StepScope
 @RequiredArgsConstructor
 public class ProductRankCalculationWriter implements ItemWriter<ProductRank> {