Merge f78f009 into 1836a2d

application/src/main/java/org/depromeet/spot/application/review/CreateReviewController.java

@@ -0,0 +1,41 @@
+package org.depromeet.spot.application.review;
+
+import jakarta.validation.Valid;
+import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Positive;
+
+import org.depromeet.spot.application.review.dto.request.CreateReviewRequest;
+import org.depromeet.spot.application.review.dto.response.ReviewResponse;
+import org.depromeet.spot.domain.review.Review;
+import org.depromeet.spot.usecase.port.in.review.CreateReviewUsecase;
+import org.springframework.http.HttpStatus;
+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.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseStatus;
+import org.springframework.web.bind.annotation.RestController;
+
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+
+@RestController
+@Tag(name = "리뷰")
+@RequiredArgsConstructor
+@RequestMapping("/api/v1")
+public class CreateReviewController {
+
+    private final CreateReviewUsecase createReviewUsecase;
+
+    @ResponseStatus(HttpStatus.CREATED)
+    @Operation(summary = "특정 좌석에 신규 리뷰를 추가한다.")
+    @PostMapping("/seats/{seatId}/members/{memberId}/reviews")
+    public ReviewResponse create(
+            @PathVariable @Positive @NotNull final Long seatId,
+            @PathVariable @Positive @NotNull final Long memberId,
+            @RequestBody @Valid @NotNull CreateReviewRequest request) {
+        Review review = createReviewUsecase.create(seatId, memberId, request.toCommand());
+        return ReviewResponse.from(review);
+    }
+}

application/src/main/java/org/depromeet/spot/application/review/dto/request/CreateReviewRequest.java

@@ -0,0 +1,32 @@
+package org.depromeet.spot.application.review.dto.request;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.time.format.DateTimeParseException;
+import java.util.List;
+
+import org.depromeet.spot.common.exception.review.ReviewException.InvalidReviewDateTimeFormatException;
+import org.depromeet.spot.usecase.port.in.review.CreateReviewUsecase.CreateReviewCommand;
+
+public record CreateReviewRequest(
+        List<String> images, List<String> good, List<String> bad, String content, String dateTime) {
+
+    public CreateReviewCommand toCommand() {
+        return CreateReviewCommand.builder()
+                .images(images)
+                .good(good)
+                .bad(bad)
+                .content(content)
+                .dateTime(toLocalDateTime(dateTime))
+                .build();
+    }
+
+    private LocalDateTime toLocalDateTime(String dateTimeStr) {
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm");
+        try {
+            return LocalDateTime.parse(dateTimeStr, formatter);
+        } catch (DateTimeParseException e) {
+            throw new InvalidReviewDateTimeFormatException();
+        }
+    }
+}

common/src/main/java/org/depromeet/spot/common/exception/review/ReviewErrorCode.java

@@ -8,7 +8,9 @@
 @Getter
 public enum ReviewErrorCode implements ErrorCode {
     REVIEW_NOT_FOUND(HttpStatus.NOT_FOUND, "RV001", "요청한 리뷰를 찾을 수 없습니다."),
-    INVALID_REVIEW_DATA(HttpStatus.BAD_REQUEST, "RV002", "유효하지 않은 리뷰 데이터입니다.");
+    INVALID_REVIEW_DATA(HttpStatus.BAD_REQUEST, "RV002", "유효하지 않은 리뷰 데이터입니다."),
+    INVALID_REVIEW_DATETIME_FORMAT(
+            HttpStatus.BAD_REQUEST, "RV003", "리뷰 작성일시는 yyyy-MM-dd HH:mm 포맷이어야 합니다.");
 
     private final HttpStatus status;
     private final String code;

common/src/main/java/org/depromeet/spot/common/exception/review/ReviewException.java

@@ -26,4 +26,14 @@ public InvalidReviewDataException(String str) {
             super(ReviewErrorCode.INVALID_REVIEW_DATA.appended(str));
         }
     }
+
+    public static class InvalidReviewDateTimeFormatException extends ReviewException {
+        public InvalidReviewDateTimeFormatException() {
+            super(ReviewErrorCode.INVALID_REVIEW_DATETIME_FORMAT);
+        }
+
+        public InvalidReviewDateTimeFormatException(String str) {
+            super(ReviewErrorCode.INVALID_REVIEW_DATETIME_FORMAT.appended(str));
+        }
+    }
 }

common/src/main/java/org/depromeet/spot/common/exception/seat/SeatErrorCode.java

