<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"/>

{
	"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"
}

{
	"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"
}

{
	"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": ""
}

{
	"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": ""
}

<?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));
}


?>

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;
  }

}