#802 поправил ошибку в обработке таблицы cdr. Зависали строки при пер…

…еадресации на недоступный номер телефона.
mikopbx · Nov 8, 2024 · 55a91ee · 55a91ee
1 parent e85c9e8
commit 55a91ee
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 0 deletions.
diff --git a/src/Core/Asterisk/Configs/lua/extensions.lua b/src/Core/Asterisk/Configs/lua/extensions.lua
@@ -1266,6 +1266,11 @@ function event_hangup_chan()
     data['agi_channel'] = get_variable("CHANNEL");
     data['OLD_LINKEDID']= get_variable("OLD_LINKEDID");
     data['UNIQUEID']  	= get_variable("pt1c_UNIQUEID");
+    if( data['UNIQUEID'] == '')then
+        -- Possible this is a call forwarding
+        data['UNIQUEID']  	= get_variable("transfer_UNIQUEID");
+    end
+
     data['VMSTATUS']  	= get_variable("VMSTATUS");
 
     -- Retrieve the verbose call ID and append the original call ID if available

diff --git a/src/Core/Workers/Libs/WorkerCallEvents/ActionHangupChan.php b/src/Core/Workers/Libs/WorkerCallEvents/ActionHangupChan.php
@@ -161,6 +161,24 @@ private static function hangupChanEndCalls(WorkerCallEvents $worker, array $data
             }
         }
 
+        // The SRC channel has been completed and DST channel has not been created
+        $filter = [
+            'verbose_call_id=:verbose_call_id: AND endtime = "" AND dst_chan = "" AND src_chan = :src_chan:',
+            'bind' => [
+                'verbose_call_id' => $data['verbose_call_id'],
+                'src_chan' => $data['agi_channel'],
+            ],
+        ];
+        $m_data = CallDetailRecordsTmp::find($filter);
+        foreach ($m_data as $row) {
+            $row->writeAttribute('endtime', $row->start);
+            $row->writeAttribute('transfer', 0);
+            $res = $row->update();
+            if (!$res) {
+                SystemMessages::sysLogMsg('Action_hangup_chan', implode(' ', $row->getMessages()), LOG_DEBUG);
+            }
+        }
+
         self::regMissedCall($data, $countRows);
     }