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

Replace duplicated v_xml_cdr_import.php with a call to the post method of xml_cdr (#5956) 

* Redirect duplicated xml_cdr_import script

This replaces the duplicated code in v_xml_cdr_import.php with xml_cdr_import.php

This also adds a call to `$cdr->post();` in that file to then process the POSTed data from FreeSWITCH
This commit is contained in:
Andrew Querol 2021-05-26 10:54:08 -05:00 committed by GitHub
parent 7133f35af5
commit b67d55b39c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 7 additions and 699 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

702
app/xml_cdr/v_xml_cdr_import.php
View File

@ -17,709 +17,15 @@
The Initial Developer of the Original Code is
Mark J Crane <markjcrane@fusionpbx.com>
Portions created by the Initial Developer are Copyright (C) 2008-2018
Portions created by the Initial Developer are Copyright (C) 2008-2021
the Initial Developer. All Rights Reserved.
Contributor(s):
Mark J Crane <markjcrane@fusionpbx.com>
Luis Daniel Lucio Quiroz <dlucio@okay.com.mx>
*/
//check the permission
if (defined('STDIN')) {
$document_root = str_replace("\\", "/", $_SERVER["PHP_SELF"]);
preg_match("/^(.*)\/app\/.*$/", $document_root, $matches);
$document_root = $matches[1];
set_include_path($document_root);
$_SERVER["DOCUMENT_ROOT"] = $document_root;
require_once "resources/require.php";
}
else {
include "root.php";
require_once "resources/require.php";
require_once "resources/pdo.php";
}
//set debug
$debug = false; //true //false
if ($debug) {
$time5 = microtime(true);
$insert_time=$insert_count=0;
}
function xml_cdr_log($msg) {
global $debug;
if (!$debug) {
return;
}
$fp = fopen($_SESSION['server']['temp']['dir'].'/xml_cdr.log', 'a+');
if (!$fp) {
return;
}
fwrite($fp, $msg);
fclose($fp);
}
//increase limits
set_time_limit(3600);
ini_set('memory_limit', '256M');
ini_set("precision", 6);
//set pdo attribute that enables exception handling
$db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
//define accept_b_leg function
function accept_b_leg($xml){
// if no filter set allow all for backward compatibility
if(empty($_SESSION['cdr']['b_leg'])) {
return true;
}
// filter out by call direction
if(in_array(@$xml->variables->call_direction, $_SESSION['cdr']['b_leg'])) {
return true;
}
// Disable cdr write
return false;
}
//define the process_xml_cdr function
function process_xml_cdr($db, $leg, $xml_string) {
//set global variable
global $debug;
//fix the xml by escaping the contents of <sip_full_XXX>
$xml_string = preg_replace_callback("/<([^><]+)>(.*?[><].*?)<\/\g1>/",
function ($matches) {
return '<' . $matches[1] . '>' .
str_replace(">", "&gt;",
str_replace("<", "&lt;", $matches[2])
) .
'</' . $matches[1] . '>';
},
$xml_string
);
//parse the xml to get the call detail record info
try {
//send info to lthe log
xml_cdr_log($xml_string);
//disable xml entities
libxml_disable_entity_loader(true);
//load the string into an xml object
$xml = simplexml_load_string($xml_string, 'SimpleXMLElement', LIBXML_NOCDATA);
//send info to the log
xml_cdr_log("\nxml load done\n");
}
catch(Exception $e) {
echo $e->getMessage();
xml_cdr_log("\nfail loadxml: " . $e->getMessage() . "\n");
}
//convert the xml object to json
$json = json_encode($xml);
//convert json to an array
$array = json_decode($json, true);
//filter out b-legs
if($leg == 'b'){
if(!accept_b_leg($xml)){
return;
}
}
//prepare the database object
require_once "resources/classes/database.php";
$database = new database;
$database->table = "v_xml_cdr";
//caller info
$database->fields['caller_destination'] = urldecode($xml->variables->caller_destination);
//misc
$uuid = urldecode($xml->variables->uuid);
$database->fields['xml_cdr_uuid'] = $uuid;
$database->fields['accountcode'] = urldecode($xml->variables->accountcode);
$database->fields['default_language'] = urldecode($xml->variables->default_language);
$database->fields['bridge_uuid'] = urldecode($xml->variables->bridge_uuid);
//$database->fields['digits_dialed'] = urldecode($xml->variables->digits_dialed);
$database->fields['sip_hangup_disposition'] = urldecode($xml->variables->sip_hangup_disposition);
$database->fields['pin_number'] = urldecode($xml->variables->pin_number);
//time
$database->fields['start_epoch'] = urldecode($xml->variables->start_epoch);
$start_stamp = urldecode($xml->variables->start_stamp);
$database->fields['start_stamp'] = $start_stamp;
$database->fields['answer_stamp'] = urldecode($xml->variables->answer_stamp);
$database->fields['answer_epoch'] = urldecode($xml->variables->answer_epoch);
$database->fields['end_epoch'] = urldecode($xml->variables->end_epoch);
$database->fields['end_stamp'] = urldecode($xml->variables->end_stamp);
$database->fields['duration'] = urldecode($xml->variables->duration);
$database->fields['mduration'] = urldecode($xml->variables->mduration);
$database->fields['billsec'] = urldecode($xml->variables->billsec);
$database->fields['billmsec'] = urldecode($xml->variables->billmsec);
//codecs
$database->fields['read_codec'] = urldecode($xml->variables->read_codec);
$database->fields['read_rate'] = urldecode($xml->variables->read_rate);
$database->fields['write_codec'] = urldecode($xml->variables->write_codec);
$database->fields['write_rate'] = urldecode($xml->variables->write_rate);
$database->fields['remote_media_ip'] = urldecode($xml->variables->remote_media_ip);
$database->fields['hangup_cause'] = urldecode($xml->variables->hangup_cause);
$database->fields['hangup_cause_q850'] = urldecode($xml->variables->hangup_cause_q850);
//store the call direction
$database->fields['direction'] = urldecode($xml->variables->call_direction);
//call center
$database->fields['cc_side'] = urldecode($xml->variables->cc_side);
$database->fields['cc_member_uuid'] = urldecode($xml->variables->cc_member_uuid);
$database->fields['cc_queue_joined_epoch'] = urldecode($xml->variables->cc_queue_joined_epoch);
$database->fields['cc_member_session_uuid'] = urldecode($xml->variables->cc_member_session_uuid);
$database->fields['cc_agent_uuid'] = urldecode($xml->variables->cc_agent_uuid);
$database->fields['cc_queue'] = urldecode($xml->variables->cc_queue);
$database->fields['cc_agent'] = urldecode($xml->variables->cc_agent);
$database->fields['cc_agent_type'] = urldecode($xml->variables->cc_agent_type);
$database->fields['cc_agent_bridged'] = urldecode($xml->variables->cc_agent_bridged);
$database->fields['cc_queue_answered_epoch'] = urldecode($xml->variables->cc_queue_answered_epoch);
$database->fields['cc_queue_terminated_epoch'] = urldecode($xml->variables->cc_queue_terminated_epoch);
$database->fields['cc_queue_canceled_epoch'] = urldecode($xml->variables->cc_queue_canceled_epoch);
$database->fields['cc_cancel_reason'] = urldecode($xml->variables->cc_cancel_reason);
$database->fields['cc_cause'] = urldecode($xml->variables->cc_cause);
$database->fields['waitsec'] = urldecode($xml->variables->waitsec);
if (urldecode($xml->variables->cc_side) == 'agent') {
$database->fields['direction'] = 'inbound';
}
if (is_uuid($xml->variables->call_center_queue_uuid)) {
$this->array[$key]['call_center_queue_uuid'] = urldecode($xml->variables->call_center_queue_uuid);
}
//app info
$database->fields['last_app'] = urldecode($xml->variables->last_app);
$database->fields['last_arg'] = urldecode($xml->variables->last_arg);
//voicemail message success
if ($xml->variables->voicemail_action == "save" && $xml->variables->voicemail_message_seconds > 0){
$database->fields['voicemail_message'] = "true";
}
elseif ($xml->variables->voicemail_action == "save") {
$database->fields['voicemail_message'] = "false";
}
//conference
$database->fields['conference_name'] = urldecode($xml->variables->conference_name);
$database->fields['conference_uuid'] = urldecode($xml->variables->conference_uuid);
$database->fields['conference_member_id'] = urldecode($xml->variables->conference_member_id);
//call quality
$rtp_audio_in_mos = urldecode($xml->variables->rtp_audio_in_mos);
if (strlen($rtp_audio_in_mos) > 0) {
$database->fields['rtp_audio_in_mos'] = $rtp_audio_in_mos;
}
//set missed calls
$database->fields['missed_call'] = 'false';
if ($xml->variables->cc_side != "agent" && strlen($xml->variables->originating_leg_uuid) == 0 && $xml->variables->call_direction != 'outbound' && strlen($xml->variables->answer_stamp) == 0) {
$database->fields['missed_call'] = 'true';
}
if ($xml->variables->missed_call == 'true') {
$database->fields['missed_call'] = 'true';
}
//get the caller details
$database->fields['caller_id_name'] = urldecode($xml->variables->caller_id_name);
$database->fields['caller_id_number'] = urldecode($xml->variables->caller_id_number);
if (isset($xml->variables->effective_caller_id_name)) {
$database->fields['caller_id_name'] = urldecode($xml->variables->effective_caller_id_name);
}
if (isset($xml->variables->effective_caller_id_number)) {
$database->fields['caller_id_number'] = urldecode($xml->variables->effective_caller_id_number);
}
//get the values from the callflow.
$i = 0;
foreach ($xml->callflow as $row) {
if ($i == 0) {
$context = urldecode($row->caller_profile->context);
$destination_number = urldecode($row->caller_profile->destination_number);
$database->fields['context'] = $context;
$database->fields['network_addr'] = urldecode($row->caller_profile->network_addr);
}
if (strlen($database->fields['caller_id_name']) == 0) {
$database->fields['caller_id_name'] = urldecode($row->caller_profile->caller_id_name);
}
if (strlen($database->fields['caller_id_number']) == 0) {
$database->fields['caller_id_number'] = urldecode($row->caller_profile->caller_id_number);
}
$i++;
}
unset($i);
//if last_sent_callee_id_number is set use it for the destination_number
if (($leg == 'a') && (strlen($xml->variables->last_sent_callee_id_number) > 0)) {
$destination_number = urldecode($xml->variables->last_sent_callee_id_number);
}
//remove the provider prefix
if (isset($xml->variables->provider_prefix) && isset($destination_number)) {
$provider_prefix = $xml->variables->provider_prefix;
if ($provider_prefix == substr($destination_number, 0, strlen($provider_prefix))) {
$destination_number = substr($destination_number, strlen($provider_prefix), strlen($destination_number));
}
}
//store the destination_number
$database->fields['destination_number'] = $destination_number;
//store the call leg
$database->fields['leg'] = $leg;
//store post dial delay, in milliseconds
$database->fields['pdd_ms'] = urldecode($xml->variables->progress_mediamsec) + urldecode($xml->variables->progressmsec);
//get break down the date to year, month and day
$start_time = strtotime($start_stamp);
$start_year = date("Y", $start_time);
$start_month = date("M", $start_time);
$start_day = date("d", $start_time);
//get the domain values from the xml
$domain_name = urldecode($xml->variables->domain_name);
$domain_uuid = urldecode($xml->variables->domain_uuid);
//get the domain name
if (strlen($domain_name) == 0) {
$domain_name = urldecode($xml->variables->dialed_domain);
}
if (strlen($domain_name) == 0) {
$domain_name = urldecode($xml->variables->sip_invite_domain);
}
if (strlen($domain_name) == 0) {
$domain_name = urldecode($xml->variables->sip_req_host);
}
if (strlen($domain_name) == 0) {
$presence_id = urldecode($xml->variables->presence_id);
if (strlen($presence_id) > 0) {
$presence_array = explode($presence_id, '%40');
$domain_name = $presence_array[1];
}
}
//send the domain name to the cdr log
xml_cdr_log("\ndomain_name is `$domain_name`; domain_uuid is '$domain_uuid'\n");
//get the domain_uuid with the domain_name
if (strlen($domain_uuid) == 0) {
$sql = "select domain_uuid from v_domains ";
if (strlen($domain_name) == 0 && $context != 'public' && $context != 'default') {
$sql .= "where domain_name = :context ";
$parameters['context'] = $context;
}
else {
$sql .= "where domain_name = :domain_name ";
$parameters['domain_name'] = $domain_name;
}
$domain_uuid = $database->select($sql, $parameters, 'column');
unset($parameters);
}
//set values in the database
if (strlen($domain_uuid) > 0) {
$database->domain_uuid = $domain_uuid;
$database->fields['domain_uuid'] = $domain_uuid;
}
if (strlen($domain_name) > 0) {
$database->fields['domain_name'] = $domain_name;
}
//save to the database in json format
if ($_SESSION['cdr']['format']['text'] == "json" && $_SESSION['cdr']['storage']['text'] == "db") {
$database->fields['json'] = $json;
}
//dynamic cdr fields
if (is_array($_SESSION['cdr']['field'])) {
foreach ($_SESSION['cdr']['field'] as $field) {
$fields = explode(",", $field);
$field_name = end($fields);
if (count($fields) == 1) {
$database->fields[$field_name] = urldecode($array['variables'][$fields[0]]);
}
if (count($fields) == 2) {
$database->fields[$field_name] = urldecode($array[$fields[0]][$fields[1]]);
}
if (count($fields) == 3) {
$database->fields[$field_name] = urldecode($array[$fields[0]][0][$fields[1]][$fields[2]]);
}
if (count($fields) == 4) {
$database->fields[$field_name] = urldecode($array[$fields[0]][$fields[1]][$fields[2]][$fields[3]]);
}
if (count($fields) == 5) {
$database->fields[$field_name] = urldecode($array[$fields[0]][$fields[1]][$fields[2]][$fields[3]][$fields[4]]);
}
}
}
//save to the database in xml format
if ($_SESSION['cdr']['format']['text'] == "xml" && $_SESSION['cdr']['storage']['text'] == "db") {
$database->fields['xml'] = $xml_string;
}
//get the extension_uuid and then add it to the database fields array
if (strlen($xml->variables->extension_uuid) > 0) {
$database->fields['extension_uuid'] = urldecode($xml->variables->extension_uuid);
}
else {
if (strlen($xml->variables->dialed_user) > 0) {
$sql = "select extension_uuid from v_extensions ";
$sql .= "where domain_uuid = :domain_uuid ";
$sql .= "and (extension = :dialed_user or number_alias = :dialed_user) ";
$parameters['domain_uuid'] = $domain_uuid;
$parameters['dialed_user'] = $xml->variables->dialed_user;
$extension_uuid = $database->select($sql, $parameters, 'column');
$database->fields['extension_uuid'] = $extension_uuid;
unset($parameters);
}
if (strlen($xml->variables->referred_by_user) > 0) {
$sql = "select extension_uuid from v_extensions ";
$sql .= "where domain_uuid = :domain_uuid ";
$sql .= "and (extension = :referred_by_user or number_alias = :referred_by_user) ";
$parameters['domain_uuid'] = $domain_uuid;
$parameters['referred_by_user'] = $xml->variables->referred_by_user;
$extension_uuid = $database->select($sql, $parameters, 'column');
$database->fields['extension_uuid'] = $extension_uuid;
unset($parameters);
}
if (strlen($xml->variables->last_sent_callee_id_number) > 0) {
$sql = "select extension_uuid from v_extensions ";
$sql .= "where domain_uuid = :domain_uuid ";
$sql .= "and (extension = :callee_id_number or number_alias = :callee_id_number) ";
$parameters['domain_uuid'] = $domain_uuid;
$parameters['callee_id_number'] = $xml->variables->last_sent_callee_id_number;
$extension_uuid = $database->select($sql, $parameters, 'column');
$database->fields['extension_uuid'] = $extension_uuid;
unset($parameters);
}
}
//get the recording details
if (strlen($xml->variables->record_session) > 0) {
$record_path = urldecode($xml->variables->record_path);
$record_name = urldecode($xml->variables->record_name);
if (isset($xml->variables->record_seconds)) {
$record_length = urldecode($xml->variables->record_seconds);
}
else {
$record_length = urldecode($xml->variables->duration);
}
}
elseif (!isset($record_path) && urldecode($xml->variables->last_app) == "record_session") {
$record_path = dirname(urldecode($xml->variables->last_arg));
$record_name = basename(urldecode($xml->variables->last_arg));
$record_length = urldecode($xml->variables->record_seconds);
}
elseif (strlen($xml->variables->record_name) > 0) {
$record_path = urldecode($xml->variables->record_path);
$record_name = urldecode($xml->variables->record_name);
$record_length = urldecode($xml->variables->duration);
}
elseif (strlen($xml->variables->sofia_record_file) > 0) {
$record_path = dirname(urldecode($xml->variables->sofia_record_file));
$record_name = basename(urldecode($xml->variables->sofia_record_file));
$record_length = urldecode($xml->variables->record_seconds);
}
elseif (strlen($xml->variables->cc_record_filename) > 0) {
$record_path = dirname(urldecode($xml->variables->cc_record_filename));
$record_name = basename(urldecode($xml->variables->cc_record_filename));
$record_length = urldecode($xml->variables->record_seconds);
}
elseif (strlen($xml->variables->api_on_answer) > 0) {
$command = str_replace("\n", " ", urldecode($xml->variables->api_on_answer));
$parts = explode(" ", $command);
if ($parts[0] == "uuid_record") {
$recording = $parts[3];
$record_path = dirname($recording);
$record_name = basename($recording);
$record_length = urldecode($xml->variables->duration);
}
}
elseif (strlen($xml->variables->current_application_data) > 0) {
$commands = explode(",", urldecode($xml->variables->current_application_data));
foreach ($commands as $command) {
$cmd = explode("=", $command);
if ($cmd[0] == "api_on_answer") {
$a = explode("]", $cmd[1]);
$command = str_replace("'", "", $a[0]);
$parts = explode(" ", $command);
if ($parts[0] == "uuid_record") {
$recording = $parts[3];
$record_path = dirname($recording);
$record_name = basename($recording);
$record_length = urldecode($xml->variables->duration);
}
}
}
}
if (!isset($record_name) || is_null ($record_name) || (strlen($record_name) == 0)) {
$bridge_uuid = urldecode($xml->variables->bridge_uuid);
$path = $_SESSION['switch']['recordings']['dir'].'/'.$domain_name.'/archive/'.$start_year.'/'.$start_month.'/'.$start_day;
if (file_exists($path.'/'.$bridge_uuid.'.wav')) {
$record_path = $path;
$record_name = $bridge_uuid.'.wav';
$record_length = urldecode($xml->variables->duration);
}
elseif (file_exists($path.'/'.$bridge_uuid.'.mp3')) {
$record_path = $path;
$record_name = $bridge_uuid.'.mp3';
$record_length = urldecode($xml->variables->duration);
}
}
if (!isset($record_name) || is_null ($record_name) || (strlen($record_name) == 0)) {
$path = $_SESSION['switch']['recordings']['dir'].'/'.$domain_name.'/archive/'.$start_year.'/'.$start_month.'/'.$start_day;
if (file_exists($path.'/'.$uuid.'.wav')) {
$record_path = $path;
$record_name = $uuid.'.wav';
$record_length = urldecode($xml->variables->duration);
}
elseif (file_exists($path.'/'.$uuid.'.mp3')) {
$record_path = $path;
$record_name = $uuid.'.mp3';
$record_length = urldecode($xml->variables->duration);
}
}
//add the call recording
if (isset($record_path) && isset($record_name) && file_exists($record_path.'/'.$record_name) && $record_length > 0) {
//add to the xml cdr table
$database->fields['record_path'] = $record_path;
$database->fields['record_name'] = $record_name;
if (isset($xml->variables->record_description)) {
$record_description = urldecode($xml->variables->record_description);
}
//add to the call recordings table
if (file_exists($_SERVER["PROJECT_ROOT"]."/app/call_recordings/app_config.php")) {
//build the array
$i = 0;
$recordings['call_recordings'][$i]['call_recording_uuid'] = $uuid;
$recordings['call_recordings'][$i]['domain_uuid'] = $domain_uuid;
$recordings['call_recordings'][$i]['call_recording_name'] = $record_name;
$recordings['call_recordings'][$i]['call_recording_path'] = $record_path;
$recordings['call_recordings'][$i]['call_recording_length'] = $record_length;
$recordings['call_recordings'][$i]['call_recording_description'] = $record_description;
$recordings['call_recordings'][$i]['call_recording_date'] = urldecode($xml->variables->start_stamp);
$recordings['call_recordings'][$i]['call_direction'] = urldecode($xml->variables->call_direction);
//$recordings['call_recordings'][$i]['call_recording_description']= $row['zzz'];
//$recordings['call_recordings'][$i]['call_recording_base64']= $row['zzz'];
//add the temporary permission
$p = new permissions;
$p->add("call_recording_add", "temp");
$p->add("call_recording_edit", "temp");
//save the call recording to the database
$recording_database = new database;
$recording_database->app_name = 'call_recordings';
$recording_database->app_uuid = '56165644-598d-4ed8-be01-d960bcb8ffed';
$recording_database->domain_uuid = $domain_uuid;
$recording_database->save($recordings, false);
//$message = $recording_database->message;
unset($recordings, $i);
//remove the temporary permission
$p->delete("call_recording_add", "temp");
$p->delete("call_recording_edit", "temp");
}
}
//insert xml_cdr into the db
if (strlen($start_stamp) > 0) {
$database->add();
if ($debug) {
echo $database->sql."\n";
}
}
//insert the values
if (strlen($uuid) > 0) {
if ($debug) {
$time5_insert = microtime(true);
//echo $sql."<br />\n";
}
try {
$error = "false";
//$db->exec($sql);
}
catch(PDOException $e) {
$tmp_dir = $_SESSION['switch']['log']['dir'].'/xml_cdr/failed/';
if (!file_exists($tmp_dir)) {
event_socket_mkdir($tmp_dir);
}
if ($_SESSION['cdr']['format']['text'] == "xml") {
$tmp_file = $uuid.'.xml';
$fh = fopen($tmp_dir.'/'.$tmp_file, 'w');
fwrite($fh, $xml_string);
}
else {
$tmp_file = $uuid.'.json';
$fh = fopen($tmp_dir.'/'.$tmp_file, 'w');
fwrite($fh, json_encode($xml));
}
fclose($fh);
if ($debug) {
echo $e->getMessage();
}
$error = "true";
}
if ($_SESSION['cdr']['storage']['text'] == "dir" && $error != "true") {
if (strlen($uuid) > 0) {
$tmp_dir = $_SESSION['switch']['log']['dir'].'/xml_cdr/archive/'.$start_year.'/'.$start_month.'/'.$start_day;
if (!file_exists($tmp_dir)) {
event_socket_mkdir($tmp_dir);
}
if ($_SESSION['cdr']['format']['text'] == "xml") {
$tmp_file = $uuid.'.xml';
$fh = fopen($tmp_dir.'/'.$tmp_file, 'w');
fwrite($fh, $xml_string);
}
else {
$tmp_file = $uuid.'.json';
$fh = fopen($tmp_dir.'/'.$tmp_file, 'w');
fwrite($fh, json_encode($xml));
}
fclose($fh);
}
}
unset($error);
if ($debug) {
GLOBAL $insert_time,$insert_count;
$insert_time+=microtime(true)-$time5_insert; //add this current query.
$insert_count++;
}
}
unset($sql);
}
//get cdr details from the http post
if (strlen($_POST["cdr"]) > 0) {
if ($debug){
print_r ($_POST["cdr"]);
}
//authentication for xml cdr http post
if ($_SESSION["cdr"]["http_enabled"]["boolean"] == "true" && strlen($_SESSION["xml_cdr"]["username"]) == 0) {
//get the contents of xml_cdr.conf.xml
$conf_xml_string = file_get_contents($_SESSION['switch']['conf']['dir'].'/autoload_configs/xml_cdr.conf.xml');
//parse the xml to get the call detail record info
try {
//disable xml entities
libxml_disable_entity_loader(true);
//load the string into an xml object
$conf_xml = simplexml_load_string($conf_xml_string, 'SimpleXMLElement', LIBXML_NOCDATA);
}
catch(Exception $e) {
echo $e->getMessage();
}
foreach ($conf_xml->settings->param as $row) {
if ($row->attributes()->name == "cred") {
$auth_array = explode(":", $row->attributes()->value);
//echo "username: ".$auth_array[0]."<br />\n";
//echo "password: ".$auth_array[1]."<br />\n";
}
if ($row->attributes()->name == "url") {
//check name is equal to url
}
}
}
//if http enabled is set to false then deny access
if ($_SESSION["cdr"]["http_enabled"]["boolean"] == "false") {
echo "access denied<br />\n";
return;
}
//check for the correct username and password
if ($_SESSION["cdr"]["http_enabled"]["boolean"] == "true") {
if ($auth_array[0] == $_SERVER["PHP_AUTH_USER"] && $auth_array[1] == $_SERVER["PHP_AUTH_PW"]) {
//echo "access granted<br />\n";
$_SESSION["xml_cdr"]["username"] = $auth_array[0];
$_SESSION["xml_cdr"]["password"] = $auth_array[1];
}
else {
echo "access denied<br />\n";
return;
}
}
//loop through all attribues
//foreach($xml->settings->param[1]->attributes() as $a => $b) {
// echo $a,'="',$b,"\"<br />\n";
//}
//get the http post variable
$xml_string = trim($_POST["cdr"]);
//get the leg of the call
if (substr($_REQUEST['uuid'], 0, 2) == "a_") {
$leg = "a";
}
else {
$leg = "b";
}
xml_cdr_log("process cdr via post\n");
//parse the xml and insert the data into the db
process_xml_cdr($db, $leg, $xml_string);
}
//check the filesystem for xml cdr records that were missed
$xml_cdr_dir = $_SESSION['switch']['log']['dir'].'/xml_cdr';
$dir_handle = opendir($xml_cdr_dir);
$x = 0;
while($file = readdir($dir_handle)) {
if ($file != '.' && $file != '..') {
//import the call detail files are less than 3 mb - 3 million bytes
if (!is_dir($xml_cdr_dir . '/' . $file) && filesize($xml_cdr_dir.'/'.$file) < 3000000) {
//get the leg of the call
if (substr($file, 0, 2) == "a_") {
$leg = "a";
}
else {
$leg = "b";
}
//get the xml cdr string
$xml_string = file_get_contents($xml_cdr_dir.'/'.$file);
//parse the xml and insert the data into the db
process_xml_cdr($db, $leg, $xml_string);
//delete the file after it has been imported
unlink($xml_cdr_dir.'/'.$file);
//increment the variable
$x++;
}
}
}
closedir($dir_handle);
//debug true
if ($debug) {
$content = ob_get_contents(); //get the output from the buffer
ob_end_clean(); //clean the buffer
$time = "\n\n$insert_count inserts in: ".number_format($insert_time,5). " seconds.\n";
$time .= "Other processing time: ".number_format((microtime(true)-$time5-$insert_time),5). " seconds.\n";
xml_cdr_log($content.$time);
}
//this file exists for legacy reasons, old installs call this script to import CDR records.
require_once "xml_cdr_import.php";
?>

4
app/xml_cdr/xml_cdr_import.php
View File

@ -44,8 +44,10 @@
ini_set('memory_limit', '256M');
ini_set("precision", 6);
//import from the file system
$cdr = new xml_cdr;
//import from the FreeSWITCH POST
$cdr->post();
//import from the file system
$cdr->read_files();
?>