交互数智人实践教程

// 客服机器人对话
func robotDialogue() {
    fmt.Println("\\n-----云小微对话（客服机器人对话）-----")
    err := api.SendTextDriveWssCommand(TextDriveWssCommand{
        Data: &TextWssData{
            Text:        "微信简介",  //根据客服机器人问答知识库回答
            ChatCommand: "",         //使用客服对话or大模型对话
        },
    })
    if err != nil {
        log.Fatalf("err:%v", err)
    }
}

// 腾讯行业大模型对话
func largeModelDialogue() {
    fmt.Println("\\n-----腾讯行业大模型对话-----")
    err := api.SendTextDriveWssCommand(TextDriveWssCommand{
        Data: &TextWssData{
            Text:        "你是谁",                                                  //可以在模型管理里面自定义配置问答
            ChatCommand: "",                                                       //使用客服对话or大模型对话
            ChatRoundId: strings.Replace(uuid.NewV4().String(), "-", "", -1)[:32], //使用腾讯行业大模型对话服务的数智人项目需要传入此字段，用于区分多轮对话
        },
    })
    if err != nil {
        log.Fatalf("err:%v", err)
    }
}

// 用户自行接入大模型来驱动数智人的场景
func SendNotSentenceStreamText() {
    //模拟大模型的返回结果
    rspText := "我是一个数智人，我在测试发送流式文本非子句模式。"
    //模拟大模型生成流式文本
    streamChan := streamResponse(rspText, time.Millisecond*500)
    reqId := strings.Replace(uuid.NewV4().String(), "-", "", -1)[:32]
    seq := 1
    for char := range streamChan {
        api.SendStreamTextDriveWssCommand(StreamTextDriveWssCommand{
            ReqId: reqId,
            Data: &StreamTextWssData{
                Text: char,
                Seq:  seq,
            },
        })
        seq++
    }
    // 发送final数据包
    api.SendStreamTextDriveWssCommand(StreamTextDriveWssCommand{
        ReqId: reqId,
        Data: &StreamTextWssData{
            Seq:     1,
            IsFinal: true,
        },
    })
}


func streamResponse(text string, delay time.Duration) <-chan string {
    ch := make(chan string)
    go func() {
        for _, char := range text {
            //模拟大模型流式返回延时
            time.Sleep(delay)
            ch <- string(char)
        }
        close(ch)
    }()
    return ch
}

func SendAudio() {
    /*
        音频格式：格式-PCM，采样率-16kHz，采样位深-16bits，声道-单声道。
            1.如果是麦克风实时收音发送，每录制160ms（5120B）的数据即可发出，中间不需要间隔等待；如果是读取离线音频文件发送，片包大小为160ms（5120B），片包发送间隔为120ms。
            2.最后一个片包大小按实际发送（需小于160ms）。
            3.当数据包发送完毕后，必须再发送一个IsFinal=true的空数据包（Audio字段填空串）结束当次音频驱动使数字人回到静默状态。
            4.发送音频实时率要介于[0.75,1]，小于0.75会触发限速，大于1会导致画面卡顿。比如160ms音频片包大小，发送间隔不能低于120ms，不能高于160ms。
    */
    chunkSize := 5120 //块大小-5120B
    sleepBase := 120 //间隔ms
    seq := 1
    reqId := strings.Replace(uuid.NewV4().String(), "-", "", -1)[:32]
    //读取音频二进制文件
    voiceFile, err := os.Open("your_audio_file.pcm")
    if err != nil {
        log.Fatalf("err:%v", err)
    }
    defer voiceFile.Close()
    buffer := make([]byte, chunkSize)
    for {
        n, err := voiceFile.Read(buffer)
        if err != nil && err != io.EOF {
            fmt.Println("Error reading file:", err)
            break
        }
        if n == 0 { // 文件读取完毕
            break
        }
        err = api.SendVoiceDriveCommand(VoiceDriveCommand{
            ReqId: reqId,
            Data: &VoiceData{
                Audio:   base64.StdEncoding.EncodeToString(buffer), //声音二进制数据编码Base64后的值。
                Seq:     seq,
                IsFinal: false,
            },
        })
        if err != nil {
            log.Fatalf("err:%v", err)
        }
        seq++ // 递增序列号
        // 等待120ms到160ms的随机时间
        sleepDuration := time.Duration(sleepBase+rand.Intn(41)) * time.Millisecond
        time.Sleep(sleepDuration)
    }
    // 发送final数据包
    api.SendVoiceDriveCommand(VoiceDriveCommand{
        ReqId: reqId,
        Data: &VoiceData{
            Seq:     seq,
            IsFinal: true,
        },
    })
}