@@ -0,0 +1,27 @@
+package org.depromeet.spot.common.exception.seat;
+
+import org.depromeet.spot.common.exception.ErrorCode;
+import org.springframework.http.HttpStatus;
+
+import lombok.Getter;
+
+@Getter
+public enum SeatErrorCode implements ErrorCode {
+    SEAT_NOT_FOUND(HttpStatus.NOT_FOUND, "SEAT001", "요청 좌석이 존재하지 않습니다."),
+    ;
+
+    private final HttpStatus status;
+    private final String code;
+    private String message;
+
+    SeatErrorCode(HttpStatus status, String code, String message) {
+        this.status = status;
+        this.code = code;
+        this.message = message;
+    }
+
+    public SeatErrorCode appended(Object o) {
+        message = message + " {" + o.toString() + "}";
+        return this;
+    }
+}

common/src/main/java/org/depromeet/spot/common/exception/seat/SeatException.java

@@ -0,0 +1,20 @@
+package org.depromeet.spot.common.exception.seat;
+
+import org.depromeet.spot.common.exception.BusinessException;
+
+public abstract class SeatException extends BusinessException {
+
+    protected SeatException(SeatErrorCode errorCode) {
+        super(errorCode);
+    }
+
+    public static class SeatNotFoundException extends SeatException {
+        public SeatNotFoundException() {
+            super(SeatErrorCode.SEAT_NOT_FOUND);
+        }
+
+        public SeatNotFoundException(Object obj) {
+            super(SeatErrorCode.SEAT_NOT_FOUND.appended(obj));
+        }
+    }
+}

domain/src/main/java/org/depromeet/spot/domain/review/Review.java

@@ -3,11 +3,13 @@
 import java.time.LocalDateTime;
 import java.util.List;
 
+import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.Getter;
 
-@Builder
 @Getter
