Feat: 투표 상태 변경 로직 추가

Author: dlwls423

src/main/java/devkor/com/teamcback/domain/vote/repository/CustomVoteRepository.java

@@ -13,4 +13,6 @@ public interface CustomVoteRepository {
     List<Vote> getVoteByStatusWithPage(VoteStatus status, Long voteTopicId, int size);
 
     List<GetVoteOptionRes> getVoteOptionByVoteId(Long voteId);
+
+    List<GetVoteOptionRes> getVoteOptionByVoteIdOrderByCount(Long voteId);
 }

src/main/java/devkor/com/teamcback/domain/vote/repository/CustomVoteRepositoryImpl.java

@@ -100,6 +100,32 @@ public List<GetVoteOptionRes> getVoteOptionByVoteId(Long voteId) {
                 .fetch();
     }
 
+    @Override
+    public List<GetVoteOptionRes> getVoteOptionByVoteIdOrderByCount(Long voteId) {
+        return jpaQueryFactory
+                .select(
+                        new QGetVoteOptionRes(
+                                voteOption.id,
+                                voteOption.optionText,
+                                voteRecord.id.count().intValue()
+                        )
+                )
+                .from(vote)
+                .join(voteOption)
+                .on(vote.voteTopicId.eq(voteOption.voteTopicId))
+                .leftJoin(voteRecord)
+                .on(voteRecord.voteId.eq(vote.id)
+                        .and(voteRecord.voteOptionId.eq(voteOption.id)))
+                .where(
+                        vote.id.eq(voteId)
+                )
+                .groupBy(voteOption.id, voteOption.optionText)
+                .orderBy(
+                        voteRecord.id.count().intValue().asc()
+                )
+                .fetch();
+    }
+
     private BooleanExpression gtVoteCursor(Long lastVoteId) {
         if (lastVoteId== null) return null;
         return vote.id.gt(lastVoteId);

src/main/java/devkor/com/teamcback/domain/vote/service/VoteService.java

@@ -20,6 +20,7 @@
 
 import java.util.*;
 
+import static devkor.com.teamcback.domain.vote.entity.VoteStatus.CLOSED;
 import static devkor.com.teamcback.global.response.ResultCode.*;
 
 @Service
@@ -58,7 +59,7 @@ public GetVoteRes getVoteByPlace(Long voteTopicId, Long placeId) {
     /**
      * 투표 저장
      */
-    @UpdateScore(addScore = 2)
+    @UpdateScore(addScore = 3)
     @Transactional
     public SaveVoteRecordRes saveVoteRecord(Long userId, SaveVoteRecordReq req) {
         if(userId == null) throw new GlobalException(FORBIDDEN);
@@ -87,6 +88,12 @@ else if(!Objects.equals(voteRecord.getVoteOptionId(), voteOption.getId())){ // 
             voteRecord.setVoteOptionId(null); // 기존 투표 옵션을 null로 설정 (기록 남기기)
         }
 
+        // 투표 상태 변경
+        List<GetVoteOptionRes> voteOptionList = voteOptionRepository.getVoteOptionByVoteIdOrderByCount(vote.getId()); // 투표 항목, 현황
+        int min = voteOptionList.get(0).getVoteCount();
+        int max = voteOptionList.get(voteOptionList.size() - 1).getVoteCount();
+        if(max - min >= 30) vote.changeStatus(CLOSED);
+
         return new SaveVoteRecordRes();
     }