Function sendOutputFilesStep

api/controller/relay/relay_agent.go:4376–4409

sendOutputFilesStep 向客户端发送 AI 上传文件信息的 process.step 事件

(c *gin.Context, ctx context.Context, requestId string, files []*model.UploadFile, messageStatus *MessageStatsInfo, emitToClient bool)

// sendOutputFilesStep 向客户端发送 AI 上传文件信息的 process.step 事件
func sendOutputFilesStep(c *gin.Context, ctx context.Context, requestId string, files []*model.UploadFile, messageStatus *MessageStatsInfo, emitToClient bool) {
	if len(files) == 0 {
		return
	}
	fileItems := buildOutputFileItems(files)
	mediaItems := buildMediaAttachmentItems(files)
	fileStep := ProcessStep{
		StepCode: "output_files",
		Name:     "生成文件",
		Status:   "completed",
		Message:  fmt.Sprintf("生成了 %d 个文件", len(files)),
		Data: map[string]interface{}{
			"files":                  fileItems,
			"contract_version":       outputFilesContractVersion,
			"media_attachments":      mediaItems,
			"media_contract_version": mediaAttachmentsContractVersion,
		},
		Timestamp: time.Now().Unix(),
	}
	fileNames := make([]string, 0, len(files))
	for _, f := range files {
		fileNames = append(fileNames, f.FileName)
	}
	if messageStatus != nil {
		recordProcessStepForHistory(ctx, config.GetEID(c), messageStatus, requestId, fileStep)
	}
	if !emitToClient {
		return
	}
	logger.Debugf(ctx, "【技能运行】发送输出文件步骤: request_id=%s, file_count=%d, file_names=%v", requestId, len(files), fileNames)
	if err := sendProcessStep(c, requestId, fileStep); err != nil {
		logger.Warnf(ctx, "Failed to send output files step: %v", err)
	}
}