Method SendStartStep

api/controller/relay/relay_process_step.go:331–351

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

}

func (ps *ProcessSender) SendStartStep(StepCode string, Message string, Data map[string]interface{}) error {
	step := ProcessStep{
		StepCode:  StepCode,
		Status:    STEP_STATUS_START,
		Message:   Message,
		Timestamp: time.Now().Unix(),
		Data:      Data,
	}
	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
}

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