[volume-10] Batch 기반 주간·월간 랭킹 시스템 구현

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

@@ -4,8 +4,13 @@
 import com.loopers.application.ranking.dto.FindRankingListResDto;
 import com.loopers.domain.product.model.Product;
 import com.loopers.domain.product.service.ProductService;
-import com.loopers.domain.ranking.repository.RankingRepository;
+import com.loopers.domain.ranking.model.RankingEntry;
+import com.loopers.domain.ranking.model.RankingQuery;
+import com.loopers.domain.ranking.model.RankingSlice;
+import com.loopers.domain.ranking.model.RankingPeriod;
+import com.loopers.domain.ranking.service.MonthlyRankingService;
 import com.loopers.domain.ranking.service.RankingService;
+import com.loopers.domain.ranking.service.WeeklyRankingService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
@@ -20,28 +25,36 @@
 @Transactional(readOnly = true)
 public class RankingFacade {
 
-    private final RankingService rankingService;
+    private final RankingService dailyRankingService;
+    private final WeeklyRankingService weeklyRankingService;
+    private final MonthlyRankingService monthlyRankingService;
     private final ProductService productService;
 
-    public FindRankingListResDto getRankings(String date, int page, int size) {
-        List<RankingRepository.RankingEntry> entries = rankingService.getTopRankings(date, page, size);
-        long totalCount = rankingService.getTotalCount(date);
-
-        if (entries.isEmpty()) {
-            return new FindRankingListResDto(List.of(), totalCount, page, size);
+    public FindRankingListResDto getRankings(RankingQuery query) {
+        RankingSlice slice = switch (query.period()) {
+            case DAILY -> new RankingSlice(
+                    dailyRankingService.getTopRankings(query.date(), query.page(), query.size()),
+                    dailyRankingService.getTotalCount(query.date())
+            );
+            case WEEKLY -> weeklyRankingService.getRankings(query.date(), query.page(), query.size());
+            case MONTHLY -> monthlyRankingService.getRankings(query.date(), query.page(), query.size());
+        };
+
+        if (slice.entries().isEmpty()) {
+            return new FindRankingListResDto(List.of(), slice.totalCount(), query.page(), query.size());
         }
 
-        List<Long> productIds = entries.stream()
-                .map(RankingRepository.RankingEntry::productId)
+        List<Long> productIds = slice.entries().stream()
+                .map(RankingEntry::productId)
                 .toList();
-        Map<Long, Product> productMap = productService.getProductsByIds(productIds).stream()
+        Map<Long, Product> productMap = productService.findAllByIds(productIds).stream()
                 .collect(Collectors.toMap(Product::getId, Function.identity()));
 
-        List<FindRankingItemResDto> items = entries.stream()
+        List<FindRankingItemResDto> items = slice.entries().stream()
                 .filter(entry -> productMap.containsKey(entry.productId()))
                 .map(entry -> FindRankingItemResDto.from(entry, productMap.get(entry.productId())))
                 .toList();
 
-        return new FindRankingListResDto(items, totalCount, page, size);
+        return new FindRankingListResDto(items, slice.totalCount(), query.page(), query.size());
     }
 }

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

@@ -1,7 +1,7 @@
 package com.loopers.application.ranking.dto;
 
 import com.loopers.domain.product.model.Product;
-import com.loopers.domain.ranking.repository.RankingRepository;
+import com.loopers.domain.ranking.model.RankingEntry;
 
 public record FindRankingItemResDto(
         long rank,
@@ -10,7 +10,7 @@ public record FindRankingItemResDto(
         String productName,
         int price
 ) {
-    public static FindRankingItemResDto from(RankingRepository.RankingEntry entry, Product product) {
+    public static FindRankingItemResDto from(RankingEntry entry, Product product) {
         return new FindRankingItemResDto(
                 entry.rank(),
                 entry.score(),

apps/commerce-api/src/main/java/com/loopers/domain/product/service/ProductService.java

@@ -158,6 +158,13 @@ public List<Product> getProductsByIds(List<Long> productIds) {
         return products;
     }
 
+    public List<Product> findAllByIds(List<Long> productIds) {
+        if (productIds == null || productIds.isEmpty()) {
+            return List.of();
+        }
+        return productRepository.findByIds(productIds);
+    }
+
     private boolean isFirstPageLatest(Long brandId, SortFilter sortFilter, Pageable pageable) {
         return brandId == null && sortFilter == SortFilter.LATEST && pageable.getPageNumber() == 0;
     }

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

@@ -0,0 +1,8 @@
+package com.loopers.domain.ranking.model;
+
+public record RankingEntry(
+        Long productId,
+        double score,
+        long rank
+) {
+}

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

@@ -0,0 +1,23 @@
+package com.loopers.domain.ranking.model;
+
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
+
+import java.util.Locale;
+
+public enum RankingPeriod {
+    DAILY,
+    WEEKLY,
+    MONTHLY;
+
+    public static RankingPeriod from(String value) {
+        if (value == null || value.isBlank()) {
+            return DAILY;
+        }
+        try {
+            return RankingPeriod.valueOf(value.toUpperCase(Locale.ROOT));
+        } catch (IllegalArgumentException e) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "지원하지 않는 랭킹 기간입니다.");
+        }
+    }
+}

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

@@ -0,0 +1,35 @@
+package com.loopers.domain.ranking.model;
+
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
+
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.time.format.DateTimeParseException;
+
+public record RankingQuery(
+        RankingPeriod period,
+        LocalDate date,
+        int page,
+        int size
+) {
+    private static final DateTimeFormatter DATE_FORMAT = DateTimeFormatter.BASIC_ISO_DATE;
+
+    public static RankingQuery of(String period, String date, int page, int size) {
+        validate(page, size);
+        try {
+            return new RankingQuery(RankingPeriod.from(period), LocalDate.parse(date, DATE_FORMAT), page, size);
+        } catch (DateTimeParseException e) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "날짜 형식이 올바르지 않습니다. (yyyyMMdd)");
+        }
+    }
+
+    private static void validate(int page, int size) {
+        if (page < 1) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "페이지 번호는 1 이상이어야 합니다.");
+        }
+        if (size < 1 || size > 100) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "페이지 크기는 1 이상 100 이하여야 합니다.");
+        }
+    }
+}

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

