• 新一代电话机器人开源PHP源代码

    使用easyswoole 框架开发的 新一代电话机器人开源PHP源码

    项目地址：https://gitee.com/ddrjcode/robotphp

    • 代理商页面演示地址

    http://119.23.229.15:8080

    用户名：c0508

    密码：123456

    包含 AI外呼管理，话术管理，CRM管理，坐席管理等功能。

    • 管理员后台演示地址

    http://119.23.229.15

    用户名：admin

    密码：123456

    包含  线路管理，代理商管理等功能

    AI外呼管理截图

    话术管理截图

    坐席页面

    管理员页面

    线路管理

    机器人话术代码：

    2. /**
    3.  * Created by PhpStorm.
    4.  * User: WIN10
    5.  * Date: 2021/12/18
    6.  * Time: 16:04
    7.  */
    8. namespace App\Traits;
    9. use App\Model\Speech\SpeechLabelSynonym;
    10. use App\Model\Speech\SpeechNodeModel;
    11. use App\Model\Speech\SpeechProcessModel;
    12. use App\Model\Speech\SpeechProcessNodeSettingModel;
    13. use App\Model\SpeechMul\SpeechMulLabelSynonym;
    14. use App\Model\SpeechMul\SpeechMulProcessSettingModel;
    15.  
    16. trait SpeechExamineTrait{
    17.  
    18.  
    19.     //主流程匹配关键词结果数组
    20.     public function getResultSynonym($speechId)
    21.     {
    22.         $resultSynonym      = [];
    23.         $synonymList        = SpeechLabelSynonym::create()->getAll(["speech_id"=>$speechId]);
    24.         foreach ($synonymList as $val){
    25.             if(isset($val["sls_name"])) {
    26.                 $resultSynonym[$val["node_id"]][$val["sls_keyword"]][] = $val["sls_name"];
    27.             }
    28.         }
    29.         return $resultSynonym;
    30.     }
    31.  
    32.  
    33.     //获取主流程的$nodesInfo信息 节点信息
    34.     //$processQueuesReal      = []; //真实存在的主流程节点（只有节点才存在到这个主流程）
    35.     public function getNodesInfoList($where)
    36.     {
    37.         $nodesInfo              = [];//所有节点信息map=>(k,v)
    38.         $processNodes           = [];
    39.         $processQueuesReal      = []; //真实存在的主流程节点（只有节点才存在到这个主流程）
    40.         //所有节点的信息
    41.         $nodesInfoList          = SpeechNodeModel::create()->getAll($where);
    42.         foreach ($nodesInfoList as $kk=>$vv)
    43.         {
    44.             $nodesInfo[$vv["node_id"]] = $vv;
    45.             if(!isset($processNodes[$vv["process_id"]])){//真实存在
    46.                 array_push($processQueuesReal,$vv["process_id"]);
    47.             }else{
    48.                 $processNodes[$vv["process_id"]]         = [];
    49.             }
    50.         }
    51.         return [$nodesInfo,$processQueuesReal];
    52.     }
    53.  
    54.  
    55.     //$processNodesArr 所有节点的数组
    56.     //$processQueues  所有的流程按照顺序
    57.     public function getProcessQueues($where)
    58.     {
    59.         $processNodesArr        = [];
    60.         $processQueues          = [];//所有的流程按照顺序
    61.         $processArray           = SpeechProcessModel::create()->getAll($where,'process_id',["sort,process_id","ASC"]);
    62.         foreach ($processArray as $a=>$item){
    63.             array_push($processQueues,$item["process_id"]);
    64.             $processNodesArr[$item["process_id"]] = [];
    65.         }
    66.         return [$processNodesArr,$processQueues];
    67.     }
    68.  
    69.  
    70.     //所有的参数节点流程
    71.     public function getArgArray($where)
    72.     {
    73.         $argList  = SpeechProcessNodeSettingModel::create()->getAll($where,"set_key,set_value,node_id");//所有的参数节点流程
    74.         $argArray = [];
    75.         foreach ($argList as $argK=>$argValue){
    76.             $argArray[$argValue["node_id"]][$argValue["set_key"]] = $argValue["set_value"];
    77.         }
    78.         return $argArray;
    79.     }
    80.  
    81.  
    82.     //获取所有树的第一个节点集
    83.     // $nodes = SpeechNodeTreeModel::create()->getAll($where,'process_id,node_id,parent_id,nodes_id',["node_id","ASC"]);
    84.     public function getTreeFirstNode($nodes)
    85.     {
    86.         $treeFirstNode      = [];
    87.         foreach ($nodes as $key=>$value)
    88.         {
    89.             if($value["parent_id"]==0){
    90.                 $treeFirstNode[$value["process_id"]] = $value;
    91.             }
    92.         }
    93.         return $treeFirstNode;
    94.     }
    95.  
    96.     public function getMulTreeFirstNode($nodes)
    97.     {
    98.         $treeFirstNode      = [];
    99.         foreach ($nodes as $key=>$value)
    100.         {
    101.             if($value["parent_id"]==0){
    102.                 $treeFirstNode[$value["process_mul_id"]] = $value;
    103.             }
    104.         }
    105.         return $treeFirstNode;
    106.     }
    107.  
    108.  
    109.     //获取流程的节点的集
    110.     //$processNodesNode 子集
    111.     // $nodes = SpeechNodeTreeModel::create()->getAll($where,'process_id,node_id,parent_id,nodes_id',["node_id","ASC"]);
    112.     //$resultSynonym  主流程匹配关键词结果数组集
    113.     //$childParent 父子节点数组        $childParent            = SpeechSmallNodeRelationModel::create()->getColumn($where,"node_id","small_node_id");
    114.     //$processReal  真实按照顺序的主流程
    115.     //$processRealFlip  主流程反转主流程
    116.     //$treeFirstNode   获取所有树的第一个节点集
    117.     //$nodeSynonymList  匹配的关键词
    118.     //$targetLabel
    119.     //$nodesInfo
    120.     public function getProcessNodesNode($nodes,$processNodesArr,$nodesInfo,$resultSynonym,$childParent,$processReal,$targetLabel,$processRealFlip,$treeFirstNode,$nodeSynonymList)
    121.     {
    122.         //判断是否有相同的节点
    123.         $sameNodeList       = [];
    124.         $processNodesNode   = [];
    125.         //用一个权重数组去获取最终值吧（始终取最大的）
    126.         $priorityArray      = [];
    127.         foreach ($nodes as $key=>$value)
    128.         {
    129.             $valueProcessId                                 = $value["process_id"];
    130.             $processNodesArr[$valueProcessId][]             = $value;
    131.             $subFlowModel   = [];
    132.             $valueNodesId   = $value["nodes_id"];
    133.             $valueParentId  = $value["parent_id"];
    134.             $valueNodeId    = $value["node_id"];
    135.             $priority       = "0"; //分支权重
    136.             if($valueNodesId) {
    137.                 $word = $targetLabel[$valueNodesId]??"";
    138.                 if ($word) {
    139.                     $synonymCode    =  "W." . $word;
    140.                     $yesSynonym     = [];
    141.                     $isMore         = 0;
    142.                     $arrSubFlow     = [];
    143.                     $synonymArray   = [];
    144.                     switch ($word){
    145.                         case "肯定":
    146.                             if(isset($resultSynonym[$childParent[$valueNodesId]]["yes"])) {
    147.                                 $yesSynonym = array_values($resultSynonym[$childParent[$valueNodesId]]["yes"]);
    148.                             }
    149.                             $priority = "5";
    150.                             break;
    151.                         case "否定":
    152.                             if(isset($resultSynonym[$childParent[$valueNodesId]]["no"])) {
    153.                                 $yesSynonym = array_values($resultSynonym[$childParent[$valueNodesId]]["no"]);
    154.                             }
    155.                             $priority = "10";
    156.                             break;
    157.                         case "拒绝":
    158.                             if(isset($resultSynonym[$childParent[$valueNodesId]]["reject"])) {
    159.                                 $yesSynonym = array_values($resultSynonym[$childParent[$valueNodesId]]["reject"]);
    160.                             }
    161.                             $priority = "12";
    162.                             break;
    163.                         case "默认":
    164.                             $priority = "2";
    165.                             $isMore = 1;
    166.                             break;
    167.                     }
    168.                     if($isMore==0) {//不是默认
    169.                         $synonymSystem = $yesSynonym ?: [$synonymCode];
    170.                         foreach ($synonymSystem as $item){
    171.                             $synonymArray[$item] = $word;
    172.                         }
    173.                         $arrSubFlow = [
    174.                             "condition" => [
    175.                                 "text" => $synonymSystem
    176.                             ],
    177.                             "priority" => $priority,
    178.                             "description" => $word
    179.                         ];
    180.                     }elseif($isMore==1){//是默认
    181.                         $arrSubFlow = [
    182.                             "condition" => [
    183.                                 "text" => ["any"]
    184.                             ],
    185.                             "priority" => $priority,
    186.                             "description" => $word
    187.                         ];
    188.                     }
    189.                     if(!isset($priorityArray[$valueNodeId])) {
    190.                         $priorityArray[$valueNodeId] = $priority;
    191.                     }else{
    192.                         if($priorityArray[$valueNodeId]<$priority){
    193.                             $priorityArray[$valueNodeId] =  $priority;
    194.                         }
    195.                     }
    196.                     if($nodesInfo[$valueNodeId]["info_talk_info"]) { //有信息的
    197.                         if(!isset($sameNodeList[$valueProcessId][$valueParentId][$valueNodeId])) {//是否存在当前流程，当前父id的，节点id
    198.                             //判断是否当前节点参数是否为空
    199.                             $subFlowModel["F" . $valueNodeId]   = $arrSubFlow;
    200.                             if($isMore==0) {//不是默认
    201.                                 $nodeSynonymList[$valueNodeId] = $synonymArray;
    202.                             }
    203.                             $sameNodeList[$valueProcessId][$valueParentId][$valueNodeId] = $key+1;
    204.                         }else{
    205.                             if(!isset($processNodesNode[$valueProcessId][$valueParentId] ["F" . $valueNodeId]["condition"]["text"])) {
    206.                                 $processNodesNode[$valueProcessId][$valueParentId] ["F" . $valueNodeId]["condition"]["text"] = [];
    207.                             }
    208.                             if($isMore==0) {//非默认
    209.                                 //有text关键词的操作
    210.                                 if ($yesSynonym) {
    211.                                     $processNodesNode[$valueProcessId][$valueParentId] ["F" . $valueNodeId]["condition"]["text"]  = array_merge($processNodesNode[$valueProcessId][$valueParentId] ["F" . $valueNodeId]["condition"]["text"] ,$yesSynonym);
    212.                                 }
    213.                                 //没有关键词的操作
    214.                                 if (!$yesSynonym) {
    215.                                     array_push($processNodesNode[$valueProcessId][$valueParentId] ["F" . $valueNodeId]["condition"]["text"], "W." . $word);
    216.                                 }
    217.                                 $nodeSynonymList[$valueNodeId] = array_merge($nodeSynonymList[$valueNodeId],$synonymArray);
    218.                             }
    219.                             if($isMore==1) {//默认
    220. //                                $processNodesNode[$valueProcessId][$valueParentId] ["F" . $valueNodeId]["condition"]["text"]= ["any"];
    221.                                 array_push($processNodesNode[$valueProcessId][$valueParentId] ["F" . $valueNodeId]["condition"]["text"], "any");
    222.                             }
    223.                             if(!isset($processNodesNode[$valueProcessId][$valueParentId]["F" . $valueNodeId]["description"])) {
    224.                                 $processNodesNode[$valueProcessId][$valueParentId]["F" . $valueNodeId]["description"] =  $word;
    225.                             }else{
    226.                                 $processNodesNode[$valueProcessId][$valueParentId]["F" . $valueNodeId]["description"] .= "," . $word;
    227.                             }
    228.                             $processNodesNode[$valueProcessId][$valueParentId]["F" . $valueNodeId]["priority"] = $priorityArray[$valueNodeId];
    229.                         }
    230.                     }
    231.                     elseif(!$nodesInfo[$valueNodeId]["info_talk_info"] && $nodesInfo[$valueNodeId]["type_id"]==2){
    232.                         $next           = $nodesInfo[$value["node_id"]]["next"];  //跳转的条件
    233.                         $nextId         = $nodesInfo[$value["node_id"]]["next_id"];//流程id
    234.                         $process_id     = $nodesInfo[$value["node_id"]]["process_id"]; //该流程id
    235.                         [$resReturnData,$returnKey,$resReturn] = $this->checkNextFlow($next,$nextId,$process_id,$processReal,$processRealFlip,$treeFirstNode,$arrSubFlow);//没有信息的就是跳转信息
    236.                         if(!isset($sameNodeList[$valueProcessId][$valueParentId][$returnKey])) {
    237.                             //判断是否当前节点参数是否为空
    238. //                            $subFlowModel["F".$returnKey]                               = $resReturn;
    239.                             if($resReturn){
    240.                                 if(!isset($subFlowModel["F" . $returnKey]["condition"]["text"])) {
    241.                                     $subFlowModel["F" . $returnKey]["condition"]["text"] = [];
    242.                                 }
    243.                                 if($isMore==0) {//非默认
    244.                                     if ($yesSynonym) {
    245.                                         $subFlowModel["F" . $returnKey]["condition"]["text"] = array_merge($processNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["condition"]["text"],$yesSynonym);
    246.                                     }
    247.                                     if (!$yesSynonym ) {
    248.                                         array_push($subFlowModel ["F" . $returnKey]["condition"]["text"], "W." . $word);
    249.                                     }
    250.                                 }
    251.                                 if($isMore==1) {//默认
    252. //                                    $subFlowModel ["F" . $returnKey]["condition"]["text"]= ["any"];
    253.                                     array_push($subFlowModel ["F" . $returnKey]["condition"]["text"], "any");
    254.                                 }
    255.                                 $subFlowModel["F" . $returnKey]["priority"] = $priorityArray[$valueNodeId];
    256.                             }
    257.                             $nodeSynonymList[$returnKey]                                = $synonymArray;
    258.                             $sameNodeList[$valueProcessId][$valueParentId][$returnKey]  = $key+1;
    259.                         }else{
    260.                             if(!isset($processNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["condition"]["text"])) {
    261.                                 $processNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["condition"]["text"] = [];
    262.                             }
    263.                             if($isMore==0) {//非默认
    264.                                 if ($yesSynonym) {
    265.                                     $processNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["condition"]["text"] = array_merge($processNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["condition"]["text"],$yesSynonym);
    266.                                     $nodeSynonymList[$returnKey]      = array_merge($nodeSynonymList[$returnKey],$synonymArray);
    267.                                 }
    268.                                 if (!$yesSynonym ) {
    269.                                     array_push($processNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["condition"]["text"], "W." . $word);
    270.                                     $nodeSynonymList[$returnKey] = array_merge($nodeSynonymList[$returnKey],$synonymArray);
    271.                                 }
    272.                             }
    273.                             if($isMore==1) {//默认
    274. //                                $processNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["condition"]["text"]= ["any"];
    275.                                 array_push($processNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["condition"]["text"], "any");
    276.                             }
    277.                             if(isset($processNodesNode[$valueProcessId][$valueParentId]["F" . $returnKey]["description"])) {
    278.                                 $processNodesNode[$valueProcessId][$valueParentId]["F" . $returnKey]["description"] =  $word;
    279.                             }else{
    280.                                 $processNodesNode[$valueProcessId][$valueParentId]["F" . $returnKey]["description"] .= "," . $word;
    281.                             }
    282.                             $processNodesNode[$valueProcessId][$valueParentId]["F" . $returnKey]["priority"] = $priorityArray[$valueNodeId];
    283.                         }
    284.                     }
    285.                 }
    286.             }
    287.             //是否存在当前的流程的process的id的，父id
    288.             //不存在就是直接把subFlow赋值给他
    289.             if (!isset($processNodesNode[$valueProcessId][$valueParentId])) {
    290.                 $processNodesNode[$valueProcessId][$valueParentId] = $subFlowModel;
    291.             } else {
    292.                 //存在就是数组连接一起
    293.                 $processNodesNode[$valueProcessId][$valueParentId] = array_merge($processNodesNode[$valueProcessId][$valueParentId],$subFlowModel);
    294.             }
    295.         }
    296.         return [$processNodesArr,$processNodesNode,$nodeSynonymList];
    297.     }
    298.  
    299.  
    300.     //获取flow流程
    301.     //获取 $nodeSynonymList  匹配的关键词
    302.     //$firstNode
    303.     //第一个主流程节点
    304.     //$version 版本
    305.     //$processReal  真实按照顺序的主流程
    306.     //$processRealFlip  主流程反转主流程
    307.     //$treeFirstNode   获取所有树的第一个节点集
    308.     //$nodeSynonymList  匹配的关键词
    309.     //$targetLabel
    310.     //$nodesInfo
    311.     //$processNodesNode 子集
    312.     public function getFlowList($flow,$processNodesArr,$nodeSynonymList,$version,$nodesInfo,$processNodesNode,$processReal,$processRealFlip,$treeFirstNode,$argArray,$allNodeWavKey,$allSettingsKey,$priority){
    313.         $count                  = 0;
    314.         $firstNode              = "";//第一个节点
    315.         foreach ($processNodesArr as $ke=>$ve){
    316.             foreach ($ve as $kkk=>$vvv){
    317.                 $vvvNodeId = $vvv["node_id"];
    318.                 if($count==0){
    319.                     $flow["Start"] = [
    320.                         'action'=>'start',
    321.                         'position'=>[
    322.                             "x"=>2489,
    323.                             "y"=>72
    324.                         ],
    325.                         "subflow"=>['F'.$vvvNodeId."_".$version=>new \stdClass()]
    326.                     ];
    327.                 }
    328.                 $count++;
    329.                 $arg = [];
    330.                 $arg["action"]          = "cti_play_and_detect_speech";
    331.                 if($count==1){
    332.                     $firstNode = $vvvNodeId."_".$version;
    333.                 }
    334.                 //模式
    335.                 $argM       = $argArray[$vvvNodeId]["moshi"]??"1";
    336.                 if(isset($allSettingsKey[$vvvNodeId]['interrupt']) && $allSettingsKey[$vvvNodeId]['interrupt']) {
    337.                     $argM = "2";
    338.                 }
    339.                 $argLuZao   = $argArray[$vvvNodeId]["luzao"]??"";
    340.                 $argKaiShi  = $argArray[$vvvNodeId]["kaishi"]??"";
    341.                 $argTingZhi = $argArray[$vvvNodeId]["tingzhi"]??"";
    342.                 $argDengDai = $argArray[$vvvNodeId]["dengdai"]??"";
    343.                 $argZuiDa   = $argArray[$vvvNodeId]["zuida"]??"";
    344.                 $argCanShu  = $argArray[$vvvNodeId]["canshu"]??"";
    345.                 $argLuYin   = $argArray[$vvvNodeId]["luyin"]??"";
    346.                 //挂机不需要这些参数
    347.                 if($nodesInfo[$vvvNodeId]['next']!=1) {
    348.                     $arg["filter"] = [
    349.                         "text" => "S",
    350.                         "dtmf" => "none"
    351.                     ];
    352.                     if ($priority == 1) {
    353.                         $arg["kb_priority"] = 0;
    354.                     } elseif ($priority == 2) {
    355.                         $arg["kb_priority"] = 1;
    356.                     }
    357.                     $arg["timeoutplaybacks"] = [];
    358.                     $arg["timeoutrepetition"] = "";
    359.                     $arg["mismatchplaybacks"] = [];
    360.                     $arg["mismatchrepetition"] = "1";
    361.                     $arg["globalflow"] = [
    362.                         "all"
    363.                     ];
    364.                 }else{//挂机节点不起用asr
    365.                     $argM = 0;
    366.                 }
    367.                 $arg["argument"]        = "'$argM' '16' '' '$argLuZao' '' '$argKaiShi' '$argTingZhi' '$argDengDai' '$argZuiDa' '' '$argCanShu' '$argLuYin' '' ''";
    368.                 $arg["position"]        = [
    369.                     "x"=>$nodesInfo[$vvvNodeId]["node_x"],
    370.                     "y"=>$nodesInfo[$vvvNodeId]["node_y"]
    371.                 ];
    372.                 $arg["description"]     = $nodesInfo[$vvvNodeId]["info_title"];
    373.                 if(isset($allNodeWavKey[$vvvNodeId]) && $allNodeWavKey[$vvvNodeId]) {
    374.                     $arg["playbacks"] = [$allNodeWavKey[$vvvNodeId]];
    375.                 }else{
    376.                     $arg["playbacks"] = [$nodesInfo[$vvvNodeId]["info_talk_info"]];
    377.                 }
    378.  
    379.                 $arg["kb"]          = 'C1';
    380.                 if(isset($processNodesNode[$vvv["process_id"]][$vvvNodeId])) {
    381.                     $arg["subflow"] = $processNodesNode[$vvv["process_id"]][$vvvNodeId];
    382.                 }else{
    383.                     $next           = $nodesInfo[$vvvNodeId]["next"];  //跳转的条件
    384.                     $nextId         = $nodesInfo[$vvvNodeId]["next_id"];//流程id
    385.                     $processId      = $nodesInfo[$vvvNodeId]["process_id"]; //该流程id
    386.                     [$arg["subflow"],$returnKey,$resReturn] = $this->checkNextFlow($next,$nextId,$processId,$processReal,$processRealFlip,$treeFirstNode);
    387.                 }
    388.                 if($nodesInfo[$vvvNodeId]["info_talk_info"]) {//如果是跳转节点，没有输入声音就是不输入
    389.                     if($count==1){
    390.                         $vvvNodeId .= "_".$version;
    391.                     }
    392.                     $flow["F" . $vvvNodeId] = $arg;
    393.                 }
    394.             }
    395.         }
    396.         return [$flow,$nodeSynonymList,$firstNode];
    397.     }
    398.  
    399.     //生成一个挂机节点
    400.     public function addEndPoints($flow)
    401.     {
    402.         /**
    403.          * 生成一个挂机节点
    404.          */
    405.         $endPointsArray = [
    406.             'action'=>'hangup',
    407.             'position'=>[
    408.                 "x"=>67,
    409.                 "y"=>33
    410.             ]
    411.         ];
    412.         $flow["F9999999999999999999"]=$endPointsArray;
    413.         return $flow;
    414.     }
    415.     //生成一个等待用户回答节点
    416.     public function addWaitPoints($flow)
    417.     {
    418.         /**
    419.          * 生成一个挂机节点
    420.          */
    421.         $endWaitArray = [
    422.             'action'=>"cti_play_and_detect_speech",
    423.             "argument"=>"'1' '16' '' '' '' '' '' '' '' '' '' '' '' ''",
    424.             "position"=>[
    425.                 "x"=>391833,
    426.                 "y"=>2372
    427.             ],
    428.             "playbacks"=>[],
    429.             "description"=>"",
    430.             "sourceflowdepth"=>"1",
    431.             "globalflow"=>[
    432.                 "all"
    433.             ],
    434.             "kb"         => 'C1',
    435.             "kb_priority"=>2,
    436.             "condition"=> [
    437.             "complete"=> [],
    438.                 "text"=> []
    439.             ],
    440.             "timeoutrepetition"=>"",
    441.             "mismatchplaybacks"=> [],
    442.             "subflow"=>[]
    443.         ];
    444.         $flow["F88888888888888888888"]=$endWaitArray;
    445. //        $flow["F66666666666666666666"]=[
    446. //            "action"=> "return",
    447. //            "position"=> [
    448. //                "x"=> 2263,
    449. //                "y"=> 492
    450. //            ]
    451. //        ];
    452.         return $flow;
    453.     }
    454.  
    455.     //生成一个挂机播放节点
    456.     public function addHangUpPlayContent($flow,$nodeId,$playbacks)
    457.     {
    458.         $hangUpArray = [
    459.             'action'=>"cti_play_and_detect_speech",
    460.             "argument"=>"'0' '16' '' '' '' '' '' '' '' '' '' '' '' ''",
    461.             "position"=>[
    462.                 "x"=>391833,
    463.                 "y"=>2372
    464.             ],
    465.             "playbacks"=>$playbacks,
    466.             "description"=>"",
    467.             "sourceflowdepth"=>"1",
    468.             "condition"=> [
    469.                 "text"=> []
    470.             ],
    471.             "mismatchplaybacks"=> [],
    472.             "subflow"=>[
    473.                 "F9999999999999999999"=> [
    474.                     "condition"=>[
    475.                         "complete"=> [
    476.                             "any"
    477.                         ],
    478.                     ],
    479.                 ]
    480.             ]
    481.         ];
    482.         $flow["F".$nodeId] = $hangUpArray;
    483.         return $flow;
    484.     }
    485.  
    486.     //生成一个挂机播放节点
    487.     public function addHangUpPlay($flow)
    488.     {
    489.         $hangUpArray = [
    490.             'action'=>"cti_play_and_detect_speech",
    491.             "argument"=>"'0' '16' '' '' '' '' '' '' '' '' '' '' '' ''",
    492.             "position"=>[
    493.                 "x"=>391833,
    494.                 "y"=>2372
    495.             ],
    496.             "playbacks"=>[],
    497.             "description"=>"",
    498.             "sourceflowdepth"=>"1",
    499.             "condition"=> [
    500.                 "text"=> []
    501.             ],
    502.             "mismatchplaybacks"=> [],
    503.             "subflow"=>[
    504.                 "F9999999999999999999"=> [
    505.                 "condition"=>[
    506.                     "text"=> [
    507.                         "any"
    508.                         ],
    509.                     ],
    510.                 ]
    511.             ]
    512.         ];
    513.         $flow["F5555555555555555555555"] = $hangUpArray;
    514.         return $flow;
    515.     }
    516.  
    517.     public function addWaitSubPoints(){
    518.         return [
    519.             "F9999999999999999999"=> [
    520.                 "condition"=>[
    521.                     "complete"=> [
    522.                         "timeout()"
    523.                     ]
    524.                 ],
    525.                 "description"=> "静音挂断"
    526.             ],
    527.             "F66666666666666666666"=>[
    528.                 "condition"=> [
    529.                     "complete"=> [],
    530.                     "text"=> [
    531.                         "F.+"
    532.                     ]
    533.                 ],
    534.                 "description"=> "有声音返回"
    535.             ]
    536.         ];
    537.     }
    538.  
    539.  
    540.  
    541.  
    542.     //生成一个挂机节点
    543.     public function addHangUpPoints()
    544.     {
    545.         $endPointsArray["F9999999999999999999"] = [
    546.             'condition'=>[
    547.                     'complete'=> [
    548.                         "any"
    549.                     ]
    550.             ],
    551.         ];
    552.         return $endPointsArray;
    553.     }
    554.  
    555.  
    556.     //跳转到指定主流程
    557.     public function toMainFlow($flowId)
    558.     {
    559.         $arg["F".$flowId]= [
    560.             "condition"=>[
    561.                 "complete"=> [],
    562.                     "text"=>[
    563.                     "any"
    564.                 ],
    565.                    "description"=>""
    566.                 ]
    567.         ];
    568.         return $arg;
    569.     }
    570.  
    571.     //跳转到指定多伦会话
    572.     public function toMulFlow($flowId)
    573.     {
    574.         $arg["F".$flowId."_".$flowId]= [
    575.             "condition"=>[
    576.                 "complete"=> [],
    577.                 "text"=>[
    578.                     "any"
    579.                 ],
    580.                 "description"=>""
    581.             ]
    582.         ];
    583.         return $arg;
    584.     }
    585.  
    586.  
    587.     //判断主流程下个流程的节点
    588.     public function  checkNextFlow($next,$nextId,$process_id,$processReal,$processRealFlip,$treeFirstNode,$arrSubFlow=[])
    589.     {
    590.         $array          = [];
    591.         $keyNext        = $processRealFlip[$process_id]+1;//下一个next
    592.         $hangUp         = $arrSubFlow?:["description"=>"无效回答", "condition"=>["text"=>["any"]]];
    593.         $nextProcess    = $arrSubFlow?: ["condition" => ["text" => ["any"]], "description" => "跳转下一个流程"];
    594.         $keyReturn      = "";
    595.         $resReturn      = "";
    596.         switch ($next)
    597.         {
    598.             case 0:
    599.             case 2:
    600.                 if(isset($processReal[$keyNext])){
    601.                     $array["F" . $treeFirstNode[$processReal[$keyNext]]["node_id"]] = $nextProcess;
    602.                     $keyReturn   = $treeFirstNode[$processReal[$keyNext]]["node_id"];
    603.                     $resReturn   = $nextProcess;
    604.                 }else{
    605.                     $array["F9999999999999999999"] = $hangUp;
    606.                     $keyReturn  = "9999999999999999999";
    607.                     $resReturn   = $hangUp;
    608.                 }
    609.                 break;
    610.             case 1:
    611.                 $array["F9999999999999999999"] = $hangUp;
    612.                 $keyReturn  = "9999999999999999999";
    613.                 $resReturn   = $hangUp;
    614.                 break;
    615.             case 3:
    616.                 if(isset($treeFirstNode[$nextId])) {
    617.                     $fistNode = $treeFirstNode[$nextId];
    618.                     $array["F" . $fistNode["node_id"]] = $nextProcess;
    619.                     $keyReturn   = $fistNode["node_id"];
    620.                     $resReturn   = $nextProcess;
    621.                 }else{
    622.                     $array["F9999999999999999999"] = $hangUp;
    623.                     $keyReturn       = "9999999999999999999";
    624.                     $resReturn       = $hangUp;
    625.                 }
    626.                 break;
    627.             case 4://返回接口
    628.                 $keyReturn  = substr(microtime(true),2,8).rand(0,99);
    629.                 $resReturn= [
    630.                     'action'  =>'return',
    631.                     'position'=>[
    632.                         'x'=>4085,
    633.                         'y'=>377
    634.                     ],
    635.                 ];
    636.                 $array["F".$keyReturn] = $resReturn;
    637.                 break;
    638.             }
    639.  
    640.         return [$array,$keyReturn,$resReturn];
    641.     }
    642.  
    643.  
    644.  
    645.     //多伦会话匹配关键词结果数组
    646.     public function getMulResultSynonym($speechId)
    647.     {
    648.         $resultSynonym      = [];
    649.         $synonymList        = SpeechMulLabelSynonym::create()->getAll(["speech_id"=>$speechId]);
    650.         foreach ($synonymList as $val){
    651.             if(isset($val["sls_name"])) {
    652.                 $resultSynonym[$val["node_mul_id"]][$val["sls_keyword"]][] = $val["sls_name"];
    653.             }
    654.         }
    655.         return $resultSynonym;
    656.     }
    657.  
    658.  
    659.     //获取所有子节点
    660.     public function getMulProcessNodesNode($flow,$nodesMul,$resultMulSynonym,$childMulParent,$nodesMulInfo,$targetMulLabel,$nodeSynonymList,$treeFirstNode)
    661.     {
    662.         //判断是否有相同的节点
    663.         $sameNodeList           = [];
    664.         $processMulNodesNode    = [];
    665.         $processMulNodesArr     = [];//所有全局话术的根节点
    666.         //用一个权重数组去获取最终值吧（始终取最大的）
    667.         $priorityArray      = [];
    668.         foreach ($nodesMul as $key=>$value)
    669.         {
    670.             $valueProcessId                     = $value["process_mul_id"];
    671.             $processMulNodesArr[$valueProcessId][]          = $value;
    672.             $subFlowModel   = [];
    673.             $valueNodesId   = $value["nodes_id"];
    674.             $valueParentId  = $value["parent_id"];
    675.             $valueNodeId    = "F".$value["node_mul_id"]."_".$value["node_mul_id"];
    676.             $priority       = "0";
    677.             if($valueNodesId) {
    678.                 $word = $targetMulLabel[$valueNodesId]??"";
    679.                 if ($word) {
    680.                     $synonymCode    =  "W." . $word;
    681.                     $yesSynonym     = [];
    682.                     $isMore         = 0;
    683.                     $arrSubFlow     = [];
    684.                     $synonymArray   = [];
    685.                     switch ($word){
    686.                         case "肯定":
    687.                             if(isset($resultMulSynonym[$childMulParent[$valueNodesId]]["yes"])) {
    688.                                 $yesSynonym = array_values($resultMulSynonym[$childMulParent[$valueNodesId]]["yes"]);
    689.                             }
    690.                             $priority = "5";
    691.                             break;
    692.                         case "否定":
    693.                             if(isset($resultMulSynonym[$childMulParent[$valueNodesId]]["no"])) {
    694.                                 $yesSynonym = array_values($resultMulSynonym[$childMulParent[$valueNodesId]]["no"]);
    695.                             }
    696.                             $priority = "10";
    697.                             break;
    698.                         case "拒绝":
    699.                             if(isset($resultMulSynonym[$childMulParent[$valueNodesId]]["reject"])) {
    700.                                 $yesSynonym = array_values($resultMulSynonym[$childMulParent[$valueNodesId]]["reject"]);
    701.                             }
    702.                             $priority = "12";
    703.                             break;
    704.                         case "默认":
    705.                             $priority = "2";
    706.                             $isMore = 1;
    707.                             break;
    708.                     }
    709.                     if($isMore==0) {//不是默认
    710.                         $synonymSystem = $yesSynonym ?: [$synonymCode];
    711.                         foreach ($synonymSystem as $item){
    712.                             $synonymArray[$item] = $word;
    713.                         }
    714.                         $arrSubFlow = [
    715.                             "condition" => [
    716.                                 "text" => $synonymSystem
    717.                             ],
    718.                             "priority" => $priority,
    719.                             "description" => $word
    720.                         ];
    721.                     }elseif($isMore==1){//是默认
    722.                         $arrSubFlow = [
    723.                             "condition" => [
    724.                                 "text" => ["any"]
    725.                             ],
    726.                             "priority" => $priority,
    727.                             "description" => $word
    728.                         ];
    729.                     }
    730.                     if(!isset($priorityArray[$valueNodeId])) {
    731.                         $priorityArray[$valueNodeId] = $priority;
    732.                     }else{
    733.                         if($priorityArray[$valueNodeId]<$priority){
    734.                             $priorityArray[$valueNodeId] =  $priority;
    735.                         }
    736.                     }
    737.                     if($nodesMulInfo[$value["node_mul_id"]]["info_talk_info"]) { //有信息的(多伦会话只要有信息判断)
    738.                         if(!isset($sameNodeList[$valueProcessId][$valueParentId][$valueNodeId])) {//是否存在当前流程，当前父id的，节点id
    739.                             //判断是否当前节点参数是否为空
    740.                             $subFlowModel[$valueNodeId]   = $arrSubFlow;
    741.                             if($isMore==0) {//不是默认
    742.                                 $nodeSynonymList[$valueNodeId] = $synonymArray;
    743.                             }
    744.                             $sameNodeList[$valueProcessId][$valueParentId][$valueNodeId] = $key+1;
    745.                         }else{
    746.                             if(!isset($processMulNodesNode[$valueProcessId][$valueParentId][$valueNodeId]["condition"]["text"])) {
    747.                                 $processMulNodesNode[$valueProcessId][$valueParentId][$valueNodeId]["condition"]["text"] = [];
    748.                             }
    749.                             if($isMore==0) {//非默认
    750.                                 if ($yesSynonym) {
    751.                                     $processMulNodesNode[$valueProcessId][$valueParentId][$valueNodeId]["condition"]["text"]  = array_merge($processMulNodesNode[$valueProcessId][$valueParentId][$valueNodeId]["condition"]["text"] ,$yesSynonym);
    752.                                 }
    753.                                 if (!$yesSynonym) {
    754.  
    755.                                     array_push($processMulNodesNode[$valueProcessId][$valueParentId][$valueNodeId]["condition"]["text"], "W." . $word);
    756.                                 }
    757.                                 $nodeSynonymList[$valueNodeId] = array_merge($nodeSynonymList[$valueNodeId],$synonymArray);
    758.                             }
    759.                             if($isMore==1) {//默认
    760. //                                $processMulNodesNode[$valueProcessId][$valueParentId][$valueNodeId]["condition"]["text"]= ["any"];
    761.                                 array_push($processMulNodesNode[$valueProcessId][$valueParentId][$valueNodeId]["condition"]["text"], "any");
    762.                             }
    763.                             if(!isset($processMulNodesNode[$valueProcessId][$valueParentId][$valueNodeId]["description"])) {
    764.                                 $processMulNodesNode[$valueProcessId][$valueParentId][$valueNodeId]["description"] =  $word;
    765.                             }else{
    766.                                 $processMulNodesNode[$valueProcessId][$valueParentId][$valueNodeId]["description"] .= "," . $word;
    767.                             }
    768.                             $processMulNodesNode[$valueProcessId][$valueParentId][$valueNodeId]["priority"] = $priorityArray[$valueNodeId];
    769.                         }
    770.                     }
    771.                     elseif(!$nodesMulInfo[$value["node_mul_id"]]["info_talk_info"] && $nodesMulInfo[$value["node_mul_id"]]["type_id"]==2){
    772.                         $next           = $nodesMulInfo[$value["node_mul_id"]]["next"];  //跳转的条件
    773.                         $nextId         = $nodesMulInfo[$value["node_mul_id"]]["next_id"];//流程id
    774.                         [$arrSubFlows,$returnKey,$resReturn,$flow] = $this->checkNextMulFlow($next,$nextId,$treeFirstNode,$flow);
    775.                         if(!isset($sameNodeList[$valueProcessId][$valueParentId][$returnKey])) {
    776.                             //判断是否当前节点参数是否为空
    777.                             if($resReturn){
    778.                                 if(!isset($subFlowModel["F" . $returnKey]["condition"]["text"])) {
    779.                                     $subFlowModel["F" . $returnKey]["condition"]["text"] = [];
    780.                                 }
    781.                                 if($isMore==0) {//非默认
    782.                                     if ($yesSynonym) {
    783.                                         $subFlowModel["F" . $returnKey]["condition"]["text"] = array_merge($processMulNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["condition"]["text"],$yesSynonym);
    784.                                     }
    785.                                     if (!$yesSynonym ) {
    786.                                         array_push($subFlowModel ["F" . $returnKey]["condition"]["text"], "W." . $word);
    787.                                     }
    788.                                 }
    789.                                 if($isMore==1) {//默认
    790. //                                    $subFlowModel ["F" . $returnKey]["condition"]["text"]= ["any"];
    791.                                     array_push($subFlowModel ["F" . $returnKey]["condition"]["text"], "any");
    792.                                 }
    793.                                 $subFlowModel["F" . $returnKey]["priority"] = $priorityArray[$valueNodeId];
    794.                             }
    795.                             if($isMore==0) {//不是默认
    796.                                 $nodeSynonymList[$valueNodeId] = $synonymArray;
    797.                             }
    798. //                            $subFlowModel["F".$returnKey]                               = $resReturn;
    799.                             $sameNodeList[$valueProcessId][$valueParentId][$returnKey]  = $key+1;
    800.                         }else{
    801.                             if(!isset($processMulNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["condition"]["text"])) {
    802.                                 $processMulNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["condition"]["text"] = [];
    803.                             }
    804.                             if($isMore==0) {//非默认
    805.                                 if ($yesSynonym) {
    806.                                     $processMulNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["condition"]["text"] = array_merge($processMulNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["condition"]["text"],$yesSynonym);
    807.                                 }
    808.                                 if (!$yesSynonym ) {
    809.                                     array_push($processMulNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["condition"]["text"], "W." . $word);
    810.                                 }
    811.                                 $nodeSynonymList[$valueNodeId] = array_merge($nodeSynonymList[$valueNodeId],$synonymArray);
    812.                             }
    813.                             if($isMore==1) {//默认
    814. //                                $processMulNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["condition"]["text"]= ["any"];
    815.                                 array_push($processMulNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["condition"]["text"], "any");
    816.                             }
    817.                             if(!isset($processMulNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["description"])){
    818.                                 $processMulNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["description"] = ",".$word;
    819.                             }else{
    820.                                 $processMulNodesNode[$valueProcessId][$valueParentId] ["F" . $returnKey]["description"] .= ",".$word;
    821.                             }
    822.                             $processMulNodesNode[$valueProcessId][$valueParentId]["F" . $returnKey]["priority"] = $priorityArray[$valueNodeId];
    823.                         }
    824.                     }
    825.                 }
    826.             }
    827.             if (!isset($processMulNodesNode[$valueProcessId][$valueParentId])) {
    828.                 $processMulNodesNode[$valueProcessId][$valueParentId] = $subFlowModel;
    829.             } else {
    830.                 $processMulNodesNode[$valueProcessId][$valueParentId] = array_merge($processMulNodesNode[$valueProcessId][$valueParentId],$subFlowModel);
    831.             }
    832.         }
    833.         return [$processMulNodesNode,$nodeSynonymList,$processMulNodesArr,$flow];
    834.     }
    835.  
    836.     //获取所有的
    837.     public function getMulFlowList($flow,$processMulNodesArr,$argMulArray,$nodesMulInfo,$treeFirstNode,$processMulNodesNode,$allNodeMulWavKey,$priority)
    838.     {
    839.         $count                  = 0;
    840.         foreach ($processMulNodesArr as $ke=>$ve){
    841.             foreach ($ve as $kkk=>$vvv){
    842.                 $vvvNodeId = $vvv["node_mul_id"];
    843.                 $count++;
    844.                 $arg = [];
    845.                 $arg["action"]          = "cti_play_and_detect_speech";
    846.                 //模式
    847.                 $argM       = $argMulArray[$vvvNodeId]["moshi"]??"1";
    848.                 $argLuZao   = $argMulArray[$vvvNodeId]["luzao"]??"";
    849.                 $argKaiShi  = $argMulArray[$vvvNodeId]["kaishi"]??"";
    850.                 $argTingZhi = $argMulArray[$vvvNodeId]["tingzhi"]??"";
    851.                 $argDengDai = $argMulArray[$vvvNodeId]["dengdai"]??"";
    852.                 $argZuiDa   = $argMulArray[$vvvNodeId]["zuida"]??"";
    853.                 $argCanShu  = $argMulArray[$vvvNodeId]["canshu"]??"";
    854.                 $argLuYin   = $argMulArray[$vvvNodeId]["luyin"]??"";
    855.                 //挂机不需要这些参数
    856.                 if($nodesMulInfo[$vvvNodeId]['next']!=1) {
    857.                     $arg["filter"] = [
    858.                         "text" => "S",
    859.                         "dtmf" => "none"
    860.                     ];
    861.                     if ($priority == 1) {
    862.                         $arg["kb_priority"] = 0;
    863.                     } elseif ($priority == 2) {
    864.                         $arg["kb_priority"] = 1;
    865.                     }
    866.                     $arg["timeoutplaybacks"] = [];
    867.                     $arg["timeoutrepetition"] = "";
    868.                     $arg["mismatchplaybacks"] = [];
    869.                     $arg["mismatchrepetition"] = "1";
    870.                     $arg["kb"] = 'C1';
    871.                     $arg["globalflow"] = [
    872.                         "all"
    873.                     ];
    874.                 }else{//挂机节点不起用asr
    875.                     $argM = 0;
    876.                 }
    877.                 $arg["argument"]        = "'$argM' '16' '' '$argLuZao' '' '$argKaiShi' '$argTingZhi' '$argDengDai' '$argZuiDa' '' '$argCanShu' '$argLuYin' '' ''";
    878.                 $arg["position"]        = [
    879.                     "x"=>$nodesMulInfo[$vvvNodeId]["node_x"],
    880.                     "y"=>$nodesMulInfo[$vvvNodeId]["node_y"]];
    881.                 $arg["description"]     = $nodesMulInfo[$vvvNodeId]["info_title"];
    882.                 if(isset($allNodeMulWavKey[$vvvNodeId]) && $allNodeMulWavKey[$vvvNodeId]) {
    883.                     $arg["playbacks"] = [$allNodeMulWavKey[$vvvNodeId]];
    884.                 }else{
    885.                     $arg["playbacks"] = [$nodesMulInfo[$vvvNodeId]["info_talk_info"]];
    886.                 }
    887.  
    888.                 if(isset($processMulNodesNode[$vvv["process_mul_id"]][$vvvNodeId])) {
    889.                     $arg["subflow"] = $processMulNodesNode[$vvv["process_mul_id"]][$vvvNodeId];
    890.                 }else{
    891.                     $next           = $nodesMulInfo[$vvvNodeId]["next"];   //跳转的条件
    892.                     $nextId         = $nodesMulInfo[$vvvNodeId]["next_id"];//流程id
    893.                     [$arg["subflow"],$returnKey,$resReturn,$flow] = $this->checkNextMulFlow($next,$nextId,$treeFirstNode,$flow);
    894.                 }
    895.                 if($nodesMulInfo[$vvvNodeId]["info_talk_info"]) {//如果是跳转节点，没有输入声音就是不输入
    896.                     $keyNode = "F".$vvvNodeId."_".$vvvNodeId;
    897.                     $flow[$keyNode] = $arg;
    898.                 }
    899.             }
    900.         }
    901.         return $flow;
    902.     }
    903.  
    904.     //多伦会话下一步
    905.     public function checkNextMulFlow($next,$nextId,$treeFirstNode,$flow)
    906.     {
    907.         $array          = [];
    908.         $info           = ["description"=>"默认回答", "condition"=>["text"=>["any"]]];
    909.         $keyReturn      = "";
    910.         $resReturn      = "";
    911.         switch ($next)
    912.         {
    913.             case 0://普通节点默认挂机
    914.             case 1://挂机
    915.                 $hangK              = substr(microtime(true),2,8).rand(0,99);
    916.                 $hangKey            = "F".$hangK;
    917.                 $array[$hangKey]    = $info;
    918.                 $keyReturn          = $hangK;
    919.                 $resReturn          = $info;
    920.                 //挂机节点需要添加挂机节点
    921.                 /**
    922.                  * 生成一个挂机节点
    923.                  */
    924.                 $endPointsArray = [
    925.                     'action'=>'hangup',
    926.                     'position'=>[
    927.                         "x"=>67,
    928.                         "y"=>33
    929.                     ]
    930.                 ];
    931.                 $flow[$hangKey]=$endPointsArray;
    932.                 break;
    933.             case 2://跳转指定多伦会话
    934.                 $hangKey            = "F".$nextId."_".$nextId;
    935.                 $array[$hangKey]    = $info;
    936.                 $keyReturn          = $nextId."_".$nextId;
    937.                 $resReturn          = $info;
    938.                 break;
    939.             case 3://指定主流程
    940.                 $hangKey            = "F".$treeFirstNode[$nextId]['node_id'];
    941.                 $array[$hangKey]    = $info;
    942.                 $keyReturn          = $treeFirstNode[$nextId]['node_id'];
    943.                 $resReturn          = $info;
    944.                 break;
    945.         }
    946.         return [$array,$keyReturn,$resReturn,$flow];
    947.     }
    948.  
    949.  
    950.     //所有的多伦会话节点流程
    951.     public function getMulArgArray($where)
    952.     {
    953.         $argList  = SpeechMulProcessSettingModel::create()->getAll($where,"set_key,set_value,node_mul_id");//所有的参数节点流程
    954.         $argArray = [];
    955.         foreach ($argList as $argK=>$argValue){
    956.             $argArray[$argValue["node_mul_id"]][$argValue["set_key"]] = $argValue["set_value"];
    957.         }
    958.         return $argArray;
    959.     }
    960.  
    961.  
    962.  
    963. }

  • 相关阅读:
    ssdp协议搜索GB28181设备
    Java修仙之基础功法篇-＞构建者模式
    PyTorch Geometric (PyG) 安装教程
    web前端网页设计期末课程大作业：旅游网页主题网站设计——紫色的旅游开发景点网站静态模板(4页)HTML+CSS+JavaScript
    BUUCTF Misc 来首歌吧 & 荷兰宽带数据泄露 & 面具下的flag & 九连环
    如何评价GPT-4o?
    Conda Channel 介绍与配置
    多输入多输出 | MATLAB实现PSO-LSSVM粒子群优化最小二乘支持向量机多输入多输出
    外包干了三年，真废了。。。
    java计算机毕业设计心理学网站源程序+mysql+系统+lw文档+远程调试
  • 原文地址：https://blog.csdn.net/iyaosan/article/details/136423142