顶顶通呼叫中心中间件(mod_cti基于FreeSWITCH)-电话机器人http接口说明

电话机器人http接口说明

介绍

这个接口是基于cti模块实现的类似smartivr接口(可以称呼为新一代smartivr接口。),但是这个接口更简单易用,smartivr接口已经逐步停止升级,所有使用smartivr接口开发的程序,都建议迁移到这个接口来。

拨号方案配置

<action application="cti_robot" data="http://49.235.127.246/flow.php?a=${destination_number}"/>
<action application="set" data="park_timeout=3600000"/>
<action application="park"/>

接口回调流程

开始流程(create),进入机器人第一个执行的回调。

cti –> web (请求)

{
"timestamp": 1658152564098414,
"call_source": "",
"source_name": "",
"callid": "27d36dee-a03f-40d2-b92e-2872c9057c21",
"appid": "451f16c4-6795-4976-a8c0-0f6c255dd9ac",
"method": "create"
}
  • timestamp 请求的时间戳
  • call_source 呼叫来源 ,比如队列外呼就是 queuedialer
  • source_name 来源名称 ,比如队列外呼就是任务名称
  • callid 通话唯一UUID
  • appid 执行动作的UUID,每次需要执行新动作系统会预先生成UUID,后续的输入都会带上这个UUID,动作执行完成时就会生成新的UUID。
  • method 方法

web –> cti (响应)

{
"action": "cti_play_and_detect_speech",
"argument": "'1' '32' '0' '0.3' '127.0.0.1:9988' '120' '800' '5000' '20000' '' '' '451f16c4-6795-4976-a8c0-0f6c255dd9ac' '1' '${strftime(%Y-%m-%d)}' 'wav'",
"tts": {
"ttsurl": "http://127.0.0.1:9989/tts",
"ttsvoicename": "",
"ttsconfig": "",
"ttsengine": "",
"ttsvolume": 0,
"ttsspeechrate": 0,
"ttspitchrate": 0
},
"privatedata": "test",
"playbacks": [
"欢迎进入测试程序,被叫号码是",
"${destination_number}",
"请说话测试吧",
"test.wav"
],
"sound_file_dir": "E:/sad/",
"pre_tts_text": [
"徐先生",
"2022年12月6日"
],
"log": "create succeed"
}
  • action 执行的动作

    • cti_play_and_detect_speech 放音同时执行语音识别
  • argument 动作参数

  • tts tts的配置说明,create的时候必须设置tts,后面可以不设置,会使用最后一次设置的。参数说明请看
    http://www.ddrj.com/smartivr/robot.html#TTS%E9%85%8D%E7%BD%AE

    如果需要对接自己的tts接口,ttsurl设置为 http://tts服务IP/tts,cti 会自动 把 tts参数加在这个URL后面, http://tts服务器ip/tts?config=&voice=&volume=0&speechrate=0&pitchrate=0&engine=&text=你好这里是顶顶通软件 类似这样。tts服务器返回tts转换后的声音文件(8000hz16位单声道的wav格式),浏览器测试可以下载到可播放的声音文件就可以。如果需要对接实时返回流的tts,改成ws://tts服务器地址:wsport/tts, URL参数不变,tts服务器实时返回8000hz16位单声道pcm声音流就可以。

  • sound_file_dir 声音文件路径,如果放音的是声音文件可以这个参数指定文件路径。后面可以不设置,会使用最后一次设置的。

  • dtmf_terminators DTMF终止符,any:任意字符,none:无终止符,max=最大输入DTMF个数,比如max=16,只有设置了DTMF终止符,才会处理DTMF输入,如果要放音的时候忽略按键,加上noplay,前缀。(DTMF就是电话按键的别称)

  • quickresponse 设置为true,识别到文字就提交。设置为false,一句话结束才提交。

  • playbacks 放音内容,支持变量,文字,录音文件等放音,详细说明请看 http://www.ddrj.com/smartivr/robot.html#%E6%94%BE%E9%9F%B3%E6%96%87%E4%BB%B6

  • privatedata 可以设置一个任意字符串,后续请求会送回这个数据,类似回调参数

  • log 如果需要输出日志到cti模块可以设置log。方便通过日志查看问题

  • pre_tts_text 需要预先tts的文本,因为TTS比较慢,可以对变量预先TTS,这样放音的时候,就已经TTS好了,不会卡顿。只有create的时候才支持pre_tts_text这个参数。

输入回调(input.text),说话或按键时执行的回调。

cti –> web (请求)

