버튼게임 수정사항

gsmgogo-api/src/main/java/team/gsmgogo/domain/game/service/impl/ButtonGameServiceImpl.java

@@ -5,6 +5,8 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Isolation;
 import org.springframework.transaction.annotation.Transactional;
+import team.gsmgogo.domain.bet.entity.BetEntity;
+import team.gsmgogo.domain.bet.repository.BetJpaRepository;
 import team.gsmgogo.domain.buttongame.entity.ButtonGameEntity;
 import team.gsmgogo.domain.buttongame.repository.ButtonGameRepository;
 import team.gsmgogo.domain.buttongameparticipate.entity.ButtonGameParticipate;
@@ -15,13 +17,19 @@
 import team.gsmgogo.global.exception.error.ExpectedException;
 import team.gsmgogo.global.facade.UserFacade;
 
+import java.util.List;
+import java.util.concurrent.atomic.AtomicInteger;
+
 @Service
 @RequiredArgsConstructor
 public class ButtonGameServiceImpl implements ButtonGameService {
 
     private final UserFacade userFacade;
     private final ButtonGameRepository buttonGameRepository;
     private final ButtonGameParticipateRepository buttonGameParticipateRepository;
+    private final BetJpaRepository buttonGameParticipate;
+
+    private final int LIMIT_POINT = 500_000;
 
     @Override
     @Transactional(isolation = Isolation.SERIALIZABLE)
@@ -35,6 +43,15 @@ public void execute(ButtonGameRequest request) {
         if (buttonGameParticipateRepository.existsByButtonGameAndUser(buttonGame, currentUser))
             throw new ExpectedException("이미 버튼을 눌렀습니다.", HttpStatus.BAD_REQUEST);
 
+        AtomicInteger betPoint = new AtomicInteger();
+        buttonGameParticipate.findByUser(currentUser)
+                .stream()
+                .filter(bet -> !bet.getMatch().getIsEnd()).toList()
+                .forEach(bet -> betPoint.addAndGet(bet.getBetPoint().intValue()));
+
+        if ((currentUser.getPoint() + betPoint.get()) >= LIMIT_POINT)
+            throw new ExpectedException("50만 포인트 이상 보유한 유저는 버튼게임에 참여할 수 없습니다.", HttpStatus.BAD_REQUEST);
+
         ButtonGameParticipate buttonGameParticipate = ButtonGameParticipate.builder()
                 .buttonGame(buttonGame)
                 .user(currentUser)

gsmgogo-batch/src/main/java/team/gsmgogo/scheduler/ButtonGameCalculateScheduler.java

@@ -31,21 +31,22 @@ public class ButtonGameCalculateScheduler {
     private final UserJpaRepository userJpaRepository;
     private final ButtonGameParticipateQueryDslRepository buttonGameParticipateQueryDslRepository;
 
-    @Scheduled(cron = "0 0 23 * * *")
-    public void start() throws JobInstanceAlreadyCompleteException, JobExecutionAlreadyRunningException, JobParametersInvalidException, JobRestartException {
+//    @Scheduled(cron = "0 0 23 * * *")
+//    public void start() throws JobInstanceAlreadyCompleteException, JobExecutionAlreadyRunningException, JobParametersInvalidException, JobRestartException {
+//
+//        Map<String, JobParameter<?>> jobParametersMap = new HashMap<>();
+//        jobParametersMap.put("button-game-time", new JobParameter(System.currentTimeMillis(), String.class));
+//        JobParameters jobParameters = new JobParameters(jobParametersMap);
+//
+//        jobLauncher.run(
+//                new CalculateButtonGameJob(
+//                        jobRepository,
+//                        platformTransactionManager,
+//                        buttonGameRepository,
+//                        userJpaRepository,
+//                        buttonGameParticipateQueryDslRepository).calculateButtonGameJob(),
+//                jobParameters
+//        );
+//    }
 
-        Map<String, JobParameter<?>> jobParametersMap = new HashMap<>();
-        jobParametersMap.put("button-game-time", new JobParameter(System.currentTimeMillis(), String.class));
-        JobParameters jobParameters = new JobParameters(jobParametersMap);
-
-        jobLauncher.run(
-                new CalculateButtonGameJob(
-                        jobRepository,
-                        platformTransactionManager,
-                        buttonGameRepository,
-                        userJpaRepository,
-                        buttonGameParticipateQueryDslRepository).calculateButtonGameJob(),
-                jobParameters
-        );
-    }
 }