✨ feat: 랭킹 업데이트 연결

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;
@@ -171,10 +176,15 @@ public void gameEnd(Room room) {
         Map<Long, Player> playerMap = room.getPlayerMap();
 
         // TODO : 랭킹 정보 업데이트
+		GameResultListResponse gameResultListResponse = toGameResultListResponse(playerMap,
+			room.getGameSetting().getRound());
+
         messageSender.sendBroadcast(
                 destination,
-                MessageType.GAME_RESULT,
-                toGameResultListResponse(playerMap, room.getGameSetting().getRound()));
+                MessageType.GAME_RESULT,gameResultListResponse
+                );
+
+        updateRank(room, gameResultListResponse);
 
         room.initializeRound();
         room.initializePlayers();
@@ -200,6 +210,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);
+
+		}
+	}
+
     @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,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

@@ -121,9 +121,7 @@ public void initializePlayers() {
         this.playerMap
                 .values()
                 .forEach(
-                        player -> {
-                            player.initializeCorrectCount();
-                        });
+					Player::initializeCorrectCount);
         resetAllPlayerReadyStates();
     }