Spring Batch 기반 집계 서비스 구현

.github/workflows/main.yml

@@ -0,0 +1,13 @@
+name: PR Agent
+on:
+  pull_request:
+    types: [opened, synchronize]
+jobs:
+  pr_agent_job:
+    runs-on: ubuntu-latest
+    steps:
+      - name: PR Agent action step
+        uses: Codium-ai/pr-agent@main
+        env:
+          OPENAI_KEY: ${{ secrets.OPENAI_KEY }}
+          GITHUB_TOKEN: ${{ secrets.G_TOKEN }}

README.md

@@ -27,6 +27,7 @@ docker-compose -f ./docker/monitoring-compose.yml up
 Root
 ├── apps ( spring-applications )
 │   ├── 📦 commerce-api
+│   ├── 📦 commerce-batch
 │   └── 📦 commerce-streamer
 ├── modules ( reusable-configurations )
 │   ├── 📦 jpa

apps/commerce-api/src/main/java/com/loopers/application/product/ProductDetailInfo.java

@@ -62,7 +62,8 @@ public static ProductDetailInfo of(ProductEntity product, BrandEntity brand, Lon
         return of(product, brand, likeCount, isLiked, null);
     }
 
-    public static ProductDetailInfo of(ProductEntity product, BrandEntity brand, Long likeCount, Boolean isLiked, RankingItem ranking) {
+    public static ProductDetailInfo of(ProductEntity product, BrandEntity brand, Long likeCount, Boolean isLiked,
+                                       RankingItem ranking) {
         if (product == null) {
             throw new IllegalArgumentException("상품 정보는 필수입니다.");
         }

apps/commerce-api/src/main/java/com/loopers/application/product/ProductFacade.java

@@ -13,6 +13,8 @@
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
+import com.loopers.application.ranking.MonthlyRankingService;
+import com.loopers.application.ranking.WeeklyRankingService;
 import com.loopers.cache.CacheStrategy;
 import com.loopers.cache.RankingRedisService;
 import com.loopers.cache.dto.CachePayloads.RankingItem;
@@ -21,6 +23,9 @@
 import com.loopers.domain.like.LikeService;
 import com.loopers.domain.product.*;
 import com.loopers.domain.product.dto.ProductSearchFilter;
+import com.loopers.domain.ranking.MonthlyRankEntity;
+import com.loopers.domain.ranking.RankingPeriod;
+import com.loopers.domain.ranking.WeeklyRankEntity;
 import com.loopers.domain.tracking.UserBehaviorTracker;
 import com.loopers.domain.user.UserService;
 
@@ -46,6 +51,8 @@ public class ProductFacade {
     private final BrandService brandService;
     private final UserBehaviorTracker behaviorTracker;
     private final RankingRedisService rankingRedisService;
+    private final WeeklyRankingService weeklyRankingService;
+    private final MonthlyRankingService monthlyRankingService;
 
     /**
      * 도메인 서비스에서 MV 엔티티를 조회하고, Facade에서 DTO로 변환합니다.
@@ -70,7 +77,7 @@ public Page<ProductInfo> getProducts(ProductSearchFilter productSearchFilter) {
      * 도메인 서비스에서 엔티티를 조회하고, Facade에서 DTO로 변환합니다.
      *
      * @param productId 상품 ID
-     * @param username    사용자 ID (nullable)
+     * @param username  사용자 ID (nullable)
      * @return 상품 상세 정보
      */
     @Transactional(readOnly = true)
@@ -129,25 +136,25 @@ public ProductDetailInfo getProductDetail(Long productId, String username) {
     @Transactional(readOnly = true)
     public Page<ProductInfo> getRankingProducts(Pageable pageable, LocalDate date) {
         LocalDate targetDate = date != null ? date : LocalDate.now();
-        
+
         // 1. 랭킹 조회
         List<RankingItem> rankings = rankingRedisService.getRanking(
                 targetDate,
-                pageable.getPageNumber() + 1, 
+                pageable.getPageNumber() + 1,
                 pageable.getPageSize()
         );
 
         // 2. 콜드 스타트 Fallback: 오늘 랭킹이 비어있으면 어제 랭킹 조회
         if (rankings.isEmpty() && date == null) {
             LocalDate yesterday = targetDate.minusDays(1);
             log.info("콜드 스타트 Fallback: 오늘({}) 랭킹 없음, 어제({}) 랭킹 조회", targetDate, yesterday);
-            
+
             rankings = rankingRedisService.getRanking(
                     yesterday,
                     pageable.getPageNumber() + 1,
                     pageable.getPageSize()
             );
-            
+
             if (!rankings.isEmpty()) {
                 targetDate = yesterday; // totalCount 계산을 위해 날짜 변경
             }
@@ -181,6 +188,119 @@ public Page<ProductInfo> getRankingProducts(Pageable pageable, LocalDate date) {
         return new PageImpl<>(sortedProducts, pageable, totalCount);
     }
 
+    /**
+     * 기간별 랭킹 상품 목록 조회
+     *
+     * @param period    랭킹 기간 (DAILY, WEEKLY, MONTHLY)
+     * @param pageable  페이징 정보
+     * @param date      조회 날짜 (DAILY용, null이면 오늘)
+     * @param yearWeek  조회 주차 (WEEKLY용, 예: "2024-W52")
+     * @param yearMonth 조회 월 (MONTHLY용, 예: "2024-12")
+     * @return 랭킹 상품 목록
+     */
+    @Transactional(readOnly = true)
+    public Page<ProductInfo> getRankingProductsByPeriod(
+            RankingPeriod period,
+            Pageable pageable,
+            LocalDate date,
+            String yearWeek,
+            String yearMonth) {
+
+        return switch (period) {
+            case DAILY -> getRankingProducts(pageable, date);
+            case WEEKLY -> getWeeklyRankingProducts(pageable, yearWeek);
+            case MONTHLY -> getMonthlyRankingProducts(pageable, yearMonth);
+        };
+    }
+
+    /**
+     * 주간 랭킹 상품 목록 조회
+     *
+     * @param pageable 페이징 정보
+     * @param yearWeek 조회 주차 (예: "2024-W52")
+     * @return 주간 랭킹 상품 목록
+     */
+    @Transactional(readOnly = true)
+    public Page<ProductInfo> getWeeklyRankingProducts(Pageable pageable, String yearWeek) {
+        if (yearWeek == null || yearWeek.trim().isEmpty()) {
+            log.warn("주간 랭킹 조회 시 yearWeek 파라미터가 필요합니다");
+            return Page.empty(pageable);
+        }
+
+        // 1. 주간 랭킹 조회
+        Page<WeeklyRankEntity> weeklyRankings = weeklyRankingService.getWeeklyRanking(yearWeek, pageable);
+
+        if (weeklyRankings.isEmpty()) {
+            log.debug("주간 랭킹 데이터 없음: yearWeek={}", yearWeek);
+            return Page.empty(pageable);
+        }
+
+        // 2. 상품 ID 목록 추출
+        List<Long> productIds = weeklyRankings.getContent().stream()
+                .map(WeeklyRankEntity::getProductId)
+                .collect(Collectors.toList());
+
+        // 3. 상품 정보 조회 (MV 사용)
+        List<ProductMaterializedViewEntity> products = mvService.getByIds(productIds);
+
+        // 4. 랭킹 순서대로 정렬
+        List<ProductInfo> sortedProducts = productIds.stream()
+                .map(productId -> products.stream()
+                        .filter(p -> p.getProductId().equals(productId))
+                        .findFirst()
+                        .map(ProductInfo::from)
+                        .orElse(null))
+                .filter(Objects::nonNull)
+                .collect(Collectors.toList());
+
+        // 5. Page 객체 생성
+        return new PageImpl<>(sortedProducts, pageable, weeklyRankings.getTotalElements());
+    }
+
+    /**
+     * 월간 랭킹 상품 목록 조회
+     *
+     * @param pageable  페이징 정보
+     * @param yearMonth 조회 월 (예: "2024-12")
+     * @return 월간 랭킹 상품 목록
+     */
+    @Transactional(readOnly = true)
+    public Page<ProductInfo> getMonthlyRankingProducts(Pageable pageable, String yearMonth) {
+        if (yearMonth == null || yearMonth.trim().isEmpty()) {
+            log.warn("월간 랭킹 조회 시 yearMonth 파라미터가 필요합니다");
+            return Page.empty(pageable);
+        }
+
+        // 1. 월간 랭킹 조회
+        Page<MonthlyRankEntity> monthlyRankings = monthlyRankingService.getMonthlyRanking(yearMonth, pageable);
+
+        if (monthlyRankings.isEmpty()) {
+            log.debug("월간 랭킹 데이터 없음: yearMonth={}", yearMonth);
+            return Page.empty(pageable);
+        }
+
+        // 2. 상품 ID 목록 추출
+        List<Long> productIds = monthlyRankings.getContent().stream()
+                .map(MonthlyRankEntity::getProductId)
+                .collect(Collectors.toList());
+
+        // 3. 상품 정보 조회 (MV 사용)
+        List<ProductMaterializedViewEntity> products = mvService.getByIds(productIds);
+
+        // 4. 랭킹 순서대로 정렬
+        List<ProductInfo> sortedProducts = productIds.stream()
+                .map(productId -> products.stream()
+                        .filter(p -> p.getProductId().equals(productId))
+                        .findFirst()
+                        .map(ProductInfo::from)
+                        .orElse(null))
+                .filter(Objects::nonNull)
+                .collect(Collectors.toList());
+
+        // 5. Page 객체 생성
+        return new PageImpl<>(sortedProducts, pageable, monthlyRankings.getTotalElements());
+    }
+
     /**
      * 상품을 삭제합니다.
      * <p>

apps/commerce-api/src/main/java/com/loopers/application/ranking/MonthlyRankingService.java

@@ -0,0 +1,48 @@
+package com.loopers.application.ranking;
+
+import java.util.List;
+
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageImpl;
+import org.springframework.data.domain.Pageable;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import com.loopers.domain.ranking.MonthlyRankEntity;
+import com.loopers.domain.ranking.MonthlyRankRepository;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * 월간 랭킹 조회 서비스
+ */
+@Service
+@RequiredArgsConstructor
+@Slf4j
+@Transactional(readOnly = true)
+public class MonthlyRankingService {
+
+    private final MonthlyRankRepository monthlyRankRepository;
+
+    /**
+     * 특정 월의 랭킹을 페이지네이션하여 조회합니다.
+     *
+     * @param yearMonth 조회할 월 (예: "2024-12")
+     * @param pageable  페이징 정보
+     * @return 월간 랭킹 페이지
+     */
+    public Page<MonthlyRankEntity> getMonthlyRanking(String yearMonth, Pageable pageable) {
+        log.debug("월간 랭킹 조회: yearMonth={}, page={}, size={}",
+                yearMonth, pageable.getPageNumber(), pageable.getPageSize());
+
+        // 1. 전체 랭킹 조회 (순위 순으로 정렬됨)
+        Page<MonthlyRankEntity> pagedRankings = monthlyRankRepository.findByYearMonth(yearMonth, pageable);
+
+
+        log.debug("월간 랭킹 조회 완료: yearMonth={}, 전체={}, 페이지={}",
+                yearMonth, pagedRankings.getTotalPages(), pagedRankings.getNumber());
+
+        return pagedRankings;
+    }
+}

apps/commerce-api/src/main/java/com/loopers/application/ranking/WeeklyRankingService.java

@@ -0,0 +1,60 @@
+package com.loopers.application.ranking;
+
+import java.util.List;
+
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageImpl;
+import org.springframework.data.domain.Pageable;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import com.loopers.domain.ranking.WeeklyRankEntity;
+import com.loopers.domain.ranking.WeeklyRankRepository;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * 주간 랭킹 조회 서비스
+ */
+@Service
+@RequiredArgsConstructor
+@Slf4j
+@Transactional(readOnly = true)
+public class WeeklyRankingService {
+
+    private final WeeklyRankRepository weeklyRankRepository;
+
+    /**
+     * 특정 주차의 랭킹을 페이지네이션하여 조회합니다.
+     *
+     * @param yearWeek 조회할 주차 (예: "2024-W52")
+     * @param pageable 페이징 정보
+     * @return 주간 랭킹 페이지
+     */
+    public Page<WeeklyRankEntity> getWeeklyRanking(String yearWeek, Pageable pageable) {
+        log.debug("주간 랭킹 조회: yearWeek={}, page={}, size={}",
+                yearWeek, pageable.getPageNumber(), pageable.getPageSize());
+
+        // 1. 전체 랭킹 조회 (순위 순으로 정렬됨)
+        Page<WeeklyRankEntity> pagedRankings = weeklyRankRepository.findByYearWeek(yearWeek , pageable);
+
+        if (pagedRankings.isEmpty()) {
+            log.debug("주간 랭킹 데이터 없음: yearWeek={}", yearWeek);
+            return Page.empty(pageable);
+        }
+
+        return pagedRankings;
+    }
+
+    /**
+     * 특정 주차의 전체 랭킹 개수를 조회합니다.
+     *
+     * @param yearWeek 조회할 주차
+     * @return 랭킹 개수
+     */
+    public long getWeeklyRankingCount(String yearWeek) {
+        List<WeeklyRankEntity> rankings = weeklyRankRepository.findByYearWeek(yearWeek);
+        return rankings.size();
+    }
+}

apps/commerce-api/src/main/java/com/loopers/domain/point/PointHistoryEntity.java

@@ -4,7 +4,6 @@
 import java.util.Objects;
 
 import com.loopers.domain.BaseEntity;
-import com.loopers.domain.product.ProductEntity;
 import com.loopers.domain.user.UserEntity;
 
 import lombok.AccessLevel;

apps/commerce-api/src/main/java/com/loopers/domain/ranking/RankingPeriod.java

@@ -0,0 +1,21 @@
+package com.loopers.domain.ranking;
+
+/**
+ * 랭킹 조회 기간 타입
+ */
+public enum RankingPeriod {
+    /**
+     * 일간 랭킹 (Redis ZSET 기반)
+     */
+    DAILY,
+
+    /**
+     * 주간 랭킹 (mv_product_rank_weekly 기반)
+     */
+    WEEKLY,
+
+    /**
+     * 월간 랭킹 (mv_product_rank_monthly 기반)
+     */
+    MONTHLY
+}

apps/commerce-api/src/main/java/com/loopers/domain/user/UserEntity.java

@@ -6,7 +6,6 @@
 import java.util.Objects;
 
 import com.loopers.domain.BaseEntity;
-import com.loopers.support.Uris;
 
 import lombok.AccessLevel;
 import lombok.Getter;