iNextrix / ASTPP

web_interface/astpp/application/modules/systems/views/view_systemconf.php

Spacing +14 added lines, -14 removed lines

@@ -176,35 +176,35 @@
               <fieldset>

                <legend> <?=ucfirst($group_title)?></legend>

                   <div style="width:50%;float:left;">

-                    <?php $currency = Common_model::$global_config['system_config']['base_currency'];?>

-                    <?php $count=ceil(sizeof($details)/2); $i=0; $class="tleft";?>

-                    <?php foreach($details as$key=>$val){ ?>

-                          <?php if($count==$i){

+                    <?php $currency = Common_model::$global_config['system_config']['base_currency']; ?>

+                    <?php $count = ceil(sizeof($details) / 2); $i = 0; $class = "tleft"; ?>

+                    <?php foreach ($details as$key=>$val) { ?>

+                          <?php if ($count == $i) {

 							  echo '</div><div style="width:50%;float:left;">';

-							  $class="tright";

+							  $class = "tright";

 						  } ?>

                           <div class="col-md-12">

                             <div class="<?=$class?>" href='#'>

-                            <label class="col-md-5 no-padding"><?php echo $val['display_name'];?> * </label>

-                            <?php if(method_exists($this->common,$val['field_type'])){

-								$option_array =  $this->common->$val['field_type'](); 

+                            <label class="col-md-5 no-padding"><?php echo $val['display_name']; ?> * </label>

+                            <?php if (method_exists($this->common, $val['field_type'])) {

+								$option_array = $this->common->$val['field_type'](); 

 								$drpstr = '<select name="'.$val['name'].'" class="col-md-5 form-control selectpicker"  data-live-search="true">';

-									  foreach($option_array as $option_key=>$option_val){

-										$selected = ($val['value'] == $option_key)? "selected='selected'":"";

+									  foreach ($option_array as $option_key=>$option_val) {

+										$selected = ($val['value'] == $option_key) ? "selected='selected'" : "";

 										$drpstr .= '<option value="'.$option_key.'"'.$selected.'>'.$option_val.'</option>';

 									  }

 								$drpstr .= '</select>';

 								echo $drpstr;

 								unset($drpstr);

-							} else{ ?>

-								<input name="<?php echo $val['name'] ?>" value='<?php echo isset($val['value'])?$val['value']:''; ?>' size="20" maxlength="100" class="col-md-5 form-control" type="text">

+							} else { ?>

+								<input name="<?php echo $val['name'] ?>" value='<?php echo isset($val['value']) ? $val['value'] : ''; ?>' size="20" maxlength="100" class="col-md-5 form-control" type="text">

 						<?php }?>

-                              <span class="demo"><?php echo str_replace('smtp',"SMTP",$val['comment']);?></span>

+                              <span class="demo"><?php echo str_replace('smtp', "SMTP", $val['comment']); ?></span>

 

                             </div>

                           </div>  

 

-                      <?php $i++;?>

+                      <?php $i++; ?>

                     <?php }?>

                   </div>

               </fieldset>

freeswitch/fs/lib/astpp.db.php

Spacing +21 added lines, -21 removed lines

@@ -27,18 +27,18 @@ 
 	private $errorCallbackFunction;
 	private $errorMsgFormat;
 	public function __construct($dsn = "", $user = "", $passwd = "") {
-		$config = parse_ini_file ( "/var/lib/astpp/astpp-config.conf" );
+		$config = parse_ini_file("/var/lib/astpp/astpp-config.conf");
 		
-		$options = array (
+		$options = array(
 				PDO::ATTR_PERSISTENT => true,
 				PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION 
 		);
 		
 		try {
-			parent::__construct ( "mysql:host=" . $config ['dbhost'] . ";dbname=" . $config ['dbname'] . "", $config ['dbuser'], $config ['dbpass'], $options );
-		} catch ( PDOException $e ) {
+			parent::__construct("mysql:host=".$config ['dbhost'].";dbname=".$config ['dbname']."", $config ['dbuser'], $config ['dbpass'], $options);
+		} catch (PDOException $e) {
 			
-			$this->error = $e->getMessage ();
+			$this->error = $e->getMessage();
 		}
 		echo $this->error;
 	}
@@ -48,39 +48,39 @@ 
 	 * @param string $bind        	
 	 */
 	public function cleanup($bind) {
-		if (! is_array ( $bind )) {
-			if (! empty ( $bind ))
-				$bind = array (
+		if ( ! is_array($bind)) {
+			if ( ! empty ($bind))
+				$bind = array(
 						$bind 
 				);
 			else
-				$bind = array ();
+				$bind = array();
 		}
 		return $bind;
 	}
 	public function run($sql, $bind = "") {
-		$this->sql = trim ( $sql );
-		$this->bind = $this->cleanup ( $bind );
+		$this->sql = trim($sql);
+		$this->bind = $this->cleanup($bind);
 		$this->error = "";
 		
 		try {
-			$pdostmt = $this->prepare ( $this->sql );
-			if ($pdostmt->execute ( $this->bind ) !== false) {
-				if (preg_match ( "/^(" . implode ( "|", array (
+			$pdostmt = $this->prepare($this->sql);
+			if ($pdostmt->execute($this->bind) !== false) {
+				if (preg_match("/^(".implode("|", array(
 						"select",
 						"describe",
 						"pragma" 
-				) ) . ") /i", $this->sql ))
-					return $pdostmt->fetchAll ( PDO::FETCH_ASSOC );
-				elseif (preg_match ( "/^(" . implode ( "|", array (
+				)).") /i", $this->sql))
+					return $pdostmt->fetchAll(PDO::FETCH_ASSOC);
+				elseif (preg_match("/^(".implode("|", array(
 						"delete",
 						"insert",
 						"update" 
-				) ) . ") /i", $this->sql ))
-					return $pdostmt->rowCount ();
+				)).") /i", $this->sql))
+					return $pdostmt->rowCount();
 			}
-		} catch ( PDOException $e ) {
-			$this->error = $e->getMessage ();
+		} catch (PDOException $e) {
+			$this->error = $e->getMessage();
 			return $this->error;
 		}
 	}

freeswitch/fs/lib/astpp.xml.php

Spacing +61 added lines, -61 removed lines

@@ -23,7 +23,7 @@ 
 
 // If module/app not found
 function xml_not_found() {
-	header ( 'Content-Type: text/xml' );
+	header('Content-Type: text/xml');
 	
 	$xml = "<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"no\"?>\n";
 	$xml .= "<document type=\"freeswitch/xml\">\n";
@@ -46,28 +46,28 @@ 
 	
 	// For customer and provider ips
 	$query = "SELECT ip FROM ip_map,accounts WHERE ip_map.accountid=accounts.id AND ip_map.status=0 AND accounts.status=0 AND accounts.deleted=0";
-	$logger->log ( "ACL Query : " . $query );
-	$res_acl = $db->run ( $query );
-	$logger->log ( $res_acl );
+	$logger->log("ACL Query : ".$query);
+	$res_acl = $db->run($query);
+	$logger->log($res_acl);
 	
-	foreach ( $res_acl as $res_acl_key => $res_acl_value ) {
-		$xml .= "       <node type=\"allow\" cidr=\"" . $res_acl_value ['ip'] . "\"/>\n";
+	foreach ($res_acl as $res_acl_key => $res_acl_value) {
+		$xml .= "       <node type=\"allow\" cidr=\"".$res_acl_value ['ip']."\"/>\n";
 	}
 	
 	// For gateways
 	$query = "SELECT * FROM gateways WHERE status=0";
-	$logger->log ( "Sofia Gateway Query : " . $query );
-	$sp_gw = $db->run ( $query );
-	$logger->log ( $sp_gw );
+	$logger->log("Sofia Gateway Query : ".$query);
+	$sp_gw = $db->run($query);
+	$logger->log($sp_gw);
 	
-	foreach ( $sp_gw as $sp_gw_key => $sp_gw_value ) {
+	foreach ($sp_gw as $sp_gw_key => $sp_gw_value) {
 		
-		$sp_gw_settings = json_decode ( $sp_gw_value ['gateway_data'], true );
-		foreach ( $sp_gw_settings as $sp_gw_settings_key => $sp_gw_settings_value ) {
+		$sp_gw_settings = json_decode($sp_gw_value ['gateway_data'], true);
+		foreach ($sp_gw_settings as $sp_gw_settings_key => $sp_gw_settings_value) {
 			if ($sp_gw_settings_value != "" && $sp_gw_settings_key == "proxy") {
-				$tmp_ip_arr = explode ( ":", $sp_gw_settings_value );
-				if (! filter_var ( $tmp_ip_arr [0], FILTER_VALIDATE_IP ) === false) {
-					$xml .= "   <node type=\"allow\" cidr=\"" . $tmp_ip_arr [0] . "/32\"/>\n";
+				$tmp_ip_arr = explode(":", $sp_gw_settings_value);
+				if ( ! filter_var($tmp_ip_arr [0], FILTER_VALIDATE_IP) === false) {
+					$xml .= "   <node type=\"allow\" cidr=\"".$tmp_ip_arr [0]."/32\"/>\n";
 				}
 			}
 		}
@@ -75,7 +75,7 @@ 
 	
 	// For opensips
 	if ($config ['opensips'] == '0') {
-		$xml .= "<node type=\"allow\" cidr=\"" . $config ['opensips_domain'] . "/32\"/>\n";
+		$xml .= "<node type=\"allow\" cidr=\"".$config ['opensips_domain']."/32\"/>\n";
 	}
 	
 	$xml .= "       </list>\n";
@@ -83,20 +83,20 @@ 
 	// For loopback
 	if ($config ['opensips'] == '0') {
 		$xml .= "<list name=\"loopback.auto\" default=\"allow\">\n";
-		$xml .= "<node type=\"allow\" cidr=\"" . $config ['opensips_domain'] . "/32\"/>\n";
+		$xml .= "<node type=\"allow\" cidr=\"".$config ['opensips_domain']."/32\"/>\n";
 		$xml .= "</list>\n";
 	}
 	
 	// For event handing
 	$xml .= "<list name=\"event\" default=\"deny\">\n";
-	$xml .= ($config ['opensips'] == "0") ? "<node type=\"allow\" cidr=\"" . $config ['opensips_domain'] . "/32\"/>\n" : "\n";
+	$xml .= ($config ['opensips'] == "0") ? "<node type=\"allow\" cidr=\"".$config ['opensips_domain']."/32\"/>\n" : "\n";
 	$xml .= "<node type=\"allow\" cidr=\"127.0.0.0/8\"/>\n";
 	$xml .= "</list>\n";
 	$xml .= "           </network-lists>\n";
 	$xml .= "       </configuration>\n";
 	$xml .= "   </section>\n";
 	$xml .= "</document>\n";
-	$logger->log ( $xml );
+	$logger->log($xml);
 	return $xml;
 }
 
@@ -109,18 +109,18 @@ 
 	$xml .= "   <profiles>\n";
 	
 	$query = "SELECT * FROM sip_profiles WHERE status=0";
-	$logger->log ( "Sofia Query : " . $query );
-	$res_sp = $db->run ( $query );
+	$logger->log("Sofia Query : ".$query);
+	$res_sp = $db->run($query);
 	// $logger->log($res_sp);
 	
-	foreach ( $res_sp as $sp_key => $sp_value ) {
+	foreach ($res_sp as $sp_key => $sp_value) {
 		
-		$settings = json_decode ( $sp_value ['profile_data'], true );
+		$settings = json_decode($sp_value ['profile_data'], true);
 		// $logger->log(print_r($settings,true));
-		$xml .= "   <profile name=\"" . $sp_value ['name'] . "\">\n";
+		$xml .= "   <profile name=\"".$sp_value ['name']."\">\n";
 		
 		$xml .= "   <domains>\n";
-		$xml .= "       <domain name=\"" . $sp_value ['sip_ip'] . "\" alias=\"true\" parse=\"true\"/>\n";
+		$xml .= "       <domain name=\"".$sp_value ['sip_ip']."\" alias=\"true\" parse=\"true\"/>\n";
 		$xml .= "   </domains>\n";
 		/*
 		 * $xml .= " <aliases>\n";
@@ -129,26 +129,26 @@ 
 		 */
 		
 		$xml .= "   <settings>\n";
-		$xml .= "       <param name=\"sip-ip\" value=\"" . $sp_value ['sip_ip'] . "\"/>\n";
-		$xml .= "       <param name=\"sip-port\" value=\"" . $sp_value ['sip_port'] . "\"/>\n";
-		foreach ( $settings as $set_key => $set_val ) {
-			$xml .= "       <param name=\"" . $set_key . "\" value=\"" . $set_val . "\"/>\n";
+		$xml .= "       <param name=\"sip-ip\" value=\"".$sp_value ['sip_ip']."\"/>\n";
+		$xml .= "       <param name=\"sip-port\" value=\"".$sp_value ['sip_port']."\"/>\n";
+		foreach ($settings as $set_key => $set_val) {
+			$xml .= "       <param name=\"".$set_key."\" value=\"".$set_val."\"/>\n";
 		}
 		$xml .= "   </settings>\n";
 		
 		// Gateway block start
 		$xml .= "   <gateways>\n";
-		$query = "SELECT * FROM gateways WHERE sip_profile_id=" . $sp_value ['id'] . " AND status=0";
-		$logger->log ( "Sofia Gateway Query : " . $query );
-		$sp_gw = $db->run ( $query );
-		$logger->log ( $sp_gw );
-		foreach ( $sp_gw as $sp_gw_key => $sp_gw_value ) {
-			$xml .= "       <gateway name=\"" . $sp_gw_value ['name'] . "\">\n";
+		$query = "SELECT * FROM gateways WHERE sip_profile_id=".$sp_value ['id']." AND status=0";
+		$logger->log("Sofia Gateway Query : ".$query);
+		$sp_gw = $db->run($query);
+		$logger->log($sp_gw);
+		foreach ($sp_gw as $sp_gw_key => $sp_gw_value) {
+			$xml .= "       <gateway name=\"".$sp_gw_value ['name']."\">\n";
 			
-			$sp_gw_settings = json_decode ( $sp_gw_value ['gateway_data'], true );
-			foreach ( $sp_gw_settings as $sp_gw_settings_key => $sp_gw_settings_value ) {
+			$sp_gw_settings = json_decode($sp_gw_value ['gateway_data'], true);
+			foreach ($sp_gw_settings as $sp_gw_settings_key => $sp_gw_settings_value) {
 				if ($sp_gw_settings_value != "")
-					$xml .= "           <param name=\"" . $sp_gw_settings_key . "\" value=\"" . $sp_gw_settings_value . "\"/>\n";
+					$xml .= "           <param name=\"".$sp_gw_settings_key."\" value=\"".$sp_gw_settings_value."\"/>\n";
 			}
 			$xml .= "       </gateway>\n";
 		}
@@ -162,47 +162,47 @@ 
 	$xml .= "   </configuration>\n";
 	$xml .= "   </section>\n";
 	$xml .= "</document>\n";
-	$logger->log ( $xml );
+	$logger->log($xml);
 	return $xml;
 }
 function update_vm_data($logger, $db, $password, $user) {
-	$query = "SELECT * FROM sip_devices where username='" . $_REQUEST ['user'] . "' limit 1";
-	$logger->log ( "Directory Query : " . $query );
-	$res_dir = $db->run ( $query );
-	$params = json_decode ( $res_dir [0] ['dir_params'], true );
+	$query = "SELECT * FROM sip_devices where username='".$_REQUEST ['user']."' limit 1";
+	$logger->log("Directory Query : ".$query);
+	$res_dir = $db->run($query);
+	$params = json_decode($res_dir [0] ['dir_params'], true);
 	$params ['vm-password'] = $password;
 	
-	$query = "update sip_devices set dir_params = '" . json_encode ( $params, true ) . "' where username='" . $_REQUEST ['user'] . "' limit 1";
-	$res_dir = $db->run ( $query );
+	$query = "update sip_devices set dir_params = '".json_encode($params, true)."' where username='".$_REQUEST ['user']."' limit 1";
+	$res_dir = $db->run($query);
 }
 
 // Build directory xml
 function load_directory($logger, $db) {
 	$xml = "";
 	
-	$query = "SELECT username,dir_params,dir_vars,number as accountcode,accountid FROM sip_devices,accounts WHERE sip_devices.status=0 AND accounts.status=0 AND accounts.deleted=0 AND accounts.id=sip_devices.accountid AND username='" . $_REQUEST ['user'] . "' limit 1";
+	$query = "SELECT username,dir_params,dir_vars,number as accountcode,accountid FROM sip_devices,accounts WHERE sip_devices.status=0 AND accounts.status=0 AND accounts.deleted=0 AND accounts.id=sip_devices.accountid AND username='".$_REQUEST ['user']."' limit 1";
 	
-	$logger->log ( "Directory Query : " . $query );
-	$res_dir = $db->run ( $query );
-	$logger->log ( $res_dir );
+	$logger->log("Directory Query : ".$query);
+	$res_dir = $db->run($query);
+	$logger->log($res_dir);
 	
-	foreach ( $res_dir as $res_dir_key => $res_dir_value ) {
+	foreach ($res_dir as $res_dir_key => $res_dir_value) {
 		$xml = "<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"no\"?>\n";
 		$xml .= "<document type=\"freeswitch/xml\">\n";
 		$xml .= "   <section name=\"Directory\" description=\"Directory\">\n";
-		$xml .= "       <domain name=\"" . $_REQUEST ['domain'] . "\" alias=\"true\">\n";
-		$xml .= "           <user id=\"" . $_REQUEST ['user'] . "\">\n";
+		$xml .= "       <domain name=\"".$_REQUEST ['domain']."\" alias=\"true\">\n";
+		$xml .= "           <user id=\"".$_REQUEST ['user']."\">\n";
 		
-		$params = json_decode ( $res_dir_value ['dir_params'], true );
+		$params = json_decode($res_dir_value ['dir_params'], true);
 		
-		$vars = json_decode ( $res_dir_value ['dir_vars'], true );
+		$vars = json_decode($res_dir_value ['dir_vars'], true);
 		$param_xml = $var_xml = "";
-		foreach ( $params as $parms_key => $res_dir_params ) {
-			$param_xml .= "<param name=\"" . $parms_key . "\" value=\"" . $res_dir_params . "\"/>\n";
+		foreach ($params as $parms_key => $res_dir_params) {
+			$param_xml .= "<param name=\"".$parms_key."\" value=\"".$res_dir_params."\"/>\n";
 		}
 		
-		foreach ( $vars as $var_key => $res_dir_vars ) {
-			$var_xml .= "<variable name=\"" . $var_key . "\" value=\"" . $res_dir_vars . "\"/>\n";
+		foreach ($vars as $var_key => $res_dir_vars) {
+			$var_xml .= "<variable name=\"".$var_key."\" value=\"".$res_dir_vars."\"/>\n";
 		}
 		
 		$xml .= "               <params>\n";
@@ -214,8 +214,8 @@ 
 		$xml .= "               <variables>\n";
 		$xml .= $var_xml;
 		$xml .= "<variable name=\"sipcall\" value=\"true\"/>\n";
-		$xml .= "<variable name=\"accountcode\" value=\"" . $res_dir_value ['accountcode'] . "\"/>\n";
-		$xml .= "<variable name=\"domain_name\" value=\"" . $_REQUEST ['domain'] . "\"/>\n";
+		$xml .= "<variable name=\"accountcode\" value=\"".$res_dir_value ['accountcode']."\"/>\n";
+		$xml .= "<variable name=\"domain_name\" value=\"".$_REQUEST ['domain']."\"/>\n";
 		$xml .= "               </variables>\n";
 		
 		$xml .= "           </user>\n";
@@ -224,7 +224,7 @@ 
 		$xml .= "</document>\n";
 	}
 	
-	$logger->log ( $xml );
+	$logger->log($xml);
 	return $xml;
 }
 

freeswitch/fs/lib/astpp.logger.php

Spacing +5 added lines, -5 removed lines

@@ -28,20 +28,20 @@
 		// $this->config['log_path'] = "/var/log/astpp/";
 		if ($this->config ['debug'] == '0') {
 			// $this->fp = fopen($this->config['log_path'] . 'astpp_' . date('Y-m-d') . '.txt', 'a+');
-			$this->fp = fopen ( $this->config ['log_path'] . 'astpp.log', 'a+' );
+			$this->fp = fopen($this->config ['log_path'].'astpp.log', 'a+');
 		}
 	}
 	function log($log) {
 		if ($this->config ['debug'] == '0') {
-			if (is_array ( $log ))
-				fwrite ( $this->fp, "[" . date ( 'Y-m-d H:i:s' ) . "] " . print_r ( $log, TRUE ) );
+			if (is_array($log))
+				fwrite($this->fp, "[".date('Y-m-d H:i:s')."] ".print_r($log, TRUE));
 			else
-				fwrite ( $this->fp, "[" . date ( 'Y-m-d H:i:s' ) . "] " . $log . "\n" );
+				fwrite($this->fp, "[".date('Y-m-d H:i:s')."] ".$log."\n");
 		}
 	}
 	function close() {
 		if ($this->config ['debug'] == '0')
-			fclose ( $this->fp );
+			fclose($this->fp);
 	}
 }
 

freeswitch/fs/lib/astpp.cdr.php

Spacing +116 added lines, -116 removed lines

@@ -26,8 +26,8 @@ 
 	// $logger->log(print_r($data,true));//exit;
 	
 	// Initializing variables
-	$origination_rate = array ();
-	$termination_rate = array ();
+	$origination_rate = array();
+	$termination_rate = array();
 	
 	// FS CDR variables
 	$dataVariable = $data ['variables'];
@@ -36,21 +36,21 @@ 
 	$dataCallflow = $data ['callflow'];
 	
 	// Get account id
-	$accountid = isset ( $dataVariable ['account_id'] ) ? $dataVariable ['account_id'] : '0';
+	$accountid = isset ($dataVariable ['account_id']) ? $dataVariable ['account_id'] : '0';
 	
 	// Get caller id name and number
-	$dataVariable ['effective_caller_id_name'] = (isset ( $dataVariable ['effective_caller_id_name'] )) ? $dataVariable ['effective_caller_id_name'] : $dataCallflow ['caller_profile'] ['caller_id_name'];
-	$dataVariable ['effective_caller_id_number'] = (isset ( $dataVariable ['effective_caller_id_number'] )) ? $dataVariable ['effective_caller_id_number'] : $dataCallflow ['caller_profile'] ['caller_id_number'];
+	$dataVariable ['effective_caller_id_name'] = (isset ($dataVariable ['effective_caller_id_name'])) ? $dataVariable ['effective_caller_id_name'] : $dataCallflow ['caller_profile'] ['caller_id_name'];
+	$dataVariable ['effective_caller_id_number'] = (isset ($dataVariable ['effective_caller_id_number'])) ? $dataVariable ['effective_caller_id_number'] : $dataCallflow ['caller_profile'] ['caller_id_number'];
 	
 	if ($dataVariable ['billsec'] == 0 && $dataVariable ['hangup_cause'] == 'NORMAL_CLEARING') {
-		$hangup_cause = isset ( $dataVariable ['last_bridge_hangup_cause'] ) ? $dataVariable ['last_bridge_hangup_cause'] : $dataVariable ['hangup_cause'];
+		$hangup_cause = isset ($dataVariable ['last_bridge_hangup_cause']) ? $dataVariable ['last_bridge_hangup_cause'] : $dataVariable ['hangup_cause'];
 	} else {
 		$hangup_cause = $dataVariable ['hangup_cause'];
 	}
 	
 	if ($dataVariable ['error_cdr'] == '1') {
 		// Get actual hangup cause
-		$hangup_cause = (isset ( $dataVariable ['error_cdr'] )) ? $dataVariable ['last_bridge_hangup_cause'] : (isset ( $dataVariable ['last_bridge_hangup_cause'] ) ? $dataVariable ['last_bridge_hangup_cause'] : $dataVariable ['hangup_cause']);
+		$hangup_cause = (isset ($dataVariable ['error_cdr'])) ? $dataVariable ['last_bridge_hangup_cause'] : (isset ($dataVariable ['last_bridge_hangup_cause']) ? $dataVariable ['last_bridge_hangup_cause'] : $dataVariable ['hangup_cause']);
 	}
 	
 	/* #### PATCH FOR ONE WAY AUDIO #### */
@@ -72,116 +72,116 @@ 
 	 * }
 	 */
 	
-	$account_type = (isset ( $dataVariable ['entity_id'] )) ? $dataVariable ['entity_id'] : '0';
-	$parentid = isset ( $dataVariable ['parent_id'] ) ? $dataVariable ['parent_id'] : '0';
+	$account_type = (isset ($dataVariable ['entity_id'])) ? $dataVariable ['entity_id'] : '0';
+	$parentid = isset ($dataVariable ['parent_id']) ? $dataVariable ['parent_id'] : '0';
 	$parent_cost = 0;
 	$cost = 0;
 	$dataVariable ['package_id'] = 0;
 	$actual_duration = $dataVariable ['billsec'];
-	$dataVariable ['calltype'] = isset ( $dataVariable ['calltype'] ) ? $dataVariable ['calltype'] : "STANDARD";
+	$dataVariable ['calltype'] = isset ($dataVariable ['calltype']) ? $dataVariable ['calltype'] : "STANDARD";
 	$actual_calltype = $dataVariable ['calltype'];
 	
 	// Normalize origination and termination rates array
-	if (isset ( $dataVariable ['origination_rates'] ))
-		$origination_rate = normalize_origination_rate ( $dataVariable ['origination_rates'] );
-	if (isset ( $dataVariable ['termination_rates'] ))
-		$termination_rate = normalize_rate ( $dataVariable ['termination_rates'] );
+	if (isset ($dataVariable ['origination_rates']))
+		$origination_rate = normalize_origination_rate($dataVariable ['origination_rates']);
+	if (isset ($dataVariable ['termination_rates']))
+		$termination_rate = normalize_rate($dataVariable ['termination_rates']);
 		
 		// If receiver account id found then explicitly set call direction and call type
-	if (isset ( $dataVariable ['receiver_accid'] )) {
+	if (isset ($dataVariable ['receiver_accid'])) {
 		$dataVariable ['call_direction'] = "outbound";
 		$dataVariable ['calltype'] = "STANDARD";
 	}
 	
 	// Check if cusotmer have any package seconds left to use
 	if ($actual_duration > 0) {
-		$package_array = package_calculation ( $dataVariable ['effective_destination_number'], $origination_rate [$accountid] ['RATEGROUP'], $actual_duration, $dataVariable ['call_direction'], $accountid, $db, $logger );
-		if (! empty ( $package_array )) {
+		$package_array = package_calculation($dataVariable ['effective_destination_number'], $origination_rate [$accountid] ['RATEGROUP'], $actual_duration, $dataVariable ['call_direction'], $accountid, $db, $logger);
+		if ( ! empty ($package_array)) {
 			$dataVariable ['calltype'] = "FREE";
 			$dataVariable ['package_id'] = $package_array ['package_id'];
 		}
 	}
 	
 	// Calculate debit of customer call
-	$debit = calc_cost ( $dataVariable, $origination_rate [$accountid], $logger, $decimal_points );
+	$debit = calc_cost($dataVariable, $origination_rate [$accountid], $logger, $decimal_points);
 	
 	// Calculate cost for customer call for provider
-	$provider_cost = calc_cost ( $dataVariable, $termination_rate, $logger, $decimal_points );
+	$provider_cost = calc_cost($dataVariable, $termination_rate, $logger, $decimal_points);
 	
 	// Calculate parent cost if customer have any parent
-	$parent_cost = ($parentid > 0) ? calc_cost ( $dataVariable, $origination_rate [$parentid], $logger, $decimal_points ) : $provider_cost;
-	$logger->log ( "Debit :" . $debit . " Cost : " . $cost . " Provider Cost : " . $parent_cost );
+	$parent_cost = ($parentid > 0) ? calc_cost ($dataVariable, $origination_rate [$parentid], $logger, $decimal_points) : $provider_cost;
+	$logger->log("Debit :".$debit." Cost : ".$cost." Provider Cost : ".$parent_cost);
 	
 	// Initialize final cost variable to use for billing
 	$cost = ($parent_cost > 0) ? $parent_cost : $provider_cost;
 	
 	// Outbound call entry for all type of calls
-	$logger->log ( "*********************** OUTBOUND CALL ENTRY START *************" );
+	$logger->log("*********************** OUTBOUND CALL ENTRY START *************");
 	
-	$cdr_string = get_cdr_string ( $dataVariable, $accountid, $account_type, $actual_duration, $termination_rate, $origination_rate, $provider_cost, $parentid, $debit, $cost, $logger );
+	$cdr_string = get_cdr_string($dataVariable, $accountid, $account_type, $actual_duration, $termination_rate, $origination_rate, $provider_cost, $parentid, $debit, $cost, $logger);
 	
 	$query = "INSERT INTO cdrs (uniqueid,accountid,type,callerid,callednum,billseconds,trunk_id,trunkip,callerip,disposition,callstart,debit,cost,provider_id,pricelist_id,package_id,pattern,notes,rate_cost,reseller_id,reseller_code,reseller_code_destination,reseller_cost,provider_code,provider_code_destination,provider_cost,provider_call_cost,call_direction,calltype,profile_start_stamp,answer_stamp,bridge_stamp,progress_stamp,progress_media_stamp,end_stamp,billmsec,answermsec,waitmsec,progress_mediamsec,flow_billmsec)  values ($cdr_string)";
-	$logger->log ( $query );
-	$db->run ( $query );
+	$logger->log($query);
+	$db->run($query);
 	
 	// Update customer balance
 	if ($debit > 0 && $dataVariable ['calltype'] != "FREE") {
-		update_balance ( $accountid, $debit, 0, $logger, $db );
+		update_balance($accountid, $debit, 0, $logger, $db);
 	}
 	
 	// Update parent or provider balance
 	if ($parent_cost > 0) {
-		update_balance ( $termination_rate ['PROVIDER'], ($parent_cost * - 1), 3, $logger, $db );
+		update_balance($termination_rate ['PROVIDER'], ($parent_cost * - 1), 3, $logger, $db);
 	}
 	
 	// Resellers CDR entry
 	$flag_parent = false;
-	insert_parent_data ( $dataVariable, $actual_calltype, $parentid, $origination_rate, $actual_duration, $provider_cost, $flag_parent, $logger, $db, $decimal_points );
+	insert_parent_data($dataVariable, $actual_calltype, $parentid, $origination_rate, $actual_duration, $provider_cost, $flag_parent, $logger, $db, $decimal_points);
 	
-	$logger->log ( "*********************** OUTBOUND CALL ENTRY END *************" );
+	$logger->log("*********************** OUTBOUND CALL ENTRY END *************");
 	
 	// ************ ADDING EXTRA ENTRY For local/DID Inbound call ****************************
 	$receiver_parentid = 0;
-	if (isset ( $dataVariable ['receiver_accid'] ) && $dataVariable ['receiver_accid'] != "") {
-		$logger->log ( "*********************** EXTRA ENTRY SECTION FOR BILLING START *************" );
+	if (isset ($dataVariable ['receiver_accid']) && $dataVariable ['receiver_accid'] != "") {
+		$logger->log("*********************** EXTRA ENTRY SECTION FOR BILLING START *************");
 		
 		// Explicitly set call direction and call type
 		$dataVariable ['call_direction'] = "inbound";
 		$dataVariable ['calltype'] = "DID";
 		// For inbound package calculation
 		if ($actual_duration > 0) {
-			$package_array = package_calculation ( $dataVariable ['effective_destination_number'], $origination_rate [$accountid] ['RATEGROUP'], $actual_duration, $dataVariable ['call_direction'], $accountid, $db, $logger );
-			if (! empty ( $package_array )) {
+			$package_array = package_calculation($dataVariable ['effective_destination_number'], $origination_rate [$accountid] ['RATEGROUP'], $actual_duration, $dataVariable ['call_direction'], $accountid, $db, $logger);
+			if ( ! empty ($package_array)) {
 				$dataVariable ['calltype'] = "FREE";
 				$dataVariable ['package_id'] = $package_array ['package_id'];
 			}
 		}
 		// Override variables if call for DID PSTN
-		if (isset ( $dataVariable ['caller_did_account_id'] )) {
+		if (isset ($dataVariable ['caller_did_account_id'])) {
 			$dataVariable ['receiver_accid'] = $dataVariable ['caller_did_account_id'];
 			$dataVariable ['call_direction'] = "outbound";
 			$dataVariable ['calltype'] = "STANDARD";
 			$dataVariable ['effective_destination_number'] = $dataVariable ['sip_to_user'];
-			unset ( $termination_rate );
-			unset ( $provider_cost );
+			unset ($termination_rate);
+			unset ($provider_cost);
 		}
 		
 		// Get call receiver account information
-		$receiver_carddata = get_accounts ( $dataVariable ['receiver_accid'], $logger, $db );
+		$receiver_carddata = get_accounts($dataVariable ['receiver_accid'], $logger, $db);
 		$receiver_parentid = $receiver_carddata ['reseller_id'];
 		
 		// For additional cdr entry of receiver
-		insert_extra_receiver_entry ( $dataVariable, $origination_rate, $termination_rate, $account_type, $actual_duration, $provider_cost, $receiver_parentid, $flag_parent, $dataVariable ['receiver_accid'], $logger, $db, $decimal_points );
+		insert_extra_receiver_entry($dataVariable, $origination_rate, $termination_rate, $account_type, $actual_duration, $provider_cost, $receiver_parentid, $flag_parent, $dataVariable ['receiver_accid'], $logger, $db, $decimal_points);
 		
 		$flag_parent = true;
-		$dataVariable ['uuid'] = $dataVariable ['uuid'] . $dataVariable ['calltype'] . "_" . $receiver_parentid;
+		$dataVariable ['uuid'] = $dataVariable ['uuid'].$dataVariable ['calltype']."_".$receiver_parentid;
 		
 		// Insert parent reseller cdr
-		insert_parent_data ( $dataVariable, $actual_calltype, $receiver_parentid, $origination_rate, $actual_duration, $provider_cost, $flag_parent, $logger, $db, $decimal_points );
-		$logger->log ( "*********************** EXTRA ENTRY SECTION FOR BILLING END *************" );
+		insert_parent_data($dataVariable, $actual_calltype, $receiver_parentid, $origination_rate, $actual_duration, $provider_cost, $flag_parent, $logger, $db, $decimal_points);
+		$logger->log("*********************** EXTRA ENTRY SECTION FOR BILLING END *************");
 	}
 	// *****************************************************************************************
-	$logger->log ( "*************************** CDR ends ********************************" );
+	$logger->log("*************************** CDR ends ********************************");
 }
 
 // Insert parent resellers cdr
@@ -191,13 +191,13 @@ 
  * @param boolean $flag_parent        	
  */
 function insert_parent_data($dataVariable, $actual_calltype, $parentid, $origination_rate, $actual_duration, $provider_cost, $flag_parent, $logger, $db, $decimal_points) {
-	while ( $parentid > 0 ) {
-		$logger->log ( "*************** IN PARENT DATA SECTION ********" );
+	while ($parentid > 0) {
+		$logger->log("*************** IN PARENT DATA SECTION ********");
 		$dataVariable ['calltype'] = $actual_calltype;
-		$carddata = get_accounts ( $parentid, $logger, $db );
+		$carddata = get_accounts($parentid, $logger, $db);
 		$accountid = $carddata ['id'];
 		
-		$debit = calc_cost ( $dataVariable, $origination_rate [$accountid], $logger, $decimal_points );
+		$debit = calc_cost($dataVariable, $origination_rate [$accountid], $logger, $decimal_points);
 		
 		// If receiver account id found then explicitly set call direction and call type
 		/*
@@ -210,8 +210,8 @@ 
 		
 		// Check if reseller have any package seconds left to use
 		if ($actual_duration > 0) {
-			$package_array = package_calculation ( $dataVariable ['effective_destination_number'], $origination_rate [$accountid] ['RATEGROUP'], $actual_duration, $dataVariable ['call_direction'], $accountid, $db, $logger );
-			if (! empty ( $package_array )) {
+			$package_array = package_calculation($dataVariable ['effective_destination_number'], $origination_rate [$accountid] ['RATEGROUP'], $actual_duration, $dataVariable ['call_direction'], $accountid, $db, $logger);
+			if ( ! empty ($package_array)) {
 				$dataVariable ['calltype'] = "FREE";
 				$dataVariable ['package_id'] = $package_array ['package_id'];
 			}
@@ -219,27 +219,27 @@ 
 		
 		// Get parent id for cost calculation
 		$parentid = $carddata ['reseller_id'];
-		$parent_cost = ($parentid > 0) ? calc_cost ( $dataVariable, $origination_rate [$parentid], $logger, $decimal_points ) : $provider_cost;
+		$parent_cost = ($parentid > 0) ? calc_cost ($dataVariable, $origination_rate [$parentid], $logger, $decimal_points) : $provider_cost;
 		$cost = ($parent_cost > 0) ? $parent_cost : $provider_cost;
 		
-		if (isset ( $dataVariable ['receiver_accid'] ) && $dataVariable ['receiver_accid'] != "" && $flag_parent == true) {
-			$logger->log ( "********* IN RESELLER FOR RECEIVER ENTRY START ******" );
+		if (isset ($dataVariable ['receiver_accid']) && $dataVariable ['receiver_accid'] != "" && $flag_parent == true) {
+			$logger->log("********* IN RESELLER FOR RECEIVER ENTRY START ******");
 			$flag_parent = true;
-			insert_extra_receiver_entry ( $dataVariable, $origination_rate, $termination_rate, $account_type, $actual_duration, $provider_cost, $parentid, $flag_parent, $accountid, $logger, $db, $decimal_points );
-			$logger->log ( "********* IN RESELLER FOR RECEIVER ENTRY END ******" );
+			insert_extra_receiver_entry($dataVariable, $origination_rate, $termination_rate, $account_type, $actual_duration, $provider_cost, $parentid, $flag_parent, $accountid, $logger, $db, $decimal_points);
+			$logger->log("********* IN RESELLER FOR RECEIVER ENTRY END ******");
 			return true;
 		} else {
 			
-			$cdr_string = get_reseller_cdr_string ( $dataVariable, $accountid, $account_type, $actual_duration, $termination_rate, $origination_rate, $provider_cost, $parentid, $debit, $cost );
+			$cdr_string = get_reseller_cdr_string($dataVariable, $accountid, $account_type, $actual_duration, $termination_rate, $origination_rate, $provider_cost, $parentid, $debit, $cost);
 			
 			$query = "INSERT INTO reseller_cdrs (uniqueid,accountid,callerid,callednum,billseconds,disposition,callstart,debit,cost,pricelist_id,package_id,pattern,notes,rate_cost,
 		reseller_id,reseller_code,reseller_code_destination,reseller_cost,call_direction,calltype) values ($cdr_string)";
-			$logger->log ( $query );
-			$db->run ( $query );
+			$logger->log($query);
+			$db->run($query);
 			
 			// Update reseller balance
 			if ($debit > 0 && $dataVariable ['calltype'] != "FREE") {
-				update_balance ( $accountid, $debit, 0, $logger, $db );
+				update_balance($accountid, $debit, 0, $logger, $db);
 			}
 		}
 		//return true;
@@ -255,26 +255,26 @@ 
 function insert_extra_receiver_entry($dataVariable, $origination_rate, $termination_rate, $account_type, $actual_duration, $provider_cost, $parentid, $flag_parent, $accountid, $logger, $db, $decimal_points) {
 	$localVariable = $dataVariable;
 	$localVariable ['call_direction'] = "inbound";
-	$localVariable ['uuid'] = $localVariable ['uuid'] . $dataVariable ['calltype'] . "_" . $accountid;
+	$localVariable ['uuid'] = $localVariable ['uuid'].$dataVariable ['calltype']."_".$accountid;
 	
 	if ($dataVariable ['calltype'] == "LOCAL") {
 		$origination_rate [$accountid] ['CODE'] = $dataVariable ['effective_destination_number'];
 		$origination_rate [$accountid] ['DESTINATION'] = $dataVariable ['calltype'];
 		if ($flag_parent == false) {
-			$cdr_string = get_cdr_string ( $localVariable, $accountid, $account_type, $actual_duration, $termination_rate, $origination_rate, $provider_cost, $parentid, 0, 0, $logger );
+			$cdr_string = get_cdr_string($localVariable, $accountid, $account_type, $actual_duration, $termination_rate, $origination_rate, $provider_cost, $parentid, 0, 0, $logger);
 		} else {
-			$cdr_string = get_reseller_cdr_string ( $dataVariable, $accountid, $account_type, $actual_duration, $termination_rate, $origination_rate, $provider_cost, $parentid, $debit, $cost );
+			$cdr_string = get_reseller_cdr_string($dataVariable, $accountid, $account_type, $actual_duration, $termination_rate, $origination_rate, $provider_cost, $parentid, $debit, $cost);
 		}
 	} else {
 		
-		$origination_rate_did = normalize_origination_rate ( $dataVariable ['origination_rates_did'] );
-		$debit = calc_cost ( $dataVariable, $origination_rate_did [$accountid], $logger, $decimal_points );
+		$origination_rate_did = normalize_origination_rate($dataVariable ['origination_rates_did']);
+		$debit = calc_cost($dataVariable, $origination_rate_did [$accountid], $logger, $decimal_points);
 		
 		if ($flag_parent == false) {
 			
-			$cdr_string = get_cdr_string ( $localVariable, $accountid, $account_type, $actual_duration, $termination_rate, $origination_rate_did, $provider_cost, $parentid, $debit, 0, $logger );
+			$cdr_string = get_cdr_string($localVariable, $accountid, $account_type, $actual_duration, $termination_rate, $origination_rate_did, $provider_cost, $parentid, $debit, 0, $logger);
 		} else {
-			$cdr_string = get_reseller_cdr_string ( $dataVariable, $accountid, $account_type, $actual_duration, $termination_rate, $origination_rate, $provider_cost, $parentid, $debit, $cost );
+			$cdr_string = get_reseller_cdr_string($dataVariable, $accountid, $account_type, $actual_duration, $termination_rate, $origination_rate, $provider_cost, $parentid, $debit, $cost);
 		}
 	}
 	
@@ -285,11 +285,11 @@ 
 	reseller_id,reseller_code,reseller_code_destination,reseller_cost,call_direction,calltype) values ($cdr_string)";
 	}
 	
-	$logger->log ( $query );
-	$db->run ( $query );
+	$logger->log($query);
+	$db->run($query);
 	
 	if ($debit > 0 && ($dataVariable ['calltype'] != "FREE" && $dataVariable ['calltype'] != "LOCAL")) {
-		update_balance ( $accountid, $debit, 0, $logger, $db );
+		update_balance($accountid, $debit, 0, $logger, $db);
 	}
 	return true;
 }
@@ -298,18 +298,18 @@ 
 function get_cdr_string($dataVariable, $accountid, $account_type, $actual_duration, $termination_rate, $origination_rate, $provider_cost, $parentid, $debit, $cost, $logger) {
 	$dataVariable ['calltype'] = ($dataVariable ['calltype'] == 'DID-LOCAL' || $dataVariable ['calltype'] == 'SIP-DID' || $dataVariable ['calltype'] == 'OTHER') ? "DID" : $dataVariable ['calltype'];
 	// $callerIdNumber = isset($dataVariable['effective_caller_id_number']) && !empty($dataVariable['effective_caller_id_number'])? $dataVariable['effective_caller_id_number'] :$dataVariable['caller_id'];
-	$callerIdNumber = ($dataVariable ['calltype'] == "DID") ? $dataVariable ['effective_caller_id_name'] . " <" . $dataVariable ['effective_caller_id_number'] . ">" : $dataVariable ['original_caller_id_name'] . " <" . $dataVariable ['original_caller_id_number'] . ">";
+	$callerIdNumber = ($dataVariable ['calltype'] == "DID") ? $dataVariable ['effective_caller_id_name']." <".$dataVariable ['effective_caller_id_number'].">" : $dataVariable ['original_caller_id_name']." <".$dataVariable ['original_caller_id_number'].">";
 	
-	return $cdr_string = "'" . ($dataVariable ['uuid']) . "','" . $accountid . "','" . $account_type . "','" . (urldecode ( $callerIdNumber )) . "','" . ($dataVariable ['effective_destination_number']) . "','" . $actual_duration . "'," . (($termination_rate ['TRUNK']) ? $termination_rate ['TRUNK'] : '0') . "," . (($dataVariable ['sip_via_host']) ? "'" . $dataVariable ['sip_via_host'] . "'" : '""') . "," . (($dataVariable ['sip_contact_host']) ? "'" . $dataVariable ['sip_contact_host'] . "'" : '""') . ",'" . ($dataVariable ['hangup_cause']) . "','" . urldecode ( $dataVariable ['callstart'] ) . "','" . $debit . "','" . $cost . "'," . (($termination_rate ['PROVIDER']) ? $termination_rate ['PROVIDER'] : '0') . ",'" . $origination_rate [$accountid] ['RATEGROUP'] . "','" . $dataVariable ['package_id'] . "','" . ($origination_rate [$accountid] ['CODE']) . "'," . (($origination_rate [$accountid] ['DESTINATION']) ? "'" . htmlentities ( $origination_rate [$accountid] ['DESTINATION'], ENT_COMPAT, 'UTF-8' ) . "'" : "'" . '' . "'") . "," . (($origination_rate [$accountid] ['COST']) ? "'" . $origination_rate [$accountid] ['COST'] . "'" : "'" . '0' . "'") . ",'" . $parentid . "'," . (($origination_rate [$parentid] ['CODE']) ? "'" . $origination_rate [$parentid] ['CODE'] . "'" : "'" . '0' . "'") . "," . (($origination_rate [$parentid] ['DESTINATION']) ? "'" . $origination_rate [$parentid] ['DESTINATION'] . "'" : "'" . '' . "'") . "," . (($origination_rate [$parentid] ['COST']) ? "'" . $origination_rate [$parentid] ['COST'] . "'" : '0') . "," . (($termination_rate ['CODE']) ? "'" . $termination_rate ['CODE'] . "'" : "'" . '' . "'") . "," . (($termination_rate ['DESTINATION']) ? "'" . $termination_rate ['DESTINATION'] . "'" : "'" . '' . "'") . "," . (($termination_rate ['COST']) ? "'" . $termination_rate ['COST'] . "'" : '0') . ",'" . $provider_cost . "'," . (($dataVariable ['call_direction']) ? "'" . $dataVariable ['call_direction'] . "'" : "'internal'") . ",'" . ($dataVariable ['calltype']) . "','" . urldecode ( $dataVariable ['profile_start_stamp'] ) . "','" . urldecode ( $dataVariable ['answer_stamp'] ) . "','" . urldecode ( $dataVariable ['bridge_stamp'] ) . "','" . urldecode ( @$dataVariable ['progress_stamp'] ) . "','" . urldecode ( @$dataVariable ['progress_media_stamp'] ) . "','" . urldecode ( $dataVariable ['end_stamp'] ) . "'," . $dataVariable ['billmsec'] . ",'" . $dataVariable ['answermsec'] . "','" . $dataVariable ['waitmsec'] . "','" . $dataVariable ['progress_mediamsec'] . "','" . $dataVariable ['flow_billmsec'] . "'";
+	return $cdr_string = "'".($dataVariable ['uuid'])."','".$accountid."','".$account_type."','".(urldecode($callerIdNumber))."','".($dataVariable ['effective_destination_number'])."','".$actual_duration."',".(($termination_rate ['TRUNK']) ? $termination_rate ['TRUNK'] : '0').",".(($dataVariable ['sip_via_host']) ? "'".$dataVariable ['sip_via_host']."'" : '""').",".(($dataVariable ['sip_contact_host']) ? "'".$dataVariable ['sip_contact_host']."'" : '""').",'".($dataVariable ['hangup_cause'])."','".urldecode($dataVariable ['callstart'])."','".$debit."','".$cost."',".(($termination_rate ['PROVIDER']) ? $termination_rate ['PROVIDER'] : '0').",'".$origination_rate [$accountid] ['RATEGROUP']."','".$dataVariable ['package_id']."','".($origination_rate [$accountid] ['CODE'])."',".(($origination_rate [$accountid] ['DESTINATION']) ? "'".htmlentities($origination_rate [$accountid] ['DESTINATION'], ENT_COMPAT, 'UTF-8')."'" : "'".''."'").",".(($origination_rate [$accountid] ['COST']) ? "'".$origination_rate [$accountid] ['COST']."'" : "'".'0'."'").",'".$parentid."',".(($origination_rate [$parentid] ['CODE']) ? "'".$origination_rate [$parentid] ['CODE']."'" : "'".'0'."'").",".(($origination_rate [$parentid] ['DESTINATION']) ? "'".$origination_rate [$parentid] ['DESTINATION']."'" : "'".''."'").",".(($origination_rate [$parentid] ['COST']) ? "'".$origination_rate [$parentid] ['COST']."'" : '0').",".(($termination_rate ['CODE']) ? "'".$termination_rate ['CODE']."'" : "'".''."'").",".(($termination_rate ['DESTINATION']) ? "'".$termination_rate ['DESTINATION']."'" : "'".''."'").",".(($termination_rate ['COST']) ? "'".$termination_rate ['COST']."'" : '0').",'".$provider_cost."',".(($dataVariable ['call_direction']) ? "'".$dataVariable ['call_direction']."'" : "'internal'").",'".($dataVariable ['calltype'])."','".urldecode($dataVariable ['profile_start_stamp'])."','".urldecode($dataVariable ['answer_stamp'])."','".urldecode($dataVariable ['bridge_stamp'])."','".urldecode(@$dataVariable ['progress_stamp'])."','".urldecode(@$dataVariable ['progress_media_stamp'])."','".urldecode($dataVariable ['end_stamp'])."',".$dataVariable ['billmsec'].",'".$dataVariable ['answermsec']."','".$dataVariable ['waitmsec']."','".$dataVariable ['progress_mediamsec']."','".$dataVariable ['flow_billmsec']."'";
 }
 
 // Generate CDR string for insert query for reseller
 function get_reseller_cdr_string($dataVariable, $accountid, $account_type, $actual_duration, $termination_rate, $origination_rate, $provider_cost, $parentid, $debit, $cost) {
 	$dataVariable ['calltype'] = ($dataVariable ['calltype'] == 'DID-LOCAL' || $dataVariable ['calltype'] == 'SIP-DID' || $dataVariable ['calltype'] == 'OTHER') ? "DID" : $dataVariable ['calltype'];
 	// $callerIdNumber = isset($dataVariable['effective_caller_id_number']) && !empty($dataVariable['effective_caller_id_number'])? $dataVariable['effective_caller_id_number'] :$dataVariable['caller_id'];
-	$callerIdNumber = ($dataVariable ['calltype'] == "DID") ? $dataVariable ['effective_caller_id_name'] . " <" . $dataVariable ['effective_caller_id_number'] . ">" : $dataVariable ['original_caller_id_name'] . " <" . $dataVariable ['original_caller_id_number'] . ">";
+	$callerIdNumber = ($dataVariable ['calltype'] == "DID") ? $dataVariable ['effective_caller_id_name']." <".$dataVariable ['effective_caller_id_number'].">" : $dataVariable ['original_caller_id_name']." <".$dataVariable ['original_caller_id_number'].">";
 	
-	return $cdr_string = "'" . ($dataVariable ['uuid']) . "','" . $accountid . "','" . (urldecode ( $callerIdNumber )) . "','" . ($dataVariable ['effective_destination_number']) . "','" . $actual_duration . "','" . ($dataVariable ['hangup_cause']) . "','" . urldecode ( $dataVariable ['callstart'] ) . "','" . $debit . "','" . $cost . "','" . $origination_rate [$accountid] ['RATEGROUP'] . "','" . $dataVariable ['package_id'] . "','" . ($origination_rate [$accountid] ['CODE']) . "'," . (($origination_rate [$accountid] ['DESTINATION']) ? "'" . $origination_rate [$accountid] ['DESTINATION'] . "'" : "'" . '' . "'") . "," . (($origination_rate [$accountid] ['COST']) ? "'" . $origination_rate [$accountid] ['COST'] . "'" : "'" . '0' . "'") . ",'" . $parentid . "'," . (($origination_rate [$parentid] ['CODE']) ? "'" . $origination_rate [$parentid] ['CODE'] . "'" : "'" . '0' . "'") . "," . (($origination_rate [$parentid] ['DESTINATION']) ? "'" . $origination_rate [$parentid] ['DESTINATION'] . "'" : "'" . '' . "'") . "," . (($origination_rate [$parentid] ['COST']) ? "'" . $origination_rate [$parentid] ['COST'] . "'" : '0') . "," . (($dataVariable ['call_direction']) ? "'" . $dataVariable ['call_direction'] . "'" : "'internal'") . ",'" . ($dataVariable ['calltype']) . "'";
+	return $cdr_string = "'".($dataVariable ['uuid'])."','".$accountid."','".(urldecode($callerIdNumber))."','".($dataVariable ['effective_destination_number'])."','".$actual_duration."','".($dataVariable ['hangup_cause'])."','".urldecode($dataVariable ['callstart'])."','".$debit."','".$cost."','".$origination_rate [$accountid] ['RATEGROUP']."','".$dataVariable ['package_id']."','".($origination_rate [$accountid] ['CODE'])."',".(($origination_rate [$accountid] ['DESTINATION']) ? "'".$origination_rate [$accountid] ['DESTINATION']."'" : "'".''."'").",".(($origination_rate [$accountid] ['COST']) ? "'".$origination_rate [$accountid] ['COST']."'" : "'".'0'."'").",'".$parentid."',".(($origination_rate [$parentid] ['CODE']) ? "'".$origination_rate [$parentid] ['CODE']."'" : "'".'0'."'").",".(($origination_rate [$parentid] ['DESTINATION']) ? "'".$origination_rate [$parentid] ['DESTINATION']."'" : "'".''."'").",".(($origination_rate [$parentid] ['COST']) ? "'".$origination_rate [$parentid] ['COST']."'" : '0').",".(($dataVariable ['call_direction']) ? "'".$dataVariable ['call_direction']."'" : "'internal'").",'".($dataVariable ['calltype'])."'";
 }
 
 // Update user balance
@@ -319,20 +319,20 @@ 
  */
 function update_balance($user_id, $amount, $entity_id, $logger, $db) {
 	$math_sign = ($entity_id == 0 || $entity_id == 1) ? '-' : '+';
-	$query = "UPDATE accounts SET balance=IF(posttoexternal=1,balance+" . $amount . ",balance-" . $amount . ") WHERE id=" . $user_id;
-	$logger->log ( "Balance update : " . $query );
-	$db->run ( $query );
+	$query = "UPDATE accounts SET balance=IF(posttoexternal=1,balance+".$amount.",balance-".$amount.") WHERE id=".$user_id;
+	$logger->log("Balance update : ".$query);
+	$db->run($query);
 }
 
 // Normalize rate string which we are getting from dialplan
 function normalize_rate($dataVariable) {
-	$rates = urldecode ( $dataVariable );
-	$data = explode ( "|", $rates );
+	$rates = urldecode($dataVariable);
+	$data = explode("|", $rates);
 	
-	$newarray = array ();
-	foreach ( $data as $key => $value ) {
-		$data1 = explode ( ":", $value );
-		foreach ( $data1 as $newkey => $newvalue ) {
+	$newarray = array();
+	foreach ($data as $key => $value) {
+		$data1 = explode(":", $value);
+		foreach ($data1 as $newkey => $newvalue) {
 			$newarray [$data1 [0]] = $data1 [$newkey];
 		}
 	}
@@ -341,13 +341,13 @@ 
 
 // Normalize originaion rate string which we are getting from dialplan
 function normalize_origination_rate($dataVariable) {
-	$rates = urldecode ( $dataVariable );
-	$data = explode ( "|", $rates );
-	$newarray = array ();
-	$newarray1 = array ();
-	foreach ( $data as $key => $value ) {
-		$data1 = explode ( ":", $value );
-		foreach ( $data1 as $newkey => $newvalue ) {
+	$rates = urldecode($dataVariable);
+	$data = explode("|", $rates);
+	$newarray = array();
+	$newarray1 = array();
+	foreach ($data as $key => $value) {
+		$data1 = explode(":", $value);
+		foreach ($data1 as $newkey => $newvalue) {
 			$newarray [$data1 [0]] = $data1 [$newkey];
 			if ($newvalue == "ACCID") {
 				$newarray1 [$data1 [1]] = $newarray;
@@ -371,43 +371,43 @@ 
 		$billseconds = $duration - $rates ['INITIALBLOCK'];
 		
 		if ($billseconds > 0) {
-			$call_cost += (ceil ( $billseconds / $rates ['INC'] ) * $rates ['INC']) * ($rates ['COST'] / 60);
+			$call_cost += (ceil($billseconds / $rates ['INC']) * $rates ['INC']) * ($rates ['COST'] / 60);
 		}
 	}
-	$call_cost = number_format ( $call_cost, $decimal_points );
-	$logger->log ( "Return cost " . $call_cost );
+	$call_cost = number_format($call_cost, $decimal_points);
+	$logger->log("Return cost ".$call_cost);
 	return $call_cost;
 }
 
 // get intial package information
 function package_calculation($destination_number, $pricelist_id, $duration, $call_direction, $accountid, $db, $logger) {
-	$package_array = array ();
-	$custom_destination = number_loop ( $destination_number, "patterns", $db );
+	$package_array = array();
+	$custom_destination = number_loop($destination_number, "patterns", $db);
 	
-	$query = "SELECT * FROM packages  as P inner join package_patterns as PKGPTR on P.id = PKGPTR.package_id WHERE " . $custom_destination . " AND status = 0 AND pricelist_id = " . $pricelist_id . " ORDER BY LENGTH(PKGPTR.patterns) DESC LIMIT 1";
+	$query = "SELECT * FROM packages  as P inner join package_patterns as PKGPTR on P.id = PKGPTR.package_id WHERE ".$custom_destination." AND status = 0 AND pricelist_id = ".$pricelist_id." ORDER BY LENGTH(PKGPTR.patterns) DESC LIMIT 1";
 	
-	$package_info = $db->run ( $query );
+	$package_info = $db->run($query);
 	if ($package_info) {
 		$package_info = $package_info [0];
 		
 		if (($package_info ['applicable_for'] == "0" && $call_direction == "outbound") || ($package_info ['applicable_for'] == "1" && $call_direction == "inbound") || ($package_info ['applicable_for'] == "2")) {
 			
-			$counter_info = get_counters ( $accountid, $package_info ['package_id'], $db, $logger );
+			$counter_info = get_counters($accountid, $package_info ['package_id'], $db, $logger);
 			
-			if (! $counter_info) {
-				$Insert_Query = "INSERT INTO counters (package_id,accountid) VALUES (" . $package_info ['package_id'] . "," . $accountid . ")";
-				$logger->log ( "Insert Counters  : " . $Insert_query );
-				$db->run ( $Insert_Query );
-				$counter_info = get_counters ( $accountid, $package_info ['package_id'], $db, $logger );
+			if ( ! $counter_info) {
+				$Insert_Query = "INSERT INTO counters (package_id,accountid) VALUES (".$package_info ['package_id'].",".$accountid.")";
+				$logger->log("Insert Counters  : ".$Insert_query);
+				$db->run($Insert_Query);
+				$counter_info = get_counters($accountid, $package_info ['package_id'], $db, $logger);
 			}
 			// print_r($counter_info);
 			if ($package_info ['includedseconds'] > ($counter_info ['seconds'])) {
 				$availableseconds = $package_info ['includedseconds'] - $counter_info ['seconds'];
 				$freeseconds = ($availableseconds >= $duration) ? $duration : $availableseconds;
 				$duration = ($availableseconds >= $duration) ? $duration : $availableseconds;
-				$update_query = "UPDATE counters SET seconds = " . ($counter_info ['seconds'] + $freeseconds) . " WHERE id = " . $counter_info ['id'];
-				$logger->log ( "Update Counters  : " . $update_query );
-				$db->run ( $update_query );
+				$update_query = "UPDATE counters SET seconds = ".($counter_info ['seconds'] + $freeseconds)." WHERE id = ".$counter_info ['id'];
+				$logger->log("Update Counters  : ".$update_query);
+				$db->run($update_query);
 				$package_array ['package_id'] = $package_info ['package_id'];
 				$package_array ['calltype'] = "FREE";
 			}
@@ -418,9 +418,9 @@ 
 
 // Getting used package minutes in counter table
 function get_counters($accountid, $package_id, $db, $logger) {
-	$query_counter = "SELECT id,seconds FROM counters  WHERE  accountid = " . $accountid . " AND package_id = " . $package_id . " AND status=1 LIMIT 1";
-	$counter = $db->run ( $query_counter );
-	$logger->log ( "GET Counters  : " . $query_counter );
+	$query_counter = "SELECT id,seconds FROM counters  WHERE  accountid = ".$accountid." AND package_id = ".$package_id." AND status=1 LIMIT 1";
+	$counter = $db->run($query_counter);
+	$logger->log("GET Counters  : ".$query_counter);
 	if ($counter)
 		return $counter [0];
 	else
@@ -429,17 +429,17 @@ 
 
 // Get user info
 function get_accounts($parent_id, $logger, $db) {
-	$query = "SELECT * FROM accounts WHERE id=" . $parent_id;
-	$logger->log ( "GET configuration  : " . $query );
-	$res_user = $db->run ( $query );
+	$query = "SELECT * FROM accounts WHERE id=".$parent_id;
+	$logger->log("GET configuration  : ".$query);
+	$res_user = $db->run($query);
 	return $res_user [0];
 }
 
 // Get configuration
 function load_configuration($logger) {
 	$query = "SELECT name,value FROM system WHERE name='decimal_points' and group_title = 'global'";
-	$config = $db->run ( $query );
-	$logger->log ( "GET configuration  : " . $query );
+	$config = $db->run($query);
+	$logger->log("GET configuration  : ".$query);
 	return $config [0];
 }
 
@@ -449,11 +449,11 @@ 
  * @param string $field        	
  */
 function number_loop($destination, $field, $db) {
-	$max_len_prefix = strlen ( $destination );
+	$max_len_prefix = strlen($destination);
 	$number_prefix = '(';
-	while ( $max_len_prefix > 0 ) {
-		$number_prefix .= "$field='^" . substr ( $destination, 0, $max_len_prefix ) . ".*' OR ";
-		$max_len_prefix --;
+	while ($max_len_prefix > 0) {
+		$number_prefix .= "$field='^".substr($destination, 0, $max_len_prefix).".*' OR ";
+		$max_len_prefix--;
 	}
 	$number_prefix .= "$field='^defaultprefix.*')"; // echo $number_prefix;exit;
 	return $number_prefix;
@@ -465,6 +465,6 @@ 
  * @param string $date        	
  */
 function convert_to_gmt($date) {
-	return gmdate ( 'Y-m-d H:i:s', strtotime ( $date ) );
+	return gmdate('Y-m-d H:i:s', strtotime($date));
 }
 ?>

freeswitch/fs/lib/astpp.constants.php

Spacing +3 added lines, -3 removed lines

@@ -22,7 +22,7 @@ 
 // ##############################################################################
 
 // Define user rates array for parsing
-$CONST_USER_RATE = array (
+$CONST_USER_RATE = array(
 		'RID' => 'id',
 		'RCD' => 'code',
 		'RDS' => 'destination',
@@ -36,7 +36,7 @@ 
 );
 
 // Define carrier rates array for parsing
-$CONST_CARRIER_RATE = array (
+$CONST_CARRIER_RATE = array(
 		'CID' => 'id',
 		'CCD' => 'code',
 		'CDS' => 'destination',
@@ -47,5 +47,5 @@ 
 		'CBB' => 'billing_block' 
 );
 
-define ( "tbl_configuration", "system" );
+define("tbl_configuration", "system");
 ?>

freeswitch/fs/lib/astpp.lib.php

Spacing +2 added lines, -2 removed lines

@@ -24,8 +24,8 @@
 	var $config;
 	function get_configurations($db) {
 		$query = "SELECT * FROM system WHERE group_title IN ('global','opensips')";
-		$res_conf = $db->run ( $query );
-		foreach ( $res_conf as $res_conf_key => $res_conf_value )
+		$res_conf = $db->run($query);
+		foreach ($res_conf as $res_conf_key => $res_conf_value)
 			$this->config [$res_conf_value ['name']] = $res_conf_value ['value'];
 		
 		return $this->config;

freeswitch/fs/lib/astpp.functions.php

Spacing +39 added lines, -39 removed lines

@@ -23,20 +23,20 @@ 
 
 // Parse user and rates array which we got in cdr xml
 function parse_rates_array($xml_rate, $constant_array, $logger) {
-	$rates_array = array ();
+	$rates_array = array();
 	
 	// decode string using urldecode
-	$xml_rate = urldecode ( $xml_rate );
-	$xml_rate_array = explode ( "||", $xml_rate );
+	$xml_rate = urldecode($xml_rate);
+	$xml_rate_array = explode("||", $xml_rate);
 	
-	foreach ( $xml_rate_array as $rate_key => $rate_value ) {
-		$rates_array = explode ( "|", $rate_value );
+	foreach ($xml_rate_array as $rate_key => $rate_value) {
+		$rates_array = explode("|", $rate_value);
 		
-		$user_id_param = $rates_array [count ( $rates_array ) - 1];
-		$user_id = (substr ( $user_id_param, 0, 3 ) == 'UID') ? substr ( $user_id_param, 3 ) : 0;
+		$user_id_param = $rates_array [count($rates_array) - 1];
+		$user_id = (substr($user_id_param, 0, 3) == 'UID') ? substr ($user_id_param, 3) : 0;
 		
-		foreach ( $rates_array as $key => $value ) {
-			$rates_array_info [$user_id] [$constant_array [substr ( $value, 0, 3 )]] = substr ( $value, 3 );
+		foreach ($rates_array as $key => $value) {
+			$rates_array_info [$user_id] [$constant_array [substr($value, 0, 3)]] = substr($value, 3);
 		}
 	}
 	return $rates_array_info;
@@ -50,50 +50,50 @@ 
 	if ($duration > 0 && $xml_cdr->variables->call_direction == 'outbound') {
 		$destination_number = $xml_cdr->variables->effective_destination_number;
 		
-		$number_len = strlen ( $destination_number );
+		$number_len = strlen($destination_number);
 		$number_loop_str = '(';
-		while ( $number_len > 0 ) {
-			$number_loop_str .= " code='" . substr ( $destination_number, 0, $number_len ) . "' OR ";
+		while ($number_len > 0) {
+			$number_loop_str .= " code='".substr($destination_number, 0, $number_len)."' OR ";
 			$number_len -= 1;
 		}
 		$number_loop_str .= " code='--')";
 		
-		$query = "SELECT A.id as package_id,code,includedseconds FROM tbl_package AS A ,tbl_package_codes AS B WHERE " . $number_loop_str . " AND B.package_id = A.id AND A.ratecard_id=" . $rates_array ['ratecard_id'] . " AND A.status=0 AND A.is_del=0 ORDER BY length(code) DESC";
-		$logger->log ( "Package Query : " . $query );
-		$res_package = $db->run ( $query );
+		$query = "SELECT A.id as package_id,code,includedseconds FROM tbl_package AS A ,tbl_package_codes AS B WHERE ".$number_loop_str." AND B.package_id = A.id AND A.ratecard_id=".$rates_array ['ratecard_id']." AND A.status=0 AND A.is_del=0 ORDER BY length(code) DESC";
+		$logger->log("Package Query : ".$query);
+		$res_package = $db->run($query);
 		
-		foreach ( $res_package as $res_package_key => $package_info ) {
-			if (isset ( $package_info ['package_id'] )) {
-				$query = "SELECT SUM(used_seconds) as used_seconds FROM tbl_package_usage WHERE code=" . $package_info ['code'] . " AND package_id=" . $package_info ['package_id'] . " AND user_id=" . $user_id;
-				$logger->log ( "Package usage Query : " . $query );
-				$res_pkg_usg = $db->run ( $query );
+		foreach ($res_package as $res_package_key => $package_info) {
+			if (isset ($package_info ['package_id'])) {
+				$query = "SELECT SUM(used_seconds) as used_seconds FROM tbl_package_usage WHERE code=".$package_info ['code']." AND package_id=".$package_info ['package_id']." AND user_id=".$user_id;
+				$logger->log("Package usage Query : ".$query);
+				$res_pkg_usg = $db->run($query);
 				$package_usage_info = $res_pkg_usg [0];
 				
-				$used_seconds = (isset ( $package_usage_info ['used_seconds'] )) ? $package_usage_info ['used_seconds'] : 0;
+				$used_seconds = (isset ($package_usage_info ['used_seconds'])) ? $package_usage_info ['used_seconds'] : 0;
 				
-				$logger->log ( "Included seconds : " . $package_info ['includedseconds'] . ", Used seconds : " . $used_seconds );
+				$logger->log("Included seconds : ".$package_info ['includedseconds'].", Used seconds : ".$used_seconds);
 				if ($package_info ['includedseconds'] > $used_seconds) {
 					$remaining_seconds = $package_info ['includedseconds'] - ($duration + $used_seconds);
 					if ($remaining_seconds > 0) {
 						$dud_sec = $duration;
 						$duration = 0;
 					} else {
-						$dud_sec = $duration - abs ( $remaining_seconds );
-						$duration = abs ( $remaining_seconds );
+						$dud_sec = $duration - abs($remaining_seconds);
+						$duration = abs($remaining_seconds);
 					}
 					$flag = true;
 					$xml_cdr->variables->package_id = $package_info ['package_id'];
 					
-					$query = "INSERT INTO tbl_package_usage (package_id,user_id,code,used_seconds) VALUES (" . $package_info ['package_id'] . "," . $user_id . ",'" . $package_info ['code'] . "'," . $dud_sec . ") ON DUPLICATE KEY UPDATE used_seconds=used_seconds+" . $dud_sec;
-					$logger->log ( "Package Usage Query : " . $query );
-					$db->run ( $query );
+					$query = "INSERT INTO tbl_package_usage (package_id,user_id,code,used_seconds) VALUES (".$package_info ['package_id'].",".$user_id.",'".$package_info ['code']."',".$dud_sec.") ON DUPLICATE KEY UPDATE used_seconds=used_seconds+".$dud_sec;
+					$logger->log("Package Usage Query : ".$query);
+					$db->run($query);
 					
 					break;
 				}
 			}
 		}
 	}
-	return array (
+	return array(
 			$duration,
 			$flag 
 	);
@@ -101,22 +101,22 @@ 
 
 // Process user/vendor cdr
 function do_cdr_process($xml_cdr, $debit, $cost, $vendor_cost, $rates_array, $parent_id = 0, $parent_rates, $carrier_rates_array, $logger, $db) {
-	$query_string = "'" . $xml_cdr->variables->uuid . "','" . $xml_cdr->variables->user_id . "','" . $xml_cdr->variables->entity_id . "','" . urldecode ( $xml_cdr->variables->effective_caller_id_name ) . "','" . $xml_cdr->variables->effective_caller_id_number . "','" . $xml_cdr->variables->effective_destination_number . "'," . $xml_cdr->variables->duration . ",'" . $xml_cdr->variables->carrier_id . "','" . $xml_cdr->callflow [0]->caller_profile->originatee->originatee_caller_profile->network_addr . "','" . $xml_cdr->variables->sip_contact_host . "','" . $xml_cdr->variables->hangup_cause . "','" . urldecode ( $xml_cdr->variables->start_stamp ) . "'," . $debit . "," . $cost . ",'" . $xml_cdr->variables->vendor_id . "'," . $vendor_cost . "," . $rates_array ['ratecard_id'] . "," . $xml_cdr->variables->package_id . ",'" . $rates_array ['code'] . "','" . $rates_array ['destination'] . "','" . $rates_array ['cost'] . "','" . $parent_id . "','" . @$parent_rates ['code'] . "','" . @$parent_rates ['destination'] . "','" . @$parent_rates ['cost'] . "','" . @$carrier_rates_array ['code'] . "','" . @$carrier_rates_array ['destination'] . "','" . @$carrier_rates_array ['cost'] . "','" . $xml_cdr->variables->call_direction . "','" . urldecode ( $xml_cdr->variables->profile_start_stamp ) . "','" . urldecode ( $xml_cdr->variables->answer_stamp ) . "','" . urldecode ( $xml_cdr->variables->bridge_stamp ) . "','" . urldecode ( $xml_cdr->variables->progress_stamp ) . "','" . urldecode ( $xml_cdr->variables->progress_media_stamp ) . "','" . urldecode ( $xml_cdr->variables->end_stamp ) . "'," . $xml_cdr->variables->billmsec . "," . $xml_cdr->variables->answermsec . "," . $xml_cdr->variables->waitmsec . "," . $xml_cdr->variables->progress_mediamsec . "," . $xml_cdr->variables->flow_billmsec;
+	$query_string = "'".$xml_cdr->variables->uuid."','".$xml_cdr->variables->user_id."','".$xml_cdr->variables->entity_id."','".urldecode($xml_cdr->variables->effective_caller_id_name)."','".$xml_cdr->variables->effective_caller_id_number."','".$xml_cdr->variables->effective_destination_number."',".$xml_cdr->variables->duration.",'".$xml_cdr->variables->carrier_id."','".$xml_cdr->callflow [0]->caller_profile->originatee->originatee_caller_profile->network_addr."','".$xml_cdr->variables->sip_contact_host."','".$xml_cdr->variables->hangup_cause."','".urldecode($xml_cdr->variables->start_stamp)."',".$debit.",".$cost.",'".$xml_cdr->variables->vendor_id."',".$vendor_cost.",".$rates_array ['ratecard_id'].",".$xml_cdr->variables->package_id.",'".$rates_array ['code']."','".$rates_array ['destination']."','".$rates_array ['cost']."','".$parent_id."','".@$parent_rates ['code']."','".@$parent_rates ['destination']."','".@$parent_rates ['cost']."','".@$carrier_rates_array ['code']."','".@$carrier_rates_array ['destination']."','".@$carrier_rates_array ['cost']."','".$xml_cdr->variables->call_direction."','".urldecode($xml_cdr->variables->profile_start_stamp)."','".urldecode($xml_cdr->variables->answer_stamp)."','".urldecode($xml_cdr->variables->bridge_stamp)."','".urldecode($xml_cdr->variables->progress_stamp)."','".urldecode($xml_cdr->variables->progress_media_stamp)."','".urldecode($xml_cdr->variables->end_stamp)."',".$xml_cdr->variables->billmsec.",".$xml_cdr->variables->answermsec.",".$xml_cdr->variables->waitmsec.",".$xml_cdr->variables->progress_mediamsec.",".$xml_cdr->variables->flow_billmsec;
 	
 	$query = "INSERT INTO tbl_cdrs (uniqueid,user_id,entity_id,callerid_name,callerid_number,dstnum,duration,carrier_id,carrierip,callerip,disposition,start_stamp,debit,cost,vendor_id,vendor_cost,ratecard_id,package_id,rate_code,rate_code_destination,rate_cost,parent_id,parent_code,parent_code_destination,parent_cost,carrier_code,carrier_code_destination ,carrier_cost,call_direction,profile_start_stamp,answer_stamp,bridge_stamp,progress_stamp,progress_media_stamp,end_stamp,billmsec,answermsec,waitmsec,progress_mediamsec,flow_billmsec) values ($query_string)";
 	
-	$logger->log ( "CDR Query : " . $query );
-	$db->run ( $query );
+	$logger->log("CDR Query : ".$query);
+	$db->run($query);
 }
 
 // Process reseller cdr
 function do_reseller_cdr_process($xml_cdr, $debit, $cost, $rates_array, $parent_id = 0, $parent_rates, $logger, $db) {
-	$query_string = "'" . $xml_cdr->variables->uuid . "','" . $xml_cdr->variables->user_id . "','" . urldecode ( $xml_cdr->variables->effective_caller_id_name ) . "','" . $xml_cdr->variables->effective_caller_id_number . "','" . $xml_cdr->variables->effective_destination_number . "'," . $xml_cdr->variables->duration . ",'" . $xml_cdr->variables->hangup_cause . "','" . urldecode ( $xml_cdr->variables->start_stamp ) . "'," . $debit . "," . $cost . "," . $rates_array ['ratecard_id'] . "," . $xml_cdr->variables->package_id . ",'" . $rates_array ['code'] . "','" . $rates_array ['destination'] . "','" . $rates_array ['cost'] . "','" . $parent_id . "','" . @$parent_rates ['code'] . "','" . @$parent_rates ['destination'] . "','" . @$parent_rates ['cost'] . "','" . $xml_cdr->variables->call_direction . "'";
+	$query_string = "'".$xml_cdr->variables->uuid."','".$xml_cdr->variables->user_id."','".urldecode($xml_cdr->variables->effective_caller_id_name)."','".$xml_cdr->variables->effective_caller_id_number."','".$xml_cdr->variables->effective_destination_number."',".$xml_cdr->variables->duration.",'".$xml_cdr->variables->hangup_cause."','".urldecode($xml_cdr->variables->start_stamp)."',".$debit.",".$cost.",".$rates_array ['ratecard_id'].",".$xml_cdr->variables->package_id.",'".$rates_array ['code']."','".$rates_array ['destination']."','".$rates_array ['cost']."','".$parent_id."','".@$parent_rates ['code']."','".@$parent_rates ['destination']."','".@$parent_rates ['cost']."','".$xml_cdr->variables->call_direction."'";
 	
 	$query = "INSERT INTO tbl_cdrs_reseller (uniqueid,reseller_id,callerid_name,callerid_number,dstnum,duration,disposition,start_stamp,debit,cost,ratecard_id,package_id,rate_code,rate_code_destination,rate_cost,parent_id,parent_code,parent_code_destination,parent_cost,call_direction) values ($query_string)";
 	
-	$logger->log ( "CDR Query : " . $query );
-	$db->run ( $query );
+	$logger->log("CDR Query : ".$query);
+	$db->run($query);
 }
 
 // Update user balance
@@ -127,16 +127,16 @@ 
 function update_balance($user_id, $amount, $entity_id, $logger, $db) {
 	if ($amount > 0) {
 		$math_sign = ($entity_id == 0 || $entity_id == 1) ? '-' : '+';
-		$query = "UPDATE tbl_users SET credit=credit$math_sign" . $amount . " WHERE id=" . $user_id;
-		$logger->log ( "Balance update : " . $query );
-		$db->run ( $query );
+		$query = "UPDATE tbl_users SET credit=credit$math_sign".$amount." WHERE id=".$user_id;
+		$logger->log("Balance update : ".$query);
+		$db->run($query);
 	}
 }
 
 // Get user info
 function get_user_info($parent_id, $db) {
-	$query = "SELECT * FROM tbl_users WHERE id=" . $parent_id;
-	$res_user = $db->run ( $query );
+	$query = "SELECT * FROM tbl_users WHERE id=".$parent_id;
+	$res_user = $db->run($query);
 	return $res_user [0];
 }
 

freeswitch/fs/cdr.php

Spacing +16 added lines, -16 removed lines

@@ -20,21 +20,21 @@ 
 // You should have received a copy of the GNU Affero General Public License
 // along with this program. If not, see <http://www.gnu.org/licenses/>.
 // ##############################################################################
-define ( 'ENVIRONMENT', 'production' );
-if (defined ( 'ENVIRONMENT' )) {
+define('ENVIRONMENT', 'production');
+if (defined('ENVIRONMENT')) {
 	switch (ENVIRONMENT) {
 		case 'development' :
 			// error_reporting(E_ALL);
-			error_reporting ( E_ERROR | E_WARNING | E_PARSE );
+			error_reporting(E_ERROR | E_WARNING | E_PARSE);
 			break;
 		
 		case 'testing' :
 		case 'production' :
-			error_reporting ( 0 );
+			error_reporting(0);
 			break;
 		
 		default :
-			exit ( 'The application environment is not set correctly.' );
+			exit ('The application environment is not set correctly.');
 	}
 }
 
@@ -45,35 +45,35 @@ 
 include ("lib/astpp.cdr.php");
 
 // Define db object
-$db = new db ();
+$db = new db();
 
 // Get default configuration
-$lib = new lib ();
-$config = $lib->get_configurations ( $db );
+$lib = new lib();
+$config = $lib->get_configurations($db);
 
 // Set default decimal points
 $decimal_points = ($config ['decimal_points'] <= 0) ? 4 : $config ['decimal_points'];
 
 // Define logger object
-$logger = new logger ( $lib );
+$logger = new logger($lib);
 
-if (isset ( $_SERVER ["CONTENT_TYPE"] ) && $_SERVER ["CONTENT_TYPE"] == "application/json") {
+if (isset ($_SERVER ["CONTENT_TYPE"]) && $_SERVER ["CONTENT_TYPE"] == "application/json") {
 	
-	$db->run ( "SET NAMES utf8" );
+	$db->run("SET NAMES utf8");
 	//$data = json_decode ( file_get_contents ( "php://input" ), true );
 	$data = file_get_contents("php://input");
         $data = utf8_encode($data);
-	$data = json_decode($data,true);
+	$data = json_decode($data, true);
 
 	// error_log(print_r($data,true));
-	$logger->log ( print_r ( $data, true ) );
+	$logger->log(print_r($data, true));
 	// process_cdr($data,$db,$logger,$decimal_points);
 	if ($data ['variables'] ['calltype'] == "CALLINGCARD") {
-		if (isset ( $data ['variables'] ['originating_leg_uuid'] )) {
-			process_cdr ( $data, $db, $logger, $decimal_points );
+		if (isset ($data ['variables'] ['originating_leg_uuid'])) {
+			process_cdr($data, $db, $logger, $decimal_points);
 		}
 	} else {
-		process_cdr ( $data, $db, $logger, $decimal_points );
+		process_cdr($data, $db, $logger, $decimal_points);
 	}
 }