moved campaign stats generation and adaptive functions out of AST_VDhopper.pl and into a new script: AST_VDadapt.pl
git-svn-id: svn://192.168.202.10@205 3d104415-ff17-0410-8863-d5cf3c621b8a
This commit is contained in:
mattf
@@ -0,0 +1,960 @@
|
||||
#!/usr/bin/perl
|
||||
#
|
||||
# AST_VDadapt.pl version 2.0.1 *DBI-version*
|
||||
#
|
||||
# DESCRIPTION:
|
||||
# adjusts the auto_dial_level for vicidial adaptive-predictive campaigns.
|
||||
#
|
||||
# Copyright (C) 2006 Matt Florell <vicidial@gmail.com> LICENSE: GPLv2
|
||||
#
|
||||
# 60823-1302 - first build from AST_VDhopper.pl
|
||||
#
|
||||
|
||||
# constants
|
||||
$DB=0; # Debug flag, set to 0 for no debug messages, On an active system this will generate lots of lines of output per minute
|
||||
$US='__';
|
||||
$MT[0]='';
|
||||
|
||||
$secT = time();
|
||||
$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) {$Fhour = "0$hour";}
|
||||
if ($min < 10) {$min = "0$min";}
|
||||
if ($sec < 10) {$sec = "0$sec";}
|
||||
$file_date = "$year-$mon-$mday";
|
||||
$now_date = "$year-$mon-$mday $hour:$min:$sec";
|
||||
$VDL_date = "$year-$mon-$mday 00:00:01";
|
||||
|
||||
### get date-time of one hour ago ###
|
||||
$VDL_hour = ($secX - (60 * 60));
|
||||
($Vsec,$Vmin,$Vhour,$Vmday,$Vmon,$Vyear,$Vwday,$Vyday,$Visdst) = localtime($VDL_hour);
|
||||
$Vyear = ($Vyear + 1900);
|
||||
$Vmon++;
|
||||
if ($Vmon < 10) {$Vmon = "0$Vmon";}
|
||||
if ($Vmday < 10) {$Vmday = "0$Vmday";}
|
||||
$VDL_hour = "$Vyear-$Vmon-$Vmday $Vhour:$Vmin:$Vsec";
|
||||
|
||||
### get date-time of half hour ago ###
|
||||
$VDL_halfhour = ($secX - (30 * 60));
|
||||
($Vsec,$Vmin,$Vhour,$Vmday,$Vmon,$Vyear,$Vwday,$Vyday,$Visdst) = localtime($VDL_halfhour);
|
||||
$Vyear = ($Vyear + 1900);
|
||||
$Vmon++;
|
||||
if ($Vmon < 10) {$Vmon = "0$Vmon";}
|
||||
if ($Vmday < 10) {$Vmday = "0$Vmday";}
|
||||
$VDL_halfhour = "$Vyear-$Vmon-$Vmday $Vhour:$Vmin:$Vsec";
|
||||
|
||||
### get date-time of five minutes ago ###
|
||||
$VDL_five = ($secX - (5 * 60));
|
||||
($Vsec,$Vmin,$Vhour,$Vmday,$Vmon,$Vyear,$Vwday,$Vyday,$Visdst) = localtime($VDL_five);
|
||||
$Vyear = ($Vyear + 1900);
|
||||
$Vmon++;
|
||||
if ($Vmon < 10) {$Vmon = "0$Vmon";}
|
||||
if ($Vmday < 10) {$Vmday = "0$Vmday";}
|
||||
$VDL_five = "$Vyear-$Vmon-$Vmday $Vhour:$Vmin:$Vsec";
|
||||
|
||||
### get date-time of one minute ago ###
|
||||
$VDL_one = ($secX - (1 * 60));
|
||||
($Vsec,$Vmin,$Vhour,$Vmday,$Vmon,$Vyear,$Vwday,$Vyday,$Visdst) = localtime($VDL_one);
|
||||
$Vyear = ($Vyear + 1900);
|
||||
$Vmon++;
|
||||
if ($Vmon < 10) {$Vmon = "0$Vmon";}
|
||||
if ($Vmday < 10) {$Vmday = "0$Vmday";}
|
||||
$VDL_one = "$Vyear-$Vmon-$Vmday $Vhour:$Vmin:$Vsec";
|
||||
|
||||
### 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(must stay in this order):\n [--debug] = debug\n [--debugX] = super debug\n [--dbgmt] = show GMT offset of records as they are inserted into hopper\n [-t] = test\n [--level=XXX] = force a hopper_level of XXX\n [--campaign=XXX] = run for campaign XXX only\n\n";
|
||||
}
|
||||
else
|
||||
{
|
||||
if ($args =~ /--campaign=/i)
|
||||
{
|
||||
# print "\n|$ARGS|\n\n";
|
||||
@data_in = split(/--campaign=/,$args);
|
||||
$CLIcampaign = $data_in[1];
|
||||
}
|
||||
else
|
||||
{$CLIcampaign = '';}
|
||||
if ($args =~ /--level=/i)
|
||||
{
|
||||
@data_in = split(/--level=/,$args);
|
||||
$CLIlevel = $data_in[1];
|
||||
$CLIlevel =~ s/ .*$//gi;
|
||||
$CLIlevel =~ s/\D//gi;
|
||||
print "\n-----HOPPER LEVEL OVERRIDE: $CLIlevel -----\n\n";
|
||||
}
|
||||
else
|
||||
{$CLIlevel = '';}
|
||||
if ($args =~ /--debug/i)
|
||||
{
|
||||
$DB=1;
|
||||
print "\n----- DEBUG -----\n\n";
|
||||
}
|
||||
if ($args =~ /--debugX/i)
|
||||
{
|
||||
$DBX=1;
|
||||
print "\n----- SUPER DEBUG -----\n\n";
|
||||
}
|
||||
if ($args =~ /--dbgmt/i)
|
||||
{
|
||||
$DB_show_offset=1;
|
||||
print "\n-----DEBUG GMT -----\n\n";
|
||||
}
|
||||
if ($args =~ /-t/i)
|
||||
{
|
||||
$T=1; $TEST=1;
|
||||
print "\n-----TESTING -----\n\n";
|
||||
}
|
||||
if ($args =~ /--wipe-hopper-clean/i)
|
||||
{
|
||||
$wipe_hopper_clean=1;
|
||||
}
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
print "no command line options set\n";
|
||||
}
|
||||
|
||||
# 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++;
|
||||
}
|
||||
|
||||
if (!$VDHLOGfile) {$VDHLOGfile = "$PATHlogs/hopper.$year-$mon-$mday";}
|
||||
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;
|
||||
|
||||
|
||||
### Grab Server values from the database
|
||||
$stmtA = "SELECT vd_server_logs,local_gmt FROM servers where server_ip = '$VARserver_ip';";
|
||||
$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;
|
||||
$DBvd_server_logs = "$aryA[0]";
|
||||
$DBSERVER_GMT = "$aryA[1]";
|
||||
if ($DBvd_server_logs =~ /Y/) {$SYSLOG = '1';}
|
||||
else {$SYSLOG = '0';}
|
||||
if (length($DBSERVER_GMT)>0) {$SERVER_GMT = $DBSERVER_GMT;}
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
|
||||
|
||||
|
||||
$secX = time();
|
||||
($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) = localtime($secX);
|
||||
$LOCAL_GMT_OFF = $SERVER_GMT;
|
||||
$LOCAL_GMT_OFF_STD = $SERVER_GMT;
|
||||
if ($isdst) {$LOCAL_GMT_OFF++;}
|
||||
|
||||
$GMT_now = ($secX - ($LOCAL_GMT_OFF * 3600));
|
||||
($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) = localtime($GMT_now);
|
||||
$mon++;
|
||||
$year = ($year + 1900);
|
||||
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";}
|
||||
|
||||
if ($DB) {print "TIME DEBUG: $LOCAL_GMT_OFF_STD|$LOCAL_GMT_OFF|$isdst| GMT: $hour:$min\n";}
|
||||
|
||||
@campaign_id=@MT;
|
||||
|
||||
if ($CLIcampaign)
|
||||
{
|
||||
$stmtA = "SELECT * from vicidial_campaigns where campaign_id='$CLIcampaign'";
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmtA = "SELECT * from vicidial_campaigns where active='Y'";
|
||||
}
|
||||
$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;
|
||||
$campaign_id[$rec_count] = "$aryA[0]";
|
||||
$dial_status_a[$rec_count] = "$aryA[3]";
|
||||
$dial_status_b[$rec_count] = "$aryA[4]";
|
||||
$dial_status_c[$rec_count] = "$aryA[5]";
|
||||
$dial_status_d[$rec_count] = "$aryA[6]";
|
||||
$dial_status_e[$rec_count] = "$aryA[7]";
|
||||
$lead_order[$rec_count] = "$aryA[8]";
|
||||
if (!$CLIlevel)
|
||||
{$hopper_level[$rec_count] = "$aryA[13]";}
|
||||
else
|
||||
{$hopper_level[$rec_count] = "$CLIlevel";}
|
||||
$auto_dial_level[$rec_count] = "$aryA[14]";
|
||||
$local_call_time[$rec_count] = "$aryA[16]";
|
||||
$lead_filter_id[$rec_count] = "$aryA[35]";
|
||||
$use_internal_dnc[$rec_count] = "$aryA[43]";
|
||||
$dial_method[$rec_count] = $aryA[46];
|
||||
$available_only_ratio_tally[$rec_count] = $aryA[47];
|
||||
$adaptive_dropped_percentage[$rec_count] = $aryA[48];
|
||||
$adaptive_maximum_level[$rec_count] = $aryA[49];
|
||||
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
if ($DB) {print "CAMPAIGNS TO PROCESSES ADAPT FOR: $rec_count|$#campaign_id\n";}
|
||||
|
||||
|
||||
##### LOOP THROUGH EACH CAMPAIGN AND PROCESS THE HOPPER #####
|
||||
$i=0;
|
||||
foreach(@campaign_id)
|
||||
{
|
||||
### Find out how many leads are in the hopper from a specific campaign
|
||||
$hopper_ready_count=0;
|
||||
$stmtA = "SELECT count(*) from vicidial_hopper where campaign_id='$campaign_id[$i]' and status='READY';";
|
||||
$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;
|
||||
$hopper_ready_count = $aryA[0];
|
||||
if ($DB) {print "\n $campaign_id[$i] hopper READY count: $hopper_ready_count\n";}
|
||||
if ($DBX) {print " |$stmtA|\n";}
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
$event_string = "|$campaign_id[$i]|$hopper_level[$i]|$hopper_ready_count|$local_call_time[$i]||";
|
||||
&event_logger;
|
||||
|
||||
if ($hopper_ready_count>0)
|
||||
{
|
||||
### BEGIN - GATHER STATS FOR THE vicidial_campaign_stats TABLE ###
|
||||
$vicidial_log = 'vicidial_log';
|
||||
$VCSdialable_leads=0;
|
||||
$VCScalls_today=0;
|
||||
$VCSdrops_today=0;
|
||||
$VCSdrops_today_pct=0;
|
||||
$VCScalls_hour=0;
|
||||
$VCSdrops_hour=0;
|
||||
$VCSdrops_hour_pct=0;
|
||||
$VCScalls_halfhour=0;
|
||||
$VCSdrops_halfhour=0;
|
||||
$VCSdrops_halfhour_pct=0;
|
||||
$VCScalls_five=0;
|
||||
$VCSdrops_five=0;
|
||||
$VCSdrops_five_pct=0;
|
||||
$VCScalls_one=0;
|
||||
$VCSdrops_one=0;
|
||||
$VCSdrops_one_pct=0;
|
||||
|
||||
$stmtA = "SELECT dialable_leads from vicidial_campaign_stats where campaign_id='$campaign_id[$i]';";
|
||||
$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;
|
||||
$VCSdialable_leads = "$aryA[0]";
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
|
||||
# TODAY CALL AND DROP STATS
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_date';";
|
||||
$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;
|
||||
$VCScalls_today = "$aryA[0]";
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
if ($VCScalls_today > 0)
|
||||
{
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_date' and status IN('DROP','XDROP');";
|
||||
$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;
|
||||
$VCSdrops_today = "$aryA[0]";
|
||||
if ($VCSdrops_today > 0)
|
||||
{
|
||||
$VCSdrops_today_pct = ( ($VCSdrops_today / $VCScalls_today) * 100 );
|
||||
$VCSdrops_today_pct = sprintf("%.2f", $VCSdrops_today_pct);
|
||||
}
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
}
|
||||
|
||||
# LAST HOUR CALL AND DROP STATS
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_hour';";
|
||||
$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;
|
||||
$VCScalls_hour = "$aryA[0]";
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
if ($VCScalls_hour > 0)
|
||||
{
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_hour' and status IN('DROP','XDROP');";
|
||||
$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;
|
||||
$VCSdrops_hour = "$aryA[0]";
|
||||
if ($VCSdrops_hour > 0)
|
||||
{
|
||||
$VCSdrops_hour_pct = ( ($VCSdrops_hour / $VCScalls_hour) * 100 );
|
||||
$VCSdrops_hour_pct = sprintf("%.2f", $VCSdrops_hour_pct);
|
||||
}
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
}
|
||||
|
||||
# LAST HALFHOUR CALL AND DROP STATS
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_halfhour';";
|
||||
$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;
|
||||
$VCScalls_halfhour = "$aryA[0]";
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
if ($VCScalls_halfhour > 0)
|
||||
{
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_halfhour' and status IN('DROP','XDROP');";
|
||||
$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;
|
||||
$VCSdrops_halfhour = "$aryA[0]";
|
||||
if ($VCSdrops_halfhour > 0)
|
||||
{
|
||||
$VCSdrops_halfhour_pct = ( ($VCSdrops_halfhour / $VCScalls_halfhour) * 100 );
|
||||
$VCSdrops_halfhour_pct = sprintf("%.2f", $VCSdrops_halfhour_pct);
|
||||
}
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
}
|
||||
|
||||
# LAST FIVE MINUTE CALL AND DROP STATS
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_five';";
|
||||
$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;
|
||||
$VCScalls_five = "$aryA[0]";
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
if ($VCScalls_five > 0)
|
||||
{
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_five' and status IN('DROP','XDROP');";
|
||||
$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;
|
||||
$VCSdrops_five = "$aryA[0]";
|
||||
if ($VCSdrops_five > 0)
|
||||
{
|
||||
$VCSdrops_five_pct = ( ($VCSdrops_five / $VCScalls_five) * 100 );
|
||||
$VCSdrops_five_pct = sprintf("%.2f", $VCSdrops_five_pct);
|
||||
}
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
}
|
||||
|
||||
# LAST ONE MINUTE CALL AND DROP STATS
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_one';";
|
||||
$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;
|
||||
$VCScalls_one = "$aryA[0]";
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
if ($VCScalls_one > 0)
|
||||
{
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_one' and status IN('DROP','XDROP');";
|
||||
$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;
|
||||
$VCSdrops_one = "$aryA[0]";
|
||||
if ($VCSdrops_one > 0)
|
||||
{
|
||||
$VCSdrops_one_pct = ( ($VCSdrops_one / $VCScalls_one) * 100 );
|
||||
$VCSdrops_one_pct = sprintf("%.2f", $VCSdrops_one_pct);
|
||||
}
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
}
|
||||
|
||||
$VCSINCALL=0;
|
||||
$VCSREADY=0;
|
||||
$VCSCLOSER=0;
|
||||
$VCSPAUSED=0;
|
||||
$VCSagents=0;
|
||||
$VCSagents_calc=0;
|
||||
$VCSagents_active=0;
|
||||
|
||||
# COUNTS OF STATUSES OF AGENTS IN THIS CAMPAIGN
|
||||
$stmtA = "SELECT count(*),status from vicidial_live_agents where campaign_id='$campaign_id[$i]' and last_update_time > '$VDL_one' group by status;";
|
||||
$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;
|
||||
$VCSagent_count = "$aryA[0]";
|
||||
$VCSagent_status = "$aryA[1]";
|
||||
$rec_count++;
|
||||
if ($VCSagent_status =~ /INCALL|QUEUE/) {$VCSINCALL = ($VCSINCALL + $VCSagent_count);}
|
||||
if ($VCSagent_status =~ /READY/) {$VCSREADY = ($VCSREADY + $VCSagent_count);}
|
||||
if ($VCSagent_status =~ /CLOSER/) {$VCSCLOSER = ($VCSCLOSER + $VCSagent_count);}
|
||||
if ($VCSagent_status =~ /PAUSED/) {$VCSPAUSED = ($VCSPAUSED + $VCSagent_count);}
|
||||
$VCSagents = ($VCSagents + $VCSagent_count);
|
||||
}
|
||||
$sthA->finish();
|
||||
|
||||
if ($available_only_ratio_tally =~ /Y/)
|
||||
{$VCSagents_calc = $VCSREADY;}
|
||||
else
|
||||
{$VCSagents_calc = ($VCSINCALL + $VCSREADY);}
|
||||
$VCSagents_active = ($VCSINCALL + $VCSREADY + $VCSCLOSER);
|
||||
|
||||
### END - GATHER STATS FOR THE vicidial_campaign_stats TABLE ###
|
||||
|
||||
##### BEGIN calculate what gmt_offset_now values are within the allowed local_call_time setting ###
|
||||
$g=0;
|
||||
$p='13';
|
||||
$GMT_gmt[0] = '';
|
||||
$GMT_hour[0] = '';
|
||||
$GMT_day[0] = '';
|
||||
if ($DBX) {print "\n |GMT-DAY-HOUR| ";}
|
||||
while ($p > -13)
|
||||
{
|
||||
$pzone = ($GMT_now + ($p * 3600));
|
||||
($psec,$pmin,$phour,$pmday,$pmon,$pyear,$pday,$pyday,$pisdst) = localtime($pzone);
|
||||
$phour=($phour * 100);
|
||||
$tz = sprintf("%.2f", $p);
|
||||
$GMT_gmt[$g] = "$tz";
|
||||
$GMT_day[$g] = "$pday";
|
||||
$GMT_hour[$g] = ($phour + $pmin);
|
||||
$p = ($p - 0.25);
|
||||
if ($DBX) {print "|$GMT_gmt[$g]-$GMT_day[$g]-$GMT_hour[$g]|";}
|
||||
$g++;
|
||||
}
|
||||
if ($DBX) {print "\n";}
|
||||
|
||||
$stmtA = "SELECT * FROM vicidial_call_times where call_time_id='$local_call_time[$i]';";
|
||||
if ($DBX) {print " |$stmtA|\n";}
|
||||
$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;
|
||||
$Gct_default_start = "$aryA[3]";
|
||||
$Gct_default_stop = "$aryA[4]";
|
||||
$Gct_sunday_start = "$aryA[5]";
|
||||
$Gct_sunday_stop = "$aryA[6]";
|
||||
$Gct_monday_start = "$aryA[7]";
|
||||
$Gct_monday_stop = "$aryA[8]";
|
||||
$Gct_tuesday_start = "$aryA[9]";
|
||||
$Gct_tuesday_stop = "$aryA[10]";
|
||||
$Gct_wednesday_start = "$aryA[11]";
|
||||
$Gct_wednesday_stop = "$aryA[12]";
|
||||
$Gct_thursday_start = "$aryA[13]";
|
||||
$Gct_thursday_stop = "$aryA[14]";
|
||||
$Gct_friday_start = "$aryA[15]";
|
||||
$Gct_friday_stop = "$aryA[16]";
|
||||
$Gct_saturday_start = "$aryA[17]";
|
||||
$Gct_saturday_stop = "$aryA[18]";
|
||||
$Gct_state_call_times = "$aryA[19]";
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
|
||||
$ct_states = '';
|
||||
$ct_state_gmt_SQL = '';
|
||||
$del_state_gmt_SQL = '';
|
||||
$ct_srs=0;
|
||||
$b=0;
|
||||
if (length($Gct_state_call_times)>2)
|
||||
{
|
||||
@state_rules = split(/\|/,$Gct_state_call_times);
|
||||
$ct_srs = ($#state_rules - 2);
|
||||
}
|
||||
while($ct_srs >= $b)
|
||||
{
|
||||
if (length($state_rules[$b])>1)
|
||||
{
|
||||
$stmtA = "SELECT * from vicidial_state_call_times where state_call_time_id='$state_rules[$b]';";
|
||||
if ($DBX) {print " |$stmtA|\n";}
|
||||
$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;
|
||||
$Gstate_call_time_id = "$aryA[0]";
|
||||
$Gstate_call_time_state = "$aryA[1]";
|
||||
$Gsct_default_start = "$aryA[4]";
|
||||
$Gsct_default_stop = "$aryA[5]";
|
||||
$Gsct_sunday_start = "$aryA[6]";
|
||||
$Gsct_sunday_stop = "$aryA[7]";
|
||||
$Gsct_monday_start = "$aryA[8]";
|
||||
$Gsct_monday_stop = "$aryA[9]";
|
||||
$Gsct_tuesday_start = "$aryA[10]";
|
||||
$Gsct_tuesday_stop = "$aryA[11]";
|
||||
$Gsct_wednesday_start = "$aryA[12]";
|
||||
$Gsct_wednesday_stop = "$aryA[13]";
|
||||
$Gsct_thursday_start = "$aryA[14]";
|
||||
$Gsct_thursday_stop = "$aryA[15]";
|
||||
$Gsct_friday_start = "$aryA[16]";
|
||||
$Gsct_friday_stop = "$aryA[17]";
|
||||
$Gsct_saturday_start = "$aryA[18]";
|
||||
$Gsct_saturday_stop = "$aryA[19]";
|
||||
$ct_states .="'$Gstate_call_time_state',";
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
|
||||
$r=0;
|
||||
$state_gmt='';
|
||||
$del_state_gmt='';
|
||||
while($r < $g)
|
||||
{
|
||||
if ($GMT_day[$r]==0) #### Sunday local time
|
||||
{
|
||||
if (($Gsct_sunday_start==0) and ($Gsct_sunday_stop==0))
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gsct_default_start) and ($GMT_hour[$r]<$Gsct_default_stop) )
|
||||
{$state_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_state_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
else
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gsct_sunday_start) and ($GMT_hour[$r]<$Gsct_sunday_stop) )
|
||||
{$state_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_state_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
}
|
||||
if ($GMT_day[$r]==1) #### Monday local time
|
||||
{
|
||||
if (($Gsct_monday_start==0) and ($Gsct_monday_stop==0))
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gsct_default_start) and ($GMT_hour[$r]<$Gsct_default_stop) )
|
||||
{$state_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_state_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
else
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gsct_monday_start) and ($GMT_hour[$r]<$Gsct_monday_stop) )
|
||||
{$state_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_state_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
}
|
||||
if ($GMT_day[$r]==2) #### Tuesday local time
|
||||
{
|
||||
if (($Gsct_tuesday_start==0) and ($Gsct_tuesday_stop==0))
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gsct_default_start) and ($GMT_hour[$r]<$Gsct_default_stop) )
|
||||
{$state_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_state_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
else
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gsct_tuesday_start) and ($GMT_hour[$r]<$Gsct_tuesday_stop) )
|
||||
{$state_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_state_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
}
|
||||
if ($GMT_day[$r]==3) #### Wednesday local time
|
||||
{
|
||||
if (($Gsct_wednesday_start==0) and ($Gsct_wednesday_stop==0))
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gsct_default_start) and ($GMT_hour[$r]<$Gsct_default_stop) )
|
||||
{$state_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_state_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
else
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gsct_wednesday_start) and ($GMT_hour[$r]<$Gsct_wednesday_stop) )
|
||||
{$state_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_state_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
}
|
||||
if ($GMT_day[$r]==4) #### Thursday local time
|
||||
{
|
||||
if (($Gsct_thursday_start==0) and ($Gsct_thursday_stop==0))
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gsct_default_start) and ($GMT_hour[$r]<$Gsct_default_stop) )
|
||||
{$state_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_state_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
else
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gsct_thursday_start) and ($GMT_hour[$r]<$Gsct_thursday_stop) )
|
||||
{$state_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_state_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
}
|
||||
if ($GMT_day[$r]==5) #### Friday local time
|
||||
{
|
||||
if (($Gsct_friday_start==0) and ($Gsct_friday_stop==0))
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gsct_default_start) and ($GMT_hour[$r]<$Gsct_default_stop) )
|
||||
{$state_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_state_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
else
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gsct_friday_start) and ($GMT_hour[$r]<$Gsct_friday_stop) )
|
||||
{$state_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_state_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
}
|
||||
if ($GMT_day[$r]==6) #### Saturday local time
|
||||
{
|
||||
if (($Gsct_saturday_start==0) and ($Gsct_saturday_stop==0))
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gsct_default_start) and ($GMT_hour[$r]<$Gsct_default_stop) )
|
||||
{$state_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_state_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
else
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gsct_saturday_start) and ($GMT_hour[$r]<$Gsct_saturday_stop) )
|
||||
{$state_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_state_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
}
|
||||
$r++;
|
||||
}
|
||||
$state_gmt = "$state_gmt'99'";
|
||||
$del_state_gmt = "$del_state_gmt'99'";
|
||||
$ct_state_gmt_SQL .= "or (state='$Gstate_call_time_state' and gmt_offset_now IN($state_gmt)) ";
|
||||
$del_state_gmt_SQL .= "or (state='$Gstate_call_time_state' and gmt_offset_now IN($del_state_gmt)) ";
|
||||
}
|
||||
|
||||
$b++;
|
||||
}
|
||||
if (length($ct_states)>2)
|
||||
{
|
||||
$ct_states =~ s/,$//gi;
|
||||
$ct_statesSQL = "and state NOT IN($ct_states)";
|
||||
}
|
||||
else
|
||||
{
|
||||
$ct_statesSQL = "";
|
||||
}
|
||||
|
||||
$r=0;
|
||||
$default_gmt='';
|
||||
$del_default_gmt='';
|
||||
while($r < $g)
|
||||
{
|
||||
if ($GMT_day[$r]==0) #### Sunday local time
|
||||
{
|
||||
if (($Gct_sunday_start==0) and ($Gct_sunday_stop==0))
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gct_default_start) and ($GMT_hour[$r]<$Gct_default_stop) )
|
||||
{$default_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_default_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
else
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gct_sunday_start) and ($GMT_hour[$r]<$Gct_sunday_stop) )
|
||||
{$default_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_default_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
}
|
||||
if ($GMT_day[$r]==1) #### Monday local time
|
||||
{
|
||||
if (($Gct_monday_start==0) and ($Gct_monday_stop==0))
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gct_default_start) and ($GMT_hour[$r]<$Gct_default_stop) )
|
||||
{$default_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_default_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
else
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gct_monday_start) and ($GMT_hour[$r]<$Gct_monday_stop) )
|
||||
{$default_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_default_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
}
|
||||
if ($GMT_day[$r]==2) #### Tuesday local time
|
||||
{
|
||||
if (($Gct_tuesday_start==0) and ($Gct_tuesday_stop==0))
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gct_default_start) and ($GMT_hour[$r]<$Gct_default_stop) )
|
||||
{$default_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_default_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
else
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gct_tuesday_start) and ($GMT_hour[$r]<$Gct_tuesday_stop) )
|
||||
{$default_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_default_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
}
|
||||
if ($GMT_day[$r]==3) #### Wednesday local time
|
||||
{
|
||||
if (($Gct_wednesday_start==0) and ($Gct_wednesday_stop==0))
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gct_default_start) and ($GMT_hour[$r]<$Gct_default_stop) )
|
||||
{$default_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_default_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
else
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gct_wednesday_start) and ($GMT_hour[$r]<$Gct_wednesday_stop) )
|
||||
{$default_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_default_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
}
|
||||
if ($GMT_day[$r]==4) #### Thursday local time
|
||||
{
|
||||
if (($Gct_thursday_start==0) and ($Gct_thursday_stop==0))
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gct_default_start) and ($GMT_hour[$r]<$Gct_default_stop) )
|
||||
{$default_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_default_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
else
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gct_thursday_start) and ($GMT_hour[$r]<$Gct_thursday_stop) )
|
||||
{$default_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_default_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
}
|
||||
if ($GMT_day[$r]==5) #### Friday local time
|
||||
{
|
||||
if (($Gct_friday_start==0) and ($Gct_friday_stop==0))
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gct_default_start) and ($GMT_hour[$r]<$Gct_default_stop) )
|
||||
{$default_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_default_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
else
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gct_friday_start) and ($GMT_hour[$r]<$Gct_friday_stop) )
|
||||
{$default_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_default_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
}
|
||||
if ($GMT_day[$r]==6) #### Saturday local time
|
||||
{
|
||||
if (($Gct_saturday_start==0) and ($Gct_saturday_stop==0))
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gct_default_start) and ($GMT_hour[$r]<$Gct_default_stop) )
|
||||
{$default_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_default_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
else
|
||||
{
|
||||
if ( ($GMT_hour[$r]>=$Gct_saturday_start) and ($GMT_hour[$r]<$Gct_saturday_stop) )
|
||||
{$default_gmt.="'$GMT_gmt[$r]',";}
|
||||
else
|
||||
{$del_default_gmt.="'$GMT_gmt[$r]',";}
|
||||
}
|
||||
}
|
||||
$r++;
|
||||
}
|
||||
|
||||
$default_gmt = "$default_gmt'99'";
|
||||
$del_default_gmt = "$del_default_gmt'99'";
|
||||
$all_gmtSQL = "(gmt_offset_now IN($default_gmt) $ct_statesSQL) $ct_state_gmt_SQL";
|
||||
$del_gmtSQL = "(gmt_offset_now IN($del_default_gmt) $ct_statesSQL) $del_state_gmt_SQL";
|
||||
|
||||
##### END calculate what gmt_offset_now values are within the allowed local_call_time setting ###
|
||||
|
||||
# $auto_dial_level[$rec_count] = "$aryA[14]";
|
||||
# $dial_method[$rec_count] = $aryA[46];
|
||||
# $available_only_ratio_tally[$rec_count] = $aryA[47];
|
||||
# $adaptive_dropped_percentage[$rec_count] = $aryA[48];
|
||||
# $adaptive_maximum_level[$rec_count] = $aryA[49];
|
||||
|
||||
$stmtA = "UPDATE vicidial_campaign_stats SET calls_today='$VCScalls_today',drops_today='$VCSdrops_today',drops_today_pct='$VCSdrops_today_pct',calls_hour='$VCScalls_hour',drops_hour='$VCSdrops_hour',drops_hour_pct='$VCSdrops_hour_pct',calls_halfhour='$VCScalls_halfhour',drops_halfhour='$VCSdrops_halfhour',drops_halfhour_pct='$VCSdrops_halfhour_pct',calls_fivemin='$VCScalls_five',drops_fivemin='$VCSdrops_five',drops_fivemin_pct='$VCSdrops_five_pct',calls_onemin='$VCScalls_one',drops_onemin='$VCSdrops_one',drops_onemin_pct='$VCSdrops_one_pct' where campaign_id='$campaign_id[$i]';";
|
||||
$affected_rows = $dbhA->do($stmtA);
|
||||
$adaptive_string = "|AGENTS: $VCSagents|ACTIVE: $VCSagents_active|CALC: $VCSagents_calc|INCALL: $VCSINCALL|READY: $VCSREADY|LEVEL: $auto_dial_level[$i]|$dial_method[$i]|$available_only_ratio_tally[$i]|$adaptive_dropped_percentage[$i]|$adaptive_maximum_level[$i]| |$VCScalls_today|$VCSdrops_today|$VCSdrops_today_pct| |$VCScalls_hour|$VCSdrops_hour|$VCSdrops_hour_pct| |$VCScalls_halfhour|$VCSdrops_halfhour|$VCSdrops_halfhour_pct| |$VCScalls_five|$VCSdrops_five|$VCSdrops_five_pct| |$VCScalls_one|$VCSdrops_one|$VCSdrops_one_pct| $campaign_id[$i]|";
|
||||
if ($DB) {print "campaign stats updated: $campaign_id[$i] $adaptive_string\n";}
|
||||
|
||||
&adaptive_logger;
|
||||
|
||||
}
|
||||
$i++;
|
||||
}
|
||||
|
||||
|
||||
$dbhA->disconnect();
|
||||
|
||||
if($DB)
|
||||
{
|
||||
### calculate time to run script ###
|
||||
$secY = time();
|
||||
$secZ = ($secY - $secT);
|
||||
|
||||
if (!$q) {print "DONE. Script execution time in seconds: $secZ\n";}
|
||||
}
|
||||
|
||||
exit;
|
||||
|
||||
|
||||
|
||||
sub event_logger
|
||||
{
|
||||
if ($SYSLOG)
|
||||
{
|
||||
### open the log file for writing ###
|
||||
open(Lout, ">>$VDHLOGfile")
|
||||
|| die "Can't open $VDHLOGfile: $!\n";
|
||||
print Lout "$now_date|$event_string|\n";
|
||||
close(Lout);
|
||||
}
|
||||
$event_string='';
|
||||
}
|
||||
|
||||
|
||||
sub adaptive_logger
|
||||
{
|
||||
if ($SYSLOG)
|
||||
{
|
||||
$VDHCLOGfile = "$PATHlogs/VDadaptive-$campaign_id[$i].$file_date";
|
||||
|
||||
### open the log file for writing ###
|
||||
open(Aout, ">>$VDHCLOGfile")
|
||||
|| die "Can't open $VDHCLOGfile: $!\n";
|
||||
print Aout "$now_date$adaptive_string\n";
|
||||
close(Aout);
|
||||
}
|
||||
$adaptive_string='';
|
||||
}
|
||||
+8
-241
@@ -53,6 +53,7 @@ $vicidial_hopper='vicidial_hopper';
|
||||
$insert_auto_CB_to_hopper = 1; # set to 1 to automatically insert ANYONE callbacks into the hopper
|
||||
|
||||
|
||||
$secT = time();
|
||||
$secX = time();
|
||||
($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) = localtime(time);
|
||||
$year = ($year + 1900);
|
||||
@@ -390,9 +391,15 @@ while ($sthArows > $rec_count)
|
||||
{$hopper_level[$rec_count] = "$aryA[13]";}
|
||||
else
|
||||
{$hopper_level[$rec_count] = "$CLIlevel";}
|
||||
$auto_dial_level[$rec_count] = "$aryA[14]";
|
||||
$local_call_time[$rec_count] = "$aryA[16]";
|
||||
$lead_filter_id[$rec_count] = "$aryA[35]";
|
||||
$use_internal_dnc[$rec_count] = "$aryA[43]";
|
||||
$dial_method[$rec_count] = $aryA[46];
|
||||
$available_only_ratio_tally[$rec_count] = $aryA[47];
|
||||
$adaptive_dropped_percentage[$rec_count] = $aryA[48];
|
||||
$adaptive_maximum_level[$rec_count] = $aryA[49];
|
||||
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
@@ -406,21 +413,6 @@ foreach(@campaign_id)
|
||||
### BEGIN - GATHER STATS FOR THE vicidial_campaign_stats TABLE ###
|
||||
$vicidial_log = 'vicidial_log';
|
||||
$VCSdialable_leads=0;
|
||||
$VCScalls_today=0;
|
||||
$VCSdrops_today=0;
|
||||
$VCSdrops_today_pct=0;
|
||||
$VCScalls_hour=0;
|
||||
$VCSdrops_hour=0;
|
||||
$VCSdrops_hour_pct=0;
|
||||
$VCScalls_halfhour=0;
|
||||
$VCSdrops_halfhour=0;
|
||||
$VCSdrops_halfhour_pct=0;
|
||||
$VCScalls_five=0;
|
||||
$VCSdrops_five=0;
|
||||
$VCSdrops_five_pct=0;
|
||||
$VCScalls_one=0;
|
||||
$VCSdrops_one=0;
|
||||
$VCSdrops_one_pct=0;
|
||||
|
||||
$stmtA = "SELECT dialable_leads from vicidial_campaign_stats where campaign_id='$campaign_id[$i]';";
|
||||
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
|
||||
@@ -434,231 +426,6 @@ foreach(@campaign_id)
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
|
||||
# TODAY CALL AND DROP STATS
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_date';";
|
||||
$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;
|
||||
$VCScalls_today = "$aryA[0]";
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
if ($VCScalls_today > 0)
|
||||
{
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_date' and status IN('DROP','XDROP');";
|
||||
$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;
|
||||
$VCSdrops_today = "$aryA[0]";
|
||||
if ($VCSdrops_today > 0)
|
||||
{
|
||||
$VCSdrops_today_pct = ( ($VCSdrops_today / $VCScalls_today) * 100 );
|
||||
$VCSdrops_today_pct = sprintf("%.2f", $VCSdrops_today_pct);
|
||||
}
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
}
|
||||
|
||||
# LAST HOUR CALL AND DROP STATS
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_hour';";
|
||||
$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;
|
||||
$VCScalls_hour = "$aryA[0]";
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
if ($VCScalls_hour > 0)
|
||||
{
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_hour' and status IN('DROP','XDROP');";
|
||||
$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;
|
||||
$VCSdrops_hour = "$aryA[0]";
|
||||
if ($VCSdrops_hour > 0)
|
||||
{
|
||||
$VCSdrops_hour_pct = ( ($VCSdrops_hour / $VCScalls_hour) * 100 );
|
||||
$VCSdrops_hour_pct = sprintf("%.2f", $VCSdrops_hour_pct);
|
||||
}
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
}
|
||||
|
||||
# LAST HALFHOUR CALL AND DROP STATS
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_halfhour';";
|
||||
$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;
|
||||
$VCScalls_halfhour = "$aryA[0]";
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
if ($VCScalls_halfhour > 0)
|
||||
{
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_halfhour' and status IN('DROP','XDROP');";
|
||||
$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;
|
||||
$VCSdrops_halfhour = "$aryA[0]";
|
||||
if ($VCSdrops_halfhour > 0)
|
||||
{
|
||||
$VCSdrops_halfhour_pct = ( ($VCSdrops_halfhour / $VCScalls_halfhour) * 100 );
|
||||
$VCSdrops_halfhour_pct = sprintf("%.2f", $VCSdrops_halfhour_pct);
|
||||
}
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
}
|
||||
|
||||
# LAST FIVE MINUTE CALL AND DROP STATS
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_five';";
|
||||
$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;
|
||||
$VCScalls_five = "$aryA[0]";
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
if ($VCScalls_five > 0)
|
||||
{
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_five' and status IN('DROP','XDROP');";
|
||||
$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;
|
||||
$VCSdrops_five = "$aryA[0]";
|
||||
if ($VCSdrops_five > 0)
|
||||
{
|
||||
$VCSdrops_five_pct = ( ($VCSdrops_five / $VCScalls_five) * 100 );
|
||||
$VCSdrops_five_pct = sprintf("%.2f", $VCSdrops_five_pct);
|
||||
}
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
}
|
||||
|
||||
# LAST ONE MINUTE CALL AND DROP STATS
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_one';";
|
||||
$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;
|
||||
$VCScalls_one = "$aryA[0]";
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
if ($VCScalls_one > 0)
|
||||
{
|
||||
$stmtA = "SELECT count(*) from $vicidial_log where campaign_id='$campaign_id[$i]' and call_date > '$VDL_one' and status IN('DROP','XDROP');";
|
||||
$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;
|
||||
$VCSdrops_one = "$aryA[0]";
|
||||
if ($VCSdrops_one > 0)
|
||||
{
|
||||
$VCSdrops_one_pct = ( ($VCSdrops_one / $VCScalls_one) * 100 );
|
||||
$VCSdrops_one_pct = sprintf("%.2f", $VCSdrops_one_pct);
|
||||
}
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
}
|
||||
|
||||
$VCSINCALL=0;
|
||||
$VCSREADY=0;
|
||||
$VCSCLOSER=0;
|
||||
$VCSPAUSED=0;
|
||||
$VCSagents=0;
|
||||
$VCSagents_calc=0;
|
||||
$VCSagents_active=0;
|
||||
|
||||
# COUNTS OF STATUSES OF AGENTS IN THIS CAMPAIGN
|
||||
$stmtA = "SELECT count(*),status from vicidial_live_agents where campaign_id='$campaign_id[$i]' and last_update_time > '$VDL_one' group by status;";
|
||||
$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;
|
||||
$VCSagent_count = "$aryA[0]";
|
||||
$VCSagent_status = "$aryA[1]";
|
||||
$rec_count++;
|
||||
if ($VCSagent_status =~ /INCALL|QUEUE/) {$VCSINCALL = ($VCSINCALL + $VCSagent_count);}
|
||||
if ($VCSagent_status =~ /READY/) {$VCSREADY = ($VCSREADY + $VCSagent_count);}
|
||||
if ($VCSagent_status =~ /CLOSER/) {$VCSCLOSER = ($VCSCLOSER + $VCSagent_count);}
|
||||
if ($VCSagent_status =~ /PAUSED/) {$VCSPAUSED = ($VCSPAUSED + $VCSagent_count);}
|
||||
$VCSagents = ($VCSagents + $VCSagent_count);
|
||||
}
|
||||
$sthA->finish();
|
||||
|
||||
if ($available_only_ratio_tally =~ /Y/)
|
||||
{$VCSagents_calc = $VCSREADY;}
|
||||
else
|
||||
{$VCSagents_calc = ($VCSINCALL + $VCSREADY);}
|
||||
$VCSagents_active = ($VCSINCALL + $VCSREADY + $VCSCLOSER);
|
||||
|
||||
$stmtA = "SELECT auto_dial_level from vicidial_campaigns where campaign_id='$campaign_id[$i]';";
|
||||
$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;
|
||||
$VCSdial_level = "$aryA[0]";
|
||||
$rec_count++;
|
||||
}
|
||||
$sthA->finish();
|
||||
|
||||
$stmtA = "UPDATE vicidial_campaign_stats SET calls_today='$VCScalls_today',drops_today='$VCSdrops_today',drops_today_pct='$VCSdrops_today_pct',calls_hour='$VCScalls_hour',drops_hour='$VCSdrops_hour',drops_hour_pct='$VCSdrops_hour_pct',calls_halfhour='$VCScalls_halfhour',drops_halfhour='$VCSdrops_halfhour',drops_halfhour_pct='$VCSdrops_halfhour_pct',calls_fivemin='$VCScalls_five',drops_fivemin='$VCSdrops_five',drops_fivemin_pct='$VCSdrops_five_pct',calls_onemin='$VCScalls_one',drops_onemin='$VCSdrops_one',drops_onemin_pct='$VCSdrops_one_pct' where campaign_id='$campaign_id[$i]';";
|
||||
$affected_rows = $dbhA->do($stmtA);
|
||||
$adaptive_string = "|AGENTS: $VCSagents|ACTIVE: $VCSagents_active|CALC: $VCSagents_calc|INCALL: $VCSINCALL|READY: $VCSREADY|LEVEL: $VCSdial_level| |$VCScalls_today|$VCSdrops_today|$VCSdrops_today_pct| |$VCScalls_hour|$VCSdrops_hour|$VCSdrops_hour_pct| |$VCScalls_halfhour|$VCSdrops_halfhour|$VCSdrops_halfhour_pct| |$VCScalls_five|$VCSdrops_five|$VCSdrops_five_pct| |$VCScalls_one|$VCSdrops_one|$VCSdrops_one_pct| $campaign_id[$i]|";
|
||||
if ($DB) {print "campaign stats updated: $campaign_id[$i] $adaptive_string\n";}
|
||||
|
||||
&adaptive_logger;
|
||||
|
||||
### END - GATHER STATS FOR THE vicidial_campaign_stats TABLE ###
|
||||
|
||||
##### BEGIN calculate what gmt_offset_now values are within the allowed local_call_time setting ###
|
||||
@@ -1458,7 +1225,7 @@ if($DB)
|
||||
{
|
||||
### calculate time to run script ###
|
||||
$secY = time();
|
||||
$secZ = ($secY - $secX);
|
||||
$secZ = ($secY - $secT);
|
||||
|
||||
if (!$q) {print "DONE. Script execution time in seconds: $secZ\n";}
|
||||
}
|
||||
|
||||
@@ -9,6 +9,7 @@ Omit Phone Code -<\/B> This field allows you to leave out the phone_code field w
|
||||
Campaign Recording -<\/B> This menu allows you to choose what level of recording is allowed on this campaign. NEVER will disable recording on the client. ONDEMAND is the default and allows the agent to start and stop recording as needed. ALLCALLS will start recording on the client whenever a call is sent to an agent. ALLFORCE will start recording on the client whenever a call is sent to an agent giving the agent no option to stop recording. For ALLCALLS and ALLFORCE there is an option to use the Recording Delay to cut down on very short recordings and recude system load
|
||||
Dial Method -<\/B> This field is the way to define how dialing is to take place. If MANUAL then the auto_dial_level will be locked at 0 unless Dial Method is changed. If RATIO then the normal dialing a number of lines for Active agents. ADAPT_HARD_LIMIT will dial predictively up to the dropped percentage and then not allow aggressive dialing once the drop limit is reached until the percentage goes down again. ADAPT_TAPERED allows for running over the dropped percentage in the first half of the shift(as defined by call_time selected for campaign) and gets more strict as the shift goes on. ADAPT_AVERAGE tries to maintain an average or the dropped percentage not imposing hard limits as aggressively as the other two methods
|
||||
Available Only Tally -<\/B> This field if set to Y will leave out INCALL and QUEUE status agents when calculating the number of calls to dial when not in MANUAL dial mode. Default is N
|
||||
Drop Percentage Limit -<\/B> This field is where you set the limit of the percentage of dropped calls you would like while using an adaptive-predictive dial method, not MANUAL or RATIO
|
||||
Maximum Adapt Dial Level -<\/B> This field is where you set the limit of the limit to the numbr of lines you would like dialed per agent while using an adaptive-predictive dial method, not MANUAL or RATIO. This number can be higher than the Auto Dial Level if your hardware will support it. Value must be a positive number greater than one and can have decimal places Default 3.0
|
||||
|
||||
System Performance
|
||||
@@ -19,6 +20,7 @@ Omit Phone Code
|
||||
Campaign Recording
|
||||
Dial Method
|
||||
Available Only Tally
|
||||
Drop Percentage Limit
|
||||
Maximum Adapt Dial Level
|
||||
|
||||
############################################################ CLIENT
|
||||
|
||||
Reference in New Issue
Block a user