mikopbx/ModuleAutoDialer

Lib/AutoDialerConf.php
493 строки28 KB
Alexey Portnov
Fix duplicate 'exten => t' registration in polling dialplan contexts
23 мар 2026, 23:38
23 мар 2026, 23:38db5b840
<?php
/*
 * MikoPBX - free phone system for small business
 * Copyright © 2017-2023 Alexey Portnov and Nikolay Beketov
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along with this program.
 * If not, see <https://www.gnu.org/licenses/>.
 */

namespace Modules\ModuleAutoDialer\Lib;

use MikoPBX\Core\Asterisk\Configs\ExtensionsConf;
use MikoPBX\Core\System\Configs\CronConf;
use MikoPBX\Core\System\PBX;
use MikoPBX\Core\System\Util;
use MikoPBX\Core\Workers\Cron\WorkerSafeScriptsCore;
use MikoPBX\Modules\Config\ConfigClass;
use Modules\ModuleAutoDialer\bin\ConnectorDB;
use Modules\ModuleAutoDialer\bin\WorkerAMI;
use Modules\ModuleAutoDialer\bin\WorkerDialer;
use Modules\ModuleAutoDialer\Lib\RestAPI\Controllers\ApiController;
use Modules\ModuleAutoDialer\Models\DialerExtensions;
use Modules\ModuleAutoDialer\Models\ModuleAutoDialer;
use Modules\ModuleAutoDialer\Models\Polling;
use Modules\ModuleAutoDialer\Models\Question;
use Modules\ModuleAutoDialer\Models\QuestionActions;
use Modules\ModuleAutoDialer\Models\Tasks;
use Exception;

class AutoDialerConf extends ConfigClass
{
    public const CONTEXT_NAME = 'dialer-out-originate-in';
    public const CONTEXT_POLLING_NAME = 'dialer-polling';
    private string $lang = '';
    private $tts;
    private string $modName = 'func_hangupcause';


    public function getSettings(): void
    {
        parent::getSettings();
        $this->lang = str_replace('_', '-', strtolower($this->generalSettings['PBXLanguage']));
    }

    /**
     * Adds priorities ащк [dial_create_chan] context section in the extensions.conf file
     * @see https://docs.mikopbx.com/mikopbx-development/module-developement/module-class#extensiongenhints
     *
     * @return string
     */
    public function extensionGenCreateChannelDialplan(): string
    {
        return 'same => n,ExecIf($["${CHANNEL(channeltype)}" == "PJSIP" && "${CHANNEL(endpoint):0:4}" == "SIP-"]?Set(CHANNEL(hangup_handler_push)=dialer-out-originate-in-hangup-handler,s,1))'."\t";
    }

    public function generateModulesConf(): string
    {
        return "load => $this->modName.so".PHP_EOL;
    }

    /**
     * Generates the internal dialplan for IVR.
     *
     * @return string The generated internal dialplan.
     */
    public function extensionGenInternal(): string
    {
        $conf = '';
        $db_data      = DialerExtensions::find()->toArray();
        foreach ($db_data as $data) {
            $conf .= "exten => {$data['exten']},1,AGI($this->moduleDir/agi-bin/get-client-info.php,{$data['id']})" . "\n";
        }
        $conf .= "\n";

        return $conf;
    }

