Function GetMessagesList

api/controller/message.go:621–763

GetMessagesList 获取消息列表 @Summary 获取消息列表 @Description 获取消息列表，支持关键词、思考方式、回答状态、知识类型、日期范围、来源筛选，支持排序 @Tags Message @Accept json @Produce json @Security BearerAuth @Param keyword query string false "搜索关键词，支持在消息内容和回答内容中搜索" @Param file_keyword query string false "文件名搜索关键词，支持模糊搜索匹配的文件" @Param offset query int

(c *gin.Context)

// @Success 200 {object} model.CommonResponse{data=MessagesResponse} "Success"
// @Router /api/messages/list [get]
func GetMessagesList(c *gin.Context) {
	var messageListRequest MessageListAllRequest
	if err := c.ShouldBindQuery(&messageListRequest); err != nil {
		c.JSON(http.StatusBadRequest, model.ParamError.ToResponse(err))
		return
	}

	// 设置默认方向为从新到旧
	if messageListRequest.Direction == "" {
		messageListRequest.Direction = "desc"
	}

	// 手动解码 agent_id HashID（防止 RequestDecoder 未能正确解码的情况）
	// 同时处理 ShouldBindQuery 解析失败的情况（agent_id 为 HashID 字符串时会导致绑定失败）
	if agentIDStr := c.Query("agent_id"); agentIDStr != "" {
		if id, err := hashids.TryParseID(agentIDStr); err == nil {
			messageListRequest.AgentID = &id
		}
	}

	eid := config.GetEID(c)
	var fileIDs []int64
	if messageListRequest.FileKeyword != "" {
		// 执行文件名搜索逻辑
		esClient := elasticsearch.GetGlobalClient()
		if esClient != nil && !esClient.IsDisabled() {
			// 创建文件搜索服务
			esSearchService := elasticsearch.NewFileNameSearchService(esClient, model.DB)
			// 构建搜索请求
			searchReq := &elasticsearch.FileNameSearchRequest{
				Query: messageListRequest.FileKeyword,
				TopK:  1000, // 搜索足够多的文件 ID
			}
			// 执行搜索
			response, err := esSearchService.Search(eid, searchReq)
			if err != nil {
				logger.SysLogf("GetMessagesList 文件名 ES 搜索失败: eid=%d, query=%s, err=%v", eid, messageListRequest.FileKeyword, err)
			} else if len(response.Results) > 0 {
				for _, res := range response.Results {
					fileIDs = append(fileIDs, res.FileID)
				}
			}
		}

		// 如果 ES 没搜到或报错，尝试数据库降级搜索（仅当 fileIDs 为空时）
		if len(fileIDs) == 0 {
			var files []model.File
			// 数据库 LIKE 搜索
			if err := model.DB.Where("eid = ? AND is_deleted = ? AND path LIKE ?", eid, false, "%"+messageListRequest.FileKeyword+"%").Limit(1000).Find(&files).Error; err == nil {
				for _, f := range files {
					fileIDs = append(fileIDs, f.ID)
				}
			}
		}

		// 如果最终还是没搜到匹配的文件，说明该文件名下没有消息，直接返回空
		if len(fileIDs) == 0 {
			c.JSON(http.StatusOK, model.Success.ToResponse(&MessagesResponse{