MikoPBX\AdminCabinet\Controllers\CallDetailRecordsController::getNewRecordsAction()

Complexity

Conditions	24
Paths	15450

Size

Total Lines	135
Code Lines	98

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function getNewRecordsAction(): void
    {
        $currentPage                 = $this->request->getPost('draw');
        $position                    = $this->request->getPost('start');
        $recordsPerPage              = $this->request->getPost('length');
        $searchPhrase                = $this->request->getPost('search');
        $this->view->draw            = $currentPage;
        $this->view->recordsTotal    = 0;
        $this->view->recordsFiltered = 0;
        $this->view->data            = [];

        // Посчитаем количество уникальных звонков без учета фильтров
        $parameters = [];
        $parameters['columns'] = 'COUNT(DISTINCT(linkedid)) as rows';
        $recordsTotalReq       = CallDetailRecords::findFirst($parameters);
        if ($recordsTotalReq) {
            $recordsTotal             = $recordsTotalReq->rows;
            $this->view->recordsTotal = $recordsTotal;
        } else {
            return;
        }
        // Посчитаем количество уникальных звонков с учетом фильтров
        if ( ! empty($searchPhrase['value'])) {
            $this->prepareConditionsForSearchPhrases($searchPhrase['value'], $parameters);
            // Если мы не смогли расшифровать строку запроса вернем пустой результата
            if (empty($parameters['conditions'])) {
                return;
            }
        }
        $recordsFilteredReq = CallDetailRecords::findFirst($parameters);
        if ($recordsFilteredReq) {
            $recordsFiltered             = $recordsFilteredReq->rows;
            $this->view->recordsFiltered = $recordsFiltered;
        }

        // Найдем все LinkedID подходящих под заданный фильтр
        $parameters['columns'] = 'DISTINCT(linkedid) as linkedid';
        $parameters['order']   = ['start desc'];
        $parameters['limit']   = $recordsPerPage;
        $parameters['offset']  = $position;

        $selectedLinkedIds = CallDetailRecords::find($parameters);
        $arrIDS            = [];
        foreach ($selectedLinkedIds as $item) {
            $arrIDS[] = $item->linkedid;
        }

        if (count($arrIDS) === 0) {
            return;
        }

        // Получим все детальные записи для обработки и склеивания
        if (count($arrIDS) === 1) {
            $parameters = [
                'conditions' => 'linkedid = :ids:',
                'columns'    => 'id, disposition, start, src_num, dst_num, billsec, recordingfile, did, dst_chan, linkedid, is_app',
                'bind'       => [
                    'ids' => $arrIDS[0],
                ],
                'order'      => ['linkedid desc', 'start asc'],
            ];
        } else {
            $parameters = [
                'conditions' => 'linkedid IN ({ids:array})',
                'columns'    => 'id, disposition, start, src_num, dst_num, billsec, recordingfile, did, dst_chan, linkedid, is_app',
                'bind'       => [
                    'ids' => $arrIDS,
                ],
                'order'      => ['linkedid desc', 'start asc'],
            ];
        }

        $selectedRecords = CallDetailRecords::find($parameters);

        $arrCdr = [];

        $objectLinkedCallRecord = (object)[
            'linkedid'    => '',
            'disposition' => '',
            'start'       => '',
            'src_num'     => '',
            'dst_num'     => '',
            'billsec'     => 0,
            'answered'    => [],
            'detail'      => [],
        ];

        foreach ($selectedRecords as $record) {
            if ( ! array_key_exists($record->linkedid, $arrCdr)) {
                $arrCdr[$record->linkedid] = clone $objectLinkedCallRecord;
            }
            if ($record->is_app !== '1'
                && $record->billsec > 0
                && ($record->disposition === 'ANSWER' || $record->disposition === 'ANSWERED')) {
                $disposition = 'ANSWERED';
            } else {
                $disposition = 'NOANSWER';
            }
            $linkedRecord              = $arrCdr[$record->linkedid];
            $linkedRecord->linkedid    = $record->linkedid;
            $linkedRecord->disposition = $linkedRecord->disposition !== 'ANSWERED' ? $disposition : 'ANSWERED';
            $linkedRecord->start       = $linkedRecord->start === '' ? $record->start : $linkedRecord->start;
            $linkedRecord->src_num     = $linkedRecord->src_num === '' ? $record->src_num : $linkedRecord->src_num;
            if ( ! empty($record->did)) {
                $linkedRecord->dst_num = $record->did;
            } else {
                $linkedRecord->dst_num = $linkedRecord->dst_num === '' ? $record->dst_num : $linkedRecord->dst_num;
            }
            $linkedRecord->billsec += (int)$record->billsec;
            if ($disposition === 'ANSWERED') {
                $linkedRecord->answered[] = [
                    'id'            => $record->id,
                    'src_num'       => $record->src_num,
                    'dst_num'       => $record->dst_num,
                    'recordingfile' => $record->recordingfile,
                ];
            }
            $linkedRecord->detail[] = $record;
        }
        $output = [];
        foreach ($arrCdr as $cdr) {
            $timing   = gmdate($cdr->billsec < 3600 ? 'i:s' : 'G:i:s', $cdr->billsec);
            $output[] = [
                date('d-m-Y H:i:s', strtotime($cdr->start)),
                $cdr->src_num,
                $cdr->dst_num,
                $timing === '00:00' ? '' : $timing,
                $cdr->answered,
                $cdr->disposition,
                'DT_RowId'    => $cdr->linkedid,
                'DT_RowClass' => 'NOANSWER' === $cdr->disposition ? 'ui negative' : 'detailed',
            ];
        }

        $this->view->data = $output;
    }
}