[feat] 투표 생성 api 개발

src/main/java/konkuk/thip/book/adapter/out/persistence/BookCommandPersistenceAdapter.java

@@ -30,4 +30,13 @@ public Long save(Book book) {
         BookJpaEntity bookJpaEntity = bookMapper.toJpaEntity(book);
         return bookJpaRepository.save(bookJpaEntity).getBookId();
     }
+
+    @Override
+    public Book findById(Long id) {
+        BookJpaEntity bookJpaEntity = bookJpaRepository.findById(id).orElseThrow(
+                () -> new EntityNotFoundException(BOOK_NOT_FOUND)
+        );
+
+        return bookMapper.toDomainEntity(bookJpaEntity);
+    }
 }

src/main/java/konkuk/thip/book/application/port/out/BookCommandPort.java

@@ -3,10 +3,11 @@
 
 import konkuk.thip.book.domain.Book;
 
-import java.util.Optional;
-
 public interface BookCommandPort {
 
     Book findByIsbn(String isbn);
+
     Long save(Book book);
+
+    Book findById(Long id);
 }

src/main/java/konkuk/thip/common/exception/code/ErrorCode.java

@@ -54,13 +54,25 @@ public enum ErrorCode implements ResponseCode {
     BOOK_NOT_SAVED_CANNOT_DELETE(HttpStatus.BAD_REQUEST, 80013, "사용자가 저장하지 않은 책은 저장삭제 할 수 없습니다."),
     BOOK_NOT_SAVED_DB_CANNOT_DELETE(HttpStatus.BAD_REQUEST, 80014, "DB에 존재하지 않은 책은 저장삭제 할 수 없습니다."),
 
+    /**
+     * 90000 : recentSearch error
+     */
+    INVALID_SEARCH_TYPE(HttpStatus.BAD_REQUEST, 900000,"알맞은 검색어 타입을 찾을 수 없습니다."),
 
 
     /**
-     * 90000 : recentSearch error
+     * 100000 : room error
+     */
+    ROOM_NOT_FOUND(HttpStatus.NOT_FOUND, 100000, "존재하지 않는 ROOM 입니다."),
+
+    /**
+     * 110000 : vote error
      */
-    INVALID_SEARCH_TYPE(HttpStatus.BAD_REQUEST, 900000,"알맞은 검색어 타입을 찾을 수 없습니다.");
+    VOTE_NOT_FOUND(HttpStatus.NOT_FOUND, 110000, "존재하지 않는 VOTE 입니다."),
+    VOTE_CANNOT_BE_OVERVIEW(HttpStatus.BAD_REQUEST, 110001, "총평이 될 수 없는 VOTE 입니다."),
+    INVALID_VOTE_PAGE_RANGE(HttpStatus.BAD_REQUEST, 110002, "VOTE의 page 값이 유효하지 않습니다.")
 
+    ;
 
     private final HttpStatus httpStatus;
     private final int code;

src/main/java/konkuk/thip/common/exception/handler/GlobalExceptionHandler.java

@@ -91,9 +91,15 @@ public ResponseEntity<ErrorResponse> authExceptionHandler(AuthException e) {
     @ExceptionHandler(BusinessException.class)
     public ResponseEntity<ErrorResponse> businessExceptionHandler(BusinessException e) {
         log.error("[BusinessExceptionHandler] {}", e.getMessage());
+
+        // 1) cause 에 포함된 상세 메시지를 파싱, 없다면 빈 문자열로 설정
+        String detail = Optional.ofNullable(e.getCause())
+                .map(Throwable::getMessage)
+                .orElse("");
+
         return ResponseEntity
                 .status(e.getErrorCode().getHttpStatus())
-                .body(ErrorResponse.of(e.getErrorCode()));
+                .body(ErrorResponse.of(e.getErrorCode(), detail));
     }
 
     // 서버 내부 오류 예외 처리
@@ -132,5 +138,4 @@ public ResponseEntity<ErrorResponse> constraintViolationExceptionHandler(Constra
                 .body(ErrorResponse.of(API_INVALID_PARAM, errorMessage));
     }
 
-
 }

src/main/java/konkuk/thip/room/adapter/out/persistence/RoomCommandPersistenceAdapter.java

@@ -1,15 +1,28 @@
 package konkuk.thip.room.adapter.out.persistence;
 
+import konkuk.thip.common.exception.EntityNotFoundException;
+import konkuk.thip.room.adapter.out.jpa.RoomJpaEntity;
 import konkuk.thip.room.adapter.out.mapper.RoomMapper;
 import konkuk.thip.room.application.port.out.RoomCommandPort;
+import konkuk.thip.room.domain.Room;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Repository;
 
+import static konkuk.thip.common.exception.code.ErrorCode.ROOM_NOT_FOUND;
+
 @Repository
 @RequiredArgsConstructor
 public class RoomCommandPersistenceAdapter implements RoomCommandPort {
 
-    private final RoomJpaRepository jpaRepository;
-    private final RoomMapper userMapper;
+    private final RoomJpaRepository roomJpaRepository;
+    private final RoomMapper roomMapper;
+
+    @Override
+    public Room findById(Long id) {
+        RoomJpaEntity roomJpaEntity = roomJpaRepository.findById(id).orElseThrow(
+                () -> new EntityNotFoundException(ROOM_NOT_FOUND)
+        );
 
+        return roomMapper.toDomainEntity(roomJpaEntity);
+    }
 }

src/main/java/konkuk/thip/room/application/port/out/RoomCommandPort.java

@@ -1,6 +1,8 @@
 package konkuk.thip.room.application.port.out;
 
+import konkuk.thip.room.domain.Room;
 
 public interface RoomCommandPort {
 
+    Room findById(Long id);
 }

src/main/java/konkuk/thip/user/adapter/in/web/UserCommandController.java

@@ -1,6 +1,7 @@
 package konkuk.thip.user.adapter.in.web;
 
 import jakarta.servlet.http.HttpServletResponse;
+import jakarta.validation.Valid;
 import konkuk.thip.common.dto.BaseResponse;
 import konkuk.thip.common.security.annotation.Oauth2Id;
 import konkuk.thip.common.security.util.JwtUtil;
@@ -11,7 +12,6 @@
 import konkuk.thip.user.application.port.in.UserSignupUseCase;
 import konkuk.thip.user.application.port.in.UserVerifyNicknameUseCase;
 import lombok.RequiredArgsConstructor;
-import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RestController;
@@ -28,7 +28,7 @@ public class UserCommandController {
     private final JwtUtil jwtUtil;
 
     @PostMapping("/users/signup")
-    public BaseResponse<UserSignupResponse> signup(@Validated @RequestBody UserSignupRequest request,
+    public BaseResponse<UserSignupResponse> signup(@Valid @RequestBody UserSignupRequest request,
                                                    @Oauth2Id String oauth2Id,
                                                    HttpServletResponse response) {
         Long userId = userSignupUseCase.signup(request.toCommand(oauth2Id));
@@ -38,7 +38,7 @@ public BaseResponse<UserSignupResponse> signup(@Validated @RequestBody UserSignu
     }
 
     @PostMapping("/users/nickname")
-    public BaseResponse<UserVerifyNicknameResponse> verifyNickname(@Validated @RequestBody UserVerifyNicknameRequest request) {
+    public BaseResponse<UserVerifyNicknameResponse> verifyNickname(@Valid @RequestBody UserVerifyNicknameRequest request) {
         return BaseResponse.ok(UserVerifyNicknameResponse.of(
                 userVerifyNicknameUseCase.isNicknameUnique(request.nickname()))
         );

src/main/java/konkuk/thip/vote/adapter/in/web/VoteCommandController.java

@@ -1,10 +1,31 @@
 package konkuk.thip.vote.adapter.in.web;
 
+import jakarta.validation.Valid;
+import konkuk.thip.common.dto.BaseResponse;
+import konkuk.thip.common.security.annotation.UserId;
+import konkuk.thip.vote.adapter.in.web.request.VoteCreateRequest;
+import konkuk.thip.vote.adapter.in.web.response.VoteCreateResponse;
+import konkuk.thip.vote.application.port.in.VoteCreateUseCase;
 import lombok.RequiredArgsConstructor;
+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.RestController;
 
 @RestController
 @RequiredArgsConstructor
 public class VoteCommandController {
 
+    private final VoteCreateUseCase voteCreateUseCase;
+
+    @PostMapping("/rooms/{roomId}/vote")
+    public BaseResponse<VoteCreateResponse> createVote(
+            @UserId Long userId,
+            @PathVariable Long roomId,
+            @Valid @RequestBody VoteCreateRequest request) {
+
+        return BaseResponse.ok(VoteCreateResponse.of(
+                voteCreateUseCase.createVote(request.toCommand(userId, roomId))
+        ));
+    }
 }

src/main/java/konkuk/thip/vote/adapter/in/web/request/VoteCreateRequest.java

@@ -0,0 +1,48 @@
+package konkuk.thip.vote.adapter.in.web.request;
+
+import jakarta.validation.Valid;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Size;
+import konkuk.thip.vote.application.port.in.dto.VoteCreateCommand;
+
+import java.util.List;
+
+public record VoteCreateRequest(
+        @NotNull(message = "page는 필수입니다.")
+        Integer page,
+
+        @NotNull(message = "isOverview(= 총평 여부)는 필수입니다.")
+        Boolean isOverview,
+
+        @NotBlank(message = "투표 내용은 필수입니다.")
+        @Size(max = 20, message = "투표 내용은 최대 20자 입니다.")
+        String content,
+
+        @NotNull(message = "투표 항목은 필수입니다.")
+        @Size(min = 1, max = 5, message = "투표 항목은 1개 이상, 최대 5개까지입니다.")
+        @Valid
+        List<VoteItemCreateRequest> voteItemList
+) {
+        public record VoteItemCreateRequest(
+                @NotBlank(message = "투표 항목 이름은 필수입니다.")
+                @Size(max = 20, message = "투표 항목 이름은 최대 20자입니다.")
+                String itemName
+        ) {}
+
+        public VoteCreateCommand toCommand(Long userId, Long roomId) {
+                List<VoteCreateCommand.VoteItemCreateCommand> mappedItems = voteItemList.stream()
+                        .map(voteItem -> new VoteCreateCommand.VoteItemCreateCommand(voteItem.itemName))
+                        .toList();
+
+                return new VoteCreateCommand(
+                        userId,
+                        roomId,
+                        page,
+                        isOverview,
+                        content,
+                        mappedItems
+                );
+        }
+
+}

src/main/java/konkuk/thip/vote/adapter/in/web/response/VoteCreateResponse.java

@@ -0,0 +1,9 @@
+package konkuk.thip.vote.adapter.in.web.response;
+
+public record VoteCreateResponse(
+        Long voteId
+) {
+    public static VoteCreateResponse of(Long voteId) {
+        return new VoteCreateResponse(voteId);
+    }
+}

src/main/java/konkuk/thip/vote/adapter/out/persistence/VoteCommandPersistenceAdapter.java

@@ -1,15 +1,62 @@
 package konkuk.thip.vote.adapter.out.persistence;
 
+import konkuk.thip.common.exception.EntityNotFoundException;
+import konkuk.thip.room.adapter.out.jpa.RoomJpaEntity;
+import konkuk.thip.room.adapter.out.persistence.RoomJpaRepository;
+import konkuk.thip.user.adapter.out.jpa.UserJpaEntity;
+import konkuk.thip.user.adapter.out.persistence.UserJpaRepository;
+import konkuk.thip.vote.adapter.out.jpa.VoteItemJpaEntity;
+import konkuk.thip.vote.adapter.out.jpa.VoteJpaEntity;
+import konkuk.thip.vote.adapter.out.mapper.VoteItemMapper;
 import konkuk.thip.vote.adapter.out.mapper.VoteMapper;
 import konkuk.thip.vote.application.port.out.VoteCommandPort;
+import konkuk.thip.vote.domain.Vote;
+import konkuk.thip.vote.domain.VoteItem;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Repository;
 
+import java.util.List;
+
+import static konkuk.thip.common.exception.code.ErrorCode.*;
+
 @Repository
 @RequiredArgsConstructor
 public class VoteCommandPersistenceAdapter implements VoteCommandPort {
 
     private final VoteJpaRepository voteJpaRepository;
+    private final VoteItemJpaRepository voteItemJpaRepository;
+    private final UserJpaRepository userJpaRepository;
+    private final RoomJpaRepository roomJpaRepository;
+
     private final VoteMapper voteMapper;
+    private final VoteItemMapper voteItemMapper;
+
+    @Override
+    public Long saveVote(Vote vote) {
+        UserJpaEntity userJpaEntity = userJpaRepository.findById(vote.getCreatorId()).orElseThrow(
+                () -> new EntityNotFoundException(USER_NOT_FOUND)
+        );
+
+        RoomJpaEntity roomJpaEntity = roomJpaRepository.findById(vote.getRoomId()).orElseThrow(
+                () -> new EntityNotFoundException(ROOM_NOT_FOUND)
+        );
+
+        return voteJpaRepository.save(voteMapper.toJpaEntity(vote, userJpaEntity, roomJpaEntity)).getPostId();
+    }
+
+    @Override
+    public void saveAllVoteItems(List<VoteItem> voteItems) {
+        if (voteItems.isEmpty()) return;
+
+        Long voteId = voteItems.get(0).getVoteId();
+        VoteJpaEntity voteJpaEntity = voteJpaRepository.findById(voteId).orElseThrow(
+                () -> new EntityNotFoundException(VOTE_NOT_FOUND)
+        );
+
+        List<VoteItemJpaEntity> voteItemJpaEntities = voteItems.stream()
+                .map(voteItem -> voteItemMapper.toJpaEntity(voteItem, voteJpaEntity))
+                .toList();
 
+        voteItemJpaRepository.saveAll(voteItemJpaEntities);
+    }
 }

src/main/java/konkuk/thip/vote/adapter/out/persistence/VoteItemJpaRepository.java

@@ -0,0 +1,11 @@
+package konkuk.thip.vote.adapter.out.persistence;
+
+import konkuk.thip.vote.adapter.out.jpa.VoteItemJpaEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.List;
+
+public interface VoteItemJpaRepository extends JpaRepository<VoteItemJpaEntity, Long> {
+
+    List<VoteItemJpaEntity> findAllByVoteJpaEntity_PostId(Long voteId);
+}

src/main/java/konkuk/thip/vote/application/port/in/VoteCreateUseCase.java

@@ -0,0 +1,8 @@
+package konkuk.thip.vote.application.port.in;
+
+import konkuk.thip.vote.application.port.in.dto.VoteCreateCommand;
+
+public interface VoteCreateUseCase {
+
+    Long createVote(VoteCreateCommand command);
+}

src/main/java/konkuk/thip/vote/application/port/in/dto/VoteCreateCommand.java

@@ -0,0 +1,19 @@
+package konkuk.thip.vote.application.port.in.dto;
+
+import java.util.List;
+
+public record VoteCreateCommand(
+        Long userId,
+
+        Long roomId,
+
+        int page,
+
+        boolean isOverview,
+
+        String content,
+
+        List<VoteItemCreateCommand> voteItemCreateCommands
+) {
+    public record VoteItemCreateCommand(String itemName) {}
+}

src/main/java/konkuk/thip/vote/application/port/out/VoteCommandPort.java

@@ -1,6 +1,13 @@
 package konkuk.thip.vote.application.port.out;
 
+import konkuk.thip.vote.domain.Vote;
+import konkuk.thip.vote.domain.VoteItem;
+
+import java.util.List;
 
 public interface VoteCommandPort {
 
+    Long saveVote(Vote vote);
+
+    void saveAllVoteItems(List<VoteItem> voteItems);
 }