Feature/ranking

apps/commerce-api/src/main/java/com/loopers/application/catalog/CatalogFacade.java

@@ -3,6 +3,7 @@
 import com.loopers.application.brand.BrandService;
 import com.loopers.application.product.ProductCacheService;
 import com.loopers.application.product.ProductService;
+import com.loopers.application.ranking.RankingService;
 import com.loopers.domain.brand.Brand;
 import com.loopers.domain.product.Product;
 import com.loopers.domain.product.ProductDetail;
@@ -14,6 +15,7 @@
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.time.LocalDate;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
@@ -34,6 +36,7 @@ public class CatalogFacade {
     private final ProductService productService;
     private final ProductCacheService productCacheService;
     private final ProductEventPublisher productEventPublisher;
+    private final RankingService rankingService;
 
     /**
      * 상품 목록을 조회합니다.
@@ -90,7 +93,7 @@ public ProductInfoList getProducts(Long brandId, String sort, int page, int size
                 }
                 // ✅ Product.likeCount 필드 사용 (비동기 집계된 값)
                 ProductDetail productDetail = ProductDetail.from(product, brand.getName(), product.getLikeCount());
-                return new ProductInfo(productDetail);
+                return ProductInfo.withoutRank(productDetail);
             })
             .toList();
 
@@ -108,10 +111,11 @@ public ProductInfoList getProducts(Long brandId, String sort, int page, int size
      * <p>
      * Redis 캐시를 먼저 확인하고, 캐시에 없으면 DB에서 조회한 후 캐시에 저장합니다.
      * 상품 조회 시 ProductViewed 이벤트를 발행하여 메트릭 집계에 사용합니다.
+     * 랭킹 정보도 함께 조회하여 반환합니다.
      * </p>
      *
      * @param productId 상품 ID
-     * @return 상품 정보와 좋아요 수
+     * @return 상품 정보와 좋아요 수, 랭킹 순위
      * @throws CoreException 상품을 찾을 수 없는 경우
      */
     @Transactional(readOnly = true)
@@ -121,7 +125,11 @@ public ProductInfo getProduct(Long productId) {
         if (cachedResult != null) {
             // 캐시 히트 시에도 조회 수 집계를 위해 이벤트 발행
             productEventPublisher.publish(ProductEvent.ProductViewed.from(productId));
-            return cachedResult;
+
+            // 랭킹 정보 조회 (캐시된 결과에 랭킹 정보 추가)
+            LocalDate today = LocalDate.now();
+            Long rank = rankingService.getProductRank(productId, today);
+            return ProductInfo.withRank(cachedResult.productDetail(), rank);
         }
 
         // 캐시에 없으면 DB에서 조회
@@ -136,16 +144,19 @@ public ProductInfo getProduct(Long productId) {
         // ProductDetail 생성 (Aggregate 경계 준수: Brand 엔티티 대신 brandName만 전달)
         ProductDetail productDetail = ProductDetail.from(product, brand.getName(), likesCount);
 
-        ProductInfo result = new ProductInfo(productDetail);
+        // 랭킹 정보 조회
+        LocalDate today = LocalDate.now();
+        Long rank = rankingService.getProductRank(productId, today);
 
-        // 캐시에 저장
-        productCacheService.cacheProduct(productId, result);
+        // 캐시에 저장 (랭킹 정보는 제외하고 저장 - 랭킹은 실시간으로 조회)
+        productCacheService.cacheProduct(productId, ProductInfo.withoutRank(productDetail));
 
         // ✅ 상품 조회 이벤트 발행 (메트릭 집계용)
         productEventPublisher.publish(ProductEvent.ProductViewed.from(productId));
 
         // 로컬 캐시의 좋아요 수 델타 적용 (DB 조회 결과에도 델타 반영)
-        return productCacheService.applyLikeCountDelta(result);
+        ProductInfo deltaApplied = productCacheService.applyLikeCountDelta(ProductInfo.withoutRank(productDetail));
+        return ProductInfo.withRank(deltaApplied.productDetail(), rank);
     }
 
 }

apps/commerce-api/src/main/java/com/loopers/application/catalog/ProductInfo.java

@@ -6,7 +6,28 @@
  * 상품 상세 정보를 담는 레코드.
  *
  * @param productDetail 상품 상세 정보 (Product + Brand + 좋아요 수)
+ * @param rank 랭킹 순위 (1부터 시작, 랭킹에 없으면 null)
  */
-public record ProductInfo(ProductDetail productDetail) {
+public record ProductInfo(ProductDetail productDetail, Long rank) {
+    /**
+     * 랭킹 정보 없이 ProductInfo를 생성합니다.
+     *
+     * @param productDetail 상품 상세 정보
+     * @return ProductInfo (rank는 null)
+     */
+    public static ProductInfo withoutRank(ProductDetail productDetail) {
+        return new ProductInfo(productDetail, null);
+    }
+
+    /**
+     * 랭킹 정보와 함께 ProductInfo를 생성합니다.
+     *
+     * @param productDetail 상품 상세 정보
+     * @param rank 랭킹 순위 (1부터 시작, 랭킹에 없으면 null)
+     * @return ProductInfo
+     */
+    public static ProductInfo withRank(ProductDetail productDetail, Long rank) {
+        return new ProductInfo(productDetail, rank);
+    }
 }
 

apps/commerce-api/src/main/java/com/loopers/application/product/ProductCacheService.java

@@ -269,7 +269,7 @@ public ProductInfo applyLikeCountDelta(ProductInfo productInfo) {
             updatedLikesCount
         );
 
-        return new ProductInfo(updatedDetail);
+        return ProductInfo.withoutRank(updatedDetail);
     }
 }
 

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

