mikopbx/ModuleBitrix24Integration

Lib/Bitrix24Integration.php
1 997 строк81 KB
Alexey Portnov
per-leg finish: защита от пустого ARGS_REGISTER (дедуп register)
13 май 2026, 16:10
13 май 2026, 16:10dc895a1
<?php
/*
 * Copyright © MIKO LLC - All Rights Reserved
 * Unauthorized copying of this file, via any medium is strictly prohibited
 * Proprietary and confidential
 * Written by Alexey Portnov, 10 2020
 */

namespace Modules\ModuleBitrix24Integration\Lib;

use Modules\ModuleBitrix24Integration\bin\ConnectorDb;
use Modules\ModuleBitrix24Integration\Models\ModuleBitrix24Users;
use Phalcon\Mvc\Model\Manager;
use MikoPBX\Common\Models\CallQueues;
use MikoPBX\Common\Models\IncomingRoutingTable;
use MikoPBX\Common\Models\Extensions;
use MikoPBX\Modules\PbxExtensionBase;
use MikoPBX\PBXCoreREST\Lib\PBXApiResult;
use Modules\ModuleBitrix24Integration\Models\ModuleBitrix24Integration;
use MikoPBX\Core\System\Util;
use Modules\ModuleBitrix24Integration\Lib\Logger as MainLogger;
use Modules\ModuleBitrix24Integration\bin\WorkerBitrix24IntegrationHTTP;

class Bitrix24Integration extends PbxExtensionBase
{
    public const URI_OAUTH = 'https://oauth.bitrix.info/oauth/token/';

    public const API_LEAD_TYPE_ALL   = 'all';
    public const API_LEAD_TYPE_IN    = 'incoming';
    public const API_LEAD_TYPE_OUT   = 'outgoing';

    public const API_ATTACH_RECORD   = 'telephony.externalCall.attachRecord';
    public const API_CALL_FINISH     = 'telephony.externalcall.finish';
    public const API_CALL_HIDE       = 'telephony.externalcall.hide';
    public const API_CALL_SHOW       = 'telephony.externalcall.show';
    public const API_CALL_REGISTER   = 'telephony.externalcall.register';
    public const API_CRM_ADD_LEAD    = 'crm.lead.add';
    public const API_CRM_ADD_CONTACT = 'crm.contact.add';
    public const API_CRM_LIST_LEAD   = 'crm.lead.list';
    public const API_CRM_LIST_COMPANY= 'crm.company.list';
    public const API_CRM_COMPANY_CONTACT= 'crm.company.contact.items.get';
    public const API_CRM_CONTACT_COMPANY= 'crm.contact.company.items.get';
    public const API_CRM_LIST_CONTACT= 'crm.contact.list';

    public const OPEN_CARD_NONE      = 'NONE';
    public const OPEN_CARD_DIRECTLY  = 'DIRECTLY';
    public const OPEN_CARD_ANSWERED  = 'ANSWERED';

    public const B24_INTEGRATION_CHANNEL = 'b24_integration_channel';
    public const B24_SEARCH_CHANNEL      = 'b24_search_channel';
    public const B24_INVOKE_REST_CHANNEL = 'b24.invoke.channel';

    public array $b24Users = [];
    public array $inner_numbers = [];
    public array $mobile_numbers = [];
    private $SESSION;
    public array $usersSettingsB24 = [];
    private array $mem_cache;
    private string $refresh_token;
    private string $portal;
    public bool $initialized = false;
    private string $b24_region;
    private string $client_id;
    private string $client_secret;
    private string $queueExtension = '';
    private string $queueUid = '';
    private bool $backgroundUpload = false;
    public MainLogger $mainLogger;
    private bool $mainProcess = false;
    private int $updateTokenTime = 300;
    private int $authFailureCount = 0;
    public const AUTH_FAILURE_THRESHOLD = 5;

    public $lastContactId;
    public $lastCompanyId;
    public $lastLeadId;

    public function __construct(string $logPrefix = '')
    {
        parent::__construct();
        $this->portal = '';
        if(php_sapi_name() === "cli"){
            $this->mainProcess     = cli_get_process_title() === WorkerBitrix24IntegrationHTTP::class;
        }
        $this->mainLogger =  new MainLogger('HttpConnection'.$logPrefix, 'ModuleBitrix24Integration');
        $this->mem_cache = [];
        $data = ConnectorDb::invoke(ConnectorDb::FUNC_GET_GENERAL_SETTINGS);
        if (is_object($data) && !empty($data->logLevel)) {
            $this->mainLogger->setLevel($data->logLevel);
        }
        if ($data === null
            || empty($data->portal)
            || empty($data->b24_region)) {
            $this->mainLogger->writeError('Settings not set...');
            return;
        }

        $this->SESSION  = empty($data->session) ? null : json_decode($data->session, true);
        if(empty($data->refresh_token) && $this->SESSION ){
            $data->refresh_token = $this->SESSION['refresh_token']??'';
        }

        if(empty($data->refresh_token)){
            $this->mainLogger->writeError('refresh_token not set...');
            return;
        }

        $this->portal           = ''.$data->portal;
        $this->refresh_token    = ''.$data->refresh_token;
        $this->b24_region       = ''.$data->b24_region;
        $this->client_id        = ''.$data->client_id;
        $this->client_secret    = ''.$data->client_secret;
        $this->initialized      = true;
        if('_www' !== $logPrefix){
            // Это работа web интерфейса. Обновление настроек не требуется.
            $this->updateSettings($data);
        }
        unset($data);
    }

    public function setIsNotMainProcess():void
    {
        $this->mainProcess = false;
        $this->mainLogger =  new MainLogger('HttpConnection_SYNC', 'ModuleBitrix24Integration');
    }

    public function updateSettings($settings=null):void
    {
        if($settings === null){
            /** @var ModuleBitrix24Integration $settings */
            $settings = ConnectorDb::invoke(ConnectorDb::FUNC_GET_GENERAL_SETTINGS);
        }
        if($settings === null){
            return;
        }
        if (!empty($settings->logLevel)) {
            $this->mainLogger->setLevel($settings->logLevel);
        }
        $this->b24GetPhones();
        $this->lastLeadId    = $settings->lastLeadId;
        $this->lastCompanyId = $settings->lastCompanyId;
        $this->lastContactId = $settings->lastContactId;

        $this->usersSettingsB24 = $this->getUsersSettings();
        $this->backgroundUpload = intval($settings->backgroundUpload) === 1;
        $default_action = IncomingRoutingTable::findFirst('priority = 9999');
        if(!empty($settings->callbackQueue)){
            $filter =  [
                'conditions' => 'extension = :id: OR uniqid = :id:',
                'columns'    => ['extension,uniqid'],
                'bind'       => [
                    'id' => $settings->callbackQueue,
                ]
            ];
        }elseif ($default_action !== null) {
            $data        = $default_action->toArray();
            unset($default_action);
            $filter =  [
                'conditions' => 'extension = :extension:',
                'columns'    => ['extension,uniqid'],
                'bind'       => [
                    'extension' => $data['extension'],
                ]
            ];
        }
        if(!empty($filter)){
            $extData = CallQueues::findFirst($filter);
            if($extData){
                $this->queueExtension = $extData->extension;
                $this->queueUid       = $extData->uniqid;
            }
            unset($extData);
        }
    }

    /**
     * Возвращает массив номеров запрещенных к обработке.
     *
     * @return array
     */
    private function getUsersSettings(): array
    {
        $this->mainLogger->rotate();
        // Мы не можем использовать JOIN в разных базах данных
        $parameters            = [
            'conditions' => 'disabled <> 1',
            'columns'    => ['user_id,open_card_mode'],
        ];
        ConnectorDb::invoke(ConnectorDb::FUNC_GET_USERS, [$parameters]);
        $bitrix24UsersTmp = CacheManager::getCacheData(ModuleBitrix24Users::class);

        $uSettings = [];
        foreach ($bitrix24UsersTmp as $uData){
            $uSettings[$uData['user_id']] = $uData;
        }
        if(empty($uSettings)){
            $this->mainLogger->writeInfo($bitrix24UsersTmp, 'empty usersSettingsB24 getUsersSettings ret []');
            return [];
        }
        unset($bitrix24UsersTmp);
        $parameters = [
            'conditions' => 'is_general_user_number = 1 AND type = "SIP" AND userid IN ({ids:array})',
            'columns'    => ['number,userid'],
            'bind'       => [
                'ids' => array_keys($uSettings),
            ],
        ];
        $dbData = Extensions::find($parameters)->toArray();
        $settings = [];
        foreach ($dbData as $row){
            $settings[$row['number']] = $uSettings[$row['userid']];
        }
        return $settings;
    }

    /**
     * Получает данные из кэш и чистит его
     *
     * @param  $key
     *
     * @return array | false
     */
    public function getMemCache($key)
    {
        $data = $this->mem_cache[$key] ?? false;
        if ($data) {
            unset($this->mem_cache[$key]);
        }

        return $data;
    }

    /**
     *
     */
    public function checkNeedUpdateToken(): void
    {
        $s_refresh_token = $this->SESSION["refresh_token"] ?? '';
        $s_access_token  = $this->SESSION["access_token"] ?? '';
        $expires         = (int)($this->SESSION['expires']??0);

        if (empty($s_refresh_token) || empty($s_access_token)
            || ($expires - time()) < $this->updateTokenTime) {
            $this->SESSION = ['refresh_token' => $this->refresh_token];
            $this->updateToken();
        }
        // Обновим подписки на события.
        $this->eventsBind();
    }

