Round 10

application/commerce-service/src/main/java/com/loopers/application/service/RankingService.java

@@ -30,6 +30,7 @@ public List<RankingInfo> getRankings(String date, int page, int size) {
         return getRankings(date, page, size, RankingType.DAILY);
     }
 
+    @Transactional(readOnly = true)
     public List<RankingInfo> getRankings(String date, int page, int size, RankingType type) {
         long offset = (long) (page - 1) * size;
         List<RankedProduct> rankedProducts = productRankingRepository.getTopProducts(date, offset, size, type);

domain/src/main/java/com/loopers/domain/ranking/DailyMetricSnapshot.java

@@ -0,0 +1,11 @@
+package com.loopers.domain.ranking;
+
+import java.time.LocalDate;
+
+public record DailyMetricSnapshot(
+        LocalDate date,
+        long viewCount,
+        long likesCount,
+        long salesCount
+) {
+}

domain/src/main/java/com/loopers/domain/ranking/RankingDateKey.java

@@ -27,4 +27,11 @@ public static String ofHour(LocalDateTime dateTime) {
     public static String currentHour() {
         return ofHour(LocalDateTime.now());
     }
+
+    public static String defaultKey(RankingType type) {
+        return switch (type) {
+            case DAILY, WEEKLY, MONTHLY -> today();
+            case HOURLY -> currentHour();
+        };
+    }
 }

domain/src/main/java/com/loopers/domain/ranking/RankingScore.java

@@ -1,10 +1,15 @@
 package com.loopers.domain.ranking;
 
+import java.time.LocalDate;
+import java.time.temporal.ChronoUnit;
+import java.util.List;
+
 public final class RankingScore {
 
     private static final double VIEW_WEIGHT = 1.0;
     private static final double LIKE_WEIGHT = 3.0;
     private static final double SALE_WEIGHT = 10.0;
+    private static final double DECAY_RATE = 0.85;
 
     private RankingScore() {
     }
@@ -30,4 +35,14 @@ public static double calculateDaily(long viewCount, long likesCount, long salesC
                 + LIKE_WEIGHT * Math.log10(likesCount + 1)
                 + SALE_WEIGHT * Math.log10(salesCount + 1);
     }
+
+    public static double calculateWithDecay(List<DailyMetricSnapshot> snapshots, LocalDate baseDate) {
+        double total = 0.0;
+        for (DailyMetricSnapshot snapshot : snapshots) {
+            long daysAgo = ChronoUnit.DAYS.between(snapshot.date(), baseDate);
+            double dailyScore = calculateDaily(snapshot.viewCount(), snapshot.likesCount(), snapshot.salesCount());
+            total += dailyScore * Math.pow(DECAY_RATE, daysAgo);
+        }
+        return total;
+    }
 }

domain/src/main/java/com/loopers/domain/ranking/RankingType.java

@@ -3,7 +3,9 @@
 public enum RankingType {
 
     DAILY("ranking:daily:", 2 * 24 * 60 * 60),
-    HOURLY("ranking:hourly:", 24 * 60 * 60);
+    HOURLY("ranking:hourly:", 24 * 60 * 60),
+    WEEKLY("ranking:weekly:", 8 * 24 * 60 * 60),
+    MONTHLY("ranking:monthly:", 32 * 24 * 60 * 60);
 
     private final String keyPrefix;
     private final long ttlSeconds;

domain/src/test/java/com/loopers/domain/ranking/RankingScoreTest.java

@@ -2,6 +2,9 @@
 
 import org.junit.jupiter.api.Test;
 
+import java.time.LocalDate;
+import java.util.List;
+
 import static org.assertj.core.api.Assertions.assertThat;
 
 class RankingScoreTest {
@@ -65,4 +68,48 @@ class RankingScoreTest {
         // then
         assertThat(salesOnly).isGreaterThan(viewsOnly);
     }
+
+    @Test
+    void 주간_점수는_최근_날짜에_높은_가중치를_적용한다() {
+        // given
+        LocalDate today = LocalDate.of(2026, 4, 16);
+        var recentDay = new DailyMetricSnapshot(today.minusDays(1), 100, 10, 5);
+        var oldDay = new DailyMetricSnapshot(today.minusDays(7), 100, 10, 5);
+
+        // when
+        double recentScore = RankingScore.calculateWithDecay(List.of(recentDay), today);
+        double oldScore = RankingScore.calculateWithDecay(List.of(oldDay), today);
+
+        // then
+        assertThat(recentScore).isGreaterThan(oldScore);
+    }
+
+    @Test
+    void 주간_점수는_여러_날의_감쇠_점수를_합산한다() {
+        // given
+        LocalDate today = LocalDate.of(2026, 4, 16);
+        var day1 = new DailyMetricSnapshot(today.minusDays(1), 100, 10, 5);
+        var day2 = new DailyMetricSnapshot(today.minusDays(2), 200, 20, 10);
+
+        double score1 = RankingScore.calculateWithDecay(List.of(day1), today);
+        double score2 = RankingScore.calculateWithDecay(List.of(day2), today);
+
+        // when
+        double combined = RankingScore.calculateWithDecay(List.of(day1, day2), today);
+
+        // then
+        assertThat(combined).isEqualTo(score1 + score2);
+    }
+
+    @Test
+    void 빈_스냅샷이면_점수는_0이다() {
+        // given
+        LocalDate today = LocalDate.of(2026, 4, 16);
+
+        // when
+        double score = RankingScore.calculateWithDecay(List.of(), today);
+
+        // then
+        assertThat(score).isEqualTo(0.0);
+    }
 }

infrastructure/jpa/src/main/java/com/loopers/infrastructure/metrics/ProductMetricsDailyRepository.java

@@ -11,4 +11,6 @@ public interface ProductMetricsDailyRepository extends JpaRepository<ProductMetr
     Optional<ProductMetricsDaily> findByProductIdAndDate(Long productId, LocalDate date);
 
     List<ProductMetricsDaily> findByDate(LocalDate date);
+
+    List<ProductMetricsDaily> findByDateBetween(LocalDate startDate, LocalDate endDate);
 }

infrastructure/jpa/src/main/java/com/loopers/infrastructure/ranking/MvProductRankMonthly.java

@@ -0,0 +1,51 @@
+package com.loopers.infrastructure.ranking;
+
+import com.loopers.domain.BaseTimeEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Index;
+import jakarta.persistence.Table;
+import jakarta.persistence.UniqueConstraint;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDate;
+
+@Entity
+@Table(name = "mv_product_rank_monthly",
+        uniqueConstraints = @UniqueConstraint(columnNames = {"productId", "calculatedDate"}),
+        indexes = @Index(name = "idx_monthly_calculated_date", columnList = "calculatedDate"))
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class MvProductRankMonthly extends BaseTimeEntity {
+
+    @Column(nullable = false)
+    private Long productId;
+
+    @Column(nullable = false)
+    private long viewCount;
+
+    @Column(nullable = false)
+    private long likesCount;
+
+    @Column(nullable = false)
+    private long salesCount;
+
+    @Column(nullable = false)
+    private LocalDate calculatedDate;
+
+    private MvProductRankMonthly(Long productId, long viewCount, long likesCount,
+                                  long salesCount, LocalDate calculatedDate) {
+        this.productId = productId;
+        this.viewCount = viewCount;
+        this.likesCount = likesCount;
+        this.salesCount = salesCount;
+        this.calculatedDate = calculatedDate;
+    }
+
+    public static MvProductRankMonthly of(Long productId, long viewCount, long likesCount,
+                                            long salesCount, LocalDate calculatedDate) {
+        return new MvProductRankMonthly(productId, viewCount, likesCount, salesCount, calculatedDate);
+    }
+}

infrastructure/jpa/src/main/java/com/loopers/infrastructure/ranking/MvProductRankMonthlyRepository.java

@@ -0,0 +1,17 @@
+package com.loopers.infrastructure.ranking;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+
+import java.time.LocalDate;
+import java.util.List;
+
+public interface MvProductRankMonthlyRepository extends JpaRepository<MvProductRankMonthly, Long> {
+
+    List<MvProductRankMonthly> findByCalculatedDate(LocalDate calculatedDate);
+
+    @Modifying
+    @Query("DELETE FROM MvProductRankMonthly m WHERE m.calculatedDate = :calculatedDate")
+    void deleteByCalculatedDate(LocalDate calculatedDate);
+}

infrastructure/jpa/src/main/java/com/loopers/infrastructure/ranking/MvProductRankWeekly.java

@@ -0,0 +1,51 @@
+package com.loopers.infrastructure.ranking;
+
+import com.loopers.domain.BaseTimeEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Index;
+import jakarta.persistence.Table;
+import jakarta.persistence.UniqueConstraint;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDate;
+
+@Entity
+@Table(name = "mv_product_rank_weekly",
+        uniqueConstraints = @UniqueConstraint(columnNames = {"productId", "calculatedDate"}),
+        indexes = @Index(name = "idx_weekly_calculated_date", columnList = "calculatedDate"))
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class MvProductRankWeekly extends BaseTimeEntity {
+
+    @Column(nullable = false)
+    private Long productId;
+
+    @Column(nullable = false)
+    private long viewCount;
+
+    @Column(nullable = false)
+    private long likesCount;
+
+    @Column(nullable = false)
+    private long salesCount;
+
+    @Column(nullable = false)
+    private LocalDate calculatedDate;
+
+    private MvProductRankWeekly(Long productId, long viewCount, long likesCount,
+                                long salesCount, LocalDate calculatedDate) {
+        this.productId = productId;
+        this.viewCount = viewCount;
+        this.likesCount = likesCount;
+        this.salesCount = salesCount;
+        this.calculatedDate = calculatedDate;
+    }
+
+    public static MvProductRankWeekly of(Long productId, long viewCount, long likesCount,
+                                          long salesCount, LocalDate calculatedDate) {
+        return new MvProductRankWeekly(productId, viewCount, likesCount, salesCount, calculatedDate);
+    }
+}

infrastructure/jpa/src/main/java/com/loopers/infrastructure/ranking/MvProductRankWeeklyRepository.java

@@ -0,0 +1,17 @@
+package com.loopers.infrastructure.ranking;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+
+import java.time.LocalDate;
+import java.util.List;
+
+public interface MvProductRankWeeklyRepository extends JpaRepository<MvProductRankWeekly, Long> {
+
+    List<MvProductRankWeekly> findByCalculatedDate(LocalDate calculatedDate);
+
+    @Modifying
+    @Query("DELETE FROM MvProductRankWeekly m WHERE m.calculatedDate = :calculatedDate")
+    void deleteByCalculatedDate(LocalDate calculatedDate);
+}

infrastructure/jpa/src/testFixtures/resources/docker-java.properties

@@ -0,0 +1 @@
+api.version=1.44

infrastructure/redis/src/testFixtures/resources/docker-java.properties

@@ -0,0 +1 @@
+api.version=1.44

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

@@ -26,16 +26,11 @@ public List<RankingApiResponse> getRankings(
             @RequestParam(defaultValue = "1") int page,
             @RequestParam(defaultValue = "DAILY") RankingType type
     ) {
-        String targetDate = date != null ? date : defaultDateKey(type);
-        return rankingService.getRankings(targetDate, page, size, type).stream()
+        if (date == null) {
+            date = RankingDateKey.defaultKey(type);
+        }
+        return rankingService.getRankings(date, page, size, type).stream()
                 .map(RankingApiResponse::from)
                 .toList();
     }
-
-    private String defaultDateKey(RankingType type) {
-        return switch (type) {
-            case DAILY -> RankingDateKey.today();
-            case HOURLY -> RankingDateKey.currentHour();
-        };
-    }
 }