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

Update the xml_cdr php class to get it operational.

Browse Source
This commit is contained in:
markjcrane
2016-04-27 23:51:53 -06:00
parent 0a039eb7b5
commit 37f725d6ab
1 changed files with 85 additions and 85 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/xml_cdr/resources/classes/xml_cdr.php
+85 -85
View File
@@ -72,7 +72,7 @@ if (!class_exists('xml_cdr')) {
if (!$fp) { if (!$fp) {
return; return;
} }
fwrite($fp, $msg); fwrite($fp, $message);
fclose($fp); fclose($fp);
} }
@@ -81,61 +81,58 @@ if (!class_exists('xml_cdr')) {
*/ */
public function fields() { public function fields() {
$array[] = "uuid"; $this->fields[] = "uuid";
$array[] = "domain_uuid"; $this->fields[] = "domain_uuid";
$array[] = "extension_uuid"; $this->fields[] = "extension_uuid";
$array[] = "domain_name"; $this->fields[] = "domain_name";
$array[] = "accountcode"; $this->fields[] = "accountcode";
$array[] = "direction"; $this->fields[] = "direction";
$array[] = "default_language"; $this->fields[] = "default_language";
$array[] = "context"; $this->fields[] = "context";
$array[] = "xml"; $this->fields[] = "xml";
$array[] = "json"; $this->fields[] = "json";
$array[] = "caller_id_name"; $this->fields[] = "caller_id_name";
$array[] = "caller_id_number"; $this->fields[] = "caller_id_number";
$array[] = "destination_number"; $this->fields[] = "destination_number";
$array[] = "start_epoch"; $this->fields[] = "start_epoch";
$array[] = "start_stamp"; $this->fields[] = "start_stamp";
$array[] = "answer_stamp"; $this->fields[] = "answer_stamp";
$array[] = "answer_epoch"; $this->fields[] = "answer_epoch";
$array[] = "end_epoch"; $this->fields[] = "end_epoch";
$array[] = "end_stamp"; $this->fields[] = "end_stamp";
$array[] = "duration"; $this->fields[] = "duration";
$array[] = "mduration"; $this->fields[] = "mduration";
$array[] = "billsec"; $this->fields[] = "billsec";
$array[] = "billmsec"; $this->fields[] = "billmsec";
$array[] = "bridge_uuid"; $this->fields[] = "bridge_uuid";
$array[] = "read_codec"; $this->fields[] = "read_codec";
$array[] = "read_rate"; $this->fields[] = "read_rate";
$array[] = "write_codec"; $this->fields[] = "write_codec";
$array[] = "write_rate"; $this->fields[] = "write_rate";
$array[] = "remote_media_ip"; $this->fields[] = "remote_media_ip";
$array[] = "network_addr"; $this->fields[] = "network_addr";
$array[] = "recording_file"; $this->fields[] = "recording_file";
$array[] = "leg"; $this->fields[] = "leg";
$array[] = "pdd_ms"; $this->fields[] = "pdd_ms";
$array[] = "rtp_audio_in_mos"; $this->fields[] = "rtp_audio_in_mos";
$array[] = "last_app"; $this->fields[] = "last_app";
$array[] = "last_arg"; $this->fields[] = "last_arg";
$array[] = "cc_side"; $this->fields[] = "cc_side";
$array[] = "cc_member_uuid"; $this->fields[] = "cc_member_uuid";
$array[] = "cc_queue_joined_epoch"; $this->fields[] = "cc_queue_joined_epoch";
$array[] = "cc_queue"; $this->fields[] = "cc_queue";
$array[] = "cc_member_session_uuid"; $this->fields[] = "cc_member_session_uuid";
$array[] = "cc_agent"; $this->fields[] = "cc_agent";
$array[] = "cc_agent_type"; $this->fields[] = "cc_agent_type";
$array[] = "waitsec"; $this->fields[] = "waitsec";
$array[] = "conference_name"; $this->fields[] = "conference_name";
$array[] = "conference_uuid"; $this->fields[] = "conference_uuid";
$array[] = "conference_member_id"; $this->fields[] = "conference_member_id";
$array[] = "digits_dialed"; $this->fields[] = "digits_dialed";
$array[] = "pin_number"; $this->fields[] = "pin_number";
$array[] = "hangup_cause"; $this->fields[] = "hangup_cause";
$array[] = "hangup_cause_q850"; $this->fields[] = "hangup_cause_q850";
$array[] = "sip_hangup_disposition"; $this->fields[] = "sip_hangup_disposition";
$this->fields($array);
unset($array);
} }
/** /**
@@ -143,11 +140,19 @@ if (!class_exists('xml_cdr')) {
*/ */
public function save() { public function save() {
$this->fields();
$field_count = sizeof($this->fields); $field_count = sizeof($this->fields);
$sql = "insert into v_xml_cdr ("; $sql = "insert into v_xml_cdr (";
$f = 1;
foreach ($this->fields as $field) { foreach ($this->fields as $field) {
$sql .= "$field, "; if ($field_count == $f) {
$sql .= "$field ";
}
else {
$sql .= "$field, ";
}
$f++;
} }
$sql .= ")\n"; $sql .= ")\n";
$sql .= "values \n"; $sql .= "values \n";
@@ -156,15 +161,15 @@ if (!class_exists('xml_cdr')) {
$i = 0; $i = 0;
foreach ($this->array as $row) { foreach ($this->array as $row) {
$sql .= "("; $sql .= "(";
$f = 0; $f = 1;
foreach ($this->fields as $field) { foreach ($this->fields as $field) {
if (isset($row[$field])) { if (isset($row[$field]) && strlen($row[$field]) > 0) {
$sql .= "'".$row[$field]."'"; $sql .= "'".$row[$field]."'";
} }
else { else {
$sql .= "null"; $sql .= "null";
} }
if ($field_count != $i) { if ($field_count != $f) {
$sql .= ","; $sql .= ",";
} }
$f++; $f++;
@@ -175,6 +180,9 @@ if (!class_exists('xml_cdr')) {
} }
$i++; $i++;
} }
if (substr($sql,-2) == ",\n") {
$sql = substr($sql,0,-2);
}
$this->db->exec(check_sql($sql)); $this->db->exec(check_sql($sql));
unset($sql); unset($sql);
} }
@@ -199,15 +207,15 @@ if (!class_exists('xml_cdr')) {
} }
//parse the xml to get the call detail record info //parse the xml to get the call detail record info
//try { try {
// xml_cdr_log($xml_string); //$this->log($xml_string);
// $xml = simplexml_load_string($xml_string); $xml = simplexml_load_string($xml_string);
// xml_cdr_log("\nxml load done\n"); //$this->log("\nxml load done\n");
//} }
//catch(Exception $e) { catch(Exception $e) {
// echo $e->getMessage(); echo $e->getMessage();
// xml_cdr_log("\nfail loadxml: " . $e->getMessage() . "\n"); //$this->log("\nfail loadxml: " . $e->getMessage() . "\n");
//} }
//misc //misc
$uuid = check_str(urldecode($xml->variables->uuid)); $uuid = check_str(urldecode($xml->variables->uuid));
@@ -262,15 +270,15 @@ if (!class_exists('xml_cdr')) {
//get the values from the callflow. //get the values from the callflow.
$x = 0; $x = 0;
foreach ($xml->callflow as $row) { foreach ($xml->callflow as $callflow) {
if ($x == 0) { if ($x == 0) {
$context = check_str(urldecode($row->caller_profile->context)); $context = check_str(urldecode($callflow->caller_profile->context));
$this->array[$row]['destination_number'] = check_str(urldecode($row->caller_profile->destination_number)); $this->array[$row]['destination_number'] = check_str(urldecode($callflow->caller_profile->destination_number));
$this->array[$row]['context'] = $context; $this->array[$row]['context'] = $context;
$this->array[$row]['network_addr'] = check_str(urldecode($row->caller_profile->network_addr)); $this->array[$row]['network_addr'] = check_str(urldecode($callflow->caller_profile->network_addr));
} }
$this->array[$row]['caller_id_name'] = check_str(urldecode($row->caller_profile->caller_id_name)); $this->array[$row]['caller_id_name'] = check_str(urldecode($callflow->caller_profile->caller_id_name));
$this->array[$row]['caller_id_number'] = check_str(urldecode($row->caller_profile->caller_id_number)); $this->array[$row]['caller_id_number'] = check_str(urldecode($callflow->caller_profile->caller_id_number));
$x++; $x++;
} }
unset($x); unset($x);
@@ -300,7 +308,7 @@ if (!class_exists('xml_cdr')) {
} }
//send the domain name to the cdr log //send the domain name to the cdr log
//xml_cdr_log("\ndomain_name is `$domain_name`; domain_uuid is '$domain_uuid'\n"); //$this->log("\ndomain_name is `$domain_name`; domain_uuid is '$domain_uuid'\n");
//get the domain_uuid with the domain_name //get the domain_uuid with the domain_name
if (strlen($domain_uuid) == 0) { if (strlen($domain_uuid) == 0) {
@@ -351,14 +359,6 @@ if (!class_exists('xml_cdr')) {
$this->array[$row]['extension_uuid'] = check_str(urldecode($xml->variables->extension_uuid)); $this->array[$row]['extension_uuid'] = check_str(urldecode($xml->variables->extension_uuid));
} }
//insert xml_cdr into the db
if (strlen($start_stamp) > 0) {
$database->add();
if ($this->debug) {
echo $database->sql."\n";
}
}
//insert the values //insert the values
if (strlen($uuid) > 0) { if (strlen($uuid) > 0) {
if ($this->debug) { if ($this->debug) {
@@ -472,7 +472,7 @@ if (!class_exists('xml_cdr')) {
if (isset($_POST["cdr"])) { if (isset($_POST["cdr"])) {
//debug method //debug method
if ($this->debug){ if ($this->debug){
print_r ($_POST["cdr"]); print_r($_POST["cdr"]);
} }
//authentication for xml cdr http post //authentication for xml cdr http post