Update xml_cdr.php

This commit is contained in:
FusionPBX 2019-09-13 00:36:24 -06:00 committed by GitHub
parent 76e1f2fa06
commit fca9b7d848
1 changed files with 21 additions and 28 deletions

View File

@ -24,7 +24,6 @@
Mark J Crane <markjcrane@fusionpbx.com> Mark J Crane <markjcrane@fusionpbx.com>
*/ */
/** /**
* xml_cdr class provides methods for adding cdr records to the database * xml_cdr class provides methods for adding cdr records to the database
* *
@ -167,7 +166,11 @@ if (!class_exists('xml_cdr')) {
$this->fields(); $this->fields();
$field_count = sizeof($this->fields); $field_count = sizeof($this->fields);
$row_count = sizeof($this->array);
//$field_count = sizeof($this->fields);
$i = 0;
if (isset($this->array)) {
foreach ($this->array as $row) {
$sql = "insert into v_xml_cdr ("; $sql = "insert into v_xml_cdr (";
$f = 1; $f = 1;
if (isset($this->fields)) { if (isset($this->fields)) {
@ -184,16 +187,11 @@ if (!class_exists('xml_cdr')) {
} }
$sql .= ")\n"; $sql .= ")\n";
$sql .= "values \n"; $sql .= "values \n";
$row_count = sizeof($this->array);
//$field_count = sizeof($this->fields);
$i = 0;
if (isset($this->array)) {
foreach ($this->array as $row) {
$sql .= "("; $sql .= "(";
$f = 1; $f = 1;
if (isset($this->fields)) { if (isset($this->fields)) {
foreach ($this->fields as $field) { foreach ($this->fields as $field) {
//$field = preg_replace('#[^a-zA-Z0-9_\-]#', '', $field); $field = preg_replace('#[^a-zA-Z0-9_\-]#', '', $field);
if (isset($row[$field]) && strlen($row[$field]) > 0) { if (isset($row[$field]) && strlen($row[$field]) > 0) {
$sql .= ":".$field." \n"; $sql .= ":".$field." \n";
$parameters[$field] = $row[$field]; $parameters[$field] = $row[$field];
@ -208,18 +206,13 @@ if (!class_exists('xml_cdr')) {
} }
} }
$sql .= ")"; $sql .= ")";
if ($row_count != $i) {
$sql .= ",\n";
}
$i++;
}
}
if (substr($sql,-2) == ",\n") {
$sql = substr($sql,0,-2);
}
$database = new database; $database = new database;
$database->execute($sql, $parameters); $database->execute($sql, $parameters);
unset($sql, $parameters); unset($sql, $parameters);
$i++;
}
}
} }
/** /**