[volume-10] 주간/월간 랭킹 - 김선민

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

@@ -6,13 +6,18 @@
 import com.loopers.domain.brand.BrandRepository;
 import com.loopers.domain.product.Product;
 import com.loopers.domain.product.ProductRepository;
+import com.loopers.domain.ranking.MonthlyRankingRepository;
+import com.loopers.domain.ranking.RankingPeriod;
 import com.loopers.domain.ranking.RankingRepository;
+import com.loopers.domain.ranking.WeeklyRankingRepository;
 import com.loopers.support.page.PageResponse;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.time.DayOfWeek;
 import java.time.LocalDate;
+import java.time.temporal.TemporalAdjusters;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
@@ -22,20 +27,22 @@
 public class RankingFacade {
 
     private final RankingRepository rankingRepository;
+    private final WeeklyRankingRepository weeklyRankingRepository;
+    private final MonthlyRankingRepository monthlyRankingRepository;
     private final ProductRepository productRepository;
     private final BrandRepository brandRepository;
     private final ProductAssembler productAssembler;
 
     @Transactional(readOnly = true)
-    public PageResponse<RankingInfo> getPage(LocalDate date, int page, int size) {
+    public PageResponse<RankingInfo> getPage(LocalDate date, RankingPeriod period, int page, int size) {
         long offset = (long) (page - 1) * size;
-        List<Long> productIds = rankingRepository.findProductIdsByRank(date, offset, (long) size);
+        List<Long> productIds = resolveProductIds(date, period, offset, (long) size);
 
         if (productIds.isEmpty()) {
             return new PageResponse<>(List.of(), page, size, 0);
         }
 
-        long count = rankingRepository.countByDate(date);
+        long count = resolveCount(date, period);
         int totalPages = (int) Math.ceil((double) count / size);
 
         List<Product> products = productRepository.findAllByIdIn(productIds);
@@ -55,4 +62,23 @@ public PageResponse<RankingInfo> getPage(LocalDate date, int page, int size) {
 
         return new PageResponse<>(rankingInfos, page, size, totalPages);
     }
+
+    private List<Long> resolveProductIds(LocalDate date, RankingPeriod period, long offset, long limit) {
+        return switch (period) {
+            case DAILY -> rankingRepository.findProductIdsByRank(date, offset, limit);
+            case WEEKLY -> weeklyRankingRepository.findProductIdsByBaseDate(
+                    date.with(TemporalAdjusters.previousOrSame(DayOfWeek.MONDAY)), offset, limit);
+            case MONTHLY -> monthlyRankingRepository.findProductIdsByBaseDate(
+                    date.withDayOfMonth(1), offset, limit);
+        };
+    }
+
+    private long resolveCount(LocalDate date, RankingPeriod period) {
+        return switch (period) {
+            case DAILY -> rankingRepository.countByDate(date);
+            case WEEKLY -> weeklyRankingRepository.countByBaseDate(
+                    date.with(TemporalAdjusters.previousOrSame(DayOfWeek.MONDAY)));
+            case MONTHLY -> monthlyRankingRepository.countByBaseDate(date.withDayOfMonth(1));
+        };
+    }
 }

apps/commerce-api/src/main/java/com/loopers/domain/ranking/MonthlyRankingRepository.java

@@ -0,0 +1,11 @@
+package com.loopers.domain.ranking;
+
+import java.time.LocalDate;
+import java.util.List;
+
+public interface MonthlyRankingRepository {
+
+    List<Long> findProductIdsByBaseDate(LocalDate baseDate, long offset, long limit);
+
+    long countByBaseDate(LocalDate baseDate);
+}

apps/commerce-api/src/main/java/com/loopers/domain/ranking/MvProductRankMonthly.java

@@ -0,0 +1,71 @@
+package com.loopers.domain.ranking;
+
+import jakarta.persistence.*;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDate;
+import java.time.ZonedDateTime;
+
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@Entity
+@Table(name = "mv_product_rank_monthly")
+public class MvProductRankMonthly {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(name = "product_id", nullable = false)
+    private Long productId;
+
+    @Column(name = "`rank`", nullable = false)
+    private int rank;
+
+    @Column(name = "score", nullable = false)
+    private double score;
+
+    @Column(name = "total_like", nullable = false)
+    private long totalLike;
+
+    @Column(name = "total_order", nullable = false)
+    private long totalOrder;
+
+    @Column(name = "total_view", nullable = false)
+    private long totalView;
+
+    @Column(name = "total_sales", nullable = false)
+    private long totalSales;
+
+    @Column(name = "base_date", nullable = false)
+    private LocalDate baseDate;
+
+    @Column(name = "created_at", nullable = false, updatable = false)
+    private ZonedDateTime createdAt;
+
+    private MvProductRankMonthly(Long productId, int rank, double score,
+                                  long totalLike, long totalOrder, long totalView,
+                                  long totalSales, LocalDate baseDate) {
+        this.productId = productId;
+        this.rank = rank;
+        this.score = score;
+        this.totalLike = totalLike;
+        this.totalOrder = totalOrder;
+        this.totalView = totalView;
+        this.totalSales = totalSales;
+        this.baseDate = baseDate;
+    }
+
+    public static MvProductRankMonthly of(Long productId, int rank, double score,
+                                           long totalLike, long totalOrder, long totalView,
+                                           long totalSales, LocalDate baseDate) {
+        return new MvProductRankMonthly(productId, rank, score, totalLike, totalOrder, totalView, totalSales, baseDate);
+    }
+
+    @PrePersist
+    private void prePersist() {
+        this.createdAt = ZonedDateTime.now();
+    }
+}

apps/commerce-api/src/main/java/com/loopers/domain/ranking/MvProductRankWeekly.java

@@ -0,0 +1,71 @@
+package com.loopers.domain.ranking;
+
+import jakarta.persistence.*;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDate;
+import java.time.ZonedDateTime;
+
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@Entity
+@Table(name = "mv_product_rank_weekly")
+public class MvProductRankWeekly {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(name = "product_id", nullable = false)
+    private Long productId;
+
+    @Column(name = "`rank`", nullable = false)
+    private int rank;
+
+    @Column(name = "score", nullable = false)
+    private double score;
+
+    @Column(name = "total_like", nullable = false)
+    private long totalLike;
+
+    @Column(name = "total_order", nullable = false)
+    private long totalOrder;
+
+    @Column(name = "total_view", nullable = false)
+    private long totalView;
+
+    @Column(name = "total_sales", nullable = false)
+    private long totalSales;
+
+    @Column(name = "base_date", nullable = false)
+    private LocalDate baseDate;
+
+    @Column(name = "created_at", nullable = false, updatable = false)
+    private ZonedDateTime createdAt;
+
+    private MvProductRankWeekly(Long productId, int rank, double score,
+                                 long totalLike, long totalOrder, long totalView,
+                                 long totalSales, LocalDate baseDate) {
+        this.productId = productId;
+        this.rank = rank;
+        this.score = score;
+        this.totalLike = totalLike;
+        this.totalOrder = totalOrder;
+        this.totalView = totalView;
+        this.totalSales = totalSales;
+        this.baseDate = baseDate;
+    }
+
+    public static MvProductRankWeekly of(Long productId, int rank, double score,
+                                          long totalLike, long totalOrder, long totalView,
+                                          long totalSales, LocalDate baseDate) {
+        return new MvProductRankWeekly(productId, rank, score, totalLike, totalOrder, totalView, totalSales, baseDate);
+    }
+
+    @PrePersist
+    private void prePersist() {
+        this.createdAt = ZonedDateTime.now();
+    }
+}

apps/commerce-api/src/main/java/com/loopers/domain/ranking/RankingPeriod.java

@@ -0,0 +1,7 @@
+package com.loopers.domain.ranking;
+
+public enum RankingPeriod {
+    DAILY,
+    WEEKLY,
+    MONTHLY
+}

apps/commerce-api/src/main/java/com/loopers/domain/ranking/WeeklyRankingRepository.java

@@ -0,0 +1,11 @@
+package com.loopers.domain.ranking;
+
+import java.time.LocalDate;
+import java.util.List;
+
+public interface WeeklyRankingRepository {
+
+    List<Long> findProductIdsByBaseDate(LocalDate baseDate, long offset, long limit);
+
+    long countByBaseDate(LocalDate baseDate);
+}

apps/commerce-api/src/main/java/com/loopers/infrastructure/ranking/JpaMonthlyRankingRepository.java

@@ -0,0 +1,28 @@
+package com.loopers.infrastructure.ranking;
+
+import com.loopers.domain.ranking.MonthlyRankingRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.stereotype.Repository;
+
+import java.time.LocalDate;
+import java.util.List;
+
+@RequiredArgsConstructor
+@Repository
+public class JpaMonthlyRankingRepository implements MonthlyRankingRepository {
+
+    private final MonthlyRankingJpaRepository jpaRepository;
+
+    @Override
+    public List<Long> findProductIdsByBaseDate(LocalDate baseDate, long offset, long limit) {
+        int pageNumber = (int) (offset / limit);
+        PageRequest pageRequest = PageRequest.of(pageNumber, (int) limit);
+        return jpaRepository.findProductIdsByBaseDate(baseDate, pageRequest);
+    }
+
+    @Override
+    public long countByBaseDate(LocalDate baseDate) {
+        return jpaRepository.countByBaseDate(baseDate);
+    }
+}

apps/commerce-api/src/main/java/com/loopers/infrastructure/ranking/JpaWeeklyRankingRepository.java

@@ -0,0 +1,28 @@
+package com.loopers.infrastructure.ranking;
+
+import com.loopers.domain.ranking.WeeklyRankingRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.stereotype.Repository;
+
+import java.time.LocalDate;
+import java.util.List;
+
+@RequiredArgsConstructor
+@Repository
+public class JpaWeeklyRankingRepository implements WeeklyRankingRepository {
+
+    private final WeeklyRankingJpaRepository jpaRepository;
+
+    @Override
+    public List<Long> findProductIdsByBaseDate(LocalDate baseDate, long offset, long limit) {
+        int pageNumber = (int) (offset / limit);
+        PageRequest pageRequest = PageRequest.of(pageNumber, (int) limit);
+        return jpaRepository.findProductIdsByBaseDate(baseDate, pageRequest);
+    }
+
+    @Override
+    public long countByBaseDate(LocalDate baseDate) {
+        return jpaRepository.countByBaseDate(baseDate);
+    }
+}

apps/commerce-api/src/main/java/com/loopers/infrastructure/ranking/MonthlyRankingJpaRepository.java

@@ -0,0 +1,18 @@
+package com.loopers.infrastructure.ranking;
+
+import com.loopers.domain.ranking.MvProductRankMonthly;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+import java.time.LocalDate;
+import java.util.List;
+
+public interface MonthlyRankingJpaRepository extends JpaRepository<MvProductRankMonthly, Long> {
+
+    @Query("SELECT m.productId FROM MvProductRankMonthly m WHERE m.baseDate = :baseDate ORDER BY m.rank ASC")
+    List<Long> findProductIdsByBaseDate(@Param("baseDate") LocalDate baseDate, Pageable pageable);
+
+    long countByBaseDate(LocalDate baseDate);
+}

apps/commerce-api/src/main/java/com/loopers/infrastructure/ranking/WeeklyRankingJpaRepository.java

@@ -0,0 +1,18 @@
+package com.loopers.infrastructure.ranking;
+
+import com.loopers.domain.ranking.MvProductRankWeekly;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+import java.time.LocalDate;
+import java.util.List;
+
+public interface WeeklyRankingJpaRepository extends JpaRepository<MvProductRankWeekly, Long> {
+
+    @Query("SELECT w.productId FROM MvProductRankWeekly w WHERE w.baseDate = :baseDate ORDER BY w.rank ASC")
+    List<Long> findProductIdsByBaseDate(@Param("baseDate") LocalDate baseDate, Pageable pageable);
+
+    long countByBaseDate(LocalDate baseDate);
+}

apps/commerce-api/src/main/java/com/loopers/interfaces/api/ranking/RankingController.java

@@ -2,6 +2,7 @@
 
 import com.loopers.application.ranking.RankingFacade;
 import com.loopers.application.ranking.RankingInfo;
+import com.loopers.domain.ranking.RankingPeriod;
 import com.loopers.interfaces.api.ApiResponse;
 import com.loopers.support.page.PageResponse;
 import lombok.RequiredArgsConstructor;
@@ -22,11 +23,12 @@ public class RankingController {
     @GetMapping("/api/v1/rankings")
     public ApiResponse<PageResponse<RankingDto.Response>> getRankings(
             @RequestParam(required = false) @DateTimeFormat(pattern = "yyyyMMdd") LocalDate date,
+            @RequestParam(defaultValue = "DAILY") RankingPeriod period,
             @RequestParam(defaultValue = "1") int page,
             @RequestParam(defaultValue = "20") int size
     ) {
         LocalDate targetDate = date != null ? date : LocalDate.now(ZoneOffset.UTC);
-        PageResponse<RankingInfo> infos = rankingFacade.getPage(targetDate, page, size);
+        PageResponse<RankingInfo> infos = rankingFacade.getPage(targetDate, period, page, size);
         return ApiResponse.success(infos.map(RankingDto.Response::from));
     }
 }