refactor(cache): 캐시 키 및 페이로드 관련 코드 개선

- 일간 랭킹 키 생성 시 날짜 형식 변경
- EventType의 weight 필드를 final로 변경하여 불변성 강화
- 로그 메시지에서 잘못된 이벤트 타입 수정
- API 문서에서 날짜 형식 설명 업데이트

Author: hyujikoh

apps/commerce-api/src/main/java/com/loopers/interfaces/api/product/ProductV1ApiSpec.java

@@ -44,7 +44,7 @@ ApiResponse<PageResponse<ProductV1Dtos.ProductListResponse>> getProducts(
     })
     ApiResponse<PageResponse<ProductV1Dtos.ProductListResponse>> getRankingProducts(
             @PageableDefault(size = 20) Pageable pageable,
-            @Parameter(description = "조회 날짜 (yyyyMMdd 형식, 선택)", example = "20251223")
+            @Parameter(description = "조회 날짜 (yyyy-MM-dd 형식, 선택)", example = "2025-12-23")
             @RequestParam(required = false) LocalDate date
     );
 

apps/commerce-streamer/src/main/java/com/loopers/CommerceStreamerApplication.java

@@ -5,11 +5,13 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.context.properties.ConfigurationPropertiesScan;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 import jakarta.annotation.PostConstruct;
 
 @ConfigurationPropertiesScan
 @SpringBootApplication
+@EnableScheduling
 public class CommerceStreamerApplication {
     @PostConstruct
     public void started() {

apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/MetricsKafkaConsumer.java

@@ -91,7 +91,7 @@ public void onOrderEvents(
                         var result = eventProcessingFacade.processOrderEvent(record.value());
                         return (result.processed()) ? result.rankingScore() : null;
                     } catch (Exception e) {
-                        log.error("Failed to process catalog event", e);
+                        log.error("Failed to process order event", e);
                         return null;
                     }
                 }, executorService))

apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/MetricsKafkaConsumerTest.java

@@ -2,7 +2,6 @@
 
 import static org.mockito.ArgumentMatchers.*;
 import static org.mockito.Mockito.*;
-
 import java.util.List;
 
 import org.apache.kafka.clients.consumer.ConsumerRecord;
@@ -156,7 +155,10 @@ void shouldContinueProcessingWhenIndividualMessageFails() {
         consumer.onCatalogEvents(List.of(validRecord, invalidRecord), acknowledgment);
 
         // Then - 유효한 메시지는 처리되고, 전체 배치는 ack 되어야 함
-        verify(eventProcessingFacade, times(2)).processCatalogEvent(any());
+        verify(eventProcessingFacade, times(1)).updateRankingScores(
+                argThat(list -> list.size() == 1),
+                isNull()
+        );
         verify(acknowledgment, times(1)).acknowledge();
     }
 

modules/redis/src/main/java/com/loopers/cache/CacheKeyGenerator.java

@@ -135,7 +135,7 @@ private String generateSortString(Sort sort) {
     }
 
     /**
-     * 일간 랭킹 키 생성: ranking:all:20251223
+     * 일간 랭킹 키 생성: ranking:all:2025-12-23
      */
     public String generateDailyRankingKey(LocalDate date) {
         return new StringJoiner(DELIMITER)

modules/redis/src/main/java/com/loopers/cache/dto/CachePayloads.java

@@ -30,15 +30,11 @@ public enum EventType {
             LIKE_ACTION(0.2),     // 좋아요: Weight = 0.2, Score = 1
             PAYMENT_SUCCESS(0.6); // 주문: Weight = 0.6, Score = price * amount (정규화 시에는 log 적용도 가능)
 
-            private double weight;
+            private final double weight;
 
             EventType(double weight) {
                 this.weight = weight;
             }
-
-            public void setWeight(double weight) {
-                this.weight = weight;
-            }
         }
 
         /**
@@ -58,7 +54,7 @@ public static RankingScore forProductView(Long productId, long occurredAt) {
         }
 
         /**
-         * 좋아요 이벤트 생성 생성
+         * 좋아요 이벤트 생성
          */
         public static RankingScore forLikeAction(Long productId, long occurredAt) {
             return new RankingScore(productId, EventType.LIKE_ACTION, 1.0, occurredAt);