[volume-10] Collect, Stack, Zip

README.md

@@ -27,6 +27,7 @@ docker-compose -f ./docker/monitoring-compose.yml up
 Root
 ├── apps ( spring-applications )
 │   ├── 📦 commerce-api
+│   ├── 📦 commerce-batch
 │   └── 📦 commerce-streamer
 ├── modules ( reusable-configurations )
 │   ├── 📦 jpa

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

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

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

@@ -0,0 +1,10 @@
+package com.loopers.application.ranking;
+
+import java.time.LocalDate;
+
+public record RankingQuery(
+        RankingPeriod period,
+        String key,
+        LocalDate date,
+        int limit
+) { }

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

@@ -1,10 +1,8 @@
 package com.loopers.application.ranking;
 
-import com.loopers.application.like.event.ProductLikeEvent;
 import com.loopers.application.product.ProductLikeSummary;
 import com.loopers.application.product.ProductQueryService;
-import com.loopers.domain.product.ProductSortType;
-import com.loopers.ranking.DailyRankingResponse;
+import com.loopers.application.ranking.strategy.RankingFetchStrategyResolver;
 import com.loopers.ranking.RankingEntry;
 import com.loopers.ranking.RankingZSetRepository;
 import com.loopers.support.error.CoreException;
@@ -16,8 +14,6 @@
 
 import java.time.LocalDate;
 import java.time.ZoneId;