@@ -0,0 +1,9 @@
+package com.loopers.domain.ranking.model;
+
+import java.util.List;
+
+public record RankingSlice(
+        List<RankingEntry> entries,
+        long totalCount
+) {
+}

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

@@ -0,0 +1,10 @@
+package com.loopers.domain.ranking.repository;
+
+import com.loopers.domain.ranking.model.RankingEntry;
+
+import java.util.List;
+
+public interface MonthlyRankingRepository {
+    List<RankingEntry> getTopRankings(String periodKey, int offset, int size);
+    long getTotalCount(String periodKey);
+}

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

@@ -0,0 +1,10 @@
+package com.loopers.domain.ranking.repository;
+
+import com.loopers.domain.ranking.model.RankingEntry;
+
+import java.util.List;
+
+public interface WeeklyRankingRepository {
+    List<RankingEntry> getTopRankings(String periodKey, int offset, int size);
+    long getTotalCount(String periodKey);
+}

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

@@ -0,0 +1,25 @@
+package com.loopers.domain.ranking.service;
+
+import com.loopers.domain.ranking.model.RankingSlice;
+import com.loopers.domain.ranking.repository.MonthlyRankingRepository;
+import com.loopers.support.util.RankingPeriodKeyFactory;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDate;
+
+@RequiredArgsConstructor
+@Component
+public class MonthlyRankingService {
+
+    private final MonthlyRankingRepository repository;
+
+    public RankingSlice getRankings(LocalDate date, int page, int size) {
+        int offset = (page - 1) * size;
+        String periodKey = RankingPeriodKeyFactory.toMonthlyKey(date);
+        return new RankingSlice(
+                repository.getTopRankings(periodKey, offset, size),
+                repository.getTotalCount(periodKey)
+        );
+    }
+}

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

@@ -1,9 +1,12 @@
 package com.loopers.domain.ranking.service;
 
+import com.loopers.domain.ranking.model.RankingEntry;
 import com.loopers.domain.ranking.repository.RankingRepository;
+import com.loopers.support.util.RankingPeriodKeyFactory;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Component;
 
+import java.time.LocalDate;
 import java.util.List;
 
 @RequiredArgsConstructor
