mysql rds로 변경

.github/workflows/CI-CD_Pipeline.yml

@@ -463,7 +463,7 @@ jobs:
 
               # prod.env 복원
               install -d -m 700 /home/ec2-user/configs
-              printf "%s" "${{ secrets.PROD_ENV_BASE64 }}" | base64 -d > /home/ec2-user/configs/prod.env
+              printf "%s" "${{ secrets.PROD_TEST_ENV_BASE64 }}" | base64 -d > /home/ec2-user/configs/prod.env
               chmod 600 /home/ec2-user/configs/prod.env
               test -s /home/ec2-user/configs/prod.env || { echo "prod.env empty"; exit 1; }
 

backend/build.gradle

@@ -41,7 +41,6 @@ dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-oauth2-client'
     implementation group: 'org.springframework.boot', name: 'spring-boot-starter-mail', version: '3.0.5'
     implementation 'org.springframework.boot:spring-boot-starter-batch'
-    implementation 'org.springframework.kafka:spring-kafka'
     testImplementation 'org.springframework.kafka:spring-kafka-test'
 
     // API Documentation (문서화)

backend/docker-compose.yml

@@ -82,40 +82,8 @@ services:
       timeout: 5s
       retries: 10
 
-  zookeeper:
-    image: confluentinc/cp-zookeeper:7.4.4
-    container_name: zookeeper
-    restart: unless-stopped
-    ports:
-      - "2181:2181"
-    environment:
-      ZOOKEEPER_CLIENT_PORT: 2181
-      ZOOKEEPER_TICK_TIME: 2000
-
-  kafka:
-    image: confluentinc/cp-kafka:7.4.4
-    container_name: kafka
-    restart: unless-stopped
-    depends_on:
-      - zookeeper
-    ports:
-      - "9092:9092"
-    environment:
-      KAFKA_BROKER_ID: 1
-      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
-      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT
-      KAFKA_LISTENERS: INTERNAL://0.0.0.0:29092,EXTERNAL://0.0.0.0:9092
-      KAFKA_ADVERTISED_LISTENERS: INTERNAL://kafka:29092,EXTERNAL://localhost:9092
-      KAFKA_INTER_BROKER_LISTENER_NAME: INTERNAL
-      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
-      KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
-      KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
-    volumes:
-      - kafka-data:/var/lib/kafka/data
-
 volumes:
   mysql-data:
   redis-data:
   qdrant-data:
-  ollama-data:
-  kafka-data:
+  ollama-data:

backend/src/main/java/com/ai/lawyer/domain/chatbot/controller/ChatBotController.java

@@ -3,40 +3,45 @@
 import com.ai.lawyer.domain.chatbot.dto.ChatDto.ChatRequest;
 import com.ai.lawyer.domain.chatbot.dto.ChatDto.ChatResponse;
 import com.ai.lawyer.domain.chatbot.service.ChatBotService;
+import com.ai.lawyer.global.util.AuthUtil;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.http.ResponseEntity;
-import org.springframework.security.core.annotation.AuthenticationPrincipal;
-import org.springframework.stereotype.Controller;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.*;
 import reactor.core.publisher.Flux;
 
 @Slf4j
 @Tag(name = "ChatBot API", description = "챗봇 관련 API")