{
"timestamp": 1658152582127483,
"input_type": "text",
"input_args": "F你好",
"input_start_time": 1658152579338493,
"input_duration": 2779,
"play_progress": 0,
"callid": "27d36dee-a03f-40d2-b92e-2872c9057c21",
"appid": "1e89c6c7-e03b-4988-be0a-7eee25df8fa7",
"method": "input",
"privatedata": "test",
"record": "C:/src/utility/freeswitch/x64/Debug/recordings/2022-07-18/27d36dee-a03f-40d2-b92e-2872c9057c21_1.wav"
}
  • input_type 输入类型

    • text ASR
    • dtmf 按键
    • complete 动作执行完成
  • input_args 输入参数,input_type TEXT时asr识别结果(如果没命中关键词可以不处理),DTMF时按键内容。COMPLETE是完成输入参数 ,必须返回新动作。

    • text:asr识别结果前缀说明
      • 前缀F:一句话识别完成
      • 前缀E:ASR错误
      • 前缀S:用户还在说话,实时识别中
      • 前缀b:检测到开始说话
      • 前缀P:放音时的识别结果(打断模式128和256时放音时候说话才触发)
      • 前缀p: 暂停放音的时候等待用户说话超时
    • dtmf:dtmf按键内容
      • d:未匹配到终止符
      • D:已经匹配到终止符
    • complete:完成输入参数
      • DONE() 输入完成,DONE(F:识别内容1F:识别内容2)
      • TIMEOUT() 输入超时了,TIMEOUT(F:放音时候的识别内容S:超过最大说话时间了)。如果没检测到声音就是TIMEOUT()。TIMEOUT(S:识别内容)这样的也代表一次ASR调用,也要对ASR进行计费。
      • ERROR() 遇到错误
      • BREAK() 外部程序执行了uuid_break
      • HANGUP() 通话挂断了
  • input_start_time 输入开始时间,比如说话开始时的时间(微秒的时间戳)
  • input_duration 输入持续时间 ,比如说话的持续时间(毫秒)
  • play_progress 当前的放音时间(毫秒),暂停放音后这个值就不变化了。

web –> cti (响应)

{
"action": "cti_play_and_detect_speech",
"argument": "'1' '32' '0' '0.3' '127.0.0.1:9988' '120' '800' '5000' '20000' '' '' '8c44580b-ee09-4eaf-9641-d54c0466d810' '1' '${strftime(%Y-%m-%d)}' 'wav'",
"privatedata": "test",
"playbacks": [
"机器人放音内容"
],
"log": "自定义日志"
}

输入回调(input.complete),动作执行完成时执行的回掉,比如等待按键或者说话超时。

cti –> web (请求)

{
"timestamp": 1658156884760552,
"input_type": "complete",
"input_args": "TIMEOUT()",
"input_start_time": 1658156884740422,
"input_duration": 0,
"play_progress": 0,
"callid": "8ea0531c-18a6-4b5d-900f-ca5a34dfb5b6",
"appid": "258c056b-205f-4822-82af-52e0cf60c970",
"method": "input",
"privatedata": "test",
"record": ""
}

web –> cti (响应)

{
"action": "hangup",
"privatedata": "test",
"playbacks": [
"谢谢你的测试,再见"
],
"log": "自定义日志"
}

这个例子是执行挂机,实际上可以继续执行cti_play_and_detect_speech,继续对话。

伴随转人工的例子(人工接通前不切断机器人对话)

cti –> web (请求)

{
"timestamp": 1658200433683591,
"input_type": "text",
"input_args": "F转人工",
"input_start_time": 1658200428163288,
"input_duration": 5509,
"play_progress": 0,
"callid": "00075aa2-f6e6-4bf9-ad5a-2eb67534ae7c",
"appid": "4617bce4-4048-4037-8165-74ef1f67947b",
"method": "input",
"privatedata": "test",
"record": "C:/src/utility/freeswitch/x64/Debug/recordings/2022-07-19/00075aa2-f6e6-4bf9-ad5a-2eb67534ae7c_2.wav"
}

web –> cti (响应)

{
"action": "cti_play_and_detect_speech",
"argument": "'1' '32' '0' '0.3' '12.0.0.1:9988' '120' '800' '5000' '20000' '' '' '4617bce4-4048-4037-8165-74ef1f67947b' '1' '${strftime(%Y-%m-%d)}' 'wav'",
"privatedata": "test",
"playbacks": [
"正在为你转接人工,人工介入前,机器人可以继续和你对话,请继续说话了"
],
"manual": {
"linegroup": "2001",
"answer_stop_robot": true,
"beep_time": 1000,
"rest_time": 5000
},
"log": "自定义日志"
}
  • manual (转人工),这个参数只能设置一次,人工介入后,会自动停止机器人对话。
    • linegroup 通知到坐席组,就是线路组。
    • answer_stop_robot false:坐席接通后进入监听模式,按DTMF*才进入通话模式 ,true:坐席接通后机器人自动停止对话 。
    • beep_time 坐席接通时的滴声时间,单位毫秒。
    • rest_time 坐席接完一个电话后的休息时间,单位毫秒。

直接转人工例子(人工接通前就切断机器人对话)

cti –> web (请求)

{
"timestamp": 1661699580762878,
"input_type": "text",
"input_args": "F转分机"
input_start_time ":1661699578603243,"
input_duration ":2159,"
play_progress ":4759,"
callid ":"6d35c505-8539-4c51-be81-ae79abe6e435",
appid ":"a61ca40e-b59c-4b64-ac11-a4be9d3385c5",
method ":"input"
}

