[FEAT] 투표 개최자 API 구현

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

@@ -0,0 +1,49 @@
+package com.debatetimer.controller.poll;
+
+import com.debatetimer.controller.auth.AuthMember;
+import com.debatetimer.domain.member.Member;
+import com.debatetimer.dto.poll.response.PollCreateResponse;
+import com.debatetimer.dto.poll.response.PollInfoResponse;
+import com.debatetimer.service.poll.PollService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PatchMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.ResponseStatus;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequiredArgsConstructor
+public class PollController {
+
+    private final PollService pollService;
+
+    @PostMapping("/api/polls/{tableId}")
+    @ResponseStatus(HttpStatus.CREATED)
+    public PollCreateResponse createPoll(
+            @AuthMember Member member,
+            @PathVariable(name = "tableId") long tableId
+    ) {
+        return pollService.create(tableId, member);
+    }
+
+    @GetMapping("/api/polls/{pollId}")
+    @ResponseStatus(HttpStatus.OK)
+    public PollInfoResponse getPollInfo(
+            @AuthMember Member member,
+            @PathVariable(name = "pollId") long pollId
+    ) {
+        return pollService.getPollInfo(pollId, member);
+    }
+
+    @PatchMapping("/api/polls/{pollId}")
+    @ResponseStatus(HttpStatus.OK)
+    public PollInfoResponse finishPoll(
+            @AuthMember Member member,
+            @PathVariable(name = "pollId") long pollId
+    ) {
+        return pollService.finishPoll(pollId, member);
+    }
+}

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

@@ -0,0 +1,22 @@
+package com.debatetimer.domain.poll;
+
+import com.debatetimer.exception.custom.DTClientErrorException;
+import com.debatetimer.exception.errorcode.ClientErrorCode;
+import lombok.Getter;
+
+@Getter
+public class ParticipantName {
+
+    private final String value;
+
+    public ParticipantName(String value) {
+        validateName(value);
+        this.value = value;
+    }
+
+    private void validateName(String value) {
+        if (value == null || value.isBlank()) {
+            throw new DTClientErrorException(ClientErrorCode.INVALID_POLL_PARTICIPANT_NAME);
+        }
+    }
+}

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

@@ -0,0 +1,22 @@
+package com.debatetimer.domain.poll;
+
+import com.debatetimer.exception.custom.DTClientErrorException;
+import com.debatetimer.exception.errorcode.ClientErrorCode;
+import lombok.Getter;
+
+@Getter
+public class ParticipateCode {
+
+    private final String value;
+
+    public ParticipateCode(String value) {
+        validateName(value);
+        this.value = value;
+    }
+
+    private void validateName(String value) {
+        if (value == null || value.isBlank()) {
+            throw new DTClientErrorException(ClientErrorCode.INVALID_POLL_PARTICIPANT_CODE);
+        }
+    }
+}

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

@@ -0,0 +1,29 @@
+package com.debatetimer.domain.poll;
+
+import com.debatetimer.domain.customize.Agenda;
+import com.debatetimer.domain.customize.TeamName;
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@Getter
+@RequiredArgsConstructor
+public class Poll {
+
+    private final Long id;
+    private final long tableId;
+    private final long memberId;
+    private final PollStatus status;
+    private final TeamName prosTeamName;
+    private final TeamName consTeamName;
+    private final Agenda agenda;
+
+    public Poll(long tableId, long memberId, String prosTeamName, String consTeamName, String agenda) {
+        this(null, tableId, memberId, PollStatus.PROGRESS,
+                new TeamName(prosTeamName), new TeamName(consTeamName), new Agenda(agenda));
+    }
+
+    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));
+    }
+}

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