    /**
     * Prepares additional contexts sections in the extensions.conf file
     *
     * @return string
     */
    public function extensionGenContexts(): string
    {
        $this->getSettings();
        $extensions = AutoDialerMain::getExtensions();
        $conf = '';
        foreach ($extensions as $extensionData){
            $conf .= 'exten => '.$extensionData->number.',1,NoOp()'.PHP_EOL."\t".
                // Скрипт завершит вызов, в случае, если extension is busy.
                $this->getAgiActionCmd(ConnectorDB::EVENT_ALL_USER_BUSY).PHP_EOL."\t".
                'same => n,return'.PHP_EOL;
        }
        return '['.self::CONTEXT_NAME.']'.PHP_EOL.
            'exten => '.ExtensionsConf::ALL_EXTENSION.',1,Noop(${MASTER_CHANNEL(CHANNEL)})'.PHP_EOL."\t".
                'same => n,Gosub(dialer-out-originate-set-bridge-peer,${EXTEN},1)'.PHP_EOL."\t".
                'same => n,ExecIf($[ "${bridgePeer}x" != "x" ]?ChannelRedirect(${bridgePeer},${CONTEXT},${EXTEN},1000))'.PHP_EOL."\t".
                // bridgePeer пустой — вызов не состоялся (например, заблокирован лимитом каналов)
                $this->getAgiActionCmd(ConnectorDB::EVENT_FAIL_ORIGINATE).PHP_EOL."\t".
                'same => n,Hangup()'.PHP_EOL."\t".

                'same => 1000,NoOp()'.PHP_EOL."\t".
                'same => n,GosubIf($["${M_IS_CALLBACK}x" != "x"]?dialer-out-originate-in-callback,check,1)'.PHP_EOL."\t".
                'same => n,ExecIf($["${M_IS_CALLBACK}x" == "x"]?Set(CALLERID(name)=${M_OUT_NUMBER}))'.PHP_EOL."\t".
                'same => n,ExecIf($["${M_IS_CALLBACK}x" == "x"]?Set(CALLERID(num)=${M_OUT_NUMBER}))'.PHP_EOL."\t".
                'same => n,Set(__FROM_DID=${EXTEN})'.PHP_EOL."\t".
                'same => n,Set(__FROM_CHAN=${CHANNEL})'.PHP_EOL."\t".
                'same => n,ExecIf($[ "${QUEUE_SRC_CHAN}x" != "x" ]?Set(__QUEUE_SRC_CHAN=${CHANNEL}))'.PHP_EOL."\t".
                'same => n,ExecIf($["${CHANNEL(channeltype)}" != "Local"]?Gosub(set_from_peer,s,1))'.PHP_EOL."\t".
                'same => n,ExecIf($["${CHANNEL(channeltype)}" == "Local"]?Set(__FROM_PEER=${CALLERID(num)}))'.PHP_EOL."\t".
                'same => n,Set(__TRANSFER_OPTIONS=t)'.PHP_EOL."\t".
                'same => n,ExecIf($["${M_EXTEN_TYPE}" == "'.Tasks::TYPE_INNER_NUM_POLLING.'"]?Goto('.self::CONTEXT_POLLING_NAME.',${EXTEN},1))'.PHP_EOL."\t".
                'same => n,GosubIf($["${M_IS_CALLBACK}x" == "x"]?hangup_chan,${EXTEN},1)'.PHP_EOL."\t".
                'same => n,Set(pt1c_UNIQUEID=${UNDEFINED})'.PHP_EOL."\t".

                $this->getAgiActionCmd(ConnectorDB::EVENT_START_DIAL_IN).PHP_EOL."\t".
                'same => n,ExecIf(${DIALPLAN_EXISTS(dialer-out-originate-check-inner-peer-state,${EXTEN},1)}?Gosub(dialer-out-originate-check-inner-peer-state,${EXTEN},1))'.PHP_EOL."\t".
                'same => n,Set(__orign_chan=${orign_chan})'.PHP_EOL."\t".
                'same => n,ExecIf($["${orign_chan}x" == "x"]?Set(__orign_chan=${CHANNEL}))'.PHP_EOL."\t".
                'same => n,ExecIf(${DIALPLAN_EXISTS(${DST_CONTEXT},${EXTEN},1)}?Dial(Local/${EXTEN}@${DST_CONTEXT},60,${TRANSFER_OPTIONS}KwWg))'.PHP_EOL."\t".
                $this->getAgiActionCmd(ConnectorDB::EVENT_END_DIAL_IN).PHP_EOL."\t".
                'same => n,Hangup()'.PHP_EOL.
            'exten => _[hit],1,Hangup() '.PHP_EOL.
            'exten => failed,1,NoOp( -- failed --)'.PHP_EOL."\t".
                $this->getAgiActionCmd(ConnectorDB::EVENT_FAIL_ORIGINATE).PHP_EOL."\t".
                'same => n,Hangup()'.PHP_EOL.PHP_EOL.
            '[dialer-out-originate-in-callback]' . PHP_EOL .
            'exten => check,1,Noop()' . PHP_EOL .
            '    same => n,GosubIf($["${DIALPLAN_EXISTS(dialer-callback-set-alert,${M_TASK_ID},1)}" == "1"]?dialer-callback-set-alert,${M_TASK_ID},1)' . PHP_EOL .
            '    same => n,ExecIf($["${CALLBACK_ALERT_FILE}x" == "x"]?return)' . PHP_EOL .
            '    same => n,Background(${CALLBACK_ALERT_FILE})' . PHP_EOL .
            '    same => n,WaitExten(6)' . PHP_EOL .
            '    same => n,Goto(${CONTEXT},cancel,1)' . PHP_EOL .
            'exten => _[0iet],1,Goto(${CONTEXT},cancel,1)' . PHP_EOL .
            'exten => 1,1,return' . PHP_EOL .
            'exten => cancel,1,Noop()' . PHP_EOL ."\t".
                $this->getAgiActionCmd(ConnectorDB::EVENT_USER_CANCEL_CALLBACK).PHP_EOL."\t".
            '    same => n,hangup'.PHP_EOL.PHP_EOL.
            '[dialer-out-originate-check-inner-peer-state]'.PHP_EOL.
            $conf.PHP_EOL.
            '[dialer-out-originate-set-bridge-peer]'.PHP_EOL."\t".
            'exten => '.ExtensionsConf::ALL_EXTENSION.',1,ExecIf($[ "${CHANNEL(channeltype)}" != "Local" ]?return)'.PHP_EOL."\t".
                'same => n,Wait(0.2))'.PHP_EOL."\t".
                'same => n,Set(pl=${IF($["${CHANNEL:-1}" == "1"]?2:1)})'.PHP_EOL."\t".
                'same => n,Set(bridgePeer=${IMPORT(${CUT(CHANNEL,\;,1)}\;${pl},DIALEDPEERNAME)})'.PHP_EOL."\t".
                'same => n,ExecIf($["${bridgePeer}x" == "x"]?Set(bridgePeer=${ORIGINATE_SRC_CHANNEL}))'.PHP_EOL."\t".
                'same => n,return'.PHP_EOL.
            'exten => _[hit],1,Hangup() '.PHP_EOL.PHP_EOL.
            '[dialer-out-originate-outgoing]'.PHP_EOL.
            'exten => '.ExtensionsConf::ALL_EXTENSION.',1,Set(__QUEUE_SRC_CHAN=${CHANNEL})'.PHP_EOL."\t". //
                'same => n,Set(__FROM_CHAN=${CHANNEL})'.PHP_EOL.
                'same => n,UserEvent(AutoDialer,dEvent: StartDial, OUT_NUMBER: ${M_OUT_NUMBER}, TASK_ID: ${M_TASK_ID})'.PHP_EOL.
                'same => n,Goto(${SRC_CONTEXT},${EXTEN},1)'.PHP_EOL.
            'exten => _[hit],1,Hangup() '.PHP_EOL.PHP_EOL.
            '[dialer-out-originate-in-hangup-handler]'.PHP_EOL.
            'exten => s,1,NoOp()'.PHP_EOL."\t".
                $this->getAgiActionCmd(ConnectorDB::EVENT_END_CALL).PHP_EOL."\t".
                'same => n,UserEvent(AutoDialer,dEvent: EndCall, OUT_NUMBER: ${M_OUT_NUMBER}, TASK_ID: ${M_TASK_ID}, DIAL_STATUS: ${M_DIALSTATUS})'.PHP_EOL.
                'same => n,Gosub(hangup_handler,${EXTEN},1)'.PHP_EOL.
                'same => n,return'.PHP_EOL.PHP_EOL.
            $this->genPollingContexts();
    }

