ActionHangupChan::hangupChanCheckSipTrtansfer() - Code Metrics - Inspection of "#461 Добавил настройки записи разговоров. Возможно..." - mikopbx/Core - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — develop ( dcb728...9b177f )

by Портнов
created 2023-02-22 13:38 UTC
ActionHangupChan::hangupChanCheckSipTrtansfer() C

↳ Parent: ActionHangupChan
Complexity

Conditions	15
Paths	69
Size

Total Lines	56
Code Lines	38
Duplication

Lines	0
Ratio	0 %
Importance

Changes	1
Bugs	0	Features	0
Metric	Value
eloc	38
dl	0
loc	56
rs	5.9166
c	1
b	0
f	0
cc	15
nc	69
nop	3
How to fix Long Method Complexity

<?php


namespace MikoPBX\Core\Workers\Libs\WorkerCallEvents;


use MikoPBX\Common\Models\CallDetailRecordsTmp;
use MikoPBX\Core\Asterisk\Configs\VoiceMailConf;
use MikoPBX\Core\System\Util;
use MikoPBX\Core\Workers\WorkerCallEvents;

class ActionHangupChan {

    public static function execute(WorkerCallEvents $worker, $data):void
    {
        $worker->removeActiveChan($data['agi_channel']);

        $channels       = [];
        $transfer_calls = [];

        self::hangupChanEndCalls($worker, $data, $transfer_calls, $channels);
        // Проверим, возможно это обычный трансфер.
        CreateRowTransfer::execute($worker, 'hangup_chan', $data, $transfer_calls);
        self::hangupChanCheckSipTrtansfer($worker, $data, $channels);

        // Очистим память.
        if(isset($worker->checkChanHangupTransfer[$data['agi_channel']])){
            unset($worker->checkChanHangupTransfer[$data['agi_channel']]);
        }
        if(isset($worker->mixMonitorChannels[$data['agi_channel']])){
            unset($worker->mixMonitorChannels[$data['agi_channel']]);
        }
    }

    /**
     * Обработка события уничтожения канала.
     * @param       $worker
     * @param array $data
     * @param array $transfer_calls
     * @param array $channels
     */
    private static function hangupChanEndCalls($worker, array $data, array &$transfer_calls, array &$channels):void{
        $filter         = [
            'linkedid=:linkedid: AND endtime = ""',
            'bind' => [
                'linkedid' => $data['linkedid'],
            ],
        ];
        /** @var CallDetailRecordsTmp $m_data */
        /** @var CallDetailRecordsTmp $row */
        $m_data    = CallDetailRecordsTmp::find($filter);
        $countRows = 0;
        $transferCdrAnswered = true;
        foreach ($m_data as $row) {
            if($row->dst_chan !== $data['agi_channel'] && $data['agi_channel'] !== $row->src_chan){
                continue;
            }
            $countRows++;
            $vmState = $data['VMSTATUS']??'';
            if($row->dst_num === VoiceMailConf::VOICE_MAIL_EXT && $vmState !== 'FAILED'){
                // Этот вызов будет заверщен событием voicemail_end
                continue;
            }
            if ($row->transfer === '1' && !empty($row->dst_chan)) {
                // Обязательно канал назначения не должен быть пустым.
                // Иначе это не переадресация.
                $transfer_calls[] = $row->toArray();
                $transferCdrAnswered = min($transferCdrAnswered, empty($row->answer));
            }
        }
        foreach ($m_data as $row) {
            if($row->dst_chan !== $data['agi_channel'] && $data['agi_channel'] !== $row->src_chan){
                continue;
            }
            $vmState = $data['VMSTATUS']??'';
            if($row->dst_num === VoiceMailConf::VOICE_MAIL_EXT && $vmState !== 'FAILED'){
                // Этот вызов будет заверщен событием voicemail_end
                continue;
            }
            if ($row->dialstatus === 'ORIGINATE') {
                $row->writeAttribute('dialstatus', '');
                if($row->answer === ''){
                    $newId = $row->linkedid.'_'.$row->src_num.'_'.substr($row->src_chan, strpos($row->src_chan,'-') +1);
                    $row->writeAttribute('UNIQUEID', $newId);
                }
            }
            $row->writeAttribute('endtime', $data['end']);
            $row->writeAttribute('transfer', 0);
            if($transferCdrAnswered === false && count($transfer_calls) === 2){
                // Завершение вызова при консультативной переадресации. Инициатор положил трубку до ответа dst.
                $row->writeAttribute('a_transfer', 1);
            }
            if ($data['dialstatus'] !== '') {
                if ($data['dialstatus'] === 'ORIGINATE') {
                    $row->writeAttribute('dst_chan', '');
                }
                $row->writeAttribute('dialstatus', $data['dialstatus']);
            }
            $res = $row->update();
            if ( ! $res) {
                Util::sysLogMsg('Action_hangup_chan', implode(' ', $row->getMessages()), LOG_DEBUG);
            }

            if ($row->src_chan !== $data['agi_channel']) {
                $channels[] = [
                    'chan' => $row->src_chan,
                    'did'  => $row->did,
                    'num'  => $row->src_num,
                    'out'  => true,
                ];
            } else {
                $worker->StopMixMonitor($row->dst_chan, 'hangupChanEndCalls');
                $channels[] = [
                    'chan' => $row->dst_chan,
                    'did'  => $row->did,
                    'num'  => $row->dst_num,
                    'out'  => false,
                ];
            }
        }

        self::regMissedCall($data, $countRows);
    }

