feat: 获取用户对话列表

src/main/java/cn/com/poc/expose/dto/DialoguesContextDto.java

+package cn.com.poc.expose.dto;
+
+import java.io.Serializable;
+
+public class DialoguesContextDto implements Serializable {
+
+
+    /** role
+     *角色 user-用户  assistant-助手
+     */
+    private java.lang.String role;
+
+    public java.lang.String getRole(){
+        return this.role;
+    }
+
+    public void setRole(java.lang.String role){
+        this.role = role;
+    }
+    /** agent_id
+     *agent应用ID
+     */
+    private java.lang.String agentId;
+
+    public java.lang.String getAgentId(){
+        return this.agentId;
+    }
+
+    public void setAgentId(java.lang.String agentId){
+        this.agentId = agentId;
+    }
+
+    /** content
+     *内容
+     */
+    private java.lang.String content;
+
+    public java.lang.String getContent(){
+        return this.content;
+    }
+
+    public void setContent(java.lang.String content){
+        this.content = content;
+    }
+
+
+    /** timestamp
+     *时间戳
+     */
+    private java.lang.Long timestamp;
+
+    public java.lang.Long getTimestamp(){
+        return this.timestamp;
+    }
+
+    public void setTimestamp(java.lang.Long timestamp){
+        this.timestamp = timestamp;
+    }
+
+}

src/main/java/cn/com/poc/expose/rest/AgentApplicationRest.java

@@ -2,8 +2,10 @@ package cn.com.poc.expose.rest;
 
 import cn.com.poc.agent_application.dto.AgentApplicationCreateContinueQuesDto;
 import cn.com.poc.agent_application.dto.AgentApplicationInfoSearchDto;
+import cn.com.poc.agent_application.dto.BizAgentApplicationDialoguesRecordDto;
 import cn.com.poc.agent_application.dto.BizAgentApplicationPublishDto;
 import cn.com.poc.expose.dto.AgentApplicationDto;
+import cn.com.poc.expose.dto.DialoguesContextDto;
 import cn.com.poc.expose.dto.UserDialoguesDto;
 import cn.com.yict.framemax.core.rest.BaseRest;
 import cn.com.yict.framemax.web.permission.Access;
@@ -48,4 +50,14 @@ public interface AgentApplicationRest extends BaseRest {
      */
     List<UserDialoguesDto> getUserDialogues() throws Exception;
 
+    /**
+     * 关闭对话
+     */
+    void closeDialogues(@RequestParam String dialogueId) throws Exception;
+
+    /**
+     * 获取对话上下文
+     */
+    List<DialoguesContextDto> getDialogueContext(@RequestParam String dialogueId) throws Exception;
+
 }

src/main/java/cn/com/poc/expose/rest/impl/AgentApplicationRestImpl.java

 package cn.com.poc.expose.rest.impl;
 
 import cn.com.poc.agent_application.convert.AgentApplicationInfoConvert;
+import cn.com.poc.agent_application.convert.BizAgentApplicationDialoguesRecordConvert;
 import cn.com.poc.agent_application.convert.BizAgentApplicationPublishConvert;
 import cn.com.poc.agent_application.dto.AgentApplicationCreateContinueQuesDto;
 import cn.com.poc.agent_application.dto.AgentApplicationInfoSearchDto;
+import cn.com.poc.agent_application.dto.BizAgentApplicationDialoguesRecordDto;
 import cn.com.poc.agent_application.dto.BizAgentApplicationPublishDto;
+import cn.com.poc.agent_application.entity.BizAgentApplicationDialoguesRecordEntity;
 import cn.com.poc.agent_application.entity.BizAgentApplicationPublishEntity;
 import cn.com.poc.agent_application.query.MemberDialoguesQueryItem;
 import cn.com.poc.agent_application.service.BizAgentApplicationDialoguesRecordService;
 import cn.com.poc.agent_application.service.BizAgentApplicationPublishService;
+import cn.com.poc.common.constant.CommonConstant;
 import cn.com.poc.common.utils.Assert;
 import cn.com.poc.common.utils.BlContext;
 import cn.com.poc.common.utils.UUIDTool;
 import cn.com.poc.expose.aggregate.AgentApplicationService;
 import cn.com.poc.expose.dto.AgentApplicationDto;
+import cn.com.poc.expose.dto.DialoguesContextDto;
 import cn.com.poc.expose.dto.UserDialoguesDto;
 import cn.com.poc.expose.rest.AgentApplicationRest;
 import cn.com.poc.support.security.oauth.entity.UserBaseEntity;
@@ -104,4 +109,39 @@ public class AgentApplicationRestImpl implements AgentApplicationRest {
         }
         return result;
     }
+
+    @Override
+    public void closeDialogues(String dialogueId) throws Exception {
+        Assert.notBlank(dialogueId, "对话ID不能为空");
+        BizAgentApplicationDialoguesRecordEntity recordEntity = new BizAgentApplicationDialoguesRecordEntity();
+        recordEntity.setDialogsId(dialogueId);
+        recordEntity.setIsDeleted(CommonConstant.IsDeleted.N);
+        List<BizAgentApplicationDialoguesRecordEntity> entities = bizAgentApplicationDialoguesRecordService.findByExample(recordEntity, null);
+        if (CollectionUtils.isNotEmpty(entities)) {
+            for (BizAgentApplicationDialoguesRecordEntity entity : entities) {
+                bizAgentApplicationDialoguesRecordService.deletedById(entity.getId());
+            }
+        }
+    }
+
+    @Override
+    public List<DialoguesContextDto> getDialogueContext(String dialogueId) throws Exception {
+        Assert.notBlank(dialogueId, "对话ID不能为空");
+        BizAgentApplicationDialoguesRecordEntity recordEntity = new BizAgentApplicationDialoguesRecordEntity();
+        recordEntity.setDialogsId(dialogueId);
+        recordEntity.setIsDeleted(CommonConstant.IsDeleted.N);
+        List<BizAgentApplicationDialoguesRecordEntity> entities = bizAgentApplicationDialoguesRecordService.findByExample(recordEntity, null);
+        if (CollectionUtils.isNotEmpty(entities)) {
+            return entities.stream().map(value -> {
+                        DialoguesContextDto dto = new DialoguesContextDto();
+                        dto.setRole(value.getRole());
+                        dto.setAgentId(value.getAgentId());
+                        dto.setContent(value.getContent());
+                        dto.setTimestamp(value.getTimestamp());
+                        return dto;
+                    }
+            ).collect(Collectors.toList());
+        }
+        return null;
+    }
 }