[feat] AI 기반 독후감 생성 api 구현

build.gradle

@@ -98,6 +98,10 @@ dependencies {
 
     // LogStash
     implementation 'net.logstash.logback:logstash-logback-encoder:7.4'
+
+	// Spring AI - Google AI(Gemini) 연동
+	implementation platform("org.springframework.ai:spring-ai-bom:1.0.0-M6")
+	implementation 'org.springframework.ai:spring-ai-openai-spring-boot-starter'
 }
 
 def querydslDir = layout.buildDirectory.dir("generated/querydsl").get().asFile

src/main/java/konkuk/thip/common/ai/adapter/out/GeminiAdapter.java

@@ -0,0 +1,94 @@
+package konkuk.thip.common.ai.adapter.out;
+
+import konkuk.thip.book.domain.Book;
+import konkuk.thip.common.ai.application.out.GeminiLoadPort;
+import konkuk.thip.common.exception.InternalServerException;
+import konkuk.thip.common.exception.code.ErrorCode;
+import konkuk.thip.roompost.domain.Record;
+import konkuk.thip.user.domain.User;
+import lombok.RequiredArgsConstructor;
+import org.springframework.ai.chat.client.ChatClient;
+import org.springframework.ai.chat.prompt.PromptTemplate;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+@Component
+@RequiredArgsConstructor
+public class GeminiAdapter implements GeminiLoadPort {
+
+    private final ChatClient chatClient;
+
+    private static final String TEMPLATE = """
+        시스템: 당신은 한국어 글쓰기 튜터이자 서평가이다. 사용자의 기록을 바탕으로 논리적이고 깔끔한 독서 감상문을 작성한다.
+
+        어투/스타일 규칙:
+        - 시점: 1인칭(저는/제가)
+        - 종결어미: 일관된 존댓말(~습니다/~합니다)
+        - 문장은 간결하고 매 단락의 주제가 분명해야 함
+        - 과도한 추측/단정 금지, 기록에 근거하여 주장 전개
+        - 필요 시 (p.페이지)로 근거 표기
+
+        책 메타데이터:
+        - 책 제목: {bookTitle}
+        - 책 설명: {bookDescription}
+
+        사용자 정보:
+        - 닉네임: {nickname}
+        - 칭호: {alias}
+        - 현재 누적 독후감 생성 횟수: {reviewCount}회
+
+        입력 기록(페이지 오름차순, 요약/정제됨):
+        {records}
+
+        작성 지시:
+        1) 서론-본론-결론 3단 구성으로 작성합니다.
+        2) 서론: 책 설명을 바탕으로 이번 독서의 관점/목표를 간단히 밝힙니다.
+        3) 본론: 기록에서 드러난 핵심 주제 2~3가지를 선택해 근거와 함께 설명합니다. 필요한 곳에 (p.xx) 표기.
+        4) 결론: 독서 전후의 생각 변화/적용 계획을 간단히 정리합니다.
+        5) 전체 분량은 대략 {minLen}~{maxLen}자 수준으로 맞춥니다.
+
+        이제 위 정보를 바탕으로 독서 감상문을 작성하세요.
+        """;
+
+    @Override
+    public String generateRecordReview(User user, List<Record> records, Book book, int minLength, int maxLength) {
+        // 방어 로직: records 비어있을 수 있음 (상위 유효성에서 걸러도 한 번 더 안전장치)
+        if (records == null || records.isEmpty()) {
+            throw new InternalServerException(ErrorCode.GEMINI_API_REQUEST_ERROR,
+                    new IllegalArgumentException("기록이 비어있습니다."));
+        }
+
+        String recordsBlock = records.stream()
+                .map(r -> "- p." + r.getPage() + ": " + r.getContent())
+                .collect(Collectors.joining("\n"));
+
+        String bookTitle = book.getTitle();
+        String bookDesc  = book.getDescription() == null ? "설명 없음" : book.getDescription();
+
+        // 템플릿 렌더링
+        String prompt = new PromptTemplate(TEMPLATE).render(Map.of(
+                "bookTitle", bookTitle,
+                "bookDescription", bookDesc,
+                "nickname", user.getNickname(),
+                "alias", user.getAlias().getValue(),
+                "reviewCount", String.valueOf(user.getRecordReviewCount()),
+                "records", recordsBlock,
+                "minLen", minLength,   // 필요 시 파라미터화
+                "maxLen", maxLength   // 필요 시 파라미터화
+        ));
+
+        try {
+            // Spring AI ChatClient 호출
+            return chatClient
+                    .prompt()
+                    .user(prompt)
+                    .call()
+                    .content();
+        } catch (Exception e) {
+            throw new InternalServerException(ErrorCode.GEMINI_API_RESPONSE_ERROR, e);
+        }
+    }
+}

