ActionHangupChan::hangupChanCheckSipTrtansfer() - Code Metrics - Inspection of "Merge branch 'develop' of https://github.com/mikop..." - mikopbx/Core - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — develop ( d5179e...bede24 )

by Портнов

created 2021-01-20 14:33 UTC

ActionHangupChan::hangupChanCheckSipTrtansfer() C

↳ Parent: ActionHangupChan

Complexity

Conditions	14
Paths	37

Size

Total Lines	55
Code Lines	38

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
eloc	38
c	1
b	0
f	0
dl	0
loc	55
rs	6.2666
cc	14
nc	37
nop	3

How to fix Long Method Complexity

<?php


namespace MikoPBX\Core\Workers\Libs\WorkerCallEvents;


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

class ActionHangupChan {

    public static function execute(WorkerCallEvents $worker, $data):void
    {
        $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 = "" AND (src_chan=:src_chan: OR dst_chan=:dst_chan:)',
            'bind' => [
                'linkedid' => $data['linkedid'],
                'src_chan' => $data['agi_channel'],
                'dst_chan' => $data['agi_channel'],
            ],
        ];
        /** @var CallDetailRecordsTmp $m_data */
        /** @var CallDetailRecordsTmp $row */
        $m_data = CallDetailRecordsTmp::find($filter);
        foreach ($m_data as $row) {
            if ($row->transfer == 1) {
                $transfer_calls[] = $row->toArray();
            }
            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 ($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);
                $channels[] = [
                    'chan' => $row->dst_chan,
                    'did'  => $row->did,
                    'num'  => $row->dst_num,
                    'out'  => false,
                ];
            }
        }
    }

    /**
     * Проверяем на SIP трансфер.
     * @param $data
     * @param $channels
     */
    private static function hangupChanCheckSipTrtansfer($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';
            $n_data['recordingfile'] = $worker->MixMonitor($n_data['dst_chan'], $n_data['UNIQUEID']);
            $n_data['did']           = $data_chan['did'];

            Util::logMsgDb('call_events', json_encode($n_data));
            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]);
        } // Обход текущих каналов.
    }
}

