[FEAT] 투표자 API 구현

src/main/java/com/debatetimer/config/ErrorDecoderConfig.java

@@ -0,0 +1,33 @@
+package com.debatetimer.config;
+
+import com.debatetimer.exception.decoder.H2ErrorDecoder;
+import com.debatetimer.exception.decoder.MySqlErrorDecoder;
+import com.debatetimer.exception.decoder.RepositoryErrorDecoder;
+import lombok.NoArgsConstructor;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
+
+@NoArgsConstructor(access = lombok.AccessLevel.PRIVATE)
+public class ErrorDecoderConfig {
+
+    @Profile({"dev", "prod"})
+    @Configuration
+    public static class MySqlErrorDecoderConfig {
+
+        @Bean
+        public RepositoryErrorDecoder mySqlErrorDecoder() {
+            return new MySqlErrorDecoder();
+        }
+    }
+
+    @Profile({"test", "local"})
+    @Configuration
+    public static class H2ErrorDecoderConfig {
+
+        @Bean
+        public RepositoryErrorDecoder h2ErrorDecoder() {
+            return new H2ErrorDecoder();
+        }
+    }
+}

src/main/java/com/debatetimer/controller/poll/VoteController.java

@@ -0,0 +1,37 @@
+package com.debatetimer.controller.poll;
+
+import com.debatetimer.dto.poll.request.VoteRequest;
+import com.debatetimer.dto.poll.response.VoteCreateResponse;
+import com.debatetimer.dto.poll.response.VoterPollInfoResponse;
+import com.debatetimer.service.poll.VoteService;
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.ResponseStatus;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequiredArgsConstructor
+public class VoteController {
+
+    private final VoteService voteService;
+
+    @GetMapping("/api/polls/{pollId}/votes")
+    @ResponseStatus(HttpStatus.OK)
+    public VoterPollInfoResponse getVotersPollInfo(@PathVariable long pollId) {
+        return voteService.getVoterPollInfo(pollId);
+    }
+
+    @PostMapping("/api/polls/{pollId}/votes")
+    @ResponseStatus(HttpStatus.CREATED)
+    public VoteCreateResponse votePoll(
+            @PathVariable long pollId,
+            @RequestBody @Valid VoteRequest voteRequest
+    ) {
+        return voteService.vote(pollId, voteRequest);
+    }
+}

src/main/java/com/debatetimer/domain/member/Member.java

@@ -1,6 +1,6 @@
 package com.debatetimer.domain.member;
 
-import com.debatetimer.entity.customize.BaseTimeEntity;
+import com.debatetimer.entity.BaseTimeEntity;
 import jakarta.persistence.Column;
 import jakarta.persistence.Entity;
 import jakarta.persistence.GeneratedValue;

src/main/java/com/debatetimer/domain/poll/Poll.java

@@ -26,4 +26,8 @@ public Poll(Long id, long tableId, long memberId, PollStatus status,
                 String prosTeamName, String consTeamName, String agenda) {
         this(id, tableId, memberId, status, new TeamName(prosTeamName), new TeamName(consTeamName), new Agenda(agenda));
     }
+
+    public boolean isProgress() {
+        return status.isProgress();
+    }
 }

src/main/java/com/debatetimer/domain/poll/PollStatus.java

@@ -5,4 +5,8 @@ public enum PollStatus {
     PROGRESS,
     DONE,
     ;
+
+    public boolean isProgress() {
+        return this == PROGRESS;
+    }
 }

src/main/java/com/debatetimer/domain/poll/Vote.java

