feat : 메인 or 랭킹화면 랭킹 구현(지난주,이번주,역대 TOP10)

pokerbearkr · pokerbearkr · commit 19b7bb64a437 · 2025-06-18T10:38:50.000+09:00
diff --git a/src/main/java/org/ezcode/codetest/application/ranking/dto/RankingResponse.java b/src/main/java/org/ezcode/codetest/application/ranking/dto/RankingResponse.java
@@ -0,0 +1,11 @@
+package org.ezcode.codetest.application.ranking.dto;
+
+import lombok.Builder;
+
+@Builder
+public record RankingResponse(
+        Long userId,
+        String nickname, // 사용자 이름
+        int rank,
+        int score
+) {}
diff --git a/src/main/java/org/ezcode/codetest/application/ranking/service/RankingFacadeService.java b/src/main/java/org/ezcode/codetest/application/ranking/service/RankingFacadeService.java
@@ -0,0 +1,31 @@
+package org.ezcode.codetest.application.ranking.service;
+
+import lombok.RequiredArgsConstructor;
+import org.ezcode.codetest.application.ranking.dto.RankingResponse;
+import org.ezcode.codetest.infrastructure.ranking.redis.RedisRankingService;
+import org.springframework.stereotype.Service;
+
+import java.time.DayOfWeek;
+import java.time.LocalDate;
+import java.util.List;
+
+@Service
+@RequiredArgsConstructor
+public class RankingFacadeService {
+
+    private final RedisRankingService redisRankingService;
+
+    public List<RankingResponse> getWeeklyRanking() {
+        LocalDate thisMonday = LocalDate.now().with(DayOfWeek.MONDAY);
+        return redisRankingService.getTopRankings("ranking:weekly:" + thisMonday, 10);
+    }
+
+    public List<RankingResponse> getLastWeekRanking() {
+        LocalDate lastMonday = LocalDate.now().with(DayOfWeek.MONDAY).minusWeeks(1);
+        return redisRankingService.getTopRankings("ranking:weekly:" + lastMonday, 10);
+    }
+
+    public List<RankingResponse> getAllTimeRanking() {
+        return redisRankingService.getTopRankings("ranking:all", 10);
+    }
+}
diff --git a/src/main/java/org/ezcode/codetest/domain/ranking/model/entity/Ranking.java b/src/main/java/org/ezcode/codetest/domain/ranking/model/entity/Ranking.java
@@ -0,0 +1,40 @@
+package org.ezcode.codetest.domain.ranking.model.entity;
+
+import jakarta.persistence.*;
+import lombok.AccessLevel;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import org.ezcode.codetest.common.base.entity.BaseEntity;
+import org.ezcode.codetest.domain.ranking.model.enums.RankingType;
+
+import java.time.LocalDate;
+
+@Entity
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class Ranking extends BaseEntity {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    private Long userId;
+
+    @Enumerated(EnumType.STRING)
+    private RankingType type; // WEEKLY, MONTHLY, ALL_TIME
+
+    private int rank;
+    private int score;
+
+    private LocalDate rankingDate; // 기준 날짜
+
+    @Builder
+    public Ranking(Long userId, RankingType type, int rank, int score, LocalDate rankingDate) {
+        this.userId = userId;
+        this.type = type;
+        this.rank = rank;
+        this.score = score;
+        this.rankingDate = rankingDate;
+    }
+}
diff --git a/src/main/java/org/ezcode/codetest/domain/ranking/model/enums/RankingType.java b/src/main/java/org/ezcode/codetest/domain/ranking/model/enums/RankingType.java
@@ -0,0 +1,5 @@
+package org.ezcode.codetest.domain.ranking.model.enums;
+
+public enum RankingType {
+    WEEKLY, MONTHLY, ALL_TIME
+}
diff --git a/src/main/java/org/ezcode/codetest/domain/ranking/repository/RankingRepository.java b/src/main/java/org/ezcode/codetest/domain/ranking/repository/RankingRepository.java
@@ -0,0 +1,13 @@
+package org.ezcode.codetest.domain.ranking.repository;
+
+import org.ezcode.codetest.domain.ranking.model.entity.Ranking;
+import org.ezcode.codetest.domain.ranking.model.enums.RankingType;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.time.LocalDate;
+import java.util.List;
+
+public interface RankingRepository extends JpaRepository<Ranking, Long> {
+
+    List<Ranking> findByTypeAndRankingDateOrderByRankAsc(RankingType type, LocalDate date);
+}
diff --git a/src/main/java/org/ezcode/codetest/domain/submission/repository/UserProblemResultRepository.java b/src/main/java/org/ezcode/codetest/domain/submission/repository/UserProblemResultRepository.java
@@ -1,13 +1,28 @@
 package org.ezcode.codetest.domain.submission.repository;
 
