a2billing_autorefill.php

来自「asterisk用 的voip记费软件」· PHP 代码 · 共 147 行

#!/usr/bin/php -q
<?php 
/***************************************************************************
 *            a2billing_autorefill.php
 *
 *  Fri June 29 2006
 *  A2Billing Copyright  2006 
 *  ADD THIS SCRIPT IN A CRONTAB JOB
 *
	crontab -e
	0 10 21 * * php /var/lib/asterisk/agi-bin/libs_a2billing/crontjob/a2billing_autorefill.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)
	
	The sample above will run the script every 21 of each month at 10AM
	
****************************************************************************/
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_AUTOREFILL, basename(__FILE__).' line:'.__LINE__."[#### BATCH BEGIN ####]");

if (!$A2B -> DbConnect()){				
			echo "[Cannot connect to the database]\n";
			write_log(LOGFILE_CRONT_AUTOREFILL, basename(__FILE__).' line:'.__LINE__."[Cannot connect to the database]");
			exit;						
}
//$A2B -> DBHandle
$instance_table = new Table();


// CHECK NUMBER OF CARD
$QUERY = 'SELECT count(*) FROM cc_card WHERE autorefill=1 AND initialbalance>0 AND credit<initialbalance';

$result = $instance_table -> SQLExec ($A2B -> DBHandle, $QUERY);
$nb_card = $result[0][0];
$nbpagemax=(intval($nb_card/$groupcard));
if ($verbose_level>=1) echo "===> NB_CARD : $nb_card - NBPAGEMAX:$nbpagemax\n";

if (!($nb_card>0)){
		if ($verbose_level>=1) echo "[No card to run the Auto Refill]\n";
		write_log(LOGFILE_CRONT_AUTOREFILL, basename(__FILE__).' line:'.__LINE__."[No card to run the Auto Refill]");
		exit();
}


if ($A2B->config["database"]['dbtype'] == "postgres"){		
	$UNIX_TIMESTAMP = "date_part('epoch',";
}else{
	$UNIX_TIMESTAMP = "UNIX_TIMESTAMP(";
}

write_log(LOGFILE_CRONT_AUTOREFILL, basename(__FILE__).' line:'.__LINE__."[Number of card found : $nb_card]");


$totalcardperform = 0;
$totalcredit = 0;
		
	
	

write_log(LOGFILE_CRONT_AUTOREFILL, basename(__FILE__).' line:'.__LINE__."[Analyze cards to apply Auto Refill]");

// BROWSE THROUGH THE CARD TO APPLY THE AUTO REFILL
for ($page = 0; $page <= $nbpagemax; $page++) {
	
	$sql = "SELECT id, username, credit, initialbalance, initialbalance-credit as refillof FROM cc_card WHERE autorefill=1 AND initialbalance>0 AND credit<initialbalance ORDER BY id ";
	if ($A2B->config["database"]['dbtype'] == "postgres"){
		$sql .= " LIMIT $groupcard OFFSET ".$page*$groupcard;
	}else{
		$sql .= " LIMIT ".$page*$groupcard.", $groupcard";
	}
	if ($verbose_level>=1) echo "==> SELECT CARD QUERY : $sql\n";
	$result_card = $instance_table -> SQLExec ($A2B -> DBHandle, $sql);
	
	foreach ($result_card as $mycard){
		
		if ($verbose_level>=1) print_r ($mycard);
		if ($verbose_level>=1) echo "------>>>  ID = ".$mycard[0]." - CARD =".$mycard[1]." - BALANCE =".$mycard[2]." - REFILLOF =".$mycard[4]." \n";	
		
		$QUERY = "UPDATE cc_card SET credit=credit+".$mycard[4]." WHERE id=".$mycard[0];
		$totalcredit += $mycard[4];
		
		$result = $instance_table -> SQLExec ($A2B -> DBHandle, $QUERY, 0);
		if ($verbose_level>=1) echo "==> UPDATE CARD QUERY: 	$QUERY\n";
		$totalcardperform ++;
		
		
		// INSERT LOG REFILL INTO THE DATABASE
		$QUERY = "INSERT INTO cc_logrefill (credit, card_id, date) VALUES ('$mycard[4]', '$mycard[0]', now())";	
		$result_insert = $instance_table -> SQLExec ($A2B -> DBHandle, $QUERY, 0);
		if ($verbose_level>=1) echo "==> INSERT LOG REFILL QUERY=$QUERY\n";
		
		//exit();
	}
	// Little bit of rest
	sleep(15);
}

write_log(LOGFILE_CRONT_AUTOREFILL, basename(__FILE__).' line:'.__LINE__."[Auto Refill finish]");



// INSERT REPORT SERVICE INTO THE DATABASE
$QUERY = "INSERT INTO cc_autorefill_report (totalcardperform, totalcredit, daterun) ".
		 "VALUES ('$totalcardperform', '$totalcredit', now())";		
$result_insert = $instance_table -> SQLExec ($A2B -> DBHandle, $QUERY, 0);
if ($verbose_level>=1) echo "==> INSERT SERVICE REPORT QUERY=$QUERY\n";

write_log(LOGFILE_CRONT_AUTOREFILL, basename(__FILE__).' line:'.__LINE__."[Service report : 'totalcardperform=$totalcardperform', 'totalcredit=$totalcredit']");



// SEND REPORT
if (strlen($A2B->config["webui"]["email_admin"])>4 && eregi("^[[:alnum:]][a-z0-9_.-]*@[a-z0-9.-]+\.[a-z]{2,4}$", $A2B->config["webui"]["email_admin"])){
	$mail_content = "AUTO REFILL";
	$mail_content .= "\n\nTotal card updated = ".$totalcardperform;
	$mail_content .= "\nTotal credit added = ".$totalcredit;
	mail($A2B->config["webui"]["email_admin"], "A2BILLING AUTO REFILL : REPORT", $mail_content);			
	if ($verbose_level>=1) echo "MAIL CONTENT (".$A2B->config["webui"]["email_admin"].") : $mail_content\n";
}


if ($verbose_level>=1) echo "#### END AUTO REFILL \n";
write_log(LOGFILE_CRONT_AUTOREFILL, basename(__FILE__).' line:'.__LINE__."[#### AUTO REFILL PROCESS END ####]");
	
?>