nsinnovations/fusionpbx
2
0
Fork 0
mirror of https://github.com/fusionpbx/fusionpbx.git synced 2025-12-30 00:53:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update the database class toggle, copy an delete methods.

Browse Source
This commit is contained in:
FusionPBX
2020-07-09 02:57:28 -06:00
committed by GitHub
parent 37061b7d6c
commit 5b5696456f
1 changed files with 568 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

602
resources/classes/database.php
View File

@@ -66,7 +66,7 @@ include "root.php";
$this->domain_uuid = $_SESSION['domain_uuid'];
}
}
/**
* Called when there are no references to a particular object
* unset the variables used in the class
@@ -76,7 +76,7 @@ include "root.php";
unset($this->$key);
}
}
/**
* Connect to the database
*/
@@ -683,7 +683,10 @@ include "root.php";
unset($sql);
}
public function delete($delete_array) {
public function delete($array) {
//return the array
if (!is_array($array)) { echo "not an array"; return false; }
//connect to the database if needed
if (!$this->db) {
@@ -710,38 +713,171 @@ include "root.php";
//echo "</pre>\n";
//exit;
//get the current data
if (is_array($delete_array)) {
foreach($delete_array as $table_name => $rows) {
foreach($rows as $row) {
$i = 0;
$sql = "select * from ".$table_prefix.$table_name." ";
foreach($row as $field_name => $field_value) {
if ($i == 0) { $sql .= "where "; } else { $sql .= "and "; }
$sql .= $field_name." = :".$field_name." ";
$parameters[$field_name] = $field_value;
$i++;
//set the message id
$m = 0;
//loop through the array
$checked = false;
if (is_array($array)) {
$x = 0;
foreach ($array as $parent_name => $tables) {
if (is_array($tables)) {
foreach ($tables as $id => $row) {
//prepare the variables
$parent_name = preg_replace('#[^a-zA-Z0-9_\-]#', '', $parent_name);
$parent_key_name = $this->singular($parent_name)."_uuid";
//build the delete array
if ($row['checked'] == 'true') {
//set checked to true
$checked = true;
//delete the child data
if (isset($row[$parent_key_name])) {
$new_array[$parent_name][$x][$parent_key_name] = $row[$parent_key_name];
}
//remove the row from the main array
unset($array[$parent_name][$x]);
}
//loop through the fields
foreach($row as $field_name => $field_value) {
//find the child tables
$y = 0;
if (is_array($field_value)) {
//prepare the variables
$child_name = preg_replace('#[^a-zA-Z0-9_\-]#', '', $field_name);
$child_key_name = $this->singular($child_name)."_uuid";
//loop through the child rows
foreach ($field_value as $sub_row) {
//build the delete array
if ($row['checked'] == 'true') {
//set checked to true
$checked = true;
//delete the child data
$new_array[$child_name][][$child_key_name] = $sub_row[$child_key_name];
//remove the row from the main array
unset($array[$parent_name][$x][$child_name][$y]);
}
//increment the value
$y++;
}
}
}
//increment the value
$x++;
}
if (strlen($field_value) > 0) {
$results = $this->execute($sql, $parameters, 'all');
if (is_array($results)) {
$array[$table_name] = $results;
}
}
unset($parameters);
}
}
}
//save the array
$old_array = &$array;
//if not checked then copy the array to delete array
if (!$checked) {
$new_array = $array;
}
//get the current data
if (is_array($new_array) && count($new_array) > 0) {
//build an array of tables, fields, and values
foreach($new_array as $table_name => $rows) {
foreach($rows as $row) {
foreach($row as $field_name => $field_value) {
$keys[$table_name][$field_name][] = $field_value;
}
}
}
//use the array to get a copy of the parent data before deleting it
foreach($new_array as $table_name => $rows) {
foreach($rows as $row) {
$table_name = preg_replace('#[^a-zA-Z0-9_\-]#', '', $table_name);
$sql = "select * from ".$table_prefix.$table_name." ";
$i = 0;
foreach($row as $field_name => $field_value) {
if ($i == 0) { $sql .= "where "; } else { $sql .= "and "; }
$sql .= $field_name." in ( ";
$i = 0;
foreach($keys[$table_name][$field_name] as $field_value) {
$field_name = preg_replace('#[^a-zA-Z0-9_\-]#', '', $field_name);
if ($i > 0) { $sql .= " ,"; }
$sql .= " :".$field_name."_".$i." ";
$i++;
}
$sql .= ") ";
$i = 0;
foreach($keys[$table_name][$field_name] as $field_value) {
$parameters[$field_name.'_'.$i] = $field_value;
$i++;
}
}
}
if (strlen($field_value) > 0) {
$results = $this->execute($sql, $parameters, 'all');
unset($parameters);
if (is_array($results)) {
$old_array[$table_name] = $results;
}
}
}
//add child data to the old array
foreach($old_array as $parent_name => $rows) {
//get relations array
$relations = $this->get_relations($parent_name);
//loop through the rows
$x = 0;
foreach($rows as $row) {
if (is_array($relations)) {
foreach ($relations as $relation) {
//set the child table
$child_table = $relation['table'];
//remove the v_ prefix
if (substr($child_table, 0, 2) == "v_") {
$child_table = substr($child_table, 2);
}
//get the child data
$sql = "select * from ".$table_prefix.$child_table." ";
$sql .= "where ".$relation['field']." = :".$relation['field'];
$parameters[$relation['field']] = $row[$relation['field']];
$results = $this->execute($sql, $parameters, 'all');
unset($parameters);
if (is_array($results)) {
$old_array[$parent_name][$x][$child_table] = $results;
}
//delete the child data
$sql = "delete from ".$table_prefix.$child_table." ";
$sql .= "where ".$relation['field']." = :".$relation['field'];
$parameters[$relation['field']] = $row[$relation['field']];
$this->execute($sql, $parameters);
unset($parameters);
}
}
$x++;
}
}
}
//start the atomic transaction
$this->db->beginTransaction();
//delete the current data
if (is_array($delete_array)) {
foreach($delete_array as $table_name => $rows) {
if (is_array($new_array)) {
foreach($new_array as $table_name => $rows) {
//echo "table: ".$table_name."\n";
foreach($rows as $row) {
if (permission_exists($this->singular($table_name).'_delete')) {
@@ -1143,6 +1279,338 @@ include "root.php";
return $this;
}
public function copy($array) {
//return the array
if (!is_array($array)) { echo "not an array"; return false; }
//set the table prefix
$table_prefix = 'v_';
//set the message id
$m = 0;
//loop through the array
if (is_array($array)) {
$x = 0;
foreach ($array as $parent_name => $tables) {
if (is_array($tables)) {
foreach ($tables as $id => $row) {
//prepare the variables
$parent_name = preg_replace('#[^a-zA-Z0-9_\-]#', '', $parent_name);
$parent_key_name = $this->singular($parent_name)."_uuid";
//build the copy array
if ($row['checked'] == 'true') {
//set checked to true
$checked = true;
//copy the child data
$copy_array[$parent_name][$x][$parent_key_name] = $row[$parent_key_name];
//remove the row from the main array
unset($array[$parent_name][$x]);
}
//loop through the fields
foreach($row as $field_name => $field_value) {
//find the child tables
$y = 0;
if (is_array($field_value)) {
//prepare the variables
$child_name = preg_replace('#[^a-zA-Z0-9_\-]#', '', $field_name);
$child_key_name = $this->singular($child_name)."_uuid";
//loop through the child rows
foreach ($field_value as $sub_row) {
//build the delete array
if ($sub_row['checked'] == 'true') {
//delete the child data
$copy_array[$child_name][$y][$child_key_name] = $sub_row[$child_key_name];
//remove the row from the main array
unset($array[$parent_name][$x][$child_name][$y]);
}
//increment the value
$y++;
}
}
}
//increment the value
$x++;
}
}
}
}
//get the current data
if (is_array($copy_array) && count($copy_array) > 0) {
//build an array of tables, fields, and values
foreach($copy_array as $table_name => $rows) {
foreach($rows as $row) {
foreach($row as $field_name => $field_value) {
$keys[$table_name][$field_name][] = $field_value;
}
}
}
//unset the array
unset($array);
//use the array to get a copy of the paent data before deleting it
foreach($copy_array as $table_name => $rows) {
foreach($rows as $row) {
$table_name = preg_replace('#[^a-zA-Z0-9_\-]#', '', $table_name);
$sql = "select * from ".$table_prefix.$table_name." ";
$i = 0;
foreach($row as $field_name => $field_value) {
if ($i == 0) { $sql .= "where "; } else { $sql .= "and "; }
$sql .= $field_name." in ( ";
$i = 0;
foreach($keys[$table_name][$field_name] as $field_value) {
$field_name = preg_replace('#[^a-zA-Z0-9_\-]#', '', $field_name);
if ($i > 0) { $sql .= " ,"; }
$sql .= " :".$field_name."_".$i." ";
$i++;
}
$sql .= ") ";
$i = 0;
foreach($keys[$table_name][$field_name] as $field_value) {
$parameters[$field_name.'_'.$i] = $field_value;
$i++;
}
}
}
$results = $this->execute($sql, $parameters, 'all');
unset($parameters);
if (is_array($results)) {
$array[$table_name] = $results;
}
}
//add child data to the old array
foreach($copy_array as $parent_name => $rows) {
//get relations array
$relations = $this->get_relations($parent_name);
//loop through the rows
$x = 0;
foreach($rows as $row) {
if (is_array($relations)) {
foreach ($relations as $relation) {
//set the child table
$child_table = $relation['table'];
//remove the v_ prefix
if (substr($child_table, 0, 2) == "v_") {
$child_table = substr($child_table, 2);
}
//get the child data
$sql = "select * from ".$table_prefix.$child_table." ";
$sql .= "where ".$relation['field']." = :".$relation['field'];
$parameters[$relation['field']] = $row[$relation['field']];
$results = $this->execute($sql, $parameters, 'all');
unset($parameters);
if (is_array($results)) {
$array[$parent_name][$x][$child_table] = $results;
}
}
}
$x++;
}
}
}
//update the parent and child keys
$checked = false;
if (is_array($array)) {
$x = 0;
foreach ($array as $parent_name => $tables) {
if (is_array($tables)) {
foreach ($tables as $id => $row) {
//prepare the variables
$parent_name = preg_replace('#[^a-zA-Z0-9_\-]#', '', $parent_name);
$parent_key_name = $this->singular($parent_name)."_uuid";
$parent_key_value = uuid();
//update the parent key id
$array[$parent_name][$x][$parent_key_name] = $parent_key_value;
//add copy to the description
if (isset($array[$parent_name][$x][$this->singular($parent_name).'_description'])) {
$array[$parent_name][$x][$this->singular($parent_name).'_description'] = '(Copy) '.$array[$parent_name][$x][$this->singular($parent_name).'_description'];
}
//loop through the fields
foreach($row as $field_name => $field_value) {
//find the child tables
$y = 0;
if (is_array($field_value)) {
//prepare the variables
$child_name = preg_replace('#[^a-zA-Z0-9_\-]#', '', $field_name);
$child_key_name = $this->singular($child_name)."_uuid";
//loop through the child rows
foreach ($field_value as $sub_row) {
//update the parent key id
$array[$parent_name][$x][$child_name][$y][$parent_key_name] = $parent_key_value;
//udpate the child key id
$array[$parent_name][$x][$child_name][$y][$child_key_name] = uuid();
//increment the value
$y++;
}
}
}
//increment the value
$x++;
}
}
}
}
//save the copy of the data
if (is_array($array) && count($array) > 0) {
$this->save($array);
unset($array);
}
} //end function copy
public function toggle($array) {
//return the array
if (!is_array($array)) { echo "not an array"; return false; }
//set the message id
$m = 0;
//loop through the array
if (is_array($array)) {
$x = 0;
foreach ($array as $parent_name => $tables) {
if (is_array($tables)) {
foreach ($tables as $id => $row) {
//prepare the variables
$parent_name = preg_replace('#[^a-zA-Z0-9_\-]#', '', $parent_name);
$parent_key_name = $this->singular($parent_name)."_uuid";
//build the toggle array
if ($row['checked'] == 'true') {
//toggle the field value
//$toggle_array[$parent_name][$x][$parent_key_name] = $row[$parent_key_name];
$toggle_array[$parent_name][$x] = $row;
//remove the row from the main array
unset($array[$parent_name][$x]);
}
//loop through the fields
foreach($row as $field_name => $field_value) {
//find the child tables
$y = 0;
if (is_array($field_value)) {
//prepare the variables
$child_name = preg_replace('#[^a-zA-Z0-9_\-]#', '', $field_name);
$child_key_name = $this->singular($child_name)."_uuid";
//loop through the child rows
foreach ($field_value as $sub_row) {
//build the delete array
if ($action == 'delete' && $sub_row['checked'] == 'true') {
//delete the child data
$delete_array[$child_name][$y][$child_key_name] = $sub_row[$child_key_name];
//remove the row from the main array
unset($array[$parent_name][$x][$child_name][$y]);
}
//increment the value
$y++;
}
}
}
//increment the value
$x++;
}
}
}
}
//unset the original array
unset($array);
//get the $apps array from the installed apps from the core and mod directories
if (!is_array($_SESSION['apps'])) {
$this->get_apps();
}
//search through all fields to see if toggle field exists
if (is_array($_SESSION['apps'])) {
foreach ($_SESSION['apps'] as $x => $app) {
if (is_array($app['db'])) {
foreach ($app['db'] as $y => $row) {
if (is_array($row['table']['name'])) {
$table_name = $row['table']['name']['text'];
}
else {
$table_name = $row['table']['name'];
}
if ($table_name === 'v_'.$parent_name) {
if (is_array($row['fields'])) {
foreach ($row['fields'] as $field) {
if (isset($field['toggle'])) {
$toggle_field = $field['name'];
$toggle_values = $field['toggle'];
}
}
}
}
}
}
}
}
//get the current values from the database
foreach ($toggle_array as $table_name => $table) {
$x = 0;
foreach($table as $row) {
$child_name = preg_replace('#[^a-zA-Z0-9_\-]#', '', $table_name);
$child_key_name = $this->singular($child_name)."_uuid";
$array[$table_name][$x][$child_key_name] = $row[$child_key_name];
$array[$table_name][$x][$toggle_field] = ($row[$toggle_field] === $toggle_values[0]) ? $toggle_values[1] : $toggle_values[0];
$x++;
}
}
unset($toggle_array);
//save the array
$this->save($array);
//view_array($this->message);
} //end function toggle
public function save($array) {
//return the array
@@ -1156,18 +1624,18 @@ include "root.php";
$this->app_name = $this->name;
}
//normalize the array structure
//$new_array = $this->normalize_array($array, $this->name);
//unset($array);
$new_array = $array;
//debug sql
$this->debug["sql"] = true;
//connect to the database if needed
if (!$this->db) {
$this->connect();
}
//debug sql
$this->debug["sql"] = true;
//normalize the array structure
//$new_array = $this->normalize_array($array, $this->name);
//unset($array);
$new_array = $array;
//start the atomic transaction
$this->db->beginTransaction();
@@ -1485,7 +1953,7 @@ include "root.php";
$child_field_names = array();
if (is_array($row)) {
foreach ($row as $k => $v) {
if (!is_array($v)) {
if (!is_array($v) && $k !== 'checked') {
$child_field_names[] = preg_replace('#[^a-zA-Z0-9_\-]#', '', $k);
}
}
@@ -1500,6 +1968,7 @@ include "root.php";
//get the data
$prep_statement->execute();
$child_array = $prep_statement->fetch(PDO::FETCH_ASSOC);
//set the action
if (is_array($child_array)) {
$action = "update";
@@ -1507,6 +1976,7 @@ include "root.php";
else {
$action = "add";
}
//add to the parent array
if (is_array($child_array)) {
$old_array[$schema_name][$schema_id][$key][] = $child_array;
@@ -1931,15 +2401,22 @@ include "root.php";
if (!is_array($_SESSION['apps'])) {
$this->get_apps();
}
//search through all fields to see if domain_uuid exists
$apps = $_SESSION['apps'];
if (is_array($apps)) {
foreach ($apps as $x => &$app) {
if (is_array($app['db'])) {
foreach ($app['db'] as $y => &$row) {
if ($row['table'] == $name) {
if (is_array($row['table']['name'])) {
$table_name = $row['table']['name']['text'];
}
else {
$table_name = $row['table']['name'];
}
if ($table_name === 'v_'.$name) {
if (is_array($row['fields'])) {
foreach ($row['fields'] as $z => $field) {
foreach ($row['fields'] as $field) {
if ($field['name'] == "domain_uuid") {
return true;
}
@@ -1950,10 +2427,67 @@ include "root.php";
} //is array
} //foreach
} //is array
//not found
return false;
}
private function get_relations($schema) {
//remove the v_ prefix
if (substr($schema, 0, 2) == "v_") {
$schema = substr($schema, 2);
}
//sanitize the values
$schema = preg_replace('#[^a-zA-Z0-9_\-]#', '', $schema);
//get the apps array
$config_list = glob($_SERVER["DOCUMENT_ROOT"] . PROJECT_PATH . "/{core,app}/{".$schema.",".$this->singular($schema)."}/app_config.php", GLOB_BRACE);
foreach ($config_list as &$config_path) {
include($config_path);
}
//search through all fields to find relations
$i = 0;
if (is_array($apps)) {
foreach ($apps as $x => &$app) {
foreach ($app['db'] as $y => &$row) {
foreach ($row['fields'] as $z => $field) {
if ($field['deprecated'] != "true") {
if ($field['key']['type'] == "foreign") {
if ($row['table']['name'] == "v_".$schema || $field['key']['reference']['table'] == "v_".$schema) {
//get the field name
if (is_array($field['name'])) {
$field_name = trim($field['name']['text']);
}
else {
$field_name = trim($field['name']);
}
//build the array
$array[$i]['table'] = $row['table']['name'];
$array[$i]['field'] = $field_name;
$array[$i]['key']['table'] = $field['key']['reference']['table'];
$array[$i]['key']['field'] = $field['key']['reference']['field'];
//increment the value
$i++;
}
}
}
unset($field_name);
}
}
}
}
//return the array
if (is_array($array)) {
return $array;
} else {
return false;
}
}
} //class database
} //!class_exists