From 85069103bd0b1a801924c660daad78aedd0bfb6c Mon Sep 17 00:00:00 2001 From: Administrator <15274802129@163.com> Date: Thu, 18 Sep 2025 16:52:52 +0800 Subject: [PATCH] ``` feat(AiMemberTalkStreamService): 添加answerV3方法以支持流式生成报告 --- src/main/java/cc/mrbird/febs/ai/service/AiMemberTalkService.java | 17 ++++++++++++++--- 1 files changed, 14 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 f533640..77f5c0e 100644 --- a/src/main/java/cc/mrbird/febs/ai/service/AiMemberTalkService.java +++ b/src/main/java/cc/mrbird/febs/ai/service/AiMemberTalkService.java @@ -1,14 +1,15 @@ 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.*; 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.List; import java.util.function.Consumer; /** @@ -24,6 +25,8 @@ FebsResponse start(ApiMemberTalkDto dto); + FebsResponse reload(ApiMemberTalkReloadDto dto); + void startStream(ApiMemberTalkDto dto, Consumer<AiResponse> callback); AiMemberTalk getByQuery(LambdaQueryWrapper<AiMemberTalk> query); @@ -32,5 +35,13 @@ FebsResponse answer(ApiMemberTalkAnswerDto dto); - AiMemberTalk add(String memberUuid, String productId, Date nowTime); + AiMemberTalk add(String memberUuid,String companyId, String productId, Date nowTime,Integer questionCount); + + FebsResponse historyPage(ApiMemberTalkItemPageDto dto); + + Flux<FebsResponse> answerStream(String question); + + List<AiMemberTalk> getListByCompanyId(String companyId); + + List<AiMemberTalk> getListByCompanyIdAndMemberUuid(String companyId, String memberUuid); } -- Gitblit v1.9.1