feat: 월간 랭킹 배치 프로세스 및 Tasklet 구현

- 월간 랭킹 처리를 위한 도메인 엔티티(MonthlyRankingMV) 및 레포지토리 추가
- MonthlyRankingJobConfig와 Tasklet으로 배치 잡 구성
- 월간 점수 계산 및 랭킹 데이터 준비를 위한 Processing 로직 구현
- Redis를 활용한 스냅샷 데이터 처리 및 랭킹 데이터 스왑 로직 추가

Author: yeonjiyeon

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

@@ -0,0 +1,70 @@
+package com.loopers.batch.job.ranking;
+
+import com.loopers.batch.job.ranking.step.RankingPrepareTasklet;
+import com.loopers.batch.job.ranking.step.monthly.MonthlyRankingTableSwapTasklet;
+import com.loopers.domain.ProductMetrics;
+import com.loopers.domain.rank.weekly.WeeklyRankingWork;
+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.launch.support.RunIdIncrementer;
+import org.springframework.batch.core.repository.JobRepository;
+import org.springframework.batch.core.step.builder.StepBuilder;
+import org.springframework.batch.item.ItemProcessor;
+import org.springframework.batch.item.database.JpaItemWriter;
+import org.springframework.batch.item.database.JpaPagingItemReader;
+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 = MonthlyRankingJobConfig.JOB_NAME)
+@Configuration
+@RequiredArgsConstructor
+public class MonthlyRankingJobConfig {
+  public static final String JOB_NAME = "monthlyRankingJob";
+
+  private final JobRepository jobRepository;
+  private final PlatformTransactionManager transactionManager;
+  private final RankingPrepareTasklet prepareTasklet;
+  private final MonthlyRankingTableSwapTasklet tableSwapTasklet; // 월간 전용 스왑
+
+  private final JpaPagingItemReader<ProductMetrics> monthlyRankingReader;
+  private final ItemProcessor<ProductMetrics, WeeklyRankingWork> rankingProcessor;
+  private final JpaItemWriter<WeeklyRankingWork> rankingWriter;
+
+  @Bean(JOB_NAME)
+  public Job monthlyRankingJob() {
+    return new JobBuilder(JOB_NAME, jobRepository)
+        .incrementer(new RunIdIncrementer())
+        .start(monthlyPrepareStep())
+        .next(monthlyCalculationStep())
+        .next(monthlyTableSwapStep())
+        .build();
+  }
+
+  @Bean
+  public Step monthlyPrepareStep() {
+    return new StepBuilder("monthlyPrepareStep", jobRepository)
+        .tasklet(prepareTasklet, transactionManager)
+        .build();
+  }
+
+  @Bean
+  public Step monthlyCalculationStep() {
+    return new StepBuilder("monthlyCalculationStep", jobRepository)
+        .<ProductMetrics, WeeklyRankingWork>chunk(100, transactionManager)
+        .reader(monthlyRankingReader) // 기간을 30일로 설정한 Reader
+        .processor(rankingProcessor)
+        .writer(rankingWriter)
+        .build();
+  }
+
+  @Bean
+  public Step monthlyTableSwapStep() {
+    return new StepBuilder("monthlyTableSwapStep", jobRepository)
+        .tasklet(tableSwapTasklet, transactionManager)
+        .build();
+  }
+}

apps/commerce-batch/src/main/java/com/loopers/batch/job/ranking/step/monthly/MonthlyRankingTableSwapTasklet.java

@@ -0,0 +1,63 @@
+package com.loopers.batch.job.ranking.step.monthly;
+
+import com.loopers.domain.rank.monthly.MonthlyRankingMV;
+import com.loopers.domain.rank.monthly.MonthlyRankingMVRepository;
+import com.loopers.domain.rank.monthly.ProductSnapshot;
+import com.loopers.domain.rank.weekly.WeeklyRankingWork;
+import com.loopers.domain.rank.weekly.WeeklyRankingWorkRepository;
+import java.util.List;
+import java.util.stream.IntStream;
+import lombok.RequiredArgsConstructor;
+import org.springframework.batch.core.StepContribution;
+import org.springframework.batch.core.scope.context.ChunkContext;
+import org.springframework.batch.core.step.tasklet.Tasklet;
+import org.springframework.batch.repeat.RepeatStatus;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class MonthlyRankingTableSwapTasklet implements Tasklet {
+
+  private final MonthlyRankingMVRepository monthlyMvRepository;
+  private final WeeklyRankingWorkRepository workRepository;
+  private final RedisTemplate<String, Object> redisTemplate; // Redis 사용
+
+  @Override
+  public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) {
+    monthlyMvRepository.deleteAllInBatch();
+    List<WeeklyRankingWork> workData = workRepository.findAll();
+    if (workData.isEmpty()) return RepeatStatus.FINISHED;
+
+    List<String> keys = workData.stream()
+        .map(work -> "product:snapshot:" + work.getProductId())
+        .toList();
+
+    List<Object> snapshots = redisTemplate.opsForValue().multiGet(keys);
+
+    String baseDate = (String) chunkContext.getStepContext().getJobParameters().get("requestDate");
+    if (baseDate == null) baseDate = "2026-01";
+
+    String finalBaseDate = baseDate;
+    List<MonthlyRankingMV> newData = IntStream.range(0, workData.size())
+        .mapToObj(i -> {
+          WeeklyRankingWork work = workData.get(i);
+          ProductSnapshot snapshot = (ProductSnapshot) snapshots.get(i); // Redis에서 가져온 스냅샷
+
+          if (snapshot == null) {
+            return MonthlyRankingMV.createFromWork(work, finalBaseDate, "Unknown", 0L, true);
+          }
+
+          return MonthlyRankingMV.createFromWork(
+              work,
+              "2026-01",
+              snapshot.getName(),
+              snapshot.getPrice(),
+              snapshot.isSoldOut()
+          );
+        }).toList();
+
+    monthlyMvRepository.saveAll(newData);
+    return RepeatStatus.FINISHED;
+  }
+}

modules/jpa/src/main/java/com/loopers/domain/rank/monthly/MonthlyRankingMV.java

@@ -0,0 +1,44 @@
+package com.loopers.domain.rank.monthly;
+
+import com.loopers.domain.rank.weekly.WeeklyRankingWork;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Getter
+@Table(name = "mv_product_rank_monthly")
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class MonthlyRankingMV {
+
+  @Id
+  @GeneratedValue(strategy = GenerationType.IDENTITY)
+  private Long id;
+  private String baseDate;
+  private Long productId;
+  private Double totalScore;
+  private Integer currentRank;
+
+  private String productName;
+  private Long price;
+  private boolean isSoldOut;
+
+  public static MonthlyRankingMV createFromWork(WeeklyRankingWork work, String baseDate, String productName, Long price, boolean isSoldOut) {
+    MonthlyRankingMV mv = new MonthlyRankingMV();
+    mv.baseDate = baseDate;
+    mv.productId = work.getProductId();
+    mv.totalScore = work.getScore();
+    mv.currentRank = work.getRanking();
+
+    mv.productName = productName;
+    mv.price = price;
+    mv.isSoldOut = isSoldOut;
+
+    return mv;
+  }
+}

modules/jpa/src/main/java/com/loopers/domain/rank/monthly/MonthlyRankingMVRepository.java

@@ -0,0 +1,12 @@
+package com.loopers.domain.rank.monthly;
+
+import java.util.List;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface MonthlyRankingMVRepository extends JpaRepository<MonthlyRankingMV, Long> {
+
+  List<MonthlyRankingMV> findByBaseDateOrderByCurrentRankAsc(String baseDate, Pageable pageable);
+}