devbox
Cpp五条
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

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

作者：Cpp五条 | 2024-03-16 06:26:06

赞

踩

新一代电话机器人开源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外呼管理截图

话术管理截图

坐席页面

管理员页面

线路管理

机器人话术代码：

  1. <?php
  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. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Cpp五条/article/detail/247676
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号