diff --git a/App/Controllers/ModuleBitrix24IntegrationController.php b/App/Controllers/ModuleBitrix24IntegrationController.php
index 6672897..a8e311c 100644
--- a/App/Controllers/ModuleBitrix24IntegrationController.php
+++ b/App/Controllers/ModuleBitrix24IntegrationController.php
@@ -202,6 +202,9 @@ public function indexAction(): void
         }
 
         $this->view->form = new ModuleBitrix24IntegrationForm($settings, $options);
+        // Опция импорта МТС доступна только если установлен соседний модуль ModuleMtsPbx.
+        // Используем FQCN-строку: при `use ...` PHP попытается зарезолвить класс ещё до class_exists.
+        $this->view->isMtsModuleInstalled = class_exists('\\Modules\\ModuleMtsPbx\\Models\\CallHistory');
         $this->view->pick("{$this->moduleDir}/App/Views/index");
     }
 
@@ -323,6 +326,12 @@ public function saveAction(): void
                 case 'lastCompanyId':
                 case 'lastLeadId':
                 case 'lastDealId':
+                case 'mts_import_last_id':
+                    // Служебные/системные поля, не отображаются в форме.
+                    // НЕ трогаем — без break-ветки default обнулил бы их
+                    // на каждом сохранении настроек ('' → INTEGER → 0).
+                    // Для mts_import_last_id это бы сбрасывало прогресс
+                    // MTS-импорта в 0 при каждом сохранении через UI.
                     break;
                 case 'callbackQueue':
                     $record->$key = trim($data[$key]);
@@ -338,6 +347,11 @@ public function saveAction(): void
                 case 'crmCreateLead':
                 case 'backgroundUpload':
                 case 'export_records':
+                case 'import_mts_calls':
+                    // Checkbox-поля: HTML отправляет 'on' если установлен,
+                    // не отправляет вовсе если снят. Раньше import_mts_calls
+                    // попадал в default → $record->key = 'on' → SQLite-affinity
+                    // INTEGER приводил к 0, и галка никогда не сохранялась как 1.
                     if (array_key_exists($key, $data)) {
                         $record->$key = ($data[$key] === 'on') ? '1' : '0';
                     } else {
@@ -366,12 +380,13 @@ public function saveAction(): void
             return;
         }
         $externalLinesPost = json_decode($data['externalLines'],true);
-        $resultSaveLines   = ConnectorDb::invokePriority(ConnectorDb::FUNC_SAVE_EXTERNAL_LINES, [$externalLinesPost]);
-        if(!$resultSaveLines){
-            $this->view->error = 'Fail save externalLines...';
-            $this->view->success = false;
-            return;
-        }
+        // Результат saveExternalLinesData(bool) теряется при RPC-сериализации:
+        // unpackResult всегда возвращает array, json_decode(true|false) → bool
+        // → is_array(bool) === false → возврат `[]`. Старая проверка
+        // `if(!$resultSaveLines)` ложно срабатывала на каждом сохранении,
+        // показывая «Fail save externalLines...» даже при успешной записи.
+        // Полагаемся на лог ConnectorDb для диагностики реальных ошибок.
+        ConnectorDb::invokePriority(ConnectorDb::FUNC_SAVE_EXTERNAL_LINES, [$externalLinesPost]);
         $this->flash->success($this->translation->_('ms_SuccessfulSaved'));
         $this->view->success = true;
     }
diff --git a/App/Forms/ModuleBitrix24IntegrationForm.php b/App/Forms/ModuleBitrix24IntegrationForm.php
index cadd787..e3c2dd1 100644
--- a/App/Forms/ModuleBitrix24IntegrationForm.php
+++ b/App/Forms/ModuleBitrix24IntegrationForm.php
@@ -46,6 +46,7 @@ public function initialize($entity = null, $options = null): void
         $this->addCheckBox('backgroundUpload', intval($entity->backgroundUpload) === 1);
         $this->addCheckBox('export_records', intval($entity->export_records) === 1);
         $this->addCheckBox('use_interception', intval($entity->use_interception) === 1);
+        $this->addCheckBox('import_mts_calls', intval($entity->import_mts_calls) === 1);
 
         // Numeric
         $this->add(new Numeric('interception_call_duration'));
@@ -99,6 +100,17 @@ public function initialize($entity = null, $options = null): void
                                   'useEmpty' => false,
                                   'class'    => 'ui selection dropdown b24_regions-select',
                               ]));
