[FIX] #232 admin 게임 관리 페이지에서 점수 수정 시 승패 수정 안되는 문제

src/main/java/com/gg/server/admin/game/controller/GameAdminController.java

@@ -4,6 +4,7 @@
 import com.gg.server.admin.game.dto.GameUserLogAdminReqDto;
 import com.gg.server.admin.game.dto.RankGamePPPModifyReqDto;
 import com.gg.server.admin.game.service.GameAdminService;
+import com.gg.server.domain.rank.redis.RankRedisService;
 import com.gg.server.global.dto.PageRequestDto;
 import com.gg.server.global.exception.ErrorCode;
 import com.gg.server.global.exception.custom.InvalidParameterException;
@@ -23,6 +24,7 @@
 @RequestMapping("/pingpong/admin/games")
 public class GameAdminController {
     private final GameAdminService gameAdminService;
+    private final RankRedisService rankRedisService;
 
     @GetMapping
     public GameLogListAdminResponseDto gameFindBySeasonId(@ModelAttribute @Valid PageRequestDto pageRequestDto) {
@@ -59,6 +61,7 @@ public ResponseEntity<Void> gameResultEdit(@Valid @RequestBody RankGamePPPModify
             throw new InvalidParameterException("점수를 잘못 입력했습니다.", ErrorCode.VALID_FAILED);
         }
         gameAdminService.rankResultEdit(reqDto, gameId);
+        rankRedisService.updateAllTier(gameId);
         return new ResponseEntity<Void>(HttpStatus.NO_CONTENT);
     }
 }

src/main/java/com/gg/server/admin/game/service/GameAdminService.java

@@ -23,9 +23,11 @@
 import com.gg.server.domain.season.data.Season;
 import com.gg.server.domain.season.exception.SeasonNotFoundException;
 import com.gg.server.domain.team.data.TeamUser;
+import com.gg.server.domain.tier.service.TierService;
 import com.gg.server.domain.user.data.User;
 import com.gg.server.domain.user.exception.UserNotFoundException;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.cache.annotation.CacheEvict;
 import org.springframework.cache.annotation.Caching;
 import org.springframework.data.domain.*;
@@ -38,6 +40,7 @@
 
 @Service
 @RequiredArgsConstructor
+@Slf4j
 public class GameAdminService {
 
     private final GameAdminRepository gameAdminRepository;
@@ -48,6 +51,7 @@ public class GameAdminService {
     private final RankRedisService rankRedisService;
     private final TeamUserAdminRepository teamUserAdminRepository;
     private final RedisMatchUserRepository redisMatchUserRepository;
+    private final TierService tierService;
 
     /**
      * <p>토너먼트 게임을 제외한 일반, 랭크 게임들을 찾아서 반환해준다.</p>
@@ -134,11 +138,15 @@ public void rankResultEdit(RankGamePPPModifyReqDto reqDto, Long gameId) {
                 throw new PChangeNotExistException();
             }
             rollbackGameResult(reqDto, season, teamUser, pChanges);
-            teamUserAdminRepository.flush();
             pChangeAdminRepository.delete(pChanges.get(0));
         }
+        for (TeamUser teamUser :
+                teamUsers) {
+            updateScore(reqDto, teamUser);
+        }
+        teamUserAdminRepository.flush();
         rankRedisService.updateRankRedis(teamUsers.get(0), teamUsers.get(1), game);
-        rankRedisService.updateAllTier(gameId);
+        tierService.updateAllTier(game.getSeason());
     }
 
     private void rollbackGameResult(RankGamePPPModifyReqDto reqDto, Season season, TeamUser teamUser, List<PChange> pChanges) {
@@ -154,6 +162,9 @@ private void rollbackGameResult(RankGamePPPModifyReqDto reqDto, Season season, T
             rankRedisService.rollbackRank(teamUser, pChanges.get(1).getPppResult(), season.getId());
             teamUser.getUser().updateExp(pChanges.get(1).getExp());
         }
+    }
+
+    private void updateScore(RankGamePPPModifyReqDto reqDto, TeamUser teamUser) {
         if (teamUser.getTeam().getId().equals(reqDto.getTeam1Id())) {
             teamUser.getTeam().updateScore(reqDto.getTeam1Score(), reqDto.getTeam1Score() > reqDto.getTeam2Score());
         } else if (teamUser.getTeam().getId().equals(reqDto.getTeam2Id())) {

src/main/java/com/gg/server/domain/rank/redis/RankRedisService.java

@@ -77,6 +77,7 @@ public void updatePPP(TeamUser teamuser, RankRedis myTeam, int enemyScore, Integ
         log.info("update after: intraId: " + teamuser.getUser().getIntraId() + ", win: db(" + rank.getWins()
                 + "), redis(" + myTeam.getWins() + "), losses: db(" + rank.getLosses()
                 + "), redis(" + myTeam.getLosses() + ")");
+        rankRepository.flush();
     }
 
     @Transactional
@@ -128,13 +129,14 @@ public void updateAllTier(Long gameId) {
         }
     }
 
+    @Transactional
     public void rollbackRank(TeamUser teamUser, int ppp, Long seasonId) {
         String hashkey = RedisKeyManager.getHashKey(seasonId);
         RankRedis myTeam = rankRedisRepository.findRankByUserId(hashkey, teamUser.getUser().getId());
-        int win = teamUser.getTeam().getWin() ? myTeam.getWins() - 1 : myTeam.getWins();
-        int losses = !teamUser.getTeam().getWin() ? myTeam.getLosses() - 1: myTeam.getLosses();
         Rank rank = rankRepository.findByUserIdAndSeasonId(myTeam.getUserId(), seasonId)
                 .orElseThrow(RankNotFoundException::new);
+        int win = teamUser.getTeam().getWin() ? rank.getWins() - 1 : rank.getWins();
+        int losses = !teamUser.getTeam().getWin() ? rank.getLosses() - 1: rank.getLosses();
         log.info("Before: userId: " + teamUser.getUser().getIntraId() + ", " + "ppp: rank("
                 + rank.getPpp() + "), redis(" + myTeam.getPpp() + "), win: " + myTeam.getWins()
                 + ", losses: " + myTeam.getLosses());