[feat] 기록 생성 api 개발

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

@@ -72,7 +72,20 @@ public enum ErrorCode implements ResponseCode {
      */
     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 값이 유효하지 않습니다.")
+    INVALID_VOTE_PAGE_RANGE(HttpStatus.BAD_REQUEST, 110002, "VOTE의 page 값이 유효하지 않습니다."),
+
+    /**
+     * 120000 : record error
+     */
+    RECORD_NOT_FOUND(HttpStatus.NOT_FOUND, 120000, "존재하지 않는 RECORD 입니다."),
+    RECORD_CANNOT_BE_OVERVIEW(HttpStatus.BAD_REQUEST, 120001, "총평이 될 수 없는 RECORD 입니다."),
+    INVALID_RECORD_PAGE_RANGE(HttpStatus.BAD_REQUEST, 120002, "RECORD의 page 값이 유효하지 않습니다."),
+    RECORD_CANNOT_WRITE_IN_EXPIRED_ROOM(HttpStatus.BAD_REQUEST, 120003, "만료된 방에는 기록을 남길 수 없습니다."),
+
+    /**
+     * 130000 : userRoom error
+     */
+    USER_ROOM_NOT_FOUND(HttpStatus.NOT_FOUND, 130000, "존재하지 않는 USER_ROOM (방과 사용자 관계) 입니다."),
 
     ;
 

src/main/java/konkuk/thip/record/adapter/in/web/RecordCommandController.java

@@ -1,10 +1,28 @@
 package konkuk.thip.record.adapter.in.web;
 
+import jakarta.validation.Valid;
+import konkuk.thip.common.dto.BaseResponse;
+import konkuk.thip.common.security.annotation.UserId;
+import konkuk.thip.record.adapter.in.web.request.RecordCreateRequest;
+import konkuk.thip.record.adapter.in.web.response.RecordCreateResponse;
+import konkuk.thip.record.application.port.in.RecordCreateUseCase;
 import lombok.RequiredArgsConstructor;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 @RestController
 @RequiredArgsConstructor
 public class RecordCommandController {
+    private final RecordCreateUseCase recordCreateUseCase;
+
+    @PostMapping("/rooms/{roomId}/record")
+    public BaseResponse<RecordCreateResponse> createRecord(
+            @UserId final Long userId,
+            @PathVariable final Long roomId,
+            @Valid @RequestBody final RecordCreateRequest recordCreateRequest) {
+        return BaseResponse.ok(
+                RecordCreateResponse.of(
+                        recordCreateUseCase.createRecord(recordCreateRequest.toCommand(roomId, userId))
+                ));
+    }
 
 }

src/main/java/konkuk/thip/record/adapter/in/web/request/RecordCreateRequest.java

@@ -0,0 +1,28 @@
+package konkuk.thip.record.adapter.in.web.request;
+
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Size;
+import konkuk.thip.record.application.port.in.dto.RecordCreateCommand;
+
+public record RecordCreateRequest (
+    @NotNull(message = "page는 필수입니다.")
+    Integer page,
+
+    @NotNull(message = "isOverview(= 총평 여부)는 필수입니다.")
+    Boolean isOverview,
+
+    @NotBlank(message = "기록 내용은 필수입니다.")
+    @Size(max = 500, message = "기록 내용은 최대 500자 입니다.")
+    String content
+) {
+    public RecordCreateCommand toCommand(Long roomId, Long creatorId) {
+        return new RecordCreateCommand(
+                creatorId,
+                roomId,
+                page,
+                isOverview,
+                content
+        );
+    }
+}

src/main/java/konkuk/thip/record/adapter/in/web/response/RecordCreateResponse.java

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

src/main/java/konkuk/thip/record/adapter/out/persistence/RecordCommandPersistenceAdapter.java

@@ -1,15 +1,41 @@
 package konkuk.thip.record.adapter.out.persistence;
 
+import konkuk.thip.common.exception.EntityNotFoundException;
 import konkuk.thip.record.adapter.out.mapper.RecordMapper;
 import konkuk.thip.record.application.port.out.RecordCommandPort;
+import konkuk.thip.record.domain.Record;
+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 lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Repository;
 
+import static konkuk.thip.common.exception.code.ErrorCode.ROOM_NOT_FOUND;
+import static konkuk.thip.common.exception.code.ErrorCode.USER_NOT_FOUND;
+
 @Repository
 @RequiredArgsConstructor
 public class RecordCommandPersistenceAdapter implements RecordCommandPort {
 
     private final RecordJpaRepository recordJpaRepository;
+    private final UserJpaRepository userJpaRepository;
+    private final RoomJpaRepository roomJpaRepository;
     private final RecordMapper recordMapper;
 
+    @Override
+    public Long saveRecord(Record record) {
+        UserJpaEntity userJpaEntity = userJpaRepository.findById(record.getCreatorId()).orElseThrow(
+                () -> new EntityNotFoundException(USER_NOT_FOUND)
+        );
+
+        RoomJpaEntity roomJpaEntity = roomJpaRepository.findById(record.getRoomId()).orElseThrow(
+                () -> new EntityNotFoundException(ROOM_NOT_FOUND)
+        );
+
+        return recordJpaRepository.save(
+                recordMapper.toJpaEntity(record, userJpaEntity, roomJpaEntity)
+        ).getPostId();
+    }
+
 }

src/main/java/konkuk/thip/record/application/port/in/RecordCreateUseCase.java

@@ -0,0 +1,9 @@
+package konkuk.thip.record.application.port.in;
+
+import konkuk.thip.record.application.port.in.dto.RecordCreateCommand;
+
+public interface RecordCreateUseCase {
+
+    Long createRecord(RecordCreateCommand command);
+
+}

src/main/java/konkuk/thip/record/application/port/in/dto/RecordCreateCommand.java

@@ -0,0 +1,15 @@
+package konkuk.thip.record.application.port.in.dto;
+
+public record RecordCreateCommand(
+        Long userId,
+
+        Long roomId,
+
+        int page,
+
+        boolean isOverview,
+
+        String content
+) {
+
+}

src/main/java/konkuk/thip/record/application/port/out/RecordCommandPort.java

@@ -1,6 +1,10 @@
 package konkuk.thip.record.application.port.out;
 
 
+import konkuk.thip.record.domain.Record;
+
 public interface RecordCommandPort {
 
+    Long saveRecord(Record record);
+
 }

src/main/java/konkuk/thip/record/application/service/RecordCreateService.java

@@ -0,0 +1,98 @@
+package konkuk.thip.record.application.service;
+
+import jakarta.transaction.Transactional;
+import konkuk.thip.book.application.port.out.BookCommandPort;
+import konkuk.thip.book.domain.Book;
+import konkuk.thip.common.exception.BusinessException;
+import konkuk.thip.common.exception.InvalidStateException;
+import konkuk.thip.record.application.port.in.RecordCreateUseCase;
+import konkuk.thip.record.application.port.in.dto.RecordCreateCommand;
+import konkuk.thip.record.application.port.out.RecordCommandPort;
+import konkuk.thip.record.domain.Record;
+import konkuk.thip.room.application.port.out.RoomCommandPort;
+import konkuk.thip.room.domain.Room;
+import konkuk.thip.user.application.port.out.UserRoomCommandPort;
+import konkuk.thip.user.domain.UserRoom;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+import static konkuk.thip.common.exception.code.ErrorCode.*;
+
+@Service
+@RequiredArgsConstructor
+public class RecordCreateService implements RecordCreateUseCase {
+
+    private final RecordCommandPort recordCommandPort;
+    private final RoomCommandPort roomCommandPort;
+    private final BookCommandPort bookCommandPort;
+    private final UserRoomCommandPort userRoomCommandPort;
+
+    @Transactional
+    @Override
+    //todo updateRoomPercentage 스케줄러로 책임을 분리할지 논의
+    public Long createRecord(RecordCreateCommand command) {
+        // 1. Record 생성
+        Record record = Record.withoutId(
+                command.content(),
+                command.userId(),
+                command.page(),
+                command.isOverview(),
+                command.roomId()
+        );
+
+        // 2. UserRoom, Room, Book 조회
+        UserRoom userRoom = userRoomCommandPort.findByUserIdAndRoomId(command.userId(), command.roomId());
+        Room room = roomCommandPort.findById(record.getRoomId());
+        Book book = bookCommandPort.findById(room.getBookId());
+
+        // 3. 유효성 검증
+        validateRoom(room);
+        validateUserRoom(userRoom);
+        validateRecord(record, book);
+
+        // 4. UserRoom의 currentPage, userPercentage 업데이트
+        updateRoomProgress(userRoom, record, book, room);
+
+        // 5. Record 저장
+        return recordCommandPort.saveRecord(record);
+    }
+
+    private void updateRoomProgress(UserRoom userRoom, Record record, Book book, Room room) {
+        if(userRoom.updateUserProgress(record.getPage(), book.getPageCount())) {
+            // userPercentage가 업데이트되었으면 Room의 roomPercentage 업데이트
+            List<UserRoom> userRoomList = userRoomCommandPort.findAllByRoomId(record.getRoomId());
+            Double totalUserPercentage = userRoomList.stream()
+                    .map(UserRoom::getUserPercentage)
+                    .reduce(0.0, Double::sum);
+            room.updateRoomPercentage(totalUserPercentage / userRoomList.size());
+        }
+    }
+
+    private void validateUserRoom(UserRoom userRoom) {
+        // UserRoom의 총평 작성 가능 여부 검증
+        if (!userRoom.canWriteOverview()) {
+            String message = String.format(
+                    "총평(isOverview)은 사용자 진행률이 80%% 이상일 때만 가능합니다. 현재 사용자 진행률 = %.2f%%",
+                    userRoom.getUserPercentage()
+            );
+            throw new InvalidStateException(RECORD_CANNOT_BE_OVERVIEW, new IllegalStateException(message));
+        }
+    }
+
+    private void validateRoom(Room room) {
+        // 방이 만료되었는지 검증
+        if (room.isExpired()) {
+            throw new BusinessException(RECORD_CANNOT_WRITE_IN_EXPIRED_ROOM);
+        }
+    }
+
+    private void validateRecord(Record record, Book book) {
+        // 페이지 유효성 검증
+        record.validatePage(book.getPageCount());
+
+        // 총평 유효성 검증
+        record.validateOverview(book.getPageCount());
+    }
+}

src/main/java/konkuk/thip/record/domain/Record.java

@@ -1,9 +1,12 @@
 package konkuk.thip.record.domain;
 
 import konkuk.thip.common.entity.BaseDomainEntity;
+import konkuk.thip.common.exception.InvalidStateException;
 import lombok.Getter;
 import lombok.experimental.SuperBuilder;
 
+import static konkuk.thip.common.exception.code.ErrorCode.*;
+
 @Getter
 @SuperBuilder
 public class Record extends BaseDomainEntity {
@@ -19,4 +22,44 @@ public class Record extends BaseDomainEntity {
     private boolean isOverview;
 
     private Long roomId;
+
+    public static Record withoutId(
+            String content,
+            Long creatorId,
+            Integer page,
+            boolean isOverview,
+            Long roomId
+    ) {
+        return Record.builder()
+                .content(content)
+                .creatorId(creatorId)
+                .page(page)
+                .isOverview(isOverview)
+                .roomId(roomId)
+                .build();
+    }
+
+
+    public void validateOverview(int totalPageCount) {
+        // 총평 기록 생성 요청인데 page가 책의 전체 페이지 수가 아니라면 에러
+        if (isOverview && page != totalPageCount) {
+            String message = String.format(
+                    "총평(isOverview)은 책의 전체 페이지 수(%d)와 동일한 페이지에서만 작성할 수 있습니다. 현재 페이지 = %d",
+                    totalPageCount, page
+            );
+            throw new InvalidStateException(RECORD_CANNOT_BE_OVERVIEW, new IllegalArgumentException(message));
+        }
+    }
+
+    public void validatePage(int totalPageCount) {
+        if (page < 1 || page > totalPageCount) {
+            String message = String.format(
+                    "페이지 범위가 잘못되었습니다. 현재 기록할 page = %d, 책 전체 page = %d",
+                    page, totalPageCount
+            );
+            throw new InvalidStateException(INVALID_RECORD_PAGE_RANGE,
+                    new IllegalArgumentException(message)
+            );
+        }
+    }
 }

src/main/java/konkuk/thip/room/domain/Room.java

@@ -1,6 +1,7 @@
 package konkuk.thip.room.domain;
 
 import konkuk.thip.common.entity.BaseDomainEntity;
+import konkuk.thip.common.entity.StatusType;
 import lombok.Getter;
 import lombok.experimental.SuperBuilder;
 
@@ -31,4 +32,12 @@ public class Room extends BaseDomainEntity {
     private Long bookId;
 
     private Long categoryId;
+
+    public boolean isExpired() {
+        return this.getStatus() == StatusType.EXPIRED;
+    }
+
+    public void updateRoomPercentage(double roomPercentage) {
+        this.roomPercentage = roomPercentage;
+    }
 }