src/main/java/konkuk/thip/common/ai/application/out/GeminiLoadPort.java

@@ -0,0 +1,11 @@
+package konkuk.thip.common.ai.application.out;
+
+import konkuk.thip.book.domain.Book;
+import konkuk.thip.roompost.domain.Record;
+import konkuk.thip.user.domain.User;
+
+import java.util.List;
+
+public interface GeminiLoadPort {
+    String generateRecordReview(User user, List<Record> records, Book book, int minLength, int maxLength);
+}

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

@@ -54,6 +54,7 @@ public enum ErrorCode implements ResponseCode {
     USER_CANNOT_DELETE_ROOM_HOST(HttpStatus.BAD_REQUEST, 70009, "모집/진행 중인 방의 방장은 회원탈퇴를 할 수 없습니다."),
     USER_ALREADY_DELETED(HttpStatus.BAD_REQUEST, 70010, "이미 삭제된 사용자 입니다."),
     USER_OAUTH2ID_CANNOT_BE_NULL(HttpStatus.INTERNAL_SERVER_ERROR, 70011, "유저의 OAuth2Id 값이 null일 수 없습니다."),
+    USER_RECORD_REVIEW_COUNT_EXCEEDS_LIMIT(HttpStatus.BAD_REQUEST, 70012, "사용자의 독후감 작성 수가 5회를 초과할 수 없습니다."),
 
     /**
      * 75000 : follow error
@@ -134,6 +135,7 @@ public enum ErrorCode implements ResponseCode {
     RECORD_CANNOT_BE_OVERVIEW(HttpStatus.BAD_REQUEST, 130001, "총평이 될 수 없는 RECORD 입니다."),
     INVALID_RECORD_PAGE_RANGE(HttpStatus.BAD_REQUEST, 130002, "RECORD의 page 값이 유효하지 않습니다."),
     RECORD_ACCESS_FORBIDDEN(HttpStatus.FORBIDDEN, 130003, "기록 접근 권한이 없습니다."),
+    RECORD_REVIEW_NOT_ENOUGH_RECORDS(HttpStatus.BAD_REQUEST, 130004, "독후감 생성을 위해서는 최소 2개의 기록이 필요합니다."),
 
     /**
      * 140000 : roomParticipant error
@@ -243,6 +245,13 @@ public enum ErrorCode implements ResponseCode {
      */
     INVALID_FE_PLATFORM(HttpStatus.BAD_REQUEST, 300000, "유효하지 않은 FE 플랫폼입니다."),
 
+
+    /**
+     * 310000 : gemini error
+     */
+    GEMINI_API_REQUEST_ERROR(HttpStatus.INTERNAL_SERVER_ERROR, 310000,"Gemini API 요청에 실패하였습니다."),
+    GEMINI_API_RESPONSE_ERROR(HttpStatus.INTERNAL_SERVER_ERROR, 310001,"Gemini API 응답에 실패하였습니다."),
+
     ;
 
     private final HttpStatus httpStatus;

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

@@ -165,6 +165,20 @@ public enum SwaggerResponseDescription {
             ROOM_IS_EXPIRED,
             ROOM_NOT_IN_PROGRESS
     ))),
