dcs 2 일 전
부모
커밋
551b6140b5

+ 6 - 4
virgo.api/src/main/java/com/bosshand/virgo/api/workark/controller/DifyController.java

@@ -172,11 +172,13 @@ public class DifyController {
 
     @ApiOperation("获取会话列表")
     @ApiImplicitParams({
-            @ApiImplicitParam(name = "difyTypeId", value = "dify类型id")
+            @ApiImplicitParam(name = "difyTypeId", value = "dify类型id"),
+            @ApiImplicitParam(name = "lastId", value = "当前页最后面一条记录的id"),
+            @ApiImplicitParam(name = "limit", value = "一次请求返回多少条记录")
     })
-    @RequestMapping(value = "/chat/conversations/{difyTypeId}", method = RequestMethod.GET)
-    public Response chatConversations(@PathVariable long difyTypeId) {
-        return Response.ok(difyService.conversations(difyTypeId));
+    @RequestMapping(value = "/chat/conversations/{difyTypeId}/{lastId}/{limit}", method = RequestMethod.GET)
+    public Response chatConversations(@PathVariable long difyTypeId, String lastId, @PathVariable int limit) {
+        return Response.ok(difyService.conversations(difyTypeId, lastId, limit));
     }
 
     @ApiOperation("删除会话")

+ 2 - 2
virgo.api/src/main/java/com/bosshand/virgo/api/workark/service/DifyService.java

@@ -616,7 +616,7 @@ public class DifyService {
     /**
      * 获取会话列表
      */
-    public ConversationListResponse conversations(long difyTypeId) {
+    public ConversationListResponse conversations(long difyTypeId, String lastId, int limit) {
 
         DifyType difyType = difyTypeDao.get(difyTypeId);
 
@@ -626,7 +626,7 @@ public class DifyService {
         DifyChatClient chatClient = DifyClientFactory.createChatClient("http://203.110.233.149:9000/v1", difyType.getApiKey());
         // 获取会话列表
         try {
-            ConversationListResponse conversations = chatClient.getConversations(userContext.getUserName() + "-" + userContext.getUserId(), null, 10, "-updated_at");
+            ConversationListResponse conversations = chatClient.getConversations(userContext.getUserName() + "-" + userContext.getUserId(), lastId, limit, "-updated_at");
             return conversations;
         } catch (IOException e) {
             e.printStackTrace();