+
+        $logLevels = [];
+        foreach (ModuleBitrix24Integration::getAvailableLogLevels() as $level) {
+            $logLevels[$level] = $this->translation->_('mod_b24_i_logLevel_' . $level);
+        }
+        $this->add(new Select('logLevel', $logLevels, [
+            'using'    => ['id', 'name'],
+            'value'    => empty($entity->logLevel) ? ModuleBitrix24Integration::LOG_LEVEL_INFO : $entity->logLevel,
+            'useEmpty' => false,
+            'class'    => 'ui selection dropdown',
+        ]));
     }
     /**
      * Adds a checkbox to the form field with the given name.
diff --git a/App/Views/index.volt b/App/Views/index.volt
index 6350470..a8ffe49 100644
--- a/App/Views/index.volt
+++ b/App/Views/index.volt
@@ -34,6 +34,19 @@
                 <label>{{ t._('mod_b24_i_backgroundUpload') }}</label>
             </div>
         </div>
+        {% if isMtsModuleInstalled %}
+        <div class="field">
+            <div class="ui toggle checkbox">
+                {{ form.render('import_mts_calls') }}
+                <label>{{ t._('mod_b24_i_ImportMtsCalls') }}</label>
+            </div>
+        </div>
+        {% endif %}
+        <div class="ten wide field">
+            <label>{{ t._('mod_b24_i_logLevel') }}</label>
+            {{ form.render('logLevel') }}
+            <div class="ui small text">{{ t._('mod_b24_i_logLevelHint') }}</div>
+        </div>
         <div class="ui divider"></div>
         <div class="field">
             <button class="ui basic button disability" id="sync-links-button" type="button">
diff --git a/CLAUDE.md b/CLAUDE.md
index 0229b0f..0e39d5a 100644
--- a/CLAUDE.md
+++ b/CLAUDE.md
@@ -105,7 +105,56 @@ GET /pbxcore/api/bitrix-integration/workers/state (без авторизации
 - `telephony.externalcall.show` — отдельный вызов для открытия карточки остальным участникам очереди
 - `open_card_mode`: `DIRECTLY` (сразу), `ANSWERED` (при ответе), `NONE` (никогда) — настройка per-user в `ModuleBitrix24Users`
 
+### Register policy: one register per call
+
+`addDataToQueue` (HTTP-воркер): первый `telephonyExternalCallRegister` для `linkedid` → реальный `telephony.externalcall.register` в B24 (создаёт CALL_ID). Последующие события того же linkedid:
+- очередь (нет маркера `b24-answered-<linkedid>`) → `telephony.externalcall.show` на оригинальном CALL_ID;
+- перевод (маркер стоит) → новый register, кладётся в `ARGS_REGISTER_<UNIQUEID>` и уходит только при finish'е этого плеча (per-leg CALL_ID).
+
+При отладке: «много register» в `IntegrationAMI.log` ≠ много REST-запросов в B24. Считать REST по REQUEST'ам в `HttpConnection.log`.
+
+### Two sources of "internal number → user" mapping
+
+- **`inner_numbers`** — карта B24 user.get (`UF_PHONE_INNER` → `{ID, NAME, EMAIL, ...}`). Источник USER_ID для register/finish/show/hide. Обновляется `b24GetPhones` раз в 5 мин на ping AMI. Защита от полного обнуления есть, от частичного пропуска сотрудника — нет (см. `inner_numbers_diff` в `Bitrix24Integration.log`).
+- **`usersSettingsB24`** — таблица модуля (`ModuleBitrix24Users`): `inner_phone` → `{user_id: MikoPBX-id, open_card_mode}`. Источник режима открытия карточки.
+- Расхождение возможно: модуль знает номер (есть в `usersSettingsB24`), а в B24 этому номеру не присвоен `UF_PHONE_INNER`/`PERSONAL_MOBILE`/`WORK_PHONE` → `inner_numbers[$num]` пуст → USER_ID="" в register. AMI-воркер `actionCreateCdr` фильтрует такие плечи: `Skip register` (`WorkerBitrix24IntegrationAMI.php:518`). В `addDataToQueue` есть зеркальная страховка: `show` не отправляется с пустым USER_ID.
+
+### Orphan-leg фильтр в HTTP-воркере
+
+Для входящих звонков AMI-воркер шлёт `telephonyExternalCallFinish` на каждое CDR-плечо. Плечи, не дошедшие до оператора (IVR/queue), помечаются `USER_ID=responsibleMissedCalls`, `GLOBAL_STATUS=NOANSWER`. Эти эвенты могут опередить ANSWERED-finish реального оператора и переписать статус звонка на «пропущен».
+
+HTTP-воркер фильтрует их: при `action_dial_answer` ставит маркер `b24-answered-<linkedid>` в Redis (TTL 3 ч, через `CacheManager`/`b24->saveCache` — переживает рестарт воркера). При обработке `telephonyExternalCallFinish` с `GLOBAL_STATUS!=ANSWERED`, если маркер стоит — эвент пропускается. Полностью пропущенные звонки (никто не ответил) идут штатно — маркера нет.
+
+## MTS Historical Import
+
+Опциональный импорт CDR из соседнего модуля `ModuleMtsPbx` (таблица `mts_cdr`). Cron `bin/MtsImporter.php` каждые 5 минут читает `Modules\ModuleMtsPbx\Models\CallHistory` через ORM (без HTTP к соседу), шлёт пачки по 10 звонков через `Bitrix24InvokeRest::invoke('importHistoricalCalls', ...)`. HTTP-воркер кладёт `register+finish` в общую `q_req` — звонки уходят обычным batch'ем как AMI-эвенты.
+
+Почему mts_cdr, а не общая `cdr_general` (cdr.db): cdr_general — большая Asterisk-таблица без индекса на `from_account`, на крупных инсталляциях первичный скан медленный. `mts_cdr` — узкая таблица соседнего модуля, заполняемая `ModuleMtsPbx/bin/synchCdr.php` через MTS API, содержит только fs-mts звонки и MTS-API метаданные (включая `mts_rec_status` для отслеживания скачивания MP3).
+
+- Опция: `import_mts_calls` в `ModuleBitrix24Integration` (галка в админке, видна только при установленном ModuleMtsPbx).
+- Курсор: `mts_import_last_id` (в той же таблице, добавлен в `$syncKeys` в `Bitrix24IntegrationConf::modelsEventChangeData` — иначе апдейты курсора триггерили бы `onAfterModuleEnable`).
+- Pending-логика: `mts_rec_status='pending'` означает, что MP3 ещё скачивается ModuleMtsPbx (`downloadRecords.php`). Cron не двигает курсор через такую запись, ждёт следующего тика.
+- ACK-протокол invoke: `IMPORT_ACK_OK` / `IMPORT_ACK_NOT_READY` (если карты сотрудников `b24->inner_numbers`/`mobile_numbers` пусты после рестарта). Cron при `not_ready` не двигает курсор.
+- Защита от повторного запуска: `flock(LOCK_EX|LOCK_NB)` на `tmp/.../mts_importer.lock`.
+- Dedup: `ConnectorDb::FUNC_GET_EXPORTED_CALL_ID` — строгий поиск по `linkedid` в `b24_cdr_data` с непустым `call_id` (без leg-семантики `getCdrDataByLinkedId`).
+
+Модель `Modules\ModuleMtsPbx\Models\CallHistory` доступна через PSR-4 (соседний модуль регистрирует свой namespace). НО при отсутствии модуля любое `use` приведёт к fatal — используем только FQCN-строки + `class_exists($fqcn)` перед обращением.
+
+## Worker initialization patterns
+
+**AMI-воркер: listener регистрируется ДО тяжёлого init.** `WorkerSafeScriptsCore::checkWorkerAMI` (core MikoPBX) шлёт ping через AMI UserEvent. После `MAX_PING_FAILURES` промахов подряд — SIGUSR1 → воркер крашится → safe.php стартует заново. Окно типично 15 секунд. `new Bitrix24Integration('_ami')` делает синхронный REST к B24 и может занимать дольше, поэтому `setFilter()` и `addEventHandler('userevent', [$this, 'callback'])` нужно вызвать **сразу после `createAstManager()`**, до тяжёлого init. `replyOnPingRequest` (WorkerBase) зависит только от `$this->am`, поэтому отвечать на ping можно без `$b24`. `callback()` использует `$this->processState === 'init'` как маркер «не готов» — пока state='init', события (кроме pong) игнорируются.
+
+## ConnectorDb::invoke contract
+
+`ConnectorDb::invoke(FUNC_GET_GENERAL_SETTINGS)` возвращает гетерогенное значение:
+- cache-hit → `stdClass` (через `(object)$cached`)
+- cache-miss + RPC success → `stdClass`
+- cache-miss + RPC fail/timeout → `[]` (пустой массив)
+- DB-empty (модель отсутствует) → может быть `false` (Phalcon 3/4)
+
+Проверять: `is_object($settings) && !empty($settings->portal)` — это и есть инвариант «настройки готовы». Обращаться к полям через `->`, **не** через `[...]`.
+
 ## Logs
 
-Логи воркеров: `ConnectorDb.log`, `HttpConnection.log`, `HttpConnection_SYNC.log`, `IntegrationAMI.log`.
+Логи воркеров: `ConnectorDb.log`, `HttpConnection.log`, `HttpConnection_SYNC.log`, `IntegrationAMI.log`, `Bitrix24Integration.log` (сюда пишется `inner_numbers_diff` — added/removed между снимками b24GetPhones).
 Формат: `[ISO8601][level] message(pid): JSON`. Для анализа звонка — искать по `linkedid` во всех логах.
diff --git a/Lib/Bitrix24Integration.php b/Lib/Bitrix24Integration.php
index 04df39b..4d956a5 100644
--- a/Lib/Bitrix24Integration.php
+++ b/Lib/Bitrix24Integration.php
@@ -85,6 +85,9 @@ public function __construct(string $logPrefix = '')
         $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)) {
@@ -130,6 +133,9 @@ public function updateSettings($settings=null):void
         if($settings === null){
             return;
         }
+        if (!empty($settings->logLevel)) {
+            $this->mainLogger->setLevel($settings->logLevel);
+        }
         $this->b24GetPhones();
         $this->lastLeadId    = $settings->lastLeadId;
         $this->lastCompanyId = $settings->lastCompanyId;
@@ -429,7 +435,7 @@ private function query(string $url, array $data, $needBuildQuery = true): array
                 }
                 $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])){
@@ -439,8 +445,13 @@ private function query(string $url, array $data, $needBuildQuery = true): array
                 }
                 if(empty($result)){
                     $this->mainLogger->writeError($response, 'EMPTY RESPONSE[result][result]');
-                }else{
-                    $this->mainLogger->writeInfo($response, 'RESPONSE');
+                } 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');
                 }
             }
         }
@@ -454,6 +465,51 @@ private function query(string $url, array $data, $needBuildQuery = true): array
         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)) {
@@ -862,6 +918,11 @@ public function b24GetPhones($user_id = null): array
                 }
             }
         } else {
+            // Сохраняем предыдущий снимок до полной перестройки:
+            // если новый ответ user.get окажется пустым/некорректным,
+            // безопасно восстановим состояние и не перетрем кеш.
+            $prevInner  = $this->inner_numbers;
+            $prevMobile = $this->mobile_numbers;
             $pbx_numbers = $this->getPbxNumbers();
             $this->inner_numbers  = [];
             $this->mobile_numbers = [];
@@ -875,26 +936,71 @@ public function b24GetPhones($user_id = null): array
                 $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']);
-                    $this->mobile_numbers[$mobile_key] = $user;
+                    $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']);
-                    $this->mobile_numbers[$mobile_key] = $user;
+                    $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']]);
-                    $this->mobile_numbers[$mobile_key] = $user;
+                    $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->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;
@@ -989,9 +1095,31 @@ public function userGet(bool $fromCache = false): array
                     $res_data[] = $res;
                 }
             }
-            // Сохраняем в кэше
-            $this->saveCache(__FUNCTION__, $res_data, 90);
-            $this->saveCache(__FUNCTION__."_LONG", $res_data);
+            // Сохраняем в кэше. Если ответ 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 = [];
         }
@@ -1291,6 +1419,30 @@ protected function fillPropertyValues($options, array &$params): void
         }
     }
 
+    /**
+     * Готовит 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
@@ -1318,38 +1470,82 @@ public function telephonyExternalCallFinish($options, &$tmpCallsData): array
             return [$arg,$finishKey];
         }
 
-        // Проверка дедупликации по оригинальному callId (до ARGS_REGISTER)
-        $finishOneKey = self::API_CALL_FINISH.'_'.$callId;
-        if($this->getCache($finishOneKey)){
-            // Finish уже отправлен, но если есть запись — прикрепим её
+        // 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, "Finish already sent, attaching record ($callId).");
+                $this->mainLogger->writeInfo($options, "Duplicate finish for leg, attaching record ($callId).");
                 $this->telephonyExternalCallAttachRecord($options['FILE'], $callId, $arg);
             } else {
-                $this->mainLogger->writeInfo($options, "The challenge has already been finish earlier ($callId).");
+                $this->mainLogger->writeInfo($options, "Duplicate finish for leg, ignored ($callId).");
             }
             return [$arg,$finishKey];
         }
-        $this->saveCache($finishOneKey, true, 30);
+        $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']]??[];
-        if( file_exists($options['FILE']) &&
+        $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']] ) &&
-            !empty($regData)) {
-            // Нужно зарегистрировать новый вызов
-            [$arg, $key] = $tmpCallsData[$id]['ARGS_REGISTER_'.$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,
@@ -1366,6 +1562,10 @@ public function telephonyExternalCallFinish($options, &$tmpCallsData): array
 
         $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);
         }
@@ -1383,6 +1583,35 @@ public function telephonyExternalCallFinish($options, &$tmpCallsData): array
         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
@@ -1402,14 +1631,24 @@ public function telephonyExternalCallPostFinish(string $finishKey, array $respon
         }
         $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'], $response['PORTAL_USER_ID'], $id);
+            $queryArray[] = $this->crmContactUpdate($cacheData['contact_id'], $assignTo, $id);
         }
         if(isset($cacheData['deal_id'])){
-            $queryArray[] = $this->crmDealUpdate($cacheData['deal_id'], $response['PORTAL_USER_ID'], $id);
+            $queryArray[] = $this->crmDealUpdate($cacheData['deal_id'], $assignTo, $id);
         }
         if(isset($cacheData['lead_id'])){
-            $queryArray[] = $this->crmLeadUpdate($cacheData['lead_id'], $response['PORTAL_USER_ID'], $id);
+            $queryArray[] = $this->crmLeadUpdate($cacheData['lead_id'], $assignTo, $id);
         }
     }
 
@@ -1646,6 +1885,7 @@ private function telephonyExternalCallAttachRecord($filename, $callId, &$arg): v
         if (!in_array($ext, ['mp3', 'wav'], true)) {
             $FILENAME = pathinfo($FILENAME, PATHINFO_FILENAME) . '.mp3';
         }
+        $callId = $this->resolveBatchCallId((string)$callId);
         $params = [
             'CALL_ID'      => $callId,
             'FILENAME'     => $FILENAME,
@@ -1692,6 +1932,7 @@ public function telephonyExternalCallHide($options): array
             '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);
@@ -1714,6 +1955,7 @@ public function telephonyExternalCallShow($options): array
             '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);
diff --git a/Lib/Bitrix24IntegrationConf.php b/Lib/Bitrix24IntegrationConf.php
index 5f2c83a..d6cf6de 100644
--- a/Lib/Bitrix24IntegrationConf.php
+++ b/Lib/Bitrix24IntegrationConf.php
@@ -56,7 +56,7 @@ public function modelsEventChangeData($data): void
     {
         if ($data['model'] === ModuleBitrix24Integration::class) {
             $changedFields = count($data['changedFields']);
-            $syncKeys = ['lastLeadId', 'lastCompanyId', 'lastContactId', 'lastDealId', 'session'];
+            $syncKeys = ['lastLeadId', 'lastCompanyId', 'lastContactId', 'lastDealId', 'session', 'mts_import_last_id'];
             if ($changedFields === 1 && in_array($data['changedFields'][0],$syncKeys, true)) {
                 return;
             }
@@ -250,5 +250,6 @@ public function createCronTasks(array &$tasks): void
 
         $phpPath   = Util::which('php');
         $tasks[]    = "*/1 * * * * $phpPath -f {$this->moduleDir}/bin/safe.php > /dev/null 2>&1".PHP_EOL;
+        $tasks[]    = "*/5 * * * * $phpPath -f {$this->moduleDir}/bin/MtsImporter.php > /dev/null 2>&1".PHP_EOL;
     }
 }
