✨ feat: 랭킹 업데이트 연결

Author: silver-eunjoo

backend/src/main/java/io/f1/backend/domain/game/app/GameService.java

@@ -15,10 +15,13 @@
 import io.f1.backend.domain.game.dto.MessageType;
 import io.f1.backend.domain.game.dto.RoomEventType;
 import io.f1.backend.domain.game.dto.request.GameSettingChanger;
+import io.f1.backend.domain.game.dto.response.GameResultListResponse;
+import io.f1.backend.domain.game.dto.response.GameResultResponse;
 import io.f1.backend.domain.game.dto.response.PlayerListResponse;
 import io.f1.backend.domain.game.event.GameCorrectAnswerEvent;
 import io.f1.backend.domain.game.event.GameTimeoutEvent;
 import io.f1.backend.domain.game.event.RoomUpdatedEvent;
+import io.f1.backend.domain.game.model.ConnectionState;
 import io.f1.backend.domain.game.model.Player;
 import io.f1.backend.domain.game.model.Room;
 import io.f1.backend.domain.game.model.RoomState;
@@ -27,6 +30,7 @@
 import io.f1.backend.domain.question.entity.Question;
 import io.f1.backend.domain.quiz.app.QuizService;
 import io.f1.backend.domain.quiz.entity.Quiz;
+import io.f1.backend.domain.stat.app.StatService;
 import io.f1.backend.domain.user.dto.UserPrincipal;
 import io.f1.backend.global.exception.CustomException;
 import io.f1.backend.global.exception.errorcode.GameErrorCode;
@@ -52,6 +56,7 @@ public class GameService {
     private static final int CONTINUE_DELAY = 3;
     private static final String NONE_CORRECT_USER = "";
 
+    private final StatService statService;
     private final QuizService quizService;
     private final RoomService roomService;
     private final TimerService timerService;
@@ -167,10 +172,15 @@ public void gameEnd(Room room) {
         Map<String, Player> playerSessionMap = room.getPlayerSessionMap();
 
         // TODO : 랭킹 정보 업데이트
+        GameResultListResponse gameResultListResponse = toGameResultListResponse(playerSessionMap,
+            room.getRound());
+
         messageSender.sendBroadcast(
                 destination,
                 MessageType.GAME_RESULT,
-                toGameResultListResponse(playerSessionMap, room.getGameSetting().getRound()));
+                toGameResultListResponse(playerSessionMap, room.getRound()));
+
+        updateRank(room, gameResultListResponse);
 
         room.initializeRound();
         room.initializePlayers();
@@ -196,6 +206,32 @@ public void gameEnd(Room room) {
                 destination, MessageType.ROOM_SETTING, toRoomSettingResponse(room));
     }
 
+    private void updateRank(Room room, GameResultListResponse gameResultListResponse) {
+
+        List<GameResultResponse> result = gameResultListResponse.result();
+
+        for(GameResultResponse gameResultResponse : result) {
+            Long playerId = gameResultResponse.id();
+            int rank = gameResultResponse.rank();
+            int score = gameResultResponse.score();
+
+            Player player = room.getPlayerByUserId(playerId);
+
+            if (Objects.equals(player.getState(), ConnectionState.DISCONNECTED)) {
+                statService.updateRank(playerId, false, 0);
+                continue;
+            }
+
+            if(rank == 1) {
+                statService.updateRank(playerId, true, score);
+                continue;
+            }
+
+            statService.updateRank(playerId, false, score);
+
+        }
+    }
+
     public void handlePlayerReady(Long roomId, String sessionId) {
 
         Room room = findRoom(roomId);

backend/src/main/java/io/f1/backend/domain/game/dto/response/GameResultResponse.java

@@ -1,3 +1,3 @@
 package io.f1.backend.domain.game.dto.response;
 
-public record GameResultResponse(String nickname, int score, int totalCorrectCount, int rank) {}
+public record GameResultResponse(Long id, String nickname, int score, int totalCorrectCount, int rank) {}

backend/src/main/java/io/f1/backend/domain/game/mapper/RoomMapper.java

@@ -121,7 +121,7 @@ public static GameResultResponse toGameResultResponse(
         double correctRate = (double) player.getCorrectCount() / round;
         int score = (int) (correctRate * 100) + (totalPlayers - rank) * 5;
 
-        return new GameResultResponse(player.nickname, score, player.getCorrectCount(), rank);
+        return new GameResultResponse(player.id, player.nickname, score, player.getCorrectCount(), rank);
     }
 
     public static GameResultListResponse toGameResultListResponse(

backend/src/main/java/io/f1/backend/domain/game/model/Room.java

@@ -142,6 +142,11 @@ public void initializePlayers() {
         resetAllPlayerReadyStates();
     }
 
+    public Player getPlayerByUserId(Long userId) {
+        String sessionId = getSessionIdByUserId(userId);
+        return playerSessionMap.get(sessionId);
+    }
+
     public String getSessionIdByUserId(Long userId) {
         for (Map.Entry<String, Player> entry : playerSessionMap.entrySet()) {
             if (entry.getValue().getId().equals(userId)) {