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

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

@@ -23,8 +23,12 @@ public class RankingFacade {
     private final ProductService productService;
     private final BrandService brandService;
 
-    public List<RankingInfo> getRankings(LocalDate date, int size, int page) {
-        List<RankedProduct> rankedProducts = rankingRepository.getTopN(date, size, page);
+    public List<RankingInfo> getRankings(LocalDate date, String period, int size, int page) {
+        List<RankedProduct> rankedProducts = switch (period) {
+            case "weekly" -> rankingRepository.getWeeklyTopN(date, size, page);
+            case "monthly" -> rankingRepository.getMonthlyTopN(date, size, page);
+            default -> rankingRepository.getTopN(date, size, page);
+        };
         if (rankedProducts.isEmpty()) {
             return List.of();
         }

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

@@ -5,6 +5,8 @@
 
 public interface RankingRepository {
     List<RankedProduct> getTopN(LocalDate date, int size, int page);
+    List<RankedProduct> getWeeklyTopN(LocalDate date, int size, int page);
+    List<RankedProduct> getMonthlyTopN(LocalDate date, int size, int page);
     Long getRank(Long productId, LocalDate date);
     void carryOver(LocalDate from, LocalDate to, double ratio);
 }

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

@@ -0,0 +1,81 @@
+package com.loopers.infrastructure.ranking;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Id;
+import jakarta.persistence.PrePersist;
+import jakarta.persistence.PreUpdate;
+import jakarta.persistence.Table;
+import java.time.LocalDateTime;
+import lombok.NoArgsConstructor;
+import org.hibernate.annotations.Comment;
+
+@Entity
+@Table(name = "mv_product_rank_monthly")
+@NoArgsConstructor
+public class MvProductRankMonthlyEntity {
+
+    @Id
+    @Comment("상품 id (ref)")
+    @Column(name = "product_id", nullable = false, updatable = false)
+    private Long productId;
+
+    @Comment("집계 점수")
+    @Column(name = "score", nullable = false)
+    private double score;
+
+    @Comment("집계 기준 월 (e.g. 202604)")
+    @Column(name = "year_month", nullable = false, length = 6)
+    private String yearMonth;
+
+    @Comment("랭킹 순위")
+    @Column(name = "product_rank", nullable = false)
+    private int productRank;
+
+    @Column(name = "created_at", nullable = false, updatable = false)
+    private LocalDateTime createdAt;
+
+    @Column(name = "updated_at", nullable = false)
+    private LocalDateTime updatedAt;
+
+    public MvProductRankMonthlyEntity(Long productId, double score, String yearMonth, int productRank) {
+        this.productId = productId;
+        this.score = score;
+        this.yearMonth = yearMonth;
+        this.productRank = productRank;
+    }
+
+    public void update(double score, String yearMonth, int productRank) {
+        this.score = score;
+        this.yearMonth = yearMonth;
+        this.productRank = productRank;
+    }
+
+    @PrePersist
+    private void prePersist() {
+        LocalDateTime now = LocalDateTime.now();
+        this.createdAt = now;
+        this.updatedAt = now;
+    }
+
+    @PreUpdate
+    private void preUpdate() {
+        this.updatedAt = LocalDateTime.now();
+    }
+
+    public Long getProductId() {
+        return productId;
+    }
+
+    public double getScore() {
+        return score;
+    }
+
+    public String getYearMonth() {
+        return yearMonth;
+    }
+
+    public int getProductRank() {
+        return productRank;
+    }
+}

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

@@ -0,0 +1,10 @@
+package com.loopers.infrastructure.ranking;
+
+import java.util.List;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface MvProductRankMonthlyJpaRepository extends JpaRepository<MvProductRankMonthlyEntity, Long> {
+
+    List<MvProductRankMonthlyEntity> findAllByYearMonthOrderByProductRankAsc(String yearMonth, Pageable pageable);
+}

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

@@ -0,0 +1,81 @@
+package com.loopers.infrastructure.ranking;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Id;
+import jakarta.persistence.PrePersist;
+import jakarta.persistence.PreUpdate;
+import jakarta.persistence.Table;
+import java.time.LocalDateTime;
+import lombok.NoArgsConstructor;
+import org.hibernate.annotations.Comment;
+
+@Entity
+@Table(name = "mv_product_rank_weekly")
+@NoArgsConstructor
+public class MvProductRankWeeklyEntity {
+
+    @Id
+    @Comment("상품 id (ref)")
+    @Column(name = "product_id", nullable = false, updatable = false)
+    private Long productId;
+
+    @Comment("집계 점수")
+    @Column(name = "score", nullable = false)
+    private double score;
+
+    @Comment("집계 기준 주 (해당 주 월요일, e.g. 20260414)")
+    @Column(name = "year_week", nullable = false, length = 8)
+    private String yearWeek;
+
+    @Comment("랭킹 순위")
+    @Column(name = "product_rank", nullable = false)
+    private int productRank;
+
+    @Column(name = "created_at", nullable = false, updatable = false)
+    private LocalDateTime createdAt;
+
+    @Column(name = "updated_at", nullable = false)
+    private LocalDateTime updatedAt;
+
+    public MvProductRankWeeklyEntity(Long productId, double score, String yearWeek, int productRank) {
+        this.productId = productId;
+        this.score = score;
+        this.yearWeek = yearWeek;
+        this.productRank = productRank;
+    }
+
+    public void update(double score, String yearWeek, int productRank) {
+        this.score = score;
+        this.yearWeek = yearWeek;
+        this.productRank = productRank;
+    }
+
+    @PrePersist
+    private void prePersist() {
+        LocalDateTime now = LocalDateTime.now();
+        this.createdAt = now;
+        this.updatedAt = now;
+    }
+
+    @PreUpdate
+    private void preUpdate() {
+        this.updatedAt = LocalDateTime.now();
+    }
+
+    public Long getProductId() {
+        return productId;
+    }
+
+    public double getScore() {
+        return score;
+    }
+
+    public String getYearWeek() {
+        return yearWeek;
+    }
+
+    public int getProductRank() {
+        return productRank;
+    }
+}

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

@@ -0,0 +1,10 @@
+package com.loopers.infrastructure.ranking;
+
+import java.util.List;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface MvProductRankWeeklyJpaRepository extends JpaRepository<MvProductRankWeeklyEntity, Long> {
+
+    List<MvProductRankWeeklyEntity> findAllByYearWeekOrderByProductRankAsc(String yearWeek, Pageable pageable);
+}

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

@@ -3,13 +3,15 @@
 import com.loopers.config.redis.RedisConfig;
 import com.loopers.domain.ranking.RankedProduct;
 import com.loopers.domain.ranking.RankingRepository;
+import java.time.DayOfWeek;
 import java.time.LocalDate;
 import java.time.format.DateTimeFormatter;
 import java.util.Collections;
 import java.util.List;
 import java.util.Set;
 import java.util.concurrent.TimeUnit;
 import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.data.domain.PageRequest;
 import org.springframework.data.redis.connection.zset.Aggregate;
 import org.springframework.data.redis.connection.zset.Weights;
 import org.springframework.data.redis.core.RedisTemplate;
@@ -25,13 +27,19 @@ public class RankingRepositoryImpl implements RankingRepository {
 
     private final RedisTemplate<String, String> redisTemplate;
     private final RedisTemplate<String, String> masterRedisTemplate;
+    private final MvProductRankWeeklyJpaRepository weeklyRepository;
+    private final MvProductRankMonthlyJpaRepository monthlyRepository;
 
     public RankingRepositoryImpl(
             RedisTemplate<String, String> redisTemplate,
-            @Qualifier(RedisConfig.REDIS_TEMPLATE_MASTER) RedisTemplate<String, String> masterRedisTemplate
+            @Qualifier(RedisConfig.REDIS_TEMPLATE_MASTER) RedisTemplate<String, String> masterRedisTemplate,
+            MvProductRankWeeklyJpaRepository weeklyRepository,
+            MvProductRankMonthlyJpaRepository monthlyRepository
     ) {
         this.redisTemplate = redisTemplate;
         this.masterRedisTemplate = masterRedisTemplate;
+        this.weeklyRepository = weeklyRepository;
+        this.monthlyRepository = monthlyRepository;
     }
 
     @Override
@@ -48,6 +56,24 @@ public List<RankedProduct> getTopN(LocalDate date, int size, int page) {
             .toList();
     }
 
+    @Override
+    public List<RankedProduct> getWeeklyTopN(LocalDate date, int size, int page) {
+        String yearWeek = date.with(DayOfWeek.MONDAY).format(DateTimeFormatter.BASIC_ISO_DATE);
+        return weeklyRepository.findAllByYearWeekOrderByProductRankAsc(yearWeek, PageRequest.of(page, size))
+                .stream()
+                .map(e -> new RankedProduct(e.getProductId(), e.getScore()))
+                .toList();
+    }
+
+    @Override
+    public List<RankedProduct> getMonthlyTopN(LocalDate date, int size, int page) {
+        String yearMonth = date.format(DateTimeFormatter.ofPattern("yyyyMM"));
+        return monthlyRepository.findAllByYearMonthOrderByProductRankAsc(yearMonth, PageRequest.of(page, size))
+                .stream()
+                .map(e -> new RankedProduct(e.getProductId(), e.getScore()))
+                .toList();
+    }
+
     @Override
     public Long getRank(Long productId, LocalDate date) {
         String key = KEY_PREFIX + date.format(DATE_FORMATTER);

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

@@ -24,11 +24,12 @@ public class RankingV1Controller {
     @GetMapping
     public ApiResponse<List<RankingV1Dto.RankingResponse>> getRankings(
         @RequestParam String date,
+        @RequestParam(defaultValue = "daily") String period,
         @RequestParam(defaultValue = "0") int page,
         @RequestParam(defaultValue = "20") int size
     ) {
         LocalDate localDate = LocalDate.parse(date, DATE_FORMATTER);
-        List<RankingInfo> rankings = rankingFacade.getRankings(localDate, size, page);
+        List<RankingInfo> rankings = rankingFacade.getRankings(localDate, period, size, page);
         List<RankingV1Dto.RankingResponse> response = rankings.stream()
             .map(RankingV1Dto.RankingResponse::from)
             .toList();

apps/commerce-batch/src/main/java/com/loopers/batch/job/ranking/RankingMonthlyJobConfig.java

@@ -0,0 +1,68 @@
+package com.loopers.batch.job.ranking;
+
+import com.loopers.batch.listener.JobListener;
+import com.loopers.batch.listener.StepMonitorListener;
+import com.loopers.batch.job.ranking.step.MonthlyMvRankingItemWriter;
+import com.loopers.batch.job.ranking.step.MonthlyRankAssignTasklet;
+import com.loopers.batch.job.ranking.step.RankedProductDto;
+import com.loopers.batch.job.ranking.step.RankingItemProcessor;
+import com.loopers.infrastructure.metrics.ProductMetricsAggregatedDto;
+import java.time.format.DateTimeFormatter;
+import lombok.RequiredArgsConstructor;
+import org.springframework.batch.core.Job;
+import org.springframework.batch.core.Step;
+import org.springframework.batch.core.job.builder.JobBuilder;
+import org.springframework.batch.core.repository.JobRepository;
+import org.springframework.batch.core.step.builder.StepBuilder;
+import org.springframework.batch.item.database.JdbcPagingItemReader;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.transaction.PlatformTransactionManager;
+
+@ConditionalOnProperty(name = "spring.batch.job.name", havingValue = RankingMonthlyJobConfig.JOB_NAME)
+@RequiredArgsConstructor
+@Configuration
+public class RankingMonthlyJobConfig {
+
+    public static final String JOB_NAME = "rankingMonthlyJob";
+    public static final DateTimeFormatter YEAR_MONTH_FORMAT = DateTimeFormatter.ofPattern("yyyyMM");
+    private static final int CHUNK_SIZE = 100;
+
+    private final JobRepository jobRepository;
+    private final JobListener jobListener;
+    private final StepMonitorListener stepMonitorListener;
+    private final PlatformTransactionManager transactionManager;
+    private final JdbcPagingItemReader<ProductMetricsAggregatedDto> productMetricsItemReader;
+    private final RankingItemProcessor rankingItemProcessor;
+    private final MonthlyMvRankingItemWriter monthlyMvRankingItemWriter;
+    private final MonthlyRankAssignTasklet monthlyRankAssignTasklet;
+
+    @Bean(JOB_NAME)
+    public Job rankingMonthlyJob() {
+        return new JobBuilder(JOB_NAME, jobRepository)
+                .start(monthlyScoreCalculationStep())
+                .next(monthlyRankAssignStep())
+                .listener(jobListener)
+                .build();
+    }
+
+    @Bean("monthlyScoreCalculationStep")
+    public Step monthlyScoreCalculationStep() {
+        return new StepBuilder("monthlyScoreCalculationStep", jobRepository)
+                .<ProductMetricsAggregatedDto, RankedProductDto>chunk(CHUNK_SIZE, transactionManager)
+                .reader(productMetricsItemReader)
+                .processor(rankingItemProcessor)
+                .writer(monthlyMvRankingItemWriter)
+                .listener(stepMonitorListener)
+                .build();
+    }
+
+    @Bean("monthlyRankAssignStep")
+    public Step monthlyRankAssignStep() {
+        return new StepBuilder("monthlyRankAssignStep", jobRepository)
+                .tasklet(monthlyRankAssignTasklet, transactionManager)
+                .listener(stepMonitorListener)
+                .build();
+    }
+}