+import java.time.LocalDateTime;
+import java.util.List;
 import java.util.Optional;
 
 import org.ezcode.codetest.domain.submission.model.entity.UserProblemResult;
+import org.springframework.data.jpa.repository.Query;
+
 
 public interface UserProblemResultRepository {
 	Optional<UserProblemResult> findUserProblemResultByUserIdAndProblemId(Long userId, Long problemId);
 
 	void saveUserProblemResult(UserProblemResult userProblemResult);
 
 	void updateUserProblemResult(UserProblemResult userProblemResult, boolean isCorrect);
+
+	@Query("""
+    SELECT upr.user.id, SUM(p.score)
+    FROM UserProblemResult upr
+    JOIN upr.problem p
+    WHERE upr.isCorrect = true
+      AND (:start IS NULL OR upr.createdAt >= :start)
+      AND (:end IS NULL OR upr.createdAt < :end)
+    GROUP BY upr.user.id
+""")
+	List<Object[]> findScoresBetween(LocalDateTime start, LocalDateTime end);
 }
diff --git a/src/main/java/org/ezcode/codetest/domain/user/repository/UserRepository.java b/src/main/java/org/ezcode/codetest/domain/user/repository/UserRepository.java
@@ -19,4 +19,6 @@ public interface UserRepository {
 
 	boolean existsByNickname(String nickname);
 
+	User findById(Long id);
+
 }
diff --git a/src/main/java/org/ezcode/codetest/infrastructure/persistence/repository/submission/impl/UserProblemResultRepositoryImpl.java b/src/main/java/org/ezcode/codetest/infrastructure/persistence/repository/submission/impl/UserProblemResultRepositoryImpl.java
@@ -1,5 +1,7 @@
 package org.ezcode.codetest.infrastructure.persistence.repository.submission.impl;
 
+import java.time.LocalDateTime;
+import java.util.List;
 import java.util.Optional;
 
 import org.ezcode.codetest.domain.submission.model.entity.UserProblemResult;
@@ -29,4 +31,11 @@ public void saveUserProblemResult(UserProblemResult userProblemResult) {
 	public void updateUserProblemResult(UserProblemResult userProblemResult, boolean isCorrect) {
 		userProblemResult.updateResult(isCorrect);
 	}
+
+	@Override
+	public List<Object[]> findScoresBetween(LocalDateTime start, LocalDateTime end) {
+		return userProblemResultJpaRepository.findScoresBetween(start, end);
+	}
+
+
 }
diff --git a/src/main/java/org/ezcode/codetest/infrastructure/persistence/repository/submission/jpa/UserProblemResultJpaRepository.java b/src/main/java/org/ezcode/codetest/infrastructure/persistence/repository/submission/jpa/UserProblemResultJpaRepository.java
@@ -1,10 +1,25 @@
 package org.ezcode.codetest.infrastructure.persistence.repository.submission.jpa;
 
