新一代电话机器人开源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;
16. trait SpeechExamineTrait{
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.     }
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.     }
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.     }
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.     }
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.     }
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.     }
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.     }
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.                 }
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.     }
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.     }
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.     }
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.     }
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.     }
542.     //生成一个挂机节点
543.     public function addHangUpPoints()
544.     {
545.         $endPointsArray["F9999999999999999999"] = [
546.             'condition'=>[
547.                     'complete'=> [
548.                         "any"
549.                     ]
550.             ],
551.         ];
552.         return $endPointsArray;
553.     }
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.     }
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.     }
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.             }
640.         return [$array,$keyReturn,$resReturn];
641.     }
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.     }
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) {
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.     }
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.                 }
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.     }
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.     }
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.     }
963. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。