+@Builder
+@AllArgsConstructor
 public class Review {
 
     private final Long id;
@@ -18,7 +20,7 @@ public class Review {
     private final Long rowId;
     private final Long seatNumber;
 
-    private final LocalDateTime dateTime; // 시간은 미표기
+    private final LocalDateTime dateTime;
     private final String content;
     private final LocalDateTime createdAt;
     private final LocalDateTime updatedAt;

infrastructure/jpa/src/main/java/org/depromeet/spot/jpa/review/repository/ReviewJpaRepository.java

@@ -0,0 +1,6 @@
+package org.depromeet.spot.jpa.review.repository;
+
+import org.depromeet.spot.jpa.review.entity.ReviewEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface ReviewJpaRepository extends JpaRepository<ReviewEntity, Long> {}

infrastructure/jpa/src/main/java/org/depromeet/spot/jpa/review/repository/ReviewRepositoryImpl.java

@@ -17,6 +17,7 @@
 @RequiredArgsConstructor
 public class ReviewRepositoryImpl implements ReviewRepository {
     private final ReviewCustomRepository reviewCustomRepository;
+    private final ReviewJpaRepository reviewJpaRepository;
 
     @Override
     public List<Review> findByBlockId(
@@ -51,6 +52,12 @@ public List<KeywordCount> findTopKeywordsByBlockId(Long stadiumId, Long blockId,
         return reviewCustomRepository.findTopKeywordsByBlockId(stadiumId, blockId, limit);
     }
 
+    @Override
+    public Review save(Review review) {
+        ReviewEntity entity = reviewJpaRepository.save(ReviewEntity.from(review));
+        return entity.toDomain();
+    }
+
     private Review fetchReviewDetails(ReviewEntity reviewEntity) {
         List<ReviewImageEntity> images =
                 reviewCustomRepository.findImagesByReviewIds(List.of(reviewEntity.getId()));

infrastructure/jpa/src/main/java/org/depromeet/spot/jpa/seat/repository/SeatJpaRepository.java

@@ -0,0 +1,6 @@
+package org.depromeet.spot.jpa.seat.repository;
+
+import org.depromeet.spot.jpa.seat.entity.SeatEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface SeatJpaRepository extends JpaRepository<SeatEntity, Long> {}

infrastructure/jpa/src/main/java/org/depromeet/spot/jpa/seat/repository/SeatRepositoryImpl.java

@@ -2,7 +2,9 @@
 
 import java.util.List;
 
+import org.depromeet.spot.common.exception.seat.SeatException.SeatNotFoundException;
 import org.depromeet.spot.domain.seat.Seat;
+import org.depromeet.spot.jpa.seat.entity.SeatEntity;
 import org.depromeet.spot.usecase.port.out.seat.SeatRepository;
 import org.springframework.stereotype.Repository;
 
@@ -13,9 +15,17 @@
 public class SeatRepositoryImpl implements SeatRepository {
 
     private final SeatJdbcRepository seatJdbcRepository;
+    private final SeatJpaRepository seatJpaRepository;
 
     @Override
     public void saveAll(List<Seat> seats) {
         seatJdbcRepository.createSeats(seats);
     }
+
+    @Override
+    public Seat findById(Long seatId) {
+        SeatEntity entity =
+                seatJpaRepository.findById(seatId).orElseThrow(SeatNotFoundException::new);
+        return entity.toDomain();
+    }
 }

usecase/src/main/java/org/depromeet/spot/usecase/port/in/member/UpdateMemberUsecase.java

@@ -8,6 +8,8 @@ public interface UpdateMemberUsecase {
 
     Member updateProfile(Long memberId, UpdateProfileCommand command);
 
+    void updateLevel(Long memberId, long reviewCnt);
+
     @Builder
     record UpdateProfileCommand(String profileImage, String nickname, Long teamId) {}
 }

usecase/src/main/java/org/depromeet/spot/usecase/port/in/review/CreateReviewUsecase.java

@@ -0,0 +1,21 @@
+package org.depromeet.spot.usecase.port.in.review;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+import org.depromeet.spot.domain.review.Review;
+
+import lombok.Builder;
+
+public interface CreateReviewUsecase {
+
+    Review create(Long seatId, Long memberId, CreateReviewCommand command);
+
+    @Builder
+    record CreateReviewCommand(
+            List<String> images,
+            List<String> good,
+            List<String> bad,
+            LocalDateTime dateTime,
+            String content) {}
+}

usecase/src/main/java/org/depromeet/spot/usecase/port/in/seat/ReadSeatUsecase.java

@@ -0,0 +1,8 @@
+package org.depromeet.spot.usecase.port.in.seat;
+
+import org.depromeet.spot.domain.seat.Seat;
+
+public interface ReadSeatUsecase {
+
+    Seat findById(Long seatId);
+}

usecase/src/main/java/org/depromeet/spot/usecase/port/out/review/ReviewRepository.java

@@ -16,4 +16,6 @@ List<Review> findByBlockId(
     Long countByUserId(Long userId, Integer year, Integer month);
 
     List<KeywordCount> findTopKeywordsByBlockId(Long stadiumId, Long blockId, int limit);
+
+    Review save(Review review);
 }

usecase/src/main/java/org/depromeet/spot/usecase/port/out/seat/SeatRepository.java

@@ -7,4 +7,6 @@
 public interface SeatRepository {
 
     void saveAll(List<Seat> seats);
+
+    Seat findById(Long seatId);
 }

usecase/src/main/java/org/depromeet/spot/usecase/service/block/BlockReadService.java

@@ -16,13 +16,15 @@
 import org.depromeet.spot.usecase.port.in.stadium.StadiumReadUsecase;
 import org.depromeet.spot.usecase.port.out.block.BlockRepository;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import lombok.Builder;
 import lombok.RequiredArgsConstructor;
 
 @Service
 @Builder
 @RequiredArgsConstructor
+@Transactional(readOnly = true)
 public class BlockReadService implements BlockReadUsecase {
 
     private final BlockRepository blockRepository;

usecase/src/main/java/org/depromeet/spot/usecase/service/block/ReadBlockRowService.java

@@ -6,11 +6,13 @@
 import org.depromeet.spot.usecase.port.in.block.ReadBlockRowUsecase;
 import org.depromeet.spot.usecase.port.out.block.BlockRowRepository;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import lombok.RequiredArgsConstructor;
 
 @Service
 @RequiredArgsConstructor
+@Transactional(readOnly = true)
 public class ReadBlockRowService implements ReadBlockRowUsecase {
 
     private final BlockRowRepository blockRowRepository;

usecase/src/main/java/org/depromeet/spot/usecase/service/member/MemberService.java

@@ -9,10 +9,12 @@
 import org.depromeet.spot.usecase.port.out.member.MemberRepository;
 import org.depromeet.spot.usecase.port.out.oauth.OauthRepository;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import lombok.RequiredArgsConstructor;
 
 @Service
+@Transactional
 @RequiredArgsConstructor
 public class MemberService implements MemberUsecase {
 

usecase/src/main/java/org/depromeet/spot/usecase/service/member/ReadMemberService.java

@@ -4,11 +4,13 @@
 import org.depromeet.spot.usecase.port.in.member.ReadMemberUsecase;
 import org.depromeet.spot.usecase.port.out.member.MemberRepository;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import lombok.RequiredArgsConstructor;
 
 @Service
 @RequiredArgsConstructor
+@Transactional(readOnly = true)
 public class ReadMemberService implements ReadMemberUsecase {
 
     private final MemberRepository memberRepository;

usecase/src/main/java/org/depromeet/spot/usecase/service/member/UpdateMemberService.java

@@ -29,4 +29,9 @@ public Member updateProfile(final Long memberId, UpdateProfileCommand command) {
                 member.updateProfile(command.profileImage(), command.nickname(), command.teamId());
         return memberRepository.update(updateMember);
     }
+
+    @Override
+    public void updateLevel(Long memberId, long reviewCnt) {
+        // TODO
+    }
 }