    /**
     * Генерация контекстов для опроса.
     * @return string
     */
    private function genPollingContexts(): string
    {
        /** @var ModuleAutoDialer $settings */
        $settings = ModuleAutoDialer::findFirst();
        if(!$settings){
            return '';
        }
        if($settings->ttsService === ModuleAutoDialer::TTS_MODEL_YANDEX){
            $this->tts = new YandexSynthesize("$this->moduleDir/db/tts", $settings->yandexApiKey);
        }else{
            $this->tts = new RHVoiceSynthesize("$this->moduleDir/db/tts", $settings->yandexApiKey);
        }
        $conf = '['.self::CONTEXT_POLLING_NAME.']'.PHP_EOL;
        $questionContexts = [];
        /** @var Polling $polling */
        $polling = Polling::find();
        foreach ($polling as $pollingData){
            $conf.= "exten => $pollingData->id,1,Answer()".PHP_EOL;
            $conf.=  "\t"."same => n,Gosub(dial_answer,s,1)".PHP_EOL;
            $conf.=  "\t".$this->getAgiActionCmd(ConnectorDB::EVENT_POLLING).PHP_EOL;

            /** @var Question $question */
            $questions = Question::find("pollingId='$pollingData->id'");
            $firstQAdded = false;
            foreach ($questions as $question){
                $context = "dialer-polling-$pollingData->id-$question->crmId";
                if($firstQAdded === false){
                    $conf.= "\t".'same => n,Set(TIMEOUT(absolute)=120)'.PHP_EOL."\t";
                    $conf.= "same => n,Goto($context,s,1)".PHP_EOL;
                    $firstQAdded = true;
                }
                // Вопрос-подтверждение STT: AGI собирает распознанные тексты, генерирует TTS
                if ($question->type === Question::TYPE_CONFIRMATION) {
                    // Генерируем TTS для базового текста вопроса (questionText)
                    $baseFilename = '';
                    if (!empty($question->questionText)) {
                        $fullFilename = $this->tts->makeSpeechFromText($question->questionText, $question->lang);
                        if ($fullFilename && file_exists($fullFilename)) {
                            $baseFilename = Util::trimExtensionForFile($fullFilename);
                        }
                    }
                    $questionContexts[$context] = "exten => s,1,Set(M_FILENAME=$baseFilename)".PHP_EOL;
                    $questionContexts[$context].= "\t"."same => n,AGI($this->moduleDir/agi-bin/confirm-stt.php,$pollingData->id,$question->crmId,$question->lang)".PHP_EOL."\t";
                    // Если STT-результатов нет — AGI не меняет M_FILENAME, пропускаем на defPress
                    $skipTarget = ($question->defPress !== null && $question->defPress !== '') ? "dialer-polling-$pollingData->id-$question->defPress,s,1" : '';
                    if ($skipTarget !== '') {
                        $questionContexts[$context].= 'same => n,ExecIf($["${M_FILENAME}" == "'.$baseFilename.'"]?Goto('.$skipTarget.'))'.PHP_EOL."\t";
                    }
                    $questionContexts[$context].= 'same => n,Background(${M_FILENAME})'.PHP_EOL."\t";
                    $timeout = max((int)$question->timeout, 10);
                    $questionContexts[$context].= "same => n,WaitExten($timeout)".PHP_EOL;
                    $questionContexts[$context].= $this->genPolingActionsContexts($question->id, $question->crmId, $pollingData->id, $question->lang, (string)($question->defPress ?? ''));
                    continue;
                }
                if(empty($question->questionText) && empty($question->questionFile) && (!empty($question->defPress) || $question->defPress == "0") ){
                    $questionContexts[$context] = "exten => s,1,Goto($context,$question->defPress,1)".PHP_EOL."\t";
                    $questionContexts[$context].= $this->genPolingActionsContexts($question->id, $question->crmId, $pollingData->id, $question->lang, (string)($question->defPress ?? ''));
                    continue;
                }
                if($question->questionFile && file_exists($question->questionFile)){
                    $fullFilename = $question->questionFile;
                }else{
                    $fullFilename = $this->tts->makeSpeechFromText($question->questionText, $question->lang);
                }
                if(!$fullFilename || !file_exists($fullFilename)){
                    continue;
                }
                $filename = Util::trimExtensionForFile($fullFilename);
                $questionContexts[$context] = "exten => s,1,Set(M_FILENAME=$filename)".PHP_EOL;
                $questionContexts[$context].= "\t".'same => n,Set(RETRY_COUNTER=${IF($["${RETRY_COUNTER}x" != "x"]?${RETRY_COUNTER}:0)})'.PHP_EOL;
                $questionContexts[$context].= "\t".'same => n,Set(RETRY_COUNTER=$[${RETRY_COUNTER} + 1])'.PHP_EOL;
                $questionContexts[$context].= "\t".'same => n,ExecIf($[${RETRY_COUNTER} > 3]?AGI('."$this->moduleDir/agi-bin/change-state-task.php,".ConnectorDB::EVENT_END_CALL."))".PHP_EOL;
                $questionContexts[$context].= "\t".'same => n,ExecIf($[${RETRY_COUNTER} > 3]?Hangup())'.PHP_EOL."\t";
                $questionContexts[$context].= 'same => n,ExecIf($["${M_PARAMS}x" != "x"]?AGI('.$this->moduleDir."/agi-bin/gen-update-media-file.php))".PHP_EOL."\t";
                $questionContexts[$context].= 'same => n,Background(${M_FILENAME})'.PHP_EOL."\t";
                $questionContexts[$context].= "same => n,WaitExten($question->timeout)".PHP_EOL;
                $questionContexts[$context].= $this->genPolingActionsContexts($question->id, $question->crmId, $pollingData->id, $question->lang, (string)($question->defPress ?? ''));
            }
            $conf.= "\t"."same => n,Hangup()".PHP_EOL;
        }
        $conf.= PHP_EOL;
        foreach ($questionContexts as $contextName => $questionContext){
            $conf.= "[$contextName]".PHP_EOL;
            $conf.= $questionContext.PHP_EOL;
        }
        $fullFilename = $this->tts->makeSpeechFromText(''.$settings->callbackAlertText, $this->lang);
        if(!empty($fullFilename) && file_exists($fullFilename)){
            $conf.= '[dialer-callback-set-alert]' . PHP_EOL .
                'exten => '.ExtensionsConf::ALL_EXTENSION.',1,Set(CALLBACK_ALERT_FILE='.Util::trimExtensionForFile($fullFilename).')' . PHP_EOL .
                'exten => '.ExtensionsConf::ALL_EXTENSION.',2,return' . PHP_EOL;
        }
        return $conf;
    }

