[volume-10] Collect, Stack, Zip

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

@@ -0,0 +1,62 @@
+package com.loopers.application.ranking;
+
+import com.loopers.domain.ranking.Period;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.core.ZSetOperations;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Set;
+
+@Component
+@RequiredArgsConstructor
+public class DailyRankingService {
+    private final StringRedisTemplate redisTemplate;
+
+    public RankingV1Dto.ProductRankingPageResponse getDailyRanking(String date, Period period, int page, int size) {
+        if (page < 1) page = 1;
+        if (size < 1) size = 20;
+
+        String key = "ranking:all:" + date;
+        ZSetOperations<String, String> zset = redisTemplate.opsForZSet();
+
+        Long total = zset.size(key);
+        long totalElements = (total == null) ? 0 : total;
+
+        if (totalElements == 0) {
+            return new RankingV1Dto.ProductRankingPageResponse(date, Period.DAILY, date, date, page, size, 0, 0, List.of());
+        }
+
+        long start = (long) (page - 1) * size;
+        long end = start + size - 1;
+
+        if (start >= totalElements) {
+            int totalPages = (int) Math.ceil((double) totalElements / size);
+            return new RankingV1Dto.ProductRankingPageResponse(date, Period.DAILY, date, date, page, size, totalElements, totalPages, List.of());
+        }
+
+        Set<ZSetOperations.TypedTuple<String>> tuples =
+                zset.reverseRangeWithScores(key, start, end);
+
+        List<RankingV1Dto.ProductRankingResponse> items = new ArrayList<>();
+        if (tuples != null) {
+            long rank = start + 1;
+            for (var t : tuples) {
+                String member = t.getValue();
+                Double score = t.getScore();
+                if (member == null || score == null) continue;
+
+                items.add(new RankingV1Dto.ProductRankingResponse(
+                        rank++,
+                        Long.parseLong(member),
+                        score
+                ));
+            }
+        }
+
+        int totalPages = (int) Math.ceil((double) totalElements / size);
+        return new RankingV1Dto.ProductRankingPageResponse(date, Period.DAILY, date, date, page, size, totalElements, totalPages, items);
+    }
+}

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

@@ -0,0 +1,90 @@
+package com.loopers.application.ranking;
+
+import com.loopers.domain.ranking.MonthlyRankingMv;
+import com.loopers.domain.ranking.MonthlyRankingRepository;
+import com.loopers.domain.ranking.Period;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.List;
+
+@Component
+@RequiredArgsConstructor
+public class MonthlyRankingService {
+    private static final DateTimeFormatter BASIC = DateTimeFormatter.BASIC_ISO_DATE;
+
+    private final MonthlyRankingRepository monthlyRankingRepository;
+
+    public RankingV1Dto.ProductRankingPageResponse getMonthlyTop100(String date, Period period, int page, int size) {
+        int safePage = Math.max(page, 1);
+        int safeSize = Math.max(size, 1);
+
+        LocalDate end = LocalDate.parse(date, BASIC);
+        String endDate = end.format(BASIC);
+
+        String startDate = end.minusDays(30).format(BASIC);
+
+        System.out.println("startDate = " + startDate);
+
+        long totalElements = monthlyRankingRepository.countMonthly(startDate, endDate);
+
+        if (totalElements == 0) {
+            return new RankingV1Dto.ProductRankingPageResponse(
+                    date,
+                    period,
+                    startDate,
+                    endDate,
+                    safePage,
+                    safeSize,
+                    0,
+                    0,
+                    List.of()
+            );
+        }
+
+        int totalPages = (int) Math.ceil((double) totalElements / safeSize);
+
+        long offset = (long) (safePage - 1) * safeSize;
+        if (offset >= totalElements) {
+            return new RankingV1Dto.ProductRankingPageResponse(
+                    date,
+                    period,
+                    startDate,
+                    endDate,
+                    safePage,
+                    safeSize,
+                    totalElements,
+                    totalPages,
+                    List.of()
+            );
+        }
+
+        List<MonthlyRankingMv> rows = monthlyRankingRepository.getMonthlyTop100(endDate, startDate, safePage, safeSize);
+
+        List<RankingV1Dto.ProductRankingResponse> items = new ArrayList<>(rows.size());
+        long rank = offset + 1;
+
+        for (MonthlyRankingMv row : rows) {
+            items.add(new RankingV1Dto.ProductRankingResponse(
+                    rank++,
+                    row.getProductId(),
+                    row.getScore().doubleValue()
+            ));
+        }
+
+        return new RankingV1Dto.ProductRankingPageResponse(
+                date,
+                period,
+                startDate,
+                endDate,
+                safePage,
+                safeSize,
+                totalElements,
+                totalPages,
+                items
+        );
+    }
+}

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

