변경된 요구사항에 따른 톡픽 본문 요약 기능 구현

src/main/java/balancetalk/talkpick/application/TalkPickService.java

@@ -13,6 +13,7 @@
 import balancetalk.member.dto.GuestOrApiMember;
 import balancetalk.talkpick.domain.TalkPick;
 import balancetalk.talkpick.domain.TalkPickFileHandler;
+import balancetalk.talkpick.domain.TalkPickSummarizer;
 import balancetalk.talkpick.domain.repository.TalkPickRepository;
 import balancetalk.vote.domain.TalkPickVote;
 import java.util.List;
@@ -30,15 +31,20 @@ public class TalkPickService {
     private final MemberRepository memberRepository;
     private final TalkPickRepository talkPickRepository;
     private final TalkPickFileHandler talkPickFileHandler;
+    private final TalkPickSummarizer talkPickSummarizer;
 
     @Transactional
     public Long createTalkPick(CreateTalkPickRequest request, ApiMember apiMember) {
         Member member = apiMember.toMember(memberRepository);
         TalkPick savedTalkPick = talkPickRepository.save(request.toEntity(member));
         Long savedTalkPickId = savedTalkPick.getId();
+
         if (request.containsFileIds()) {
             talkPickFileHandler.handleFilesOnTalkPickCreate(request.getFileIds(), savedTalkPickId);
         }
+
+        talkPickSummarizer.summary(savedTalkPick);
+
         return savedTalkPickId;
     }
 
@@ -81,6 +87,7 @@ public void updateTalkPick(Long talkPickId, UpdateTalkPickRequest request, ApiMe
         talkPick.update(request.toEntity(member));
         talkPickFileHandler
                 .handleFilesOnTalkPickUpdate(request.getNewFileIds(), request.getDeleteFileIds(), talkPickId);
+        talkPickSummarizer.summary(talkPick);
     }
 
     @Transactional

src/main/java/balancetalk/talkpick/domain/SummaryStatus.java

@@ -0,0 +1,5 @@
+package balancetalk.talkpick.domain;
+
+public enum SummaryStatus {
+    PENDING, SUCCESS, FAIL, NOT_REQUIRED
+}

src/main/java/balancetalk/talkpick/domain/TalkPick.java

@@ -20,6 +20,7 @@
 import jakarta.persistence.ManyToOne;
 import jakarta.persistence.OneToMany;
 import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
 import jakarta.validation.constraints.PositiveOrZero;
 import jakarta.validation.constraints.Size;
 import java.time.LocalDate;
@@ -40,6 +41,8 @@
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
 public class TalkPick extends BaseTimeEntity {
 
+    private static final int MIN_CONTENT_LENGTH_FOR_SUMMARY = 200;
+
     @Id
     @GeneratedValue(strategy = GenerationType.IDENTITY)
     private Long id;
@@ -55,6 +58,9 @@ public class TalkPick extends BaseTimeEntity {
     @Embedded
     private Summary summary;
 
+    @NotNull
+    private SummaryStatus summaryStatus;
+
     @NotBlank
     @Size(max = 2000)
     private String content;
@@ -146,6 +152,14 @@ public NotificationHistory getNotificationHistory() {
         return this.notificationHistory;
     }
 
+    public boolean hasShortContent() {
+        return content.length() < MIN_CONTENT_LENGTH_FOR_SUMMARY;
+    }
+
+    public void updateSummaryStatus(SummaryStatus summaryStatus) {
+        this.summaryStatus = summaryStatus;
+    }
+
     public TodayTalkPick toTodayTalkPick() {
         return TodayTalkPick.builder()
                 .pickDate(LocalDate.now())

src/main/java/balancetalk/talkpick/domain/TalkPickSummarizer.java

@@ -0,0 +1,104 @@
+package balancetalk.talkpick.domain;
+
+import static balancetalk.global.exception.ErrorCode.SUMMARY_SIZE_IS_OVER;
+import static balancetalk.talkpick.domain.SummaryStatus.FAIL;
+import static balancetalk.talkpick.domain.SummaryStatus.NOT_REQUIRED;
+import static balancetalk.talkpick.domain.SummaryStatus.SUCCESS;
+
+import balancetalk.global.exception.BalanceTalkException;
+import balancetalk.talkpick.dto.fields.BaseTalkPickFields;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.ai.chat.client.ChatClient;
+import org.springframework.ai.chat.client.advisor.SimpleLoggerAdvisor;
+import org.springframework.retry.annotation.Backoff;
+import org.springframework.retry.annotation.Recover;
+import org.springframework.retry.annotation.Retryable;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class TalkPickSummarizer {
+
+    private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
+
+    private final ChatClient chatClient;
+
+    @Async
+    @Retryable(backoff = @Backoff(delay = 1000), maxAttempts = 3)
+    @Transactional
+    public void summary(TalkPick talkPick) {
+        // 본문 글자수가 너무 짧으면 요약 제공 안함
+        if (talkPick.hasShortContent()) {
+            talkPick.updateSummaryStatus(NOT_REQUIRED);
+            return;
+        }
+
+        // 요약 수행
+        Summary summary = getSummary(talkPick);
+
+        // 요약 글자수 검증
+        if (summary.isOverSize()) {
+            throw new BalanceTalkException(SUMMARY_SIZE_IS_OVER);
+        }
+
+        // 톡픽 요약 내용 및 상태 업데이트
+        talkPick.updateSummary(summary);
+        talkPick.updateSummaryStatus(SUCCESS);
+    }
+
+    private Summary getSummary(TalkPick talkPick) {
+        return chatClient.prompt()
+                .advisors(new SimpleLoggerAdvisor())
+                .system("""
+                        당신은 저에게 고용된 노동자입니다.
+                        당신의 역할은 게시글을 작성한 사용자가 되어, 사용자의 어투 및 문체와 동일하게 3줄로 요약하는 것입니다.
+
+                        다음은 이 작업에 대한 접근 방식입니다:
+                        Step 1: 제목, 선택지 A, 선택지 B, 그리고 본문 내용을 바탕으로 맥락을 파악합니다.
+                        Step 2: 파악한 맥락을 토대로 본문 중 불필요한 내용 혹은 표현을 제거합니다.
+                        Step 3: 사용자가 두 가지 선택지 중 선택하길 원한다는 사실을 전제로 합니다.
+                        Step 4: 마지막 3번째 문장에는 주요 비교군을 명확히 제시하는 질문을 배치합니다.
+                        Step 5: 요약한 3개의 문장을 JSON 형태로 된 firstLine, secondLine, thirdLine 키에 각각 한 문장씩 담습니다.
+
+                        지금부터 주어진 단계별로 요약을 진행하세요.
+                        작업을 아주 잘 수행할 경우, 10만 달러의 인센티브를 제공할게요. 당신은 최고의 전문가니까 잘 해낼 수 있을 것이라 믿어요.
+                        """)
+                .user(u -> u.text("""
+                        제목: {title}
+                        선택지 A: {optionA}
+                        선택지 B: {optionB}
+                        본문: {content}
+                        """).params(getBaseTalkPickFieldsMap(talkPick)))
+                .call()
+                .entity(Summary.class);
+    }
+
+    private Map<String, Object> getBaseTalkPickFieldsMap(TalkPick talkPick) {
+        return OBJECT_MAPPER.convertValue(
+                getBaseTalkPickFields(talkPick),
+                new TypeReference<ConcurrentHashMap<String, Object>>() {});
+    }
+
+    private BaseTalkPickFields getBaseTalkPickFields(TalkPick talkPick) {
+        return BaseTalkPickFields.from(
+                talkPick.getTitle(),
+                talkPick.getContent(),
+                talkPick.getOptionA(),
+                talkPick.getOptionB());
+    }
+
+    @Recover
+    public void recoverSummary(Throwable ex, TalkPick talkPick) {
+        log.error("Fail to summary ID={} TalkPick", talkPick.getId());
+        log.error("exception message = {} {}", ex.getMessage(), ex.getStackTrace());
+        talkPick.updateSummaryStatus(FAIL);
+    }
+}

src/main/java/balancetalk/talkpick/dto/TalkPickDto.java

@@ -7,6 +7,7 @@
 import balancetalk.bookmark.domain.TalkPickBookmark;
 import balancetalk.comment.domain.Comment;
 import balancetalk.member.domain.Member;
+import balancetalk.talkpick.domain.SummaryStatus;
 import balancetalk.talkpick.domain.TalkPick;
 import balancetalk.talkpick.dto.fields.BaseTalkPickFields;
 import balancetalk.talkpick.dto.fields.ValidatedNotBlankTalkPickFields;
@@ -47,6 +48,7 @@ public TalkPick toEntity(Member member) {
                     .optionA(baseFields.getOptionA())
                     .optionB(baseFields.getOptionB())
                     .sourceUrl(baseFields.getSourceUrl())
+                    .summaryStatus(SummaryStatus.PENDING)
                     .views(0L)
                     .bookmarks(0L)
                     .viewStatus(NORMAL)
@@ -82,6 +84,7 @@ public TalkPick toEntity(Member member) {
                     .optionA(baseFields.getOptionA())
                     .optionB(baseFields.getOptionB())
                     .sourceUrl(baseFields.getSourceUrl())
+                    .summaryStatus(SummaryStatus.PENDING)
                     .editedAt(LocalDateTime.now())
                     .build();
         }
@@ -112,6 +115,8 @@ public static class TalkPickDetailResponse {
 
         private SummaryResponse summary;
 
+        private SummaryStatus summaryStatus;
+
         @Schema(description = "톡픽 작성 시 첨부한 이미지 URL 목록",
                 example = "["
                         + "\"https://picko-image.amazonaws.com/temp-talk-pick/ad80-a94e083301d2_czz.png\",\n"
@@ -164,6 +169,7 @@ public static TalkPickDetailResponse from(TalkPick entity,
                             .sourceUrl(entity.getSourceUrl())
                             .build())
                     .summary(new SummaryResponse(entity.getSummary()))
+                    .summaryStatus(entity.getSummaryStatus())
                     .imgUrls(imgUrls)
                     .fileIds(fileIds)
                     .votesCountOfOptionA(entity.votesCountOf(A))

src/main/java/balancetalk/talkpick/dto/fields/BaseTalkPickFields.java

@@ -1,5 +1,6 @@
 package balancetalk.talkpick.dto.fields;
 
+import com.fasterxml.jackson.annotation.JsonInclude;
 import io.swagger.v3.oas.annotations.media.Schema;
 import jakarta.validation.constraints.Size;
 import lombok.AllArgsConstructor;
@@ -28,6 +29,7 @@ public class BaseTalkPickFields {
     private String optionB;
 
     @Schema(description = "출처 URL", example = "https://github.com/CHZZK-Study/Balance-Talk-Backend/issues/506")
+    @JsonInclude(JsonInclude.Include.NON_NULL)
     private String sourceUrl;
 
     public static BaseTalkPickFields from(String title, String content,
@@ -41,4 +43,14 @@ public static BaseTalkPickFields from(String title, String content,
                 .sourceUrl(sourceUrl)
                 .build();
     }
+
+    public static BaseTalkPickFields from(String title, String content,
+                                          String optionA, String optionB) {
+        return BaseTalkPickFields.builder()
+                .title(title)
+                .content(content)
+                .optionA(optionA)
+                .optionB(optionB)
+                .build();
+    }
 }