feat: 주간 랭킹 배치 프로세스 및 스케줄러 구현

- 주간 랭킹 처리를 위한 도메인 엔티티(WeeklyRankingMV, WeeklyRankingWork) 추가
- WeeklyRankingJobConfig 및 RankingChunkConfig로 배치 잡 구성
- WeeklyRankingProcessor 및 Tasklet을 통해 점수 계산, 데이터 준비 및 스왑 처리 구현
- 스케줄링을 통해 배치 잡 자동 실행 (매주 월요일 2시 설정)
- MonthlyRankingJob 스켈레톤 추가, 향후 확장 고려

Author: yeonjiyeon

apps/commerce-batch/src/main/java/com/loopers/CommerceBatchApplication.java

@@ -6,7 +6,9 @@
 import org.springframework.boot.context.properties.ConfigurationPropertiesScan;
 
 import java.util.TimeZone;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
+@EnableScheduling
 @ConfigurationPropertiesScan
 @SpringBootApplication
 public class CommerceBatchApplication {

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

@@ -0,0 +1,65 @@
+package com.loopers.batch.job.ranking;
+
+import com.loopers.batch.job.ranking.step.weekly.WeeklyRankingProcessor;
+import com.loopers.domain.ProductMetrics;
+import com.loopers.domain.rank.weekly.WeeklyRankingWork;
+import jakarta.persistence.EntityManagerFactory;
+import java.time.LocalDateTime;
+import java.util.Map;
+import lombok.RequiredArgsConstructor;
+import org.springframework.batch.core.configuration.annotation.StepScope;
+import org.springframework.batch.item.ItemProcessor;
+import org.springframework.batch.item.database.JpaItemWriter;
+import org.springframework.batch.item.database.JpaPagingItemReader;
+import org.springframework.batch.item.database.builder.JpaItemWriterBuilder;
+import org.springframework.batch.item.database.builder.JpaPagingItemReaderBuilder;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@RequiredArgsConstructor
+public class RankingChunkConfig {
+
+  private final WeeklyRankingProcessor weeklyRankingProcessor;
+  private final EntityManagerFactory emf;
+
+  @Bean
+  @StepScope
+  public JpaPagingItemReader<ProductMetrics> rankingReader() {
+    return new JpaPagingItemReaderBuilder<ProductMetrics>()
+        .name("rankingReader")
+        .entityManagerFactory(emf)
+        .queryString("SELECT m FROM ProductMetrics m WHERE m.updatedAt >= :startDate")
+        .parameterValues(Map.of("startDate", LocalDateTime.now().minusDays(7)))
+        .pageSize(100)
+        .build();
+  }
+
+  @Bean
+  public ItemProcessor<ProductMetrics, WeeklyRankingWork> rankingProcessor() {
+    return weeklyRankingProcessor;
+  }
+
+  @Bean
+  @StepScope
+  public JpaItemWriter<WeeklyRankingWork> rankingWriter() {
+    return new JpaItemWriterBuilder<WeeklyRankingWork>()
+        .entityManagerFactory(emf)
+        .build();
+  }
+
+  @Bean
+  @StepScope
+  public JpaPagingItemReader<ProductMetrics> monthlyRankingReader(
+      @Value("#{jobParameters['startDate']}") String startDate
+  ) {
+    return new JpaPagingItemReaderBuilder<ProductMetrics>()
+        .name("monthlyRankingReader")
+        .entityManagerFactory(emf)
+        .queryString("SELECT m FROM ProductMetrics m WHERE m.updatedAt >= :startDate")
+        .parameterValues(Map.of("startDate", LocalDateTime.parse(startDate)))
+        .pageSize(100)
+        .build();
+  }
+}

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

@@ -0,0 +1,75 @@
+package com.loopers.batch.job.ranking;
+
+import com.loopers.batch.job.ranking.step.RankingPrepareTasklet;
+import com.loopers.batch.job.ranking.step.RankingTableSwapTasklet;
+import com.loopers.batch.listener.JobListener;
+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.ItemReader;
+import org.springframework.batch.item.ItemWriter;
+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 = WeeklyRankingJobConfig.JOB_NAME)
+@RequiredArgsConstructor
+@Configuration
+public class WeeklyRankingJobConfig {
+
+  public static final String JOB_NAME = "weeklyRankingJob";
+
+  private final JobRepository jobRepository;
+  private final JobListener jobListener;
+  private final PlatformTransactionManager transactionManager;
+
+  private final RankingPrepareTasklet prepareTasklet;
+  private final RankingTableSwapTasklet tableSwapTasklet;
+
+  private final ItemReader<ProductMetrics> rankingReader;
+  private final ItemProcessor<ProductMetrics, WeeklyRankingWork> rankingProcessor;
+  private final ItemWriter<WeeklyRankingWork> rankingWriter;
+
+  @Bean(JOB_NAME)
+  public Job weeklyRankingJob() {
+    return new JobBuilder(JOB_NAME, jobRepository)
+        .incrementer(new RunIdIncrementer())
+        .start(prepareStep())
+        .next(calculationStep())
+        .next(tableSwapStep())
+        .listener(jobListener)
+        .build();
+  }
+
+  @Bean
+  public Step prepareStep() {
+    return new StepBuilder("prepareStep", jobRepository)
+        .tasklet(prepareTasklet, transactionManager)
+        .build();
+  }
+
+  @Bean
+  public Step calculationStep() {
+    return new StepBuilder("calculationStep", jobRepository)
+        .<ProductMetrics, WeeklyRankingWork>chunk(100, transactionManager)
+        .reader(rankingReader)
+        .processor(rankingProcessor)
+        .writer(rankingWriter)
+        .build();
+  }
+
+  @Bean
+  public Step tableSwapStep() {
+    return new StepBuilder("tableSwapStep", jobRepository)
+        .tasklet(tableSwapTasklet, transactionManager)
+        .build();
+  }
+}

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