    /**
     * Обновление / поддержание данных сессии. Коробочная версия.
     *
     * @param null $refresh_token
     *
     * @return bool
     */
    public function updateToken($refresh_token = null): bool
    {
        if(!$this->mainProcess && !$refresh_token){
            return $this->getTokenFromSettings();
        }
        if ($refresh_token) {
            $this->SESSION                  = [];
            $this->SESSION["refresh_token"] = $refresh_token;
        }
        if ( ! isset($this->SESSION["refresh_token"])) {
            return false;
        }

        return $this->authByCode($this->SESSION["refresh_token"], $this->b24_region, 'refresh_token');
    }

    /**
     * oAuth2 аутентификация по code.
     * @param string $code
     * @param string $region
     * @param string $grantType
     * @return bool
     */
    public function authByCode(string $code, string $region, string $grantType = 'authorization_code'): bool
    {
        $tokenKey = [
            'authorization_code' => 'code',
            'refresh_token' => 'refresh_token',
        ];
        $result = false;
        $oAuthToken = ModuleBitrix24Integration::getAvailableRegions()[$region];
        if(empty($oAuthToken['CLIENT_ID'])){
            $oAuthToken['CLIENT_ID']     = $this->client_id;
            $oAuthToken['CLIENT_SECRET'] = $this->client_secret;
        }
        $params     = [
            "grant_type"          => $grantType,
            "client_id"           => $oAuthToken['CLIENT_ID'],
            "client_secret"       => $oAuthToken['CLIENT_SECRET'],
            $tokenKey[$grantType]??'-' => $code,
        ];
        $query_data = $this->query(self::URI_OAUTH, $params);
        if( ($query_data['error']??'') === 'invalid_grant' ){
            // Не корректно выбран регион.
            $oAuthToken = ModuleBitrix24Integration::getAvailableRegions()['WORLD'];
            $params['client_id']     = $oAuthToken['CLIENT_ID'];
            $params['client_secret'] = $oAuthToken['CLIENT_SECRET'];
            $query_data = $this->query(self::URI_OAUTH, $params);
        }
        if (isset($query_data["access_token"])) {
            $result = true;
            $this->updateSessionData($query_data);
            if($grantType == 'authorization_code'){
                $ir = new Bitrix24InvokeRest();
                $ir->invoke('needRestart', []);
            }

            $this->mainLogger->writeInfo('The token has been successfully updated');
        }else{
            $this->mainLogger->writeError('Refresh token: response: '.json_encode($query_data).', params:'.json_encode($params));
        }
        return $result;
    }

    /**
     * Получение токен из настроек или кэш.
     * @return bool
     */
    private function getTokenFromSettings():bool
    {
        $result = false;
        usleep(500000);
        $session = CacheManager::getCacheData('access_token');
        if(!empty($session)){
            $this->SESSION = $session;
            $result = true;
            $this->mainLogger->writeInfo('Get token from cache: '.json_encode($session));
        }else{
            // Только mainProcess процесс может обновлять информацию по токену.
            // Тк кэш пуст, получаем из базы данных.
            $data = ConnectorDb::invoke(ConnectorDb::FUNC_GET_GENERAL_SETTINGS);
            if($data){
                $this->SESSION          = empty($data->session) ? null : json_decode($data->session, true);
                $result = true;
            }
            unset($data);
        }

        return $result;
    }

    /**
     * Совершает запрос с заданными данными по заданному адресу. В ответ ожидается JSON
     * @param string $url
     * @param array  $data
     * @param        $needBuildQuery
     * @return array
     */
    private function query(string $url, array $data, $needBuildQuery = true): array
    {
        if(($data['grant_type']??'') !== 'refresh_token'){
            $expires = (int)($this->SESSION['expires']??0);
            if($expires - time() < $this->updateTokenTime){
                // Запрос обновленного token.
                $this->updateToken();
            }
        }
        if (parse_url($url) === false) {
            return [];
        }
        $q4Dump                              = json_encode($data);
        $startTime                           = microtime(true);
        $curlOptions                         = [];
        $curlOptions[CURLOPT_POST]           = true;
        $curlOptions[CURLOPT_POSTFIELDS]     = ($needBuildQuery)?http_build_query($data):$data;
        $curlOptions[CURLOPT_RETURNTRANSFER] = true;
        $curlOptions[CURLOPT_TIMEOUT]        = 30;
        $curlOptions[CURLOPT_CONNECTTIMEOUT] = 10;

        $status          = 0;
        $headersResponse = '';

        $totalTime = 0;
        $response  = $this->execCurl($url, $curlOptions, $status, $headersResponse, $totalTime);

         if (is_array($response)) {
             $error_name = $response['error'] ?? '';
             if ('expired_token' === $error_name) {
                 $this->updateToken();
                 // Обновляем параметры запроса:
                 $data['auth']                    = $this->getAccessToken();
                 $curlOptions[CURLOPT_POSTFIELDS] = http_build_query($data);
                 // Передышка. Сохраняем требование к кол-ву запросов в секунду (2шт.)
                 usleep(500000);
                 // Отправляем запрос повторно:
                 $response = $this->execCurl($url, $curlOptions, $status, $headersResponse, $totalTime);
                 // Проверяем наличие ошибки:
                 $error_name = $response['error'] ?? '';
             } elseif (in_array($error_name,['wrong_client','NO_AUTH_FOUND'], true)) {
                 $this->mainLogger->writeError($response, 'Fail REST response');
                 $this->mainLogger->writeError($this->SESSION, "$error_name: session: ");
                 $this->authFailureCount++;
             } elseif ('QUERY_LIMIT_EXCEEDED' === $error_name) {
                 $this->mainLogger->writeInfo('Too many requests. Sleeping 1s ... ');
                 sleep(1);
                 $response   = $this->execCurl($url, $curlOptions, $status, $headersResponse, $totalTime);
                 $error_name = $response['error'] ?? '';
             }elseif(!empty($response['result_error'])){
                 $this->mainLogger->writeInfo($response['result_error'], "RESPONSE-ERROR");
             }

             if (!empty($error_name)) {
                $this->mainLogger->writeError($response, 'Fail REST response');
            }
        }
        if(isset($data['cmd']) && is_array($data['cmd'])){
            $queues = $data['cmd'];
            unset($queues['event.get'], $queues['event.offline.get']);
            foreach ($queues as $index => $queue){
                [$apiKey] = explode('_', $index);
                if(!in_array($apiKey, [self::API_CRM_LIST_LEAD, self::API_CRM_LIST_CONTACT, self::API_CRM_LIST_COMPANY], true)){
                    continue;
                }
                if(empty($response['result']["result"][$index])){
                    unset($queues[$index]);
                }
            }

            if(!empty($queues)){
                foreach ($queues as $index => $queue){
                    if (!is_string($queue)) {
                        continue;
                    }
                    $query = [];
                    parse_str(parse_url(rawurldecode($queue), PHP_URL_QUERY) ?? '', $query);
                    unset($query['auth']);
                    $queues[$index] = $query;
                }
                $this->mainLogger->writeInfo($queues, 'REQUEST');
                $result = $response['result']["result"]??[];
                // Чистый массив перед выводом в лог: события не нужны для отладки CRM-листингов.
                if(is_array($result)){
                    foreach (['event.get', 'event.offline.get'] as $key){
                        if(isset($result[$key])){
                            unset($result[$key]);
                        }
                    }
                }
                if(empty($result)){
                    $this->mainLogger->writeError($response, 'EMPTY RESPONSE[result][result]');
                } else {
                    // На INFO — только summary (count/total/next/первый ID),
                    // полный payload — только на DEBUG. Защита от OOM при крупных
                    // crm.lead.list / crm.contact.list / crm.company.list.
                    $summary = $this->buildBatchResponseSummary($response, $result);
                    $this->mainLogger->writeInfo($summary, 'RESPONSE');
                    $this->mainLogger->writeDebug($response, 'RESPONSE-FULL');
                }
            }
        }
        $this->checkErrorInResponse($response, $status);
        $delta = microtime(true) - $startTime;
        if ($delta > 5 || $totalTime > 5) {
            $this->mainLogger->writeError($response, "Slow response. PHP time:{$delta}s, cURL time: {$totalTime}, url:{$url}, Data:$q4Dump, Response: ");
        }

        $this->mainLogger->rotate();
        return $response;
    }

    /**
     * Краткая сводка по batch-ответу для INFO-лога. Цель — оставить
     * информацию, достаточную для диагностики (что вернулось, сколько,
     * есть ли next, был ли total), не выгружая весь массив записей в память.
     *
     * @param array $response — полный ответ Bitrix24
     * @param array $result   — $response['result']['result'] (уже без event.*)
     * @return array
     */
    private function buildBatchResponseSummary(array $response, array $result): array
    {
        $summary = [
            'http_total'       => $response['total'] ?? null,
            'time'             => $response['time']['duration'] ?? null,
            'result_total'     => $response['result']['result_total'] ?? null,
            'result_next'      => $response['result']['result_next'] ?? null,
            'result_error'     => $response['result']['result_error'] ?? null,
            'commands'         => [],
        ];
        foreach ($result as $cmdKey => $cmdResult) {
            $entry = ['count' => null, 'first_id' => null, 'last_id' => null];
            if (is_array($cmdResult)) {
                $entry['count'] = count($cmdResult);
                $first = reset($cmdResult);
                $last  = end($cmdResult);
                if (is_array($first) && isset($first['ID'])) {
                    $entry['first_id'] = $first['ID'];
                }
                if (is_array($last) && isset($last['ID'])) {
                    $entry['last_id'] = $last['ID'];
                }
            } else {
                $entry['value'] = $cmdResult;
            }
            $summary['commands'][$cmdKey] = $entry;
        }
        // Срезаем пустые поля, чтобы лог оставался читаемым.
        foreach (['http_total', 'time', 'result_total', 'result_next', 'result_error'] as $k) {
            if ($summary[$k] === null || $summary[$k] === [] || $summary[$k] === '') {
                unset($summary[$k]);
            }
        }
        return $summary;
    }

