dbxe
/
fusionpbx
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update app_defaults.php

This commit is contained in:
FusionPBX 2017-02-08 13:29:48 -07:00 committed by GitHub
parent 478f164024
commit e20184d893
1 changed files with 70 additions and 70 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

140
app/recordings/app_defaults.php
View File

@ -24,79 +24,79 @@
Mark J Crane <markjcrane@fusionpbx.com> Mark J Crane <markjcrane@fusionpbx.com>
*/ */
if ($domains_processed == 1) { //if the recordings directory doesn't exist then create it
if (is_array($_SESSION['switch']['recordings']) && strlen($_SESSION['switch']['recordings']['dir']."/".$domain_name) > 0) {
if (!is_readable($_SESSION['switch']['recordings']['dir']."/".$domain_name)) { event_socket_mkdir($_SESSION['switch']['recordings']['dir']."/".$domain_name,02770,true); }
}
//if the recordings directory doesn't exist then create it //process one time
if (is_array($_SESSION['switch']['recordings']) && strlen($_SESSION['switch']['recordings']['dir']."/".$domain_name) > 0) { if ($domains_processed == 1) {
if (!is_readable($_SESSION['switch']['recordings']['dir']."/".$domain_name)) { event_socket_mkdir($_SESSION['switch']['recordings']['dir']."/".$domain_name,02770,true); }
}
//if base64, populate from existing recording files, then remove //if base64, populate from existing recording files, then remove
if (is_array($_SESSION['recordings']['storage_type']) && $_SESSION['recordings']['storage_type']['text'] == 'base64') { if (is_array($_SESSION['recordings']['storage_type']) && $_SESSION['recordings']['storage_type']['text'] == 'base64') {
//get recordings without base64 in db //get recordings without base64 in db
$sql = "select recording_uuid, domain_uuid, recording_filename "; $sql = "select recording_uuid, domain_uuid, recording_filename ";
$sql .= "from v_recordings where recording_base64 is null or recording_base64 = '' "; $sql .= "from v_recordings where recording_base64 is null or recording_base64 = '' ";
$prep_statement = $db->prepare(check_sql($sql)); $prep_statement = $db->prepare(check_sql($sql));
$prep_statement->execute(); $prep_statement->execute();
$result = $prep_statement->fetchAll(PDO::FETCH_NAMED); $result = $prep_statement->fetchAll(PDO::FETCH_NAMED);
if (is_array($result)) { if (is_array($result)) {
foreach ($result as &$row) { foreach ($result as &$row) {
$recording_uuid = $row['recording_uuid']; $recording_uuid = $row['recording_uuid'];
$recording_domain_uuid = $row['domain_uuid']; $recording_domain_uuid = $row['domain_uuid'];
$recording_filename = $row['recording_filename']; $recording_filename = $row['recording_filename'];
//set recording directory //set recording directory
$recording_directory = $_SESSION['switch']['recordings']['dir'].'/'.$domain_name; $recording_directory = $_SESSION['switch']['recordings']['dir'].'/'.$domain_name;
//encode recording file (if exists) //encode recording file (if exists)
if (file_exists($recording_directory.'/'.$recording_filename)) { if (file_exists($recording_directory.'/'.$recording_filename)) {
$recording_base64 = base64_encode(file_get_contents($recording_directory.'/'.$recording_filename)); $recording_base64 = base64_encode(file_get_contents($recording_directory.'/'.$recording_filename));
//update recording record with base64 //update recording record with base64
$sql = "update v_recordings set "; $sql = "update v_recordings set ";
$sql .= "recording_base64 = '".$recording_base64."' "; $sql .= "recording_base64 = '".$recording_base64."' ";
$sql .= "where domain_uuid = '".$recording_domain_uuid."' "; $sql .= "where domain_uuid = '".$recording_domain_uuid."' ";
$sql .= "and recording_uuid = '".$recording_uuid."' "; $sql .= "and recording_uuid = '".$recording_uuid."' ";
$db->exec(check_sql($sql)); $db->exec(check_sql($sql));
unset($sql); unset($sql);
//remove local recording file //remove local recording file
@unlink($recording_directory.'/'.$recording_filename);
}
}
}
unset($sql, $prep_statement, $result, $row);
}
//if not base64, decode to local files, remove base64 data from db
else if (is_array($_SESSION['recordings']['storage_type']) && $_SESSION['recordings']['storage_type']['text'] != 'base64') {
//get recordings with base64 in db
$sql = "select recording_uuid, domain_uuid, recording_filename, recording_base64 ";
$sql .= "from v_recordings where recording_base64 is not null ";
$prep_statement = $db->prepare(check_sql($sql));
$prep_statement->execute();
$result = $prep_statement->fetchAll(PDO::FETCH_NAMED);
if (count($result) > 0) {
foreach ($result as &$row) {
$recording_uuid = $row['recording_uuid'];
$recording_domain_uuid = $row['domain_uuid'];
$recording_filename = $row['recording_filename'];
$recording_base64 = $row['recording_base64'];
//set recording directory
$recording_directory = $_SESSION['switch']['recordings']['dir'].'/'.$domain_name;
//remove local file, if any
if (file_exists($recording_directory.'/'.$recording_filename)) {
@unlink($recording_directory.'/'.$recording_filename); @unlink($recording_directory.'/'.$recording_filename);
} }
//decode base64, save to local file
$recording_decoded = base64_decode($recording_base64);
file_put_contents($recording_directory.'/'.$recording_filename, $recording_decoded);
$sql = "update v_recordings ";
$sql .= "set recording_base64 = null ";
$sql .= "where domain_uuid = '".$recording_domain_uuid."' ";
$sql .= "and recording_uuid = '".$recording_uuid."' ";
$db->exec(check_sql($sql));
unset($sql);
}
} }
} unset($sql, $prep_statement, $result, $row);
unset($sql, $prep_statement, $result, $row); }
} }
//if not base64, decode to local files, remove base64 data from db
else if (is_array($_SESSION['recordings']['storage_type']) && $_SESSION['recordings']['storage_type']['text'] != 'base64') {
//get recordings with base64 in db
$sql = "select recording_uuid, domain_uuid, recording_filename, recording_base64 ";
$sql .= "from v_recordings where recording_base64 is not null ";
$prep_statement = $db->prepare(check_sql($sql));
$prep_statement->execute();
$result = $prep_statement->fetchAll(PDO::FETCH_NAMED);
if (count($result) > 0) {
foreach ($result as &$row) {
$recording_uuid = $row['recording_uuid'];
$recording_domain_uuid = $row['domain_uuid'];
$recording_filename = $row['recording_filename'];
$recording_base64 = $row['recording_base64'];
//set recording directory
$recording_directory = $_SESSION['switch']['recordings']['dir'].'/'.$domain_name;
//remove local file, if any
if (file_exists($recording_directory.'/'.$recording_filename)) {
@unlink($recording_directory.'/'.$recording_filename);
}
//decode base64, save to local file
$recording_decoded = base64_decode($recording_base64);
file_put_contents($recording_directory.'/'.$recording_filename, $recording_decoded);
$sql = "update v_recordings ";
$sql .= "set recording_base64 = null ";
$sql .= "where domain_uuid = '".$recording_domain_uuid."' ";
$sql .= "and recording_uuid = '".$recording_uuid."' ";
$db->exec(check_sql($sql));
unset($sql);
}
}
unset($sql, $prep_statement, $result, $row);
}
}
?> ?>