\ No newline at end of file
diff --git a/Lib/Logger.php b/Lib/Logger.php
index 07f7db6..08b0677 100644
--- a/Lib/Logger.php
+++ b/Lib/Logger.php
@@ -31,7 +31,24 @@
 
 class Logger
 {
-    public bool $debug;
+    public const LEVEL_NONE  = 0;
+    public const LEVEL_ERROR = 1;
+    public const LEVEL_INFO  = 2;
+    public const LEVEL_DEBUG = 3;
+
+    /**
+     * Безопасный максимум для одной записи в лог. Большие данные обрезаются,
+     * чтобы json_encode не съел всю PHP-память (по умолчанию memory_limit = 128M).
+     */
+    private const MAX_PAYLOAD_BYTES = 512 * 1024;
+
+    /**
+     * Совместимость с прежним кодом, где встречается обращение к публичному
+     * полю $debug. Теперь оно отражает: "уровень ≥ INFO".
+     */
+    public bool $debug = true;
+
+    private int $level = self::LEVEL_INFO;
     private $logger;
     private string $module_name;
     private string $logFile;
@@ -46,7 +63,6 @@ class Logger
     public function __construct(string $class, string $module_name)
     {
         $this->module_name = $module_name;
-        $this->debug = true;
         $logPath = Directories::getDir(Directories::CORE_LOGS_DIR) . '/' . $this->module_name . '/';
         if (!file_exists($logPath)) {
             Util::mwMkdir($logPath);
@@ -56,6 +72,42 @@ public function __construct(string $class, string $module_name)
         $this->initLogger();
     }
 
+    /**
+     * Преобразует строковое имя уровня (NONE/ERROR/INFO/DEBUG) во внутренний int.
+     */
+    public static function resolveLevel(?string $name): int
+    {
+        switch (strtoupper((string)$name)) {
+            case 'NONE':  return self::LEVEL_NONE;
+            case 'ERROR': return self::LEVEL_ERROR;
+            case 'DEBUG': return self::LEVEL_DEBUG;
+            case 'INFO':
+            default:      return self::LEVEL_INFO;
+        }
+    }
+
+    /**
+     * Установить уровень логирования. Принимает строку (NONE/ERROR/INFO/DEBUG)
+     * или int-константу LEVEL_*.
+     *
+     * @param int|string $level
+     */
+    public function setLevel($level): void
+    {
+        $this->level = is_int($level) ? $level : self::resolveLevel($level);
+        $this->debug = $this->level >= self::LEVEL_INFO;
+    }
+
+    public function getLevel(): int
+    {
+        return $this->level;
+    }
+
+    public function isDebugEnabled(): bool
+    {
+        return $this->level >= self::LEVEL_DEBUG;
+    }
+
     /**
      * Инициализация логгера.
      * @return void
@@ -130,34 +182,81 @@ private function cleanupOrphanedLogs(): void
 
     public function writeError($data, string $header = ''): void
     {
+        if ($this->level < self::LEVEL_ERROR) {
+            return;
+        }
         $this->rotate();
-        if ($this->debug) {
-            if(!empty($header)){
-                $header.= '('.posix_getpid()."): ";
-            }
-            $this->logger->error($header . $this->getDecodedString($data));
+        if (!empty($header)) {
+            $header .= '(' . posix_getpid() . "): ";
         }
+        $this->logger->error($header . $this->getDecodedString($data));
     }
 
     public function writeInfo($data, string $header = ''): void
     {
+        if ($this->level < self::LEVEL_INFO) {
+            return;
+        }
         $this->rotate();
-        if ($this->debug) {
-            if(!empty($header)){
-                $header.= '('.posix_getpid()."): ";
-            }
-            $this->logger->info($header . $this->getDecodedString($data));
+        if (!empty($header)) {
+            $header .= '(' . posix_getpid() . "): ";
+        }
+        $this->logger->info($header . $this->getDecodedString($data));
+    }
+
+    /**
+     * Подробная запись — выводится только при уровне DEBUG. Используется для
+     * больших payload'ов (полный JSON ответа CRM), которые на INFO дают
+     * только summary.
+     */
+    public function writeDebug($data, string $header = ''): void
+    {
+        if ($this->level < self::LEVEL_DEBUG) {
+            return;
+        }
+        $this->rotate();
+        if (!empty($header)) {
+            $header .= '(' . posix_getpid() . "): ";
         }
+        $this->logger->debug($header . $this->getDecodedString($data));
     }
 
+    /**
+     * Сериализует данные для лога с защитой от перегрузки памяти.
+     *
+     * Раньше использовалась цепочка json_encode + urldecode, которая
+     * удваивала пиковую память (urldecode возвращает новую строку даже
+     * если декодировать нечего). При больших payload'ах из batch CRM это
+     * приводило к OOM (см. Sentry MIKOPBX-MH7).
+     *
+     * Теперь:
+     *  - сразу проверяем грубую оценку размера через strlen на строках;
+     *  - для массивов/объектов кодируем без urldecode и с лимитом в байтах;
+     *  - при превышении лимита возвращаем обрезанную строку с маркером.
+     */
     private function getDecodedString($data): string
     {
-        $printedData = json_encode($data, JSON_UNESCAPED_SLASHES|JSON_UNESCAPED_UNICODE);
-        if (is_bool($printedData)) {
-            $result = '';
-        } else {
-            $result = urldecode($printedData);
+        if (is_string($data)) {
+            $len = strlen($data);
+            return $len > self::MAX_PAYLOAD_BYTES
+                ? substr($data, 0, self::MAX_PAYLOAD_BYTES) . '...[truncated, ' . $len . ' bytes]'
+                : $data;
+        }
+        if (is_scalar($data) || $data === null) {
+            return (string)$data;
+        }
+        $printedData = json_encode(
+            $data,
+            JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE | JSON_PARTIAL_OUTPUT_ON_ERROR | JSON_INVALID_UTF8_SUBSTITUTE
+        );
+        if (!is_string($printedData)) {
+            return '';
+        }
+        $len = strlen($printedData);
+        if ($len > self::MAX_PAYLOAD_BYTES) {
+            return substr($printedData, 0, self::MAX_PAYLOAD_BYTES)
+                . '...[truncated, ' . $len . ' bytes]';
         }
-        return $result;
+        return $printedData;
     }
-}
\ No newline at end of file
+}
diff --git a/Messages/en.php b/Messages/en.php
index 1e1bf19..00a2e10 100644
--- a/Messages/en.php
+++ b/Messages/en.php
@@ -22,6 +22,7 @@
     'mod_b24_i_Auth' => 'Login to Bitrix24',
     'mod_b24_i_NotifyOnCall' => 'Upload call history to the portal',
     'mod_b24_i_ExportRecords' => 'To upload on the portal copies of records of conversations',
+    'mod_b24_i_ImportMtsCalls' => 'Import call history from the «MTS Auto-secretary 2.0» module',
     'mod_b24_i_UpdateStatus' => 'Getting status',
     'mod_b24_i_Connected' => 'Connected to Bitrix24',
     'mod_b24_i_Disconnected' => 'Disconnected or unauthorized',
@@ -71,4 +72,11 @@
     'mod_b24_i_OPEN_CARD_ANSWERED' => 'Open on answer',
     'mod_b24_i_lead_type_incoming' => 'Inbox only',
     'mod_b24_i_lead_type_outgoing' => 'Outgoing only',
+
+    'mod_b24_i_logLevel'           => 'Log verbosity',
+    'mod_b24_i_logLevelHint'       => 'INFO is enough for routine issue analysis (call lookup by linkedid). Switch to DEBUG only for deep investigation — full request/response payloads will be written to disk and may significantly increase memory usage on portals with large CRM volumes.',
+    'mod_b24_i_logLevel_NONE'      => 'Off',
+    'mod_b24_i_logLevel_ERROR'     => 'Errors only',
+    'mod_b24_i_logLevel_INFO'      => 'Standard (recommended)',
+    'mod_b24_i_logLevel_DEBUG'     => 'Detailed (full payloads)',
 ];
diff --git a/Messages/ru.php b/Messages/ru.php
index 6daf5d0..4bc7fa0 100644
--- a/Messages/ru.php
+++ b/Messages/ru.php
@@ -24,6 +24,7 @@
     'mod_b24_i_NotifyOnCall'              => 'Загружать на портал историю звонков',
     'mod_b24_i_CrmCreate'                 => 'Создавать в CRM сущности, связанные со звонком (Лид / сделка / контакт).',
     'mod_b24_i_ExportRecords'             => 'Загружать на портал копии записей разговоров',
+    'mod_b24_i_ImportMtsCalls'            => 'Импорт истории звонков из модуля «МТС Автосекретарь 2.0»',
     'mod_b24_i_StatusError'               => 'Ошибка работы модуля',
     'mod_b24_i_Connected'                 => 'Авторизован',
     'mod_b24_i_Connected_v2'              => 'Авторизован',
@@ -78,4 +79,11 @@
     'mod_b24_i_OPEN_CARD_NONE'            => 'Не открывать',
     'mod_b24_i_OPEN_CARD_DIRECTLY'        => 'Открывать при звонке',
     'mod_b24_i_OPEN_CARD_ANSWERED'        => 'Открывать при ответе',
+
+    'mod_b24_i_logLevel'                  => 'Уровень логирования',
+    'mod_b24_i_logLevelHint'              => 'Стандартного уровня (INFO) достаточно для большинства задач: остаётся вся информация для разбора звонка по linkedid и анализа ошибок API. Включайте «Подробный» (DEBUG) только на время диагностики — будут писаться полные тела запросов и ответов CRM, что заметно увеличит объём логов и потребление памяти на порталах с большой базой.',
+    'mod_b24_i_logLevel_NONE'             => 'Отключено',
+    'mod_b24_i_logLevel_ERROR'            => 'Только ошибки',
+    'mod_b24_i_logLevel_INFO'             => 'Стандартный (рекомендуется)',
+    'mod_b24_i_logLevel_DEBUG'            => 'Подробный (полные payload)',
 ];