    private function checkErrorInResponse(&$response, $status)
    {
        if ( ! is_array($response)) {
            if ($status === 0) {
                usleep(500000);
                $key        = "http_query_status_{$status}";
                $cache_data = $this->getCache($key);
                if (empty($cache_data)) {
                    $this->mainLogger->writeError("Fail HTTP. Status: {$status}. Can not connect to host.");
                    $this->saveCache($key, '1', 60);
                }
            } else {
                $this->mainLogger->writeError("Fail HTTP. Status: {$status}. Response: $response");
            }
            $response = [];
        }

    }

    /**
     * Выполнить запрос HTTP через CURL
     *
     * @param     $url
     * @param     $curlOptions
     * @param     $status
     * @param     $headers
     * @param float $time
     *
     * @return mixed
     */
    private function execCurl($url, $curlOptions, &$status = 0, &$headers = '', float &$time = 0)
    {
        $curl = curl_init($url);
        curl_setopt_array($curl, $curlOptions);
        curl_setopt($curl, CURLOPT_HEADER, 1);

        $result      = curl_exec($curl);
        $header_size = curl_getinfo($curl, CURLINFO_HEADER_SIZE);
        $headers     = substr($result, 0, $header_size);
        $response    = trim(substr($result, $header_size));

        $status = (int)curl_getinfo($curl, CURLINFO_HTTP_CODE);
        $time   += (float)curl_getinfo($curl, CURLINFO_TOTAL_TIME);
        $data   = json_decode($response, true);
        if ( ! $data) {
            // Передаем ответ "КАК ЕСТЬ".
            $data = $response;
        }

        return $data;
    }

    /**
     * Возвращает значение access_token.
     *
     * @return string
     */
    public function getAccessToken(): string
    {
        return $this->SESSION['access_token'] ?? '';
    }

    public function getAuthFailureCount(): int
    {
        return $this->authFailureCount;
    }

    /** Возвращает данные из кэш.
     *
     * @param $cacheKey
     *
     * @return mixed|null
     */
    public function getCache($cacheKey)
    {
        $value = null;
        $data = CacheManager::getCacheData($cacheKey);
        if(!empty($data) && isset($data[0])){
            $value = $data[0];
        }
        return $value;
    }

    /**
     * Функции взаимодействия с API.
     */

    /**
     * Сохраняет даныне в кэш.
     *
     * @param string $cacheKey ключ
     * @param mixed  $resData  данные
     * @param int    $ttl      время жизни кеша
     */
    public function saveCache(string $cacheKey, $resData, int $ttl = 3600): void
    {
        CacheManager::setCacheData($cacheKey, [$resData], $ttl);
    }

    /**
     * Обновление данных сессии.
     *
     * @param $query_data
     */
    private function updateSessionData($query_data): void
    {
        $query_data["ts"] = time();
        $this->SESSION    = $query_data;
        $this->authFailureCount = 0;

        /** @var ModuleBitrix24Integration $data */
        $data = ConnectorDb::invoke(ConnectorDb::FUNC_GET_GENERAL_SETTINGS);
        if ($data === null) {
            return;
        }
        $data->session = json_encode($this->SESSION, JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES);
        ConnectorDb::invoke(ConnectorDb::FUNC_UPDATE_GENERAL_SETTINGS, [(array)$data], true, 10);
        CacheManager::setCacheData('access_token', $this->SESSION, 3600);
    }

    /**
     * Подписаться на события.
     *
     * @return bool
     */
    public function eventsBind(): bool
    {
        $eventResults = $this->eventGet();

        usleep(500000);
        $binds  = $eventResults['result']['result']['event.get'] ?? [];
        static $subscriptionsLogged = false;
        if (!$subscriptionsLogged) {
            $this->mainLogger->writeInfo(json_encode($binds, JSON_UNESCAPED_UNICODE), 'event.get subscriptions');
            $subscriptionsLogged = true;
        }
        $events = [];
        foreach ($binds as $bind) {
            $events[] = $bind['event'];
        }
        $arg = [];
        $eventsAll = [
            'OnExternalCallStart',
            'OnExternalCallBackStart',
            'onCrmLeadUpdate',
            'onCrmCompanyUpdate',
            'onCrmContactUpdate',
            'onCrmContactDelete',
            'onCrmCompanyDelete',
            'onCrmLeadDelete',
        ];
        foreach ($eventsAll as $event){
            if (!in_array(strtoupper($event), $events, true)) {
                $paramsCallBack                 = [
                    "event_type" => 'offline',
                    "event"      => $event,
                    "auth"       => $this->getAccessToken(),
                ];
                $arg[$event] = 'event.bind?' . http_build_query($paramsCallBack);
            }
        }
        if (!empty($arg)) {
            $this->mainLogger->writeInfo('Update event binding...');
            $arg      = array_merge($arg, $this->eventOfflineGet());
            $response = $this->sendBatch($arg);
            $result   = empty($response['result']['result_error']??[]);
        } else {
            $result = true;
        }

        return $result;
    }

    /**
     * Получение подписок на события.
     *
     * @return array
     */
    private function eventGet(): array
    {
        $params           = [
            "auth" => $this->getAccessToken(),
        ];
        $arg["event.get"] = 'event.get?' . http_build_query($params);

        return $this->sendBatch($arg);
    }

    /**
     * Отправка файла по ссылке в b24 POST запросом.
     * @param $targetUrl
     * @param $filename
     * @return array
     */
    public function uploadRecord($targetUrl, $filename): array
    {
        if (!file_exists($filename)) {
            return [];
        }
        $uploadFile = $filename;
        $tmpFile = '';
        $ext = strtolower(pathinfo($filename, PATHINFO_EXTENSION));
        if (!in_array($ext, ['mp3', 'wav'], true)) {
            $tmpFile = tempnam('/tmp', 'b24_') . '.mp3';
            $cmd = "ffmpeg -i " . escapeshellarg($filename) . " -y -codec:a libmp3lame -b:a 64k " . escapeshellarg($tmpFile) . " 2>&1";
            exec($cmd, $output, $retCode);
            if ($retCode === 0 && file_exists($tmpFile) && filesize($tmpFile) > 0) {
                $uploadFile = $tmpFile;
            } else {
                $this->mainLogger->writeError("ffmpeg convert failed ($retCode): " . implode("\n", $output));
                if ($tmpFile !== '' && file_exists($tmpFile)) {
                    unlink($tmpFile);
                }
                return [
                    'error' => 'ffmpeg_failed',
                    'error_description' => 'ffmpeg conversion failed, upload aborted',
                ];
            }
        }
        $post = ['file'=> curl_file_create($uploadFile)];
        $result = $this->query($targetUrl, $post, false);
        if ($tmpFile !== '' && file_exists($tmpFile)) {
            unlink($tmpFile);
        }
        return $result;
    }

    /**
     * Отправка пакета запросов. За раз не более 50ти.
     *
     * @param $cmd
     *
     * @return array
     */
    public function sendBatch($cmd): array
    {
        if (count($cmd) === 0) {
            return [];
        }
        $url    = "https://{$this->portal}/rest/batch";
        $params = [
            "auth" => $this->getAccessToken(),
            "halt" => 0,
            "cmd"  => $cmd,
        ];
        return $this->query($url, $params);
    }

    public function getCompanyContacts($id): array
    {
        $paramsCallBack = [
            "id" => $id,
            "auth"  => $this->getAccessToken(),
        ];
        $arg[Bitrix24Integration::API_CRM_COMPANY_CONTACT."_".$id] = Bitrix24Integration::API_CRM_COMPANY_CONTACT.'?' . http_build_query($paramsCallBack);
        return $arg;
    }

    public function getContactCompany($id): array
    {
        $paramsCallBack = [
            "id" => $id,
            "auth"  => $this->getAccessToken(),
        ];
        $arg[Bitrix24Integration::API_CRM_CONTACT_COMPANY."_".$id] = Bitrix24Integration::API_CRM_CONTACT_COMPANY.'?' . http_build_query($paramsCallBack);
        return $arg;
    }

    /**
     * Формирование команды для получения событий.
     *
     * @return mixed
     */
    public function eventOfflineGet()
    {
        $paramsCallBack           = [
            "limit" => '100',
            "auth"  => $this->getAccessToken(),
        ];
        $arg["event.offline.get"] = 'event.offline.get?' . http_build_query($paramsCallBack);

        return $arg;
    }