+    RECORD_AI_REVIEW_CREATE(new LinkedHashSet<>(Set.of(
+            USER_NOT_FOUND,
+            ROOM_NOT_FOUND,
+            RECORD_NOT_FOUND,
+            ROOM_ACCESS_FORBIDDEN,
+            RECORD_REVIEW_NOT_ENOUGH_RECORDS,
+            USER_RECORD_REVIEW_COUNT_EXCEEDS_LIMIT,
+            GEMINI_API_REQUEST_ERROR,
+            GEMINI_API_RESPONSE_ERROR
+    ))),
+    RECORD_AI_USAGE(new LinkedHashSet<>(Set.of(
+            USER_NOT_FOUND,
+            ROOM_ACCESS_FORBIDDEN
+    ))),
 
     // Vote
     VOTE_CREATE(new LinkedHashSet<>(Set.of(

src/main/java/konkuk/thip/config/GeminiAiConfig.java

@@ -0,0 +1,14 @@
+package konkuk.thip.config;
+
+import org.springframework.ai.chat.client.ChatClient;
+import org.springframework.ai.chat.model.ChatModel;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class GeminiAiConfig {
+    @Bean
+    public ChatClient chatClient(ChatModel geminiModel) {
+        return ChatClient.builder(geminiModel).build();
+    }
+}

src/main/java/konkuk/thip/roompost/adapter/in/web/RoomPostCommandController.java

@@ -33,6 +33,8 @@ public class RoomPostCommandController {
     private final AttendanceCheckCreateUseCase attendanceCheckCreateUseCase;
     private final AttendanceCheckDeleteUseCase attendanceCheckDeleteUseCase;
 
+    private final RecordReviewCreateUseCase recordReviewCreateUseCase;
+
     /**
      * 기록 관련
      */
@@ -179,4 +181,20 @@ public BaseResponse<AttendanceCheckDeleteResponse> deleteAttendanceCheck(
                 attendanceCheckDeleteUseCase.delete(userId, roomId, attendanceCheckId)
         ));
     }
+
+    @Operation(
+            summary = "AI 기반 기록 독후감 생성",
+            description = "AI를 활용하여 사용자가 작성한 기록을 바탕으로 독후감을 생성합니다."
+    )
+    @ExceptionDescription(RECORD_AI_REVIEW_CREATE)
+    @PostMapping("/rooms/{roomId}/record/ai-review")
+    public BaseResponse<RecordReviewCreateResponse> createAIRecordReview(
+            @Parameter(hidden = true) @UserId final Long userId,
+            @Parameter(description = "독후감을 생성할 방 ID", example = "1") @PathVariable final Long roomId
+    ) {
+        return BaseResponse.ok(
+                RecordReviewCreateResponse.of(
+                        recordReviewCreateUseCase.createAiRecordReview(roomId, userId)
+                ));
+    }
 }

src/main/java/konkuk/thip/roompost/adapter/in/web/RoomPostQueryController.java

@@ -6,14 +6,16 @@
 import konkuk.thip.common.dto.BaseResponse;
 import konkuk.thip.common.security.annotation.UserId;
 import konkuk.thip.common.swagger.annotation.ExceptionDescription;
+import konkuk.thip.roompost.adapter.in.web.request.RecordAiUsageResponse;
 import konkuk.thip.roompost.adapter.in.web.response.AttendanceCheckShowResponse;
 import konkuk.thip.roompost.adapter.in.web.response.RecordPinResponse;
 import konkuk.thip.roompost.adapter.in.web.response.RoomPostSearchResponse;
 import konkuk.thip.roompost.application.port.in.AttendanceCheckShowUseCase;
+import konkuk.thip.roompost.application.port.in.RecordAiUsageUseCase;
 import konkuk.thip.roompost.application.port.in.RecordPinUseCase;
 import konkuk.thip.roompost.application.port.in.RoomPostSearchUseCase;
-import konkuk.thip.roompost.application.port.in.dto.record.RecordPinQuery;
 import konkuk.thip.roompost.application.port.in.dto.RoomPostSearchQuery;
+import konkuk.thip.roompost.application.port.in.dto.record.RecordPinQuery;
 import lombok.RequiredArgsConstructor;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
@@ -30,6 +32,7 @@ public class RoomPostQueryController {
     private final RoomPostSearchUseCase roomPostSearchUseCase;
     private final RecordPinUseCase recordPinUseCase;
     private final AttendanceCheckShowUseCase attendanceCheckShowUseCase;
+    private final RecordAiUsageUseCase recordAiUsageUseCase;
 
     @Operation(
             summary = "방의 게시글(기록, 투표) 목록 조회",
@@ -100,4 +103,20 @@ public BaseResponse<AttendanceCheckShowResponse> showDailyGreeting(
             @Parameter(hidden = true) @UserId final Long userId) {
         return BaseResponse.ok(attendanceCheckShowUseCase.showDailyGreeting(userId, roomId, cursor));
     }
+
+    @Operation(
+            summary = "사용자의 AI 이용 횟수 및 기록 작성 횟수 조회",
+            description = "사용자의 AI 이용 횟수 및 기록 작성 횟수를 조회합니다."
+    )
+    @ExceptionDescription(RECORD_AI_USAGE)
+    @GetMapping("/rooms/{roomId}/users/ai-usage")
+    public BaseResponse<RecordAiUsageResponse> getUserAiUsageCount(
+            @Parameter(description = "조회할 방 ID", example = "1") @PathVariable final Long roomId,
+            @Parameter(hidden = true) @UserId final Long userId) {
+        return BaseResponse.ok(
+                RecordAiUsageResponse.of(
+                        recordAiUsageUseCase.getUserAiUsage(userId, roomId)
+                )
+        );
+    }
 }

src/main/java/konkuk/thip/roompost/adapter/in/web/request/RecordAiUsageResponse.java

@@ -0,0 +1,15 @@
+package konkuk.thip.roompost.adapter.in.web.request;
+
+import konkuk.thip.roompost.application.port.in.dto.record.RecordAiUsageResult;
+
+public record RecordAiUsageResponse(
+        Integer recordReviewCount,
+        Integer recordCount
+) {
+    public static RecordAiUsageResponse of(RecordAiUsageResult result) {
+        return new RecordAiUsageResponse(
+                result.recordReviewCount(),
+                result.recordCount()
+        );
+    }
+}

src/main/java/konkuk/thip/roompost/adapter/in/web/response/RecordReviewCreateResponse.java

@@ -0,0 +1,12 @@
+package konkuk.thip.roompost.adapter.in.web.response;
+
+import konkuk.thip.roompost.application.port.in.dto.record.RecordReviewCreateResult;
+
+public record RecordReviewCreateResponse(
+        String content,
+        int count
+) {
+    public static RecordReviewCreateResponse of(RecordReviewCreateResult result) {
+        return new RecordReviewCreateResponse(result.content(), result.reviewCount());
+    }
+}

src/main/java/konkuk/thip/roompost/adapter/out/persistence/RecordQueryPersistenceAdapter.java

@@ -2,9 +2,11 @@
 
 import konkuk.thip.common.util.Cursor;
 import konkuk.thip.common.util.CursorBasedList;
+import konkuk.thip.roompost.adapter.out.mapper.RecordMapper;
 import konkuk.thip.roompost.adapter.out.persistence.repository.record.RecordJpaRepository;
 import konkuk.thip.roompost.application.port.out.RecordQueryPort;
 import konkuk.thip.roompost.application.port.out.dto.RoomPostQueryDto;
+import konkuk.thip.roompost.domain.Record;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Repository;
 
@@ -15,6 +17,7 @@
 public class RecordQueryPersistenceAdapter implements RecordQueryPort {
 
     private final RecordJpaRepository recordJpaRepository;
+    private final RecordMapper recordMapper;
 
     @Override
     public CursorBasedList<RoomPostQueryDto> searchMyRecords(Long roomId, Long userId, Cursor cursor) {
@@ -63,4 +66,16 @@ public CursorBasedList<RoomPostQueryDto> searchGroupRecordsByComment(Long roomId
             return nextCursor.toEncodedString();
         });
     }
+
+    @Override
+    public List<Record> findAllByRoomIdAndUserId(Long roomId, Long userId) {
+        return recordJpaRepository.findAllByRoomIdAndUserIdOrderByPageAsc(roomId, userId).stream()
+                .map(recordMapper::toDomainEntity)
+                .toList();
+    }
+
+    @Override
+    public Integer countAllByRoomIdAndUserId(Long roomId, Long userId) {
+        return recordJpaRepository.countAllByRoomIdAndUserId(roomId, userId);
+    }
 }

src/main/java/konkuk/thip/roompost/adapter/out/persistence/repository/record/RecordJpaRepository.java

@@ -22,4 +22,17 @@ public interface RecordJpaRepository extends JpaRepository<RecordJpaEntity, Long
     @Modifying(clearAutomatically = true, flushAutomatically = true)
     @Query("UPDATE RecordJpaEntity r SET r.status = 'INACTIVE' WHERE r.userJpaEntity.userId = :userId")
     void softDeleteAllByUserId(@Param("userId") Long userId);
+
+    @Query("SELECT r FROM RecordJpaEntity r " +
+            "WHERE r.roomJpaEntity.roomId = :roomId " +
+            "AND r.userJpaEntity.userId = :userId " +
+            "AND r.isOverview = false " +
+            "ORDER BY r.page ASC")
+    List<RecordJpaEntity> findAllByRoomIdAndUserIdOrderByPageAsc(Long roomId, Long userId);
+
+    @Query("SELECT COUNT(r) FROM RecordJpaEntity r " +
+            "WHERE r.roomJpaEntity.roomId = :roomId " +
+            "AND r.userJpaEntity.userId = :userId " +
+            "AND r.isOverview = false")
+    Integer countAllByRoomIdAndUserId(Long roomId, Long userId);
 }