    /**
     * Обработка нажатий в контексте опроса.
     * @param $questionId
     * @param $pollingDataId
     * @param $lang
     * @return string
     */
    private function genPolingActionsContexts($questionId, $questionCrmId, $pollingDataId, $lang, string $defPress = ''):string
    {
        $conf = '';
        /** @var QuestionActions $actionData */
        $actions = QuestionActions::find("questionId='$questionId' AND pollingId='$pollingDataId'");
        foreach ($actions as $actionData){
            $conf.= "exten => $actionData->key,1,NoOp()".PHP_EOL."\t";
            if($actionData->action === QuestionActions::ACTION_ANSWER || $actionData->action === QuestionActions::ACTION_RESTART){
                $conf.= "same => n,AGI($this->moduleDir/agi-bin/saveResult.php,$pollingDataId,$questionCrmId,$actionData->value,\${EXTEN})".PHP_EOL."\t";
                $conf.= 'same => n,Set(TIMEOUT(absolute)=0)'.PHP_EOL."\t";
                // Сброс счётчика повторов при рестарте опроса
                if ($actionData->action === QuestionActions::ACTION_RESTART) {
                    $conf.= 'same => n,Set(RETRY_COUNTER=0)'.PHP_EOL."\t";
                }
            }elseif ($actionData->action === QuestionActions::ACTION_PLAYBACK_RECORD){
                $fullFilename = $this->tts->makeSpeechFromText($actionData->value??'', 'ru-RU');
                if(file_exists($fullFilename)){
                    $filename = Util::trimExtensionForFile($fullFilename);
                    $conf.= "same => n,Set(M_FILENAME=$filename)".PHP_EOL."\t";
                    $conf.= 'same => n,ExecIf($["${M_PARAMS}x" != "x"]?AGI('.$this->moduleDir."/agi-bin/gen-update-media-file.php))".PHP_EOL."\t";
                    $conf.= 'same => n,Playback(${M_FILENAME})'.PHP_EOL."\t";
                }
                // Установка переменных для STT-распознавания
                if ($actionData->needRecognize === '1') {
                    $conf.= "same => n,Set(M_NEED_RECOGNIZE=1)".PHP_EOL."\t";
                    $conf.= "same => n,Set(M_STT_LANG=$lang)".PHP_EOL."\t";
                    $recognizeLabel = str_replace('"', '', $actionData->recognizeLabel ?? '');
                    $conf.= "same => n,Set(M_RECOGNIZE_LABEL=$recognizeLabel)".PHP_EOL."\t";
                }
                $conf.= 'same => n,ExecIf($["${M_OUT_NUMBER}x" == "x"]?Set(M_OUT_NUMBER=${CALLERID(num)}))'.PHP_EOL."\t";

                $conf.= 'same => n,Set(MIX_FILENAME=${MONITOR_DIR}/polling/${STRFTIME(${EPOCH},,%Y/%m/%d)}/${CHANNEL(linkedid)}-${CONTEXT}-${exten}.wav)'.PHP_EOL."\t";
                $conf.= 'same => n,MixMonitor(${MIX_FILENAME},i(TMP_MONITOR_ID))'.PHP_EOL."\t";
                $conf.= 'same => n,Read(VALUE,,20,,1,'.$actionData->valueOptions.')'.PHP_EOL."\t";
                $conf.= 'same => n,StopMixMonitor(${TMP_MONITOR_ID})'.PHP_EOL."\t";
                $conf.= "same => n,AGI($this->moduleDir/agi-bin/saveResult.php,$pollingDataId,$questionCrmId,\${VALUE},\${MIX_FILENAME})".PHP_EOL."\t";
                $conf.= 'same => n,Set(TIMEOUT(absolute)=0)'.PHP_EOL."\t";
                // Сброс переменных STT после сохранения результата
                if ($actionData->needRecognize === '1') {
                    $conf.= "same => n,Set(M_NEED_RECOGNIZE=)".PHP_EOL."\t";
                    $conf.= "same => n,Set(M_RECOGNIZE_LABEL=)".PHP_EOL."\t";
                }

            }elseif ($actionData->action === QuestionActions::ACTION_PLAYBACK){
                $conf.= "same => n,AGI($this->moduleDir/agi-bin/saveResult.php,$pollingDataId,$questionCrmId,\${EXTEN},\${EXTEN})".PHP_EOL."\t";
                $conf.= 'same => n,Set(TIMEOUT(absolute)=0)'.PHP_EOL."\t";
                if($actionData->valueOptions === QuestionActions::ACTION_PLAYBACK_TEXT){
                    $fullFilename = $this->tts->makeSpeechFromText($actionData->value, $lang);
                }else{
                    $fullFilename = $actionData->value;
                }
                if($fullFilename && file_exists($fullFilename)){
                    $conf.= 'same => n,Playback('.Util::trimExtensionForFile($fullFilename).')'.PHP_EOL."\t";
                }else{
                    $conf.= 'same => n,NoOp(File not found)'.PHP_EOL."\t";
                }
            }elseif ($actionData->action === QuestionActions::ACTION_SEND_CRM){
                $conf.= "same => n,AGI($this->moduleDir/agi-bin/saveResult.php,$pollingDataId,$questionCrmId,\${EXTEN},\${EXTEN})".PHP_EOL."\t";
                $conf.= 'same => n,Set(TIMEOUT(absolute)=0)'.PHP_EOL."\t";
                // Сохраняем шаблон ответа в файл для передачи в AGI
                $tplFile = dirname(__DIR__) . '/db/tts/crm-tpl-' . md5($actionData->crmResponseTemplate) . '.txt';
                file_put_contents($tplFile, $actionData->crmResponseTemplate);
                $conf.= "same => n,AGI($this->moduleDir/agi-bin/send-crm.php,$pollingDataId,$tplFile)".PHP_EOL."\t";
                $conf.= 'same => n,ExecIf($["${M_CRM_RESPONSE_FILE}x" != "x"]?Playback(${M_CRM_RESPONSE_FILE}))'.PHP_EOL."\t";
                $conf.= $this->getAgiActionCmd(ConnectorDB::EVENT_POLLING_END).PHP_EOL."\t";
                $conf.= "same => n,Hangup()".PHP_EOL;
                continue;
            }elseif ($actionData->action === QuestionActions::ACTION_DIAL){
                $conf.= 'same => n,Set(pt1c_UNIQUEID=${UNDEFINED})'.PHP_EOL."\t";
                $conf.= 'same => n,Set(TIMEOUT(absolute)=0)'.PHP_EOL."\t";
                $conf.= "same => n,AGI($this->moduleDir/agi-bin/saveResult.php,$pollingDataId,$questionCrmId,$actionData->value,\${EXTEN})".PHP_EOL."\t";
                $conf.= $this->getAgiActionCmd(ConnectorDB::EVENT_POLLING_END).PHP_EOL."\t";
                $conf.= 'same => n,Dial(Local/'.$actionData->value.'@internal,,${TRANSFER_OPTIONS}KwW)'.PHP_EOL."\t";
                $conf.= "same => n,Hangup()".PHP_EOL;
                continue;
            }
            if($actionData->nextQuestion !== null && $actionData->nextQuestion !== ''){
                $conf.= "same => n,Goto(dialer-polling-$pollingDataId-$actionData->nextQuestion,s,1)".PHP_EOL."\t";
            }else{
                $conf.= $this->getAgiActionCmd(ConnectorDB::EVENT_POLLING_END).PHP_EOL."\t";
            }
            $conf.= "same => n,Hangup()".PHP_EOL;
        }
        $conf.= 'exten => e,1,Goto(${CONTEXT},s,1)'.PHP_EOL;
        if ($defPress !== '') {
            $conf.= "exten => t,1,Goto(dialer-polling-$pollingDataId-$defPress,s,1)".PHP_EOL;
        } else {
            $conf.= 'exten => t,1,Goto(${CONTEXT},s,1)'.PHP_EOL;
        }
        $conf.= 'exten => i,1,Goto(${CONTEXT},s,1)'.PHP_EOL;
        return $conf;
    }

