feat(ranking): 월간 및 주간 랭킹 엔티티 필드명 수정

- rank_position을 base_rank_position으로 변경
- year_month를 base_year_month로 변경
- 로그 메시지 개선 및 예외 처리 강화

Author: hyujikoh

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

@@ -32,30 +32,33 @@ public class MonthlyRankWriter implements ItemWriter<RankingAggregation> {
     @Override
     public void write(Chunk<? extends RankingAggregation> chunk) throws Exception {
         List<? extends RankingAggregation> items = chunk.getItems();
-        
+
         if (items.isEmpty()) {
-            log.info("저장할 월간 랭킹 데이터가 없습니다: yearMonth={}", yearMonth);
+            log.info("[Batch-Ranking] 저장할 월간 랭킹 데이터가 없습니다. (yearMonth: {})", yearMonth);
             return;
         }
 
-        log.info("월간 랭킹 저장 시작: yearMonth={}, 저장할 데이터 수={}", yearMonth, items.size());
+        int targetCount = items.size();
+        log.info("[Batch-Ranking] 월간 랭킹 저장 프로세스 시작 (yearMonth: {}, 대상 건수: {})", yearMonth, targetCount);
 
         try {
             // 1. 기존 데이터 삭제 (멱등성 보장)
             long deletedCount = monthlyRankRepository.deleteByYearMonth(yearMonth);
-            log.info("기존 월간 랭킹 데이터 삭제: yearMonth={}, 삭제된 수={}", yearMonth, deletedCount);
+            log.info("[Batch-Ranking] 기존 데이터 클렌징 완료 (yearMonth: {}, 삭제 건수: {})", yearMonth, deletedCount);
 
             // 2. 새로운 데이터 저장
             List<MonthlyRankEntity> entities = items.stream()
                     .map(this::convertToEntity)
                     .toList();
 
-            List<MonthlyRankEntity> savedEntities = monthlyRankRepository.saveAll(entities);
-            log.info("월간 랭킹 저장 완료: yearMonth={}, 저장된 수={}", yearMonth, savedEntities.size());
+            monthlyRankRepository.saveAll(entities);
+            log.info("[Batch-Ranking] 월간 랭킹 저장 성공 (yearMonth: {}, 저장 건수: {})", yearMonth, entities.size());
 
         } catch (Exception e) {
-            log.error("월간 랭킹 저장 중 오류 발생: yearMonth={}", yearMonth, e);
-            throw new RuntimeException("월간 랭킹 저장 실패", e);
+            // 상세한 컨텍스트를 포함한 에러 로그
+            log.error("[Batch-Ranking] 월간 랭킹 저장 중 예외 발생! (yearMonth: {}, 처리 중이던 건수: {}) - 원인: {}",
+                    yearMonth, targetCount, e.getMessage(), e);
+            throw e;
         }
     }
 
@@ -71,4 +74,4 @@ private MonthlyRankEntity convertToEntity(RankingAggregation aggregation) {
                 aggregation.getRankPosition()
         );
     }
-}
+}

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

@@ -32,30 +32,33 @@ public class WeeklyRankWriter implements ItemWriter<RankingAggregation> {
     @Override
     public void write(Chunk<? extends RankingAggregation> chunk) throws Exception {
         List<? extends RankingAggregation> items = chunk.getItems();
-        
+
         if (items.isEmpty()) {
-            log.info("저장할 주간 랭킹 데이터가 없습니다: yearWeek={}", yearWeek);
+            log.info("[Batch-Ranking] 저장할 주간 랭킹 데이터가 없습니다. (yearWeek: {})", yearWeek);
             return;
         }
 
-        log.info("주간 랭킹 저장 시작: yearWeek={}, 저장할 데이터 수={}", yearWeek, items.size());
+        int targetCount = items.size();
+        log.info("[Batch-Ranking] 주간 랭킹 저장 프로세스 시작 (yearWeek: {}, 대상 건수: {})", yearWeek, targetCount);
 
         try {
             // 1. 기존 데이터 삭제 (멱등성 보장)
             long deletedCount = weeklyRankRepository.deleteByYearWeek(yearWeek);
-            log.info("기존 주간 랭킹 데이터 삭제: yearWeek={}, 삭제된 수={}", yearWeek, deletedCount);
+            log.info("[Batch-Ranking] 기존 데이터 클렌징 완료 (yearWeek: {}, 삭제 건수: {})", yearWeek, deletedCount);
 
             // 2. 새로운 데이터 저장
             List<WeeklyRankEntity> entities = items.stream()
                     .map(this::convertToEntity)
                     .toList();
 
-            List<WeeklyRankEntity> savedEntities = weeklyRankRepository.saveAll(entities);
-            log.info("주간 랭킹 저장 완료: yearWeek={}, 저장된 수={}", yearWeek, savedEntities.size());
+            weeklyRankRepository.saveAll(entities);
+            log.info("[Batch-Ranking] 주간 랭킹 저장 성공 (yearWeek: {}, 저장 건수: {})", yearWeek, entities.size());
 
         } catch (Exception e) {
-            log.error("주간 랭킹 저장 중 오류 발생: yearWeek={}", yearWeek, e);
-            throw new RuntimeException("주간 랭킹 저장 실패", e);
+            // 상세한 컨텍스트를 포함한 에러 로그
+            log.error("[Batch-Ranking] 주간 랭킹 저장 중 예외 발생! (yearWeek: {}, 처리 중이던 건수: {}) - 원인: {}",
+                    yearWeek, targetCount, e.getMessage(), e);
+            throw e; // 예외를 그대로 던져서 Batch Step이 실패 상태가 되도록 위임
         }
     }
 
@@ -71,4 +74,4 @@ private WeeklyRankEntity convertToEntity(RankingAggregation aggregation) {
                 aggregation.getRankPosition()
         );
     }
-}
+}

modules/jpa/src/main/java/com/loopers/domain/ranking/MonthlyRankEntity.java

@@ -20,7 +20,7 @@
 @Table(
     name = "mv_product_rank_monthly",
     indexes = {
-        @Index(name = "idx_year_month_rank", columnList = "year_month, rank_position")
+        @Index(name = "idx_year_month_rank", columnList = "base_year_month, base_rank_position으로")
     }
 )
 @Getter
@@ -45,7 +45,7 @@ public class MonthlyRankEntity {
     @Column(name = "total_score", nullable = false)
     private long totalScore;
 
-    @Column(name = "rank_position", nullable = false)
+    @Column(name = "base_rank_position", nullable = false)
     private long rankPosition;
 
     @Column(name = "created_at", nullable = false)

modules/jpa/src/main/java/com/loopers/domain/ranking/MonthlyRankId.java

@@ -22,7 +22,7 @@ public class MonthlyRankId implements Serializable {
     @Column(name = "product_id", nullable = false)
     private Long productId;
 
-    @Column(name = "year_month", nullable = false, length = 7)
+    @Column(name = "base_year_month", nullable = false, length = 7)
     private String yearMonth;  // e.g., "2024-12"
 
     private MonthlyRankId(Long productId, String yearMonth) {