@@ -13,6 +13,10 @@ public class Vote {
     private final ParticipantName name;
     private final ParticipateCode code;
 
+    public Vote(long pollId, VoteTeam team, String name, String code) {
+        this(null, pollId, team, name, code);
+    }
+
     public Vote(Long id, long pollId, VoteTeam team, String name, String code) {
         this(id, pollId, team, new ParticipantName(name), new ParticipateCode(code));
     }

src/main/java/com/debatetimer/domainrepository/poll/PollDomainRepository.java

@@ -2,8 +2,6 @@
 
 import com.debatetimer.domain.poll.Poll;
 import com.debatetimer.entity.poll.PollEntity;
-import com.debatetimer.exception.custom.DTClientErrorException;
-import com.debatetimer.exception.errorcode.ClientErrorCode;
 import com.debatetimer.repository.poll.PollRepository;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Repository;
@@ -24,19 +22,20 @@ public Poll create(Poll poll) {
 
     @Transactional(readOnly = true)
     public Poll getByIdAndMemberId(long id, long memberId) {
-        return findPoll(id, memberId)
+        return pollRepository.getByIdAndMemberId(id, memberId)
+                .toDomain();
+    }
+
+    @Transactional(readOnly = true)
+    public Poll getById(long id) {
+        return pollRepository.getById(id)
                 .toDomain();
     }
 
     @Transactional
     public Poll finishPoll(long pollId, long memberId) {
-        PollEntity pollEntity = findPoll(pollId, memberId);
+        PollEntity pollEntity = pollRepository.getByIdAndMemberId(pollId, memberId);
         pollEntity.updateToDone();
         return pollEntity.toDomain();
     }
-
-    private PollEntity findPoll(long pollId, long memberId) {
-        return pollRepository.findByIdAndMemberId(pollId, memberId)
-                .orElseThrow(() -> new DTClientErrorException(ClientErrorCode.POLL_NOT_FOUND));
-    }
 }

src/main/java/com/debatetimer/domainrepository/poll/VoteDomainRepository.java

@@ -1,20 +1,30 @@
 package com.debatetimer.domainrepository.poll;
 
+import com.debatetimer.domain.poll.ParticipateCode;
+import com.debatetimer.domain.poll.Vote;
 import com.debatetimer.domain.poll.VoteInfo;
 import com.debatetimer.domain.poll.VoteTeam;
+import com.debatetimer.entity.poll.PollEntity;
 import com.debatetimer.entity.poll.VoteEntity;
+import com.debatetimer.exception.custom.DTClientErrorException;
+import com.debatetimer.exception.decoder.RepositoryErrorDecoder;
+import com.debatetimer.exception.errorcode.ClientErrorCode;
+import com.debatetimer.repository.poll.PollRepository;
 import com.debatetimer.repository.poll.VoteRepository;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 import lombok.RequiredArgsConstructor;
+import org.springframework.dao.DataIntegrityViolationException;
 import org.springframework.stereotype.Repository;
 
 @Repository
 @RequiredArgsConstructor
 public class VoteDomainRepository {
 
+    private final PollRepository pollRepository;
     private final VoteRepository voteRepository;
+    private final RepositoryErrorDecoder errorDecoder;
 
     public VoteInfo findVoteInfoByPollId(long pollId) {
         List<VoteEntity> pollVotes = voteRepository.findAllByPollId(pollId);
@@ -28,4 +38,22 @@ private VoteInfo countVotes(long pollId, List<VoteEntity> voteEntities) {
         long consCount = teamCount.getOrDefault(VoteTeam.CONS, 0L);
         return new VoteInfo(pollId, prosCount, consCount);
     }
+
+    public boolean isExists(long pollId, ParticipateCode code) {
+        return voteRepository.existsByPollIdAndParticipateCode(pollId, code.getValue());
+    }
+
+    public Vote save(Vote vote) {
+        try {
+            PollEntity pollEntity = pollRepository.getById(vote.getPollId());
+            VoteEntity voteEntity = new VoteEntity(vote, pollEntity);
+            return voteRepository.save(voteEntity)
+                    .toDomain();
+        } catch (DataIntegrityViolationException exception) {
+            if (errorDecoder.isUniqueConstraintViolation(exception)) {
+                throw new DTClientErrorException(ClientErrorCode.ALREADY_VOTED_PARTICIPANT);
+            }
+            throw exception;
+        }
+    }
 }

src/main/java/com/debatetimer/domainrepository/poll/CustomizeTableDomainRepository.java → src/main/java/com/debatetimer/domainrepository/table/CustomizeTableDomainRepository.java

@@ -1,4 +1,4 @@
-package com.debatetimer.domainrepository.poll;
+package com.debatetimer.domainrepository.table;
 
 import com.debatetimer.domain.customize.CustomizeTable;
 import com.debatetimer.domain.member.Member;

src/main/java/com/debatetimer/dto/poll/request/VoteRequest.java

@@ -0,0 +1,13 @@
+package com.debatetimer.dto.poll.request;
+
+import com.debatetimer.domain.poll.VoteTeam;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+
+public record VoteRequest(
+        @NotBlank String name,
+        @NotBlank String participateCode,
+        @NotNull VoteTeam team
+) {
+
+}

src/main/java/com/debatetimer/dto/poll/response/VoteCreateResponse.java

@@ -0,0 +1,16 @@
+package com.debatetimer.dto.poll.response;
+
+import com.debatetimer.domain.poll.Vote;
+import com.debatetimer.domain.poll.VoteTeam;
+
+public record VoteCreateResponse(
+        long id,
+        String name,
+        String participateCode,
+        VoteTeam team
+) {
+
+    public VoteCreateResponse(Vote vote) {
+        this(vote.getId(), vote.getName().getValue(), vote.getCode().getValue(), vote.getTeam());
+    }
+}

src/main/java/com/debatetimer/dto/poll/response/VoterPollInfoResponse.java

@@ -0,0 +1,31 @@
+package com.debatetimer.dto.poll.response;
+
+import com.debatetimer.domain.poll.ParticipateCode;
+import com.debatetimer.domain.poll.Poll;
+import com.debatetimer.domain.poll.PollStatus;
+import com.debatetimer.domain.poll.VoteInfo;
+
+public record VoterPollInfoResponse(
+        long id,
+        PollStatus status,
+        String prosTeamName,
+        String consTeamName,
+        String participateCode,
+        long totalCount,
+        long prosCount,
+        long consCount
+) {
+
+    public VoterPollInfoResponse(Poll poll, VoteInfo voteInfo, ParticipateCode code) {
+        this(
+                poll.getId(),
+                poll.getStatus(),
+                poll.getProsTeamName().getValue(),
+                poll.getConsTeamName().getValue(),
+                code.getValue(),
+                voteInfo.getTotalCount(),
+                voteInfo.getProsCount(),
+                voteInfo.getConsCount()
+        );
+    }
+}

src/main/java/com/debatetimer/entity/customize/BaseTimeEntity.java → src/main/java/com/debatetimer/entity/BaseTimeEntity.java

@@ -1,4 +1,4 @@
-package com.debatetimer.entity.customize;
+package com.debatetimer.entity;
 
 import jakarta.persistence.EntityListeners;
 import jakarta.persistence.MappedSuperclass;

src/main/java/com/debatetimer/entity/customize/CustomizeTableEntity.java

@@ -3,6 +3,7 @@
 import com.debatetimer.domain.customize.CustomizeTable;
 import com.debatetimer.domain.member.Member;
 import com.debatetimer.dto.member.TableType;
+import com.debatetimer.entity.BaseTimeEntity;
 import jakarta.persistence.Entity;
 import jakarta.persistence.FetchType;
 import jakarta.persistence.GeneratedValue;
@@ -22,7 +23,7 @@
 @Getter
 @Table(name = "customize_table")
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
-public class CustomizeTableEntity {
+public class CustomizeTableEntity extends BaseTimeEntity {
 
     @Id
     @GeneratedValue(strategy = GenerationType.IDENTITY)

src/main/java/com/debatetimer/entity/poll/PollEntity.java

@@ -2,7 +2,7 @@
 
 import com.debatetimer.domain.poll.Poll;
 import com.debatetimer.domain.poll.PollStatus;
-import com.debatetimer.entity.customize.BaseTimeEntity;
+import com.debatetimer.entity.BaseTimeEntity;
 import jakarta.persistence.Column;
 import jakarta.persistence.Entity;
 import jakarta.persistence.EnumType;

src/main/java/com/debatetimer/entity/poll/VoteEntity.java

@@ -2,6 +2,7 @@
 
 import com.debatetimer.domain.poll.Vote;
 import com.debatetimer.domain.poll.VoteTeam;
+import jakarta.persistence.Column;
 import jakarta.persistence.Entity;
 import jakarta.persistence.EnumType;
 import jakarta.persistence.Enumerated;
@@ -12,6 +13,7 @@
 import jakarta.persistence.JoinColumn;
 import jakarta.persistence.ManyToOne;
 import jakarta.persistence.Table;
+import jakarta.persistence.UniqueConstraint;
 import jakarta.validation.constraints.NotBlank;
 import jakarta.validation.constraints.NotNull;
 import lombok.AccessLevel;
@@ -21,7 +23,9 @@
 
 @Entity
 @Getter
-@Table(name = "vote")
+@Table(name = "vote", uniqueConstraints = {
+        @UniqueConstraint(columnNames = {"poll_id", "participate_code"})
+})
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
 @AllArgsConstructor
 public class VoteEntity {
@@ -43,9 +47,14 @@ public class VoteEntity {
     private String name;
 
     @NotBlank
-    private String participantCode;
+    @Column(name = "participate_code")
+    private String participateCode;
+
+    public VoteEntity(Vote vote, PollEntity pollEntity) {
+        this(vote.getId(), pollEntity, vote.getTeam(), vote.getName().getValue(), vote.getCode().getValue());
+    }
 
     public Vote toDomain() {
-        return new Vote(id, poll.getId(), team, name, participantCode);
+        return new Vote(id, poll.getId(), team, name, participateCode);
     }
 }

src/main/java/com/debatetimer/exception/decoder/H2ErrorDecoder.java

@@ -0,0 +1,22 @@
+package com.debatetimer.exception.decoder;
+
+import org.hibernate.exception.ConstraintViolationException;
+import org.springframework.dao.DataIntegrityViolationException;
+
+public class H2ErrorDecoder implements RepositoryErrorDecoder {
+
+    protected static final String UNIQUE_CONSTRAINT_VIOLATION_SQL_STATE = "23505";
+
+    @Override
+    public boolean isUniqueConstraintViolation(DataIntegrityViolationException e) {
+        Throwable cause = e.getCause();
+        while (cause != null) {
+            if (cause instanceof ConstraintViolationException cve) {
+                String sqlState = cve.getSQLException().getSQLState();
+                return UNIQUE_CONSTRAINT_VIOLATION_SQL_STATE.equals(sqlState);
+            }
+            cause = cause.getCause();
+        }
+        return false;
+    }
+}

src/main/java/com/debatetimer/exception/decoder/MySqlErrorDecoder.java

@@ -0,0 +1,27 @@
+package com.debatetimer.exception.decoder;
+
+import java.sql.SQLException;
+import org.hibernate.exception.ConstraintViolationException;
+import org.springframework.dao.DataIntegrityViolationException;
+
+public class MySqlErrorDecoder implements RepositoryErrorDecoder {
+
+    protected static final String MYSQL_UNIQUE_VIOLATION = "23000";
+    protected static final int MYSQL_DUP_ERROR_CODE = 1062;
+
+    @Override
+    public boolean isUniqueConstraintViolation(DataIntegrityViolationException e) {
+        Throwable cause = e.getCause();
+        while (cause != null) {
+            if (cause instanceof ConstraintViolationException cve) {
+                SQLException sqlEx = cve.getSQLException();
+                String sqlState = sqlEx.getSQLState();
+                int errorCode = sqlEx.getErrorCode();
+                return MYSQL_UNIQUE_VIOLATION.equals(sqlState)
+                        && MYSQL_DUP_ERROR_CODE == errorCode;
+            }
+            cause = cause.getCause();
+        }
+        return false;
+    }
+}