feat: MonthlyRankingJpaRepository 및 WeeklyRankingJpaRepository에 삭제 메서드 추가

Author: rnqhstmd

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

@@ -0,0 +1,28 @@
+package com.loopers.infrastructure.ranking;
+
+import com.loopers.domain.ranking.MonthlyRanking;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+import java.time.YearMonth;
+import java.util.List;
+import java.util.Optional;
+
+public interface MonthlyRankingJpaRepository extends JpaRepository<MonthlyRanking, Long> {
+
+    @Query(value = """
+            SELECT * FROM mv_product_rank_monthly 
+            WHERE month_period = :monthPeriod 
+            ORDER BY monthly_rank ASC 
+            LIMIT :limit OFFSET :offset
+            """, nativeQuery = true)
+    List<MonthlyRanking> findByPeriodWithPagination(
+            @Param("monthPeriod") String monthPeriod,
+            @Param("limit") int limit,
+            @Param("offset") int offset);
+
+    Optional<MonthlyRanking> findByProductIdAndMonthPeriod(Long productId, YearMonth monthPeriod);
+
+    long countByMonthPeriod(YearMonth monthPeriod);
+}

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

@@ -0,0 +1,48 @@
+package com.loopers.infrastructure.ranking;
+
+import com.loopers.domain.ranking.*;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Repository;
+
+import java.time.LocalDate;
+import java.time.YearMonth;
+import java.util.List;
+import java.util.Optional;
+
+@Repository
+@RequiredArgsConstructor
+public class RankingRepositoryImpl implements RankingRepository {
+
+    private final WeeklyRankingJpaRepository weeklyJpaRepository;
+    private final MonthlyRankingJpaRepository monthlyJpaRepository;
+
+    @Override
+    public List<WeeklyRanking> findWeeklyByDateOrderByRank(LocalDate weekStart, LocalDate weekEnd, int limit, int offset) {
+        return weeklyJpaRepository.findByDateWithPagination(weekStart, weekEnd, limit, offset);
+    }
+
+    @Override
+    public Optional<WeeklyRanking> findWeeklyByProductIdAndDate(Long productId, LocalDate weekStart, LocalDate weekEnd) {
+        return weeklyJpaRepository.findByProductIdAndWeekStartAndWeekEnd(productId, weekStart, weekEnd);
+    }
+
+    @Override
+    public long countWeeklyByDate(LocalDate weekStart, LocalDate weekEnd) {
+        return weeklyJpaRepository.countByWeekStartAndWeekEnd(weekStart, weekEnd);
+    }
+
+    @Override
+    public List<MonthlyRanking> findMonthlyByPeriodOrderByRank(YearMonth period, int limit, int offset) {
+        return monthlyJpaRepository.findByPeriodWithPagination(period.toString(), limit, offset);
+    }
+
+    @Override
+    public Optional<MonthlyRanking> findMonthlyByProductIdAndPeriod(Long productId, YearMonth period) {
+        return monthlyJpaRepository.findByProductIdAndMonthPeriod(productId, period);
+    }
+
+    @Override
+    public long countMonthlyByPeriod(YearMonth period) {
+        return monthlyJpaRepository.countByMonthPeriod(period);
+    }
+}

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

@@ -0,0 +1,29 @@
+package com.loopers.infrastructure.ranking;
+
+import com.loopers.domain.ranking.WeeklyRanking;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+import java.time.LocalDate;
+import java.util.List;
+import java.util.Optional;
+
+public interface WeeklyRankingJpaRepository extends JpaRepository<WeeklyRanking, Long> {
+
+    @Query(value = """
+            SELECT * FROM mv_product_rank_weekly 
+            WHERE week_start = :weekStart AND week_end = :weekEnd 
+            ORDER BY weekly_rank ASC 
+            LIMIT :limit OFFSET :offset
+            """, nativeQuery = true)
+    List<WeeklyRanking> findByDateWithPagination(
+            @Param("weekStart") LocalDate weekStart,
+            @Param("weekEnd") LocalDate weekEnd,
+            @Param("limit") int limit,
+            @Param("offset") int offset);
+
+    Optional<WeeklyRanking> findByProductIdAndWeekStartAndWeekEnd(Long productId, LocalDate weekStart, LocalDate weekEnd);
+
+    long countByWeekStartAndWeekEnd(LocalDate weekStart, LocalDate weekEnd);
+}

apps/commerce-batch/src/main/java/com/loopers/batch/domain/metrics/ProductMetricsRepository.java

@@ -0,0 +1,10 @@
+package com.loopers.batch.domain.metrics;
+
+import com.loopers.dto.ProductMetricsSummary;
+
+import java.time.LocalDate;
+import java.util.List;
+
+public interface ProductMetricsRepository {
+    List<ProductMetricsSummary> findAllByDateRange(LocalDate startDate, LocalDate endDate);
+}

apps/commerce-batch/src/main/java/com/loopers/batch/domain/ranking/MonthlyRankingRepository.java