    /**
     * Модули: Выполнение к-либо действия.
     *
     * @param $req_data
     *
     * @return array
     */
    public function handleEvent($req_data): array
    {
        $result = [
            'result' => 'ERROR',
            'data'   => $req_data,
        ];
        $this->mainLogger->writeInfo($req_data);
        $event = $req_data['event']??[];
        if ('ONEXTERNALCALLSTART' === $req_data['event']['EVENT_NAME']) {
            $delta = time() - strtotime($event['TIMESTAMP_X']);
            if ($delta > 15) {
                $this->mainLogger->writeInfo(
                    "An outdated response was received {$delta}s: " . json_encode($event)
                );
            }
            $FROM_USER_ID = $req_data['data']['USER_ID'];
            $dst          = $req_data['data']['PHONE_NUMBER'];

            // Повторный вызов на тот же номер возможен только через N секунд.
            $cache_key = 'tmp5_' . __FUNCTION__ . "_{$FROM_USER_ID}_$dst";
            $res_data  = $this->getCache($cache_key);
            if ($res_data !== null) {
                $this->mainLogger->writeInfo("Repeated calls to the number $dst are possible in N seconds ");

                return $result;
            }
            $this->saveCache($cache_key, $res_data, 5);

            $phone_data = $this->b24GetPhones($FROM_USER_ID);
            if ( ! empty($phone_data['peer_number'])) {
                $data         = [
                    'CALL_ID'      => $req_data['data']['CALL_ID'],
                    'USER_ID'      => $req_data['data']['USER_ID'],
                    'PHONE_NUMBER' => $req_data['data']['PHONE_NUMBER'],
                ];
                $pre_call_key = "tmp5_{$phone_data['peer_number']}_" . self::getPhoneIndex($req_data['data']['PHONE_NUMBER']);
                $this->saveCache($pre_call_key, $data, 5);
                $PHONE_NUMBER = preg_replace("/[^0-9+]/", '', urldecode($req_data['data']['PHONE_NUMBER']));
                $data         = [
                    'CRM_ENTITY_TYPE' => $req_data['data']['CRM_ENTITY_TYPE'],
                    'CRM_ENTITY_ID'   => $req_data['data']['CRM_ENTITY_ID'],
                    'PHONE_NUMBER'    => $PHONE_NUMBER,
                ];
                $pre_call_key = "tmp5_ONEXTERNALCALLBACKSTART_" . self::getPhoneIndex($PHONE_NUMBER);
                $this->saveCache($pre_call_key, $data, 5);

                Util::amiOriginate($phone_data['peer_number'], '', $PHONE_NUMBER);
                $this->mainLogger->writeInfo("ONEXTERNALCALLSTART: originate from user {$FROM_USER_ID} <{$phone_data['peer_number']}> to $dst)");
            }else{
                $this->mainLogger->writeInfo('User: '.$FROM_USER_ID." - ".json_encode($req_data));
            }
        } elseif ('ONEXTERNALCALLBACKSTART' === $req_data['event']['EVENT_NAME']) {
            $PHONE_NUMBER = preg_replace("/[^0-9+]/", '', urldecode($req_data['data']['PHONE_NUMBER']));
            $data         = [
                'CRM_ENTITY_TYPE' => $req_data['data']['CRM_ENTITY_TYPE'],
                'CRM_ENTITY_ID'   => $req_data['data']['CRM_ENTITY_ID'],
                'PHONE_NUMBER'    => $PHONE_NUMBER,
            ];
            $pre_call_key = "tmp5_ONEXTERNALCALLBACKSTART_" . self::getPhoneIndex($PHONE_NUMBER);
            $this->saveCache($pre_call_key, $data, 5);

            if(empty($this->queueUid)){
                $this->mainLogger->writeInfo("ONEXTERNALCALLBACKSTART: default action for incoming rout is not queue)");
            }else{
                $channel        = "Local/{$this->queueExtension}@internal-originate";
                $variable       = "pt1c_cid={$PHONE_NUMBER},SRC_QUEUE={$this->queueUid}";
                $am       = Util::getAstManager('off');
                $am->Originate($channel, $PHONE_NUMBER, 'all_peers', '1', null, null, null, null, $variable, null, true);
                $this->mainLogger->writeInfo("ONEXTERNALCALLBACKSTART: originate from queue {$data['extension']} to {$PHONE_NUMBER})");
            }
        }

        return $result;
    }

    /**
     * Получение массива пользователей. Ключ массива - номер телефона пользователея.
     *
     * @param null $user_id
     *
     * @return array
     */
    public function b24GetPhones($user_id = null): array
    {
        $data       = [];
        $users_list = $this->userGet();

        if ( ! isset($users_list['result']) || ! is_array($users_list['result'])) {
            return $data;
        }
        if ($user_id) {
            foreach ($users_list['result'] as $value) {
                if ($value['ID'] === $user_id) {
                    $peer_number = preg_replace('/(\D)/', '', $value['UF_PHONE_INNER']??'');
                    $peer_mobile = preg_replace('/(\D)/', '', $value['PERSONAL_MOBILE']??'');

                    // Проверим, существуют ли номера в разрешенных.
                    /** @var Extensions $ext_data */
                    $ext_data    = Extensions::findFirst("number={$peer_number}");
                    $peer_number = $ext_data !== null ? $ext_data->number : '';

                    if ( ! empty($peer_mobile)) {
                        $p_key = self::getPhoneIndex($peer_mobile);
                        /** @var Extensions $exten_mobile */
                        $exten_mobile = Extensions::findFirst("number LIKE '%{$p_key}'");
                        $peer_mobile  = $exten_mobile !== null ? $exten_mobile->number : '';
                    }

                    // Подготавливаем ответ.
                    $data = [
                        'peer_mobile' => $peer_mobile,
                        'peer_number' => $peer_number,
                    ];
                    break;
                }
            }
        } else {
            // Сохраняем предыдущий снимок до полной перестройки:
            // если новый ответ user.get окажется пустым/некорректным,
            // безопасно восстановим состояние и не перетрем кеш.
            $prevInner  = $this->inner_numbers;
            $prevMobile = $this->mobile_numbers;
            $pbx_numbers = $this->getPbxNumbers();
            $this->inner_numbers  = [];
            $this->mobile_numbers = [];
            $this->b24Users = [];
            foreach ($users_list['result'] as $value) {
                $user                    = [];
                $user['NAME']            = '' . $value['NAME'] . ' ' . $value['LAST_NAME'];
                $user['ID']              = $value['ID'];
                $user['PERSONAL_MOBILE'] = preg_replace('/(\D)/', '', $value['PERSONAL_MOBILE']??'');
                $user['WORK_PHONE']      = preg_replace('/(\D)/', '', $value['WORK_PHONE']??'');
                $user['EMAIL']           = $value['EMAIL'] ?? '';
                $user['UF_PHONE_INNER']  = preg_replace('/(\D)/', '', $value['UF_PHONE_INNER']??'');

                // Не индексируем пользователей с пустым ключом: иначе все «безномерные»
                // (UF_PHONE_INNER/PERSONAL_MOBILE/WORK_PHONE пустой или нечисловой)
                // перезаписывают друг друга под ключом "" и любой звонок без
                // явного маппинга (например, на voicemail) будет приземляться
                // на «последнего созданного пользователя без UF_PHONE_INNER».
                if (!empty($user['PERSONAL_MOBILE'])) {
                    $mobile_key = self::getPhoneIndex($user['PERSONAL_MOBILE']);
                    if ($mobile_key !== '') {
                        $this->mobile_numbers[$mobile_key] = $user;
                    }
                }
                if (!empty($value['WORK_PHONE'])) {
                    $mobile_key = self::getPhoneIndex($user['WORK_PHONE']);
                    if ($mobile_key !== '') {
                        $this->mobile_numbers[$mobile_key] = $user;
                    }
                }
                if(isset($pbx_numbers[$user['UF_PHONE_INNER']])){
                    $mobile_key = self::getPhoneIndex($pbx_numbers[$user['UF_PHONE_INNER']]);
                    if ($mobile_key !== '') {
                        $this->mobile_numbers[$mobile_key] = $user;
                    }
                }
                if (!empty($user['UF_PHONE_INNER'])) {
                    $this->inner_numbers[$user['UF_PHONE_INNER']] = $user;
                }
                $this->b24Users[$value['ID']] = $user['UF_PHONE_INNER'];
            }

            $data = $this->mobile_numbers;

            // Защита от обнуления кеша при сбое user.get: если новый снимок
            // пустой, оставляем предыдущий. Без этого один неудачный запрос к
            // B24 «прячет» всех операторов на следующем 5-минутном тике AMI.
            if (empty($this->inner_numbers) && !empty($prevInner)) {
                $this->logger->writeError('b24GetPhones: empty inner_numbers built, restoring previous snapshot. prev_count=' . count($prevInner));
                $this->inner_numbers  = $prevInner;
                $this->mobile_numbers = $prevMobile;
                $data = $this->mobile_numbers;
                return $data;
            }

            // Лог диффа: какие внутренние номера пропали/появились между
            // снимками. Полезно для постфактум-разбора кейсов "оператора
            // временно не было в карте".
            $addedKeys   = array_diff(array_keys($this->inner_numbers), array_keys($prevInner));
            $removedKeys = array_diff(array_keys($prevInner), array_keys($this->inner_numbers));
            if (!empty($prevInner) && (!empty($addedKeys) || !empty($removedKeys))) {
                $added = [];
                foreach ($addedKeys as $k) {
                    $added[] = ['inner' => $k, 'id' => $this->inner_numbers[$k]['ID'] ?? '', 'name' => $this->inner_numbers[$k]['NAME'] ?? ''];
                }
                $removed = [];
                foreach ($removedKeys as $k) {
                    $removed[] = ['inner' => $k, 'id' => $prevInner[$k]['ID'] ?? '', 'name' => $prevInner[$k]['NAME'] ?? ''];
                }
                $this->logger->writeInfo(['added' => $added, 'removed' => $removed], 'inner_numbers_diff');
            }

            $this->saveCache('inner_numbers', $this->inner_numbers);
            $this->saveCache('mobile_numbers', $this->mobile_numbers);
            // Долгоживущий fallback (по аналогии с userGet_LONG).
            // Используется AMI-воркером, если основной кеш протух/пуст.
            $this->saveCache('inner_numbers_LONG',  $this->inner_numbers,  7 * 24 * 3600);
            $this->saveCache('mobile_numbers_LONG', $this->mobile_numbers, 7 * 24 * 3600);
        }

        return $data;
    }

