Skip to content

배포 #347

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 2 commits into from
Oct 15, 2025
Merged

배포 #347

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
c6c291d
work
GarakChoi Oct 15, 2025
12a5d81
Merge pull request #346 from prgrms-web-devcourse-final-project/feat/…
asowjdan Oct 15, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 3 additions & 9 deletions backend/src/main/java/com/ai/lawyer/domain/chatbot/service/ChatBotService.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -61,13 +61,7 @@ public class ChatBotService {
// 멤버 조회 -> 벡터 검색 -> 프롬프트 생성 -> LLM 호출 (스트림) -> Kafka 이벤트 발행 -> 응답 반환
@Transactional
public Flux<ChatResponse> sendMessage(Long memberId, ChatRequest chatRequestDto, Long roomId) {

// Mono.fromCallable()과 subscribeOn()을 사용하여 블로킹 작업을 별도 스레드에서 실행
// boundedElastic 스케줄러는 블로킹 I/O 작업에 최적화된 스레드 풀 사용
return Mono.fromCallable(() -> {
// 멤버 조회 (블로킹)
Member member = memberRepository.findById(memberId)
.orElseThrow(() -> new IllegalArgumentException("존재하지 않는 회원입니다."));

// 벡터 검색 (판례, 법령) (블로킹)
List<Document> similarCaseDocuments = qdrantService.searchDocument(chatRequestDto.getMessage(), "type", "판례");
Expand All @@ -77,7 +71,7 @@ public Flux<ChatResponse> sendMessage(Long memberId, ChatRequest chatRequestDto,
String lawContext = formatting(similarLawDocuments);

// 채팅방 조회 또는 생성 (블로킹)
History history = getOrCreateRoom(member, roomId);
History history = getOrCreateRoom(memberId, roomId);

// 메시지 기억 관리 (User 메시지 추가)
ChatMemory chatMemory = saveChatMemory(chatRequestDto, history);
Expand Down Expand Up @@ -167,11 +161,11 @@ private Prompt getPrompt(String caseContext, String lawContext, ChatMemory chatM
return new Prompt(List.of(systemMessage, userMessage));
}

private History getOrCreateRoom(Member member, Long roomId) {
private History getOrCreateRoom(Long memberId, Long roomId) {
if (roomId != null) {
return historyService.getHistory(roomId);
} else {
return historyRepository.save(History.builder().memberId(member.getMemberId()).build());
return historyRepository.save(History.builder().memberId(memberId).build());
}
}

Expand Down