@@ -0,0 +1,52 @@
+package com.loopers.application.ranking;
+
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+
+/**
+ * 랭킹 키 생성 유틸리티.
+ * <p>
+ * Redis ZSET 랭킹 키를 생성합니다.
+ * </p>
+ *
+ * @author Loopers
+ * @version 1.0
+ */
+@Component
+public class RankingKeyGenerator {
+    private static final String DAILY_KEY_PREFIX = "ranking:all:";
+    private static final String HOURLY_KEY_PREFIX = "ranking:hourly:";
+    private static final DateTimeFormatter DATE_FORMATTER = DateTimeFormatter.ofPattern("yyyyMMdd");
+    private static final DateTimeFormatter DATE_TIME_FORMATTER = DateTimeFormatter.ofPattern("yyyyMMddHH");
+
+    /**
+     * 일간 랭킹 키를 생성합니다.
+     * <p>
+     * 예: ranking:all:20241215
+     * </p>
+     *
+     * @param date 날짜
+     * @return 일간 랭킹 키
+     */
+    public String generateDailyKey(LocalDate date) {
+        String dateStr = date.format(DATE_FORMATTER);
+        return DAILY_KEY_PREFIX + dateStr;
+    }
+
+    /**
+     * 시간 단위 랭킹 키를 생성합니다.
+     * <p>
+     * 예: ranking:hourly:2024121514
+     * </p>
+     *
+     * @param dateTime 날짜 및 시간
+     * @return 시간 단위 랭킹 키
+     */
+    public String generateHourlyKey(LocalDateTime dateTime) {
+        String dateTimeStr = dateTime.format(DATE_TIME_FORMATTER);
+        return HOURLY_KEY_PREFIX + dateTimeStr;
+    }
+}

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