    private function getPbxNumbers():array
    {
        $pbx_numbers = $this->getCache('pbx_numbers');

        if($pbx_numbers){
            return $pbx_numbers;
        }
        $pbx_numbers = [];
        /** @var Manager $manager */
        $manager = $this->di->get('modelsManager');
        $parameters = [
            'models'     => [
                'ExtensionsSip' => Extensions::class,
            ],
            'conditions' => 'ExtensionsSip.type = :typeSip:',
            'bind'                => ['typeSip' => Extensions::TYPE_SIP,'typeExternal' => Extensions::TYPE_EXTERNAL],
            'columns'    => [
                'number'         => 'ExtensionsSip.number',
                'mobile'         => 'ExtensionsExternal.number',
                'userid'         => 'ExtensionsSip.userid',
            ],
            'order'      => 'number',
            'joins'      => [
                'ExtensionsExternal' => [
                    0 => Extensions::class,
                    1 => 'ExtensionsSip.userid = ExtensionsExternal.userid AND ExtensionsExternal.type = :typeExternal:',
                    2 => 'ExtensionsExternal',
                    3 => 'INNER',
                ],
            ],
        ];
        $query  = $manager->createBuilder($parameters)->getQuery();
        $result = $query->execute()->toArray();
        foreach ($result as $data){
            $pbx_numbers[$data['number']] = $data['mobile'];
        }
        $this->saveCache('pbx_numbers', $pbx_numbers, 60);
        return $pbx_numbers;
    }

    /**
     * Получение списка пользователей.
     * @param bool $fromCache
     * @return array
     */
    public function userGet(bool $fromCache = false): array
    {
        // Пробуем получить кэшированные записи
        if($this->mainProcess === false){
            $res_data = max($this->getCache(__FUNCTION__."_LONG"), $this->getCache(__FUNCTION__));
        }else{
            $res_data = $this->getCache(__FUNCTION__);
        }
        if ($fromCache === false && $res_data === null && !empty($this->portal)) {
            // Кэш не пуст / истекло время жизни.
            $url      = 'https://' . $this->portal . '/rest/user.get';

            $next   = 0;
            $params = [
                'auth'  => $this->getAccessToken(),
                'start' => $next,
                'FILTER' => ['ACTIVE' => true]
            ];
            // Выполняем первичный запрос. В нем станет ясно количество сотрудников.
            $data  = $this->query($url, $params);
            $total = $data['total'] ?? 0;
            // В одну выборку попадают максимум 50 сотрудников.
            $next = $data['next'] ?? $total;
            $step = 0;
            if (isset($data['result'])) {
                $res_data[] = $data['result'];
                // Размер шага определяем размером первой выборки.
                $step = count($data['result']);
            }
            $arg = [];
            while ($next < $total) {
                // Пользователей больше 50ти, формируем пакетный запрос к b24.
                $arg["userGet_$next"] = 'user.get?' . http_build_query(["start" => (string)$next, 'FILTER' => ['ACTIVE' => true]]);
                $next                 += $step;
            }
            // Пакет запросов сформирован, отправляем.
            $response = $this->sendBatch($arg);
            foreach ($arg as $key => $value) {
                $res = $response['result']['result'][$key] ?? false;
                if ($res) {
                    // Собираем результат в массив.
                    $res_data[] = $res;
                }
            }
            // Сохраняем в кэше. Если ответ b24 пустой — НЕ перетираем
            // предыдущий снимок: иначе при разовом сбое user.get
            // (тайм-аут/невалидный токен) карты inner_numbers/mobile_numbers
            // на следующем тике b24GetPhones обнулятся, и AMI-воркер
            // перестанет распознавать операторов до следующего успеха.
            $userCount = 0;
            foreach ($res_data as $page) {
                if (is_array($page)) {
                    $userCount += count($page);
                }
            }
            if ($userCount > 0) {
                $this->saveCache(__FUNCTION__, $res_data, 90);
                $this->saveCache(__FUNCTION__."_LONG", $res_data, 7 * 24 * 3600);
            } else {
                $this->logger->writeError(
                    'userGet: empty result from user.get, keeping previous cache. response=' . json_encode($response['result']['result_error'] ?? $response['error'] ?? 'no_error_info')
                );
                // Возвращаем предыдущий снимок, чтобы вызывающий код
                // (b24GetPhones) не построил пустую карту inner_numbers.
                $fallback = $this->getCache(__FUNCTION__."_LONG");
                if (is_array($fallback) && !empty($fallback)) {
                    $res_data = $fallback;
                }
            }
        }elseif ($res_data === null ){
            $res_data = [];
        }

        if(!is_array($res_data)){
            $res_data = [];
        }

        if (count($res_data) > 1) {
            $res_data = array_merge(... $res_data);
        } elseif (count($res_data) === 1) {
            $res_data = $res_data[0]??[];
        }

        // Объединяем массивы данных в один и возвращаем результат.
        return ['result' => $res_data];
    }

    /**
     * Возвращает усеценный слева номер телефона.
     *
     * @param $number
     *
     * @return bool|string
     */
    public static function getPhoneIndex($number)
    {
        $number = preg_replace('/\D+/', '', $number);
        if(!is_numeric(str_replace('+', '', $number))){
            return $number;
        }
        return substr($number, -10);
    }

    /**
     * Интеграция с API телефонии.
     */

    /**
     * Синхронизация внешних линий.
     */
    public function syncExternalLines(): array
    {
        $external_lines_keys = [];
        $local_lines_keys    = [];
        $resp_data           = $this->getExternalLines();
        foreach ($resp_data as $line_data) {
            $external_lines_keys[] = $line_data['NUMBER'];
        }

        $arg = [];
        // Обход локальных данных внешних линий MIKOPX
        $db_data = ConnectorDb::invoke(ConnectorDb::FUNC_GET_EXTERNAL_LINES, []);
        foreach ($db_data as $line) {
            $local_lines_keys[] = $line['number'];
            if (in_array($line['number'], $external_lines_keys, true)) {
                continue;
            }
            // Номера нет в Б24, добавим его.
            $params                                = [
                'NUMBER' => $line['number'],
                'NAME'   => '' // $line['number']
            ];
            $arg[uniqid('externalLine.add', true)] = 'telephony.externalLine.add?' . http_build_query($params);
        }

        // Обход сохраненных в b24 внешних линий.
        foreach ($external_lines_keys as $line) {
            if (in_array($line, $local_lines_keys, true)) {
                continue;
            }
            $params = [
                'NUMBER' => $line,
                'NAME'   => '',
            ];
            // Ключа нет на MikoPBX. Удалим его из Б24
            $arg[uniqid('externalLine.add', true)] = 'telephony.externalLine.delete?' . http_build_query($params);
        }
        if (!empty($arg)) {
            $this->sendBatch($arg);
            usleep(500000);
        }

        return $db_data;
    }

    /**
     * @return array|mixed
     */
    protected function getExternalLines()
    {
        $key      = uniqid('externalLine.get', true);
        $arg      = [$key => 'telephony.externalLine.get'];
        $response = $this->sendBatch($arg);
        usleep(500000);

        return $response['result']['result'][$key] ?? [];
    }

    /**
     * Удаление всех внешних линий на портале.
     */
    public function deleteExternalLines(): void
    {
        $arg       = [];
        $resp_data = $this->getExternalLines();
        foreach ($resp_data as $line_data) {
            $params = [
                'NUMBER' => $line_data['NUMBER'],
            ];
            $arg[uniqid('externalLine.delete', true)] = 'telephony.externalLine.delete?' . http_build_query($params);
        }
        $this->sendBatch($arg);
    }

    /**
     * Получение информации правам доступа для приложения.
     *
     * @return PBXApiResult An object containing the result of the API call.
     */
    public function getScope(): PBXApiResult
    {
        $res            = new PBXApiResult();
        $res->processor = __METHOD__;
        $access_token   = $this->getAccessToken();
        if (empty($access_token)) {
            $res->messages[] = Util::translate('mod_b24_i_AuthError');

            return $res;
        }
        $res->success = true;
        $res_data     = $this->getCache(__FUNCTION__);
        if ($res_data === null || isset($res_data['error'])) {
            $params   = ["auth" => $access_token];
            $url      = "https://" . $this->portal . "/rest/scope";
            $res_data = $this->query($url, $params);
            $this->saveCache(__FUNCTION__, $res_data, 60);
        }

        if (is_array($res_data) && isset($res_data['error'])) {
            $res->messages = $res_data;
            $res->success  = false;
        } else {
            $res = $this->checkScope($res_data);
        }

        return $res;
    }

