feat: 월별/주간별 job config 추가

Author: rnqhstmd

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

@@ -0,0 +1,59 @@
+package com.loopers.batch.job.ranking;
+
+import com.loopers.batch.domain.ranking.MonthlyRanking;
+import com.loopers.batch.listener.JobListener;
+import com.loopers.batch.listener.StepMonitorListener;
+import com.loopers.dto.RankedProduct;
+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 = MonthlyRankingJobConfig.JOB_NAME)
+@RequiredArgsConstructor
+@Configuration
+public class MonthlyRankingJobConfig {
+
+    public static final String JOB_NAME = "monthlyRankingJob";
+    private static final String STEP_NAME = "monthlyRankingStep";
+    private static final int CHUNK_SIZE = 100;
+
+    private final JobRepository jobRepository;
+    private final PlatformTransactionManager transactionManager;
+    private final JobListener jobListener;
+    private final StepMonitorListener stepMonitorListener;
+
+    private final ItemReader<RankedProduct> monthlyRankingReader;
+    private final ItemProcessor<RankedProduct, MonthlyRanking> monthlyRankingProcessor;
+    private final ItemWriter<MonthlyRanking> monthlyRankingWriter;
+
+    @Bean(JOB_NAME)
+    public Job monthlyRankingJob() {
+        return new JobBuilder(JOB_NAME, jobRepository)
+                .incrementer(new RunIdIncrementer())
+                .start(monthlyRankingStep())
+                .listener(jobListener)
+                .build();
+    }
+
+    @Bean(STEP_NAME)
+    public Step monthlyRankingStep() {
+        return new StepBuilder(STEP_NAME, jobRepository)
+                .<RankedProduct, MonthlyRanking>chunk(CHUNK_SIZE, transactionManager)
+                .reader(monthlyRankingReader)
+                .processor(monthlyRankingProcessor)
+                .writer(monthlyRankingWriter)
+                .listener(stepMonitorListener)
+                .build();
+    }
+}

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

@@ -0,0 +1,59 @@
+package com.loopers.batch.job.ranking;
+
+import com.loopers.batch.domain.ranking.WeeklyRanking;
+import com.loopers.batch.listener.JobListener;
+import com.loopers.batch.listener.StepMonitorListener;
+import com.loopers.dto.RankedProduct;
+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 static final String STEP_NAME = "weeklyRankingStep";
+    private static final int CHUNK_SIZE = 100;
+
+    private final JobRepository jobRepository;
+    private final PlatformTransactionManager transactionManager;
+    private final JobListener jobListener;
+    private final StepMonitorListener stepMonitorListener;
+
+    private final ItemReader<RankedProduct> weeklyRankingReader;
+    private final ItemProcessor<RankedProduct, WeeklyRanking> weeklyRankingProcessor;
+    private final ItemWriter<WeeklyRanking> weeklyRankingWriter;
+
+    @Bean(JOB_NAME)
+    public Job weeklyRankingJob() {
+        return new JobBuilder(JOB_NAME, jobRepository)
+                .incrementer(new RunIdIncrementer())
+                .start(weeklyRankingStep())
+                .listener(jobListener)
+                .build();
+    }
+
+    @Bean(STEP_NAME)
+    public Step weeklyRankingStep() {
+        return new StepBuilder(STEP_NAME, jobRepository)
+                .<RankedProduct, WeeklyRanking>chunk(CHUNK_SIZE, transactionManager)
+                .reader(weeklyRankingReader)
+                .processor(weeklyRankingProcessor)
+                .writer(weeklyRankingWriter)
+                .listener(stepMonitorListener)
+                .build();
+    }
+}