src/main/java/konkuk/thip/roompost/application/port/in/RecordAiUsageUseCase.java

@@ -0,0 +1,7 @@
+package konkuk.thip.roompost.application.port.in;
+
+import konkuk.thip.roompost.application.port.in.dto.record.RecordAiUsageResult;
+
+public interface RecordAiUsageUseCase {
+    RecordAiUsageResult getUserAiUsage(Long userId, Long roomId);
+}

src/main/java/konkuk/thip/roompost/application/port/in/RecordReviewCreateUseCase.java

@@ -0,0 +1,8 @@
+package konkuk.thip.roompost.application.port.in;
+
+import konkuk.thip.roompost.application.port.in.dto.record.RecordReviewCreateResult;
+
+public interface RecordReviewCreateUseCase {
+
+    RecordReviewCreateResult createAiRecordReview(Long roomId, Long userId);
+}

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

@@ -0,0 +1,7 @@
+package konkuk.thip.roompost.application.port.in.dto.record;
+
+public record RecordAiUsageResult(
+        Integer recordReviewCount,
+        Integer recordCount
+) {
+}

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

@@ -0,0 +1,7 @@
+package konkuk.thip.roompost.application.port.in.dto.record;
+
+public record RecordReviewCreateResult(
+        String content,
+        int reviewCount
+) {
+}

src/main/java/konkuk/thip/roompost/application/port/out/RecordQueryPort.java

@@ -3,6 +3,9 @@
 import konkuk.thip.common.util.Cursor;
 import konkuk.thip.common.util.CursorBasedList;
 import konkuk.thip.roompost.application.port.out.dto.RoomPostQueryDto;
+import konkuk.thip.roompost.domain.Record;
+
+import java.util.List;
 
 public interface RecordQueryPort {
 
@@ -13,5 +16,9 @@ public interface RecordQueryPort {
     CursorBasedList<RoomPostQueryDto> searchGroupRecordsByLike(Long roomId, Long userId, Cursor cursor, Integer pageStart, Integer pageEnd, Boolean isOverview);
 
     CursorBasedList<RoomPostQueryDto> searchGroupRecordsByComment(Long roomId, Long userId, Cursor cursor, Integer pageStart, Integer pageEnd, Boolean isOverview);
+
+    List<Record> findAllByRoomIdAndUserId(Long roomId, Long userId);
+
+    Integer countAllByRoomIdAndUserId(Long roomId, Long userId);
 }