    /**
     * Скрыть карточку звонка для пользователя.
     *
     * @param string $tubeName
     *
     * @return array
     */
    public function getScopeAsync(string $tubeName=''): array
    {
        $params = [
            'auth'    => $this->getAccessToken(),
        ];
        $arg                   = [];
        $arg['scope'.'_'.uniqid('', true)."_$tubeName"] = 'scope?' . http_build_query($params);
        return $arg;
    }

    private function checkScope($res_data):PBXApiResult
    {
        $result  = $res_data['result'] ?? [];
        $res            = new PBXApiResult();
        $res->success   = true;
        $needles = [['user','user_basic'], 'telephony', 'crm'];
        foreach ($needles as $needle) {
            if(is_array($needle)){
                $found = false;
                foreach ($needle as $value){
                    if(in_array($value, $result, true)) {
                        $found = true;
                        break;
                    }
                }
                if($found !== false){
                    continue;
                }
            }elseif(in_array($needle, $result, true)) {
                continue;
            }
            $res->success    = false;
            $res->messages[] = Util::translate('mod_b24_i_CheckPermissions').' ' . implode(
                    ',',
                    $result
                );
            break;
        }
        return $res;
    }

    /**
     * Регистрация звонка на портале b24.
     *
     * @param array $options
     *
     * @return array
     */
    public function telephonyExternalCallRegister(array $options): array
    {
        // Сформируем кэш, чтобы исключить дублирующие события.
        $cache_key = "tmp180_call_register_{$options['USER_ID']}_" .
            strtotime($options['CALL_START_DATE']) . "_" .
            self::getPhoneIndex($options['PHONE_NUMBER']). "_" .
            self::getPhoneIndex($options['USER_PHONE_INNER']);

        $id = $options['linkedid']??'';
        $res_data = $this->getCache($cache_key);
        if ($res_data) {
            $this->mainLogger->writeInfo("Igonre $id 'telephonyExternalCallRegister' id dublicate...");
            return [[], ''];
        }
        // Сохраним кэш.
        $this->saveCache($cache_key, '1', 180);

        $show_card = '0';
        $userNumber = $this->b24Users[$options['USER_ID']]??'';
        if(empty($userNumber)){
            $userNumber = $options['USER_PHONE_INNER'];
        }
        $cardOpenSetting = $this->usersSettingsB24[$userNumber]['open_card_mode']??'';
        if ($cardOpenSetting === self::OPEN_CARD_DIRECTLY || $cardOpenSetting === '') {
            $show_card = '1';
        }
        $params = [
            'USER_PHONE_INNER' => '', // Внутренний номер пользователя
            'USER_ID'          => '', // Идентификатор пользователя
            'PHONE_NUMBER'     => '', // Номер телефона собеседника.
            'CALL_START_DATE'  => '', // Дата/время звонка в формате iso8601.
            'CRM_CREATE'       => '1',// Создавать или нет сущность CRMесли номер не найден
            'CRM_SOURCE'       => '', // STATUS_ID источника из справочника источников.
            'CRM_ENTITY_ID'    => '',
            'CRM_ENTITY_TYPE'  => '',
            'SHOW'             => $show_card,// [0/1] Показывать ли карточку звонка?
            'TYPE'             => '1', // 1 - исходящий 2 - входящий 3 - входящий с перенаправлением  4 - обратный
            'LINE_NUMBER'      => '',  // Номер внешней линии, через который совершался звонок
            'CALL_LIST_ID'     => '',  // Идентификатор списка обзвона, к которому должен быть привязан звонок.
            'auth'             => $this->getAccessToken(),
        ];

        $this->fillPropertyValues($options, $params);

        $arg       = [];
        $key       = self::API_CALL_REGISTER.'_'.$id . uniqid('', true);
        $arg[$key] = self::API_CALL_REGISTER.'?' . http_build_query($params);

        $options['time']       = time();
        $this->mem_cache[$key] = $options;

        return [$arg, $key];
    }

    /**
     * Запись в базу данных идентификаторов звонка.
     *
     * @param $key
     * @param $response
     */
    public function telephonyExternalCallPostRegister($key, $response): array
    {
        $request = $this->mem_cache[$key] ?? null;
        if ( ! $request) {
            return [];
        }
        unset($this->mem_cache[$key]);
        ConnectorDb::invoke(ConnectorDb::FUNC_UPDATE_CDR_BY_UID, [$request['UNIQUEID'], $request, $response]);

        return [$request['linkedid'], $response['CALL_ID']];
    }

    /**
     * @param       $options
     * @param array $params
     */
    protected function fillPropertyValues($options, array &$params): void
    {
        foreach ($options as $key => $value) {
            if (array_key_exists($key, $params)) {
                $params[$key] = $value;
            }
        }
        $del_keys = [];
        foreach ($params as $key => $value) {
            if ($value === '') {
                $del_keys[] = $key;
            }
        }
        foreach ($del_keys as $key) {
            // Не будем отправлять пустые данные.
            unset($params[$key]);
        }
    }

    /**
     * Готовит CALL_ID для batch-параметра. Если значение — ключ register-метода
     * (register ещё не выполнился, реального CALL_ID нет), оборачивает его в
     * $result[<key>][CALL_ID], чтобы Bitrix24 разрешил ссылку на результат
     * предыдущего вызова в этой же транзакции. Уже разрешённые/реальные значения
     * (externalCall.xxx или $result[...]) возвращаются без изменений.
     *
     * @param string $callId
     * @return string
     */
    public function resolveBatchCallId(string $callId): string
    {
        if ($callId === '') {
            return $callId;
        }
        if (stripos($callId, '$result[') === 0) {
            return $callId;
        }
        if (stripos($callId, self::API_CALL_REGISTER) === 0) {
            return '$result['.$callId.'][CALL_ID]';
        }
        return $callId;
    }

