[volume-10] Collect, Stack, Zip

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

@@ -3,9 +3,7 @@
 import com.loopers.application.product.ProductInfo;
 import com.loopers.domain.product.Product;
 import com.loopers.domain.product.ProductService;
-import com.loopers.domain.ranking.Ranking;
-import com.loopers.domain.ranking.RankingService;
-import com.loopers.domain.ranking.RankingType;
+import com.loopers.domain.ranking.*;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
@@ -20,14 +18,27 @@
 public class RankingFacade {
 
     private final RankingService rankingService;
+    private final PeriodRankingService periodRankingService;
     private final ProductService productService;
 
     /**
      * TOP N 랭킹 조회 (상품 정보 포함)
      */
     @Transactional(readOnly = true)
-    public List<RankingInfo> getTopRanking(RankingType rankingType, LocalDate date, int limit) {
-        List<Ranking> entries = rankingService.getTopRanking(rankingType, date, limit);
+    public List<RankingInfo> getTopRanking(
+            RankingType rankingType,
+            PeriodType periodType,
+            LocalDate date,
+            int limit
+    ) {
+        // period가 null이면 DAILY로 처리
+        PeriodType period = periodType != null ? periodType : PeriodType.DAILY;
+
+        List<Ranking> entries = switch (period) {
+            case DAILY -> rankingService.getTopRanking(rankingType, LocalDate.now(), limit);
+            case WEEKLY -> periodRankingService.getTopWeeklyRanking(rankingType, date, limit);
+            case MONTHLY -> periodRankingService.getTopMonthlyRanking(rankingType, date, limit);
+        };
 
         if (entries.isEmpty()) {
             return List.of();
@@ -40,9 +51,21 @@ public List<RankingInfo> getTopRanking(RankingType rankingType, LocalDate date,
      * 페이지네이션 랭킹 조회
      */
     @Transactional(readOnly = true)
-    public List<RankingInfo> getRankingWithPaging(RankingType rankingType, LocalDate date,
-                                                  int page, int size) {
-        List<Ranking> entries = rankingService.getRankingWithPaging(rankingType, date, page, size);
+    public List<RankingInfo> getRankingWithPaging(
+            RankingType rankingType,
+            PeriodType periodType,
+            LocalDate date,
+            int page,
+            int size
+    ) {
+
+        PeriodType period = periodType != null ? periodType : PeriodType.DAILY;
+
+        List<Ranking> entries = switch (period) {
+            case DAILY -> rankingService.getRankingWithPaging(rankingType, LocalDate.now(), page, size);
+            case WEEKLY -> periodRankingService.getWeeklyRankingWithPaging(rankingType, date, page, size);
+            case MONTHLY -> periodRankingService.getMonthlyRankingWithPaging(rankingType, date, page, size);
+        };
 
         if (entries.isEmpty()) {
             return List.of();
@@ -55,7 +78,11 @@ public List<RankingInfo> getRankingWithPaging(RankingType rankingType, LocalDate
      * 특정 상품의 특정 랭킹 조회
      */
     @Transactional(readOnly = true)
-    public RankingInfo getProductRanking(RankingType rankingType, LocalDate date, Long productId) {
+    public RankingInfo getProductRanking(
+            RankingType rankingType,
+            LocalDate date,
+            Long productId
+    ) {
         Ranking entry = rankingService.getProductRanking(rankingType, date, productId);
 
         if (entry == null) {

apps/commerce-api/src/main/java/com/loopers/domain/metrics/ProductMetricsMonthly.java

@@ -0,0 +1,66 @@
+package com.loopers.domain.metrics;
+
+import jakarta.persistence.*;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import org.hibernate.annotations.Immutable;
+
+import java.time.LocalDate;
+import java.time.ZonedDateTime;
+
+/**
+ * 월간 상품 집계 Materialized View (읽기 전용)
+ * commerce-collector에서 생성한 집계 데이터 조회용
+ */
+@Entity
+@Table(name = "mv_product_metrics_monthly")
+@Getter
+@NoArgsConstructor
+@Immutable // 읽기 전용
+public class ProductMetricsMonthly {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(name = "product_id", nullable = false)
+    private Long productId;
+
+    @Column(name = "year", nullable = false)
+    private Integer year;
+
+    @Column(name = "month", nullable = false)
+    private Integer month;
+
+    @Column(name = "period_start_date", nullable = false)
+    private LocalDate periodStartDate;
+
+    @Column(name = "period_end_date", nullable = false)
+    private LocalDate periodEndDate;
+
+    @Column(name = "total_like_count", nullable = false)
+    private Long totalLikeCount;
+
+    @Column(name = "total_view_count", nullable = false)
+    private Long totalViewCount;
+
+    @Column(name = "total_order_count", nullable = false)
+    private Long totalOrderCount;
+
+    @Column(name = "aggregated_at")
+    private ZonedDateTime aggregatedAt;
+
+    @Column(name = "created_at")
+    private ZonedDateTime createdAt;
+
+    @Column(name = "updated_at")
+    private ZonedDateTime updatedAt;
+
+    /**
+     * 종합 점수 계산 (가중치 적용)
+     * Score = (like * 0.2) + (view * 0.1) + (order * 0.6)
+     */
+    public double calculateCompositeScore() {
+        return (totalLikeCount * 0.2) + (totalViewCount * 0.1) + (totalOrderCount * 0.6);
+    }
+}

apps/commerce-api/src/main/java/com/loopers/domain/metrics/ProductMetricsMonthlyRepository.java

@@ -0,0 +1,36 @@
+package com.loopers.domain.metrics;
+
+import java.util.List;
+import java.util.Optional;
+
+public interface ProductMetricsMonthlyRepository {
+    /**
+     * 특정 년도/월의 랭킹 조회 (좋아요 기준 정렬)
+     */
+    List<ProductMetricsMonthly> findByYearAndMonthOrderByLikeCountDesc(int year, int month, int limit);
+
+    /**
+     * 특정 년도/월의 랭킹 조회 (조회수 기준 정렬)
+     */
+    List<ProductMetricsMonthly> findByYearAndMonthOrderByViewCountDesc(int year, int month, int limit);
+
+    /**
+     * 특정 년도/월의 랭킹 조회 (주문수 기준 정렬)
+     */
+    List<ProductMetricsMonthly> findByYearAndMonthOrderByOrderCountDesc(int year, int month, int limit);
+
+    /**
+     * 특정 년도/월의 랭킹 조회 (Score 기준 정렬)
+     */
+    List<ProductMetricsMonthly> findByYearAndMonthOrderByCompositeScoreDesc(int year, int month, int limit);
+
+    /**
+     * 특정 상품의 월간 랭킹 조회
+     */
+    Optional<ProductMetricsMonthly> findByYearAndMonthAndProductId(int year, int month, Long productId);
+
+    /**
+     * 특정 년도/월의 전체 상품 수
+     */
+    long countByYearAndMonth(int year, int month);
+}

apps/commerce-api/src/main/java/com/loopers/domain/metrics/ProductMetricsWeekly.java

@@ -0,0 +1,66 @@
+package com.loopers.domain.metrics;
+
+import jakarta.persistence.*;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import org.hibernate.annotations.Immutable;
+
+import java.time.LocalDate;
+import java.time.ZonedDateTime;
+
+/**
+ * 주간 상품 집계 Materialized View (읽기 전용)
+ * commerce-collector에서 생성한 집계 데이터 조회용
+ */
+@Entity
+@Table(name = "mv_product_metrics_weekly")
+@Getter
+@NoArgsConstructor
+@Immutable // 읽기 전용
+public class ProductMetricsWeekly {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(name = "product_id", nullable = false)
+    private Long productId;
+
+    @Column(name = "year", nullable = false)
+    private Integer year;
+
+    @Column(name = "week", nullable = false)
+    private Integer week;
+
+    @Column(name = "period_start_date", nullable = false)
+    private LocalDate periodStartDate;
+
+    @Column(name = "period_end_date", nullable = false)
+    private LocalDate periodEndDate;
+
+    @Column(name = "total_like_count", nullable = false)
+    private Long totalLikeCount;
+
+    @Column(name = "total_view_count", nullable = false)
+    private Long totalViewCount;
+
+    @Column(name = "total_order_count", nullable = false)
+    private Long totalOrderCount;
+
+    @Column(name = "aggregated_at")
+    private ZonedDateTime aggregatedAt;
+
+    @Column(name = "created_at")
+    private ZonedDateTime createdAt;
+
+    @Column(name = "updated_at")
+    private ZonedDateTime updatedAt;
+
+    /**
+     * 종합 점수 계산 (가중치 적용)
+     * Score = (like * 0.2) + (view * 0.1) + (order * 0.6)
+     */
+    public double calculateCompositeScore() {
+        return (totalLikeCount * 0.2) + (totalViewCount * 0.1) + (totalOrderCount * 0.6);
+    }
+}

apps/commerce-api/src/main/java/com/loopers/domain/metrics/ProductMetricsWeeklyRepository.java

@@ -0,0 +1,36 @@
+package com.loopers.domain.metrics;
+
+import java.util.List;
+import java.util.Optional;
+
+public interface ProductMetricsWeeklyRepository {
+    /**
+     * 특정 년도/주차의 랭킹 조회 (좋아요 기준 정렬)
+     */
+    List<ProductMetricsWeekly> findByYearAndWeekOrderByLikeCountDesc(int year, int week, int limit);
+
+    /**
+     * 특정 년도/주차의 랭킹 조회 (조회수 기준 정렬)
+     */
+    List<ProductMetricsWeekly> findByYearAndWeekOrderByViewCountDesc(int year, int week, int limit);
+
+    /**
+     * 특정 년도/주차의 랭킹 조회 (주문수 기준 정렬)
+     */
+    List<ProductMetricsWeekly> findByYearAndWeekOrderByOrderCountDesc(int year, int week, int limit);
+
+    /**
+     * 특정 년도/주차의 랭킹 조회 (score 기준 정렬)
+     */
+    List<ProductMetricsWeekly> findByYearAndWeekOrderByCompositeScoreDesc(int year, int week, int limit);
+
+    /**
+     * 특정 상품의 주간 랭킹 조회
+     */
+    Optional<ProductMetricsWeekly> findByYearAndWeekAndProductId(int year, int week, Long productId);
+
+    /**
+     * 특정 년도/주차의 전체 상품 수
+     */
+    long countByYearAndWeek(int year, int week);
+}