    /**
     * Возвращает dialplan вызова agi change-state-task.php
     * @param $event
     * @return string
     */
    private function getAgiActionCmd($event):string
    {
        return "same => n,AGI(".$this->moduleDir."/agi-bin/change-state-task.php,$event)";
    }

    /**
     * Prepares additional parameters for each outgoing route context
     * after dial call in the extensions.conf file
     * @see https://docs.mikopbx.com/mikopbx-development/module-developement/module-class#generateoutroutafterdialcontext
     *
     * @param array $rout
     *
     * @return string
     */
    public function generateOutRoutAfterDialContext(array $rout): string
    {
        return  "\t".$this->getAgiActionCmd(ConnectorDB::EVENT_AFTER_DIAL_OUT).PHP_EOL.
                "\t".'same => n,ExecIf($["${M_TASK_ID}x" != "x"]?Gosub(hangup_chan,${EXTEN},1))';
    }

    /**
     * Returns module workers to start it at WorkerSafeScriptCore
     *
     * @return array
     */
    public function getModuleWorkers(): array
    {
        return [
            [
                'type'   => WorkerSafeScriptsCore::CHECK_BY_BEANSTALK,
                'worker' => ConnectorDB::class,
            ],
            [
                'type'   => WorkerSafeScriptsCore::CHECK_BY_AMI,
                'worker' => WorkerAMI::class,
            ],
            [
                'type'   => WorkerSafeScriptsCore::CHECK_BY_BEANSTALK,
                'worker' => WorkerDialer::class,
            ],
        ];
    }