    /**
     * Регистрация факта завершения звонка в b24.
     * @param $options
     * @param $tmpCallsData
     *
     * @return array
     */
    public function telephonyExternalCallFinish($options, &$tmpCallsData): array
    {
        $arg     = [];
        $callId = '';
        $callDataFromDB = [];
        $finishKey = '';

        $result = ConnectorDb::invoke(ConnectorDb::FUNC_GET_CDR_BY_LINKED_ID, [$options]);
        if(!empty($result)){
            [$callDataFromDB, $callId] = $result;
        }
        $id = $options['linkedid'];
        if (empty($callId)) {
            $callId = $tmpCallsData[$id]['CALL_ID'] ?? '';
        }
        if (empty($callId)) {
            $this->mainLogger->writeInfo($options, "CALL_ID is empty, ConnectorDb and tmpCallsData have no data ($id)");
            return [$arg,$finishKey];
        }

        // 1) Дедуп ПЛЕЧА (UNIQUEID): блокирует повтор того же AMI-эвента (один и тот же leg).
        $legDedupKey = self::API_CALL_FINISH.'_leg_'.$options['UNIQUEID'];
        if($this->getCache($legDedupKey)){
            if ($options['export_records'] && !empty($options['FILE']) && ($this->backgroundUpload || file_exists($options['FILE']))) {
                $this->mainLogger->writeInfo($options, "Duplicate finish for leg, attaching record ($callId).");
                $this->telephonyExternalCallAttachRecord($options['FILE'], $callId, $arg);
            } else {
                $this->mainLogger->writeInfo($options, "Duplicate finish for leg, ignored ($callId).");
            }
            return [$arg,$finishKey];
        }
        $this->saveCache($legDedupKey, true, 30);

        // 2) Учитываем плечо в "best leg" (по DURATION). Best leg используется в
        // PostFinish для назначения ASSIGNED_BY_ID лида/контакта/сделки реальному
        // собеседнику, а не первому ответившему до перевода.
        $duration = isset($options['DURATION']) ? (int)$options['DURATION'] : 0;
        $userId   = isset($options['USER_ID'])  ? (string)$options['USER_ID']  : '';
        $this->updateBestLegForCall($id, $userId, $duration);

        ///////////////////////////////////////////////////////////////
        // 3) Подмена $callId через ARGS_REGISTER_<UNIQUEID> ДО дедупа finishOneKey.
        // Для второго (и далее) плеча HTTP-воркер уже отправил отдельный
        // telephony.externalcall.register (см. WorkerBitrix24IntegrationHTTP.php:609
        // ветка transfer: $tmpCallsData[...]['ARGS_REGISTER_'.$UNIQUEID]) — на каждое
        // плечо B24 возвращает СВОЙ CALL_ID. Без подмены ниже finishOneKey-дедуп
        // сравнивает оригинальный CALL_ID (первого плеча) и схлопывает все
        // последующие плечи в attachRecord (Bitrix24 хранит один файл на CALL_ID,
        // и записи плеч до перевода теряются, а в карточке звонка USER_ID остаётся
        // от первого ответившего). С per-leg CALL_ID в B24 на один MikoPBX-звонок
        // создаётся отдельная карточка звонка на каждое плечо: свой USER_ID, своя
        // запись, свой DURATION. Регрессия c0de8d3 (24.02.2026) отменена.
        $callData = &$tmpCallsData[$id];
        $regData  = $tmpCallsData[$id]['ARGS_REGISTER_'.$options['UNIQUEID']]??[];
        // file_exists || backgroundUpload — выравниваем с проверкой ниже в attachRecord:
        // при асинхронной загрузке (backgroundUpload=1) запись плеча ещё не лежит на
        // диске в момент finish, но UploaderB24 догрузит её позже. Без || backgroundUpload
        // блок не срабатывал бы, и второе плечо снова попадало бы в дедуп по первому
        // CALL_ID и теряло свою карточку.
        $fileReady = !empty($options['FILE']) && ($this->backgroundUpload || file_exists($options['FILE']));
        // Проверяем, что register не отдедупился: при повторе он возвращает [[],''] —
        // если подставить $key='' в "$result[][CALL_ID]", получится невалидная
        // batch-ссылка, и B24 отвергнет finish с "Call is not found". В таком случае
        // оставляем оригинальный $callId и проваливаемся в обычный дедуп-attachRecord
        // (поведение fallback, как до возврата per-leg).
        $hasFreshRegister = !empty($regData[1] ?? '');
        if( $fileReady &&
            isset($callData['MAIN_FILE']) && !isset($callData['FILE_'.$options['UNIQUEID']] ) &&
            $hasFreshRegister) {
            // Подключаем register этого плеча к нашему batch и берём из него CALL_ID.
            [$arg, $key] = $regData;
            $callId = '$result['.$key.'][CALL_ID]';
            $callData['FILE_'.$options['UNIQUEID']] = $options['FILE'];
        }
        if(!isset($callData['MAIN_FILE'])){
            $callData['MAIN_FILE'] = $options['FILE'];
        }

        // 4) Дедуп ЗВОНКА по подменённому CALL_ID. Для первого плеча — оригинальный
        // CALL_ID; для второго — новый (из ARGS_REGISTER), значит в кеше его нет,
        // и finish пройдёт в B24 как самостоятельный звонок.
        $finishOneKey = self::API_CALL_FINISH.'_'.$callId;
        if($this->getCache($finishOneKey)){
            if ($options['export_records'] && !empty($options['FILE']) && ($this->backgroundUpload || file_exists($options['FILE']))) {
                $this->mainLogger->writeInfo($options, "Finish already sent, attaching record ($callId).");
                $this->telephonyExternalCallAttachRecord($options['FILE'], $callId, $arg);
            } else {
                $this->mainLogger->writeInfo($options, "The challenge has already been finish earlier ($callId).");
            }
            return [$arg,$finishKey];
        }
        $this->saveCache($finishOneKey, true, 30);
        ///////////////////////////////////////////////////////////////
        $userId = (intval($callDataFromDB['answer']??0) === 1) ? $callDataFromDB['user_id']??'' : '';
        // Если register уйдёт в одном batch — finish должен ссылаться на его результат.
        $callId = $this->resolveBatchCallId((string)$callId);
        $params = [
            'CALL_ID'       => $callId,
            'USER_ID'       => $userId,
            'DURATION'      => '',
            'COST'          => '', // Стоимость звонка.
            'COST_CURRENCY' => '', // Валюта, в которой указана стоимость звонка.
            'STATUS_CODE'   => '', // SIP-код статуса звонка.
            'FAILED_REASON' => '', // Причина несостоявшегося звонка.
            'VOTE'          => '', // Оценка звонка пользователем (если АТС поддерживает функционал оценки разговора).
            'ADD_TO_CHAT'   => 0,
            'auth'          => $this->getAccessToken(),
        ];
        $this->fillPropertyValues($options, $params);

        $finishKey       = self::API_CALL_FINISH.'_'.$id.'_' . uniqid('', true);
        $arg[$finishKey] = self::API_CALL_FINISH.'?' . http_build_query($params);
        // linkedid плеча для PostFinish (понадобится для вычитки best leg из кеша).
        $this->mem_cache["$finishKey-leg"] = [
            'linkedid' => $id,
        ];
        if ($options['export_records']) {
            $this->telephonyExternalCallAttachRecord($options['FILE'], $callId, $arg);
        }

        if ($options['GLOBAL_STATUS'] === 'ANSWERED' && $options['disposition'] !== 'ANSWERED') {
            $this->mem_cache[$finishKey] = $callDataFromDB;
        }
        if ($options['GLOBAL_STATUS'] !== 'ANSWERED') {
            $this->mem_cache["$finishKey-missed"]   = $callDataFromDB;
        }
        if ($options['GLOBAL_STATUS'] === 'ANSWERED' && $options['disposition'] === 'ANSWERED') {
            $this->mem_cache["$finishKey-answered"] = $callDataFromDB;
        }
        $this->mainLogger->writeInfo($params, "Add finish req ($id)");
        return [$arg,$finishKey];
    }

    /**
     * Сохраняет плечо с максимальной длительностью для звонка (linkedid).
     * Используется в PostFinish, чтобы ASSIGNED_BY_ID назначался по реальному
     * собеседнику, завершившему разговор, а не по первому ответившему до перевода.
     */
    private function updateBestLegForCall(string $linkedId, string $userId, int $duration): void
    {
        if ($linkedId === '' || $userId === '') {
            return;
        }
        $key  = self::API_CALL_FINISH.'-best-leg-'.$linkedId;
        $best = $this->getCache($key);
        if (!is_array($best) || $duration > (int)($best['duration'] ?? -1)) {
            $this->saveCache($key, ['user_id' => $userId, 'duration' => $duration], 300);
        }
    }

    /**
     * Возвращает USER_ID плеча с максимальной длительностью для звонка.
     */
    private function getBestLegUserId(string $linkedId): string
    {
        if ($linkedId === '') {
            return '';
        }
        $best = $this->getCache(self::API_CALL_FINISH.'-best-leg-'.$linkedId);
        return is_array($best) ? (string)($best['user_id'] ?? '') : '';
    }

    /**
     * Обработка действий после получения ответа на telephonyExternalCallFinish.
     * @param string $finishKey
     * @param array  $response
     * @param array  $queryArray
     */
    public function telephonyExternalCallPostFinish(string $finishKey, array $response, array &$queryArray): void{
        $cache_data = $this->getMemCache($finishKey);
        $activityId = $response['CRM_ACTIVITY_ID']??'';
        if($cache_data && !empty($activityId)){
            // Постановка задачи на удаление activity.
            $queryArray[] = $this->crmActivityDelete($activityId);
        }
        $cacheData = $this->getMemCache("$finishKey-answered");
        if($cacheData === null){
            $cacheData = $this->getMemCache("$finishKey-missed");
        }
        $id = str_replace(self::API_CALL_FINISH, '', $finishKey);

        // ASSIGNED_BY_ID назначаем по "лучшему" плечу (с максимальной DURATION) звонка,
        // если оно известно. Это важно при переводе: B24 принимает только первый finish
        // (на CALL_ID), и его USER_ID может оказаться не тем, кто реально завершил
        // разговор. Подменяем PORTAL_USER_ID лучшим из всех собранных плеч.
        $legMeta      = $this->getMemCache("$finishKey-leg");
        $linkedId     = is_array($legMeta) ? (string)($legMeta['linkedid'] ?? '') : '';
        $bestUserId   = $this->getBestLegUserId($linkedId);
        $portalUserId = (string)($response['PORTAL_USER_ID'] ?? '');
        $assignTo     = ($bestUserId !== '') ? $bestUserId : $portalUserId;

        if(isset($cacheData['contact_id'])){
            $queryArray[] = $this->crmContactUpdate($cacheData['contact_id'], $assignTo, $id);
        }
        if(isset($cacheData['deal_id'])){
            $queryArray[] = $this->crmDealUpdate($cacheData['deal_id'], $assignTo, $id);
        }
        if(isset($cacheData['lead_id'])){
            $queryArray[] = $this->crmLeadUpdate($cacheData['lead_id'], $assignTo, $id);
        }
    }

    /**
     * Обновление пользователя для Lead,
     * @param string $id
     * @param string $newUserId
     * @param string $linkedId
     * @return array
     */
    public function crmDealUpdate(string $id, string $newUserId, string $linkedId = ''): array
    {
        $params = [
            'id'   => $id,
            'fields' => [
                'ASSIGNED_BY_ID' => $newUserId
            ],
            'auth' => $this->getAccessToken(),
            'params' => [
                'REGISTER_SONET_EVENT' => 'N'
            ]
        ];
        $arg = [];
        $arg['crm.deal.update_'.$linkedId.'_' . uniqid('', true)] = 'crm.deal.update?' . http_build_query($params);
        return $arg;
    }

    /**
     * Обновление пользователя для Lead,
     * @param string $phone
     * @param string $id
     * @param string $user
     * @param string $did
     * @return array
     */
    public function crmAddLead(string $phone, string $id = '', string  $user = '', string $did = ''): array
    {
        $params = [
            'fields' => [
                'TITLE' => "$phone - Входящий звонок | $did",
                'OPENED' => "Y",
                "STATUS_ID" => "NEW",
                "ASSIGNED_BY_ID" => $user,
                "PHONE"=> [ [ "VALUE"=> $phone, "VALUE_TYPE"=> "WORK" ] ]
            ],
            'auth' => $this->getAccessToken(),
            'params' => [
                'REGISTER_SONET_EVENT' => 'N'
            ]
        ];
        $arg = [];
        if(empty($id)){
            $id = self::API_CRM_ADD_LEAD.'_' . uniqid('', true);
        }else{
            $id = self::API_CRM_ADD_LEAD.'_' . $id;
        }
        $arg[$id] = self::API_CRM_ADD_LEAD.'?' . http_build_query($params);
        return $arg;
    }