@@ -1,70 +1,31 @@
 package com.loopers.application.ranking;
 
-import com.loopers.interfaces.api.ranking.RankingV1Dto;
+import com.loopers.domain.ranking.Period;
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
 import lombok.RequiredArgsConstructor;
-import org.springframework.data.redis.core.StringRedisTemplate;
-import org.springframework.data.redis.core.ZSetOperations;
 import org.springframework.stereotype.Component;
 
-import java.time.LocalDate;
-import java.time.ZoneId;
-import java.time.format.DateTimeFormatter;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Set;
-
 @Component
 @RequiredArgsConstructor
 public class RankingFacade {
-    private final StringRedisTemplate redisTemplate;
-    private static final ZoneId KST = ZoneId.of("Asia/Seoul");
-    private static final DateTimeFormatter YYYYMMDD = DateTimeFormatter.BASIC_ISO_DATE;
-
-    public RankingV1Dto.ProductRankingPageResponse getDailyProductRanking(int page, int size) {
-        if (page < 1) page = 1;
-        if (size < 1) size = 20;
-
-        String date = LocalDate.now(KST).format(YYYYMMDD);
-
-        String key = "ranking:all:" + date;
-        ZSetOperations<String, String> zset = redisTemplate.opsForZSet();
-
-        Long total = zset.size(key);
-        long totalElements = (total == null) ? 0 : total;
-
-        if (totalElements == 0) {
-            return new RankingV1Dto.ProductRankingPageResponse(date, page, size, 0, 0, List.of());
-        }
-
-        long start = (long) (page - 1) * size;
-        long end = start + size - 1;
-
-        if (start >= totalElements) {
-            int totalPages = (int) Math.ceil((double) totalElements / size);
-            return new RankingV1Dto.ProductRankingPageResponse(date, page, size, totalElements, totalPages, List.of());
-        }
-
-        Set<ZSetOperations.TypedTuple<String>> tuples =
-                zset.reverseRangeWithScores(key, start, end);
-
-        List<RankingV1Dto.ProductRankingResponse> items = new ArrayList<>();
-        if (tuples != null) {
-            long rank = start + 1;
-            for (var t : tuples) {
-                String member = t.getValue();
-                Double score = t.getScore();
-                if (member == null || score == null) continue;
-
-                items.add(new RankingV1Dto.ProductRankingResponse(
-                        rank++,
-                        Long.parseLong(member),
-                        score
-                ));
+    private final DailyRankingService dailyRankingService;
+    private final WeeklyRankingService weeklyRankingService;
+    private final MonthlyRankingService monthlyRankingService;
+
+    public RankingV1Dto.ProductRankingPageResponse getProductRanking(String date, Period period, int page, int size) {
+        switch (period) {
+            case DAILY -> {
+                return dailyRankingService.getDailyRanking(date, period, page, size);
+            }
+            case WEEKLY -> {
+                return weeklyRankingService.getWeeklyTop100(date, period, page, size);
             }
+            case MONTHLY -> {
+                return monthlyRankingService.getMonthlyTop100(date, period, page, size);
+            }
+            default -> throw new CoreException(ErrorType.BAD_REQUEST, "지원하지 않는 기간입니다.");
         }
-
-        int totalPages = (int) Math.ceil((double) totalElements / size);
-        return new RankingV1Dto.ProductRankingPageResponse(date, page, size, totalElements, totalPages, items);
     }
 
 }

apps/commerce-api/src/main/java/com/loopers/interfaces/api/ranking/RankingV1Dto.java → apps/commerce-api/src/main/java/com/loopers/application/ranking/RankingV1Dto.java

@@ -1,20 +1,25 @@
-package com.loopers.interfaces.api.ranking;
-
-import java.util.List;
-
-public class RankingV1Dto {
-    public record ProductRankingResponse(
-            Long rank,
-            Long productId,
-            double score
-    ) {}
-
-    public record ProductRankingPageResponse(
-            String date,
-            int page,
-            int size,
-            long totalElements,
-            int totalPages,
-            List<ProductRankingResponse> items
-    ) {}
-}
+package com.loopers.application.ranking;
+
+import com.loopers.domain.ranking.Period;
+
+import java.util.List;
+
+public class RankingV1Dto {
+    public record ProductRankingResponse(
+            Long rank,
+            Long productId,
+            double score
+    ) {}
+
+    public record ProductRankingPageResponse(
+            String date,
+            Period period,
+            String startDate,
+            String endDate,
+            int page,
+            int size,
+            long totalElements,
+            int totalPages,
+            List<ProductRankingResponse> items
+    ) {}
+}

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

@@ -0,0 +1,91 @@
+package com.loopers.application.ranking;
+
+import com.loopers.domain.ranking.Period;
+import com.loopers.domain.ranking.WeeklyRankingMv;
+import com.loopers.domain.ranking.WeeklyRankingRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.List;
+
+@Component
+@RequiredArgsConstructor
+public class WeeklyRankingService {
+    private static final DateTimeFormatter BASIC = DateTimeFormatter.BASIC_ISO_DATE;
+
+    private final WeeklyRankingRepository weeklyRankingRepository;
+
+    public RankingV1Dto.ProductRankingPageResponse getWeeklyTop100(String date, Period period, int page, int size) {
+        int safePage = Math.max(page, 1);
+        int safeSize = Math.max(size, 1);
+
+        LocalDate end = LocalDate.parse(date, BASIC);
+        String endDate = end.format(BASIC);
+
+        String startDate = end.minusDays(6).format(BASIC);
+
+        System.out.println("startDate = " + startDate);
+
+        long totalElements = weeklyRankingRepository.countWeekly(startDate, endDate);
+
+        if (totalElements == 0) {
+            return new RankingV1Dto.ProductRankingPageResponse(
+                    date,
+                    period,
+                    startDate,
+                    endDate,
+                    safePage,
+                    safeSize,
+                    0,
+                    0,
+                    List.of()
+            );
+        }
+
+        int totalPages = (int) Math.ceil((double) totalElements / safeSize);
+
+        long offset = (long) (safePage - 1) * safeSize;
+        if (offset >= totalElements) {
+            return new RankingV1Dto.ProductRankingPageResponse(
+                    date,
+                    period,
+                    startDate,
+                    endDate,
+                    safePage,
+                    safeSize,
+                    totalElements,
+                    totalPages,
+                    List.of()
+            );
+        }
+
+        List<WeeklyRankingMv> rows = weeklyRankingRepository.getWeeklyTop100(endDate, startDate, safePage, safeSize);
+
+        List<RankingV1Dto.ProductRankingResponse> items = new ArrayList<>(rows.size());
+        long rank = offset + 1;
+
+        for (WeeklyRankingMv row : rows) {
+            items.add(new RankingV1Dto.ProductRankingResponse(
+                    rank++,
+                    row.getProductId(),
+                    row.getScore().doubleValue()
+            ));
+        }
+
+        return new RankingV1Dto.ProductRankingPageResponse(
+                date,
+                period,
+                startDate,
+                endDate,
+                safePage,
+                safeSize,
+                totalElements,
+                totalPages,
+                items
+        );
+    }
+
+}