From 841f1631b790d2c4caf24a40eb4830f57a9bafa5 Mon Sep 17 00:00:00 2001 From: Administrator <15274802129@163.com> Date: Wed, 17 Sep 2025 17:21:07 +0800 Subject: [PATCH] feat(ai): 添加知识点推荐功能- 新增 AiProductPointService接口的 recommend 方法 - 实现 AiProductPointServiceImpl 中的 recommend 方法逻辑 - 添加 ApiProductPointController 中的 recommend 接口 - 创建 ApiProductPointRecommendDto 和 ApiProductPointRecommendVo 类 --- src/main/java/cc/mrbird/febs/ai/controller/talk/ApiAiTalkController.java | 27 +++++++++++++++------------ 1 files changed, 15 insertions(+), 12 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/ai/controller/talk/ApiAiTalkController.java b/src/main/java/cc/mrbird/febs/ai/controller/talk/ApiAiTalkController.java index ce47ea2..2cf5a30 100644 --- a/src/main/java/cc/mrbird/febs/ai/controller/talk/ApiAiTalkController.java +++ b/src/main/java/cc/mrbird/febs/ai/controller/talk/ApiAiTalkController.java @@ -1,20 +1,14 @@ package cc.mrbird.febs.ai.controller.talk; -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.talk.AiTalkAnswerStream; import cc.mrbird.febs.ai.req.talk.ApiTalkDto; import cc.mrbird.febs.ai.req.talk.ApiTalkItemPageDto; import cc.mrbird.febs.ai.req.talk.ApiTalkPageDto; -import cc.mrbird.febs.ai.res.memberTalk.ApiMemberTalkItemVo; -import cc.mrbird.febs.ai.res.memberTalk.ApiMemberTalkStreamVo; -import cc.mrbird.febs.ai.res.memberTalk.ApiMemberTalkVo; +import cc.mrbird.febs.ai.res.memberTalk.ApiMemberTalkStreamVoOld; import cc.mrbird.febs.ai.res.talk.ApiTalkItemPageVo; import cc.mrbird.febs.ai.res.talk.ApiTalkPageVo; import cc.mrbird.febs.ai.res.talk.ApiTalkQuestionVo; import cc.mrbird.febs.ai.res.talk.ApiTalkVo; -import cc.mrbird.febs.ai.service.AiMemberTalkService; import cc.mrbird.febs.ai.service.AiTalkService; import cc.mrbird.febs.common.entity.FebsResponse; import cn.hutool.core.util.StrUtil; @@ -23,10 +17,7 @@ import lombok.extern.slf4j.Slf4j; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; -import org.springframework.web.servlet.mvc.method.annotation.SseEmitter; import reactor.core.publisher.Flux; - -import java.io.IOException; /** * @author Administrator @@ -83,7 +74,7 @@ @ApiOperation("提问AI(流式)") @ApiResponses({ - @ApiResponse(code = 200, message = "流式响应", response = ApiMemberTalkStreamVo.class), + @ApiResponse(code = 200, message = "流式响应", response = ApiMemberTalkStreamVoOld.class), }) @GetMapping("/answer-stream") public Flux<FebsResponse> answerStream(@RequestParam String question) { @@ -93,7 +84,7 @@ @ApiOperation("提问AI(流式)V2") @ApiResponses({ - @ApiResponse(code = 200, message = "流式响应", response = ApiMemberTalkStreamVo.class), + @ApiResponse(code = 200, message = "流式响应", response = ApiMemberTalkStreamVoOld.class), }) @PostMapping("/answer-streamV2") public Flux<FebsResponse> answerStreamV2(@RequestBody @Validated AiTalkAnswerStream dto) { @@ -102,4 +93,16 @@ } return aiTalkService.answerStreamV2(dto); } + + @ApiOperation("提问AI(流式带思考过程)V3") + @ApiResponses({ + @ApiResponse(code = 200, message = "流式响应", response = ApiMemberTalkStreamVoOld.class), + }) + @PostMapping("/answer-streamV3") + public Flux<FebsResponse> answerStreamV3(@RequestBody @Validated AiTalkAnswerStream dto) { + if (StrUtil.isEmpty(dto.getQuestion())){ + return Flux.just(new FebsResponse().fail().message("请输入问题")); + } + return aiTalkService.answerStreamV3(dto); + } } -- Gitblit v1.9.1