mikopbx / Core

src/Core/Workers/WorkerCdr.php

Spacing +16 added lines, -16 removed lines

@@ -23,7 +23,7 @@ 
 
     public const SELECT_CDR_TUBE = 'select_cdr_tube';
     public const UPDATE_CDR_TUBE = 'update_cdr_tube';
-    protected int $maxProc=1;
+    protected int $maxProc = 1;
 
 
     private BeanstalkClient $client_queue;
@@ -93,12 +93,12 @@ 
         $result = json_decode($result_data, true);
         if (file_exists($result)) {
             $file_data = json_decode(file_get_contents($result), true);
-            if(!is_dir($result)){
+            if (!is_dir($result)) {
                 Util::mwExec("rm -rf {$result}");
             }
             $result = $file_data;
         }
-        if ( ! is_array($result) && ! is_object($result)) {
+        if (!is_array($result) && !is_object($result)) {
             return;
         }
         if (count($result) < 1) {
@@ -115,7 +115,7 @@ 
             if (trim($row['recordingfile']) !== '') {
                 // Если каналов не существует с ID, то можно удалить временные файлы.
                 $p_info = pathinfo($row['recordingfile']);
-                $fname  = $p_info['dirname'] . '/' . $p_info['filename'] . '.wav';
+                $fname  = $p_info['dirname'].'/'.$p_info['filename'].'.wav';
                 if (file_exists($fname) && !is_dir($fname)) {
                     Util::mwExec("rm -rf {$fname}");
                 }
@@ -139,19 +139,19 @@ 
                 $row['answer'] = '';
                 $billsec       = 0;
 
-                if ( ! empty($row['recordingfile'])) {
+                if (!empty($row['recordingfile'])) {
                     $p_info    = pathinfo($row['recordingfile']);
                     $file_list = [
-                        $p_info['dirname'] . '/' . $p_info['filename'] . '.mp3',
-                        $p_info['dirname'] . '/' . $p_info['filename'] . '.wav',
-                        $p_info['dirname'] . '/' . $p_info['filename'] . '_in.wav',
-                        $p_info['dirname'] . '/' . $p_info['filename'] . '_out.wav',
+                        $p_info['dirname'].'/'.$p_info['filename'].'.mp3',
+                        $p_info['dirname'].'/'.$p_info['filename'].'.wav',
+                        $p_info['dirname'].'/'.$p_info['filename'].'_in.wav',
+                        $p_info['dirname'].'/'.$p_info['filename'].'_out.wav',
                     ];
                     foreach ($file_list as $file) {
-                        if ( ! file_exists($file)) {
+                        if (!file_exists($file)) {
                             continue;
                         }
-                        if(!is_dir($file)){
+                        if (!is_dir($file)) {
                             Util::mwExec("rm -rf {$file}");
                         }
                     }
@@ -162,9 +162,9 @@ 
                 if (file_exists($row['recordingfile']) && !is_dir($row['recordingfile'])) {
                     Util::mwExec("rm -rf {$row['recordingfile']}");
                 }
-            } elseif (  ! empty($row['recordingfile']) &&
-                        ! file_exists(Util::trimExtensionForFile($row['recordingfile']) . 'wav') &&
-                        ! file_exists( $row['recordingfile']) ) {
+            } elseif (!empty($row['recordingfile']) &&
+                        !file_exists(Util::trimExtensionForFile($row['recordingfile']).'wav') &&
+                        !file_exists($row['recordingfile'])) {
                 /** @var CallDetailRecordsTmp $rec_data */
                 $rec_data = CallDetailRecordsTmp::findFirst(
                     "linkedid='{$row['linkedid']}' AND dst_chan='{$row['dst_chan']}'"
@@ -213,7 +213,7 @@ 
      */
     private function getActiveIdChannels(): array
     {
-        $am           = Util::getAstManager('off');
+        $am = Util::getAstManager('off');
         return $am->GetChannels(true);
     }
 
@@ -228,7 +228,7 @@ 
             $this->no_answered_calls[$row['linkedid']]['NOANSWER'] = false;
             return;
         }
-        if ( ! array_key_exists($row['dst_num'], $this->internal_numbers)) {
+        if (!array_key_exists($row['dst_num'], $this->internal_numbers)) {
             // dst_num - не является номером сотрудника. Это исходящий.
             return;
         }