Feature: 교육 결승진출자, 우승자 계산, 재전송 API 구현

src/main/java/org/cotato/csquiz/api/education/controller/EducationController.java

@@ -13,6 +13,7 @@
 import org.cotato.csquiz.api.education.dto.WinnerInfoResponse;
 import org.cotato.csquiz.api.quiz.dto.KingMemberInfo;
 import org.cotato.csquiz.domain.education.service.EducationService;
+import org.cotato.csquiz.domain.education.service.KingMemberService;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -30,6 +31,7 @@
 public class EducationController {
 
     private final EducationService educationService;
+    private final KingMemberService kingMemberService;
 
     @GetMapping
     public ResponseEntity<List<AllEducationResponse>> findEducationListByGeneration(
@@ -60,15 +62,29 @@ public ResponseEntity<EducationIdOfQuizResponse> findEducationId(@RequestParam("
         return ResponseEntity.ok().body(educationService.findEducationIdOfQuizId(quizId));
     }
 
-    @GetMapping("/result/kings")
+    @GetMapping("/kings")
     public ResponseEntity<List<KingMemberInfo>> findFinalKingMembers(@RequestParam("educationId") Long educationId) {
         log.info("[{} 교육 결승진출자 조회 컨트롤러]", educationId);
-        return ResponseEntity.ok().body(educationService.findKingMemberInfo(educationId));
+        return ResponseEntity.ok().body(kingMemberService.findKingMemberInfo(educationId));
     }
 
-    @GetMapping("/result/winner")
+    @PostMapping("/kings")
+    public ResponseEntity<Void> calculateKingMembers(@RequestParam("educationId") Long educationId) {
+        log.info("[{} 교육 결승진출자 계산하기]", educationId);
+        kingMemberService.saveKingMember(educationId);
+        return ResponseEntity.noContent().build();
+    }
+
+    @GetMapping("/winner")
     public ResponseEntity<WinnerInfoResponse> findWinner(@RequestParam("educationId") Long educationId) {
         log.info("[{} 교육 우승자 조회 컨트롤러]", educationId);
-        return ResponseEntity.ok().body(educationService.findWinner(educationId));
+        return ResponseEntity.ok().body(kingMemberService.findWinner(educationId));
+    }
+
+    @PostMapping("/winner")
+    public ResponseEntity<Void> calculateWinner(@RequestParam("educationId") Long educationId) {
+        log.info("[{} 교육 우승자 계산]", educationId);
+        kingMemberService.calculateWinner(educationId);
+        return ResponseEntity.noContent().build();
     }
 }

src/main/java/org/cotato/csquiz/api/socket/controller/SocketController.java

@@ -15,6 +15,7 @@
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestHeader;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 @RestController
@@ -68,4 +69,19 @@ public ResponseEntity<Void> stopAllQuiz(@RequestBody @Valid EducationCloseReques
     public ResponseEntity<SocketTokenDto> makeSocketToken(@RequestHeader("Authorization") String authorizationHeader) {
         return ResponseEntity.ok(socketService.createSocketToken(authorizationHeader));
     }
+
+
+    @PostMapping("/kings")
+    public ResponseEntity<Void> sendKingCommand(@RequestParam("educationId") Long educationId) {
+        log.info("[{} 교육 결승진출자 재전송하기]", educationId);
+        socketService.sendKingCommand(educationId);
+        return ResponseEntity.noContent().build();
+    }
+
+    @PostMapping("/winner")
+    public ResponseEntity<Void> sendWinnerCommand(@RequestParam("educationId") Long educationId) {
+        log.info("[{} 교육 결승진출자 재전송하기]", educationId);
+        socketService.sendWinnerCommand(educationId);
+        return ResponseEntity.noContent().build();
+    }
 }

src/main/java/org/cotato/csquiz/api/socket/dto/EducationResultResponse.java

@@ -0,0 +1,13 @@
+package org.cotato.csquiz.api.socket.dto;
+
+import org.cotato.csquiz.domain.education.entity.Education;
+
+public record EducationResultResponse(
+        String command,
+        Long educationId
+) {
+    public static EducationResultResponse of(String command, Long educationId) {
+        return new EducationResultResponse(command, educationId);
+    }
+
+}

src/main/java/org/cotato/csquiz/api/socket/dto/QuizStopResponse.java

@@ -4,9 +4,11 @@ public record QuizStopResponse(
         String command,
         Long quizId
 ) {
-    public static QuizStopResponse from(String command, Long quizId) {
+    public static final String STOP_COMMAND = "stop";
+
+    public static QuizStopResponse from(Long quizId) {
         return new QuizStopResponse(
-                command,
+                STOP_COMMAND,
                 quizId
         );
     }

src/main/java/org/cotato/csquiz/common/error/ErrorCode.java

@@ -56,8 +56,12 @@ public enum ErrorCode {
 
     SUBJECT_INVALID(HttpStatus.BAD_REQUEST, "E-000", "교육 주제는 NULL이거나 비어있을 수 없습니다."),
 
+    KING_MEMBER_EXIST(HttpStatus.CONFLICT, "K-301", "이미 킹킹 멤버가 존재합니다"),
+
     ALREADY_REPLY_CORRECT(HttpStatus.BAD_REQUEST, "R-301", "해당 사용자는 이미 정답 처리되었습니다."),
 
+    LAST_QUIZ_SCORER_NOT_EXIST(HttpStatus.CONFLICT, "W-201", "아직 마지막 문제 득점자가 없습니다"),
+    WINNER_EXIST(HttpStatus.CONFLICT, "W-301", "이미 우승자가 존재합니다"),
     // 500 오류 -> 서버측에서 처리가 실패한 부분들
     WEBSOCKET_SEND_EXCEPTION(HttpStatus.INTERNAL_SERVER_ERROR, "S-001", "소캣 메세지 전송 실패"),
     IMAGE_PROCESSING_FAIL(HttpStatus.INTERNAL_SERVER_ERROR, "S-002", "이미지 처리에 실패했습니다."),

src/main/java/org/cotato/csquiz/common/websocket/WebSocketHandler.java

@@ -2,6 +2,7 @@
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.cotato.csquiz.api.socket.dto.CsQuizStopResponse;
+import org.cotato.csquiz.api.socket.dto.EducationResultResponse;
 import org.cotato.csquiz.api.socket.dto.QuizStartResponse;
 import org.cotato.csquiz.api.socket.dto.QuizStatusResponse;
 import org.cotato.csquiz.api.socket.dto.QuizStopResponse;
@@ -118,14 +119,23 @@ public void startQuiz(Long quizId) {
     }
 
     public void stopQuiz(Quiz quiz) {
-        String command = "";
-        if (quiz.getNumber() == 9) {
-            command = KING_COMMAND;
+        QuizStopResponse response = QuizStopResponse.from(quiz.getId());
+        for (WebSocketSession clientSession : CLIENTS.values()) {
+            sendMessage(clientSession, response);
         }
-        if (quiz.getNumber() == 10) {
-            command = WINNER_COMMAND;
+    }
+
+    public void sendKingMemberCommand(Long educationId) {
+        EducationResultResponse response = EducationResultResponse.of(KING_COMMAND, educationId);
+
+        for (WebSocketSession clientSession : CLIENTS.values()) {
+            sendMessage(clientSession, response);
         }
-        QuizStopResponse response = QuizStopResponse.from(command, quiz.getId());
+    }
+
+    public void sendWinnerCommand(Long educationId) {
+        EducationResultResponse response = EducationResultResponse.of(WINNER_COMMAND, educationId);
+
         for (WebSocketSession clientSession : CLIENTS.values()) {
             sendMessage(clientSession, response);
         }

src/main/java/org/cotato/csquiz/domain/education/repository/KingMemberRepository.java

@@ -7,4 +7,6 @@
 
 public interface KingMemberRepository extends JpaRepository<KingMember, Long> {
     List<KingMember> findAllByEducation(Education education);
+
+    boolean existsByEducation(Education education);
 }

src/main/java/org/cotato/csquiz/domain/education/repository/QuizRepository.java

@@ -1,5 +1,6 @@
 package org.cotato.csquiz.domain.education.repository;
 
+import org.cotato.csquiz.domain.education.entity.Education;
 import org.cotato.csquiz.domain.education.entity.Quiz;
 import org.cotato.csquiz.domain.education.enums.QuizStatus;
 import java.util.List;
@@ -29,4 +30,8 @@ public interface QuizRepository extends JpaRepository<Quiz, Long> {
     @Modifying
     @Query("select q from Quiz q where q.education.id in :educationIds")
     List<Quiz> findAllByEducationIdsInQuery(@Param("educationIds") List<Long> educationIds);
+
+    Optional<Quiz> findByEducationIdAndNumber(Long educationId, Integer i);
+
+    Optional<Quiz> findFirstByEducationOrderByNumberDesc(Education education);
 }

src/main/java/org/cotato/csquiz/domain/education/repository/WinnerRepository.java

@@ -7,4 +7,6 @@
 
 public interface WinnerRepository extends JpaRepository<Winner, Long> {
     Optional<Winner> findByEducation(Education education);
+
+    boolean existsByEducation(Education education);
 }

src/main/java/org/cotato/csquiz/domain/education/service/EducationService.java

@@ -36,11 +36,8 @@
 @Slf4j
 public class EducationService {
 
-    private final MemberService memberService;
     private final EducationRepository educationRepository;
-    private final KingMemberRepository kingMemberRepository;
     private final QuizRepository quizRepository;
-    private final WinnerRepository winnerRepository;
     private final SessionRepository sessionRepository;
 
     @Transactional
@@ -97,32 +94,6 @@ public List<AllEducationResponse> findEducationListByGeneration(Long generationI
                 .toList();
     }
 
-    public List<KingMemberInfo> findKingMemberInfo(Long educationId) {
-        Education findEducation = educationRepository.findById(educationId)
-                .orElseThrow(() -> new EntityNotFoundException("해당 교육을 찾을 수 없습니다."));
-        List<KingMember> kingMembers = kingMemberRepository.findAllByEducation(findEducation);
-        validateIsEmpty(kingMembers);
-        return kingMembers.stream()
-                .map(kingMember -> memberService.findById(kingMember.getMemberId()))
-                .map(member -> KingMemberInfo.from(member, memberService.findBackFourNumber(member)))
-                .toList();
-    }
-
-    private void validateIsEmpty(List<KingMember> kingMembers) {
-        if (kingMembers.isEmpty()) {
-            throw new EntityNotFoundException("아직 결승 진출자가 결정되지 않았습니다.");
-        }
-    }
-
-    public WinnerInfoResponse findWinner(Long educationId) {
-        Education findEducation = educationRepository.findById(educationId)
-                .orElseThrow(() -> new EntityNotFoundException("해당 교육을 찾을 수 없습니다."));
-        Winner findWinner = winnerRepository.findByEducation(findEducation)
-                .orElseThrow(() -> new EntityNotFoundException("해당 교육의 우승자를 찾을 수 없습니다."));
-        Member findMember = memberService.findById(findWinner.getMemberId());
-        return WinnerInfoResponse.of(findWinner, findMember, memberService.findBackFourNumber(findMember));
-    }
-
     public EducationIdOfQuizResponse findEducationIdOfQuizId(Long quizId) {
         Quiz quiz = quizRepository.findById(quizId)
                 .orElseThrow(() -> new EntityNotFoundException("해당 문제를 찾을 수 없습니다."));

src/main/java/org/cotato/csquiz/domain/education/service/KingMemberService.java

@@ -8,11 +8,16 @@
 import java.util.stream.Collectors;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.cotato.csquiz.api.education.dto.WinnerInfoResponse;
+import org.cotato.csquiz.api.quiz.dto.KingMemberInfo;
+import org.cotato.csquiz.common.error.ErrorCode;
+import org.cotato.csquiz.common.error.exception.AppException;
 import org.cotato.csquiz.domain.education.entity.Education;
 import org.cotato.csquiz.domain.education.entity.KingMember;
 import org.cotato.csquiz.domain.education.entity.Quiz;
 import org.cotato.csquiz.domain.education.entity.Scorer;
 import org.cotato.csquiz.domain.education.entity.Winner;
+import org.cotato.csquiz.domain.education.repository.EducationRepository;
 import org.cotato.csquiz.domain.education.repository.QuizRepository;
 import org.cotato.csquiz.domain.education.repository.ScorerRepository;
 import org.cotato.csquiz.domain.auth.entity.Member;
@@ -35,13 +40,20 @@ public class KingMemberService {
     private final KingMemberRepository kingMemberRepository;
     private final ScorerRepository scorerRepository;
     private final WinnerRepository winnerRepository;
+    private final EducationRepository educationRepository;
 
-    public List<KingMember> calculateKingMember(Education education) {
-        List<Member> members = findKingMembersFromEducation(education);
+    @Transactional
+    public void saveKingMember(Long educationId) {
+        Education education = findEducationById(educationId);
+
+        checkKingMemberExist(education);
 
-        return members.stream()
+        List<KingMember> kingMembers = findKingMembersFromEducation(education).stream()
                 .map(member -> KingMember.of(member, education))
                 .toList();
+
+        kingMemberRepository.saveAll(kingMembers);
+        saveWinnerIfKingMemberIsOne(education);
     }
 
     private List<Member> findKingMembersFromEducation(Education education) {
@@ -64,13 +76,7 @@ private List<Member> findKingMembers(List<Scorer> scorers) {
                 .toList();
     }
 
-    @Transactional
-    public void saveKingMembers(List<KingMember> kingMembers) {
-        kingMemberRepository.saveAll(kingMembers);
-    }
-
-    @Transactional
-    public void saveWinnerIfKingMemberIsOne(Education education) {
+    private void saveWinnerIfKingMemberIsOne(Education education) {
         List<KingMember> kingMembers = kingMemberRepository.findAllByEducation(education);
         if (kingMembers.size() == 1) {
             Member findMember = memberRepository.findById(kingMembers.get(0).getMemberId())
@@ -80,13 +86,18 @@ public void saveWinnerIfKingMemberIsOne(Education education) {
     }
 
     @Transactional
-    public void saveWinnerIfNoWinnerExist(Quiz quiz) {
-        Education education = quiz.getEducation();
-        if (isWinnerExist(education)) {
-            Scorer findScorer = scorerRepository.findByQuizId(quiz.getId())
-                    .orElseThrow(() -> new EntityNotFoundException("해당 퀴즈엔 득점자가 존재하지 않습니다."));
-            saveWinner(findScorer.getMemberId(), education);
+    public void calculateWinner(Long educationId) {
+        Education education = findEducationById(educationId);
+        if (winnerRepository.existsByEducation(education)) {
+            throw new AppException(ErrorCode.WINNER_EXIST);
         }
+
+        Quiz quiz = quizRepository.findFirstByEducationOrderByNumberDesc(education)
+                .orElseThrow(() -> new EntityNotFoundException("마지막 문제가 없습니다"));
+        Scorer lastQuizScorer = scorerRepository.findByQuizId(quiz.getId())
+                .orElseThrow(() -> new EntityNotFoundException("마지막 퀴즈 득점자가 존재하지 않습니다."));
+
+        saveWinner(lastQuizScorer.getMemberId(), education);
     }
 
     @Transactional
@@ -95,7 +106,40 @@ public void saveWinner(final Long memberId, final Education education) {
         winnerRepository.save(winner);
     }
 
-    public boolean isWinnerExist(Education education) {
-        return winnerRepository.findByEducation(education).isPresent();
+    public List<KingMemberInfo> findKingMemberInfo(Long educationId) {
+        Education findEducation = educationRepository.findById(educationId)
+                .orElseThrow(() -> new EntityNotFoundException("해당 교육을 찾을 수 없습니다."));
+        List<KingMember> kingMembers = kingMemberRepository.findAllByEducation(findEducation);
+        validateIsEmpty(kingMembers);
+        return kingMembers.stream()
+                .map(kingMember -> memberService.findById(kingMember.getMemberId()))
+                .map(member -> KingMemberInfo.from(member, memberService.findBackFourNumber(member)))
+                .toList();
+    }
+
+    private void validateIsEmpty(List<KingMember> kingMembers) {
+        if (kingMembers.isEmpty()) {
+            throw new EntityNotFoundException("아직 결승 진출자가 결정되지 않았습니다.");
+        }
+    }
+
+    public WinnerInfoResponse findWinner(Long educationId) {
+        Education findEducation = educationRepository.findById(educationId)
+                .orElseThrow(() -> new EntityNotFoundException("해당 교육을 찾을 수 없습니다."));
+        Winner findWinner = winnerRepository.findByEducation(findEducation)
+                .orElseThrow(() -> new EntityNotFoundException("해당 교육의 우승자를 찾을 수 없습니다."));
+        Member findMember = memberService.findById(findWinner.getMemberId());
+        return WinnerInfoResponse.of(findWinner, findMember, memberService.findBackFourNumber(findMember));
+    }
+
+    private Education findEducationById(Long educationId) {
+        return educationRepository.findById(educationId)
+                .orElseThrow(() -> new EntityNotFoundException("해당 교육 id:" + educationId + " 찾다가 에러 발생했습니다."));
+    }
+
+    private void checkKingMemberExist(Education education) {
+        if (kingMemberRepository.existsByEducation(education)) {
+            throw new AppException(ErrorCode.KING_MEMBER_EXIST);
+        }
     }
 }