feat: 월별/주간별 랭킹 프로세서 추가

Author: rnqhstmd

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

@@ -0,0 +1,47 @@
+package com.loopers.batch.job.ranking.processor;
+
+import com.loopers.batch.domain.ranking.MonthlyRanking;
+import com.loopers.dto.RankedProduct;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.batch.core.configuration.annotation.StepScope;
+import org.springframework.batch.item.ItemProcessor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+import java.time.YearMonth;
+import java.time.format.DateTimeFormatter;
+import java.util.concurrent.atomic.AtomicInteger;
+
+@Slf4j
+@StepScope
+@Component
+public class MonthlyRankingProcessor implements ItemProcessor<RankedProduct, MonthlyRanking> {
+
+    @Value("#{jobParameters['yearMonth']}")
+    private String yearMonthStr;
+
+    private static final DateTimeFormatter YEAR_MONTH_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM");
+
+    private final AtomicInteger rankCounter = new AtomicInteger(0);
+
+    @Override
+    public MonthlyRanking process(RankedProduct item) {
+        YearMonth yearMonth = parseYearMonth();
+
+        int rank = rankCounter.incrementAndGet();
+
+        return MonthlyRanking.create(
+                rank,
+                item.productId(),
+                item.score(),
+                yearMonth
+        );
+    }
+
+    private YearMonth parseYearMonth() {
+        if (yearMonthStr != null && !yearMonthStr.isBlank()) {
+            return YearMonth.parse(yearMonthStr, YEAR_MONTH_FORMATTER);
+        }
+        return YearMonth.now();
+    }
+}

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

@@ -0,0 +1,60 @@
+package com.loopers.batch.job.ranking.processor;
+
+import com.loopers.batch.domain.ranking.WeeklyRanking;
+import com.loopers.dto.RankedProduct;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.batch.core.configuration.annotation.StepScope;
+import org.springframework.batch.item.ItemProcessor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+import java.time.DayOfWeek;
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.util.concurrent.atomic.AtomicInteger;
+
+@Slf4j
+@StepScope
+@Component
+public class WeeklyRankingProcessor implements ItemProcessor<RankedProduct, WeeklyRanking> {
+
+    @Value("#{jobParameters['startDate']}")
+    private String startDateStr;
+
+    @Value("#{jobParameters['endDate']}")
+    private String endDateStr;
+
+    private static final DateTimeFormatter DATE_FORMATTER = DateTimeFormatter.ofPattern("yyyyMMdd");
+
+    private final AtomicInteger rankCounter = new AtomicInteger(0);
+
+    @Override
+    public WeeklyRanking process(RankedProduct item) {
+        LocalDate weekStart = parseStartDate();
+        LocalDate weekEnd = parseEndDate();
+
+        int rank = rankCounter.incrementAndGet();
+
+        return WeeklyRanking.create(
+                rank,
+                item.productId(),
+                item.score(),
+                weekStart,
+                weekEnd
+        );
+    }
+
+    private LocalDate parseStartDate() {
+        if (startDateStr != null && !startDateStr.isBlank()) {
+            return LocalDate.parse(startDateStr, DATE_FORMATTER);
+        }
+        return LocalDate.now().with(DayOfWeek.MONDAY);
+    }
+
+    private LocalDate parseEndDate() {
+        if (endDateStr != null && !endDateStr.isBlank()) {
+            return LocalDate.parse(endDateStr, DATE_FORMATTER);
+        }
+        return LocalDate.now().with(DayOfWeek.SUNDAY);
+    }
+}