Method SendEndStep

api/controller/relay/relay_process_step.go:353–375

(StepCode string, Message string, Data map[string]interface{})

}

func (ps *ProcessSender) SendEndStep(StepCode string, Message string, Data map[string]interface{}) error {
	// ⭐ 在发送前处理 data，截取 content
	processedData := ps.truncateSourcesContent(Data)

	step := ProcessStep{
		StepCode:  StepCode,
		Status:    STEP_STATUS_COMPLETED,
		Message:   Message,
		Timestamp: time.Now().Unix(),
		Data:      processedData, // 使用处理后的数据
	}
	if ps != nil && ps.chatRequest != nil && ps.chatRequest.EnableProcessSteps {
		ps.recordProcessStep(step)
	}
	if !ps.CheckNeedSend() {
		return nil
	}
	if err := sendProcessStep(ps.c, ps.requestId, step); err != nil {
		logger.SysErrorf("发送处理步骤失败: %s", err.Error())
		return err
	}
	return nil
}

// truncateSourcesContent 截取 data 中 sources 的 content
func (ps *ProcessSender) truncateSourcesContent(data map[string]interface{}) map[string]interface{} {