astpp.cdr.php ➔ normalize_origination_rate() - Code Metrics - iNextrix/ASTPP - Measure and Improve Code Quality continuously with Scrutinizer

astpp.cdr.php ➔ normalize_origination_rate() A
last analyzed 2017-06-12 08:08 UTC

↳ Parent: Project
Complexity

Conditions	4
Paths	4
Size

Total Lines	19
Code Lines	12
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
cc	4
eloc	12
nc	4
nop	1
dl	0
loc	19
rs	9.2
c	0
b	0
f	0
<?php
###############################################################################
# ASTPP - Open Source VoIP Billing Solution
#
# Copyright (C) 2016 iNextrix Technologies Pvt. Ltd.
# Samir Doshi <[email protected]>
# ASTPP Version 3.0 and above
# License https://www.gnu.org/licenses/agpl-3.0.html
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as
# published by the Free Software Foundation, either version 3 of the
# License, or (at your option) any later version.
# 
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU Affero General Public License for more details.
# 
# 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/>.
###############################################################################

//Process CDR 
function process_cdr($data, $db, $logger, $decimal_points)
{
	//$logger->log(print_r($data,true));//exit;


	//Initializing variables 
	$origination_rate = array();
	$termination_rate = array();

	//FS CDR variables 
	$dataVariable = $data['variables'];

	//FS CDR Call flow variables 
	$dataCallflow = $data['callflow'];

	//Get account id
	$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'];


	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'];
	}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']); 
	}

	/*#### PATCH FOR ONE WAY AUDIO ####*/
	if ($hangup_cause == "NORMAL_UNSPECIFIED" && $dataVariable['billsec'] > 0)
	{
		$hangup_cause = "NORMAL_CLEARING";
	}
	/*#### ************* END *************####*/

	//Don't thing this will be useful anytime. Need to remove it after testing. 
	if($hangup_cause == "NONE")
	{
		$hangup_cause = $dataVariable['current_application_data'];
	}

	$dataVariable['hangup_cause'] = $hangup_cause;

	/*if ( ($dataVariable['hangup_cause'] != 'NORMAL_CLEARING') && ($dataVariable['hangup_cause'] != 'ALLOTTED_TIMEOUT')) {

	  	$dataVariable['billsec'] = 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";
	$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 receiver account id found then explicitly set call direction and call type 
	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))
			{
				$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);

	//Calculate cost for customer call for provider
	$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);
    
	//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 *************");

	$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);
	
	//Update customer balance
	if($debit > 0 && $dataVariable['calltype'] != "FREE")
	{
		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);
	}

	//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);

	$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 *************");            

		//Explicitly set call direction and call type 
		$dataVariable['call_direction'] = "inbound";
		$dataVariable['calltype'] = "DID";

    //Override variables if call for DID PSTN
    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);
     }

        

		//Get call receiver account information 
		$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);

		$flag_parent = true;
		$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 *************");            
	}
	//*****************************************************************************************
	$logger->log("*************************** CDR ends ********************************");
}

//Insert parent resellers cdr
/**
 * @param string $provider_cost
 * @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 ********");
		$dataVariable['calltype'] = $actual_calltype;
		$carddata = get_accounts($parentid,$logger,$db);
		$accountid = $carddata['id'];

		$debit = calc_cost($dataVariable,$origination_rate[$accountid],$logger,$decimal_points);

		//If receiver account id found then explicitly set call direction and call type
		/*if(isset($dataVariable['receiver_accid']))

        {
            $dataVariable['call_direction'] = "outbound";
            $dataVariable['calltype'] = "STANDARD";
        }*/

		//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))
			{
				$dataVariable['calltype'] = "FREE";
				$dataVariable['package_id']= $package_array['package_id'];
			}
		}	

		//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;
		$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 ******");
			$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 ******");
			//return true;	

		} else{

			$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);

			//Update reseller balance
			if ($debit > 0 && $dataVariable['calltype'] != "FREE") {
				update_balance($accountid, $debit, 0, $logger, $db);
			}
		}
		//return true;
	}
	return true;
}

