[feat] 오늘의 한마디 작성 api 개발

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

@@ -189,6 +189,11 @@ public enum ErrorCode implements ResponseCode {
     COMMENT_DELETE_FORBIDDEN(HttpStatus.FORBIDDEN, 190005, "댓글 삭제 권한이 없습니다."),
     COMMENT_COUNT_UNDERFLOW(HttpStatus.BAD_REQUEST, 190007, "댓글 수는 0 이하로 감소할 수 없습니다."),
 
+    /**
+     * 195000 : AttendanceCheck error
+     */
+    ATTENDANCE_CHECK_WRITE_LIMIT_EXCEEDED(HttpStatus.BAD_REQUEST, 195000, "오늘의 한마디 작성 가능 횟수를 초과하였습니다."),
+
     ;
 
     private final HttpStatus httpStatus;

src/main/java/konkuk/thip/common/swagger/SwaggerResponseDescription.java

@@ -281,6 +281,14 @@ public enum SwaggerResponseDescription {
             RECENT_SEARCH_NOT_ADDED_BY_USER
     ))),
 
+    // Attendance Check
+    ATTENDANCE_CHECK_CREATE(new LinkedHashSet<>(Set.of(
+            ROOM_ACCESS_FORBIDDEN,
+            ROOM_NOT_FOUND,
+            USER_NOT_FOUND,
+            ATTENDANCE_CHECK_WRITE_LIMIT_EXCEEDED
+    ))),
+
   ;
     private final Set<ErrorCode> errorCodeList;
     SwaggerResponseDescription(Set<ErrorCode> errorCodeList) {

src/main/java/konkuk/thip/room/adapter/in/web/RoomCommandController.java

@@ -4,6 +4,9 @@
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.validation.Valid;
+import konkuk.thip.room.adapter.in.web.request.AttendanceCheckCreateRequest;
+import konkuk.thip.room.adapter.in.web.response.AttendanceCheckCreateResponse;
+import konkuk.thip.room.application.port.in.AttendanceCheckCreateUseCase;
 import konkuk.thip.common.dto.BaseResponse;
 import konkuk.thip.common.security.annotation.UserId;
 import konkuk.thip.common.swagger.annotation.ExceptionDescription;
@@ -35,6 +38,7 @@ public class RoomCommandController {
     private final RoomJoinUseCase roomJoinUsecase;
     private final RoomRecruitCloseUseCase roomRecruitCloseUsecase;
     private final PostLikeUseCase postLikeUseCase;
+    private final AttendanceCheckCreateUseCase attendanceCheckCreateUseCase;
 
     /**
      * 방 생성 요청
@@ -102,4 +106,22 @@ public BaseResponse<RoomPostIsLikeResponse> likeRoomPost(
             @Parameter(hidden = true) @UserId final Long userId) {
         return BaseResponse.ok(RoomPostIsLikeResponse.of(postLikeUseCase.changeLikeStatusPost(request.toCommand(userId, postId))));
     }
+
+    /**
+     * 오늘의 한마디 작성
+     */
+    @Operation(
+            summary = "오늘의 한마디 작성",
+            description = "방 참여자가 오늘의 한마디를 작성합니다."
+    )
+    @ExceptionDescription(ATTENDANCE_CHECK_CREATE)
+    @PostMapping("/rooms/{roomId}/daily-greeting")
+    public BaseResponse<AttendanceCheckCreateResponse> createFeed(
+            @RequestBody @Valid final AttendanceCheckCreateRequest request,
+            @Parameter(description = "오늘의 한마디를 작성할 방 id값") @PathVariable("roomId") final Long roomId,
+            @Parameter(hidden = true) @UserId final Long userId) {
+        return BaseResponse.ok(AttendanceCheckCreateResponse.of(
+                attendanceCheckCreateUseCase.create(request.toCommand(userId, roomId))
+        ));
+    }
 }

src/main/java/konkuk/thip/room/adapter/in/web/request/AttendanceCheckCreateRequest.java

@@ -0,0 +1,15 @@
+package konkuk.thip.room.adapter.in.web.request;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotBlank;
+import konkuk.thip.room.application.port.in.dto.AttendanceCheckCreateCommand;
+
+public record AttendanceCheckCreateRequest(
+        @Schema(description = "유저가 작성한 오늘의 한마디 내용")
+        @NotBlank(message = "오늘의 한마디 내용은 필수입니다.")
+        String content
+) {
+    public AttendanceCheckCreateCommand toCommand(Long creatorId, Long roomId) {
+        return new AttendanceCheckCreateCommand(creatorId, roomId, content);
+    }
+}

src/main/java/konkuk/thip/room/adapter/in/web/response/AttendanceCheckCreateResponse.java

@@ -0,0 +1,20 @@
+package konkuk.thip.room.adapter.in.web.response;
+
+import konkuk.thip.room.application.port.in.dto.AttendanceCheckCreateResult;
+
+public record AttendanceCheckCreateResponse(
+        Long attendanceCheckId,
+        Long roomId,
+        boolean isFirstWrite
+) {
+    public static AttendanceCheckCreateResponse of(AttendanceCheckCreateResult result) {
+        boolean isFirstWrite = false;
+        if (result.todayWriteCountOfUser() == 1) isFirstWrite = true;
+
+        return new AttendanceCheckCreateResponse(
+                result.attendanceCheckId(),
+                result.roomId(),
+                isFirstWrite
+        );
+    }
+}

src/main/java/konkuk/thip/attendancecheck/adapter/out/jpa/AttendanceCheckJpaEntity.java → src/main/java/konkuk/thip/room/adapter/out/jpa/AttendanceCheckJpaEntity.java

@@ -1,8 +1,7 @@
-package konkuk.thip.attendancecheck.adapter.out.jpa;
+package konkuk.thip.room.adapter.out.jpa;
 
 import jakarta.persistence.*;
 import konkuk.thip.common.entity.BaseJpaEntity;
-import konkuk.thip.room.adapter.out.jpa.RoomJpaEntity;
 import konkuk.thip.user.adapter.out.jpa.UserJpaEntity;
 import lombok.*;
 

src/main/java/konkuk/thip/attendancecheck/adapter/out/mapper/AttendanceCheckMapper.java → src/main/java/konkuk/thip/room/adapter/out/mapper/AttendanceCheckMapper.java

@@ -1,7 +1,7 @@
-package konkuk.thip.attendancecheck.adapter.out.mapper;
+package konkuk.thip.room.adapter.out.mapper;
 
-import konkuk.thip.attendancecheck.adapter.out.jpa.AttendanceCheckJpaEntity;
-import konkuk.thip.attendancecheck.domain.AttendanceCheck;
+import konkuk.thip.room.adapter.out.jpa.AttendanceCheckJpaEntity;
+import konkuk.thip.room.domain.AttendanceCheck;
 import konkuk.thip.room.adapter.out.jpa.RoomJpaEntity;
 import konkuk.thip.user.adapter.out.jpa.UserJpaEntity;
 import org.springframework.stereotype.Component;

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

@@ -0,0 +1,41 @@
+package konkuk.thip.room.adapter.out.persistence;
+
+import konkuk.thip.room.adapter.out.mapper.AttendanceCheckMapper;
+import konkuk.thip.room.adapter.out.persistence.repository.attendancecheck.AttendanceCheckJpaRepository;
+import konkuk.thip.room.application.port.out.AttendanceCheckCommandPort;
+import konkuk.thip.room.domain.AttendanceCheck;
+import konkuk.thip.common.exception.EntityNotFoundException;
+import konkuk.thip.room.adapter.out.jpa.RoomJpaEntity;
+import konkuk.thip.room.adapter.out.persistence.repository.RoomJpaRepository;
+import konkuk.thip.user.adapter.out.jpa.UserJpaEntity;
+import konkuk.thip.user.adapter.out.persistence.repository.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 AttendanceCheckCommandPersistenceAdapter implements AttendanceCheckCommandPort {
+
+    private final AttendanceCheckJpaRepository attendanceCheckJpaRepository;
+    private final RoomJpaRepository roomJpaRepository;
+    private final UserJpaRepository userJpaRepository;
+    private final AttendanceCheckMapper attendanceCheckMapper;
+
+    @Override
+    public Long save(AttendanceCheck attendanceCheck) {
+        RoomJpaEntity roomJpaEntity = roomJpaRepository.findById(attendanceCheck.getRoomId()).orElseThrow(
+                () -> new EntityNotFoundException(ROOM_NOT_FOUND)
+        );
+
+        UserJpaEntity userJpaEntity = userJpaRepository.findById(attendanceCheck.getCreatorId()).orElseThrow(
+                () -> new EntityNotFoundException(USER_NOT_FOUND)
+        );
+
+        return attendanceCheckJpaRepository.save(
+                attendanceCheckMapper.toJpaEntity(attendanceCheck, roomJpaEntity, userJpaEntity)
+        ).getAttendanceCheckId();
+    }
+}

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

@@ -0,0 +1,27 @@
+package konkuk.thip.room.adapter.out.persistence;
+
+import konkuk.thip.room.adapter.out.mapper.AttendanceCheckMapper;
+import konkuk.thip.room.adapter.out.persistence.repository.attendancecheck.AttendanceCheckJpaRepository;
+import konkuk.thip.room.application.port.out.AttendanceCheckQueryPort;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Repository;
+
+import java.time.LocalDateTime;
+
+import static konkuk.thip.common.entity.StatusType.ACTIVE;
+
+@Repository
+@RequiredArgsConstructor
+public class AttendanceCheckQueryPersistenceAdapter implements AttendanceCheckQueryPort {
+
+    private final AttendanceCheckJpaRepository attendanceCheckJpaRepository;
+    private final AttendanceCheckMapper attendanceCheckMapper;
+
+    @Override
+    public int countAttendanceChecksOnTodayByUser(Long userId, Long roomId) {
+        LocalDateTime startOfDay = LocalDateTime.now().toLocalDate().atStartOfDay();
+        LocalDateTime endOfDay = startOfDay.plusDays(1);
+
+        return attendanceCheckJpaRepository.countByUserIdAndRoomIdAndCreatedAtBetween(userId, roomId, startOfDay, endOfDay, ACTIVE);
+    }
+}

src/main/java/konkuk/thip/room/adapter/out/persistence/repository/attendancecheck/AttendanceCheckJpaRepository.java

@@ -0,0 +1,21 @@
+package konkuk.thip.room.adapter.out.persistence.repository.attendancecheck;
+
+import konkuk.thip.common.entity.StatusType;
+import konkuk.thip.room.adapter.out.jpa.AttendanceCheckJpaEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+import java.time.LocalDateTime;
+
+public interface AttendanceCheckJpaRepository extends JpaRepository<AttendanceCheckJpaEntity, Long> {
+
+    // TODO : count 값을 매번 쿼리를 통해 계산하는게 아니라 DB에 저장 or redis 캐시에 저장하는 방법도 좋을 듯
+    @Query("SELECT COUNT(a) FROM AttendanceCheckJpaEntity a " +
+            "WHERE a.userJpaEntity.userId = :userId " +
+            "AND a.roomJpaEntity.roomId = :roomId " +
+            "AND a.status = :status " +
+            "AND a.createdAt >= :startOfDay " +
+            "AND a.createdAt < :endOfDay")
+    int countByUserIdAndRoomIdAndCreatedAtBetween(@Param("userId") Long userId, @Param("roomId") Long roomId, @Param("startOfDay") LocalDateTime startOfDay, @Param("endOfDay") LocalDateTime endOfDay, @Param("status")StatusType status);
+}

src/main/java/konkuk/thip/room/application/port/in/AttendanceCheckCreateUseCase.java

@@ -0,0 +1,9 @@
+package konkuk.thip.room.application.port.in;
+
+import konkuk.thip.room.application.port.in.dto.AttendanceCheckCreateCommand;
+import konkuk.thip.room.application.port.in.dto.AttendanceCheckCreateResult;
+
+public interface AttendanceCheckCreateUseCase {
+
+    AttendanceCheckCreateResult create(AttendanceCheckCreateCommand command);
+}

src/main/java/konkuk/thip/room/application/port/in/dto/AttendanceCheckCreateCommand.java

@@ -0,0 +1,7 @@
+package konkuk.thip.room.application.port.in.dto;
+
+public record AttendanceCheckCreateCommand(
+        Long creatorId,
+        Long roomId,
+        String content
+) { }