电话机器人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"
}
|
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": ""
}
|
结束流程 （destory），通话结束最后一个执行的回调。
cti –> web （请求）
{
"timestamp": 1658152593247392,
"callid": "27d36dee-a03f-40d2-b92e-2872c9057c21",
"appid": "",
"method": "destory",
"privatedata": "test",
"cause": "send_bye"
}
|
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实现执行动作前先执行一个命令。
关键词停止放音(不打断)
关键词打断，就是匹配到关键词就播放新的声音，有一种场景，匹配到关键词停止放音，但是要等待用户说完才播放声音。下面就是描述这种场景的实现方法。
- quickresponse 设置为true，开启实时识别结果输出。
- 打断模式设置不要设置为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
- 匹配到关键词执行API命令 uuid_cti_play_and_detect_speech_break_play $callid
- 也可以结合 play_progress 参数实现放音时候不允许打断。
放音控制
uuid_cti_fileman :<+val|-val>
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就是电话按键的别称)
默认只有符合按键终止符才会停止放音，如果需要不符合按键终止符也停止放音，需要设置打断模式为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()”
例子
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;
}
}
|