@@ -0,0 +1,193 @@
+package com.loopers.application.ranking;
+
+import com.loopers.application.brand.BrandService;
+import com.loopers.application.product.ProductService;
+import com.loopers.domain.brand.Brand;
+import com.loopers.domain.product.Product;
+import com.loopers.domain.product.ProductDetail;
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
+import com.loopers.zset.ZSetEntry;
+import com.loopers.zset.RedisZSetTemplate;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.time.LocalDate;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ * 랭킹 조회 서비스.
+ * <p>
+ * Redis ZSET에서 랭킹을 조회하고 상품 정보를 Aggregation하여 제공합니다.
+ * </p>
+ * <p>
+ * <b>설계 원칙:</b>
+ * <ul>
+ *   <li>Application 유즈케이스: Ranking은 도메인이 아닌 파생 View로 취급</li>
+ *   <li>상품 정보 Aggregation: 상품 ID만이 아닌 상품 정보 포함</li>
+ *   <li>배치 조회: N+1 쿼리 문제 방지</li>
+ * </ul>
+ * </p>
+ *
+ * @author Loopers
+ * @version 1.0
+ */
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class RankingService {
+    private final RedisZSetTemplate zSetTemplate;
+    private final RankingKeyGenerator keyGenerator;
+    private final ProductService productService;
+    private final BrandService brandService;
+
+    /**
+     * 랭킹을 조회합니다 (페이징).
+     * <p>
+     * ZSET에서 상위 N개를 조회하고, 상품 정보를 Aggregation하여 반환합니다.
+     * </p>
+     *
+     * @param date 날짜 (yyyyMMdd 형식의 문자열 또는 LocalDate)
+     * @param page 페이지 번호 (0부터 시작)
+     * @param size 페이지당 항목 수
+     * @return 랭킹 조회 결과
+     */
+    @Transactional(readOnly = true)
+    public RankingsResponse getRankings(LocalDate date, int page, int size) {
+        String key = keyGenerator.generateDailyKey(date);
+        long start = (long) page * size;
+        long end = start + size - 1;
+
+        // ZSET에서 Top N 조회
+        List<ZSetEntry> entries = zSetTemplate.getTopRankings(key, start, end);
+
+        if (entries.isEmpty()) {
+            return RankingsResponse.empty(page, size);
+        }
+
+        // 상품 ID 추출
+        List<Long> productIds = entries.stream()
+            .map(entry -> Long.parseLong(entry.member()))
+            .toList();
+
+        // 상품 정보 배치 조회
+        List<Product> products = productService.getProducts(productIds);
+
+        // 상품 ID → Product Map 생성
+        Map<Long, Product> productMap = products.stream()
+            .collect(Collectors.toMap(Product::getId, product -> product));
+
+        // 브랜드 ID 수집
+        List<Long> brandIds = products.stream()
+            .map(Product::getBrandId)
+            .distinct()
+            .toList();
+
+        // 브랜드 배치 조회
+        Map<Long, Brand> brandMap = brandService.getBrands(brandIds).stream()
+            .collect(Collectors.toMap(Brand::getId, brand -> brand));
+
+        // 랭킹 항목 생성 (순위, 점수, 상품 정보 포함)
+        List<RankingItem> rankingItems = new ArrayList<>();
+        for (int i = 0; i < entries.size(); i++) {
+            ZSetEntry entry = entries.get(i);
+            Long productId = Long.parseLong(entry.member());
+            Long rank = start + i + 1; // 1-based 순위
+
+            Product product = productMap.get(productId);
+            if (product == null) {
+                log.warn("랭킹에 포함된 상품을 찾을 수 없습니다: productId={}", productId);
+                continue;
+            }
+
+            Brand brand = brandMap.get(product.getBrandId());
+            if (brand == null) {
+                log.warn("상품의 브랜드를 찾을 수 없습니다: productId={}, brandId={}", 
+                    productId, product.getBrandId());
+                continue;
+            }
+
+            ProductDetail productDetail = ProductDetail.from(
+                product, 
+                brand.getName(), 
+                product.getLikeCount()
+            );
+
+            rankingItems.add(new RankingItem(
+                rank,
+                entry.score(),
+                productDetail
+            ));
+        }
+
+        // 전체 랭킹 개수 조회 (ZSET 크기)
+        Long totalSize = zSetTemplate.getSize(key);
+        boolean hasNext = (start + size) < totalSize;
+
+        return new RankingsResponse(rankingItems, page, size, hasNext);
+    }
+
+    /**
+     * 특정 상품의 순위를 조회합니다.
+     * <p>
+     * 상품이 랭킹에 없으면 null을 반환합니다.
+     * </p>
+     *
+     * @param productId 상품 ID
+     * @param date 날짜
+     * @return 순위 (1부터 시작, 없으면 null)
+     */
+    @Transactional(readOnly = true)
+    public Long getProductRank(Long productId, LocalDate date) {
+        String key = keyGenerator.generateDailyKey(date);
+        Long rank = zSetTemplate.getRank(key, String.valueOf(productId));
+
+        if (rank == null) {
+            return null;
+        }
+
+        // 0-based → 1-based 변환
+        return rank + 1;
+    }
+
+    /**
+     * 랭킹 조회 결과.
+     *
+     * @param items 랭킹 항목 목록
+     * @param page 현재 페이지 번호
+     * @param size 페이지당 항목 수
+     * @param hasNext 다음 페이지 존재 여부
+     */
+    public record RankingsResponse(
+        List<RankingItem> items,
+        int page,
+        int size,
+        boolean hasNext
+    ) {
+        /**
+         * 빈 랭킹 조회 결과를 생성합니다.
+         */
+        public static RankingsResponse empty(int page, int size) {
+            return new RankingsResponse(List.of(), page, size, false);
+        }
+    }
+
+    /**
+     * 랭킹 항목 (순위, 점수, 상품 정보).
+     *
+     * @param rank 순위 (1부터 시작)
+     * @param score 점수
+     * @param productDetail 상품 상세 정보
+     */
+    public record RankingItem(
+        Long rank,
+        Double score,
+        ProductDetail productDetail
+    ) {
+    }
+}

apps/commerce-api/src/main/java/com/loopers/interfaces/api/catalog/ProductV1Dto.java

@@ -21,14 +21,16 @@ public class ProductV1Dto {
      * @param stock 상품 재고
      * @param brandId 브랜드 ID
      * @param likesCount 좋아요 수
+     * @param rank 랭킹 순위 (1부터 시작, 랭킹에 없으면 null)
      */
     public record ProductResponse(
         Long productId,
         String name,
         Integer price,
         Integer stock,
         Long brandId,
-        Long likesCount
+        Long likesCount,
+        Long rank
     ) {
         /**
          * ProductInfo로부터 ProductResponse를 생성합니다.
@@ -44,7 +46,8 @@ public static ProductResponse from(ProductInfo productInfo) {
                 detail.getPrice(),
                 detail.getStock(),
                 detail.getBrandId(),
-                detail.getLikesCount()
+                detail.getLikesCount(),
+                productInfo.rank()
             );
         }
     }