Function GetUserMessages

api/controller/message.go:330–389

@Summary Get messages by user and agent @Description Get messages between user and specific agent with pagination and keyword search. 返回的消息包含RAG检索统计数据（如果存在） @Tags Message @Accept json @Produce json @Security BearerAuth @Param agent_id path int true "Agent ID" @Param user_id path int true "User ID" @

(c *gin.Context)

// @Success 200 {object} model.CommonResponse{data=MessagesResponse} "Success"
// @Router /api/users/{user_id}/agents/{agent_id}/messages [get]
func GetUserMessages(c *gin.Context) {
	agent_id, err := strconv.ParseInt(c.Param("agent_id"), 10, 64)
	if err != nil {
		c.JSON(http.StatusBadRequest, model.ParamError.ToResponse(nil))
		return
	}

	user_id, err := strconv.ParseInt(c.Param("user_id"), 10, 64)
	if err != nil {
		c.JSON(http.StatusBadRequest, model.ParamError.ToResponse(nil))
		return
	}
	user, err := model.GetUserByID(user_id)
	if err != nil {
		c.JSON(http.StatusInternalServerError, model.DBError.ToResponse(err))
		return
	}

	if user.Eid != config.GetEID(c) {
		c.JSON(http.StatusForbidden, model.NotFound.ToResponse(nil))
		return
	}

	var messageListRequest MessageListRequest
	if err := c.ShouldBindQuery(&messageListRequest); err != nil {
		c.JSON(http.StatusBadRequest, model.ParamError.ToResponse(err))
		return
	}

	eid := config.GetEID(c)
	count, messages, err := model.GetMessagesByUserAndAgentWithVisitor(
		eid, user_id, agent_id,
		messageListRequest.Keyword, messageListRequest.FileID, session.GetVisitorID(c), messageListRequest.Limit, messageListRequest.Offset)
	if err != nil {
		c.JSON(http.StatusInternalServerError, model.DBError.ToResponse(err))
		return
	}

	// 批量获取文件名，避免 N+1 查询
	fileMap := make(map[int64]string)
	var targetFileIDs []int64
	for _, msg := range messages {
		if msg.FileID > 0 {
			targetFileIDs = append(targetFileIDs, msg.FileID)
		}
	}
	if len(targetFileIDs) > 0 {
		var files []model.File
		if err := model.DB.Select("id, path").Where("id IN ?", targetFileIDs).Find(&files).Error; err == nil {
			for _, f := range files {
				fileMap[f.ID] = model.ExtractSimpleFileName(f.Path)
			}
		}
	}

	c.JSON(http.StatusOK, model.Success.ToResponse(&MessagesResponse{
		Count:    count,
		Messages: convertToEnhancedMessages(messages, fileMap),