web –> cti (响应)

{
"variables": ["continue_on_fail=true", "robot_response=${variable_originate_disposition}", "robot_result=${variable_last_bridge_proto_specific_hangup_cause}"],
"action": "bridge",
"argument": "user\/120",
"privatedata": "test",
"playbacks": ["\u6b63\u5728\u4e3a\u4f60\u8f6c\u63a5\u5206\u673a\uff0c\u8bf7\u7b49\u5f85"],
"log": "\u81ea\u5b9a\u4e49\u65e5\u5fd7"
}
  • bridge 呼叫分机的命令
  • argument 转接给user/120 这个分机,{ignore_early_media=true}user/120 忽略原始彩铃(如果需要一直播放自定义彩铃,需要加上这个变量)
  • playbacks 转分机前播放的提示音
  • variables
    • transfer_ringback=彩铃文件路径
    • instant_ringback=true 启用自定义回铃音
    • continue_on_fail=true 呼叫分机失败后,不要挂断,返回流程
    • robot_response 设置bridge 动作完成参数response映射的变量
      • variable_originate_disposition SUCCESS,其他呼叫失败原因
      • variable_DIALSTATUS SUCCESS,其他呼叫失败原因,这个变量对部分失败原因进行了改写
    • robot_result 设置bridge动作完成输入result映射的变量。
      • variable_last_bridge_proto_specific_hangup_cause 返回“sip:挂机代码”
      • variable_last_bridge_hangup_cause 返回挂机原因
      • variable_sip_invite_failure_status 返回挂机代码
      • variable_sip_hangup_phrase 返回挂机代码的文字描述

cti –> web (请求)

呼叫分机失败

{
"timestamp": 1661699585183419,
"input_type": "complete",
"input_args": "CALL_REJECTED(sip:603)",
"input_start_time": 1661699585183419,
"input_duration": 0,
"play_progress": 0,
"callid": "6d35c505-8539-4c51-be81-ae79abe6e435",
"appid": "f7c4f9e4-f9aa-49e0-971d-9b94af09f5a8",
"method": "input",
"privatedata": "test",
"record": ""
}

cti –> web (请求)

呼叫分机成功(通话结束)

{
"timestamp": 1661700908024623,
"input_type": "complete",
"input_args": "SUCCESS(sip:200)",
"input_start_time": 1661700908024623,
"input_duration": 0,
"play_progress": 0,
"callid": "651cb138-b8b7-4935-8ebc-28ff40c65d98",
"appid": "c8548c25-2b8e-49d8-ac12-a99abc5248f5",
"method": "input",
"privatedata": "test",
"record": ""
}
  • input_args SUCCESS转接成功。

结束流程 (destory),通话结束最后一个执行的回调。

cti –> web (请求)

{
"timestamp": 1658152593247392,
"callid": "27d36dee-a03f-40d2-b92e-2872c9057c21",
"appid": "",
"method": "destory",
"privatedata": "test",
"cause": "send_bye"
}
  • cause 结束原因

web –> cti (响应)

{
"log":"destory succeed"
}

动作参数说明

支持FreeSWTICH所有APP,这里只介绍几个cti模块专有的APP

cti_play_and_detect_speech

放音的同时执行ASR识别,详细参数文档请看 http://www.ddrj.com/callcenter/asr.html#%E6%94%BE%E9%9F%B3%E7%9A%84%E5%90%8C%E6%97%B6%E6%89%A7%E8%A1%8CASR%E8%AF%86%E5%88%AB

hangup

挂机,参数就一个挂机原因。可以不设置参数。

cti_acd

进入排队 详细参数请看 http://www.ddrj.com/callcenter/acd.html#%E8%BF%9B%E5%85%A5%E6%8E%92%E9%98%9F

执行动作前放音

"playbacks": ["放音文字", "${destination_number}", "test.wav"] 任意动作都可以通过设置参数playbacks实现执行前放音。比如挂机(hangup)动作添加一个playbacks参数,就可以实现挂机前先放音。

执行动作前执行fs命令(API)