@@ -0,0 +1,11 @@
+package com.loopers.batch.domain.ranking;
+
+import java.time.YearMonth;
+import java.util.List;
+
+public interface MonthlyRankingRepository {
+
+    void deleteByMonthPeriod(YearMonth monthPeriod);
+
+    void saveAll(List<MonthlyRanking> rankings);
+}

apps/commerce-batch/src/main/java/com/loopers/batch/domain/ranking/WeeklyRankingRepository.java

@@ -0,0 +1,11 @@
+package com.loopers.batch.domain.ranking;
+
+import java.time.LocalDate;
+import java.util.List;
+
+public interface WeeklyRankingRepository {
+
+    void deleteByWeekStartAndWeekEnd(LocalDate weekStart, LocalDate weekEnd);
+
+    void saveAll(List<WeeklyRanking> rankings);
+}

apps/commerce-batch/src/main/java/com/loopers/infrastructure/metrics/ProductMetricsJpaRepository.java

@@ -0,0 +1,31 @@
+package com.loopers.infrastructure.metrics;
+
+import com.loopers.batch.domain.metrics.ProductMetrics;
+import com.loopers.batch.domain.metrics.ProductMetricsId;
+import com.loopers.dto.ProductMetricsSummary;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+import java.time.LocalDate;
+import java.util.List;
+
+public interface ProductMetricsJpaRepository extends JpaRepository<ProductMetrics, ProductMetricsId> {
+
+    @Query("""
+        SELECT new com.loopers.dto.ProductMetricsSummary(
+            pm.id.productId,
+            pm.id.metricsDate,
+            CAST(pm.likesDelta AS long),
+            CAST(pm.salesDelta AS long),
+            CAST(pm.viewsDelta AS long)
+        )
+        FROM ProductMetrics pm
+        WHERE pm.id.metricsDate BETWEEN :startDate AND :endDate
+        ORDER BY pm.id.productId, pm.id.metricsDate
+        """)
+    List<ProductMetricsSummary> findAllByDateRange(
+            @Param("startDate") LocalDate startDate,
+            @Param("endDate") LocalDate endDate
+    );
+}

apps/commerce-batch/src/main/java/com/loopers/infrastructure/metrics/ProductMetricsRepositoryImpl.java

@@ -0,0 +1,21 @@
+package com.loopers.infrastructure.metrics;
+
+import com.loopers.batch.domain.metrics.ProductMetricsRepository;
+import com.loopers.dto.ProductMetricsSummary;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Repository;
+
+import java.time.LocalDate;
+import java.util.List;
+
+@Repository
+@RequiredArgsConstructor
+public class ProductMetricsRepositoryImpl implements ProductMetricsRepository {
+
+    private final ProductMetricsJpaRepository jpaRepository;
+
+    @Override
+    public List<ProductMetricsSummary> findAllByDateRange(LocalDate startDate, LocalDate endDate) {
+        return jpaRepository.findAllByDateRange(startDate, endDate);
+    }
+}

apps/commerce-batch/src/main/java/com/loopers/infrastructure/ranking/MonthlyRankingJpaRepository.java

@@ -0,0 +1,16 @@
+package com.loopers.infrastructure.ranking;
+
+import com.loopers.batch.domain.ranking.MonthlyRanking;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+import java.time.YearMonth;
+
+public interface MonthlyRankingJpaRepository extends JpaRepository<MonthlyRanking, Long> {
+
+    @Modifying
+    @Query("DELETE FROM MonthlyRanking m WHERE m.monthPeriod = :monthPeriod")
+    void deleteByMonthPeriod(@Param("monthPeriod") YearMonth monthPeriod);
+}

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

@@ -0,0 +1,40 @@
+package com.loopers.infrastructure.ranking;
+
+import com.loopers.batch.domain.ranking.MonthlyRanking;
+import com.loopers.batch.domain.ranking.MonthlyRankingRepository;
+import com.loopers.batch.domain.ranking.WeeklyRanking;
+import com.loopers.batch.domain.ranking.WeeklyRankingRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Repository;
+
+import java.time.LocalDate;
+import java.time.YearMonth;
+import java.util.List;
+
+@Repository
+@RequiredArgsConstructor
+public class RankingRepositoryImpl implements WeeklyRankingRepository, MonthlyRankingRepository {
+
+    private final WeeklyRankingJpaRepository weeklyJpaRepository;
+    private final MonthlyRankingJpaRepository monthlyJpaRepository;
+
+    @Override
+    public void deleteByWeekStartAndWeekEnd(LocalDate weekStart, LocalDate weekEnd) {
+        weeklyJpaRepository.deleteByWeekStartAndWeekEnd(weekStart, weekEnd);
+    }
+
+    @Override
+    public void saveAll(List<WeeklyRanking> rankings) {
+        weeklyJpaRepository.saveAll(rankings);
+    }
+
+    @Override
+    public void deleteByMonthPeriod(YearMonth monthPeriod) {
+        monthlyJpaRepository.deleteByMonthPeriod(monthPeriod);
+    }
+
+    @Override
+    public void saveAll(List<MonthlyRanking> rankings) {
+        monthlyJpaRepository.saveAll(rankings);
+    }
+}