//Insert callee cdr entry for DID calls
/**
 * @param boolean $flag_parent
 */
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;
		
		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);
			} else{
				$cdr_string = get_reseller_cdr_string($dataVariable,$accountid,$account_type,$actual_duration,$termination_rate,$origination_rate,$provider_cost,$parentid,$debit,$cost);
function someFunction() {
    $x = 5;
    echo $x;
}
			}
		} else{

			$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);
			} else{
				$cdr_string = get_reseller_cdr_string($dataVariable,$accountid,$account_type,$actual_duration,$termination_rate,$origination_rate,$provider_cost,$parentid,$debit,$cost);
			}
		}
	  
		if($flag_parent == false)

		{
			$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)";
		} else{
			$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);	

		if ($debit > 0 && ($dataVariable['calltype'] != "FREE" && $dataVariable['calltype'] != "LOCAL"))
		{
			update_balance($accountid, $debit, 0, $logger, $db);
function myFunction($a) {
    switch ($a) {
        case 'foo':
            $x = 1;
            break;

        case 'bar':
            $x = 2;
            break;
    }

    // $x is potentially undefined here.
    echo $x;
}
		}
		return true;
}

//Generate CDR string for insert query for customer.
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'];
		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'])."','".convert_to_gmt(urldecode($dataVariable['profile_start_stamp']))."','".convert_to_gmt(urldecode($dataVariable['answer_stamp']))."','".convert_to_gmt(urldecode($dataVariable['bridge_stamp']))."','".convert_to_gmt(urldecode(@$dataVariable['progress_stamp']))."','".convert_to_gmt(urldecode(@$dataVariable['progress_media_stamp']))."','".convert_to_gmt(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'];
	
	return $cdr_string = "'".($dataVariable['uuid'])."','".$accountid."','".(urldecode($callerIdNumber))."','".($dataVariable['effective_destination_number'])."','".$actual_duration."','".($dataVariable['hangup_cause'])."','".convert_to_gmt(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
/**
 * @param integer $entity_id
 */
function update_balance($user_id, $amount, $entity_id, $logger, $db) {

    $math_sign = ($entity_id == 0 || $entity_id == 1) ? '-' : '+';
    $query = "UPDATE accounts SET balance=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);

	$newarray = array();
    foreach ($data as $key => $value)
    {
            $data1 = explode(":", $value);
            foreach ($data1 as $newkey => $newvalue)
            {
                    $newarray[$data1[0]] = $data1[$newkey];
            }
    }
	return $newarray;
}

//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)
		{
			$newarray[$data1[0]] = $data1[$newkey];
			if ($newvalue == "ACCID") {
				$newarray1[$data1[1]] = $newarray;
			}
		}
	}
		return $newarray1;
}

// Calculate cost for billing 
function calc_cost($dataVariable, $rates, $logger, $decimal_points)
{
	//$logger->log(print_r($rates,true));

	$duration = $dataVariable['billsec'];
	$call_cost = 0;  
	$duration -= $rates['INCLUDEDSECONDS'];
	if ($duration > 0 && ($dataVariable['hangup_cause'] == 'NORMAL_CLEARING' || $dataVariable['hangup_cause'] == 'ALLOTTED_TIMEOUT')) {

			$rates['INC'] = ($rates['INC'] == 0) ? 1 : $rates['INC'];
			$call_cost = $rates['CONNECTIONCOST'];
			$call_cost += ($rates['INITIALBLOCK'] * $rates['COST']) / 60;
			$billseconds = $duration - $rates['INITIALBLOCK'];
    
			if ($billseconds > 0)
			{
				$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);
	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);

	$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);
	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);

			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);
				$package_array['package_id']= $package_info['package_id'];
				$package_array['calltype'] = "FREE";
			}						
		} 
	}
	return $package_array;
} 

// 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);
	if($counter)
		return $counter[0];	
	else
		return "";
}

//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);
	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);
	return $config[0];
}

// String append prefix for checking rates
/**
 * @param string $field
 */
function number_loop($destination,$field,$db)

{
	$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--;
	}
	$number_prefix .= "$field='^defaultprefix.*')";//echo $number_prefix;exit;

	return $number_prefix;
}

//Convert current time to GMT
/**
 * @param string $date
 */
function convert_to_gmt($date)
{
	return gmdate('Y-m-d H:i:s', strtotime($date) );
}
?>


iNextrix / ASTPP

astpp.cdr.php ➔ normalize_origination_rate() A last analyzed 2017-06-12 08:08 UTC

Complexity

Size

Duplication

Importance

Available Fixes

Duplication Side-by-Side

Filter issues like

astpp.cdr.php ➔ normalize_origination_rate() A
last analyzed 2017-06-12 08:08 UTC