`”commands”:[“uuid_cti_play_and_detect_speech_break_play 534f5291-25bd-4440-af6d-173f26ffd83f”]} 任意动作都可以通过设置参数commands实现执行动作前先执行一个命令。

关键词停止放音(不打断)

关键词打断,就是匹配到关键词就播放新的声音,有一种场景,匹配到关键词停止放音,但是要等待用户说完才播放声音。下面就是描述这种场景的实现方法。

  1. quickresponse 设置为true,开启实时识别结果输出。
  2. 打断模式设置不要设置为1或者2,可以设置0,16或者32。 cti_play_and_detect_speech的第二个参数 就是[打断:【interrupt】0:关键词打断;1:检测到声音打断; 2:有识别结果打断; 3:识别到一句话打断。【关键词打断的可选功能,可以组合使用,比如要使用16和32,就设置48。16: 放音结束后识别到一句话就停止等待。 32: 放音时识别到一句话就不等待(隐含16)。64:放音时检测到声音就暂停放音。】] 具体可以参考 http://www.ddrj.com/smartivr/robot.html#ASR%E9%85%8D%E7%BD%AE
  3. 匹配到关键词执行API命令 uuid_cti_play_and_detect_speech_break_play $callid
  4. 也可以结合 play_progress 参数实现放音时候不允许打断。

放音控制

uuid_cti_fileman :<+val|-val>

  • speed 控制放音速度 比如 +1,-1

  • volume 控制放音音量 比如 +10,-10

  • pause 暂停放音,再次执行就恢复放音

    注意在暂停放音的时候,如果用户后续不在说话(超过wait_speech_timeout_ms 最大等待说话时间),会有一个text输入,前缀p,内容wait_speech_timeout 的回调,通知到接口暂停超时了。可以通过设置通道变量 cti_pause_wait_speech_timeout_ms自定义暂停时最大等待说话时间。

    {
    "timestamp": 1709196090518067,
    "input_type": "text",
    "input_args": "pwait_speech_timeout",
    "input_start_time": 1709196090518067,
    "input_duration": 0,
    "play_progress": 2480,
    "callid": "1ec37ad9-b1fb-4aa4-a2d5-d1761928d89b",
    "appid": "6a701aa4-9828-4b4b-8095-397b8ef291e6",
    "method": "input",
    }
  • stop 停止放音

  • truncate

  • restart 重新开始放音

  • seek 设置放音位置

设置通道变量

{"variables":["continue_on_fail=true","robot_response=${variable_originate_disposition}","robot_result=${variable_last_bridge_proto_specific_hangup_cause}"] 任意动作都可以添加variables参数,来实现动作执行前设置fs通道变量。

自定义动作完成返回值

可以通过设置通道变量robot_response和通道变量robot_result来实现自定义动作完成输入参数。 “input_type”:”complete”,”input_args”:”${robot_response)(${robot_result})”,比如bridge的例子设置变量”robot_response=${variable_originate_disposition}”,”robot_result=${variable_last_bridge_proto_specific_hangup_cause}”,动作完成输入input:complete CALL_REJECTED(sip:603),查看fs全部通道变量的方法是 fs控制台执行命令 uuid_dump callid ,这样查询到全部通道变量,然后设置你需要的通道变量。

接收DTMF按键

cti_play_and_detect_speech动作时添加"dtmf_terminators":"#"这个参数就可以启用DTMF按键接收,如果需要只接收DTMF按键,不要开启语音识别,只需要把argument的第一个参数改成0,就不会开启ASR语音识别了。

dtmf_terminators DTMF终止符,any:任意字符,none:无终止符,max=最大输入DTMF个数,比如max=16,只有设置了DTMF终止符,才会处理DTMF输入(DTMF就是电话按键的别称),如果需要放音的时候不接收按键,可以添加一个前缀 “noplay,”,比如放音的时候最大接收1个案件就是设置为”noplay,max=1”。

默认只有符合按键终止符才会停止放音,如果需要不符合按键终止符也停止放音,需要设置打断模式为512。

input_type TEXT和COMPLETE的区别

ASR识别到文字执行input_type=TEXT的回调,前缀S表示还在识别中,如果命中了关键词可以返回新流程动作,前缀F表示说话完成。如不继续等待用户说话,可以返回新流程动作。如果用户没说话或者input_type=TEXT的时候没有返回新流程动作,最大等待时间到达就会执行input_type=COMPLETE回调,这个回调必须返回新流程动作。

外部程序打断

可以调用httpcli接口http://127.0.0.1:88/cli?key=abc&cmd=uuid_break&arg=4cd77bdc-78ae-4f00-9018-b4ffcd395238 arg为要打断的通话callid。打断后回调通知”input_type”:”complete”,”input_args”:”BREAK()”

对接大模型注意事项

有的大模型可以逐步返回文本,可以逐步返回给接口放音,让对话更流畅。
比如大模型返回,第一句话。第二句话。第三句话。
大模型返回了第一句话,就把第一句话返回给接口去放音,返回的动作cti_play_and_detect_speech的参数等待说话时间,设置为0,这样放音完成了就会发送 input_type COMPLETE 请求,收到这个请求,继续返回后续的放音内容。就实现了低延迟放音了。

例子

php

<?php


$asr_addr="127.0.0.1:9988";
$tts_addr="http://127.0.0.1:9989/tts";


$data=file_get_contents("php://input");
$request = json_decode($data, TRUE);
$timestamp = $request["timestamp"]; //请求的时间戳
$method = $request["method"];
$callid=$request["callid"]; //通话唯一UUID
$appid=$request["appid"]; //执行动作的UUID,每次需要执行新动作系统会预先生成UUID,后续的输入都会带上这个UUID,动作执行完成时就会生成新的UUID。



if($method=="create"){

$call_source=$request["call_source"]; //呼叫来源 ,比如队列外呼就是 queuedialer
$source_name=$request["source_name"]; //来源名称 ,比如队列外呼就是任务名称

//cti_play_and_detect_speech的argument顺序。
//<mode> <interrupt> <vad_mode> <vad_filter> <asrproxy_addr> vad_min_active_time_ms vad_max_end_silence_time_ms wait_speech_timeout_ms max_speech_time_ms hot_word asr_params appid record_mode record_template record_format
//参数说明请看 http://www.ddrj.com/smartivr/robot.html#ASR%E9%85%8D%E7%BD%AE

//tts的配置说明,create的时候必须设置tts,后面可以不设置,会使用最后一次设置的。
//参数说明请看 http://www.ddrj.com/smartivr/robot.html#TTS%E9%85%8D%E7%BD%AE

//sound_file_dir
//声音文件路径,如果放音的是声音文件可以这个参数指定文件路径。后面可以不设置,会使用最后一次设置的。

//dtmf_terminators
//DTMF终止符,any:任意字符,none:无终止符,max=最大输入DTMF个数,比如max=16,只有设置了DTMF终止符,才会处理DTMF输入(DTMF就是电话按键的别称)

//quickresponse
//设置为true,识别到文字就提交。设置为false,一句话结束才提交。


//playbacks
//放音内容,支持变量,文字,录音文件等放音
//详细说明请看 http://www.ddrj.com/smartivr/robot.html#%E6%94%BE%E9%9F%B3%E6%96%87%E4%BB%B6
//详细参数文档请看 http://www.ddrj.com/callcenter/asr.html#%E6%94%BE%E9%9F%B3%E7%9A%84%E5%90%8C%E6%97%B6%E6%89%A7%E8%A1%8CASR%E8%AF%86%E5%88%AB

//privatedata
//可以设置一个任意字符串,后续请求会送回这个数据,类似回调参数

//log
//如果需要输出日志到cti模块可以设置log。方便通过日志查看问题

//pre_tts_text
//需要预先tts的文本,因为TTS比较慢,可以对变量预先TTS,这样放音的时候,就已经TTS好了,不会卡顿。只有create的时候才支持pre_tts_text这个参数。


//打断参数可以自己设置,例子第一句话开了实时打断,后续的没开实时打断
$response = array(
"action"=>"cti_play_and_detect_speech",
"argument"=>"'1' '64' '0' '0.8' '$asr_addr' '120' '800' '5000' '20000' '' '' '$appid' '1' '\${strftime(%Y-%m-%d)}' 'wav'", //打断模式是第二个参数,具体看看http://www.ddrj.com/smartivr/robot.html#ASR%E9%85%8D%E7%BD%AE
"tts"=>array("ttsurl"=>$tts_addr,"ttsvoicename"=>"","ttsconfig"=>"","ttsengine"=>"","ttsvolume"=>0,"ttsspeechrate"=>0,"ttspitchrate"=>0),
"privatedata"=>"test",
"playbacks"=>array("欢迎进入测试程序,被叫号码是","\${destination_number}","请说话测试吧","test.wav"),
"sound_file_dir"=>"E:/sad/",
"pre_tts_text"=>array("徐先生","2022年12月6日"),
"quickresponse"=>true,
"log"=>"create succeed");



echo(json_encode($response));

}
else if($method=="input"){

//input_type
//text asr转换后的文字
//dtmf 按键
//complete 动作执行完成

//input_args
//输入参数,input_type TEXT时asr识别结果,DTMF时按键内容。COMPLETE是完成输入参数
//asr识别结果前缀说明
// 前缀F:一句话识别完成
// 前缀E:ASR错误
// 前缀S:用户还在说话,实时识别中。
//dtmf按键内容
// d:未匹配到终止符
// D:已经匹配到终止符
//完成输入参数
// DONE() 输入完成,DONE(F:识别内容1F:识别内容2)
// TIMEOUT() 输入超时了,TIMEOUT(F:放音时候的识别内容S:超过最大说话时间了)。如果没检测到声音就是TIMEOUT()。TIMEOUT(S:识别内容)这样的也代表一次ASR调用,也要对ASR进行计费。
// ERROR() 遇到错误
// BREAK() 外部程序执行了uuid_break
// HANGUP() 用户挂机


//input_start_time (微秒的时间戳)
//输入开始时间,比如说话开始时的时间

//input_duration (毫秒)
//输入持续时间 ,比如说话的持续时间

//play_progress (毫秒)
//当前的放音时间


//manual (转人工),这个参数只能设置一次,人工介入后,会自动停止机器人对话。
// linegroup 通知到坐席组,就是线路组。
// answer_stop_robot false:坐席接通后进入监听模式,按DTMF*才进入通话模式 ,true:坐席接通后机器人自动停止对话 。
// beep_time 坐席接通时的滴声时间,单位毫秒。
// rest_time 坐席接完一个电话后的休息时间,单位毫秒。

$privatedata=$request["privatedata"];
$input_type=$request["input_type"];
$input_args=$request["input_args"];
$input_start_time=$request["input_start_time"];
$input_duration=$request["input_duration"];
$play_progress=$request["play_progress"];


//动作执行完成必须返回新的动作,不然会挂断通话
if($input_type=="complete"){



if(strncasecmp($input_args,"hangup",6)==0){
$response = array(
"action"=>"hangup",
"log"=>"挂机");
}
else if(strncmp($input_args,"record",6)==0){
$recordfile=substr($input_args,7,strlen($input_args)-8);
$response = array(
"action"=>"cti_play_and_detect_speech",
"argument"=>"'1' '1' '0' '0.8' '$asr_addr' '120' '800' '5000' '20000' '' '' '$appid' '1' '\${strftime(%Y-%m-%d)}' 'wav'",
"privatedata"=>"test",
"playbacks"=>array("刚刚的录音内容是",$recordfile,"请继续说话,可以说关键词,人工,转接,暂停,停止,分机来测试"),
"quickresponse"=>true,
"log"=>"播放录音");
}
else{

$response = array(
"action"=>"cti_play_and_detect_speech",
"argument"=>"'1' '1' '0' '0.8' '$asr_addr' '120' '800' '5000' '20000' '' '' '$appid' '1' '\${strftime(%Y-%m-%d)}' 'wav'",
"privatedata"=>"test",
"playbacks"=>array("动作执行完成,这里必须放音,请继续说话,可以说关键词,人工,转接,暂停,停止,分机来测试"),
"quickresponse"=>true,
"log"=>"重新开始放音");

}

echo(json_encode($response));


}
else{


$prefix = substr($input_args,0,1);
$text = substr($input_args,1);

if($prefix=='S'){
if($privatedata!="stop"){

if(intval($play_progress)>0){
$response = array(
"commands"=>array("uuid_cti_play_and_detect_speech_break_play ${callid}"),
"privatedata"=>"stop",
"log"=>"停止放音,但是不停止ASR识别。模拟关键词打断");
echo(json_encode($response));
}
}
}
else if($prefix=='F'){


if(strstr($text ,"挂断")){

$response = array(
"action"=>"hangup",
"privatedata"=>"test",
"playbacks"=>array("谢谢你的测试,再见"),
"log"=>"挂机");

echo(json_encode($response));

}
else if(strstr($text ,"人工")){

$response = array(
"action"=>"cti_play_and_detect_speech",
"argument"=>"'1' '1' '0' '0.8' '$asr_addr' '120' '800' '5000' '20000' '' '' '$appid' '1' '\${strftime(%Y-%m-%d)}' 'wav'",
"privatedata"=>"test",
"playbacks"=>array("正在为你转接人工,人工介入前,机器人可以继续和你对话,请继续说话了"),
"manual"=>array("linegroup"=>"2001","answer_stop_robot"=>true,"beep_time"=>200,"rest_time"=>5000),
"log"=>"转线路组");
echo(json_encode($response));

}
else if(strstr($text ,"分机")){

//variables设置通道变量
//continue_on_fail=true, 呼叫分机失败,不要挂断电话
//robot_response 动作完成时resposne读取的变量,本例子使用${variable_originate_disposition},支持多个变量组合
//robot_result 动作完成时result读取的变量,本例子使用${variable_last_bridge_proto_specific_hangup_cause},持多个变量组合
$response = array(
"variables"=>array("continue_on_fail=true","robot_response=\${variable_originate_disposition}","robot_result=\${variable_last_bridge_proto_specific_hangup_cause}"),
"action"=>"bridge",
"argument"=>"user/120",
"privatedata"=>"test",
"playbacks"=>array("正在为你转接分机,请等待"),
"log"=>"转分机");
echo(json_encode($response));

}
else if(strstr($text ,"按键")){

$response = array(
"action"=>"cti_play_and_detect_speech",
//cti_play_and_detect_speech的第一个参数改成0,就不会启用ASR,如果只需要按键,不需要ASR,把第一个参数改成0
"argument"=>"'1' '1' '0' '0.8' '$asr_addr' '120' '800' '5000' '20000' '' '' '$appid' '1' '\${strftime(%Y-%m-%d)}' 'wav'",
//DTMF终止符,any:任意字符,none:无终止符,max=最大输入DTMF个数,比如max=16,只有设置了DTMF终止符,才会处理DTMF输入(DTMF就是电话按键的别称)
"dtmf_terminators"=>"max=1",
"privatedata"=>"test",
"playbacks"=>array("按键测试,你按键试试吧"),
"log"=>"dtmf test");
echo(json_encode($response));

}

else if(strstr($text ,"录音")){

$response = array(
"action"=>"record",
//录音路径 最大录音时间 静音阈值 最大静音时间
"argument"=>"\${recordings_dir}/testrecord.wav 10 200 3",
"playbacks"=>array("请在滴声后开始录音,井号键停止录音","tone_stream://%(500,0,800)"),
"privatedata"=>"record",
"variables"=>array("playback_terminators=#","robot_response=record","robot_result=\${recordings_dir}/testrecord.wav"),
"log"=>"record test");
echo(json_encode($response));

}

else{


$response = array(
"action"=>"cti_play_and_detect_speech",
"argument"=>"'1' '1' '0' '0.8' '$asr_addr' '120' '800' '5000' '20000' '' '' '$appid' '1' '\${strftime(%Y-%m-%d)}' 'wav'",
"privatedata"=>"test",
"playbacks"=>array("刚刚的输入内容是", $text, "请继续说话测试吧,可以说关键词,人工,转接,暂停,停止,分机来测试"),
"quickresponse"=>true,
"log"=>"播放识别结果");
echo(json_encode($response));

}

}
if($prefix=='D'){
$response = array(
"action"=>"cti_play_and_detect_speech",
"argument"=>"'1' '1' '0' '0.8' '$asr_addr' '120' '800' '10000' '20000' '' '' '$appid' '1' '\${strftime(%Y-%m-%d)}' 'wav'",
"privatedata"=>"test",
"dtmf_terminators"=>"#",
"playbacks"=>array("刚刚的按键内容是", $text, "请继续按键测试吧,并以#号键结束"),
"log"=>"按键识别结果");
echo(json_encode($response));

}
else{
$response = array("log"=>"no processing");
echo(json_encode($response));
}

}
}
else if($method=="destory") {
$response = array("log"=>"destory succeed");
echo(json_encode($response));
}


?>

java

package com.cs.app.controller;

import cn.hutool.core.util.StrUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.time.LocalDateTime;
import java.util.*;

@RestController
@RequestMapping("/test")
@Slf4j
public class Test {

@PostMapping("/flow")
public Map<String, Object> flow(@RequestBody Map<String, Object> tokenMap) {
String asrAddr = "127.0.0.1:9988";
String ttsAddr = "http://127.0.0.1:9989/tts";

Long timestamp = (Long) tokenMap.get("timestamp");
String method = (String) tokenMap.get("method");
String callid = (String) tokenMap.get("callid");
String appid = (String) tokenMap.get("appid");
Map<String, Object> resultMap = new HashMap<>();
if ("create".equals(method)) {
String callSource = (String) tokenMap.get("call_source");
log.info("callSource ===>{}", callSource);
String sourceName = (String) tokenMap.get("source_name");
log.info("sourceName ===>{}", sourceName);

Map<String, Object> ttsMap = new HashMap<>();
resultMap.put("action", "cti_play_and_detect_speech");
String date = LocalDateTime.now().toString();
resultMap.put("argument", "'1' '64' '0' '0.8' '" + asrAddr + "' '120' '800' '5000' '20000' '' '' '" + appid + "' '1' '" + date + "' 'wav'");

ttsMap.put("ttsurl", ttsAddr);
ttsMap.put("ttsvoicename", "");
ttsMap.put("ttsconfig", "");
ttsMap.put("ttsengine", "");
ttsMap.put("ttsvolume", 0);
ttsMap.put("ttsspeechrate", 0);
ttsMap.put("ttspitchrate", 0);

resultMap.put("tts", ttsMap);
resultMap.put("privatedata", "test");
List<String> list = Arrays.asList("欢迎进入测试程序,被叫号码是", "13067436770", "请说话测试吧", "test.wav");
resultMap.put("playbacks", list);
resultMap.put("sound_file_dir", "D:\\sad\\");
resultMap.put("pre_tts_text", Arrays.asList("徐先生", "2022年12月6日"));
resultMap.put("quickresponse", true);
resultMap.put("log", "create succeed");

} else if ("input".equals(method)) {
String privatedata = (String) tokenMap.get("privatedata");
log.info("privatedata ===>{}", privatedata);
String input_type = (String) tokenMap.get("input_type");
log.info("input_type ===>{}", input_type);
String input_args = (String) tokenMap.get("input_args");
log.info("input_args ===>{}", input_args);
Long input_start_time = (Long) tokenMap.get("input_start_time");
log.info("input_start_time ===>{}", input_start_time);
Integer input_duration = (Integer) tokenMap.get("input_duration");
log.info("input_duration ===>{}", input_duration);
Integer play_progress = (Integer) tokenMap.get("play_progress");
log.info("play_progress ===>{}", play_progress);
if ("complete".equals(input_type)) {
// String inputArgSub = input_args.substring(0, 6);
if (input_args.contains("hangup")) {
resultMap.put("action", "hangup");
resultMap.put("log", "挂机");
} else if (input_args.contains("record")) {
String recordfile = StrUtil.subWithLength(input_args, 7, input_args.length() - 8);
resultMap.put("action", "cti_play_and_detect_speech");
String date = LocalDateTime.now().toString();
resultMap.put("argument", "'1' '1' '0' '0.8' '" + asrAddr + "' '120' '800' '5000' '20000' '' '' " + appid + " '1' '" + date + "' 'wav'");
resultMap.put("privatedata", "test");
resultMap.put("playbacks", Arrays.asList("刚刚的录音内容是", recordfile, "请继续说话,可以说关键词,人工,转接,暂停,停止,分机来测试"));
resultMap.put("quickresponse", true);
resultMap.put("log", "播放录音");
} else {
resultMap.put("action", "cti_play_and_detect_speech");
String date = LocalDateTime.now().toString();
resultMap.put("argument", "'1' '1' '0' '0.8' '" + asrAddr + "' '120' '800' '5000' '20000' '' '' '" + appid + "' '1' '" + date + "' 'wav'");
resultMap.put("privatedata", "test");
resultMap.put("playbacks", Collections.singletonList("动作执行完成,这里必须放音,请继续说话,可以说关键词,人工,转接,暂停,停止,分机来测试"));
resultMap.put("quickresponse", true);
resultMap.put("log", "重新开始放音");
}
} else {
String prefix = StrUtil.sub(input_args, 0, 1);
String text = StrUtil.subSuf(input_args, 1);
if ("S".equals(prefix)) {
if (!"stop".equals(privatedata)) {
if (play_progress > 0) {
resultMap.put("commands", Collections.singletonList("uuid_cti_play_and_detect_speech_break_play " + callid));
resultMap.put("privatedata", "stop");
resultMap.put("log", "停止放音,但是不停止ASR识别。模拟关键词打断");
}
}
} else if ("F".equals(prefix)) {
if (text.contains("挂断")) {
resultMap.put("action", "hangup");
resultMap.put("privatedata", "test");
resultMap.put("playbacks", Collections.singletonList("谢谢你的测试,再见"));
resultMap.put("log", "挂机");
} else if (text.contains("人工")) {
resultMap.put("action", "cti_play_and_detect_speech");
String date = LocalDateTime.now().toString();
resultMap.put("argument", "'1' '1' '0' '0.8' '" + asrAddr + "' '120' '800' '5000' '20000' '' '' '" + appid + "' '1' '" + date + "' 'wav'");
resultMap.put("privatedata", "test");
resultMap.put("playbacks", Collections.singletonList("正在为你转接人工,人工介入前,机器人可以继续和你对话,请继续说话了"));
Map<String, Object> manualMap = new HashMap<>();
manualMap.put("linegroup", "2001");
manualMap.put("answer_stop_robot", true);
manualMap.put("beep_time", 200);
manualMap.put("rest_time", 5000);
resultMap.put("manual", manualMap);
resultMap.put("log", "转线路组");
} else if (text.contains("分机")) {
List<String> list = Arrays.asList("continue_on_fail=true", "robot_response=\\${variable_originate_disposition}", "robot_result=\\${variable_last_bridge_proto_specific_hangup_cause}");
resultMap.put("variables", list);
resultMap.put("action", "bridge");
resultMap.put("argument", "user/120");
resultMap.put("privatedata", "test");
resultMap.put("playbacks", Collections.singletonList("正在为你转接分机,请等待"));
resultMap.put("log", "转分机");
} else if (text.contains("按键")) {
resultMap.put("action", "cti_play_and_detect_speech");
String date = LocalDateTime.now().toString();
resultMap.put("argument", "'1' '1' '0' '0.8' '" + asrAddr + "' '120' '800' '5000' '20000' '' '' '" + appid + "' '1' '" + date + "' 'wav'");
resultMap.put("dtmf_terminators", "max=1");
resultMap.put("privatedata", "test");
resultMap.put("playbacks", Arrays.asList("按键测试", "你按键试试吧"));
resultMap.put("log", "dtmf test");
} else if (text.contains("录音")) {
resultMap.put("action", "record");
resultMap.put("argument", "${recordings_dir}/testrecord.wav 10 200 3");
resultMap.put("playbacks", Arrays.asList("请在滴声后开始录音,井号键停止录音", "tone_stream://%(500,0,800)"));
resultMap.put("privatedata", "record");
resultMap.put("variables", Arrays.asList("playback_terminators=#", "robot_response=record", "robot_result=\\${recordings_dir}/testrecord.wav"));
resultMap.put("log", "record test");
} else {
resultMap.put("action", "cti_play_and_detect_speech");
String date = LocalDateTime.now().toString();
resultMap.put("argument", "'1' '1' '0' '0.8' '" + asrAddr + "' '120' '800' '5000' '20000' '' '' '" + appid + "' '1' '" + date + "' 'wav'");
resultMap.put("privatedata", "test");
resultMap.put("playbacks", Arrays.asList("刚刚的输入内容是", text, "请继续说话测试吧,可以说关键词,人工,转接,暂停,停止,分机来测试"));
resultMap.put("quickresponse", true);
resultMap.put("log", "播放识别结果");
}
}
if ("D".equals(prefix)) {
resultMap.put("action", "cti_play_and_detect_speech");
String date = LocalDateTime.now().toString();
resultMap.put("argument", "'1' '1' '0' '0.8' '" + asrAddr + "' '120' '800' '10000' '20000' '' '' '" + appid + "' '1' '" + date + "' 'wav'");
resultMap.put("privatedata", "test");
resultMap.put("dtmf_terminators", "#");
resultMap.put("playbacks", Arrays.asList("刚刚的按键内容是", text, "请继续按键测试吧,并以#号键结束"));
resultMap.put("log", "按键识别结果");
} else {
resultMap.put("log", "no processing");
}
}
} else if ("destory".equals(method)) {
resultMap.put("log", "destory succeed");
}
return resultMap;
}

}