1			<?php
2
3
4			namespace MikoPBX\Core\Workers\Libs\WorkerCallEvents;
5
6
7			use MikoPBX\Common\Models\CallDetailRecordsTmp;
8			use MikoPBX\Core\System\Util;
9			use MikoPBX\Core\Workers\WorkerCallEvents;
10
11			class ActionHangupChan {
12
13			public static function execute(WorkerCallEvents $worker, $data):void
14			{
15			$channels = [];
16			$transfer_calls = [];
17
18			self::hangupChanEndCalls($worker, $data, $transfer_calls, $channels);
19			// Проверим, возможно это обычный трансфер.
20			CreateRowTransfer::execute($worker, 'hangup_chan', $data, $transfer_calls);
21			self::hangupChanCheckSipTrtansfer($worker, $data, $channels);
22
23			// Очистим память.
24			if(isset($worker->checkChanHangupTransfer[$data['agi_channel']])){
25			unset($worker->checkChanHangupTransfer[$data['agi_channel']]);
26			}
27			if(isset($worker->mixMonitorChannels[$data['agi_channel']])){
28			unset($worker->mixMonitorChannels[$data['agi_channel']]);
29			}
30
31			}
32
33			/**
34			* Обработка события уничтожения канала.
35			* @param $worker
36			* @param array $data
37			* @param array $transfer_calls
38			* @param array $channels
39			*/
40			private static function hangupChanEndCalls($worker, array $data, array &$transfer_calls, array &$channels):void{
41			$filter = [
42			'linkedid=:linkedid: AND endtime = "" AND (src_chan=:src_chan: OR dst_chan=:dst_chan:)',
43			'bind' => [
44			'linkedid' => $data['linkedid'],
45			'src_chan' => $data['agi_channel'],
46			'dst_chan' => $data['agi_channel'],
47			],
48			];
49			/** @var CallDetailRecordsTmp $m_data */
50			/** @var CallDetailRecordsTmp $row */
51			$m_data = CallDetailRecordsTmp::find($filter);
52			foreach ($m_data as $row) {
53			if ($row->transfer == 1) {
54			$transfer_calls[] = $row->toArray();
55			}
56			if ($row->dialstatus === 'ORIGINATE') {
57			$row->writeAttribute('dialstatus', '');
58			if($row->answer === ''){
59			$newId = $row->linkedid.'_'.$row->src_num.'_'.substr($row->src_chan, strpos($row->src_chan,'-') +1);
60			$row->writeAttribute('UNIQUEID', $newId);
61			}
62			}
63			$row->writeAttribute('endtime', $data['end']);
64			$row->writeAttribute('transfer', 0);
65			if ($data['dialstatus'] !== '') {
66			if ($data['dialstatus'] === 'ORIGINATE') {
67			$row->writeAttribute('dst_chan', '');
68			}
69			$row->writeAttribute('dialstatus', $data['dialstatus']);
70			}
71			$res = $row->update();
72			if ( ! $res) {
73			Util::sysLogMsg('Action_hangup_chan', implode(' ', $row->getMessages()), LOG_DEBUG);
74			}
75
76			if ($row->src_chan !== $data['agi_channel']) {
77			$channels[] = [
78			'chan' => $row->src_chan,
79			'did' => $row->did,
80			'num' => $row->src_num,
81			'out' => true,
82			];
83			} else {
84			$worker->StopMixMonitor($row->dst_chan);
85			$channels[] = [
86			'chan' => $row->dst_chan,
87			'did' => $row->did,
88			'num' => $row->dst_num,
89			'out' => false,
90			];
91			}
92			}
93			}
94
95			/**
96			* Проверяем на SIP трансфер.
97			* @param $data
98			* @param $channels
99			*/
100			private static function hangupChanCheckSipTrtansfer($worker, $data, $channels):void{
101			$not_local = (stripos($data['agi_channel'], 'local/') === false);
102			if($not_local === false \|\| $data['OLD_LINKEDID'] !== $data['linkedid']) {
103			return;
104			}
105			$am = Util::getAstManager('off');
106			$active_chans = $am->GetChannels(false);
107			// Намек на SIP трансфер.
108			foreach ($channels as $data_chan) {
109			if ( ! in_array($data_chan['chan'], $active_chans, true)) {
110			// Вызов уже завершен. Не интересно.
111			continue;
112			}
113			$BRIDGEPEER = $am->GetVar($data_chan['chan'], 'BRIDGEPEER', null, false);
114			if ( !is_string($BRIDGEPEER) \|\| ! in_array($BRIDGEPEER, $active_chans, true)) {
115			// Вызов уже завершен. Не интересно.
116			continue;
117			}
118
119			$linkedid = $am->GetVar($data_chan['chan'], 'CHANNEL(linkedid)', null, false);
120			if ( empty($linkedid) \|\| $linkedid === $data['linkedid']) {
121			continue;
122			}
123
124			$CALLERID = $am->GetVar($BRIDGEPEER, 'CALLERID(num)', null, false);
125			$n_data['action'] = 'sip_transfer';
126			$n_data['src_chan'] = $data_chan['out'] ? $data_chan['chan'] : $BRIDGEPEER;
127			$n_data['src_num'] = $data_chan['out'] ? $data_chan['num'] : $CALLERID;
128			$n_data['dst_chan'] = $data_chan['out'] ? $BRIDGEPEER : $data_chan['chan'];
129			$n_data['dst_num'] = $data_chan['out'] ? $CALLERID : $data_chan['num'];
130			$n_data['start'] = date('Y-m-d H:i:s');
131			$n_data['answer'] = date('Y-m-d H:i:s');
132			$n_data['linkedid'] = $linkedid;
133			$n_data['UNIQUEID'] = $data['linkedid'] . Util::generateRandomString();
134			$n_data['transfer'] = '0';
135			$n_data['recordingfile'] = $worker->MixMonitor($n_data['dst_chan'], $n_data['UNIQUEID']);
136			$n_data['did'] = $data_chan['did'];
137
138			Util::logMsgDb('call_events', json_encode($n_data));
139			InsertDataToDB::execute($n_data);
140			$filter = [
141			'linkedid=:linkedid:',
142			'bind' => ['linkedid' => $data['linkedid']],
143			];
144			$m_data = CallDetailRecordsTmp::find($filter);
145			foreach ($m_data as $row) {
146			$row->writeAttribute('linkedid', $linkedid);
147			$row->save();
148			}
149
150			/**
151			* Отправка UserEvent
152			*/
153			$AgiData = base64_encode(json_encode($n_data));
154			$am->UserEvent('CdrConnector', ['AgiData' => $AgiData]);
155			} // Обход текущих каналов.
156			}
157			}

mikopbx / Core

Push — develop ( d5179e...bede24 )

ActionHangupChan::hangupChanCheckSipTrtansfer() C

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like