@@ -0,0 +1,59 @@
+package com.loopers.batch.job.ranking.scheduler;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.batch.core.Job;
+import org.springframework.batch.core.JobParametersBuilder;
+import org.springframework.batch.core.launch.JobLauncher;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class RankingScheduler {
+
+  private final JobLauncher jobLauncher;
+
+  @Qualifier("weeklyRankingJob")
+  private final Job weeklyRankingJob;
+
+  @Qualifier("monthlyRankingJob")
+  private final Job monthlyRankingJob;
+
+  @Scheduled(cron = "0 0 2 * * MON")
+  public void runWeeklyRankingJob() {
+    String requestDate = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMdd"));
+    log.info(">>> Weekly Ranking Job Scheduler Start: {}", requestDate);
+
+    try {
+      jobLauncher.run(weeklyRankingJob, new JobParametersBuilder()
+          .addString("requestDate", requestDate)
+          .addLong("timestamp", System.currentTimeMillis())
+          .toJobParameters());
+    } catch (Exception e) {
+      log.error(">>> Weekly Ranking Job Error: {}", e.getMessage());
+    }
+  }
+
+  @Scheduled(cron = "0 0 3 1 * *")
+  public void runMonthlyRankingJob() {
+    String requestDate = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMdd"));
+    String startDate = LocalDateTime.now().minusMonths(1).format(DateTimeFormatter.ISO_LOCAL_DATE_TIME);
+
+    log.info(">>> Monthly Ranking Job Scheduler Start: {}", requestDate);
+
+    try {
+      jobLauncher.run(monthlyRankingJob, new JobParametersBuilder()
+          .addString("requestDate", requestDate)
+          .addString("startDate", startDate)
+          .addLong("timestamp", System.currentTimeMillis())
+          .toJobParameters());
+    } catch (Exception e) {
+      log.error(">>> Monthly Ranking Job Error: {}", e.getMessage());
+    }
+  }
+}

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

@@ -0,0 +1,24 @@
+package com.loopers.batch.job.ranking.step;
+
+import com.loopers.domain.rank.weekly.WeeklyRankingWorkRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.batch.core.StepContribution;
+import org.springframework.batch.core.configuration.annotation.StepScope;
+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.stereotype.Component;
+
+@Component
+@StepScope
+@RequiredArgsConstructor
+public class RankingPrepareTasklet implements Tasklet {
+
+  private final WeeklyRankingWorkRepository workingRepository;
+
+  @Override
+  public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) {
+    workingRepository.deleteAllInBatch();
+    return RepeatStatus.FINISHED;
+  }
+}

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