+import java.time.LocalDateTime;
+import java.util.List;
 import java.util.Optional;
 
 import org.ezcode.codetest.domain.submission.model.entity.UserProblemResult;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
 
 public interface UserProblemResultJpaRepository extends JpaRepository<UserProblemResult, Long> {
 	Optional<UserProblemResult> findByUserIdAndProblemId(Long userId, Long problemId);
+
+	@Query("""
+    SELECT upr.user.id, SUM(p.score)
+    FROM UserProblemResult upr
+    JOIN upr.problem p
+    WHERE upr.isCorrect = true
+      AND (:start IS NULL OR upr.createdAt >= :start)
+      AND (:end IS NULL OR upr.createdAt < :end)
+    GROUP BY upr.user.id
+""")
+	List<Object[]> findScoresBetween(LocalDateTime start, LocalDateTime end);
+
 }
diff --git a/src/main/java/org/ezcode/codetest/infrastructure/persistence/repository/user/UserRepositoryImpl.java b/src/main/java/org/ezcode/codetest/infrastructure/persistence/repository/user/UserRepositoryImpl.java
@@ -43,4 +43,9 @@ public boolean existsByNickname(String nickname) {
 		return userJpaRepository.existsByNickname(nickname);
 	}
 
+	@Override
+	public User findById(Long id) {
+		return userJpaRepository.findById(id).get();
+	}
+
 }