    /**
     * REST API модуля.
     * @return array[]
     */
    public function getPBXCoreRESTAdditionalRoutes(): array
    {
        $taskUrl = '/pbxcore/api/module-dialer/v1/task/{id}';
        return [
            [ApiController::class, 'testAction','/pbxcore/api/module-dialer/v1/test', 'get', '/', false],
            [ApiController::class, 'postCrmTestAction','/pbxcore/api/module-dialer/v1/crm-test', 'post', '/', false],
            [ApiController::class, 'postClientAction','/pbxcore/api/module-dialer/v1/client', 'post', '/', false],
            [ApiController::class, 'uploadXlsAction','/pbxcore/api/module-dialer/v1/upload-xls', 'post', '/', false],
            [ApiController::class, 'deleteClientAction','/pbxcore/api/module-dialer/v1/client/{id}', 'delete', '/', false],
            [ApiController::class, 'getClientByPhoneAction','/pbxcore/api/module-dialer/v1/client-by-phone/{phone}', 'get', '/', false],

            [ApiController::class, 'postPollingAction','/pbxcore/api/module-dialer/v1/polling', 'post', '/', false],
            [ApiController::class, 'getPollingAction', '/pbxcore/api/module-dialer/v1/polling', 'get', '/', false],
            [ApiController::class, 'deletePollingByIdAction', '/pbxcore/api/module-dialer/v1/polling/{id}', 'delete', '/', false],
            [ApiController::class, 'getPollingByIdAction', '/pbxcore/api/module-dialer/v1/polling/{id}', 'get', '/', false],
            [ApiController::class, 'getTasksAction',   '/pbxcore/api/module-dialer/v1/task', 'get', '/', false],
            [ApiController::class, 'postTaskAction',   '/pbxcore/api/module-dialer/v1/task', 'post', '/', false],
            [ApiController::class, 'postTaskSignalAction',   '/pbxcore/api/module-dialer/v1/task-signal-close', 'post', '/', false],
            [ApiController::class, 'getTaskAction',    $taskUrl, 'get', '/', false],
            [ApiController::class, 'putTaskAction',    $taskUrl, 'put', '/', false],
            [ApiController::class, 'deleteTaskAction', $taskUrl, 'delete', '/', false],
            [ApiController::class, 'getResultsAction', '/pbxcore/api/module-dialer/v1/results/{changeTime}', 'get', '/', false],
            [ApiController::class, 'getResultsPollingAction', '/pbxcore/api/module-dialer/v1/polling-results/{changeTime}', 'get', '/', false],
            [ApiController::class, 'uploadAudio', '/pbxcore/api/module-dialer/v1/audio', 'post', '/', false],
            [ApiController::class, 'listAudioFiles', '/pbxcore/api/module-dialer/v1/audio', 'get', '/', false],
            [ApiController::class, 'deleteAudioFile', '/pbxcore/api/module-dialer/v1/audio/{name}', 'delete', '/', false],
        ];
    }

