#!/usr/bin/php -q
<?php

set_time_limit(5);
require('phpagi.php');
require('class_freepbx.php');

error_reporting(0);


$AGI = new AGI();
$db = new AGIDB($AGI);
  
/*** My sample codes ***/
$AGI->verbose("This is sample AGI code");

// Sample#1: show the trunk name for a specified trunkid
$trunk = $argv[1];
$sql='SELECT * FROM `trunks` WHERE trunkid=\''.$trunk.'\'';
$res = $db->sql($sql,'ASSOC');
$name=$res[0]['name'];
$AGI->verbose("Sample#1: TrunkID->[$trunk], Trunk Name->[$name]");

// Sample #2: connect to another DB other than DB 'asterisk'.
$db2 = new AGIDB($AGI);
$db2->dbname='asteriskcdrdb';
$sql='SELECT * FROM `cdr` WHERE dstchannel LIKE \'%ccnet%\'';
$res = $db2->sql($sql,'ASSOC');
$channel=$res[0]['channel'];
$AGI->verbose("Sample#2: Channel->[$channel]");






/***************** Below are original codes
if (!isset($argv[1])) {
        $agi->verbose('Missing trunk info');
        exit(1);
}

$trunk = $argv[1];

$sql='SELECT * FROM `trunks` WHERE trunkid=\''.$trunk.'\'';
$res = $db->sql($sql,'ASSOC');
$name=$res[0]['name'];


if (substr($name,0,4)=='BAL_') //balanced trunk
	{
	$name=substr($name,4);
	//$AGI->verbose("name is $name", 3);

	$trunkallowed=true;
	$AGI->verbose("This trunk $name is balanced. Evaluating rules", 3);
	$sql='SELECT * FROM `trunkbalance` WHERE description=\''.$name.'\'';
	$baltrunk = $db->sql($sql,'ASSOC');
	$desttrunk=$baltrunk[0]['desttrunk_id'];
       $timegroup=$baltrunk[0]['timegroup_id'];
	$maxnumber=$baltrunk[0]['maxnumber'];
	$maxidentical=$baltrunk[0]['maxidentical'];
	$maxtime=$baltrunk[0]['maxtime'];
	$billingday=$baltrunk[0]['billingday'];
	$billingperiod=$baltrunk[0]['billingperiod'];
	$endingdate=$baltrunk[0]['endingdate'];
	$dialpattern=$baltrunk[0]['dialpattern'];
	$notdialpattern=$baltrunk[0]['notdialpattern'];
	//test ratio
	$loadratio=$baltrunk[0]['loadratio'];
	$todaydate=gettimeofday(true);
	$today=getdate();

       if ($timegroup>0) // check the time group condition
       { 
	   $daynames = array("sun"=>0, "mon"=>1, "tue"=>2, "wed"=>3, "thu"=>4, "fri"=>5, "sat"=>6); 
          $monthnames= array ("jan"=>1, "feb"=>2, "mar"=>3, "apr"=>4, "may"=>5, "jun"=>6, "jul"=>7, "aug"=>8, "sep"=>9, "oct"=>10, "nov"=>11, "dec"=>12);
          $timegroupcondition=false;
          $sql='SELECT * FROM `timegroups_details` WHERE timegroupid=\''.$timegroup.'\'';
          $res = $db->sql($sql,'ASSOC');
	   if(is_array($res))
	   {
		foreach($res as $timegroupdetail)
		{
		   $timedetail=$timegroupdetail['time'];
                 $timecondition=true;
		   if ($timedetail<>'')
                 {
			$AGI->verbose("  Timedetail: $timedetail ", 4);
			list($condtimerange,$conddaysweek,$conddaysmonth,$condmonths)=explode("|",$timedetail);
			
			if ($condmonths<>'*')
			{ 
			  $startmonth='';
			  $endmonth='';
			  list($startmonth,$endmonth)=explode("-",$condmonths);
			  if ($endmonth=='') {$endmonth=$startmonth;}
			  $endmonthnum=$monthnames[$endmonth];
			  $startmonthnum=$monthnames[$startmonth];

			  if ((($endmonthnum<$today[mon])&($today[mon]<$startmonthnum)) or
                          (($endmonthnum>=$startmonthnum)& (($today[mon]<$startmonthnum)or($today[mon]>$endmonthnum))))
                       {
                         $AGI->verbose("     month condition '$condmonths' failed", 4);
			    $timecondition=false;
			  } else
                       {
			    $AGI->verbose("     month condition '$condmonths' passed", 4);
			  } 

			}

			if ($conddaysmonth<>'*')
			{
			  $startdate=0;
			  $enddate=0;
			  list($startdate,$enddate)=explode("-",$conddaysmonth);
			  if ($enddate==0) { $enddate=$startdate;}
                       if ((($enddate<$today[mday])&($today[mday]<$startdate)) or
                          (($enddate>=$startdate)& (($today[mday]<$startdate)or($today[mday]>$enddate))))
                       {
                         $AGI->verbose("     day of the month condition '$conddaysmonth' failed", 4);
			    $timecondition=false;
			  } else
                       {
			    $AGI->verbose("     day of the month condition '$conddaysmonth' passed", 4);
			  } 
			}

			if ($conddaysweek<>'*')
			{
			  $startday='';
			  $endday='';
			  list($startday,$endday)=explode("-",$conddaysweek);
			  if ($endday=='') {$endday=$startday;}
			  $startdaynum=$daynames[$startday];
			  $enddaynum=$daynames[$endday];


			  if ((($enddaynum<$today[wday])&($today[wday]<$startdaynum)) or
                          (($enddaynum>=$startdaynum)& (($today[wday]<$startdaynum)or($today[wday]>$enddaynum))))
                       {
                         $AGI->verbose("     day of the week condition '$conddaysweek' failed", 4);
			    $timecondition=false;
			  } else
                       {
			    $AGI->verbose("     day of the week condition '$conddaysweek' passed", 4);
			  } 

			}

			if ($condtimerange<>'*')
			{
			  $starttime='';
			  $endtime='';
			  $todaysminutes=$today[hours]*60+$today[minutes];
			  list($starttime,$endtime)=explode("-",$condtimerange);
			  if ($endtime=='') {$endtime=$starttime;}
			  list($thou,$tmin)=explode(":",$starttime);
			  $starttimemin=$thou*60+$tmin;
			  list($thou,$tmin)=explode(":",$endtime);
			  $endtimemin=$thou*60+$tmin;
			  if ((($endtimemin<$todaysminutes)&($todaysminutes<$starttimemin)) or
                          (($endtimemin>=$starttimemin)& (($todaysminutes<$starttimemin)or($todaysminutes>$endtimemin))))
                       {
                         $AGI->verbose("     time of the day condition '$condtimerange' failed", 4);
			    $timecondition=false;
			  } else
                       {
			    $AGI->verbose("     time of the day condition '$condtimerange' passed", 4);
			  } 


			}

                 
		       if ($timecondition)
		       {
			    $timegroupcondition=true;
		 	    $AGI->verbose("  Timedetail condition passed", 4);
			
		       } else
		       {
		   	   $AGI->verbose("  Timedetail condition failed", 4);
		       }
		   }

              } 
	   } 
	  if ($timegroupcondition)
         {
	    $trunkallowed=true;
 	    $AGI->verbose("Time condition passed", 3);

         } else
         {
	    $trunkallowed=false;
	    $AGI->verbose("Time condition failed", 3);
         }
	}



	if (($loadratio>1)&($trunkallowed))
	{
		$randnum=rand(1,$loadratio);
		if ($randnum==1)
			{
			$AGI->verbose("Balance ratio rule of 1:$loadratio. $randnum was pooled. Rule passed", 3);

			} else
			{
			$AGI->verbose("Balance ratio rule of 1:$loadratio. $randnum was pooled. Rule failed", 3);
			$trunkallowed=false;

			} 
	}

	if ($trunkallowed) //to save time, if the call is already denied ignore the following
	{
		$sqldate='';
		if ($billingday>0)
			{
			//get the date of the billing period
			$diff= $billingday - (date("j",$todaydate));
			$stringdate=(date("Y-m-",$todaydate)).$billingday;
			if ($diff>0)
				{
				$billingdate=strtotime($stringdate. " - 1 month");
				} else
				{
				$billingdate=strtotime($stringdate);
				}
			
			$stringdate=date("Y-m-d 00:00",$billingdate);
			$AGI->verbose("billing date $stringdate", 3);
			$sqldate=' AND calldate>\''.$stringdate.'\'';
			}
		if ($billingperiod>0)
			{
			//get the begining date of the period
			$AGI->verbose("billing period $billingperiod", 3);
			$sqldate=' AND calldate>=DATE_SUB(curdate(), INTERVAL '.$billingperiod.' DAY)';
			}
		
		$sqlpattern='';
		if ($dialpattern!=='')
			{
			$sqlpattern=' AND dst LIKE \''.$dialpattern.'\'';
			}
		if ($notdialpattern!=='')
			{
			$sqlpattern=$sqlpattern.' AND dst NOT LIKE \''.$notdialpattern.'\'';
			}

	

		// load info from the destination trunk
		$sql='SELECT * FROM `trunks` WHERE trunkid=\''.$desttrunk.'\'';
		$res = $db->sql($sql,'ASSOC');
		$destrunk_tech=$res[0]['tech'];
		$destrunk_channelid=$res[0]['channelid'];
		switch ($destrunk_tech)
			{
			case 'sip':
				$channel_filter='SIP/'.$destrunk_channelid.'%';
				break;
			case 'iax':
				$channel_filter='IAX2/'.$destrunk_channelid.'%';
				break;
			default: $channel_filter=$destrunk_channelid;;
			}

		
		//$AGI->verbose("channel_filter $channel_filter", 3);
	
	
		$db2 = new AGIDB($AGI);
		$db2->dbname='asteriskcdrdb';

	
		//test number of calls
		if ($maxnumber>1)
			{
			$sql='SELECT COUNT(*) FROM `cdr` WHERE disposition=\'ANSWERED\' AND dstchannel LIKE \''.$channel_filter.'\''.$sqldate.$sqlpattern;
			$query= $db2->sql($sql,'NUM');
			$numberofcall=$query[0][0];
			if ($maxnumber>$numberofcall)
				{ 
				$AGI->verbose("$maxnumber max calls. This trunk has now only $numberofcall calls - Rule passed", 3);
				} else
				{
				$AGI->verbose("$maxnumber max calls. This trunk has now $numberofcall calls - Rule failed", 3);
				$trunkallowed=false;
				}
		
			}

		//test number of different calls
		if (($maxidentical>1) and ($trunkallowed))
			{
			$sql='SELECT COUNT(DISTINCT(dst)) FROM `cdr` WHERE disposition=\'ANSWERED\' AND dstchannel LIKE \''.$channel_filter.'\''.$sqldate.$sqlpattern;
			$query= $db2->sql($sql,'NUM');
			$numberofdiffcall=$query[0][0];
			if ($maxidentical>$numberofdiffcall)
				{ 
				$AGI->verbose("$maxidentical max different calls. This trunk has now only $numberofdiffcall calls - Rule passed", 3);
				} else
				{
				$AGI->verbose("$maxidentical max different calls. This trunk has now $numberofdiffcall calls - Rule failed", 3);
				$trunkallowed=false;
				}
			}


		//duration of call
		if (($maxtime>0) and ($trunkallowed))
			{
			$sql='SELECT SUM(billsec) FROM `cdr` WHERE disposition=\'ANSWERED\' AND dstchannel LIKE \''.$channel_filter.'\''.$sqldate.$sqlpattern;
			$query= $db2->sql($sql,'NUM');
			$numberofminutes=($query[0][0])/60; 
			if ($maxtime>$numberofminutes)
				{
				$AGI->verbose("$maxtime max minutes. This trunk has now only $numberofminutes min. - Rule passed", 3);		

				} else
				{
				$AGI->verbose("$maxtime max minutes. This trunk has now $numberofminutes min. - Rule failed", 3);
				$trunkallowed=false;
				}
			}

		//limit date
		
		if (($trunkallowed) and ($endingdate!=='0000-00-00 00:00:00'))
			{
	 		if ($todaydate<strtotime($endingdate)) 
				{
				$AGI->verbose("Expiration date $endingdate  - Rule passed", 3);
				} else
				{
				$AGI->verbose("Expiration date $endingdate  - Rule failed", 3);
				$trunkallowed=false;
				}
			}
	
		}
	
	if ($trunkallowed)
		{
		$AGI->verbose("Call authorized. The new trunk number is $desttrunk", 3);
		$AGI->set_variable('DIAL_TRUNK', $desttrunk);
		} else
		{
		$AGI->verbose("At least one condition failed. Call refused.", 3);
		}

	} else
	{
	$AGI->verbose("No balancing rules are defined for this trunk", 3);

	}
*****************/

?>