@@ -12,13 +15,15 @@ public class RankingService {
 
     private final RankingRepository rankingRepository;
 
-    public List<RankingRepository.RankingEntry> getTopRankings(String date, int page, int size) {
+    public List<RankingEntry> getTopRankings(LocalDate date, int page, int size) {
         int offset = (page - 1) * size;
-        return rankingRepository.getTopRankings(date, offset, size);
+        return rankingRepository.getTopRankings(RankingPeriodKeyFactory.toDailyKey(date), offset, size).stream()
+                .map(entry -> new RankingEntry(entry.productId(), entry.score(), entry.rank()))
+                .toList();
     }
 
-    public long getTotalCount(String date) {
-        return rankingRepository.getTotalCount(date);
+    public long getTotalCount(LocalDate date) {
+        return rankingRepository.getTotalCount(RankingPeriodKeyFactory.toDailyKey(date));
     }
 
     public RankingRepository.RankingEntry getProductRanking(String date, Long productId) {

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

@@ -0,0 +1,25 @@
+package com.loopers.domain.ranking.service;
+
+import com.loopers.domain.ranking.model.RankingSlice;
+import com.loopers.domain.ranking.repository.WeeklyRankingRepository;
+import com.loopers.support.util.RankingPeriodKeyFactory;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDate;
+
+@RequiredArgsConstructor
+@Component
+public class WeeklyRankingService {
+
+    private final WeeklyRankingRepository repository;
+
+    public RankingSlice getRankings(LocalDate date, int page, int size) {
+        int offset = (page - 1) * size;
+        String periodKey = RankingPeriodKeyFactory.toWeeklyKey(date);
+        return new RankingSlice(
+                repository.getTopRankings(periodKey, offset, size),
+                repository.getTotalCount(periodKey)
+        );
+    }
+}

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

@@ -0,0 +1,50 @@
+package com.loopers.infrastructure.ranking.entity;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Id;
+import jakarta.persistence.IdClass;
+import jakarta.persistence.Table;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@Entity
+@Table(name = "mv_product_rank_monthly")
+@IdClass(MonthlyRankingEntity.MonthlyRankingId.class)
+public class MonthlyRankingEntity {
+
+    @Id
+    @Column(nullable = false, length = 16)
+    private String periodKey;
+
+    @Id
+    @Column(nullable = false)
+    private int rankNo;
+
+    @Column(nullable = false)
+    private Long productId;
+
+    @Column(nullable = false)
+    private double score;
+
+    @Column(nullable = false)
+    private long viewCount;
+
+    @Column(nullable = false)
+    private long likeCount;
+
+    @Column(nullable = false)
+    private long orderCount;
+
+    @Column(nullable = false)
+    private LocalDateTime updatedAt;
+
+    public record MonthlyRankingId(String periodKey, int rankNo) implements Serializable {
+    }
+}

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

@@ -0,0 +1,50 @@
+package com.loopers.infrastructure.ranking.entity;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Id;
+import jakarta.persistence.IdClass;
+import jakarta.persistence.Table;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@Entity
+@Table(name = "mv_product_rank_weekly")
+@IdClass(WeeklyRankingEntity.WeeklyRankingId.class)
+public class WeeklyRankingEntity {
+
+    @Id
+    @Column(nullable = false, length = 16)
+    private String periodKey;
+
+    @Id
+    @Column(nullable = false)
+    private int rankNo;
+
+    @Column(nullable = false)
+    private Long productId;
+
+    @Column(nullable = false)
+    private double score;
+
+    @Column(nullable = false)
+    private long viewCount;
+
+    @Column(nullable = false)
+    private long likeCount;
+
+    @Column(nullable = false)
+    private long orderCount;
+
+    @Column(nullable = false)
+    private LocalDateTime updatedAt;
+
+    public record WeeklyRankingId(String periodKey, int rankNo) implements Serializable {
+    }
+}

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

@@ -0,0 +1,12 @@
+package com.loopers.infrastructure.ranking.repository;
+
+import com.loopers.infrastructure.ranking.entity.MonthlyRankingEntity;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.List;
+
+public interface MonthlyRankingJpaRepository extends JpaRepository<MonthlyRankingEntity, MonthlyRankingEntity.MonthlyRankingId> {
+    List<MonthlyRankingEntity> findByPeriodKeyOrderByRankNoAsc(String periodKey, Pageable pageable);
+    long countByPeriodKey(String periodKey);
+}