    /**
     * Process after disable action in web interface
     *
     * @return void
     */
    public function onAfterModuleDisable(): void
    {
        PBX::dialplanReload();
    }

    /**
     * Process after enable action in web interface
     *
     * @return void
     * @throws Exception
     */
    public function onAfterModuleEnable(): void
    {
        $cron = new CronConf();
        $cron->reStart();
        PBX::dialplanReload();
        $asteriskPath = Util::which('asterisk');
        $countMod = trim(shell_exec("$asteriskPath  -rx 'module show like $this->modName' | grep $this->modName | wc -l"));
        if($countMod === '0'){
            shell_exec("$asteriskPath -rx 'module load $this->modName'");
        }
    }

    /**
     * @param array $tasks
     */
    public function createCronTasks(&$tasks): void
    {
        $nicePath   = Util::which('nice');
        $findPath   = Util::which('find');
        $monDir     = dirname(__DIR__)."/db/tts-additional";
        $tasks[]    = "*/1 * * * * $nicePath -n 19 $findPath $monDir -type f -mtime +1 -delete; > /dev/null 2>&1\n";
        $phpPath    = Util::which('php');
        $tasks[]    = "*/1 * * * * $phpPath -f {$this->moduleDir}/bin/safe.php > /dev/null 2>&1\n";
    }
}