375 lines
10 KiB
Perl
375 lines
10 KiB
Perl
#!/usr/bin/perl
|
|
#
|
|
# AST_manager_send.pl version 0.3 *DBI-version*
|
|
#
|
|
# Part of the Asterisk Central Queue System (ACQS)
|
|
#
|
|
# DESCRIPTION:
|
|
# spawns child processes (AST_send_action_child.pl) to execute action commands
|
|
# on the Asterisk manager interface from records in the vicidial_manager table
|
|
# of the asterisk database in MySQL that are marked as a status of NEW
|
|
#
|
|
# SUMMARY:
|
|
# This program was designed as the send-only part of the ACQS. It's job is to
|
|
# pick NEW actions from the vicidial_manager table and send them to be executed
|
|
# by separate child process. This allows for a higher degree of flexibility and
|
|
# scalability over just using a single process. Also, this means that a single
|
|
# action execution lock cannot bring the entire system down.
|
|
#
|
|
# For this program to work you need to have the "asterisk" MySQL database
|
|
# created and create the tables listed in the CONF_MySQL.txt file, also make sure
|
|
# that the machine running this program has read/write/update/delete access
|
|
# to that database
|
|
#
|
|
# In your Asterisk server setup you also need to have several things activated
|
|
# and defined. See the CONF_Asterisk.txt file for details
|
|
#
|
|
# Copyright (C) 2006 Matt Florell <vicidial@gmail.com> LICENSE: GPLv2
|
|
#
|
|
# CHANGES
|
|
# 50823-1514 - Added commandline debug options with debug printouts
|
|
# 50902-1051 - Added extra debug output launch sub(commented out)
|
|
# 60718-0909 - changed to DBI by Marin Blu
|
|
#
|
|
|
|
# constants
|
|
$COUNTER_OUTPUT=1; # set to 1 to display the counter as the script runs
|
|
$US='__';
|
|
$MT[0]='';
|
|
|
|
### begin parsing run-time options ###
|
|
if (length($ARGV[0])>1)
|
|
{
|
|
$i=0;
|
|
while ($#ARGV >= $i)
|
|
{
|
|
$args = "$args $ARGV[$i]";
|
|
$i++;
|
|
}
|
|
|
|
if ($args =~ /--help/i)
|
|
{
|
|
print "allowed run time options:\n [-t] = test\n [-debug] = verbose debug messages\n[-debugX] = Extra-verbose debug messages\n\n";
|
|
}
|
|
else
|
|
{
|
|
if ($args =~ /-debug/i)
|
|
{
|
|
$DB=1; # Debug flag
|
|
}
|
|
if ($args =~ /--debugX/i)
|
|
{
|
|
$DBX=1;
|
|
print "\n----- SUPER-DUPER DEBUGGING -----\n\n";
|
|
}
|
|
if ($args =~ /-sendonlyone/i)
|
|
{
|
|
$sendonlyone=1;
|
|
print "\n-----SEND ONLY ONE COMMAND -----\n\n";
|
|
}
|
|
if ($args =~ /-t/i)
|
|
{
|
|
$TEST=1;
|
|
$T=1;
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
# print "no command line options set\n";
|
|
}
|
|
### end parsing run-time options ###
|
|
|
|
### Make sure this file is in a libs path or put the absolute path to it
|
|
require("/home/cron/AST_SERVER_conf.pl"); # local configuration file
|
|
|
|
if (!$DB_port) {$DB_port='3306';}
|
|
|
|
&get_time_now;
|
|
|
|
$event_string='PROGRAM STARTED||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||';
|
|
&event_logger;
|
|
|
|
#use lib './lib', '../lib';
|
|
use Time::HiRes ('gettimeofday','usleep','sleep'); # necessary to have perl sleep command of less than one second
|
|
use DBI;
|
|
#use Net::Telnet ();
|
|
|
|
$dbhA = DBI->connect("DBI:mysql:$DB_database:$DB_server:$DB_port", "$DB_user", "$DB_pass")
|
|
or die "Couldn't connect to database: " . DBI->errstr;
|
|
|
|
$event_string='LOGGED INTO MYSQL SERVER ON 1 CONNECTION|';
|
|
&event_logger;
|
|
|
|
$one_day_interval = 90; # 1 day loops for 3 months
|
|
while($one_day_interval > 0)
|
|
{
|
|
|
|
|
|
$endless_loop=864000; # 10 days at .20 seconds per loop
|
|
|
|
while($endless_loop > 0)
|
|
{
|
|
|
|
$affected_rows=0;
|
|
$NEW_actions=0;
|
|
|
|
$stmtA = "SELECT count(*) from vicidial_manager where server_ip = '$server_ip' and status = 'NEW'";
|
|
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
|
|
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
|
|
$sthArows=$sthA->rows;
|
|
$rec_count=0;
|
|
@aryA = $sthA->fetchrow_array;
|
|
if($DB){print STDERR $aryA[0]," NEW Actions to send on server $server_ip $endless_loop\n";}
|
|
$NEW_actions = "$aryA[0]";
|
|
$rec_count++;
|
|
$sthA->finish();
|
|
|
|
if (!$NEW_actions)
|
|
{
|
|
$affected_rows=0;
|
|
}
|
|
else
|
|
{
|
|
$stmtA = "UPDATE vicidial_manager set status='QUEUE' where server_ip = '$server_ip' and status = 'NEW' order by entry_date limit 1";
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if ($DB) {print STDERR "rows updated to QUEUE: |$affected_rows|\n";}
|
|
}
|
|
|
|
|
|
if ($affected_rows)
|
|
{
|
|
$stmtA = "SELECT * FROM vicidial_manager where server_ip = '$server_ip' and status = 'QUEUE' order by entry_date desc limit 1";
|
|
$event_string="SQL_QUERY|$stmtA|";
|
|
&event_logger;
|
|
|
|
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
|
|
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
|
|
$sthArows=$sthA->rows;
|
|
$rec_count=0;
|
|
while ($sthArows > $rec_count)
|
|
{
|
|
@aryA = $sthA->fetchrow_array;
|
|
|
|
if($DB){print STDERR $aryA[0],"|", $aryA[1],"|", $aryA[6],"|", $aryA[7],"|", $aryA[8],"\n";}
|
|
$man_id = "$aryA[0]";
|
|
$uniqueid = "$aryA[1]";
|
|
$channel = "$aryA[6]";
|
|
$action = "$aryA[7]";
|
|
$callid = "$aryA[8]";
|
|
$cmd_line_b = "$aryA[9]";
|
|
$cmd_line_c = "$aryA[10]";
|
|
$cmd_line_d = "$aryA[11]";
|
|
$cmd_line_e = "$aryA[12]";
|
|
$cmd_line_f = "$aryA[13]";
|
|
$cmd_line_g = "$aryA[14]";
|
|
$cmd_line_h = "$aryA[15]";
|
|
$cmd_line_i = "$record->[16]";
|
|
$cmd_line_j = "$aryA[17]";
|
|
$cmd_line_k = "$aryA[18]";
|
|
|
|
$originate_command = '';
|
|
$originate_command .= "Action: $action\n";
|
|
if (length($cmd_line_b)>3) {$originate_command .= "$cmd_line_b\n";}
|
|
if (length($cmd_line_c)>3) {$originate_command .= "$cmd_line_c\n";}
|
|
if (length($cmd_line_d)>3) {$originate_command .= "$cmd_line_d\n";}
|
|
if (length($cmd_line_e)>3) {$originate_command .= "$cmd_line_e\n";}
|
|
if (length($cmd_line_f)>3) {$originate_command .= "$cmd_line_f\n";}
|
|
if (length($cmd_line_g)>3) {$originate_command .= "$cmd_line_g\n";}
|
|
if (length($cmd_line_h)>3) {$originate_command .= "$cmd_line_h\n";}
|
|
if (length($cmd_line_i)>3) {$originate_command .= "$cmd_line_i\n";}
|
|
if (length($cmd_line_j)>3) {$originate_command .= "$cmd_line_j\n";}
|
|
if (length($cmd_line_k)>3) {$originate_command .= "$cmd_line_k\n";}
|
|
$originate_command .= "\n";
|
|
|
|
$SENDNOW=1;
|
|
if ($originate_command =~ /Action: Hangup|Action: Redirect/)
|
|
{
|
|
$SENDNOW=0;
|
|
if($DB){print STDERR "\n|checking for dead call before executing|$callid|$uniqueid|\n";}
|
|
$stmtB = "SELECT count(*) FROM vicidial_manager where server_ip = '$server_ip' and callerid='$callid' and status = 'DEAD'";
|
|
$sthB = $dbhA->prepare($stmtB) or die "preparing: ",$dbhA->errstr;
|
|
$sthB->execute or die "executing: $stmtA ", $dbhA->errstr;
|
|
$sthArows=$sthB->rows;
|
|
$rec_countH=0;
|
|
@aryB = $sthB->fetchrow_array;
|
|
$rec_countH = "$aryB[0]";
|
|
|
|
if (!$rec_countH){$SENDNOW=1;}
|
|
else
|
|
{
|
|
$launch_string = "|not sending command line is dead|$callid|$uniqueid|";
|
|
if($DB){print STDERR "\n$launch_string\n";}
|
|
}
|
|
$sthB->finish();
|
|
|
|
|
|
}
|
|
|
|
$event_string="----BEGIN NEW COMMAND----\n$originate_command----END NEW COMMAND----\n";
|
|
&event_logger;
|
|
|
|
if ($SENDNOW)
|
|
{
|
|
# $tn->buffer_empty;
|
|
|
|
$launch_string = "/home/cron/AST_send_action_child.pl --data1=$man_id $callid $uniqueid $channel";
|
|
# &launch_logger;
|
|
|
|
system("/home/cron/AST_send_action_child.pl --data1=$man_id >> /home/cron/action.$action_log_date \&");
|
|
|
|
$launch_string = "SENT $man_id $callid $uniqueid $channel";
|
|
# &launch_logger;
|
|
|
|
$stmtA = "UPDATE vicidial_manager set status='SENT' where man_id='$man_id'";
|
|
if($DB){print STDERR "\n|$stmtA|\n";}
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
|
|
$event_string="SQL_QUERY|$stmtA|";
|
|
&event_logger;
|
|
}
|
|
else
|
|
{
|
|
$stmtA = "UPDATE vicidial_manager set status='DEAD' where man_id='$man_id'";
|
|
if($DB){print STDERR "\n|$stmtA|\n";}
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
$event_string="COMMAND NOT SENT, SQL_QUERY|$stmtA|";
|
|
&event_logger;
|
|
}
|
|
$rec_count++;
|
|
}
|
|
$sthA->finish();
|
|
}
|
|
|
|
if ($affected_rows)
|
|
{
|
|
### sleep for 10 hundredths of a second
|
|
usleep(1*100*1000);
|
|
}
|
|
else
|
|
{
|
|
### sleep for 20 hundredths of a second
|
|
usleep(1*200*1000);
|
|
}
|
|
|
|
$endless_loop--;
|
|
if( ($COUNTER_OUTPUT) or ($DB) ){print STDERR "loop counter: |$endless_loop|\r";}
|
|
|
|
### putting a blank file called "sendmgr.kill" in a directory will automatically safely kill this program
|
|
if ( (-e '/home/cron/sendmgr.kill') or ($sendonlyone) )
|
|
{
|
|
unlink('/home/cron/sendmgr.kill');
|
|
$endless_loop=0;
|
|
$one_day_interval=0;
|
|
print "\nPROCESS KILLED MANUALLY... EXITING\n\n";
|
|
}
|
|
|
|
if ($endless_loop =~ /0$/)
|
|
{
|
|
&get_time_now;
|
|
|
|
if( ($COUNTER_OUTPUT) or ($DB) ){print "checking to see if listener is dead |$sendonlyone|$running_listen|\n";}
|
|
#@psoutput = `/bin/ps -f --no-headers -A`;
|
|
@psoutput = `/bin/ps -o "%p %a" --no-headers -A`;
|
|
|
|
$running_listen = 0;
|
|
|
|
$i=0;
|
|
foreach (@psoutput)
|
|
{
|
|
chomp($psoutput[$i]);
|
|
|
|
if ($DBX) {print "$i|$psoutput[$i]| \n";}
|
|
@psline = split(/\/usr\/bin\/perl /,$psoutput[$i]);
|
|
|
|
if ($psline[1] =~ /AST_manager_li/)
|
|
{
|
|
$running_listen++;
|
|
if ($DB) {print "SEND RUNNING: |$psline[1]|\n";}
|
|
}
|
|
|
|
$i++;
|
|
}
|
|
|
|
if (!$running_listen)
|
|
{
|
|
$sendonlyone++;
|
|
if( ($COUNTER_OUTPUT) or ($DB) ){print "LISTENER DEAD STOPPING PROGRAM... ATTEMPTING TO START keepalive SCRIPT\n";}
|
|
$event_string='LISTENER DEAD STOPPING PROGRAM... ATTEMPTING TO START keepalive SCRIPT|';
|
|
&event_logger;
|
|
`/usr/bin/at now < /home/cron/ADMIN_keepalive_send_listen.at 2>/dev/null 1>&2`;
|
|
}
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
if( ($COUNTER_OUTPUT) or ($DB) ){print "DONE... Exiting... Goodbye... See you later... Not really, initiating next loop...$one_day_interval left\n";}
|
|
|
|
$one_day_interval--;
|
|
|
|
}
|
|
|
|
$event_string='CLOSING DB CONNECTION|';
|
|
&event_logger;
|
|
|
|
|
|
$dbhA->disconnect();
|
|
|
|
|
|
if( ($COUNTER_OUTPUT) or ($DB) ){print "DONE... Exiting... Goodbye... See you later... Really I mean it this time\n";}
|
|
|
|
|
|
exit;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
sub get_time_now #get the current date and time and epoch for logging call lengths and datetimes
|
|
{
|
|
($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) = localtime(time);
|
|
$year = ($year + 1900);
|
|
$mon++;
|
|
if ($mon < 10) {$mon = "0$mon";}
|
|
if ($mday < 10) {$mday = "0$mday";}
|
|
if ($hour < 10) {$Fhour = "0$hour";}
|
|
if ($min < 10) {$min = "0$min";}
|
|
if ($sec < 10) {$sec = "0$sec";}
|
|
|
|
$now_date_epoch = time();
|
|
$now_date = "$year-$mon-$mday $hour:$min:$sec";
|
|
$action_log_date = "$year-$mon-$mday";
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
sub event_logger {
|
|
### open the log file for writing ###
|
|
open(Lout, ">>$MSLOGfile")
|
|
|| die "Can't open $MSLOGfile: $!\n";
|
|
|
|
print Lout "$now_date|$event_string|\n";
|
|
|
|
close(Lout);
|
|
|
|
$event_string='';
|
|
}
|
|
|
|
sub launch_logger {
|
|
### open the log file for writing ###
|
|
open(LLout, ">>/home/cron/action_launch.$action_log_date")
|
|
|| die "Can't open /home/cron/action_launch.$action_log_date: $!\n";
|
|
|
|
print LLout "$now_date|$launch_string|\n";
|
|
|
|
close(LLout);
|
|
|
|
$event_string='';
|
|
}
|