[feat] 게임 종료 후 전체 랭킹 업데이트 (#160)

* ✨ feat: 랭킹 업데이트 연결

* chore: Java 스타일 수정

* chore: Java 스타일 수정

* 🔧 chore: GameService 리팩토링

---------

Co-authored-by: github-actions <>

Author: silver-eunjoo

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

@@ -15,9 +15,12 @@
 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.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;
@@ -26,6 +29,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;
@@ -170,11 +175,12 @@ public void gameEnd(Room room) {
 
         Map<Long, Player> playerMap = room.getPlayerMap();
 
-        // TODO : 랭킹 정보 업데이트
-        messageSender.sendBroadcast(
-                destination,
-                MessageType.GAME_RESULT,
-                toGameResultListResponse(playerMap, room.getGameSetting().getRound()));
+        GameResultListResponse gameResultListResponse =
+                toGameResultListResponse(playerMap, room.getGameSetting().getRound());
+
+        messageSender.sendBroadcast(destination, MessageType.GAME_RESULT, gameResultListResponse);
+
+        updateRank(room, gameResultListResponse);
 
         room.initializeRound();
         room.initializePlayers();
@@ -200,6 +206,31 @@ 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 (room.isPlayerInState(playerId, ConnectionState.DISCONNECTED)) {
+                statService.updateRank(playerId, false, 0);
+                continue;
+            }
+
+            if (rank == 1) {
+                statService.updateRank(playerId, true, score);
+                continue;
+            }
+
+            statService.updateRank(playerId, false, score);
+        }
+    }
+
     @DistributedLock(prefix = "room", key = "#roomId")
     public void handlePlayerReady(Long roomId, UserPrincipal userPrincipal) {
 

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

@@ -1,3 +1,4 @@
 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,8 @@ 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

@@ -118,12 +118,7 @@ public List<Player> getDisconnectedPlayers() {
     }
 
     public void initializePlayers() {
-        this.playerMap
-                .values()
-                .forEach(
-                        player -> {
-                            player.initializeCorrectCount();
-                        });
+        this.playerMap.values().forEach(Player::initializeCorrectCount);
         resetAllPlayerReadyStates();
     }