class.rateengine.php

来自「asterisk用 的voip记费软件」· PHP 代码 · 共 1,109 行 · 第 1/3 页

<?php
/***************************************************************************
 *
 * Class.RateEngine.php : RateEngine Functions for A2Billing
 * Written for PHP 4.x & PHP 5.X versions.
 *
 * A2Billing -- Asterisk billing solution.
 * Copyright (C) 2004, 2007 Belaid Arezqui <areski _atl_ gmail com>
 *
 * See http://www.asterisk2billing.org for more information about
 * the A2Billing project. 
 * Please submit bug reports, patches, etc to <areski _atl_ gmail com>
 *
 * This software is released under the terms of the GNU Lesser General Public License v2.1
 * A copy of which is available from http://www.gnu.org/copyleft/lesser.html
 *
 ****************************************************************************/
 
 
class RateEngine {
	var $debug_st = 0;
	
	var $ratecard_obj = array();
	
	var $freetimetocall_left = array();
	
	var $number_trunk=0;
	var $lastcost=0;
	var $lastbuycost=0;
	var $answeredtime;
	var $dialstatus;
	var $usedratecard;
	var $webui = 1;
	var $usedtrunk;

	/* CONSTRUCTOR */

	function RateEngine () {     
		
	}
	
	
	/* CONSTRUCTOR */
	function Reinit () {     
		
		$this -> number_trunk = 0;
		$this -> answeredtime = 0;	
		$this -> dialstatus = '';
		$this -> usedratecard = '';
		$this -> usedtrunk = '';
		$this -> lastcost = '';
		$this -> lastbuycost = '';
		
	}
	
	
	/*
		RATE ENGINE
		CALCUL THE RATE ACCORDING TO THE RATEGROUP, LCR - RATECARD
	*/
	function rate_engine_findrates (&$A2B, $phonenumber, $tariffgroupid){
		
		global $agi;
		
		// Check if we want to force the call plan
		if (is_numeric($A2B->agiconfig['force_callplan_id']) && ($A2B->agiconfig['force_callplan_id'] > 0)){
			$A2B -> debug( VERBOSE | WRITELOG, $agi, __FILE__, __LINE__, "force the call plan : ".$A2B->agiconfig['force_callplan_id']);
			$tariffgroupid = $A2B->tariff = $A2B->agiconfig['force_callplan_id'];
		}
		
		if ($this->webui){
			$A2B -> debug( WRITELOG, $agi, __FILE__, __LINE__, "[CC_asterisk_rate-engine: ($tariffgroupid, $phonenumber)]");	
		}
		
		
		/***  0 ) CODE TO RETURN THE DAY OF WEEK + CREATE THE CLAUSE  ***/
		
		$daytag = date("w", time()); // Day of week ( Sunday = 0 .. Saturday = 6 )
		$hours = date("G", time()); // Hours in 24h format ( 0-23 )
		$minutes = date("i", time()); // Minutes (00-59)
		if (!$daytag) $daytag=6;
		else $daytag--;
		if ($this -> debug_st) echo "$daytag $hours $minutes <br>";
		// Race condiction on $minutes ?! 
		$minutes_since_monday = ($daytag * 1440) + ($hours * 60) + $minutes;
		if ($this -> debug_st) echo "$minutes_since_monday<br> ";
		//$sql_clause_days = " AND ".$daytable[$daytag]."='1' ";		
		$sql_clause_days = " AND (starttime <= ".$minutes_since_monday." AND endtime >=".$minutes_since_monday.") "; 
		
		/*
		
		SELECT tariffgroupname, lcrtype, idtariffgroup, cc_tariffgroup_plan.idtariffplan, tariffname, destination,
		
		cc_ratecard.id,
		dialprefix, destination, buyrate, buyrateinitblock, buyrateincrement, rateinitial, initblock, billingblock, 
		connectcharge, disconnectcharge, stepchargea, chargea, timechargea, billingblocka, stepchargeb, chargeb, 
		timechargeb, billingblockb, stepchargec, chargec, timechargec, billingblockc,	
		
		cc_tariffplan.id_trunk AS tp_id_trunk, tp_trunk.trunkprefix AS tp_trunk, tp_trunk.providertech AS tp_providertech, 
		tp_trunk.providerip AS tp_providerip, tp_trunk.removeprefix AS tp_removeprefix,
		cc_ratecard.id_trunk AS rc_id_trunk, rt_trunk.trunkprefix AS rc_trunkprefix, rt_trunk.providertech AS rc_providertech, 
		rt_trunk.providerip AS rc_providerip, rt_trunk.removeprefix AS rc_removeprefix
		
		FROM cc_tariffgroup 
		LEFT JOIN cc_tariffgroup_plan ON idtariffgroup=id
		LEFT JOIN cc_tariffplan ON cc_tariffplan.id=cc_tariffgroup_plan.idtariffplan
		LEFT JOIN cc_ratecard ON cc_ratecard.idtariffplan=cc_tariffplan.id
		LEFT JOIN trunk AS rt_trunk ON cc_ratecard.id_trunk=rt_trunk.id_trunk
		LEFT JOIN trunk AS tp_trunk ON cc_tariffplan.id_trunk=tp_trunk.id_trunk
		
		WHERE dialprefix=SUBSTRING('346586699595',1,length(dialprefix)) 
		AND startingdate<= CURRENT_TIMESTAMP AND (expirationdate > CURRENT_TIMESTAMP OR expirationdate IS NULL OR LENGTH(expirationdate)<5)
		AND startdate<= CURRENT_TIMESTAMP AND (stopdate > CURRENT_TIMESTAMP OR stopdate IS NULL OR LENGTH(stopdate)<5)
		ORDER BY LENGTH(dialprefix) DESC
		
		*/
		
		if (strlen($A2B->dnid)>=1) $mydnid = $A2B->dnid;
		if (strlen($A2B->CallerID)>=1) $mycallerid = $A2B->CallerID;
		
		if ($this->webui) $A2B -> debug( WRITELOG, $agi, __FILE__, __LINE__, "[CC_asterisk_rate-engine: CALLERID]\n".$A2B->CallerID."\n",0);
		
		if ($A2B->config["database"]['dbtype'] != "postgres"){
			$DNID_QUERY = "SELECT count(dnidprefix) FROM cc_tariffplan RIGHT JOIN cc_tariffgroup_plan ON cc_tariffgroup_plan.idtariffgroup=$tariffgroupid WHERE dnidprefix=SUBSTRING('$mydnid',1,length(dnidprefix))";
			$result_sub = $A2B->instance_table -> SQLExec ($A2B -> DBHandle, $DNID_QUERY);
			if (!is_array($result_sub) || count($result_sub)==0) $nb_dnid = 0;
			else $nb_dnid = $result_sub[0][0];
			$DNID_SUB_QUERY = "AND 0 = $nb_dnid";
			
			$CALLERID_QUERY = "SELECT count(calleridprefix) FROM cc_tariffplan RIGHT JOIN cc_tariffgroup_plan ON cc_tariffgroup_plan.idtariffgroup=$tariffgroupid WHERE calleridprefix=SUBSTRING('$mycallerid',1,length(calleridprefix))";
			$result_sub = $A2B->instance_table -> SQLExec ($A2B -> DBHandle, $CALLERID_QUERY);
			if (!is_array($result_sub) || count($result_sub)==0) $nb_callerid = 0;
			else $nb_callerid = $result_sub[0][0];
			$CID_SUB_QUERY = "AND 0 = $nb_callerid";
			if ($this->webui) $A2B -> debug( WRITELOG, $agi, __FILE__, __LINE__, "[CALLERID_QUERY]\n".$CALLERID_QUERY."\n[RESULT]".print_r($result_sub, 1)."\n",0);
			
		}else{
			$DNID_SUB_QUERY = "AND 0 = (SELECT count(dnidprefix) FROM cc_tariffplan RIGHT JOIN cc_tariffgroup_plan ON cc_tariffgroup_plan.idtariffgroup=$tariffgroupid WHERE dnidprefix=SUBSTRING('$mydnid',1,length(dnidprefix)) ) ";
			
			$CID_SUB_QUERY = "AND 0 = (SELECT count(calleridprefix) FROM cc_tariffplan RIGHT JOIN cc_tariffgroup_plan ON cc_tariffgroup_plan.idtariffgroup=$tariffgroupid WHERE calleridprefix=SUBSTRING('$mycallerid',1,length(calleridprefix)) ) ";
		}
		
		$QUERY = "SELECT tariffgroupname, lcrtype, idtariffgroup, cc_tariffgroup_plan.idtariffplan, tariffname, destination,
		
		cc_ratecard.id,	dialprefix, destination, buyrate, buyrateinitblock, buyrateincrement, rateinitial, initblock, billingblock, 
		connectcharge, disconnectcharge, stepchargea, chargea, timechargea, billingblocka, stepchargeb, chargeb, 
		timechargeb, billingblockb, stepchargec, chargec, timechargec, billingblockc,
		cc_tariffplan.id_trunk AS tp_id_trunk, tp_trunk.trunkprefix AS tp_trunk, tp_trunk.providertech AS tp_providertech, 
		tp_trunk.providerip AS tp_providerip, tp_trunk.removeprefix AS tp_removeprefix,
		cc_ratecard.id_trunk AS rc_id_trunk, rt_trunk.trunkprefix AS rc_trunkprefix, rt_trunk.providertech AS rc_providertech, 
		rt_trunk.providerip AS rc_providerip, rt_trunk.removeprefix AS rc_removeprefix,
		musiconhold,
		tp_trunk.failover_trunk AS tp_failover_trunk,
		rt_trunk.failover_trunk AS rt_failover_trunk,
		tp_trunk.addparameter AS tp_addparameter_trunk,
		rt_trunk.addparameter AS rt_addparameter_trunk,
		id_outbound_cidgroup,
		freetimetocall_package_offer, freetimetocall, packagetype, billingtype, startday, id_cc_package_offer

		
		FROM cc_tariffgroup 
		RIGHT JOIN cc_tariffgroup_plan ON cc_tariffgroup.id=$tariffgroupid
		
		INNER JOIN cc_tariffplan ON (cc_tariffplan.id=cc_tariffgroup_plan.idtariffplan )
		
		LEFT JOIN cc_ratecard ON cc_ratecard.idtariffplan=cc_tariffplan.id
		LEFT JOIN cc_trunk AS rt_trunk ON cc_ratecard.id_trunk=rt_trunk.id_trunk
		LEFT JOIN cc_trunk AS tp_trunk ON cc_tariffplan.id_trunk=tp_trunk.id_trunk
		LEFT JOIN cc_package_offer ON cc_package_offer.id=cc_tariffgroup.id_cc_package_offer
		
		WHERE (dialprefix=SUBSTRING('$phonenumber',1,length(dialprefix)) OR dialprefix='defaultprefix')
		AND startingdate<= CURRENT_TIMESTAMP AND (expirationdate > CURRENT_TIMESTAMP OR expirationdate IS NULL OR LENGTH(expirationdate)<5)
		AND startdate<= CURRENT_TIMESTAMP AND (stopdate > CURRENT_TIMESTAMP OR stopdate IS NULL OR LENGTH(stopdate)<5)
		$sql_clause_days
		AND idtariffgroup='$tariffgroupid'
		AND ( dnidprefix=SUBSTRING('$mydnid',1,length(dnidprefix)) OR (dnidprefix='all' $DNID_SUB_QUERY)) 
		AND ( calleridprefix=SUBSTRING('$mycallerid',1,length(calleridprefix)) OR (calleridprefix='all' $CID_SUB_QUERY)) 
		ORDER BY LENGTH(dialprefix) DESC";
		
		//-- if ($this -> debug_st) echo $QUERY."\n\n";
		if ($this->webui) $A2B -> debug( WRITELOG, $agi, __FILE__, __LINE__, "[RATE ENGINE QUERY]\n".$QUERY."\n",0);	
		
		
		$A2B->instance_table = new Table();
		$result = $A2B->instance_table -> SQLExec ($A2B -> DBHandle, $QUERY);
		
		
		if (!is_array($result) || count($result)==0) return 0; // NO RATE FOR THIS NUMBER
	
		if ($this -> debug_st) echo "::> Count Total result ".count($result)."\n\n";
		if ($this->webui) $A2B -> debug( WRITELOG, $agi, __FILE__, __LINE__, "[rate-engine: Count Total result ".count($result)."]");	
		
		// CHECK IF THERE IS OTHER RATE THAT 'DEFAULT', IF YES REMOVE THE DEFAULT RATES
		// NOT NOT REMOVE SHIFT THEM TO THE END :P
		$ind_stop_default = -1;
		for ($i=0;$i<count($result);$i++){
			if ( $result[$i][7] != 'defaultprefix'){ 
				$ind_stop_default = $i; 
				break;
			}	
		}
		// IMPORTANT TO CUT THE PART OF THE defaultprefix CAUSE WE WILL APPLY THE SORT ACCORDING TO THE RATE
		// DEFAULPERFIX IS AN ESCAPE IN CASE OF NO RATE IS DEFINED, NOT BE COUNT WITH OTHER DURING THE 
		// SORT OF RATE
		if ($ind_stop_default>0) {
			$result_defaultprefix = array_slice ($result, 0, $ind_stop_default);
			$result = array_slice ($result, $ind_stop_default, count($result)-$ind_stop_default);
		}
		
		
		//if ($ind_stop_default>0)  array_rotate($result, $ind_stop_default);
		
		
		//1) REMOVE THOSE THAT HAVE A SMALLER DIALPREFIX
		$max_len_prefix = strlen($result[0][7]);
		for ($i=1;$i<count($result);$i++){
			if ( strlen($result[$i][7]) < $max_len_prefix) break;
		}	
		$result = array_slice ($result, 0, $i);
		
		
		//2) TAKE THE VALUE OF LCTYPE 
		//LCR : According to the buyer price	-0 	buyrate [col 6]
		//LCD : According to the seller price	-1  rateinitial	[col 9]
		
		$LCtype = $result[0][1];
		
		// Thanks for the fix from the wiki :D next time email me, lol
		if ($LCtype==0){
			//$result = $this -> array_csort($result,'6',SORT_ASC); GOTTYA!
			$result = $this -> array_csort($result,'9',SORT_ASC); //1
		}else{
			//$result = $this -> array_csort($result,'9',SORT_ASC); GOTTYA!
			$result = $this -> array_csort($result,'12',SORT_ASC); //1
		} 
	
		
		// WE ADD THE DEFAULTPREFIX WE REMOVE BEFORE
		if ($ind_stop_default>0) {
			$result = array_merge ($result, $result_defaultprefix);
		}
	
		
		// 3) REMOVE THOSE THAT USE THE SAME TRUNK - MAKE A DISTINCT
		$mylistoftrunk = array();
		for ($i=0;$i<count($result);$i++){
			
			if ($result[$i][34]==-1) $mylistoftrunk_next[]= $mycurrenttrunk = $result[$i][29];
			else $mylistoftrunk_next[]= $mycurrenttrunk = $result[$i][34];
			
			
			// Check if we already have the same trunk in the ratecard 
			if ($i==0 || !in_array ($mycurrenttrunk , $mylistoftrunk)) {
				$distinct_result[] = $result[$i];			
			}	
			
			$mylistoftrunk[]= $mycurrenttrunk;				
		}	
	
		
		//4) $result[K][34]==-1 USE THE VALUES OF THE TRUNK OF $result[K][29]
		
		
		$this -> ratecard_obj = $distinct_result;
		$this -> number_trunk = count($distinct_result);
		
		// if an extracharge DID number was called increase rates with the extracharge fee
		if (strlen($A2B->dnid)>2 && is_array($A2B->agiconfig['extracharge_did']) && in_array($A2B->dnid, $A2B->agiconfig['extracharge_did']))
		{
			$fee=$A2B->agiconfig['extracharge_fee'][array_search($A2B->dnid, $A2B->agiconfig['extracharge_did'])];
			$A2B -> debug( WRITELOG, $agi, __FILE__, __LINE__, "[CC_asterisk_rate-engine: Extracharge DID found: ".$A2B->dnid.", extra fee: ".$fee."]");
			for ($i=0; $i<count($this->ratecard_obj); $i++)
			{
				$this->ratecard_obj[$i][9] +=$fee;
				$this->ratecard_obj[$i][12]+=$fee;
			}
		}
		
		if ($this -> debug_st)echo "::> Count Total result ".count($distinct_result)."\n\n";
		if ($this->webui) $A2B -> debug( WRITELOG, $agi, __FILE__, __LINE__, "[CC_asterisk_rate-engine: Count Total result ".count($distinct_result)."]");	
		if ($this->webui) $A2B -> debug( WRITELOG, $agi, __FILE__, __LINE__, "[CC_asterisk_rate-engine: number_trunk ".$this -> number_trunk."]");
		
		return 1;
	}
	
	
	/*
		RATE ENGINE - CALCUL TIMEOUT
		* CALCUL THE DURATION ALLOWED FOR THE CALLER TO THIS NUMBER
	*/
	function rate_engine_all_calcultimeout (&$A2B, $credit){
			
		if ($this->webui) $A2B -> debug( WRITELOG, $agi, __FILE__, __LINE__, "[CC_RATE_ENGINE_ALL_CALCULTIMEOUT ($credit)]");
		if (!is_array($this -> ratecard_obj) || count($this -> ratecard_obj)==0) return false;
		
		for ($k=0;$k<count($this -> ratecard_obj);$k++){
			$res_calcultimeout = $this -> rate_engine_calcultimeout ($A2B,$credit,$k);
			if ($this->webui) 
				$A2B -> debug( WRITELOG, $agi, __FILE__, __LINE__, "[CC_RATE_ENGINE_ALL_CALCULTIMEOUT: k=$k - res_calcultimeout:$res_calcultimeout]");
			if (substr($res_calcultimeout,0,5)=='ERROR')	return false;
		}	
			
		return true;
	}
	
