From 634a0506c29607586456ea0a4ba7ec4b5c57f45c Mon Sep 17 00:00:00 2001 From: Administrator <15274802129@163.com> Date: Tue, 02 Sep 2025 17:20:09 +0800 Subject: [PATCH] refactor(ai): 优化 AI交流输出类型的描述 --- src/main/java/cc/mrbird/febs/ai/service/AiMemberTalkService.java | 9 ++++++--- 1 files changed, 6 insertions(+), 3 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/ai/service/AiMemberTalkService.java b/src/main/java/cc/mrbird/febs/ai/service/AiMemberTalkService.java index 1d1502a..4b51641 100644 --- a/src/main/java/cc/mrbird/febs/ai/service/AiMemberTalkService.java +++ b/src/main/java/cc/mrbird/febs/ai/service/AiMemberTalkService.java @@ -1,13 +1,12 @@ package cc.mrbird.febs.ai.service; import cc.mrbird.febs.ai.entity.AiMemberTalk; -import cc.mrbird.febs.ai.req.memberTalk.ApiMemberTalkAnswerDto; -import cc.mrbird.febs.ai.req.memberTalk.ApiMemberTalkDto; -import cc.mrbird.febs.ai.req.memberTalk.ApiMemberTalkItemPageDto; +import cc.mrbird.febs.ai.req.memberTalk.*; import cc.mrbird.febs.ai.res.ai.AiResponse; import cc.mrbird.febs.common.entity.FebsResponse; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.IService; +import reactor.core.publisher.Flux; import java.util.Date; import java.util.function.Consumer; @@ -25,6 +24,8 @@ FebsResponse start(ApiMemberTalkDto dto); + FebsResponse reload(ApiMemberTalkReloadDto dto); + void startStream(ApiMemberTalkDto dto, Consumer<AiResponse> callback); AiMemberTalk getByQuery(LambdaQueryWrapper<AiMemberTalk> query); @@ -36,4 +37,6 @@ AiMemberTalk add(String memberUuid, String productId, Date nowTime); FebsResponse historyPage(ApiMemberTalkItemPageDto dto); + + Flux<FebsResponse> answerStream(String question); } -- Gitblit v1.9.1