Merge pull request #233 from 42organization/fix/점수입력오류수정

[fix] 점수 입력 시 game table에 배타락 추가

Author: AYoungSn

src/main/java/com/gg/server/domain/game/data/GameRepository.java

@@ -7,11 +7,13 @@
 import java.util.Optional;
 
 import com.gg.server.domain.team.dto.GameUser;
+import javax.persistence.LockModeType;
 import org.springframework.cache.annotation.Cacheable;
 import org.springframework.data.jpa.repository.JpaRepository;
 import com.gg.server.domain.game.dto.GameTeamUser;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.domain.Slice;
+import org.springframework.data.jpa.repository.Lock;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.query.Param;
 
@@ -69,4 +71,7 @@ public interface GameRepository extends JpaRepository<Game, Long>, GameRepositor
             "team t, team_user tu, user u " +
             "WHERE g.id=t.game_id AND t.id = tu.team_id AND tu.user_id=u.id AND g.status = 'BEFORE'", nativeQuery = true)
     List<GameUser> findAllByStartTimeLessThanEqual(@Param("time") LocalDateTime time);
+    @Lock(LockModeType.PESSIMISTIC_WRITE)
+    @Query(value = "SELECT g FROM Game g WHERE g.id=:gamdId")
+    Optional<Game> findWithPessimisticLockById(@Param("gameId") Long gameId);
 }

src/main/java/com/gg/server/domain/game/service/GameService.java

@@ -60,7 +60,8 @@ public GameTeamInfo getUserGameInfo(Long gameId, Long userId) {
     })
     public Boolean createRankResult(RankResultReqDto scoreDto, Long userId) {
         // 현재 게임 id
-        Game game = gameFindService.findByGameId(scoreDto.getGameId());
+        Game game = gameRepository.findWithPessimisticLockById(scoreDto.getGameId())
+                .orElseThrow(GameNotExistException::new);
         if (game.getStatus() != StatusType.WAIT && game.getStatus() != StatusType.LIVE) {
             return false;
         }