hotfix: gpt prompt 수정

Author: 2ghrms

src/main/java/com/haru/api/domain/moodTracker/service/MoodTrackerReportServiceImpl.java

@@ -125,6 +125,59 @@ public void generateReport(Long moodTrackerId) {
 
     }
 
+    /* ========================= 헬퍼들 ========================= */
+
+    @SuppressWarnings("unchecked")
+    private String extractContentSafely(Map<String, Object> responseBody) {
+        Object choicesObj = responseBody.get("choices");
+        if (!(choicesObj instanceof List<?> choices) || choices.isEmpty())
+            throw new MoodTrackerHandler(ErrorStatus.GPT_FAILED);
+
+        Object first = choices.get(0);
+        if (!(first instanceof Map<?, ?> firstMap))
+            throw new MoodTrackerHandler(ErrorStatus.GPT_FAILED);
+
+        Object messageObj = firstMap.get("message");
+        if (messageObj instanceof Map<?, ?> messageMap) {
+            Object contentObj = messageMap.get("content");
+            if (contentObj instanceof String s) return s;
+        }
+        Object textObj = firstMap.get("text");
+        if (textObj instanceof String s) return s;
+
+        throw new MoodTrackerHandler(ErrorStatus.GPT_FAILED);
+    }
+
+    /** ```json ... ``` 형태여도 첫 번째 JSON 오브젝트만 추출 */
+    private String extractFirstJsonObject(String content) {
+        if (content == null || content.isBlank())
+            throw new MoodTrackerHandler(ErrorStatus.GPT_FAILED);
+
+        String cleaned = content
+                .replaceAll("(?s)```json\\s*", "")
+                .replaceAll("(?s)```\\s*", "")
+                .trim();
+
+        int start = cleaned.indexOf('{');
+        int end = findMatchingBrace(cleaned, start);
+        if (start >= 0 && end > start) return cleaned.substring(start, end + 1);
+        return cleaned; // 순수 JSON일 수도 있음
+    }
+
+    private int findMatchingBrace(String s, int start) {
+        if (start < 0) return -1;
+        int depth = 0;
+        for (int i = start; i < s.length(); i++) {
+            char c = s.charAt(i);
+            if (c == '{') depth++;
+            else if (c == '}') {
+                depth--;
+                if (depth == 0) return i;
+            }
+        }
+        return -1;
+    }
+
     private String buildPrompt(String title,
                                List<SurveyQuestion> questions,
                                Map<Long, List<SubjectiveAnswer>> subjectiveMap,

src/main/java/com/haru/api/global/apiPayload/code/status/ErrorStatus.java

@@ -72,6 +72,9 @@ public enum ErrorStatus implements BaseErrorCode {
     MAIL_SEND_FAIL(HttpStatus.INTERNAL_SERVER_ERROR, "MAIL500", "이메일 전송에 실패했습니다. (존재하지 않는 이메일일 수 있습니다)"),
     MAIL_INVALID_FORMAT(HttpStatus.BAD_REQUEST, "MAIL400", "이메일 형식이 잘못되었습니다."),
 
+    // GPT 에러
+    GPT_FAILED(HttpStatus.SERVICE_UNAVAILABLE, "GPT500", "GPT 에러입니다."),
+
     // SNS 이벤트 관련 에러
     SNS_EVENT_NOT_FOUND(HttpStatus.BAD_REQUEST, "SNSEVENT4001", "SNS 이벤트가 존재하지 않습니다."),
     SNS_EVENT_LINK_NOT_FOUND(HttpStatus.BAD_REQUEST, "SNS_EVENT4002", "잘못된 인스타그램 게시물 링크 형식입니다."),

src/main/java/com/haru/api/infra/api/client/ChatGPTClient.java

@@ -155,7 +155,7 @@ public Mono<SurveyReportResponse> getMoodTrackerReport(String userMessageContent
         sb.append("### 3. 자유 응답 기반 주요 키워드 정리\n");
         sb.append("   - 예: 잦힌 (37건), 말은 덜 불분명 (29건) 등\n\n");
 
-        sb.append("응답은 반드시 다음 JSON 형식으로 해줘. 형식만 따르고, 값은 생성한 값을 넣어줘야해. 질문에 대한 제안은 입력받은 질문 Id와 해당 질문에 매칭되는 제안 내용을 넣어줘. : \n");
+        sb.append("응답은 반드시 다음 JSON 형식으로 해줘. 벡틱(`)과 json 표시는 제외하고 본문만 출력해줘야해. 형식만 따르고, 값은 생성한 값을 넣어줘야해. 질문에 대한 제안은 입력받은 질문 Id와 해당 질문에 매칭되는 제안 내용을 넣어줘. : \n");
         sb.append("{\n");
         sb.append("  \"report\": \"전체 리포트 마크다운 텍스트\",\n");
         sb.append("  \"suggestionsByQuestionId\": {\n");

src/main/java/com/haru/api/infra/redis/RedisReportConsumer.java

@@ -17,6 +17,7 @@
 @RequiredArgsConstructor
 public class RedisReportConsumer {
 
+    private final MoodTrackerReportService reportService;
     private final StringRedisTemplate redisTemplate;
 
     @Value("${queue-name}")
@@ -75,13 +76,10 @@ public void pollFailedQueueEvery1Minutes() {
 
         for (String id : failedIds) {
             try {
-                // 다시 워커 큐로 push
-                redisTemplate.opsForList().leftPush("REPORT_WORKER_QUEUE", id);
-                log.info("[RedisReportConsumer] 실패 큐 재실행 → {}", id);
+                reportService.generateAndUploadReportFileAndThumbnail(Long.valueOf(id));
 
                 // 실패 큐에서 제거
-                redisTemplate.opsForZSet().remove("REPORT_FAILED_QUEUE", id);
-
+                redisTemplate.opsForZSet().remove(FAILED_QUEUE, id);
             } catch (Exception e) {
                 log.error("[RedisReportConsumer] 실패 큐 재실행 중 에러 → {}", id, e);
             }