-@Controller
+@RestController
 @RequiredArgsConstructor
 @RequestMapping("/api/chat")
 public class ChatBotController {
 
     private final ChatBotService chatBotService;
 
     @Operation(summary = "01. 새로운 채팅", description = "첫 메시지 전송으로 새로운 채팅방을 생성하고 챗봇과 대화를 시작")
-    @PostMapping("/message")
-    public ResponseEntity<Flux<ChatResponse>> postNewMessage(
-            @AuthenticationPrincipal Long memberId,
-            @RequestBody ChatRequest chatRequest) {
-        return ResponseEntity.ok(chatBotService.sendMessage(memberId, chatRequest, null));
+    @PostMapping(value = "/message")
+    public Flux<ChatResponse> postNewMessage(@RequestBody ChatRequest chatRequest) {
+
+        Long memberId = AuthUtil.getAuthenticatedMemberId();
+
+        log.info("새로운 채팅 요청: memberId={}", memberId);
+
+        return chatBotService.sendMessage(memberId, chatRequest, null);
     }
 
     @Operation(summary = "02. 기존 채팅", description = "기존 채팅방에 메시지를 보내고 챗봇과 대화를 이어감")
-    @PostMapping("{roomId}/message")
-    public ResponseEntity<Flux<ChatResponse>> postMessage(@AuthenticationPrincipal Long memberId, @RequestBody ChatRequest chatRequest, @PathVariable(value = "roomId", required = false) Long roomId) {
-        return ResponseEntity.ok(chatBotService.sendMessage(memberId, chatRequest, roomId));
+    @PostMapping(value = "{roomId}/message")
+    public Flux<ChatResponse> postMessage(
+            @RequestBody ChatRequest chatRequest,
+            @PathVariable(value = "roomId", required = false) Long roomId) {
+
+        Long memberId = AuthUtil.getAuthenticatedMemberId();
+
+        log.info("기존 채팅 요청: memberId={}, roomId={}", memberId, roomId);
+
+        return chatBotService.sendMessage(memberId, chatRequest, roomId);
     }
 
 }

backend/src/main/java/com/ai/lawyer/domain/chatbot/entity/History.java

@@ -1,6 +1,5 @@
 package com.ai.lawyer.domain.chatbot.entity;
 
-import com.ai.lawyer.domain.member.entity.Member;
 import jakarta.persistence.*;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
@@ -24,9 +23,10 @@ public class History {
     @GeneratedValue(strategy = GenerationType.IDENTITY)
     private Long historyId;
 
-    @ManyToOne
-    @JoinColumn(name = "member_id", foreignKey = @ForeignKey(name = "FK_HISTORY_MEMBER"))
-    private Member memberId;
+    // Member와 OAuth2Member 모두 지원하기 위해 FK 제약 조건 제거 (ConstraintMode.NO_CONSTRAINT)
+    // member_id를 직접 저장하고, 애플리케이션 레벨에서 AuthUtil로 참조 무결성 보장
+    @Column(name = "member_id")
+    private Long memberId;
 
     @OneToMany(mappedBy = "historyId", cascade = CascadeType.ALL, orphanRemoval = true)
     private List<Chat> chats;

backend/src/main/java/com/ai/lawyer/domain/chatbot/repository/ChatLawRepository.java

@@ -12,8 +12,9 @@ public interface ChatLawRepository extends JpaRepository<ChatLaw, Long> {
 
     /**
      * member_id에 해당하는 모든 ChatLaw 삭제 (회원 탈퇴 시 사용)
+     * History.memberId가 Long 타입이므로 직접 비교
      */
     @Modifying
-    @Query("DELETE FROM ChatLaw cl WHERE cl.chatId.historyId.memberId.memberId = :memberId")
+    @Query("DELETE FROM ChatLaw cl WHERE cl.chatId.historyId.memberId = :memberId")
     void deleteByMemberIdValue(@Param("memberId") Long memberId);
 }

backend/src/main/java/com/ai/lawyer/domain/chatbot/repository/ChatPrecedentRepository.java

@@ -10,8 +10,9 @@ public interface ChatPrecedentRepository extends JpaRepository<ChatPrecedent, Lo
 
     /**
      * member_id에 해당하는 모든 ChatPrecedent 삭제 (회원 탈퇴 시 사용)
+     * History.memberId가 Long 타입이므로 직접 비교
      */
     @Modifying
-    @Query("DELETE FROM ChatPrecedent cp WHERE cp.chatId.historyId.memberId.memberId = :memberId")
+    @Query("DELETE FROM ChatPrecedent cp WHERE cp.chatId.historyId.memberId = :memberId")
     void deleteByMemberIdValue(@Param("memberId") Long memberId);
 }

backend/src/main/java/com/ai/lawyer/domain/chatbot/repository/ChatRepository.java

@@ -12,8 +12,9 @@ public interface ChatRepository extends JpaRepository<Chat, Long> {
 
     /**
      * member_id에 해당하는 모든 Chat 삭제 (회원 탈퇴 시 사용)
+     * History.memberId가 Long 타입이므로 직접 비교
      */
     @Modifying
-    @Query("DELETE FROM Chat c WHERE c.historyId.memberId.memberId = :memberId")
+    @Query("DELETE FROM Chat c WHERE c.historyId.memberId = :memberId")
     void deleteByMemberIdValue(@Param("memberId") Long memberId);
 }

backend/src/main/java/com/ai/lawyer/domain/chatbot/repository/HistoryRepository.java

@@ -1,7 +1,6 @@
 package com.ai.lawyer.domain.chatbot.repository;
 
 import com.ai.lawyer.domain.chatbot.entity.History;
-import com.ai.lawyer.domain.member.entity.Member;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
@@ -13,16 +12,17 @@
 @Repository
 public interface HistoryRepository extends JpaRepository<History, Long> {
 
-    List<History> findAllByMemberId(Member memberId);
+    // member_id로 직접 조회 (Member, OAuth2Member 모두 지원)
+    List<History> findAllByMemberId(Long memberId);
 
-    History findByHistoryIdAndMemberId(Long roomId, Member memberId);
+    History findByHistoryIdAndMemberId(Long roomId, Long memberId);
 
     /**
      * member_id로 채팅 히스토리 삭제 (회원 탈퇴 시 사용)
      * Member와 OAuth2Member 모두 같은 member_id 공간을 사용하므로 Long 타입으로 삭제
      */
     @Modifying
-    @Query("DELETE FROM History h WHERE h.memberId.memberId = :memberId")
+    @Query("DELETE FROM History h WHERE h.memberId = :memberId")
     void deleteByMemberIdValue(@Param("memberId") Long memberId);
 
 }

backend/src/main/java/com/ai/lawyer/domain/chatbot/service/AsyncPostChatProcessingService.java

@@ -1,9 +1,13 @@
 package com.ai.lawyer.domain.chatbot.service;
 
+import com.ai.lawyer.domain.chatbot.dto.ChatDto.ChatHistoryDto;
+import com.ai.lawyer.domain.chatbot.dto.ChatDto.ChatLawDto;
+import com.ai.lawyer.domain.chatbot.dto.ChatDto.ChatPrecedentDto;
 import com.ai.lawyer.domain.chatbot.dto.ExtractionDto.KeywordExtractionDto;
 import com.ai.lawyer.domain.chatbot.dto.ExtractionDto.TitleExtractionDto;
 import com.ai.lawyer.domain.chatbot.entity.*;
 import com.ai.lawyer.domain.chatbot.repository.*;
+import com.ai.lawyer.infrastructure.redis.service.ChatCacheService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.ai.chat.memory.ChatMemory;
@@ -13,9 +17,11 @@
 import org.springframework.ai.chat.messages.MessageType;
 import org.springframework.ai.document.Document;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.ArrayList;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -27,6 +33,8 @@
 public class AsyncPostChatProcessingService {
 
     private final KeywordService keywordService;
+    private final ChatCacheService chatCacheService;
+
     private final HistoryRepository historyRepository;
     private final ChatRepository chatRepository;
     private final KeywordRankRepository keywordRankRepository;
@@ -39,7 +47,7 @@ public class AsyncPostChatProcessingService {
     @Value("{$custom.ai.keyword-extraction}")
     private String keywordExtraction;
 
-    //@Async
+    @Async
     @Transactional
     public void processHandlerTasks(Long historyId, String userMessage, String fullResponse, List<Document> similarCaseDocuments, List<Document> similarLawDocuments) {
         try {
@@ -98,6 +106,9 @@ private void extractAndUpdateKeywordRanks(String message) {
     }
 
     private void saveChatWithDocuments(History history, MessageType type, String message, List<Document> similarCaseDocuments, List<Document> similarLawDocuments) {
+        List<ChatPrecedent> chatPrecedents = new ArrayList<>();
+        List<ChatLaw> chatLaws = new ArrayList<>();
+
         Chat chat = chatRepository.save(Chat.builder()
                 .historyId(history)
                 .type(type)
@@ -107,7 +118,7 @@ private void saveChatWithDocuments(History history, MessageType type, String mes
         // Ai 메시지가 저장될 때 관련 문서 저장
         if (type == MessageType.ASSISTANT) {
             if (similarCaseDocuments != null && !similarCaseDocuments.isEmpty()) {
-                List<ChatPrecedent> chatPrecedents = similarCaseDocuments.stream()
+                chatPrecedents = similarCaseDocuments.stream()
                         .map(doc -> ChatPrecedent.builder()
                                 .chatId(chat)
                                 .precedentContent(doc.getText())
@@ -119,7 +130,7 @@ private void saveChatWithDocuments(History history, MessageType type, String mes
             }
 
             if (similarLawDocuments != null && !similarLawDocuments.isEmpty()) {
-                List<ChatLaw> chatLaws = similarLawDocuments.stream()
+                chatLaws = similarLawDocuments.stream()
                         .map(doc -> ChatLaw.builder()
                                 .chatId(chat)
                                 .content(doc.getText())
@@ -129,5 +140,16 @@ private void saveChatWithDocuments(History history, MessageType type, String mes
                 chatLawRepository.saveAll(chatLaws);
             }
         }
+
+        // Redis 캐시에 DTO 저장
+        ChatHistoryDto dto = ChatHistoryDto.builder()
+                .type(type.toString())
+                .message(message)
+                .createdAt(chat.getCreatedAt())
+                .precedent(chatPrecedents.isEmpty() ? null : ChatPrecedentDto.from(chatPrecedents.get(0)))
+                .law(chatLaws.isEmpty() ? null : ChatLawDto.from(chatLaws.get(0)))
+                .build();
+
+        chatCacheService.cacheChatMessage(history.getHistoryId(), dto);
     }
 }