Skip to content

Commit

Permalink
Доработал генератор dialplan.
Browse files Browse the repository at this point in the history
  • Loading branch information
apor committed Jan 15, 2021
1 parent 4f13daa commit 18615a3
Showing 1 changed file with 55 additions and 31 deletions.
86 changes: 55 additions & 31 deletions src/Core/Asterisk/Configs/Generators/Extensions/IncomingContexts.php
View file
Original file line number Diff line number Diff line change
Expand Up @@ -51,14 +51,14 @@ public static function generate($provider, $login = '', $uniqid = ''): string
$timeout = trim($rout['timeout']);
$rout_number = ($number === '') ? 'X!' : $number;
$rout_data = &$dialplan[$rout_number];
self::generateRouteDialplan($rout_data, $provider, $rout, $lang, $additionalModules);
if (empty($rout_data)) {
self::generateRouteDialplan($rout_data, $provider, $rout, $lang, $additionalModules);
}
self::generateDialActions($rout_data_dial, $rout, $rout_number, $confExtensions, $timeout, $provider, $number);
}

self::multiplyExtensionsInDialplan($dialplan, $rout_data_dial, $login, $data, $need_def_rout, $provider);

self::trimDialplans($dialplan, $rout_data_dial);

self::createSummaryDialplan($conf, $provider, $uniqid, $dialplan, $default_action, $confExtensions, $additionalModules);

return $conf;
Expand Down Expand Up @@ -110,9 +110,7 @@ private static function checkNeedDefRout($provider, array &$data): bool{
* @param $additionalModules
*/
private static function generateRouteDialplan(?string &$rout_data, $provider, array $rout, string $lang, $additionalModules): void{
if (!empty($rout_data)) {
return;
}

$number = trim($rout['number']);
$rout_number = ($number === '') ? 'X!' : $number;

Expand Down Expand Up @@ -211,21 +209,33 @@ private static function trimDialplans(array $dialplans, array $rout_data_dial):v
*/
private static function multiplyExtensionsInDialplan(array &$dialplan, array &$rout_data_dial, $login, array $data, bool $need_def_rout, $provider): void{
if (is_string($login)) {
$add_login_pattern = self::needAddLoginExtension($login, $data);
if ($add_login_pattern && array_key_exists('X!', $rout_data_dial) && isset($dialplan['X!'])) {
$dialplan[$login] = str_replace('_X!,1', "{$login},1", $dialplan['X!']);
$rout_data_dial[$login] = $rout_data_dial['X!'];
} elseif ($add_login_pattern === true && $need_def_rout === true && count($data) === 1) {
// Только маршрут "По умолчанию".
$dialplan[$login] = str_replace('_X!,1', "{$login},1", $dialplan['X!']);
}
} elseif (is_array($provider)) {
self::multiplyExtensionsInDialplanStringLogin($login, $data, $rout_data_dial, $dialplan, $need_def_rout);
}
if (is_array($provider)) {
foreach (array_values($provider) as $_login) {
$dialplan[$_login] = str_replace('_X!,1', "{$_login},1", $dialplan['X!']);
}
}
}

/**
* @param string $login
* @param array $data
* @param array $rout_data_dial
* @param array $dialplan
* @param bool $need_def_rout
*/
private static function multiplyExtensionsInDialplanStringLogin(string $login, array $data, array &$rout_data_dial, array &$dialplan, bool $need_def_rout): void{
$add_login_pattern = self::needAddLoginExtension($login, $data);
if ($add_login_pattern && array_key_exists('X!', $rout_data_dial) && isset($dialplan['X!'])) {
$dialplan[$login] = str_replace('_X!,1', "{$login},1", $dialplan['X!']);
$rout_data_dial[$login] = $rout_data_dial['X!'];
} elseif ($add_login_pattern === true && $need_def_rout === true && count($data) === 1) {
// Только маршрут "По умолчанию".
$dialplan[$login] = str_replace('_X!,1', "{$login},1", $dialplan['X!']);
}
}

/**
* Если логин не числовой, то нужно добавить такой Exten.
* @param string $login
Expand Down Expand Up @@ -256,6 +266,7 @@ private static function needAddLoginExtension(string $login, array $data): bool{
}

/**
* Формирование итогового dialplan.
* @param string $conf
* @param $provider
* @param string $uniqId
Expand All @@ -274,22 +285,7 @@ private static function createSummaryDialplan(string & $conf, $provider, string
continue;
}
if ('extension' === $default_action->action) {
// Обязательно проверяем "DIALSTATUS", в случае с парковой через AMI вызова это необходимо.
// При ответе может отработать следующий приоритет.
$conf .= "\t" . 'same => n,Set(M_TIMEOUT=0)' . "\n";
if (in_array($default_action->extension, $confExtensions, true)) {
// Это конференция. Тут не требуется обработка таймаута ответа.
// Вызов будет отвечен сразу конференцией.
$conf .= "\t" . "same => n," . 'ExecIf($["${M_DIALSTATUS}" != "ANSWER"]?' . "Goto(internal,{$default_action->extension},1)); default action" . "\n";
} else {
$conf .= "\t" . "same => n," . 'ExecIf($["${M_DIALSTATUS}" != "ANSWER"]?' . "Dial(Local/{$default_action->extension}@internal/n,,TKg)); default action" . "\n";
}
foreach ($additionalModules as $appClass) {
$addition = $appClass->generateIncomingRoutAfterDialContext($uniqId);
if (!empty($addition)) {
$conf .= $appClass->confBlockWithComments($addition);
}
}
$conf = self::createSummaryDialplanGoto($conf, $default_action, $confExtensions, $additionalModules, $uniqId);
$conf .= " \t" . 'same => n,GosubIf($["${DIALPLAN_EXISTS(${CONTEXT}-after-dial-custom,${EXTEN},1)}" == "1"]?${CONTEXT}-after-dial-custom,${EXTEN},1)' . "\n";
} elseif ('busy' === $default_action->action) {
$conf .= "\t" . "same => n,Busy()" . "\n";
Expand All @@ -299,4 +295,32 @@ private static function createSummaryDialplan(string & $conf, $provider, string
return $conf;
}

/**
* @param string $conf
* @param IncomingRoutingTable $default_action
* @param array $confExtensions
* @param $additionalModules
* @param string $uniqId
* @return string
*/
private static function createSummaryDialplanGoto(string $conf, IncomingRoutingTable $default_action, array $confExtensions, $additionalModules, string $uniqId): string{
// Обязательно проверяем "DIALSTATUS", в случае с парковой через AMI вызова это необходимо.
// При ответе может отработать следующий приоритет.
$conf .= "\t" . 'same => n,Set(M_TIMEOUT=0)' . "\n";
if (in_array($default_action->extension, $confExtensions, true)) {
// Это конференция. Тут не требуется обработка таймаута ответа.
// Вызов будет отвечен сразу конференцией.
$conf .= "\t" . "same => n," . 'ExecIf($["${M_DIALSTATUS}" != "ANSWER"]?' . "Goto(internal,{$default_action->extension},1)); default action" . "\n";
} else {
$conf .= "\t" . "same => n," . 'ExecIf($["${M_DIALSTATUS}" != "ANSWER"]?' . "Dial(Local/{$default_action->extension}@internal/n,,TKg)); default action" . "\n";
}
foreach ($additionalModules as $appClass) {
$addition = $appClass->generateIncomingRoutAfterDialContext($uniqId);
if (!empty($addition)) {
$conf .= $appClass->confBlockWithComments($addition);
}
}
return $conf;
}

}

0 comments on commit 18615a3

Please sign in to comment.