    /**
     * Запрос синхронизации справочников.
     * @param string $type
     * @param array $arIds
     * @return array
     */
    public function crmListEnt(string $type, array $arIds = []): array
    {
        $id = '0';
        $select = [ "ID", "ASSIGNED_BY_ID", "PHONE"];
        if(self::API_CRM_LIST_CONTACT === $type){
            $id = $this->lastContactId;
            $select = [ "ID", "NAME", "LAST_NAME", "SECOND_NAME", "COMPANY_ID",  "ASSIGNED_BY_ID", "PHONE", "LEAD_ID", "DATE_CREATE", "DATE_MODIFY"];
        }elseif (self::API_CRM_LIST_COMPANY === $type){
            $id = $this->lastCompanyId;
            $select = [ "ID", "TITLE",  "ASSIGNED_BY_ID", "PHONE", "LEAD_ID", "DATE_CREATE", "DATE_MODIFY"];
        }elseif (self::API_CRM_LIST_LEAD === $type){
            $id = $this->lastLeadId;
            $select = [ "ID", "TITLE",  "ASSIGNED_BY_ID", "PHONE", "CONTACT_ID", "COMPANY_ID", "STATUS_ID", "STATUS_SEMANTIC_ID", "DATE_CREATE", "DATE_MODIFY"];
        }
        if(empty($arIds)){
            $filter = ['>ID' => $id];
            $keyId = $type . '_init';
        }else{
            $filter = ['ID' => $arIds];
            $keyId = $type . '_update_'.uniqid('', true);
        }
        $type = strtolower($type);
        $params = [
            'order'  => ["ID" =>  "ASC"],
            'filter' => $filter,
            'start'  => '-1',
            'select' => $select,
            'auth'   => $this->getAccessToken(),
        ];
        $arg = [];
        $arg[$keyId] = $type.'?' . http_build_query($params);
        return $arg;
    }

    /**
     * Сохранение данных контактов.
     * @param $action
     * @param $keyId
     * @param $data
     * @param bool $waitSave
     * @return void
     */
    public function crmListEntResults($action, $keyId, $data, bool $waitSave = true):void
    {
        if(empty($data)){
            return;
        }
        $chunks = array_chunk($data, 3);
        foreach ($chunks as $chunk) {
            $settings = ConnectorDb::invoke(ConnectorDb::FUNC_UPDATE_ENT_CONTACT, [$action, $chunk], $waitSave);
            usleep(100000);
        }
        if($waitSave === false || $keyId === 'update' || empty($settings)){
            return;
        }
        $settings = (object)$settings;
        $this->lastContactId = empty($settings->lastContactId)?"0":$settings->lastContactId;
        $this->lastCompanyId = empty($settings->lastCompanyId)?"0":$settings->lastCompanyId;
        $this->lastLeadId    = empty($settings->lastLeadId)?"0":$settings->lastLeadId;
    }

    /**
     * Обновление пользователя для Lead,
     * @param string $id
     * @param string $newUserId
     * @param string $linkedId
     * @return array
     */
    public function crmContactUpdate(string $id, string $newUserId, string $linkedId = ''): array
    {
        $params = [
            'id'   => $id,
            'fields' => [
                'ASSIGNED_BY_ID' => $newUserId,
            ],
            'auth' => $this->getAccessToken(),
            'params' => [
                'REGISTER_SONET_EVENT' => 'N'
            ]
        ];
        $arg = [];
        $arg['crm.contact.update_'.$linkedId . '_' . uniqid('', true)] = 'crm.contact.update?' . http_build_query($params);
        return $arg;
    }

    /**
     * Обновление пользователя для Lead,
     * @param string $id
     * @param string $newUserId
     * @param string $linkedId
     * @return array
     */
    public function crmLeadUpdate(string $id, string $newUserId, string $linkedId = ''): array
    {
        $params = [
            'id'   => $id,
            'fields' => [
                'ASSIGNED_BY_ID' => $newUserId
            ],
            'auth' => $this->getAccessToken(),
            'params' => [
                'REGISTER_SONET_EVENT' => 'N'
            ]
        ];

        $arg                                        = [];
        $arg['crm.lead.update_'.$linkedId.'_'. uniqid('', true)] = 'crm.lead.update?' . http_build_query($params);

        return $arg;
    }

    /**
     * Обновление дела звонка,
     * @param string $id
     * @param string $linkedId
     * @param string $description
     * @return array
     */
    public function crmActivityUpdate(string $id, string $linkedId, string $description): array
    {
        $params = [
            'id'   => $id,
            'fields' => [
                'DESCRIPTION' => $description
            ],
            'auth' => $this->getAccessToken(),
        ];
        $arg = [];
        $arg['crm.activity.update_'.$linkedId.'_'. uniqid('', true)] = 'crm.activity.update?' . http_build_query($params);
        return $arg;
    }

    /**
     * Обработка ответа запроса загрузки файла.
     * @param $key
     * @param $uploadUrl
     * @return array
     */
    public function telephonyPostAttachRecord($key, $uploadUrl): array
    {
        $data = $this->getMemCache($key);
        if(empty($uploadUrl) || empty($data)){
            return [];
        }
        $data['uploadUrl'] = $uploadUrl;
        return $data;
    }

    /**
     * Прикрепление записи разговора к звонку в b24.
     * @param $filename
     * @param $callId
     * @param $arg
     * @return void
     */
    private function telephonyExternalCallAttachRecord($filename, $callId, &$arg): void
    {
        if (empty($filename)) {
            return;
        }
        // При фоновой загрузке файл может ещё не существовать (race condition с Asterisk),
        // но он не нужен сейчас — UploaderB24 загрузит позже с задержкой 30с.
        if (!$this->backgroundUpload && !file_exists($filename)) {
            return;
        }
        $FILENAME     = basename($filename);
        $ext = strtolower(pathinfo($FILENAME, PATHINFO_EXTENSION));
        if (!in_array($ext, ['mp3', 'wav'], true)) {
            $FILENAME = pathinfo($FILENAME, PATHINFO_FILENAME) . '.mp3';
        }
        $callId = $this->resolveBatchCallId((string)$callId);
        $params = [
            'CALL_ID'      => $callId,
            'FILENAME'     => $FILENAME,
            'auth'         => $this->getAccessToken(),
        ];
        if(!$this->backgroundUpload){
            $uploadFile = $filename;
            if (!in_array($ext, ['mp3', 'wav'], true)) {
                $tmpFile = tempnam('/tmp', 'b24_') . '.mp3';
                $cmd = "ffmpeg -i " . escapeshellarg($filename) . " -y -codec:a libmp3lame -b:a 64k " . escapeshellarg($tmpFile) . " 2>&1";
                exec($cmd, $output, $retCode);
                if ($retCode === 0 && file_exists($tmpFile) && filesize($tmpFile) > 0) {
                    $uploadFile = $tmpFile;
                } else {
                    $this->mainLogger->writeError("ffmpeg convert failed ($retCode): " . implode("\n", $output));
                }
            }
            $params['FILE_CONTENT'] = base64_encode(file_get_contents($uploadFile));
            if (isset($tmpFile) && $tmpFile !== '' && file_exists($tmpFile)) {
                unlink($tmpFile);
            }
        }
        $cmd = self::API_ATTACH_RECORD.'?'.http_build_query($params);
        $key = self::API_ATTACH_RECORD.'_'.uniqid('', true);
        $arg[$key] = $cmd;
        $this->mem_cache[$key] = [
            'CALL_ID'      => $callId,
            'FILENAME'     => $filename,
        ];
    }

    /**
     * Скрыть карточку звонка для пользователя.
     *
     * @param $options
     *
     * @return array
     */
    public function telephonyExternalCallHide($options): array
    {
        $params = [
            'CALL_ID' => '',
            'USER_ID' => '',
            'auth'    => $this->getAccessToken(),
        ];
        $this->fillPropertyValues($options, $params);
        $params['CALL_ID'] = $this->resolveBatchCallId((string)$params['CALL_ID']);

        $arg                   = [];
        $arg[self::API_CALL_HIDE.'_'.$options['linkedid'].'_'.uniqid('', true)] = self::API_CALL_HIDE.'?' . http_build_query($params);

        return $arg;
    }

    /**
     * Показать карточку звонка для пользователя.
     *
     * @param $options
     *
     * @return array
     */
    public function telephonyExternalCallShow($options): array
    {
        $params = [
            'CALL_ID' => '',
            'USER_ID' => '',
            'auth'    => $this->getAccessToken(),
        ];
        $this->fillPropertyValues($options, $params);
        $params['CALL_ID'] = $this->resolveBatchCallId((string)$params['CALL_ID']);

        $arg                   = [];
        $arg[self::API_CALL_SHOW.$options['linkedid'].'_'.uniqid('', true)] = self::API_CALL_SHOW.'?' . http_build_query($params);

        return $arg;
    }

    /**
     * Удаление Дела по ID
     *
     * @param      $id
     *
     * @return array
     */
    public function crmActivityDelete($id): array
    {
        $params = [
            'ID'   => $id,
            'auth' => $this->getAccessToken(),
        ];

        $arg                                        = [];
        $arg['activity.delete_' . uniqid('', true)] = 'crm.activity.delete?' . http_build_query($params);

        return $arg;
    }

    /**
     */
    public function startAllServices(): void
    {
        // Сервисы будут запущены по cron в течение минуты.
    }

    public function testUpdateToken($token):void
    {
        $this->updateToken($token);
    }
}