diff --git a/src/main/java/org/ezcode/codetest/infrastructure/ranking/redis/RedisRankingService.java b/src/main/java/org/ezcode/codetest/infrastructure/ranking/redis/RedisRankingService.java
@@ -0,0 +1,58 @@
+package org.ezcode.codetest.infrastructure.ranking.redis;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.ezcode.codetest.application.ranking.dto.RankingResponse;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.core.ZSetOperations;
+import org.springframework.stereotype.Service;
+
+import java.time.Duration;
+import java.time.LocalDate;
+import java.util.*;
+import java.util.stream.Collectors;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class RedisRankingService {
+
+    private final StringRedisTemplate redisTemplate;
+
+    private static final String WEEKLY_PREFIX = "ranking:weekly:";
+    private static final String ALLTIME_KEY = "ranking:all";
+
+    public void writeWeeklyRanking(Map<Long, Double> scoreMap, LocalDate monday) {
+        String key = WEEKLY_PREFIX + monday;
+        redisTemplate.delete(key);
+
+        scoreMap.forEach((userId, score) ->
+                redisTemplate.opsForZSet().add(key, userId.toString(), score)
+        );
+        redisTemplate.expire(key, Duration.ofDays(8));
+    }
+
+    public void writeAllTimeRanking(Map<Long, Double> scoreMap) {
+        redisTemplate.delete(ALLTIME_KEY);
+
+        scoreMap.forEach((userId, score) ->
+                redisTemplate.opsForZSet().add(ALLTIME_KEY, userId.toString(), score)
+        );
+    }
+
+    public List<RankingResponse> getTopRankings(String key, int limit) {
+        Set<ZSetOperations.TypedTuple<String>> raw = redisTemplate.opsForZSet()
+                .reverseRangeWithScores(key, 0, limit - 1);
+
+        if (raw == null) return List.of();
+
+        int[] rank = {1};
+        return raw.stream().map(tuple -> RankingResponse.builder()
+                .userId(Long.parseLong(tuple.getValue()))
+                .nickname("유저닉네임")
+                .rank(rank[0]++)
+                .score(tuple.getScore().intValue())
+                .build()
+        ).collect(Collectors.toList());
+    }
+}
diff --git a/src/main/java/org/ezcode/codetest/infrastructure/ranking/scheduler/RankingSyncScheduler.java b/src/main/java/org/ezcode/codetest/infrastructure/ranking/scheduler/RankingSyncScheduler.java
@@ -0,0 +1,64 @@
+package org.ezcode.codetest.infrastructure.ranking.scheduler;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.ezcode.codetest.domain.submission.repository.UserProblemResultRepository;
+import org.ezcode.codetest.infrastructure.ranking.redis.RedisRankingService;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.time.DayOfWeek;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class RankingSyncScheduler {
+
+    private final RedisRankingService redisRankingService;
+    private final UserProblemResultRepository resultRepository;
+
+    @Scheduled(cron = "0 0 * * * *") // 매시 정각
+    public void syncRankingsToRedis() {
+        LocalDate thisMonday = LocalDate.now().with(DayOfWeek.MONDAY);
+        LocalDate lastMonday = thisMonday.minusWeeks(1);
+
+        LocalDateTime thisWeekStart = thisMonday.atStartOfDay();
+        LocalDateTime lastWeekStart = lastMonday.atStartOfDay();
+        LocalDateTime lastWeekEnd = thisWeekStart;
+
+        // 지난주 랭킹 계산
+        List<Object[]> lastWeek = resultRepository.findScoresBetween(lastWeekStart, lastWeekEnd);
+        Map<Long, Double> lastWeekMap = lastWeek.stream()
+                .collect(Collectors.toMap(
+                        row -> (Long) row[0],
+                        row -> ((Number) row[1]).doubleValue()
+                ));
+        redisRankingService.writeWeeklyRanking(lastWeekMap, lastMonday);
+
+        // 이번주 랭킹 계산
+        List<Object[]> thisWeek = resultRepository.findScoresBetween(thisWeekStart, LocalDateTime.now());
+        Map<Long, Double> thisWeekMap = thisWeek.stream()
+                .collect(Collectors.toMap(
+                        row -> (Long) row[0],
+                        row -> ((Number) row[1]).doubleValue()
+                ));
+        redisRankingService.writeWeeklyRanking(thisWeekMap, thisMonday);
+
+
+        // 역대 랭킹 계산
+        List<Object[]> allTime = resultRepository.findScoresBetween(null, null);
+        Map<Long, Double> allMap = allTime.stream()
+                .collect(Collectors.toMap(
+                        row -> (Long) row[0],
+                        row -> ((Number) row[1]).doubleValue()
+                ));
+        redisRankingService.writeAllTimeRanking(allMap);
+
+        log.info("Redis 랭킹 갱신 완료: {}", LocalDateTime.now());
+    }
+}
diff --git a/src/main/java/org/ezcode/codetest/presentation/ranking/RankingController.java b/src/main/java/org/ezcode/codetest/presentation/ranking/RankingController.java
@@ -0,0 +1,42 @@
+package org.ezcode.codetest.presentation.ranking;
+
+import lombok.RequiredArgsConstructor;
+import org.ezcode.codetest.application.ranking.dto.RankingResponse;
+import org.ezcode.codetest.application.ranking.service.RankingFacadeService;
+import org.ezcode.codetest.infrastructure.ranking.scheduler.RankingSyncScheduler;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/api/rankings")
+@RequiredArgsConstructor
+public class RankingController {
+
+    private final RankingFacadeService rankingService;
+    private final RankingSyncScheduler rankingSyncScheduler;
+
+
+    @GetMapping("/weekly")
+    public List<RankingResponse> getWeekly() {
+        return rankingService.getWeeklyRanking();
+    }
+
+    @GetMapping("/last-week")
+    public List<RankingResponse> getLastWeek() {
+        return rankingService.getLastWeekRanking();
+    }
+
+    @GetMapping("/all-time")
+    public List<RankingResponse> getAllTime() {
+        return rankingService.getAllTimeRanking();
+    }
+
+    @PostMapping("/refresh-rankings")
+    public void forceRefreshRankings() {
+        rankingSyncScheduler.syncRankingsToRedis();
+    }
+}

Original file line number	Diff line number	Diff line change
`@@ -19,4 +19,6 @@ public interface UserRepository {`
`19`	`19`
`20`	`20`	`boolean existsByNickname(String nickname);`
`21`	`21`
	`22`	`+ User findById(Long id);`
	`23`	`+`
`22`	`24`	`}`
Original file line number	Diff line number	Diff line change
`@@ -43,4 +43,9 @@ public boolean existsByNickname(String nickname) {`
`43`	`43`	`return userJpaRepository.existsByNickname(nickname);`
`44`	`44`	`}`
`45`	`45`
	`46`	`+ @Override`
	`47`	`+ public User findById(Long id) {`
	`48`	`+ return userJpaRepository.findById(id).get();`
	`49`	`+ }`
	`50`	`+`
`46`	`51`	`}`