	/*
		RATE ENGINE - CALCUL TIMEOUT
		* CALCUL THE DURATION ALLOWED FOR THE CALLER TO THIS NUMBER
	*/
	function rate_engine_calcultimeout (&$A2B, $credit, $K=0){
		
		$rateinitial = round(abs($this -> ratecard_obj[$K][12]),4);
		$initblock = $this -> ratecard_obj[$K][13];
		$billingblock = $this -> ratecard_obj[$K][14];	
		$connectcharge = round(abs($this -> ratecard_obj[$K][15]),4);
		$disconnectcharge = round(abs($this -> ratecard_obj[$K][16]),4);	
		$stepchargea = $this -> ratecard_obj[$K][17]; 		$chargea = round(abs($this -> ratecard_obj[$K][18]),4);
		$timechargea = $this -> ratecard_obj[$K][19];		$billingblocka = $this -> ratecard_obj[$K][20];	
		$stepchargeb = $this -> ratecard_obj[$K][21];		$chargeb = round(abs($this -> ratecard_obj[$K][22]),4);
		$timechargeb = $this -> ratecard_obj[$K][23];		$billingblockb = $this -> ratecard_obj[$K][24];	
		$stepchargec = $this -> ratecard_obj[$K][25];		$chargec = round(abs($this -> ratecard_obj[$K][26]),4);	
		$timechargec = $this -> ratecard_obj[$K][27];		$billingblockc = $this -> ratecard_obj[$K][28];
		
		// ****************  PACKAGE PARAMETERS ****************  
		$freetimetocall_package_offer = $this -> ratecard_obj[$K][45];
		$freetimetocall = $this -> ratecard_obj[$K][46];
		$packagetype = $this -> ratecard_obj[$K][47];
		$billingtype = $this -> ratecard_obj[$K][48];
		$startday = $this -> ratecard_obj[$K][49];
		$id_cc_package_offer = $this -> ratecard_obj[$K][50];
		
		// CHANGE THIS - ONLY ALLOW FREE TIME FOR CUSTOMER THAT HAVE MINIMUM CREDIT TO CALL A DESTINATION
		
		// WE HAVE THE SAME CALL PLAN FOR ALL SO WE CAN RESTRICT THIS CALCULATION TO 1 BEFORE EACH CALL
		$this -> freetimetocall_left[$K] = 0;
		if ($K == 0){
			// CHECK IF WE HAVE A FREETIME THAT CAN APPLY FOR THIS DESTINATION
			if ($freetimetocall_package_offer==1 && $freetimetocall>0){
				// WE NEED TO RETRIEVE THE AMOUNT OF USED MINUTE FOR THIS CUSTOMER ACCORDING TO BILLINGTYPE (Monthly ; Weekly) & STARTDAY
				if ($billingtype == 0){
					// PROCESSING FOR MONTHLY
					// if > last day of the month
					if ($startday > date("t")) $startday = date("t");
					if ($startday <= 0 ) $startday = 1;
					
					// Check if the startday is upper that the current day
					if ($startday > date("j")) $year_month = date('Y-m', strtotime('-1 month'));
					else $year_month = date('Y-m');
					
					$yearmonth = sprintf("%s-%02d",$year_month,$startday);
					if ($A2B->config["database"]['dbtype'] == "postgres"){
	 					$UNIX_TIMESTAMP = "";
					}else{
						$UNIX_TIMESTAMP = "UNIX_TIMESTAMP";
					}
					$CLAUSE_DATE=" $UNIX_TIMESTAMP(date_consumption) >= $UNIX_TIMESTAMP('$yearmonth')";
				}else{
					// PROCESSING FOR WEEKLY
					$startday = $startday % 7;
					$dayofweek = date("w"); // Numeric representation of the day of the week 0 (for Sunday) through 6 (for Saturday)
					if ($dayofweek==0) $dayofweek=7;
					if ($dayofweek < $startday) $dayofweek = $dayofweek + 7;
					$diffday = $dayofweek < $startday;
					if ($A2B->config["database"]['dbtype'] == "postgres"){
	 					$UNIX_TIMESTAMP = " (now() - interval '$diffday day') ";
					}else{
						$UNIX_TIMESTAMP = " DATE_SUB(NOW(), INTERVAL $diffday DAY) ";
					}
				}
				$QUERY = "SELECT  sum(used_secondes) AS used_secondes FROM cc_card_package_offer ".