mattf
426af85077
Fixed Re-Queue bug and INBOUND_MAN blended checkbox display git-svn-id: svn://192.168.202.10@1196 3d104415-ff17-0410-8863-d5cf3c621b8a
314 lines
10 KiB
Perl
314 lines
10 KiB
Perl
#!/usr/bin/perl
|
|
#
|
|
# AST_twoday_tables_control.pl version 2.2.0
|
|
#
|
|
# DESCRIPTION:
|
|
# populates the twoday_ log tables during the day, and purges them at night
|
|
#
|
|
# crontab entry example:
|
|
# two-day processes
|
|
#0,5,10,15,20,25,30,35,40,45,50,55 0,8,9,10,11,12,13,14,15,16,17,18,19,20,21,22,23 * * * /usr/share/astguiclient/AST_twoday_tables_control.pl --insert
|
|
#31 2 * * * /usr/share/astguiclient/AST_twoday_tables_control.pl --purge
|
|
#
|
|
# Copyright (C) 2009 Matt Florell <vicidial@gmail.com> LICENSE: AGPLv2
|
|
#
|
|
# CHANGES
|
|
# 90729-0951 - First build
|
|
#
|
|
|
|
### 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";
|
|
print " [--help] = this screen\n";
|
|
print " [-t] = test\n";
|
|
print " [-debug] = verbose debug messages\n";
|
|
print " [-q] = quiet\n";
|
|
print " [-insert] = run inserts, grab records in the past hour\n";
|
|
print " [-purge] = purge records more than 24 hours old\n";
|
|
print "\n";
|
|
exit;
|
|
}
|
|
else
|
|
{
|
|
if ($args =~ /-q/i)
|
|
{
|
|
$Q=1;
|
|
}
|
|
if ($args =~ /-insert/i)
|
|
{
|
|
$insert=1;
|
|
}
|
|
if ($args =~ /-purge/i)
|
|
{
|
|
$purge=1;
|
|
}
|
|
if ($args =~ /-debug/i)
|
|
{
|
|
$DB=1; # Debug flag, set to 0 for no debug messages, On an active system this will generate hundreds of lines of output per minute
|
|
}
|
|
if ($args =~ /-t/i)
|
|
{
|
|
$TEST=1;
|
|
$T=1;
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if ($Q < 1) {print "no command line options set\n";}
|
|
}
|
|
### end parsing run-time options ###
|
|
|
|
|
|
# default path to astguiclient configuration file:
|
|
$PATHconf = '/etc/astguiclient.conf';
|
|
|
|
open(conf, "$PATHconf") || die "can't open $PATHconf: $!\n";
|
|
@conf = <conf>;
|
|
close(conf);
|
|
$i=0;
|
|
foreach(@conf)
|
|
{
|
|
$line = $conf[$i];
|
|
$line =~ s/ |>|\n|\r|\t|\#.*|;.*//gi;
|
|
if ( ($line =~ /^PATHhome/) && ($CLIhome < 1) )
|
|
{$PATHhome = $line; $PATHhome =~ s/.*=//gi;}
|
|
if ( ($line =~ /^PATHlogs/) && ($CLIlogs < 1) )
|
|
{$PATHlogs = $line; $PATHlogs =~ s/.*=//gi;}
|
|
if ( ($line =~ /^PATHagi/) && ($CLIagi < 1) )
|
|
{$PATHagi = $line; $PATHagi =~ s/.*=//gi;}
|
|
if ( ($line =~ /^PATHweb/) && ($CLIweb < 1) )
|
|
{$PATHweb = $line; $PATHweb =~ s/.*=//gi;}
|
|
if ( ($line =~ /^PATHsounds/) && ($CLIsounds < 1) )
|
|
{$PATHsounds = $line; $PATHsounds =~ s/.*=//gi;}
|
|
if ( ($line =~ /^PATHmonitor/) && ($CLImonitor < 1) )
|
|
{$PATHmonitor = $line; $PATHmonitor =~ s/.*=//gi;}
|
|
if ( ($line =~ /^VARserver_ip/) && ($CLIserver_ip < 1) )
|
|
{$VARserver_ip = $line; $VARserver_ip =~ s/.*=//gi;}
|
|
if ( ($line =~ /^VARDB_server/) && ($CLIDB_server < 1) )
|
|
{$VARDB_server = $line; $VARDB_server =~ s/.*=//gi;}
|
|
if ( ($line =~ /^VARDB_database/) && ($CLIDB_database < 1) )
|
|
{$VARDB_database = $line; $VARDB_database =~ s/.*=//gi;}
|
|
if ( ($line =~ /^VARDB_user/) && ($CLIDB_user < 1) )
|
|
{$VARDB_user = $line; $VARDB_user =~ s/.*=//gi;}
|
|
if ( ($line =~ /^VARDB_pass/) && ($CLIDB_pass < 1) )
|
|
{$VARDB_pass = $line; $VARDB_pass =~ s/.*=//gi;}
|
|
if ( ($line =~ /^VARDB_port/) && ($CLIDB_port < 1) )
|
|
{$VARDB_port = $line; $VARDB_port =~ s/.*=//gi;}
|
|
$i++;
|
|
}
|
|
|
|
# Customized Variables
|
|
$server_ip = $VARserver_ip; # Asterisk server IP
|
|
|
|
if (!$VARDB_port) {$VARDB_port='3306';}
|
|
|
|
use DBI;
|
|
|
|
$dbhA = DBI->connect("DBI:mysql:$VARDB_database:$VARDB_server:$VARDB_port", "$VARDB_user", "$VARDB_pass")
|
|
or die "Couldn't connect to database: " . DBI->errstr;
|
|
|
|
|
|
$secX = time();
|
|
($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) {$hour = "0$hour";}
|
|
if ($min < 10) {$min = "0$min";}
|
|
if ($sec < 10) {$sec = "0$sec";}
|
|
$filedate = "$year$mon$mday-$hour$min$sec";
|
|
$ABIfiledate = "$mon-$mday-$year$us$hour$min$sec";
|
|
$shipdate = "$year-$mon-$mday";
|
|
$datestamp = "$year/$mon/$mday $hour:$min";
|
|
|
|
use Time::Local;
|
|
|
|
$secX = time();
|
|
|
|
$HHtarget = ($secX - 7200); # 2 hours
|
|
($Hsec,$Hmin,$Hhour,$Hmday,$Hmon,$Hyear,$Hwday,$Hyday,$Hisdst) = localtime($HHtarget);
|
|
$Hyear = ($Hyear + 1900);
|
|
$Hmon++;
|
|
if ($Hmon < 10) {$Hmon = "0$Hmon";}
|
|
if ($Hmday < 10) {$Hmday = "0$Hmday";}
|
|
if ($Hhour < 10) {$Hhour = "0$Hhour";}
|
|
if ($Hmin < 10) {$Hmin = "0$Hmin";}
|
|
if ($Hsec < 10) {$Hsec = "0$Hsec";}
|
|
$HHSQLdate = "$Hyear-$Hmon-$Hmday $Hhour:$Hmin:$Hsec";
|
|
|
|
$YDtarget = ($secX - 86400); # 24 hours
|
|
($Ysec,$Ymin,$Yhour,$Ymday,$Ymon,$Yyear,$Ywday,$Yyday,$Yisdst) = localtime($YDtarget);
|
|
$Yyear = ($Yyear + 1900);
|
|
$Ymon++;
|
|
if ($Ymon < 10) {$Ymon = "0$Ymon";}
|
|
if ($Ymday < 10) {$Ymday = "0$Ymday";}
|
|
if ($Yhour < 10) {$Yhour = "0$Yhour";}
|
|
if ($Ymin < 10) {$Ymin = "0$Ymin";}
|
|
if ($Ysec < 10) {$Ysec = "0$Ysec";}
|
|
$YDSQLdate = "$Yyear-$Ymon-$Ymday $Yhour:$Ymin:$Ysec";
|
|
|
|
|
|
################################ INSERT PROCESS
|
|
if ($insert > 0)
|
|
{
|
|
$stmtA = "INSERT IGNORE INTO twoday_call_log SELECT * from call_log where start_time > '$HHSQLdate' ON DUPLICATE KEY UPDATE end_time=VALUES(end_time),end_epoch=VALUES(end_epoch),length_in_sec=VALUES(length_in_sec),length_in_min=VALUES(length_in_min);";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
$stmtA = "INSERT IGNORE INTO twoday_vicidial_log SELECT * from vicidial_log where call_date > '$HHSQLdate' ON DUPLICATE KEY UPDATE end_epoch=VALUES(end_epoch),length_in_sec=VALUES(length_in_sec),status=VALUES(status),user=VALUES(user),comments=VALUES(comments),user_group=VALUES(user_group),term_reason=VALUES(term_reason),alt_dial=VALUES(alt_dial);";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
$stmtA = "INSERT IGNORE INTO twoday_vicidial_closer_log SELECT * from vicidial_closer_log where call_date > '$HHSQLdate' ON DUPLICATE KEY UPDATE list_id=VALUES(list_id),campaign_id=VALUES(campaign_id),end_epoch=VALUES(end_epoch),length_in_sec=VALUES(length_in_sec),status=VALUES(status),user=VALUES(user),comments=VALUES(comments),queue_seconds=VALUES(queue_seconds),user_group=VALUES(user_group),xfercallid=VALUES(xfercallid),term_reason=VALUES(term_reason),uniqueid=VALUES(uniqueid),agent_only=VALUES(agent_only);";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
$stmtA = "INSERT IGNORE INTO twoday_recording_log SELECT * from recording_log where start_time > '$HHSQLdate' ON DUPLICATE KEY UPDATE end_time=VALUES(end_time),end_epoch=VALUES(end_epoch),length_in_sec=VALUES(length_in_sec),length_in_min=VALUES(length_in_min),filename=VALUES(filename),location=VALUES(location),lead_id=VALUES(lead_id),user=VALUES(user),vicidial_id=VALUES(vicidial_id);";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
$stmtA = "INSERT IGNORE INTO twoday_vicidial_xfer_log SELECT * from vicidial_xfer_log where call_date > '$HHSQLdate' ON DUPLICATE KEY UPDATE list_id=VALUES(list_id),campaign_id=VALUES(campaign_id),call_date=VALUES(call_date),user=VALUES(user),closer=VALUES(closer);";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
$stmtA = "INSERT IGNORE INTO twoday_vicidial_agent_log SELECT * from vicidial_agent_log where event_time > '$HHSQLdate' ON DUPLICATE KEY UPDATE lead_id=VALUES(lead_id),campaign_id=VALUES(campaign_id),pause_epoch=VALUES(pause_epoch),pause_sec=VALUES(pause_sec),wait_epoch=VALUES(wait_epoch),wait_sec=VALUES(wait_sec),talk_epoch=VALUES(talk_epoch),talk_sec=VALUES(talk_sec),dispo_epoch=VALUES(dispo_epoch),dispo_sec=VALUES(dispo_sec),status=VALUES(status),user_group=VALUES(user_group),comments=VALUES(comments),sub_status=VALUES(sub_status);";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
}
|
|
|
|
|
|
################################ PURGE PROCESS
|
|
if ($purge > 0)
|
|
{
|
|
##### PURGE RECORDS OLDER THAN 24 HOURS
|
|
$stmtA = "DELETE FROM twoday_call_log where start_time < '$YDSQLdate';";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
$stmtA = "DELETE FROM twoday_vicidial_log where call_date < '$YDSQLdate';";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
$stmtA = "DELETE FROM twoday_vicidial_closer_log where call_date < '$YDSQLdate';";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
$stmtA = "DELETE FROM twoday_recording_log where start_time < '$YDSQLdate';";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
$stmtA = "DELETE FROM twoday_vicidial_xfer_log where call_date < '$YDSQLdate';";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
$stmtA = "DELETE FROM twoday_vicidial_agent_log where event_time < '$YDSQLdate';";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
|
|
##### OPTIMIZE TABLES
|
|
$stmtA = "OPTIMIZE TABLE twoday_call_log;";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
$stmtA = "OPTIMIZE TABLE twoday_vicidial_log;";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
$stmtA = "OPTIMIZE TABLE twoday_vicidial_closer_log;";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
$stmtA = "OPTIMIZE TABLE twoday_recording_log;";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
$stmtA = "OPTIMIZE TABLE twoday_vicidial_xfer_log;";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
$stmtA = "OPTIMIZE TABLE twoday_vicidial_agent_log;";
|
|
if (!$T)
|
|
{
|
|
$affected_rows = $dbhA->do($stmtA);
|
|
if($DB){print "\n|$affected_rows records changed|$stmtA|\n";}
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
$dbhA->disconnect();
|
|
|
|
if ($DB > 0)
|
|
{
|
|
$secY=time();
|
|
$seconds = ($secY - $secX);
|
|
print "Finished, $seconds seconds\n";
|
|
}
|
|
|
|
exit;
|