[volume-10] Collect, Stack, Zip

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

@@ -4,8 +4,15 @@
 
 public class RankingCommand {
 
-    public record GetDailyRankingCommand(
+    public enum RankingType {
+        DAILY,
+        WEEKLY,
+        MONTHLY
+    }
+
+    public record GetRankingCommand(
             LocalDate date,
+            RankingType type,
             int page,
             int size
     ) {

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

@@ -5,6 +5,8 @@
 import com.loopers.domain.product.ProductService;
 import com.loopers.domain.ranking.Ranking;
 import com.loopers.domain.ranking.RankingService;
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
 import java.util.Objects;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -23,12 +25,18 @@ public class RankingFacade {
     private final ProductService productService;
     private final BrandService brandService;
 
-    public RankingInfo getDailyRanking(RankingCommand.GetDailyRankingCommand command) {
-        List<Ranking> rankings = rankingService.getRanking(
-                command.date(),
-                command.page(),
-                command.size()
-        );
+    public RankingInfo getRanking(RankingCommand.GetRankingCommand command) {
+        List<Ranking> rankings;
+
+        if (command.type() == RankingCommand.RankingType.DAILY) {
+            rankings = rankingService.getDailyRanking(command.date(), command.page(), command.size());
+        } else if (command.type() == RankingCommand.RankingType.WEEKLY) {
+            rankings = rankingService.getWeeklyRanking(command.date(), command.page(), command.size());
+        } else if (command.type() == RankingCommand.RankingType.MONTHLY) {
+            rankings = rankingService.getMonthlyRanking(command.date(), command.page(), command.size());
+        } else {
+            throw new CoreException(ErrorType.BAD_REQUEST, "지원하지 않는 랭킹 타입입니다: " + command.type());
+        }
 
         if (rankings.isEmpty()) {
             return new RankingInfo(List.of());

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

@@ -0,0 +1,77 @@
+package com.loopers.domain.ranking;
+
+import com.loopers.domain.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Table;
+import jakarta.persistence.UniqueConstraint;
+import lombok.Builder;
+import lombok.Getter;
+
+import java.time.LocalDate;
+
+@Entity
+@Table(
+        name = "mv_product_rank_monthly",
+        uniqueConstraints = {
+                @UniqueConstraint(columnNames = {"product_id", "period_start_date", "period_end_date"})
+        }
+)
+@Getter
+public class MvProductRankMonthly extends BaseEntity {
+
+    @Column(name = "product_id", nullable = false)
+    private Long productId;
+
+    @Column(nullable = true)
+    private Integer ranking;
+
+    @Column(nullable = false)
+    private Double score;
+
+    @Column(name = "period_start_date", nullable = false)
+    private LocalDate periodStartDate;
+
+    @Column(name = "period_end_date", nullable = false)
+    private LocalDate periodEndDate;
+
+    @Column(name = "like_count", nullable = false)
+    private Long likeCount;
+
+    @Column(name = "view_count", nullable = false)
+    private Long viewCount;
+
+    @Column(name = "sales_count", nullable = false)
+    private Long salesCount;
+
+    @Builder
+    private MvProductRankMonthly(Long productId, Integer ranking, Double score, LocalDate periodStartDate,
+                                 LocalDate periodEndDate, Long likeCount, Long viewCount, Long salesCount) {
+        this.productId = productId;
+        this.ranking = ranking;
+        this.score = score;
+        this.periodStartDate = periodStartDate;
+        this.periodEndDate = periodEndDate;
+        this.likeCount = likeCount;
+        this.viewCount = viewCount;
+        this.salesCount = salesCount;
+    }
+
+    public MvProductRankMonthly() {
+    }
+
+    public static MvProductRankMonthly create(Long productId, Integer ranking, Double score, LocalDate periodStartDate,
+                                              LocalDate periodEndDate, Long likeCount, Long viewCount, Long salesCount) {
+        return MvProductRankMonthly.builder()
+                .productId(productId)
+                .ranking(ranking)
+                .score(score)
+                .periodStartDate(periodStartDate)
+                .periodEndDate(periodEndDate)
+                .likeCount(likeCount)
+                .viewCount(viewCount)
+                .salesCount(salesCount)
+                .build();
+    }
+}
+

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

@@ -0,0 +1,9 @@
+package com.loopers.domain.ranking;
+
+import java.time.LocalDate;
+import java.util.List;
+
+public interface MvProductRankMonthlyRepository {
+    List<MvProductRankMonthly> findByPeriodOrderByRankingAsc(LocalDate periodStartDate, LocalDate periodEndDate, int page, int size);
+}
+

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

@@ -0,0 +1,77 @@
+package com.loopers.domain.ranking;
+
+import com.loopers.domain.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Table;
+import jakarta.persistence.UniqueConstraint;
+import lombok.Builder;
+import lombok.Getter;
+
+import java.time.LocalDate;
+
+@Entity
+@Table(
+        name = "mv_product_rank_weekly",
+        uniqueConstraints = {
+                @UniqueConstraint(columnNames = {"product_id", "period_start_date", "period_end_date"})
+        }
+)
+@Getter
+public class MvProductRankWeekly extends BaseEntity {
+
+    @Column(name = "product_id", nullable = false)
+    private Long productId;
+
+    @Column(nullable = true)
+    private Integer ranking;
+
+    @Column(nullable = false)
+    private Double score;
+
+    @Column(name = "period_start_date", nullable = false)
+    private LocalDate periodStartDate;
+
+    @Column(name = "period_end_date", nullable = false)
+    private LocalDate periodEndDate;
+
+    @Column(name = "like_count", nullable = false)
+    private Long likeCount;
+
+    @Column(name = "view_count", nullable = false)
+    private Long viewCount;
+
+    @Column(name = "sales_count", nullable = false)
+    private Long salesCount;
+
+    @Builder
+    private MvProductRankWeekly(Long productId, Integer ranking, Double score, LocalDate periodStartDate, LocalDate periodEndDate,
+                                Long likeCount, Long viewCount, Long salesCount) {
+        this.productId = productId;
+        this.ranking = ranking;
+        this.score = score;
+        this.periodStartDate = periodStartDate;
+        this.periodEndDate = periodEndDate;
+        this.likeCount = likeCount;
+        this.viewCount = viewCount;
+        this.salesCount = salesCount;
+    }
+
+    public MvProductRankWeekly() {
+    }
+
+    public static MvProductRankWeekly create(Long productId, Integer ranking, Double score, LocalDate periodStartDate,
+                                             LocalDate periodEndDate, Long likeCount, Long viewCount, Long salesCount) {
+        return MvProductRankWeekly.builder()
+                .productId(productId)
+                .ranking(ranking)
+                .score(score)
+                .periodStartDate(periodStartDate)
+                .periodEndDate(periodEndDate)
+                .likeCount(likeCount)
+                .viewCount(viewCount)
+                .salesCount(salesCount)
+                .build();
+    }
+}
+

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

@@ -0,0 +1,9 @@
+package com.loopers.domain.ranking;
+
+import java.time.LocalDate;
+import java.util.List;
+
+public interface MvProductRankWeeklyRepository {
+    List<MvProductRankWeekly> findByPeriodOrderByRankingAsc(LocalDate periodStartDate, LocalDate periodEndDate, int page, int size);
+}
+

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

@@ -0,0 +1,25 @@
+package com.loopers.domain.ranking;
+
+import java.time.DayOfWeek;
+import java.time.LocalDate;
+import java.time.YearMonth;
+import java.time.temporal.TemporalAdjusters;
+
+public record RankingPeriod(
+        LocalDate startDate,
+        LocalDate endDate
+) {
+    public static RankingPeriod ofWeek(LocalDate date) {
+        LocalDate weekStart = date.with(TemporalAdjusters.previousOrSame(DayOfWeek.MONDAY));
+        LocalDate weekEnd = date.with(TemporalAdjusters.nextOrSame(DayOfWeek.SUNDAY));
+        return new RankingPeriod(weekStart, weekEnd);
+    }
+
+    public static RankingPeriod ofMonth(LocalDate date) {
+        YearMonth yearMonth = YearMonth.from(date);
+        LocalDate monthStart = yearMonth.atDay(1);
+        LocalDate monthEnd = yearMonth.atEndOfMonth();
+        return new RankingPeriod(monthStart, monthEnd);
+    }
+}
+

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

@@ -14,8 +14,10 @@
 public class RankingService {
 
     private final RankingCacheService rankingCacheService;
+    private final MvProductRankWeeklyRepository mvProductRankWeeklyRepository;
+    private final MvProductRankMonthlyRepository mvProductRankMonthlyRepository;
 
-    public List<Ranking> getRanking(LocalDate date, int page, int size) {
+    public List<Ranking> getDailyRanking(LocalDate date, int page, int size) {
         long start = (long) (page - 1) * size;
         long end = start + size - 1;
 
@@ -33,5 +35,53 @@ public List<Ranking> getRanking(LocalDate date, int page, int size) {
                 })
                 .toList();
     }
+
+    public List<Ranking> getWeeklyRanking(LocalDate date, int page, int size) {
+        RankingPeriod period = RankingPeriod.ofWeek(date);
+        List<MvProductRankWeekly> weeklyRanks = mvProductRankWeeklyRepository
+                .findByPeriodOrderByRankingAsc(
+                        period.startDate(),
+                        period.endDate(),
+                        page,
+                        size
+                );
+
+        if (weeklyRanks.isEmpty()) {
+            return new ArrayList<>();
+        }
+
+        return weeklyRanks.stream()
+                .filter(rank -> rank.getRanking() != null)
+                .map(rank -> new Ranking(
+                        rank.getProductId(),
+                        rank.getRanking().longValue(),
+                        rank.getScore()
+                ))
+                .toList();
+    }
+
+    public List<Ranking> getMonthlyRanking(LocalDate date, int page, int size) {
+        RankingPeriod period = RankingPeriod.ofMonth(date);
+        List<MvProductRankMonthly> monthlyRanks = mvProductRankMonthlyRepository
+                .findByPeriodOrderByRankingAsc(
+                        period.startDate(),
+                        period.endDate(),
+                        page,
+                        size
+                );
+
+        if (monthlyRanks.isEmpty()) {
+            return new ArrayList<>();
+        }
+
+        return monthlyRanks.stream()
+                .filter(rank -> rank.getRanking() != null)
+                .map(rank -> new Ranking(
+                        rank.getProductId(),
+                        rank.getRanking().longValue(),
+                        rank.getScore()
+                ))
+                .toList();
+    }
 }
 

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

@@ -0,0 +1,19 @@
+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 java.time.LocalDate;
+import java.util.List;
+
+public interface MvProductRankMonthlyJpaRepository extends JpaRepository<MvProductRankMonthly, Long> {
+
+    List<MvProductRankMonthly> findByPeriodStartDateAndPeriodEndDateOrderByRankingAsc(
+            LocalDate periodStartDate,
+            LocalDate periodEndDate,
+            Pageable pageable
+    );
+
+}
+

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

@@ -0,0 +1,25 @@
+package com.loopers.infrastructure.ranking;
+
+import com.loopers.domain.ranking.MvProductRankMonthly;
+import com.loopers.domain.ranking.MvProductRankMonthlyRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.stereotype.Repository;
+
+import java.time.LocalDate;
+import java.util.List;
+
+@Repository
+@RequiredArgsConstructor
+public class MvProductRankMonthlyRepositoryImpl implements MvProductRankMonthlyRepository {
+
+    private final MvProductRankMonthlyJpaRepository mvProductRankMonthlyJpaRepository;
+
+    @Override
+    public List<MvProductRankMonthly> findByPeriodOrderByRankingAsc(LocalDate periodStartDate, LocalDate periodEndDate, int page, int size) {
+        Pageable pageable = PageRequest.of(page - 1, size);
+        return mvProductRankMonthlyJpaRepository.findByPeriodStartDateAndPeriodEndDateOrderByRankingAsc(periodStartDate, periodEndDate, pageable);
+    }
+}
+

apps/commerce-api/src/main/java/com/loopers/infrastructure/ranking/MvProductRankWeeklyJpaRepository.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 java.time.LocalDate;
+import java.util.List;
+
+public interface MvProductRankWeeklyJpaRepository extends JpaRepository<MvProductRankWeekly, Long> {
+
+    List<MvProductRankWeekly> findByPeriodStartDateAndPeriodEndDateOrderByRankingAsc(
+            LocalDate periodStartDate,
+            LocalDate periodEndDate,
+            Pageable pageable
+    );
+}
+