refactor: 동적 랭킹 키 생성을 위한 RankingKeyGenerator 분리 및 commerce-streamer의 스케줄러 사용을 위한 RankingService 개선

- 동적이고 재사용 가능한 랭킹 키 생성을 위해 RankingKeyGenerator 인터페이스와 RedisRankingKeyGenerator 구현체 도입
- 유지보수성 향상을 위해 RankingService에서 RankingKeyGenerator를 사용하도록 리팩토링
- commerce-api에 있던 중복 carryOverRanking 로직 제거 후 commerce-streamer 모듈로 통합
- 리팩토링된 RankingService를 사용하도록 RankingScheduler 수정

Author: yeonjiyeon

apps/commerce-api/src/main/java/com/loopers/infrastructure/rank/RankingService.java

@@ -41,14 +41,4 @@ public Integer getProductRank(Long productId) {
 
     return (rank != null) ? rank.intValue() + 1 : null;
   }
-
-  public void carryOverRanking(String sourceDate, String targetDate, double weight) {
-    String sourceKey = "ranking:all:" + sourceDate;
-    String targetKey = "ranking:all:" + targetDate;
-
-    redisTemplate.opsForZSet().unionAndStore(sourceKey, List.of(), targetKey,
-        Aggregate.SUM, Weights.of(weight));
-
-    redisTemplate.expire(targetKey, 2, TimeUnit.DAYS);
-  }
 }

…s/application/rank/RankingScheduler.java …s/application/rank/RankingScheduler.javaapps/commerce-api/src/main/java/com/loopers/application/rank/RankingScheduler.java renamed to apps/commerce-streamer/src/main/java/com/loopers/application/rank/RankingScheduler.java apps/commerce-api/src/main/java/com/loopers/application/rank/RankingScheduler.java renamed to apps/commerce-streamer/src/main/java/com/loopers/application/rank/RankingScheduler.java

@@ -1,6 +1,6 @@
 package com.loopers.application.rank;
 
-import com.loopers.infrastructure.rank.RankingService;
+import com.loopers.domain.rank.RankingService;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import lombok.RequiredArgsConstructor;

apps/commerce-streamer/src/main/java/com/loopers/domain/rank/RankingKeyGenerator.java

@@ -0,0 +1,9 @@
+package com.loopers.domain.rank;
+
+import org.springframework.stereotype.Component;
+
+public interface RankingKeyGenerator {
+
+  String generateDailyKey(String date);
+}
+

apps/commerce-streamer/src/main/java/com/loopers/domain/rank/RankingService.java

@@ -2,9 +2,12 @@
 
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
+import java.util.List;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 import lombok.RequiredArgsConstructor;
+import org.springframework.data.redis.connection.zset.Aggregate;
+import org.springframework.data.redis.connection.zset.Weights;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Component;
 
@@ -13,14 +16,13 @@
 public class RankingService {
 
   private final RedisTemplate<String, String> redisTemplate;
-
-  private static final String KEY_PREFIX = "ranking:all:";
+  private final RankingKeyGenerator rankingKeyGenerator;
   private static final double VIEW_WEIGHT = 0.1;
   private static final double LIKE_WEIGHT = 0.2;
   private static final double ORDER_WEIGHT = 0.6;
 
   public void addScore(Long productId, double baseScore, double weight, LocalDateTime dateTime) {
-    String dateKey = KEY_PREFIX + dateTime.format(DateTimeFormatter.ofPattern("yyyyMMdd"));
+    String dateKey = rankingKeyGenerator.generateDailyKey(dateTime.format(DateTimeFormatter.ofPattern("yyyyMMdd")));
     double finalScore = baseScore * weight;
 
     redisTemplate.opsForZSet().incrementScore(dateKey, productId.toString(), finalScore);
@@ -35,4 +37,14 @@ public void addOrderScoresBatch(Map<String, Map<Long, Double>> updates) {
       redisTemplate.expire(dateKey, 2, TimeUnit.DAYS);
     });
   }
+
+  public void carryOverRanking(String sourceDate, String targetDate, double weight) {
+    String sourceKey = rankingKeyGenerator.generateDailyKey(sourceDate);
+    String targetKey = rankingKeyGenerator.generateDailyKey(targetDate);
+
+    redisTemplate.opsForZSet().unionAndStore(sourceKey, List.of(), targetKey,
+        Aggregate.SUM, Weights.of(weight));
+
+    redisTemplate.expire(targetKey, 2, TimeUnit.DAYS);
+  }
 }

apps/commerce-streamer/src/main/java/com/loopers/domain/rank/RedisRankingKeyGenerator.java

@@ -0,0 +1,14 @@
+package com.loopers.domain.rank;
+
+import org.springframework.stereotype.Component;
+
+@Component
+public class RedisRankingKeyGenerator implements RankingKeyGenerator {
+
+  private static final String DAILY_RANKING_PREFIX = "ranking:all:";
+
+  @Override
+  public String generateDailyKey(String date) {
+    return DAILY_RANKING_PREFIX + date;
+  }
+}