-import java.time.ZoneOffset;
-import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.OptionalDouble;
@@ -29,17 +25,20 @@ public class RankingQueryService {
     private final RankingZSetRepository rankingZSetRepository;
     private final ProductQueryService productQueryService;
 
+    private final RankingFetchStrategyResolver rankingResolver;
+
     @Transactional(readOnly = true)
-    public RankingQueryResponse getDailyPopularProducts(String date, int size) {
-        LocalDate target = initLocalDate(date);
+    public RankingQueryResponse getDailyPopularProducts(RankingPeriod period, String date, int size) {
+        log.debug("Get {} popular products for {}", period, date);
 
-        int limit = (size <= 0) ? 20 : Math.min(size, 100);
+        RankingFetchStrategyResolver.Resolved resolved = rankingResolver.resolve(period, date, size);
+        RankingQuery rankingQuery = resolved.rankingQuery();
 
-        List<RankingEntry> rankingEntries = rankingZSetRepository.findTopDailyAllByLimit(target, limit);
+        List<RankingEntry> rankingEntries = resolved.policy().fetchRankingEntries(rankingQuery.key(), rankingQuery.limit());
         List<ProductLikeSummary> productLikeSummaries = findProductSummaryFrom(rankingEntries);
 
         return new RankingQueryResponse(
-                target,
+                rankingQuery.date(),
                 rankingEntries,
                 productLikeSummaries
         );
@@ -51,17 +50,6 @@ public OptionalDouble getDailyRankingScore(Long productId) {
         return rankingZSetRepository.findDailyRanking(now, productId);
     }
 
-    private boolean hasValidDate(String date) {
-        return date == null || date.isBlank();
-    }
-
-    private LocalDate initLocalDate(String date) {
-         return (hasValidDate(date))
-                ? LocalDate.now(ZoneId.systemDefault())
-                : LocalDate.parse(date, DateTimeFormatter.BASIC_ISO_DATE);
-
-    }
-
     private List<ProductLikeSummary> findProductSummaryFrom(List<RankingEntry> rankingEntries) {
         List<ProductLikeSummary> result = new ArrayList<>();
 

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

@@ -0,0 +1,39 @@
+package com.loopers.application.ranking.strategy;
+
+import com.loopers.application.ranking.RankingPeriod;
+import com.loopers.ranking.RankingEntry;
+import com.loopers.ranking.RankingZSetRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDate;
+import java.time.ZoneId;
+import java.time.format.DateTimeFormatter;
+import java.util.List;
+
+@Component
+@RequiredArgsConstructor
+public class DailyRankingFetcher implements RankingFetchStrategy {
+    private final RankingZSetRepository rankingZSetRepository;
+
+    @Override
+    public RankingPeriod getRankingPeriod() {
+        return RankingPeriod.DAILY;
+    }
+
+    @Override
+    public List<RankingEntry> fetchRankingEntries(String key, int limit) {
+        LocalDate target = initLocalDate(key);
+        return rankingZSetRepository.findTopDailyAllByLimit(target, limit);
+    }
+
+    private LocalDate initLocalDate(String date) {
+        return (hasValidDate(date))
+                ? LocalDate.now(ZoneId.systemDefault())
+                : LocalDate.parse(date, DateTimeFormatter.BASIC_ISO_DATE);
+    }
+
+    private boolean hasValidDate(String date) {
+        return date == null || date.isBlank();
+    }
+}

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

@@ -0,0 +1,29 @@
+package com.loopers.application.ranking.strategy;
+
+import com.loopers.application.ranking.RankingPeriod;
+import com.loopers.infrastructure.ranking.ProductRankMonthlyRepository;
+import com.loopers.ranking.RankingEntry;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class MonthlyRankingFetcher implements RankingFetchStrategy {
+    private final ProductRankMonthlyRepository monthlyRankingRepository;
+
+    @Override
+    public RankingPeriod getRankingPeriod() {
+        return RankingPeriod.MONTHLY;
+    }
+
+    @Override
+    public List<RankingEntry> fetchRankingEntries(String key, int limit) {
+        log.debug("Fetching ranking entries for key {}", key);
+        return monthlyRankingRepository.findTopByYearMonth(key, PageRequest.of(0, limit));
+    }
+}

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

@@ -0,0 +1,12 @@
+package com.loopers.application.ranking.strategy;
+
+import com.loopers.application.ranking.RankingPeriod;
+import com.loopers.ranking.RankingEntry;
+
+import java.util.List;
+
+
+public interface RankingFetchStrategy {
+    RankingPeriod getRankingPeriod();
+    List<RankingEntry> fetchRankingEntries(String key, int limit);
+}

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

@@ -0,0 +1,78 @@
+package com.loopers.application.ranking.strategy;
+
+import com.loopers.application.ranking.RankingPeriod;
+import com.loopers.application.ranking.RankingQuery;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDate;
+import java.time.ZoneId;
+import java.time.format.DateTimeFormatter;
+import java.time.temporal.WeekFields;
+import java.util.List;
+import java.util.Map;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+@Component
+public class RankingFetchStrategyResolver {
+    private static final DateTimeFormatter YYYYMMDD = DateTimeFormatter.BASIC_ISO_DATE;
+    private static final DateTimeFormatter YYYYMM = DateTimeFormatter.ofPattern("yyyyMM");
+    private final Map<RankingPeriod, RankingFetchStrategy> policies;
+
+    public RankingFetchStrategyResolver(List<RankingFetchStrategy> policies) {
+        this.policies = policies.stream()
+                .collect(Collectors.toMap(RankingFetchStrategy::getRankingPeriod, Function.identity()));
+    }
+
+    /**
+     * 랭킹 조회 방법을 선택합니다.
+     * @param period
+     * @param date
+     * @param size
+     * @return
+     */
+    public Resolved resolve(RankingPeriod period, String date, int size) {
+        LocalDate target = initLocalDate(date);
+        int limit = normalizeSize(size);
+
+        String key = switch (period) {
+            case DAILY -> target.format(YYYYMMDD);
+            case WEEKLY -> yearWeekKey(target);   // 2026-W01
+            case MONTHLY -> target.format(YYYYMM); // 202601
+        };
+
+        RankingFetchStrategy policy = policies.get(period);
+        if (policy == null) throw new IllegalArgumentException("Unsupported period: " + period);
+
+        return new Resolved(new RankingQuery(period, key, target, limit), policy);
+    }
+
+    public record Resolved(RankingQuery rankingQuery, RankingFetchStrategy policy) {}
+
+    /**
+     * 최대 상한선 TOP-100 으로 설정
+     * @param size
+     * @return
+     */
+    private int normalizeSize(int size) {
+        if (size <= 0) return 20;
+        return Math.min(size, 100);
+    }
+
+    private LocalDate initLocalDate(String date) {
+        return (hasValidDate(date))
+                ? LocalDate.now(ZoneId.systemDefault())
+                : LocalDate.parse(date, DateTimeFormatter.BASIC_ISO_DATE);
+    }
+
+    private String yearWeekKey(LocalDate date) {
+        WeekFields wf = WeekFields.ISO;
+        int y = date.get(wf.weekBasedYear());
+        int w = date.get(wf.weekOfWeekBasedYear());
+        return "%d-W%02d".formatted(y, w);
+    }
+
+    private boolean hasValidDate(String date) {
+        return date == null || date.isBlank();
+    }
+}

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

@@ -0,0 +1,29 @@
+package com.loopers.application.ranking.strategy;
+
+import com.loopers.application.ranking.RankingPeriod;
+import com.loopers.infrastructure.ranking.ProductRankWeeklyRepository;
+import com.loopers.ranking.RankingEntry;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class WeeklyRankingFetcher implements RankingFetchStrategy {
+    private final ProductRankWeeklyRepository weeklyRankingRepository;
+
+    @Override
+    public RankingPeriod getRankingPeriod() {
+        return RankingPeriod.WEEKLY;
+    }
+
+    @Override
+    public List<RankingEntry> fetchRankingEntries(String key, int limit) {
+        log.debug("Fetching ranking entries for key {}", key);
+        return weeklyRankingRepository.findTopByYearWeek(key, PageRequest.of(0, limit));
+    }
+}

apps/commerce-api/src/main/java/com/loopers/domain/mv/ProductRankMonthly.java

@@ -0,0 +1,65 @@
+package com.loopers.domain.mv;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.EmbeddedId;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Table;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDateTime;
+
+@Entity
+@Table(name = "mv_product_rank_monthly")
+@Getter
+@NoArgsConstructor
+public class ProductRankMonthly {
+
+    @EmbeddedId
+    private ProductRankMonthlyId id;
+
+    @Column(name = "view_count", nullable = false)
+    private long viewCount;
+
+    @Column(name = "like_count", nullable = false)
+    private long likeCount;
+
+    @Column(name = "order_count", nullable = false)
+    private long orderCount;
+
+    @Column(name = "score", nullable = false)
+    private double score;
+
+    @Column(name = "created_at", nullable = false)
+    private LocalDateTime createdAt;
+
+    @Column(name = "updated_at", nullable = false)
+    private LocalDateTime updatedAt;
+
+    public static ProductRankMonthly of(String yearMonth, Long productId,
+                                        long viewCount, long likeCount, long orderCount) {
+        ProductRankMonthly e = new ProductRankMonthly();
+        e.id = new ProductRankMonthlyId(yearMonth, productId);
+        e.viewCount = viewCount;
+        e.likeCount = likeCount;
+        e.orderCount = orderCount;
+        e.createdAt = LocalDateTime.now();
+        e.updatedAt = LocalDateTime.now();
+        return e;
+    }
+
+    public void overwrite(long viewCount, long likeCount, long orderCount) {
+        this.viewCount = viewCount;
+        this.likeCount = likeCount;
+        this.orderCount = orderCount;
+        this.updatedAt = LocalDateTime.now();
+    }
+
+    public Long productId() {
+        return id.getProductId();
+    }
+
+    public String yearMonth() {
+        return id.getYearMonth();
+    }
+}

apps/commerce-api/src/main/java/com/loopers/domain/mv/ProductRankMonthlyId.java

@@ -0,0 +1,21 @@
+package com.loopers.domain.mv;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Embeddable;
+import lombok.*;
+
+import java.io.Serializable;
+
+@Embeddable
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+@EqualsAndHashCode
+public class ProductRankMonthlyId implements Serializable {
+
+    @Column(name = "year_month_key", length = 8, nullable = false)
+    private String yearMonth; // e.g. 202601
+
+    @Column(name = "product_id", nullable = false)
+    private Long productId;
+}