#!/usr/bin/php -q<?php /*************************************************************************** *            a2billing_alarm.php * *  ADD THIS SCRIPT IN A CRONTAB JOB *	crontab -e	0 0 * * * php /var/lib/asterisk/agi-bin/libs_a2billing/crontjob/a2billing_alarm.php		field	 allowed values	-----	 --------------	minute	 		0-59	hour		 	0-23	day of month	1-31	month	 		1-12 (or names, see below)	day of week	 	0-7 (0 or 7 is Sun, or use names)		****************************************************************************/set_time_limit(0);error_reporting(E_ALL ^ (E_NOTICE | E_WARNING));//dl("pgsql.so"); // remove "extension= pgsql.so !include (dirname(__FILE__)."/../db_php_lib/Class.Table.php");include (dirname(__FILE__)."/../Class.A2Billing.php");include (dirname(__FILE__)."/../Misc.php");$verbose_level=0;$groupcard=5000;$A2B = new A2Billing();$A2B -> load_conf($agi, NULL, 0, $idconfig);write_log(LOGFILE_CRONT_ALARM, basename(__FILE__).' line:'.__LINE__."[#### BATCH BEGIN ####]");if (!$A2B -> DbConnect()){							echo "[Cannot connect to the database]\n";			write_log(LOGFILE_CRONT_ALARM, basename(__FILE__).' line:'.__LINE__."[Cannot connect to the database]");			exit;						}//$A2B -> DBHandle$instance_table = new Table();// CHECK THE ALARMS$QUERY = "SELECT id, name, periode, type, maxvalue, minvalue, id_trunk, status, numberofrun, datecreate,datelastrun, emailreport FROM cc_alarm WHERE status=1";$result = $instance_table -> SQLExec ($A2B -> DBHandle, $QUERY);if ($verbose_level>=1) print_r ($result);if( !is_array($result)) {		echo "[No Alarm to run]\n";		write_log(LOGFILE_CRONT_ALARM, basename(__FILE__).' line:'.__LINE__."[ No Alarm to run]");		exit();}// 0 id, 1 name, 2 period, 3 type, 4 maxvalue, 5 minvalue, 6 id_trunk, 7 status, 8 numberofrun, 9 datecreate, 10 datelastrun, 11 emailreport $oneday = 60*60*24;$groupcalls = 5000;// BROWSE THROUGH THE ALARMS foreach ($result as $myalarm) {	$SQL_CLAUSE="";	$timestamp_lastsend = strtotime($myalarm[10]);	if ($verbose_level>=3) echo "timestamp_lastsend = $timestamp_lastsend"." ; now = ".time();		//  1 "Daily", 2 "Weekly", 3 "Monthly"	$run_alarm=false;		// LITTLE TRICK TO MAKE IT WORKS WITH POSTGRES TOO AS THE VALUE WILL BE NULL	if ($myalarm[10] == "0000-00-00 00:00:00"){		$myalarm[10] = "";		// WE WILL THEN COMPARE TO AN EMPTY STRING ""	}		switch ($myalarm[2]) {		// Hourly		case 1:				if (date("G",time())!=date("G",$timestamp_lastsend) || $myalarm[10] == ""){				$run_alarm=true;				$SQL_CLAUSE="WHERE starttime BETWEEN '".date("Y-m-j H:i:s",$timestamp_lastsend)."' AND '".date("Y-m-j H:i:s",time())."'";			}			if ($verbose_level>=1) echo "\n\n TODAY :".date("G",time())." LAST RUN DAY :".date("G",$timestamp_lastsend);		break;		// Daily		case 2:				if (date("j",time())!=date("j",$timestamp_lastsend) || $myalarm[10] == ""){				$run_alarm=true;				$SQL_CLAUSE="WHERE starttime BETWEEN '".date("Y-m-j",time())." 00:00:00' AND '".date("Y-m-j",time())." 23:59:59'";			}			if ($verbose_level>=1) echo "\n\n TODAY :".date("j",time())." LAST RUN DAY :".date("j",$timestamp_lastsend);		break;		//Weekly -> will run only monday and check if the week is not the same		case 3:			if (((date("w",time()) == 1) && (date("W",time())!=date("W",$timestamp_lastsend))) || $myalarm[10] == ""){				$run_alarm=true;				$SQL_CLAUSE="WHERE starttime BETWEEN '".date("Y-m-j",(time()-($oneday*7)))." 00:00:00' AND '".date("Y-m-j",time())." 23:59:59'";			}			if ($verbose_level>=1) echo "\n\n TODAY :".date("w",time())." WEEK:".date("W",time()).										" LAST RUN DAY :".date("w",$timestamp_lastsend)." LAST RUN WEEK :".date("W",$timestamp_lastsend);		break;		//Monthly		case 4:			if (((date("j",time()) == 1) && (date("m",time())!=date("m",$timestamp_lastsend))) || $myalarm[10] == ""){				$run_alarm=true;				$SQL_CLAUSE="WHERE starttime BETWEEN '".date("Y-m-j",(time()-($oneday*date("t",time()-$oneday))))." 00:00:00' AND '".date("Y-m-j",(time()-$oneday))." 23:59:59'";			}			if ($verbose_level>=1) echo "\n\n THIS MONTH :".date("m",time())." LAST RUN MONTH :".date("m",$timestamp_lastsend);		break;	}		if ($run_alarm){				if (isset($myalarm[6]) && $myalarm[6] != "") $SQL_CLAUSE.=" AND id_trunk = '".$myalarm[6]."'";		write_log(LOGFILE_CRONT_ALARM, basename(__FILE__).' line:'.__LINE__."[Alarm : ".$myalarm[1]." ]");		$QUERY =	"SELECT COUNT(*) FROM cc_call $SQL_CLAUSE";				if ($verbose_level>=1) echo "\n===> QUERY = $QUERY\n";		$calls = $instance_table -> SQLExec ($A2B -> DBHandle, $QUERY,1);					$nb_card = $calls[0][0];		$nbpagemax=(intval($nb_card/$groupcalls));		if ($verbose_level>=1) echo "===> NB_CARD : $nb_card - NBPAGEMAX:$nbpagemax\n";				if (!($nb_card>0)){			if ($verbose_level>=1) echo "[No call to run the Alarm Service]\n";				write_log(LOGFILE_CRONT_ALARM, basename(__FILE__).' line:'.__LINE__."[No call to run the Alarm service]");				exit();		}				$totalsuccess=0;		$totalfail=0;		$totaltime=0;		$max_fail=0;		$max=0;		$update=array();		for ($page = 0; $page <= $nbpagemax; $page++) 		{			// REST AFTER $groupcalls CARD HANDLED			if ($page > 0) sleep(15);						$QUERY =	"SELECT CASE WHEN terminatecause = 'ANSWER' THEN 1 ELSE 0 END AS success,".						"CASE WHEN terminatecause ='ANSWER' THEN 0 ELSE 1 END AS fail,sessiontime FROM cc_call $SQL_CLAUSE";						if ($A2B->config["database"]['dbtype'] == "postgres")			{				$QUERY .= " LIMIT $groupcard OFFSET ".$page*$groupcard;			}			else			{				$QUERY .= " LIMIT ".$page*$groupcard.", $groupcard";			}						if ($verbose_level>=1) echo "\n\n".$QUERY;						$res = $instance_table -> SQLExec ($A2B -> DBHandle, $QUERY,1);			for($i=0;$i<count($res);$i++)			{				$totalsuccess+=$res[$i][0];				$totalfail+=$res[$i][1];				$totaltime+=$res[$i][2];				// FIND THE CIC (Consecutive Incomplete Calls)  				if($res[$i][1] == 1)	$max++;					if($res[$i][1] == 0)				{					if($max > $max_fail)					$max_fail = $max;					$max = 0;				}			}			if($max > $max_fail)	$max_fail = $max;							} // LOOP FOR THE CALLS						if ($max_fail == 1)	$max_fail = 0;			$ASR = $totalsuccess / $totalsuccess + $totalfail;		$ALOC = $totaltime / $totalsuccess + $totalfail;				$send_alarm = false;						//$type_list   ["0" ALOC, "1" ASR, "2" CIC]		switch ($myalarm[3]) {			case 1:				if ( $ALOC >= $myalarm[4] || $ALOC <= $myalarm[5]){					$value=$ALOC;					$send_alarm=true;				}				$content="\n\n The ALOC $ALOC seconde is too low or too hight than the max: ".$myalarm[4]." min:".$myalarm[5]." defined in the alarm";			break;						case 2:				if ($ASR >= $myalarm[4] || $ASR <= $myalarm[5]){					$value = $ASR;					$send_alarm=true;				}				$content="\n\n The ASR $ASR is too low or too hight than the max: ".$myalarm[4]." min:".$myalarm[5]." defined in the alarm";							break;						case 3:				if ($max_fail >= $myalarm[4]){										$value=$max_fail;					$send_alarm=true;				}				$content="\n\n The Max Consecutive Incomplete Calls : ".$max_fail." calls is too hight than the max: ".$myalarm[4]." defined in the alarm";			break;		}		if ($verbose_level>=1) echo "content = $content\n";		write_log(LOGFILE_CRONT_ALARM, basename(__FILE__).' line:'.__LINE__."[Alarm finish]");		// INSERT REPORT ALARM INTO THE DATABASE		$QUERY = "INSERT INTO cc_alarm_report (cc_alarm_id, calculatedvalue, daterun) ". "VALUES ('$myalarm[0]', '$value', now())";		$result_insert = $instance_table -> SQLExec ($A2B -> DBHandle, $QUERY, 0);		if ($verbose_level>=1) echo "\n\n ==> INSERT ALARM REPORT QUERY=$QUERY\n";				write_log(LOGFILE_CRONT_ALARM, basename(__FILE__).' line:'.__LINE__."[Alarm report : 'Alarm name=$myalarm[1]', 'Alarm type=$myalarm[3]', 'Calculated value=$value']");				// UPDATE THE ALARM				if ($send_alarm) $add_field=", numberofalarm=numberofalarm+1";		else $add_field="";		$QUERY = "UPDATE cc_alarm SET datelastrun=now(), numberofrun=numberofrun+1 $add_field WHERE id=".$myalarm[0];		$result = $instance_table -> SQLExec ($A2B -> DBHandle, $QUERY, 0);		if ($verbose_level>=1) echo "\n\n ==> ALARM UPDATE QUERY: 	$QUERY\n";						// SEND REPORT		if (($send_alarm) && (strlen($myalarm[7])>0)){			$mail_content = "ALARM NAME = ".$myalarm[1];			$mail_content .= $content;			mail($myalarm[11], "A2BILLING ALARM : REPORT", $mail_content);		}			} // IF ALARM	} // MAIN LOOP FOR THE ALARMif ($verbose_level>=1) echo "#### END ALARMS \n";write_log(LOGFILE_CRONT_ALARM, basename(__FILE__).' line:'.__LINE__."[#### ALARM END ####]");?>