    /**
     * Если hangup_chan единственный event.
     * @param array $data
     * @param int   $tmpCdrCount
     */
    private static function regMissedCall(array $data, int $tmpCdrCount):void
    {
        if($tmpCdrCount > 0 || $data['did'] === ''){
            return;
        }
        if(stripos($data['agi_channel'], 'local/') !== false){
            // Локальные каналы не логируем как пропущенные.
            return;
        }
        $filter         = [
            'linkedid=:linkedid: AND (src_chan=:src_chan: OR dst_chan=:dst_chan:)',
            'bind' => [
                'linkedid' => $data['linkedid'],
                'src_chan' => $data['agi_channel'],
                'dst_chan' => $data['agi_channel'],
            ],
        ];
        $m_data = CallDetailRecordsTmp::findFirst($filter);
        if($m_data !== null){
            return;
        }
        if(empty($data['UNIQUEID'])){
            $data['UNIQUEID'] = $data['agi_threadid'];
        }
        $time = (float)str_replace('mikopbx-', '', $data['linkedid']);
        $data['start']   = date("Y-m-d H:i:s.v", $time);
        $data['start']   = date("Y-m-d H:i:s.v", /** @scrutinizer ignore-type */ $time);
        $data['endtime'] = $data['end'];

        InsertDataToDB::execute($data);
    }

    /**
     * Проверяем на SIP трансфер.
     * @param WorkerCallEvents $worker
     * @param $data
     * @param $channels
     */
    private static function hangupChanCheckSipTrtansfer(WorkerCallEvents $worker, $data, $channels):void{
        $not_local = (stripos($data['agi_channel'], 'local/') === false);
        if($not_local === false || $data['OLD_LINKEDID'] !== $data['linkedid']) {
            return;
        }
        $am = Util::getAstManager('off');
        $active_chans = $am->GetChannels(false);
        // Намек на SIP трансфер.
        foreach ($channels as $data_chan) {
            if ( ! in_array($data_chan['chan'], $active_chans, true)) {
                // Вызов уже завершен. Не интересно.
                continue;
            }
            $BRIDGEPEER = $am->GetVar($data_chan['chan'], 'BRIDGEPEER', null, false);
            if ( !is_string($BRIDGEPEER) || ! in_array($BRIDGEPEER, $active_chans, true)) {
                // Вызов уже завершен. Не интересно.
                continue;
            }

            $linkedid = $am->GetVar($data_chan['chan'], 'CHANNEL(linkedid)', null, false);
            if ( empty($linkedid) || $linkedid === $data['linkedid']) {
                continue;
            }

            $CALLERID = $am->GetVar($BRIDGEPEER, 'CALLERID(num)', null, false);
            $n_data['action']        = 'sip_transfer';
            $n_data['src_chan']      = $data_chan['out'] ? $data_chan['chan'] : $BRIDGEPEER;
            $n_data['src_num']       = $data_chan['out'] ? $data_chan['num'] : $CALLERID;
            $n_data['dst_chan']      = $data_chan['out'] ? $BRIDGEPEER : $data_chan['chan'];
            $n_data['dst_num']       = $data_chan['out'] ? $CALLERID : $data_chan['num'];
            $n_data['start']         = date('Y-m-d H:i:s');
            $n_data['answer']        = date('Y-m-d H:i:s');
            $n_data['linkedid']      = $linkedid;
            $n_data['UNIQUEID']      = $data['linkedid'] . Util::generateRandomString();
            $n_data['transfer']      = '0';
            if($worker->enableMonitor($n_data['src_num']??'', $n_data['dst_num']??'')){
                $n_data['recordingfile'] = $worker->MixMonitor($n_data['dst_chan'], $n_data['UNIQUEID'], null, null, 'hangupChanCheckSipTrtansfer');
            }
            $n_data['did']           = $data_chan['did'];

            InsertDataToDB::execute($n_data);
            $filter = [
                'linkedid=:linkedid:',
                'bind' => ['linkedid' => $data['linkedid']],
            ];
            $m_data = CallDetailRecordsTmp::find($filter);
            foreach ($m_data as $row) {
                $row->writeAttribute('linkedid', $linkedid);
                $row->save();
            }

            /**
             * Отправка UserEvent
             */
            $AgiData = base64_encode(json_encode($n_data));
            $am->UserEvent('CdrConnector', ['AgiData' => $AgiData]);
        } // Обход текущих каналов.
    }
}
mikopbx / Core

Push — develop ( dcb728...9b177f )

ActionHangupChan::hangupChanCheckSipTrtansfer() C

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like
