From c7cee264bccb5026fd42a9f0dc83d274aaee40cf Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Thu, 30 Oct 2025 10:05:28 +0800
Subject: [PATCH] feat(ai): 新增AI陪练流式对话V2接口

---
 src/main/java/cc/mrbird/febs/ai/controller/memberTalk/ApiMemberTalkStreamController.java |   83 +++++++++++++++++++++++------------------
 1 files changed, 47 insertions(+), 36 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/ai/controller/memberTalk/ApiMemberTalkStreamController.java b/src/main/java/cc/mrbird/febs/ai/controller/memberTalk/ApiMemberTalkStreamController.java
index 93a7e2b..9f71745 100644
--- a/src/main/java/cc/mrbird/febs/ai/controller/memberTalk/ApiMemberTalkStreamController.java
+++ b/src/main/java/cc/mrbird/febs/ai/controller/memberTalk/ApiMemberTalkStreamController.java
@@ -7,6 +7,7 @@
 import cc.mrbird.febs.ai.req.memberTalk.ApiMemberTalkListDto;
 import cc.mrbird.febs.ai.res.memberTalk.*;
 import cc.mrbird.febs.ai.res.memberTalkStream.ApiMemberTalkReloadStreamVo;
+import cc.mrbird.febs.ai.res.memberTalkStream.ApiMemberTalkStreamV2Vo;
 import cc.mrbird.febs.ai.res.memberTalkStream.ApiMemberTalkStreamVo;
 import cc.mrbird.febs.ai.service.AiMemberTalkStreamService;
 import cc.mrbird.febs.common.entity.FebsResponse;
@@ -40,44 +41,13 @@
         return aiMemberTalkStreamService.start(dto);
     }
 
-    @ApiOperation(value = "陪练记录", notes = "陪练记录")
+    @ApiOperation("继续回答")
     @ApiResponses({
-            @ApiResponse(code = 200, message = "success", response = ApiMemberTalkListVo.class)
+            @ApiResponse(code = 200, message = "流式响应", response = ApiMemberTalkStreamV2Vo.class),
     })
-    @PostMapping(value = "/talkList")
-    public FebsResponse talkList(@RequestBody @Validated ApiMemberTalkListDto dto) {
-
-        return aiMemberTalkStreamService.talkList(dto);
-    }
-
-    @ApiOperation(value = "陪练记录-答题记录", notes = "陪练记录-答题记录")
-    @ApiResponses({
-            @ApiResponse(code = 200, message = "success", response = ApiTalkMemberListVo.class)
-    })
-    @PostMapping(value = "/talkMemberList")
-    public FebsResponse talkMemberList(@RequestBody @Validated ApiTalkMemberListDto dto) {
-
-        return aiMemberTalkStreamService.talkMemberList(dto);
-    }
-
-    @ApiOperation(value = "陪练记录-查看报告", notes = "陪练记录-查看报告")
-    @ApiResponses({
-            @ApiResponse(code = 200, message = "success", response = ApiTalkReportListVo.class)
-    })
-    @PostMapping(value = "/talkReportList")
-    public Flux<FebsResponse> talkReportList(@RequestBody @Validated ApiTalkReportListDto dto) {
-
-        return aiMemberTalkStreamService.talkReportList(dto);
-    }
-
-    @ApiOperation(value = "陪练记录-查看报告", notes = "陪练记录-查看报告")
-    @ApiResponses({
-            @ApiResponse(code = 200, message = "success", response = ApiTalkReportListVo.class)
-    })
-    @PostMapping(value = "/talkReportListV2")
-    public FebsResponse talkReportListV2(@RequestBody @Validated ApiTalkReportListDto dto) {
-
-        return aiMemberTalkStreamService.talkReportListV2(dto);
+    @PostMapping("/startV2")
+    public Flux<FebsResponse> startV2(@RequestBody @Validated ApiMemberTalkStreamV2Dto dto) {
+        return aiMemberTalkStreamService.startV2(dto);
     }
 
     @ApiOperation(value = "再练一次(重新回答)", notes = "再练一次(重新回答)")
@@ -160,4 +130,45 @@
         return aiMemberTalkStreamService.saveReport(dto);
     }
 
+
+    @ApiOperation(value = "陪练记录", notes = "陪练记录")
+    @ApiResponses({
+            @ApiResponse(code = 200, message = "success", response = ApiMemberTalkListVo.class)
+    })
+    @PostMapping(value = "/talkList")
+    public FebsResponse talkList(@RequestBody @Validated ApiMemberTalkListDto dto) {
+
+        return aiMemberTalkStreamService.talkList(dto);
+    }
+
+    @ApiOperation(value = "陪练记录-答题记录", notes = "陪练记录-答题记录")
+    @ApiResponses({
+            @ApiResponse(code = 200, message = "success", response = ApiTalkMemberListVo.class)
+    })
+    @PostMapping(value = "/talkMemberList")
+    public FebsResponse talkMemberList(@RequestBody @Validated ApiTalkMemberListDto dto) {
+
+        return aiMemberTalkStreamService.talkMemberList(dto);
+    }
+
+    @ApiOperation(value = "陪练记录-查看报告", notes = "陪练记录-查看报告")
+    @ApiResponses({
+            @ApiResponse(code = 200, message = "success", response = ApiTalkReportListVo.class)
+    })
+    @PostMapping(value = "/talkReportList")
+    public Flux<FebsResponse> talkReportList(@RequestBody @Validated ApiTalkReportListDto dto) {
+
+        return aiMemberTalkStreamService.talkReportList(dto);
+    }
+
+    @ApiOperation(value = "陪练记录-查看报告", notes = "陪练记录-查看报告")
+    @ApiResponses({
+            @ApiResponse(code = 200, message = "success", response = ApiTalkReportListVo.class)
+    })
+    @PostMapping(value = "/talkReportListV2")
+    public FebsResponse talkReportListV2(@RequestBody @Validated ApiTalkReportListDto dto) {
+
+        return aiMemberTalkStreamService.talkReportListV2(dto);
+    }
+
 }

--
Gitblit v1.9.1