@@ -0,0 +1,40 @@
+package com.loopers.batch.job.ranking.step;
+
+import com.loopers.domain.rank.weekly.WeeklyRankingMV;
+import com.loopers.domain.rank.weekly.WeeklyRankingMVRepository;
+import com.loopers.domain.rank.weekly.WeeklyRankingWork;
+import com.loopers.domain.rank.weekly.WeeklyRankingWorkRepository;
+import java.time.LocalDate;
+import java.util.List;
+import lombok.AllArgsConstructor;
+import org.springframework.batch.core.StepContribution;
+import org.springframework.batch.core.configuration.annotation.StepScope;
+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.stereotype.Component;
+
+@Component
+@StepScope
+@AllArgsConstructor
+public class RankingTableSwapTasklet implements Tasklet {
+
+  private final WeeklyRankingMVRepository mvRepository;
+  private final WeeklyRankingWorkRepository workRepository;
+
+  @Override
+  public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) {
+    String baseDate = LocalDate.now().toString();
+
+    mvRepository.deleteAllInBatch();
+
+    List<WeeklyRankingWork> workData = workRepository.findAll();
+
+    List<WeeklyRankingMV> newData = workData.stream()
+        .map(work -> WeeklyRankingMV.createFromWork(work, baseDate))
+        .toList();
+
+    mvRepository.saveAll(newData);
+    return RepeatStatus.FINISHED;
+  }
+}

apps/commerce-batch/src/main/java/com/loopers/batch/job/ranking/step/weekly/WeeklyRankingProcessor.java

@@ -0,0 +1,30 @@
+package com.loopers.batch.job.ranking.step.weekly;
+
+import com.loopers.domain.ProductMetrics;
+import com.loopers.domain.rank.weekly.WeeklyRankingWork;
+import org.springframework.batch.core.configuration.annotation.StepScope;
+import org.springframework.batch.item.ItemProcessor;
+import org.springframework.stereotype.Component;
+
+@Component
+@StepScope
+public class WeeklyRankingProcessor implements ItemProcessor<ProductMetrics, WeeklyRankingWork> {
+
+  private int rankCounter = 0;
+
+  @Override
+  public WeeklyRankingWork process(ProductMetrics item) {
+    rankCounter++;
+    if (rankCounter > 100) {
+      return null;
+    }
+
+    Double score = (item.getViewCount() * 0.1) + (item.getLikeCount() * 0.2) + (item.getSalesCount() * 0.6);
+
+    return new WeeklyRankingWork(
+        item.getProductId(),
+        score,
+        rankCounter
+    );
+  }
+}

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

@@ -0,0 +1,19 @@
+package com.loopers.domain.rank.monthly;
+
+import java.io.Serializable;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor
+public class ProductSnapshot implements Serializable {
+  private String name;
+  private long price;
+  private boolean isSoldOut;
+
+  public static ProductSnapshot of(String name, long price, boolean isSoldOut) {
+    return new ProductSnapshot(name, price, isSoldOut);
+  }
+}

modules/jpa/src/main/java/com/loopers/domain/rank/weekly/WeeklyRankingMV.java

@@ -0,0 +1,53 @@
+package com.loopers.domain.rank.weekly;
+
+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
+@Table(name = "mv_product_rank_weekly")
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@Getter
+public class WeeklyRankingMV {
+  @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;
+
+  private WeeklyRankingMV(String baseDate, Long productId, Double totalScore, Integer currentRank,
+      String productName, Long price, boolean isSoldOut) {
+    this.baseDate = baseDate;
+    this.productId = productId;
+    this.totalScore = totalScore;
+    this.currentRank = currentRank;
+    this.productName = productName;
+    this.price = price;
+    this.isSoldOut = isSoldOut;
+  }
+
+  // 정적 팩토리 메서드 (의미 있는 생성 방식 제공)
+  public static WeeklyRankingMV createFromWork(WeeklyRankingWork work, String baseDate) {
+    return new WeeklyRankingMV(
+        baseDate,
+        work.getProductId(),
+        work.getScore(),
+        work.getRanking(),
+        "상품명 임시", // 실제 구현 시 Product 정보 결합 필요
+        0L,          // 실제 구현 시 Product 정보 결합 필요
+        false        // 실제 구현 시 Product 정보 결합 필요
+    );
+  }
+}

modules/jpa/src/main/java/com/loopers/domain/rank/weekly/WeeklyRankingMVRepository.java

@@ -0,0 +1,12 @@
+package com.loopers.domain.rank.weekly;
+
+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 WeeklyRankingMVRepository extends JpaRepository<WeeklyRankingMV, Long> {
+
+  List<WeeklyRankingMV> findByBaseDateOrderByCurrentRankAsc(String baseDate, Pageable pageable);
+}