@@ -0,0 +1,19 @@
+package com.debatetimer.domain.poll;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@Getter
+@RequiredArgsConstructor
+public class Vote {
+
+    private final Long id;
+    private final long pollId;
+    private final VoteTeam team;
+    private final ParticipantName name;
+    private final ParticipateCode 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/domain/poll/VoteInfo.java

@@ -0,0 +1,19 @@
+package com.debatetimer.domain.poll;
+
+import lombok.Getter;
+
+@Getter
+public class VoteInfo {
+
+    private final long pollId;
+    private final long totalCount;
+    private final long prosCount;
+    private final long consCount;
+
+    public VoteInfo(long pollId, long prosCount, long consCount) {
+        this.pollId = pollId;
+        this.totalCount = prosCount + consCount;
+        this.prosCount = prosCount;
+        this.consCount = consCount;
+    }
+}

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

@@ -0,0 +1,24 @@
+package com.debatetimer.domainrepository.poll;
+
+import com.debatetimer.domain.customize.CustomizeTable;
+import com.debatetimer.domain.member.Member;
+import com.debatetimer.exception.custom.DTClientErrorException;
+import com.debatetimer.exception.errorcode.ClientErrorCode;
+import com.debatetimer.repository.customize.CustomizeTableRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Repository;
+import org.springframework.transaction.annotation.Transactional;
+
+@Repository
+@RequiredArgsConstructor
+public class CustomizeTableDomainRepository {
+
+    private final CustomizeTableRepository customizeTableRepository;
+
+    @Transactional(readOnly = true)
+    public CustomizeTable getByIdAndMember(long tableId, Member member) {
+        return customizeTableRepository.findByIdAndMember(tableId, member)
+                .orElseThrow(() -> new DTClientErrorException(ClientErrorCode.TABLE_NOT_FOUND))
+                .toDomain();
+    }
+}

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

@@ -0,0 +1,42 @@
+package com.debatetimer.domainrepository.poll;
+
+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;
+import org.springframework.transaction.annotation.Transactional;
+
+@Repository
+@RequiredArgsConstructor
+public class PollDomainRepository {
+
+    private final PollRepository pollRepository;
+
+    @Transactional
+    public Poll create(Poll poll) {
+        PollEntity pollEntity = new PollEntity(poll);
+        return pollRepository.save(pollEntity)
+                .toDomain();
+    }
+
+    @Transactional(readOnly = true)
+    public Poll getByIdAndMemberId(long id, long memberId) {
+        return findPoll(id, memberId)
+                .toDomain();
+    }
+
+    @Transactional
+    public Poll finishPoll(long pollId, long memberId) {
+        PollEntity pollEntity = findPoll(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

@@ -0,0 +1,31 @@
+package com.debatetimer.domainrepository.poll;
+
+import com.debatetimer.domain.poll.VoteInfo;
+import com.debatetimer.domain.poll.VoteTeam;
+import com.debatetimer.entity.poll.VoteEntity;
+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.stereotype.Repository;
+
+@Repository
+@RequiredArgsConstructor
+public class VoteDomainRepository {
+
+    private final VoteRepository voteRepository;
+
+    public VoteInfo findVoteInfoByPollId(long pollId) {
+        List<VoteEntity> pollVotes = voteRepository.findAllByPollId(pollId);
+        return countVotes(pollId, pollVotes);
+    }
+
+    private VoteInfo countVotes(long pollId, List<VoteEntity> voteEntities) {
+        Map<VoteTeam, Long> teamCount = voteEntities.stream()
+                .collect(Collectors.groupingBy(VoteEntity::getTeam, Collectors.counting()));
+        long prosCount = teamCount.getOrDefault(VoteTeam.PROS, 0L);
+        long consCount = teamCount.getOrDefault(VoteTeam.CONS, 0L);
+        return new VoteInfo(pollId, prosCount, consCount);
+    }
+}

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

@@ -0,0 +1,16 @@
+package com.debatetimer.dto.poll.response;
+
+import com.debatetimer.domain.poll.Poll;
+import com.debatetimer.domain.poll.PollStatus;
+
+public record PollCreateResponse(
+        long id,
+        PollStatus status,
+        String prosTeamName,
+        String consTeamName
+) {
+
+    public PollCreateResponse(Poll poll) {
+        this(poll.getId(), poll.getStatus(), poll.getProsTeamName().getValue(), poll.getConsTeamName().getValue());
+    }
+}

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

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

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

@@ -1,7 +1,9 @@
 package com.debatetimer.entity.poll;
 
+import com.debatetimer.domain.poll.Poll;
 import com.debatetimer.domain.poll.PollStatus;
 import com.debatetimer.entity.customize.BaseTimeEntity;
+import jakarta.persistence.Column;
 import jakarta.persistence.Entity;
 import jakarta.persistence.EnumType;
 import jakarta.persistence.Enumerated;
@@ -12,9 +14,11 @@
 import jakarta.validation.constraints.NotBlank;
 import jakarta.validation.constraints.NotNull;
 import lombok.AccessLevel;
+import lombok.Getter;
 import lombok.NoArgsConstructor;
 
 @Entity
+@Getter
 @Table(name = "poll")
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
 public class PollEntity extends BaseTimeEntity {
@@ -23,8 +27,12 @@ public class PollEntity extends BaseTimeEntity {
     @GeneratedValue(strategy = GenerationType.IDENTITY)
     private Long id;
 
+    @Column(name = "table_id")
     private long tableId;
 
+    @Column(name = "member_id")
+    private long memberId;
+
     @NotNull
     @Enumerated(EnumType.STRING)
     private PollStatus status;
@@ -36,4 +44,22 @@ public class PollEntity extends BaseTimeEntity {
     private String consTeamName;
 
     private String agenda;
+
+    public PollEntity(Poll poll) {
+        this.id = poll.getId();
+        this.tableId = poll.getTableId();
+        this.memberId = poll.getMemberId();
+        this.status = poll.getStatus();
+        this.prosTeamName = poll.getProsTeamName().getValue();
+        this.consTeamName = poll.getConsTeamName().getValue();
+        this.agenda = poll.getAgenda().getValue();
+    }
+
+    public void updateToDone() {
+        this.status = PollStatus.DONE;
+    }
+
+    public Poll toDomain() {
+        return new Poll(id, tableId, memberId, status, prosTeamName, consTeamName, agenda);
+    }
 }