\ No newline at end of file
diff --git a/Models/ModuleBitrix24Integration.php b/Models/ModuleBitrix24Integration.php
index d46d0e1..c38e872 100644
--- a/Models/ModuleBitrix24Integration.php
+++ b/Models/ModuleBitrix24Integration.php
@@ -13,6 +13,24 @@
 
 class ModuleBitrix24Integration extends ModulesModelsBase
 {
+    public const LOG_LEVEL_NONE  = 'NONE';
+    public const LOG_LEVEL_ERROR = 'ERROR';
+    public const LOG_LEVEL_INFO  = 'INFO';
+    public const LOG_LEVEL_DEBUG = 'DEBUG';
+
+    /**
+     * Возвращает доступные уровни логирования.
+     */
+    public static function getAvailableLogLevels(): array
+    {
+        return [
+            self::LOG_LEVEL_NONE,
+            self::LOG_LEVEL_ERROR,
+            self::LOG_LEVEL_INFO,
+            self::LOG_LEVEL_DEBUG,
+        ];
+    }
+
     /**
      * @Primary
      * @Identity
@@ -135,6 +153,27 @@ class ModuleBitrix24Integration extends ModulesModelsBase
      */
     public $lastLeadId;
 
+    /**
+     * Уровень логирования: NONE, ERROR, INFO, DEBUG.
+     *
+     * @Column(type="string", nullable=true, default="INFO")
+     */
+    public $logLevel = 'INFO';
+
+    /**
+     * Импортировать историю звонков из ModuleMtsPbx в Bitrix24.
+     *
+     * @Column(type="integer", nullable=true, default="0")
+     */
+    public $import_mts_calls = '0';
+
+    /**
+     * Курсор (mts_cdr.id) последней записи, поставленной в очередь импорта.
+     *
+     * @Column(type="integer", nullable=true, default="0")
+     */
+    public $mts_import_last_id = '0';
+
 
     public function initialize(): void
     {
diff --git a/Setup/PbxExtensionSetup.php b/Setup/PbxExtensionSetup.php
index 8bdaae6..de34945 100644
--- a/Setup/PbxExtensionSetup.php
+++ b/Setup/PbxExtensionSetup.php
@@ -50,6 +50,9 @@ public function installDB(): bool
             if (empty($settings->b24_region)) {
                 $settings->b24_region = 'RUSSIA';
             }
+            if (empty($settings->logLevel)) {
+                $settings->logLevel = ModuleBitrix24Integration::LOG_LEVEL_INFO;
+            }
             $result = $settings->save();
         }
 
diff --git a/bin/ConnectorDb.php b/bin/ConnectorDb.php
index 08e836d..b262164 100644
--- a/bin/ConnectorDb.php
+++ b/bin/ConnectorDb.php
@@ -50,6 +50,7 @@ class ConnectorDb extends WorkerBase
     public const FUNC_FIND_CDR_BY_UID               = "findCdrByUID";
     public const FUNC_UPDATE_CDR_BY_UID             = "updateCdrByUID";
     public const FUNC_GET_CDR_BY_LINKED_ID          = "getCdrDataByLinkedId";
+    public const FUNC_GET_EXPORTED_CALL_ID          = "getExportedCallIdByLinkedId";
     public const FUNC_GET_CDR_BY_FILTER             = "getCdrByFilter";
     public const FUNC_UPDATE_FROM_ARRAY_CDR_BY_UID  = "updateCdrFromArrayByUID";
     public const FUNC_SAVE_EXTERNAL_LINES           = "saveExternalLinesData";
@@ -78,6 +79,7 @@ class ConnectorDb extends WorkerBase
         'findCdrByUID'                => 2,
         'updateCdrByUID'              => 2,
         'getCdrDataByLinkedId'        => 2,
+        'getExportedCallIdByLinkedId' => 2,
         'getCdrByFilter'              => 2,
         'updateCdrFromArrayByUID'     => 2,
         'updateGeneralSettings'       => 10,
@@ -126,6 +128,10 @@ public function pingCallBack(BeanstalkClient $message): void
     public function start($argv):void
     {
         $this->logger =  new Logger('ConnectorDb', self::MODULE_ID);
+        $settings = ModuleBitrix24Integration::findFirst();
+        if ($settings && !empty($settings->logLevel)) {
+            $this->logger->setLevel($settings->logLevel);
+        }
         $this->logger->writeInfo('Starting');
         $beanstalk      = new BeanstalkClient(self::class);
         $beanstalk->subscribe(self::class, [$this, 'onEvents']);
@@ -587,14 +593,23 @@ public function getFirstExternalLines(array $filter= []):array
     public function saveExternalLinesData(array $externalLinesPost):bool
     {
         if(empty($externalLinesPost)){
-            // Больше нет внешних линий, чистим все.
-            $filter = [];
-        }else{
-            $filter = [
-                'conditions' => 'id NOT IN ({ids:array})',
-                'bind' => ['ids' => array_column($externalLinesPost, 'id')]
-            ];
+            // Пустой POST — НЕ удаляем существующие линии. Раньше тут было
+            // `$filter = []` → find().delete() стирало все строки безусловно;
+            // при сбое JS на форме (если он не передал externalLines) таблица
+            // обнулялась за один клик «Сохранить». Удаление линий должно
+            // быть осознанным действием — отдельный экшн/кнопка, а не
+            // побочный эффект сохранения настроек.
+            if (ModuleBitrix24ExternalLines::count() > 0) {
+                $this->logger->writeError(
+                    'External lines POST is empty while table is non-empty — skipping destructive delete-all to preserve data'
+                );
+            }
+            return true;
         }
+        $filter = [
+            'conditions' => 'id NOT IN ({ids:array})',
+            'bind' => ['ids' => array_column($externalLinesPost, 'id')]
+        ];
         $externalLines = ModuleBitrix24ExternalLines::find($filter);
         foreach ($externalLines as $externalLine){
             $externalLine->delete();
@@ -1180,6 +1195,37 @@ private function getCdrDataByLinkedId(array $options): array
         return $result;
     }
 
+    /**
+     * Идемпотентная проверка для импорта исторических звонков:
+     * возвращает ['call_id' => '<b24-id>'] если звонок с таким linkedid
+     * уже был успешно отправлен в Bitrix24, или [] в противном случае.
+     *
+     * Отличие от getCdrDataByLinkedId: нет фильтра по UNIQUEID (leg-семантика
+     * не применима к импорту) и нет fallback на «первый попавшийся row».
+     * Возвращается ровно один ряд с непустым call_id; если такого нет —
+     * пустой массив.
+     *
+     * Результат обёрнут в массив, потому что unpackResult всегда требует
+     * массив от Beanstalk-RPC.
+     *
+     * @param string $linkedid
+     * @return array
+     */
+    private function getExportedCallIdByLinkedId(string $linkedid): array
+    {
+        if ($linkedid === '') {
+            return [];
+        }
+        $row = ModuleBitrix24CDR::findFirst([
+            'conditions' => "linkedid = :linkedid: AND call_id IS NOT NULL AND call_id <> ''",
+            'bind'       => ['linkedid' => $linkedid],
+        ]);
+        if (!$row) {
+            return [];
+        }
+        return ['call_id' => (string)$row->call_id];
+    }
+
     /**
      * Возвращает все CDR по фильтру.
      * @param array $filter
diff --git a/bin/MtsImporter.php b/bin/MtsImporter.php
new file mode 100644
index 0000000..2c0b6e3
--- /dev/null
+++ b/bin/MtsImporter.php
@@ -0,0 +1,271 @@
+<?php
+/*
+ * MikoPBX - free phone system for small business
+ * Copyright © 2017-2026 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\ModuleBitrix24Integration\bin;
+require_once 'Globals.php';
+
+use MikoPBX\Modules\PbxExtensionUtils;
+use Modules\ModuleBitrix24Integration\Lib\Bitrix24InvokeRest;
+use Modules\ModuleBitrix24Integration\Lib\Logger;
+
+// Источник данных — таблица mts_cdr соседнего модуля ModuleMtsPbx,
+// которая содержит только MTS-звонки и обогащённые MTS API метаданные
+// (recordingfile, mts_rec_status). Это узкая таблица без посторонних
+// записей — индекс на from_account не нужен (по сути все строки fs-mts).
+//
+// Альтернатива (cdr_general в cdr.db) была отвергнута: на крупных
+// инсталляциях миллионы записей без индекса на from_account делают
+// первичный скан медленным, а индекс на чужую БД мы добавлять не хотим.
+//
+// FQCN-строка вместо `use`, потому что Modules\ModuleMtsPbx\Models\CallHistory
+// может отсутствовать (соседний модуль не установлен) — `use` уронит
+// автозагрузку. Доступ — только через переменную после class_exists().
+const MTS_CALL_HISTORY_FQCN = '\\Modules\\ModuleMtsPbx\\Models\\CallHistory';
+
+const MAX_PER_RUN = 300;
+/**
+ * Размер порции, посылаемой одним invoke в HTTP-воркер.
+ * ВАЖНО: значение должно совпадать с
+ * WorkerBitrix24IntegrationHTTP::MAX_HISTORICAL_CALLS_PER_INVOKE — воркер
+ * срезает по своему потолку, и при рассинхроне часть звонков молча
+ * отбрасывается. Если меняете — поднимите оба.
+ */
+const BATCH_SIZE  = 10;
+const MIN_PAUSE   = 2;
+const MAX_PAUSE   = 5;
+
+$logger = new Logger('MtsImporter', 'ModuleBitrix24Integration');
+
+if (!PbxExtensionUtils::isEnabled('ModuleBitrix24Integration')) {
+    exit(0);
+}
+
+// Защита от повторного запуска (cron каждые 5 мин, скрипт может занять до ~150 сек).
+$lockFile = ConnectorDb::getTempDir() . '/mts_importer.lock';
+$lockHandle = @fopen($lockFile, 'c');
+if (!$lockHandle || !@flock($lockHandle, LOCK_EX | LOCK_NB)) {
+    // Уже работает другой инстанс — тихо выходим.
+    if ($lockHandle) {
+        @fclose($lockHandle);
+    }
+    exit(0);
+}
+register_shutdown_function(static function () use (&$lockHandle, $lockFile) {
+    if (is_resource($lockHandle)) {
+        @flock($lockHandle, LOCK_UN);
+        @fclose($lockHandle);
+    }
+    @unlink($lockFile);
+});
+
+// Проверяем доступность модели соседнего модуля — это и источник данных,
+// и смысловой guard «MTS-trunk сконфигурирован».
+$callHistoryClass = MTS_CALL_HISTORY_FQCN;
+if (!class_exists($callHistoryClass)) {
+    // ModuleMtsPbx не установлен — это штатная ситуация. Тихо выходим.
+    exit(0);
+}
+
+// ConnectorDb::FUNC_GET_GENERAL_SETTINGS возвращает stdClass (см. invoke():
+// `return (object)$cached;` для cache-hit и upstream-сериализацию модели).
+// Раньше здесь была проверка is_array — она роняла скрипт каждые 5 минут
+// с "Settings unavailable, exiting".
+$settings = ConnectorDb::invoke(ConnectorDb::FUNC_GET_GENERAL_SETTINGS);
+if (!is_object($settings)) {
+    // RPC-таймаут или fallback в invoke() вернул пустой массив. Cron повторит
+    // через 5 мин; пишем явно, чтобы отличать от «нет настроек в БД».
+    $logger->writeError(['type' => gettype($settings)], 'Settings RPC returned non-object (likely timeout), exiting');
+    exit(0);
+}
+if (empty($settings->portal)) {
+    // Модуль установлен, но не привязан к порталу B24 — OAuth не пройден.
+    // Импортировать всё равно некуда; молча выходим, чтобы не шуметь в логах.
+    $logger->writeInfo('B24 portal is not configured yet, exiting');
+    exit(0);
+}
+
+if (((string)($settings->import_mts_calls ?? '0')) !== '1') {
+    // Опция выключена.
+    exit(0);
+}
+
+$cursor            = (int)($settings->mts_import_last_id ?? 0);
+$crmCreateFlag     = (((string)($settings->crmCreateLead ?? '0')) === '1') ? '1' : '0';
+$exportRecordsFlag = (((string)($settings->export_records ?? '0')) === '1') ? '1' : '0';
+
+$logger->writeInfo(
+    [
+        'cursor'         => $cursor,
+        'crm_create'     => $crmCreateFlag,
+        'export_records' => $exportRecordsFlag,
+    ],
+    'MTS importer started'
+);
+
+$invoker     = new Bitrix24InvokeRest();
+$processed   = 0;
+$todayStart  = (new \DateTime())->setTime(0, 0)->format('Y-m-d H:i:s');
+
+while ($processed < MAX_PER_RUN) {
+    // mts_cdr содержит только MTS-звонки — фильтр по from_account не нужен.
+    // Двусторонний курсор (id > cursor OR start >= today) — на случай
+    // повторной синхронизации MTS API за текущий день (мerging обновлений
+    // mts_rec_status для уже виденных id).
+    $rows = $callHistoryClass::find([
+        'id > :id: OR start >= :start:',
+        'bind'  => [
+            'id'    => $cursor,
+            'start' => $todayStart,
+        ],
+        'order' => 'id',
+        'limit' => BATCH_SIZE,
+    ])->toArray();
+
+    if (empty($rows)) {
+        break;
+    }
+
+    $batch = [];
+    $cursorCandidate = $cursor; // курсор сдвинется только после успешного invoke
+    $stopAtPending = false;
+    foreach ($rows as $row) {
+        $rowId     = (int)($row['id'] ?? 0);
+        $recStatus = (string)($row['mts_rec_status'] ?? '');
+        // Pending — MP3 ещё не докачан ModuleMtsPbx (downloadRecords.php).
+        // Останавливаемся БЕЗОГОВОРОЧНО (без проверки rowId > cursor): иначе
+        // запись с id<=cursor, попавшая в выборку через ветку `start>=today`,
+        // ускользнёт от pending-guard и уйдёт в B24 без FILE. После докачки
+        // MP3 dedup (FUNC_GET_EXPORTED_CALL_ID) не пустит её повторно —
+        // запись разговора потеряется навсегда. См. ревью.
+        if ($recStatus === 'pending') {
+            $logger->writeInfo(
+                ['id' => $rowId, 'linkedid' => $row['linkedid'] ?? ''],
+                'Skip pending and stop run (wait for MP3 download next tick)'
+            );
+            $stopAtPending = true;
+            break;
+        }
+
+        // mts_cdr содержит только MTS-звонки, но защищаемся от поломок ORM
+        // или будущих изменений модели — другой from_account пропускаем со
+        // сдвигом курсора.
+        $fromAccount = (string)($row['from_account'] ?? '');
+        if ($fromAccount !== 'fs-mts') {
+            if ($rowId > $cursorCandidate) {
+                $cursorCandidate = $rowId;
+            }
+            continue;
+        }
+
+        $payload = [
+            'linkedid'              => (string)($row['linkedid'] ?? ''),
+            'src_num'               => (string)($row['src_num'] ?? ''),
+            'dst_num'               => (string)($row['dst_num'] ?? ''),
+            'did'                   => (string)($row['did'] ?? ''),
+            'start'                 => (string)($row['start'] ?? ''),
+            'duration'              => (string)($row['duration'] ?? '0'),
+            'disposition'           => (string)($row['disposition'] ?? 'NOANSWER'),
+            'recordingfile'         => (string)($row['recordingfile'] ?? ''),
+            'mts_rec_status'        => $recStatus,
+            'from_account'          => $fromAccount,
+            'crm_create'            => $crmCreateFlag,
+            'export_records_setting'=> $exportRecordsFlag,
+        ];
+        $batch[] = $payload;
+        if ($rowId > $cursorCandidate) {
+            $cursorCandidate = $rowId;
+        }
+    }
+
+    $invokeStatus = WorkerBitrix24IntegrationHTTP::IMPORT_ACK_OK;
+    if (!empty($batch)) {
+        try {
+            $ack = $invoker->invoke('importHistoricalCalls', ['calls' => $batch], 5);
+        } catch (\Throwable $e) {
+            $logger->writeError(
+                ['error' => $e->getMessage(), 'batch_size' => count($batch)],
+                'Invoke failed, stopping run'
+            );
+            // Не двигаем курсор; следующий тик cron'а вернётся к этой партии.
+            break;
+        }
+        $invokeStatus = (string)($ack['status'] ?? '');
+        if ($invokeStatus === WorkerBitrix24IntegrationHTTP::IMPORT_ACK_NOT_READY) {
+            // HTTP-воркер сообщил, что его карты пользователей B24 пусты
+            // (например, после рестарта). НЕ двигаем курсор, ждём следующего тика.
+            $logger->writeInfo(
+                ['batch_size' => count($batch)],
+                'HTTP worker not ready, leaving cursor untouched'
+            );
+            break;
+        }
+        if ($invokeStatus !== WorkerBitrix24IntegrationHTTP::IMPORT_ACK_OK) {
+            $logger->writeError(
+                ['ack' => $ack, 'batch_size' => count($batch)],
+                'Unexpected ack from HTTP worker, stopping run'
+            );
+            break;
+        }
+        $processed += count($batch);
+    }
+
+    // Курсор продвигаем только если HTTP-воркер подтвердил приём
+    // (или партия была пустой — все записи фильтровались как «чужие»).
+    if ($cursorCandidate > $cursor) {
+        $cursor = $cursorCandidate;
+        ConnectorDb::invoke(
+            ConnectorDb::FUNC_UPDATE_GENERAL_SETTINGS,
+            [['mts_import_last_id' => $cursor]],
+            false
+        );
+    }
+
+    if ($stopAtPending) {
+        // Перед нами «застрявшая» pending-запись; продолжать выборку
+        // бессмысленно (тот же фильтр повторно её вернёт). Завершаем прогон,
+        // ждём следующего тика — MP3 успеет докачаться.
+        break;
+    }
+    if ($processed >= MAX_PER_RUN) {
+        break;
+    }
+    if (count($rows) < BATCH_SIZE) {
+        // Получили меньше лимита — данных больше нет.
+        break;
+    }
+    if (empty($batch) && $cursorCandidate === $cursor) {
+        // Защита от бесконечного цикла: вернулись BATCH_SIZE рядов из
+        // ветки «start >= today» с id <= cursor (например, не fs-mts),
+        // курсор не сдвинулся и сдвинуть не сможем. Прерываем прогон.
+        $logger->writeInfo(
+            ['cursor' => $cursor, 'rows_fetched' => count($rows)],
+            'No progress possible (all rows filtered, cursor at ceiling), stopping run'
+        );
+        break;
+    }
+    if (empty($batch)) {
+        // Все строки этой выборки были отфильтрованы как «чужие» — курсор
+        // уже двинут на rowId последней записи; следующая итерация
+        // продолжит с этого места. Пауза не нужна.
+        continue;
+    }
+    sleep(random_int(MIN_PAUSE, MAX_PAUSE));
+}
+
+$logger->writeInfo(['processed' => $processed, 'cursor' => $cursor], 'MTS importer finished');
diff --git a/bin/UploaderB24.php b/bin/UploaderB24.php
index c67b49e..bc4594e 100644
--- a/bin/UploaderB24.php
+++ b/bin/UploaderB24.php
@@ -60,6 +60,9 @@ public function start($argv):void
         $this->logger->writeInfo('Start daemon...');
 
         $this->b24    = new Bitrix24Integration('_uploader');
+        // Bitrix24Integration уже подгрузил настройки через ConnectorDb::invoke
+        // и применил уровень к своему логгеру — синхронизируемся.
+        $this->logger->setLevel($this->b24->mainLogger->getLevel());
         $this->ffprobePath = Util::which('ffprobe') ?: '';
         $this->logger->writeInfo("ffprobe path: '{$this->ffprobePath}'");
         $this->initBeanstalk();
diff --git a/bin/WorkerBitrix24IntegrationAMI.php b/bin/WorkerBitrix24IntegrationAMI.php
index d8c1cc7..8fdb955 100644
--- a/bin/WorkerBitrix24IntegrationAMI.php
+++ b/bin/WorkerBitrix24IntegrationAMI.php
@@ -96,21 +96,40 @@ public function start($argv):void
 
         $this->client = new BeanstalkClient(Bitrix24Integration::B24_INTEGRATION_CHANNEL);
         $this->am     = $this->createAstManager();
+
+        // ВАЖНО: AMI-фильтр и обработчик регистрируем ДО тяжёлого new
+        // Bitrix24Integration (он делает синхронный REST к B24 и может занимать
+        // секунды). safe.php (WorkerSafeScriptsCore::checkWorkerAMI) шлёт ping
+        // через UserEvent каждые ~5 сек и засчитывает 3 промаха подряд → SIGUSR1.
+        // Если listener не зарегистрирован к этому моменту, воркер крашится
+        // в цикле «Start daemon → Need SHUTDOWN... 10 → Start daemon». Ping-
+        // обработчик (replyOnPingRequest) зависит только от $this->am, поэтому
+        // безопасно выводить его регистрацию вперёд.
+        $this->setFilter();
+        $this->am->addEventHandler('userevent', [$this, 'callback']);
+
         $this->b24    = new Bitrix24Integration('_ami');
 
         if (!$this->b24->initialized) {
             $this->logger->writeError('Settings not set... exit');
             exit();
         }
-        $this->setFilter();
+        // Bitrix24Integration уже подгрузил настройки через ConnectorDb::invoke
+        // и применил уровень к своему логгеру — синхронизируемся.
+        $this->logger->setLevel($this->b24->mainLogger->getLevel());
         $this->updateSettings();
 
         $config                = new MikoPBXConfig();
         $this->extensionLength = $config->getGeneralSettings('PBXInternalExtensionLength');
 
-        $this->am->addEventHandler("userevent", [$this, "callback"]);
         if ($this->needRestart) {
-            $this->logger->writeInfo('Restart signal received during init, deferring — entering main loop.');
+            // SIGUSR1 пришёл во время init (например, safe.php засчитал нас
+            // мёртвыми по ping'у до того, как listener успел зарегистрироваться).
+            // Мы УЖЕ восстановили обработку — игнорируем этот сигнал, чтобы не
+            // рестартоваться сразу после старта. Реальный shutdown потребует
+            // нового SIGUSR1, который придёт через ping-механизм если воркер
+            // снова перестанет отвечать.
+            $this->logger->writeInfo('Ignoring early SIGUSR1 received during init — listener is now ready, entering main loop.');
             $this->needRestart = false;
         }
         $this->processState = 'idle';
@@ -198,8 +217,19 @@ private function updateSettings():void{
         // Обновляем данные B24 (внутри вызывается b24GetPhones → обновляет кеш inner_numbers)
         $this->b24->updateSettings($settings);
 
-        // Читаем inner_numbers из кеша (заполнен b24GetPhones выше)
+        // Читаем inner_numbers из кеша (заполнен b24GetPhones выше).
+        // Если основной кеш пуст/протух (типичный кейс: разовый сбой
+        // user.get → b24GetPhones построил пустую карту в более ранней
+        // ветке без защиты, либо TTL=3600 истёк раньше следующего тика
+        // updateSettings), пробуем долгоживущий снимок inner_numbers_LONG.
         $innerNumbers = $this->b24->getCache('inner_numbers');
+        if (!is_array($innerNumbers) || count($innerNumbers) === 0) {
+            $longSnapshot = $this->b24->getCache('inner_numbers_LONG');
+            if (is_array($longSnapshot) && count($longSnapshot) > 0) {
+                $innerNumbers = $longSnapshot;
+                $this->logger->writeInfo('inner_numbers restored from LONG snapshot. count=' . count($longSnapshot));
+            }
+        }
         if (is_array($innerNumbers) && count($innerNumbers) > 0) {
             $this->inner_numbers = (array)$innerNumbers;
         } else {
@@ -277,6 +307,16 @@ private function setFilter():void
     public function callback($parameters):void{
 
         if ($this->replyOnPingRequest($parameters)){
+            // Pong через replyOnPingRequest зависит только от $this->am и уже
+            // отправлен выше. Дальше начинается работа на $this->b24 /
+            // updateSettings — её НЕ дёргаем пока воркер в фазе init.
+            // processState='init' выставлен на уровне поля и меняется на
+            // 'idle' только в конце start() — это надёжный маркер
+            // «warming up», см. start(): между регистрацией listener
+            // и завершением new Bitrix24Integration окно несколько секунд.
+            if ($this->processState === 'init') {
+                return;
+            }
             $this->counter++;
             // Пинг приходит раз в минуту. Обычный интервал обновления — 5 минут.
             // Если inner_numbers пуст (токен был невалиден) — обновляем каждый пинг для быстрого восстановления.
@@ -293,6 +333,14 @@ public function callback($parameters):void{
         if(!isset($parameters['AgiData'])){
             return;
         }
+        // CDR-event может прийти до окончания инициализации (b24, extensions,
+        // external_lines, extensionLength — всё ставится последовательно
+        // в start()). Обработчики ниже требуют их. Тот же маркер processState.
+        // Asterisk переотправит CDR при следующем звонке; во время первичного
+        // запуска воркера активных звонков обычно нет.
+        if ($this->processState === 'init') {
+            return;
+        }
         $agiData = $parameters['AgiData'];
         if (strpos($agiData, 'GZ:') === 0) {
             $stringData = gzdecode(base64_decode(substr($agiData, 3)));
@@ -460,6 +508,13 @@ private function actionCreateCdr($data, $general_src_num):void
                 $userId = $this->inner_numbers[$data['dst_num']]['ID'] ?? '';
             }
             $inner  = $data['dst_num'];
+            // dst_num настроен в модуле, но в B24 не привязан к пользователю —
+            // open карточки некому. Register с пустым USER_ID создаёт бесхозную
+            // карточку в B24; в очереди остальные плечи отработают своими dial'ами.
+            if ($userId === '') {
+                $this->logger->writeInfo("Internal $inner is configured in module but not assigned to any B24 user (empty USER_ID). Skip register. $linkedId");
+                return;
+            }
             $this->logger->writeInfo("This is an incoming call to an employee's internal number. $linkedId");
             $createLead = ($this->leadType !== Bitrix24Integration::API_LEAD_TYPE_OUT && $this->crmCreateLead)?'1':'0';
             if (strlen($general_src_num) > $this->extensionLength && ! in_array($general_src_num, $this->extensions, true)) {
@@ -627,6 +682,30 @@ private function actionCompleteCdr($data):void
 
         $responsible = '';
         $isMissed = ($data['GLOBAL_STATUS'] ?? '') !== 'ANSWERED';
+        // Голосовая почта формально ANSWERED, но для CRM это пропущенный
+        // входящий: реального оператора не было — направляем на ответственного
+        // по умолчанию (responsibleMissedCalls), а не на «случайного» пользователя.
+        $isVoicemail = !$isOutgoing
+            && ($dstNum === 'voicemail' || ($data['dst_chan'] ?? '') === 'VOICEMAIL');
+        if ($isVoicemail) {
+            $isMissed = true;
+        }
+
+        // Входящий внешний звонок, который не дошёл до сотрудника
+        // (например, IVR/очередь ответили — GLOBAL_STATUS=ANSWERED — но
+        // абонент сбросил до распределения на оператора). Без этой ветки
+        // такие звонки терялись: USER_ID пуст, isMissed=false, и обработчик
+        // уходил в "responsible person was not found". Voicemail исключаем —
+        // он идёт по своему пути, длительность/запись там значимы.
+        $isOrphanIncoming = (!$isOutgoing
+            && !$isVoicemail
+            && empty($USER_ID)
+            && strlen($srcNum) > $this->extensionLength
+            && !in_array($srcNum, $this->extensions, true)
+            && !empty($this->responsibleMissedCalls));
+        if ($isOrphanIncoming) {
+            $isMissed = true;
+        }
 
         $finishKeyID = 'finish-cdr-'.$uniqueId;
         if(!empty($USER_ID) && !$isMissed) {
@@ -642,7 +721,35 @@ private function actionCompleteCdr($data):void
         }elseif ($isMissed && !empty($USER_ID) ){
             // Рандомно назначаем ответственного для пропущенного.
             $responsible = $USER_ID;
+            // Дедуп — по linkedid, а не по UNIQUEID: при нескольких NOANSWER-
+            // плечах одного звонка в B24 должна попадать ровно одна карточка
+            // «пропущенного», иначе для очереди из N операторов уехало бы
+            // N missed-карточек.
+            $finishKeyID = 'finish-cdr-'.$linkedId;
         }else{
+            // Расширенная диагностика причины: чаще всего сюда попадают
+            // плечи входящих звонков, у которых dst_num — реальный
+            // внутренний номер оператора, но он отсутствует в карте
+            // inner_numbers/mobile_numbers на момент обработки CDR
+            // (см. inner_numbers_diff в IntegrationAMI.log).
+            $this->logger->writeInfo([
+                'linkedid'               => $linkedId,
+                'src_num'                => $srcNum,
+                'dst_num'                => $dstNum,
+                'USER_ID'                => $USER_ID,
+                'srsUserId'              => $srsUserId,
+                'dstUserId'              => $dstUserId,
+                'isMissed'               => $isMissed,
+                'isOutgoing'             => $isOutgoing,
+                'isVoicemail'            => $isVoicemail,
+                'isOrphanIncoming'       => $isOrphanIncoming,
+                'GLOBAL_STATUS'          => $data['GLOBAL_STATUS'] ?? '',
+                'disposition'            => $data['disposition'] ?? '',
+                'responsibleMissedCalls' => $this->responsibleMissedCalls,
+                'inner_numbers_count'    => count($this->inner_numbers),
+                'dst_in_inner_numbers'   => isset($this->inner_numbers[$dstNum]),
+                'src_in_inner_numbers'   => isset($this->inner_numbers[$srcNum]),
+            ], 'CancellationContext');
             $this->logger->writeInfo("The responsible person was not found. cancellation ".$linkedId);
             return;
         }
@@ -683,14 +790,26 @@ private function actionCompleteCdr($data):void
                 }
             }
 
+            // Для orphan-incoming реальный оператор не отвечал — IVR/очередь
+            // ответили формально. Принудительно помечаем звонок как пропущенный,
+            // чтобы B24 показал его в "Пропущенных" у ответственного.
+            $globalStatus = $data['GLOBAL_STATUS'] ?? '';
+            $disposition  = $data['disposition'] ?? '';
+            $billsec      = $data['billsec'] ?? '0';
+            if ($isOrphanIncoming) {
+                $globalStatus = 'NOANSWER';
+                $disposition  = 'NOANSWER';
+                $billsec      = '0';
+            }
+
             $this->logger->writeInfo("Send finish event...".$linkedId);
             $params = [
                 'UNIQUEID'       => $uniqueId,
                 'USER_ID'        => $responsible,
-                'DURATION'       => $data['billsec'] ?? '0',
+                'DURATION'       => $billsec,
                 'FILE'           => $data['recordingfile'] ?? '',
-                'GLOBAL_STATUS'  => $data['GLOBAL_STATUS'] ?? '',
-                'disposition'    => $data['disposition'] ?? '',
+                'GLOBAL_STATUS'  => $globalStatus,
+                'disposition'    => $disposition,
                 "export_records" => $this->export_records,
                 'linkedid'       => $linkedId,
                 'LINE_NUMBER'    => $LINE_NUMBER,
@@ -725,8 +844,16 @@ public function actionDialCreateChan($data):void{
      */
     private function getInnerNum(string $number):string
     {
-        $userId = '';
+        if ($number === '') {
+            return '';
+        }
         $number = Bitrix24Integration::getPhoneIndex($number);
+        // После getPhoneIndex нечисловой ввод (например 'voicemail') превращается
+        // в '' — обращение по такому ключу подцепило бы «безномерных» пользователей.
+        if ($number === '') {
+            return '';
+        }
+        $userId = '';
         if(isset($this->inner_numbers[$number])){
             $userId = $this->inner_numbers[$number]['ID'];
         } elseif(isset($this->b24->mobile_numbers[$number])){
diff --git a/bin/WorkerBitrix24IntegrationHTTP.php b/bin/WorkerBitrix24IntegrationHTTP.php
index e1b9e15..c83c7af 100644
--- a/bin/WorkerBitrix24IntegrationHTTP.php
+++ b/bin/WorkerBitrix24IntegrationHTTP.php
@@ -30,6 +30,20 @@
 
 class WorkerBitrix24IntegrationHTTP extends WorkerBase
 {
+    /**
+     * Максимум исторических звонков в одном invoke. 10×2 cmd (register+finish)
+     * = 20 элементов, безопасно для лимита B24 batch в 50 cmd.
+     *
+     * ВАЖНО: значение должно совпадать с BATCH_SIZE в bin/MtsImporter.php —
+     * cron-импортёр шлёт пачками по BATCH_SIZE, а воркер срезает по этому
+     * потолку. Если меняете одно — поднимите оба.
+     */
+    public const MAX_HISTORICAL_CALLS_PER_INVOKE = 10;
+
+    /** Статусы ACK для action 'importHistoricalCalls'. */
+    public const IMPORT_ACK_OK        = 'ok';
+    public const IMPORT_ACK_NOT_READY = 'not_ready';
+
     private Bitrix24Integration $b24;
     private $pidSyncProcContacts;
     private $timeSyncProcContacts;
@@ -74,6 +88,10 @@ public function signalHandler(int $signal): void
      */
     public function start($argv): void
     {
+        // Поднимаем PHP memory_limit. Дефолт 128M ловит OOM на batch-ответах
+        // crm.lead.list / crm.contact.list / crm.company.list, когда в портале
+        // десятки тысяч записей. См. Sentry MIKOPBX-MH7 / issue #135.
+        ini_set('memory_limit', '256M');
         $this->b24 = new Bitrix24Integration();
         if (!$this->b24->initialized) {
             die('Settings not set...');
@@ -160,6 +178,11 @@ public function invokeRest($client): void
             $arg = $this->b24->getScopeAsync($data['inbox_tube']??'');
         }elseif($action === 'needRestart'){
             $this->needRestart = true;
+        }elseif($action === 'importHistoricalCalls'){
+            $this->handleImportHistoricalCalls(
+                $data['args']['calls'] ?? [],
+                (string)($data['inbox_tube'] ?? '')
+            );
         }
         if(!empty($arg)){
             $this->b24->mainLogger->writeInfo($data, "Add action $action in queue...");
@@ -167,6 +190,333 @@ public function invokeRest($client): void
         }
     }
 
+    /**
+     * Публикует ответ инициатору invoke (Bitrix24InvokeRest::invoke).
+     * Без публикации клиент будет ждать timeout и логировать ошибку, поэтому
+     * для всех веток `invokeRest` с указанным inbox_tube нужно отправлять
+     * хотя бы пустой/статусный ACK.
+     *
+     * @param string $tube  Имя tube'а из payload (data['inbox_tube']).
+     * @param array  $body  Тело ответа: например ['status' => self::IMPORT_ACK_OK].
+     */
+    private function publishInvokeAck(string $tube, array $body): void
+    {
+        if ($tube === '') {
+            return;
+        }
+        $resFile = ConnectorDb::saveResultInTmpFile($body);
+        if ($resFile === '') {
+            return;
+        }
+        $this->queueAgent->publish($resFile, $tube);
+    }
+
+    /**
+     * Импорт пачки исторических звонков (например, из ModuleMtsPbx).
+     * Каждый звонок проходит штатный путь register+finish и попадает в общую
+     * очередь $this->q_req, которая batch'ем уходит в Bitrix24 через sendBatch().
+     *
+     * Жёсткий потолок MAX_HISTORICAL_CALLS_PER_INVOKE звонков на один invoke:
+     * 10×2 cmd = 20 элементов в batch, безопасно для лимита B24 в 50 cmd.
+     * Cron-импортёр сам не превышает этот лимит, но подстраховываемся на случай
+     * ручных вызовов.
+     *
+     * Контракт ACK:
+     *  - self::IMPORT_ACK_NOT_READY пока inner_numbers / mobile_numbers ещё
+     *    не наполнены (стартап). Импортёр должен НЕ двигать курсор и попробовать позже.
+     *  - self::IMPORT_ACK_OK штатная обработка завершена. Импортёр двигает курсор.
+     *
+     * @param array  $calls
+     * @param string $inboxTube  tube для ACK инициатору invoke.
+     */
+    private function handleImportHistoricalCalls(array $calls, string $inboxTube = ''): void
+    {
+        // Защита от обработки до синхронизации пользователей B24:
+        // findMtsEmployee опирается на inner_numbers/mobile_numbers, заполняемые
+        // в Bitrix24Integration::b24GetPhones(). Если оба пусты, мы не можем
+        // достоверно разрешить USER_ID и ошибочно пропустим все звонки.
+        if (empty($this->b24->inner_numbers) && empty($this->b24->mobile_numbers)) {
+            $this->b24->mainLogger->writeError(
+                ['count' => count($calls)],
+                'MTS import: employee maps are empty (cold worker?), instructing caller to retry'
+            );
+            $this->publishInvokeAck($inboxTube, [
+                'status'   => self::IMPORT_ACK_NOT_READY,
+                'received' => count($calls),
+            ]);
+            return;
+        }
+
+        if (count($calls) > self::MAX_HISTORICAL_CALLS_PER_INVOKE) {
+            $this->b24->mainLogger->writeError(
+                ['received' => count($calls)],
+                'MTS import: too many calls in single invoke, truncating to '
+                . self::MAX_HISTORICAL_CALLS_PER_INVOKE
+            );
+            $calls = array_slice($calls, 0, self::MAX_HISTORICAL_CALLS_PER_INVOKE);
+        }
+        $accepted = 0;
+        $skipped  = 0;
+        foreach ($calls as $call) {
+            if (!is_array($call)) {
+                $skipped++;
+                continue;
+            }
+            if ($this->enqueueHistoricalCall($call)) {
+                $accepted++;
+            } else {
+                $skipped++;
+            }
+        }
+        if (!$this->insideExecuteTasks && count($this->q_req) >= 49) {
+            $this->executeTasks();
+        }
+        $this->publishInvokeAck($inboxTube, [
+            'status'   => self::IMPORT_ACK_OK,
+            'accepted' => $accepted,
+            'skipped'  => $skipped,
+        ]);
+    }
+
+    /**
+     * Помещает один исторический звонок в очередь q_req:
+     *  1) резолвит сотрудника (USER_ID/USER_PHONE_INNER) и направление (TYPE)
+     *     поиском в inner_numbers и mobile_numbers;
+     *  2) проверяет, не отправлялся ли уже звонок (по linkedid в b24_cdr_data);
+     *  3) формирует register, кладёт в q_req, сохраняет ключ register
+     *     в tmpCallsData[linkedid]['CALL_ID'] — это активирует механизм
+     *     resolveBatchCallId() и finish сошлётся на результат register
+     *     внутри одной batch-транзакции;
+     *  4) формирует finish (с FILE/export_records, если запись доступна локально).
+     *
+     * @param array $call Сырые поля звонка из mts_cdr.
+     * @return bool true если оба запроса (register+finish или хотя бы register)
+     *              положены в q_req; false если запись пропущена (internal,
+     *              сотрудник не найден, уже отправлена, dedup-cache hit и т.п.).
+     */
+    private function enqueueHistoricalCall(array $call): bool
+    {
+        $linkedId = (string)($call['linkedid'] ?? '');
+        if ($linkedId === '') {
+            $this->b24->mainLogger->writeError($call, 'MTS import: empty linkedid, skipping');
+            return false;
+        }
+        // Защита от чужих источников, если когда-нибудь в mts_cdr появятся.
+        if (($call['from_account'] ?? '') !== 'fs-mts') {
+            $this->b24->mainLogger->writeError($call, "MTS import: unexpected from_account, skipping ($linkedId)");
+            return false;
+        }
+
+        // 1) Резолв сотрудника.
+        $srcEmp = $this->findMtsEmployee((string)($call['src_num'] ?? ''));
+        $dstEmp = $this->findMtsEmployee((string)($call['dst_num'] ?? ''));
+
+        $type = '';
+        $userId = '';
+        $userPhoneInner = '';
+        $clientPhone = '';
+        if ($srcEmp !== null && $dstEmp !== null) {
+            $this->b24->mainLogger->writeInfo($call, "MTS import: internal call, skipping ($linkedId)");
+            return false;
+        }
+        if ($srcEmp !== null) {
+            // Звонит сотрудник наружу — исходящий.
+            $type = '1';
+            $userId         = (string)($srcEmp['ID'] ?? '');
+            $userPhoneInner = (string)($srcEmp['UF_PHONE_INNER'] ?? '');
+            $clientPhone    = (string)($call['dst_num'] ?? '');
+        } elseif ($dstEmp !== null) {
+            // Звонят сотруднику снаружи — входящий.
+            $type = '2';
+            $userId         = (string)($dstEmp['ID'] ?? '');
+            $userPhoneInner = (string)($dstEmp['UF_PHONE_INNER'] ?? '');
+            $clientPhone    = (string)($call['src_num'] ?? '');
+        } else {
+            $this->b24->mainLogger->writeError(
+                $call,
+                "MTS import: employee not found among inner_numbers/mobile_numbers, skipping ($linkedId)"
+            );
+            return false;
+        }
+
+        if ($userId === '' || $userPhoneInner === '') {
+            $this->b24->mainLogger->writeError(
+                $call,
+                "MTS import: resolved employee has empty ID/UF_PHONE_INNER, skipping ($linkedId)"
+            );
+            return false;
+        }
+
+        // 2) Строгий dedup по linkedid: ищем CDR с непустым call_id.
+        // Используем специальный метод (FUNC_GET_EXPORTED_CALL_ID), а не общий
+        // FUNC_GET_CDR_BY_LINKED_ID — у последнего leg-семантика и fallback
+        // на «первую попавшуюся CDR», что для импорта некорректно.
+        $exported = ConnectorDb::invoke(
+            ConnectorDb::FUNC_GET_EXPORTED_CALL_ID,
+            [$linkedId]
+        );
+        if (!empty($exported['call_id'])) {
+            $this->b24->mainLogger->writeDebug(
+                ['linkedid' => $linkedId, 'call_id' => $exported['call_id']],
+                'MTS import: call already sent, skipping'
+            );
+            return false;
+        }
+
+        // 3) Подготовка tmpCallsData. wait=false, чтобы при последующих AMI-эвентах
+        // не запускалась логика поиска контактов по этому linkedid.
+        if (!isset($this->tmpCallsData[$linkedId])) {
+            $this->tmpCallsData[$linkedId] = [
+                'wait'       => false,
+                'events'     => [],
+                'search'     => 1,
+                'lead'       => -1,
+                'list-lead'  => -1,
+                'company'    => -1,
+                'data'       => $call,
+                'crm-data'   => [],
+                'inbox_tube' => '',
+                'responsible'=> '',
+                'CALL_ID'    => '',
+            ];
+        }
+
+        // Флаги настроек прокидывает cron-импортёр (он уже читает их для своей логики).
+        $crmCreate = (((string)($call['crm_create'] ?? '0')) === '1') ? '1' : '0';
+        $exportRecordsSetting = (((string)($call['export_records_setting'] ?? '0')) === '1');
+
+        $disposition = (string)($call['disposition'] ?? 'NOANSWER');
+        $statusCode  = ($disposition === 'ANSWERED') ? '200' : '304';
+
+        // 4) Register.
+        $payloadRegister = [
+            'linkedid'         => $linkedId,
+            'UNIQUEID'         => $linkedId,
+            'USER_ID'          => $userId,
+            'USER_PHONE_INNER' => $userPhoneInner,
+            'PHONE_NUMBER'     => $clientPhone,
+            'CALL_START_DATE'  => $this->formatHistoricalDate($call['start'] ?? ''),
+            'TYPE'             => $type,
+            'CRM_CREATE'       => $crmCreate,
+            'SHOW'             => '0',
+            'LINE_NUMBER'      => (string)($call['did'] ?? ''),
+        ];
+        [$argRegister, $registerKey] = $this->b24->telephonyExternalCallRegister($payloadRegister);
+        if (!empty($argRegister)) {
+            $this->q_req = array_merge($this->q_req, $argRegister);
+        }
+        if ($registerKey === '') {
+            // Дубликат по кешу register (180 сек) — finish тоже не имеет смысла
+            // в этой итерации, так как CALL_ID в batch получить неоткуда.
+            $this->b24->mainLogger->writeDebug(
+                ['linkedid' => $linkedId],
+                'MTS import: register dedup-cache hit, skipping'
+            );
+            return false;
+        }
+        $this->tmpCallsData[$linkedId]['CALL_ID'] = $registerKey;
+
+        // 5) Finish.
+        $recordFile = '';
+        $exportRecords = false;
+        $recStatus = (string)($call['mts_rec_status'] ?? '');
+        $recPath   = (string)($call['recordingfile'] ?? '');
+        // Прикрепляем запись при status='ok' ИЛИ при пустом status: старые
+        // строки mts_cdr (записанные ModuleMtsPbx до апдейта схемы) имеют
+        // NULL в mts_rec_status, но recordingfile заполнен и MP3 лежит на
+        // диске. Решающий признак — реально существующий файл. 'pending' и
+        // 'gone' при этом отсекаются: у них file_exists даёт false либо путь пуст.
+        if (($recStatus === 'ok' || $recStatus === '') && $recPath !== '' && file_exists($recPath)) {
+            $recordFile = $recPath;
+            $exportRecords = $exportRecordsSetting;
+        }
+
+        $payloadFinish = [
+            'linkedid'        => $linkedId,
+            'UNIQUEID'        => $linkedId,
+            'USER_ID'         => $userId,
+            'DURATION'        => (string)($call['duration'] ?? '0'),
+            'STATUS_CODE'     => $statusCode,
+            'GLOBAL_STATUS'   => $disposition,
+            'disposition'     => $disposition,
+            'FILE'            => $recordFile,
+            'export_records'  => $exportRecords,
+            'ADD_TO_CHAT'     => 0,
+        ];
+        [$argFinish, $finishKey] = $this->b24->telephonyExternalCallFinish($payloadFinish, $this->tmpCallsData);
+        if (!empty($argFinish)) {
+            $this->q_req = array_merge($this->q_req, $argFinish);
+        }
+        $this->b24->mainLogger->writeInfo(
+            [
+                'linkedid' => $linkedId,
+                'type'     => $type,
+                'user_id'  => $userId,
+                'inner'    => $userPhoneInner,
+                'phone'    => $clientPhone,
+                'rec'      => $recStatus,
+                'registerKey' => $registerKey,
+                'finishKey'   => $finishKey,
+            ],
+            'MTS import: enqueued'
+        );
+        return true;
+    }
+
+    /**
+     * Ищет сотрудника по номеру телефона из mts_cdr.
+     * Сначала по внутренним номерам (UF_PHONE_INNER) — для коротких номеров.
+     * Потом по mobile_numbers (PERSONAL_MOBILE / WORK_PHONE / соответствие
+     * UF_PHONE_INNER → внешний PBX-номер) — для мобильных сотрудников.
+     *
+     * @param string $number
+     * @return array|null Запись пользователя из b24->inner_numbers/mobile_numbers либо null.
+     */
+    private function findMtsEmployee(string $number): ?array
+    {
+        $clean = preg_replace('/\D+/', '', $number);
+        if ($clean === '') {
+            return null;
+        }
+        // Внутренние номера индексируются по UF_PHONE_INNER без нормализации.
+        if (isset($this->b24->inner_numbers[$clean])) {
+            return $this->b24->inner_numbers[$clean];
+        }
+        // Мобильные индексируются по getPhoneIndex (последние 10 цифр).
+        $key = Bitrix24Integration::getPhoneIndex($clean);
+        if ($key !== '' && isset($this->b24->mobile_numbers[$key])) {
+            return $this->b24->mobile_numbers[$key];
+        }
+        return null;
+    }
+
+    /**
+     * Преобразует время старта звонка из mts_cdr в ISO 8601.
+     * synchCdr.php уже применяет gap-сдвиг, поэтому значение в БД хранится
+     * как локальное время PBX. Привязываем DateTime к default-таймзоне
+     * (date_default_timezone_get) — иначе при работе без явной TZ-инфо во
+     * входной строке Bitrix24 может получить смещённое время.
+     *
+     * @param string $start
+     * @return string
+     */
+    private function formatHistoricalDate(string $start): string
+    {
+        if ($start === '') {
+            return '';
+        }
+        try {
+            $tz = new \DateTimeZone(date_default_timezone_get() ?: 'UTC');
+            return (new \DateTime($start, $tz))->format('c');
+        } catch (\Throwable $e) {
+            $this->b24->mainLogger->writeError(
+                ['start' => $start, 'error' => $e->getMessage()],
+                'MTS import: failed to parse start date'
+            );
+            return '';
+        }
+    }
+
     /**
      * Обработка ответа API внешнему скрипту.
      * @param $response
@@ -259,18 +609,26 @@ private function addDataToQueue(array $data): void
                         // Это Метод register
                         $callId = $key;
                     }
-                }elseif(stripos($callId,Bitrix24Integration::API_CALL_REGISTER) === false){
-                    $this->tmpCallsData[$data['linkedid']]['ARG_REGISTER_USER_'.$data['UNIQUEID']] = $data['USER_ID']??'';
-                    $this->tmpCallsData[$data['linkedid']]['ARGS_REGISTER_'.$data['UNIQUEID']] = $this->b24->telephonyExternalCallRegister($data);
-                    $data['CALL_ID'] = $callId;
-                    if($this->needShowCardDirectly($data['USER_ID'])){
-                        $arg = $this->b24->telephonyExternalCallShow($data);
-                    }
                 }else{
                     $this->tmpCallsData[$data['linkedid']]['ARG_REGISTER_USER_'.$data['UNIQUEID']] = $data['USER_ID']??'';
-                    $this->tmpCallsData[$data['linkedid']]['ARGS_REGISTER_'.$data['UNIQUEID']] = $this->b24->telephonyExternalCallRegister($data);
-                    $data['CALL_ID'] = '$result['.$callId.'][CALL_ID]';
-                    if($this->needShowCardDirectly($data['USER_ID'])){
+                    // Политика "один register на звонок":
+                    //   - очередь (звонок ещё не отвечен): доп. register НЕ создаём,
+                    //     для каждого участника очереди открываем общую карточку
+                    //     через telephony.externalcall.show на оригинальном CALL_ID;
+                    //   - переадресация (b24-answered-<linkedid> уже стоит — был
+                    //     action_dial_answer): создаём дополнительный register, чтобы
+                    //     у плеча-получателя перевода в B24 появилась СВОЯ карточка
+                    //     звонка со своим USER_ID/DURATION/записью. Этот register
+                    //     попадает в q_req только в момент finish'а через ARGS_REGISTER
+                    //     в Lib/Bitrix24Integration::telephonyExternalCallFinish.
+                    $isTransfer = !empty($this->b24->getCache('b24-answered-' . $data['linkedid']));
+                    if ($isTransfer) {
+                        $this->tmpCallsData[$data['linkedid']]['ARGS_REGISTER_'.$data['UNIQUEID']] = $this->b24->telephonyExternalCallRegister($data);
+                    }
+                    $data['CALL_ID'] = $this->b24->resolveBatchCallId((string)$callId);
+                    // Страховка: show с пустым USER_ID не имеет получателя
+                    // (аналогичная защита есть в ветке action_hangup_chan).
+                    if(!empty($data['USER_ID']) && $this->needShowCardDirectly($data['USER_ID'])){
                         $arg = $this->b24->telephonyExternalCallShow($data);
                     }
                 }
@@ -291,8 +649,74 @@ private function addDataToQueue(array $data): void
                 $this->q_req = array_merge($this->q_req, $arg);
             }
         } elseif ('action_dial_answer' === $data['action']) {
+            // Помечаем звонок как реально отвеченный оператором.
+            // Это блокирует orphan-finish'и (USER_ID=responsibleMissedCalls,
+            // GLOBAL_STATUS=NOANSWER) от IVR/queue-leg'ов, которые AMI-воркер
+            // шлёт в той же серии CDR — без этого они приходят в B24 раньше
+            // ANSWERED-finish'а реального оператора и переписывают статус
+            // звонка на «пропущен», а ответственного — на «ответственного
+            // за пропущенные» (см. AMI:actionCompleteCdr ветка isOrphanIncoming).
+            //
+            // Маркер хранится в Redis, а не в $tmpCallsData: при крашах
+            // HTTP-воркера (см. OOM-фиксы 0bae398) очередь Beanstalk переживает
+            // рестарт, RAM — нет. Без persistence orphan-finish после рестарта
+            // прошёл бы фильтр и баг возродился.
+            //
+            // TTL = 3 часа: маркер должен пережить весь разговор до hangup'а.
+            // 3 часа покрывают практически все реальные кейсы (конференции,
+            // длинная техподдержка); звонки длиннее — редкое исключение,
+            // в нём фильтр перестанет работать, но критичной регрессии нет:
+            // вернётся прежнее поведение. Asterisk-linkedid (unixtime.seq)
+            // не переиспользуется, «протекание» в чужой звонок исключено.
+            $this->b24->saveCache('b24-answered-' . $data['linkedid'], true, 10800);
             $tmpArr = [];
             $userId = $this->tmpCallsData[$data['linkedid']]['ARG_REGISTER_USER_'.$data['UNIQUEID']]??'';
+
+            // Очередь: при ответе одного оператора у всех остальных участников,
+            // которым через register (TYPE=2/первое плечо) и show открыта общая
+            // карточка звонка, она должна сразу закрыться. Раньше hide шёл
+            // только в action_hangup_chan канала каждого участника — в очередях,
+            // где Asterisk не успевал прислать CANCEL → hangup_chan, карточка
+            // у не-ответивших висела до самого конца звонка.
+            //
+            // Маркер b24-hide-others-<linkedid> защищает от повторной рассылки
+            // при втором action_dial_answer (после перевода ответит ещё один
+            // сотрудник, но «остальных» в очереди скрывать второй раз не надо).
+            $linkedCallId = $this->tmpCallsData[$data['linkedid']]['CALL_ID'] ?? '';
+            $hideOthersKey = 'b24-hide-others-' . $data['linkedid'];
+            if (!empty($linkedCallId) && !$this->b24->getCache($hideOthersKey)) {
+                $resolvedCallId   = $this->b24->resolveBatchCallId((string)$linkedCallId);
+                $answeredUniqueId = (string)($data['UNIQUEID'] ?? '');
+                $hiddenUsers      = [];
+                $hideEmitted      = false;
+                foreach ($this->tmpCallsData[$data['linkedid']] as $tKey => $tValue) {
+                    if (strpos($tKey, 'ARG_REGISTER_USER_') !== 0) {
+                        continue;
+                    }
+                    $uid = substr($tKey, strlen('ARG_REGISTER_USER_'));
+                    if ($uid === $answeredUniqueId) {
+                        continue; // плечо, которое только что ответило
+                    }
+                    $regUserId = (string)$tValue;
+                    if ($regUserId === '' || $regUserId === (string)$userId) {
+                        continue; // тот же сотрудник по другому UNIQUEID — не скрываем
+                    }
+                    if (isset($hiddenUsers[$regUserId])) {
+                        continue;
+                    }
+                    $hiddenUsers[$regUserId] = true;
+                    $tmpArr[] = $this->b24->telephonyExternalCallHide([
+                        'CALL_ID'  => $resolvedCallId,
+                        'USER_ID'  => (int)$regUserId,
+                        'linkedid' => $data['linkedid'],
+                    ]);
+                    $hideEmitted = true;
+                }
+                if ($hideEmitted) {
+                    $this->b24->saveCache($hideOthersKey, true, 10800);
+                }
+            }
+
             $dealId = '';
             $leadId = '';
             $filter = [
@@ -339,12 +763,80 @@ private function addDataToQueue(array $data): void
                 $this->q_req = array_merge($this->q_req, ...$tmpArr);
             }
         } elseif ('telephonyExternalCallFinish' === $data['action']) {
-            [$arg,$finishKey] = $this->b24->telephonyExternalCallFinish($data, $this->tmpCallsData);
-            $this->q_req = array_merge($this->q_req, $arg);
+            // Политика отправки finish в B24 для входящих звонков:
+            //
+            // 1) Если звонок В ЦЕЛОМ был отвечен сотрудником (action_dial_answer
+            //    пришёл хотя бы для одного плеча → маркер b24-answered-<linkedid>):
+            //    в B24 должны попасть ТОЛЬКО плечи, которые сами ответили
+            //    (disposition=ANSWERED). Любое плечо с disposition!=ANSWERED
+            //    (IVR/queue-orphan, второй оператор-перевод, который не взял
+            //    трубку) — отбрасываем целиком: register для него тоже не
+            //    уйдёт (он лежит в tmpCallsData[ARGS_REGISTER_<UNIQUEID>]
+            //    и попадает в q_req только из telephonyExternalCallFinish).
+            //    Без этого в журнале телефонии B24 появлялись «фантомные»
+            //    карточки с DURATION=0 и неверным RESPONSIBLE_ID, перетирающие
+            //    реальный статус. См. кейсы 79245067790@2026-05-08 12:52,
+            //    79636988999@16:36 и 79101755605@2026-05-13 10:01.
+            //
+            // 2) Если звонок ни один сотрудник не отвечал — отправляем РОВНО
+            //    ОДИН finish на linkedid (на первое NOANSWER-плечо), остальные
+            //    плечи того же звонка дедуплицируются по
+            //    'b24-missed-finish-<linkedid>'. Иначе в B24 на один MikoPBX-
+            //    звонок плодились бы N карточек «пропущенных».
+            //
+            // Маркеры в Redis (через b24->getCache/saveCache) переживают
+            // рестарт HTTP-воркера и согласованы с persistent Beanstalk-очередью.
+            $alreadyAnswered = !empty($this->b24->getCache('b24-answered-' . $data['linkedid']));
+            $disposition     = (string)($data['disposition']    ?? '');
+            $globalStatus    = (string)($data['GLOBAL_STATUS']  ?? '');
+            $isLegAnswered   = ($disposition === 'ANSWERED');
+            $missedDedupKey  = 'b24-missed-finish-' . $data['linkedid'];
+
+            $skipReason = '';
+            if ($alreadyAnswered && !$isLegAnswered) {
+                // Случай (1): звонок ответил другой leg, этот — лишний.
+                $skipReason = 'call was answered, this leg disp='.$disposition.' global='.$globalStatus;
+            } elseif (!$isLegAnswered && $this->b24->getCache($missedDedupKey)) {
+                // Случай (2): missed-finish для linkedid уже отправлен.
+                $skipReason = 'missed finish already sent for linkedid (one per call)';
+            }
 
-            if(!empty($finishKey)){
-                $arg = $this->b24->crmActivityUpdate('$result['.$finishKey.'][CRM_ACTIVITY_ID]', $data['linkedid'], $data['linkedid']);
+            if ($skipReason !== '') {
+                $this->b24->mainLogger->writeInfo(
+                    $data,
+                    "Skip leg finish ($skipReason): {$data['linkedid']}"
+                );
+            } else {
+                if (!$isLegAnswered) {
+                    // Маркер для последующих missed-плеч того же звонка.
+                    // TTL 3 часа — как у b24-answered (одна и та же логическая
+                    // «продолжительность звонка»).
+                    $this->b24->saveCache($missedDedupKey, true, 10800);
+                }
+                [$arg,$finishKey] = $this->b24->telephonyExternalCallFinish($data, $this->tmpCallsData);
                 $this->q_req = array_merge($this->q_req, $arg);
+
+                if(!empty($finishKey)){
+                    // Обогащаем DESCRIPTION плеча, чтобы при переводе разные
+                    // карточки звонка в B24 (per-leg, см. Bitrix24Integration::
+                    // telephonyExternalCallFinish: ARGS_REGISTER + finishOneKey)
+                    // визуально различались: видно, какой внутренний номер
+                    // обработал плечо, сколько говорил и чем закончилось.
+                    $descParts = [(string)$data['linkedid']];
+                    $inner     = (string)($data['USER_PHONE_INNER'] ?? '');
+                    $duration  = (string)($data['DURATION'] ?? '');
+                    $dispo     = (string)($data['disposition']  ?? '');
+                    if ($inner !== '' || $duration !== '' || $dispo !== '') {
+                        $legParts = [];
+                        if ($inner    !== '') { $legParts[] = "leg=$inner"; }
+                        if ($duration !== '') { $legParts[] = "{$duration}s"; }
+                        if ($dispo    !== '') { $legParts[] = $dispo; }
+                        $descParts[] = implode(', ', $legParts);
+                    }
+                    $description = implode(' | ', $descParts);
+                    $arg = $this->b24->crmActivityUpdate('$result['.$finishKey.'][CRM_ACTIVITY_ID]', $data['linkedid'], $description);
+                    $this->q_req = array_merge($this->q_req, $arg);
+                }
             }
         }else{
             $this->b24->mainLogger->writeInfo($data, "The event handler was not found ($data[linkedid])");