mattf
79662d7066
calculations Added new export script, VICI_CSV_dump_call_log.pl git-svn-id: svn://192.168.202.10@2535 3d104415-ff17-0410-8863-d5cf3c621b8a
222 lines
7.4 KiB
Perl
222 lines
7.4 KiB
Perl
#!/usr/bin/perl
|
|
|
|
# VICI_CSV_dump_call_log.pl
|
|
|
|
# DESCRIPTION:
|
|
# adjusts the auto_dial_level for vicidial adaptive-predictive campaigns.
|
|
# gather call stats for campaigns and in-groups
|
|
#
|
|
# Copyright (C) 2016 Joe Johnson, Matt Florell <vicidial@gmail.com> LICENSE: AGPLv2
|
|
#
|
|
# CHANGELOG
|
|
# 60823-1302 - First build
|
|
#
|
|
|
|
$secX = time();
|
|
$time = $secX;
|
|
($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";}
|
|
$timestamp = "$year-$mon-$mday $hour:$min:$sec";
|
|
$start_date = "$year-$mon-$mday";
|
|
$filedate="$year$mon$mday";
|
|
$dayofweek=$wday;
|
|
$datestamp = "$year/$mon/$mday $hour:$min";
|
|
|
|
|
|
# default path to astguiclient configuration file:
|
|
if (length($PATHconf) < 5)
|
|
{$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;}
|
|
if ( ($line =~ /^VARREPORT_host/) && ($CLIREPORT_host < 1) )
|
|
{$VARREPORT_host = $line; $VARREPORT_host =~ s/.*=//gi;}
|
|
if ( ($line =~ /^VARREPORT_user/) && ($CLIREPORT_user < 1) )
|
|
{$VARREPORT_user = $line; $VARREPORT_user =~ s/.*=//gi;}
|
|
if ( ($line =~ /^VARREPORT_pass/) && ($CLIREPORT_pass < 1) )
|
|
{$VARREPORT_pass = $line; $VARREPORT_pass =~ s/.*=//gi;}
|
|
if ( ($line =~ /^VARREPORT_port/) && ($CLIREPORT_port < 1) )
|
|
{$VARREPORT_port = $line; $VARREPORT_port =~ s/.*=//gi;}
|
|
if ( ($line =~ /^VARREPORT_dir/) && ($CLIREPORT_dir < 1) )
|
|
{$VARREPORT_dir = $line; $VARREPORT_dir =~ s/.*=//gi;}
|
|
$i++;
|
|
}
|
|
|
|
# DEFAULT VALUES
|
|
$file_type="csv";
|
|
$delimiter=",";
|
|
$output_file="Vicidial_CSV_dump";
|
|
$subdir="/";
|
|
|
|
for ($q=0; $q<scalar(@ARGV); $q++) {
|
|
if ($ARGV[$q]=~/--timestamp/) {
|
|
$ARGV[$q]=~s/\-\-timestamp=//;
|
|
if ($ARGV[$q]=~/day/i) {
|
|
$file_suffix="_$filedate";
|
|
} elsif ($ARGV[$q]=~/week|wk/i) {
|
|
$file_suffix="_$dayofweek";
|
|
} else {
|
|
$file_suffix="";
|
|
}
|
|
}
|
|
if ($ARGV[$q]=~/--file_type/) {
|
|
$ARGV[$q]=~s/\-\-file_type=//;
|
|
$file_type=$ARGV[$q];
|
|
$file_type=~s/[^a-z]//gi;
|
|
}
|
|
if ($ARGV[$q]=~/--delimiter/) {
|
|
$ARGV[$q]=~s/\-\-delimiter=//;
|
|
$delimiter=$ARGV[$q];
|
|
}
|
|
if ($ARGV[$q]=~/--output_file/) {
|
|
$ARGV[$q]=~s/\-\-output_file=//;
|
|
$output_file=$ARGV[$q];
|
|
}
|
|
if ($ARGV[$q]=~/--subdir/) {
|
|
$ARGV[$q]=~s/\-\-subdir=//;
|
|
$subdir=$ARGV[$q];
|
|
if ($subdir!~/^\//) {
|
|
$subdir="/$subdir";
|
|
}
|
|
}
|
|
|
|
if ($ARGV[$q]=~/--debug/) {
|
|
$DB=1;
|
|
}
|
|
if ($ARGV[$q]=~/--debugX/) {
|
|
$DBX=1;
|
|
}
|
|
|
|
if ($ARGV[$q]=~/--help/) {
|
|
print "Run time options:\n";
|
|
print " [--timestamp] = set to 'day' to put today's date as part of the outfile name, or 'week' or 'wk' for the numeric day of the week\n";
|
|
print " [--output_file] = customize output file name - do not put a file type as part of the name. Default is 'Vicidial_CSV_dump'\n";
|
|
print " [--file_type] = determines file type, which must be either txt or csv\n";
|
|
print " [--delimiter] = If file_type is txt, this character will be the delimiter (remember to include backslashes if needed). Default is ',' for txt files and quote-comma for csv files\n";
|
|
print " [--subdir] = specify sub-directory in the web directory to write file to. Default is web path: $PATHweb/\n";
|
|
print " [--debug or --debugX] = Debug options. debug will show output parameters and statuses queried for, debugX will show the SQL queries as well\n";
|
|
print "\n";
|
|
exit;
|
|
}
|
|
}
|
|
$output_file.=$file_suffix.".".$file_type;
|
|
$output_dir="$PATHweb$subdir";
|
|
|
|
|
|
# Check that file is txt or csv. If csv set delimiter to quote-comma.
|
|
if ($file_type!~/txt|csv/i) {
|
|
die "\nInvalid output file type\n";
|
|
} elsif ($file_type=~/csv/i) {
|
|
$delimiter="\",\"";
|
|
}
|
|
|
|
if ($DB || $DBX) {
|
|
print "\nOutput parameters\n";
|
|
print "-------------------\n";
|
|
print "Output filename : $output_file\n";
|
|
print "Output directory : $output_dir\n";
|
|
print "Timestamp : $file_suffix\n";
|
|
print "File type : $file_type\n";
|
|
print "Delimiter : $delimiter\n\n";
|
|
sleep(3);
|
|
}
|
|
|
|
# Check if directory exists, then open file to write to if it does.
|
|
if (-d $output_dir) {
|
|
open(STORAGE, "> $output_dir/$output_file");
|
|
} else {
|
|
die "\nOutput directory $PATHweb$subdir does not exist or is not a directory\n";
|
|
}
|
|
|
|
# Customized Variables
|
|
$server_ip = $VARserver_ip; # Asterisk server IP
|
|
|
|
$start_time = time();
|
|
$servers=0;
|
|
|
|
use DBI;
|
|
|
|
$dbh = DBI->connect("DBI:mysql:$VARDB_database:$VARDB_server:$VARDB_port", "$VARDB_user", "$VARDB_pass")
|
|
or die "Couldn't connect to database: " . DBI->errstr;
|
|
|
|
# $user_stmt="SELECT distinct '' as full_name, user from ".$agent_log_table." where event_time >= '$start_date 00:00:00' and event_time <= '$start_date 23:59:59' order by user asc";
|
|
|
|
$status_stmt="select distinct status from vicidial_campaign_statuses where customer_contact='Y' UNION select distinct status from vicidial_statuses where customer_contact='Y' order by status";
|
|
if ($DBX) {print "$status_stmt\n";}
|
|
$status_rslt=$dbh->prepare($status_stmt);
|
|
$status_rslt->execute();
|
|
@status_array=();
|
|
while (@row=$status_rslt->fetchrow_array) {
|
|
$status=$row[0];
|
|
if (!grep(/^$status$/, @status_array)) {push(@status_array, "$status");}
|
|
}
|
|
|
|
$status_str=join("','", @status_array);
|
|
|
|
if ($DB || $DBX) {print "Status list: '$status_str'\n";}
|
|
|
|
$agent_log_stmt="select event_time, vu.full_name, vu.user, talk_sec, v.phone_number from vicidial_list v, vicidial_agent_log val, vicidial_users vu where event_time >= '$start_date 00:00:00' and event_time <= '$start_date 23:59:59' and val.status in ('".$status_str."') and val.user=vu.user and val.lead_id=v.lead_id order by event_time asc";
|
|
if ($DBX) {print "$agent_log_stmt\n";}
|
|
$agent_log_rslt=$dbh->prepare($agent_log_stmt);
|
|
$agent_log_rslt->execute();
|
|
while (@row=$agent_log_rslt->fetchrow_array) {
|
|
for ($i=0; $i<scalar(@row); $i++) {
|
|
if ($delimiter eq "\",\"") {
|
|
$row[$i]=~s/\"/\\\"/gi;
|
|
} else {
|
|
$row[$i]=~s/$delimiter/\\$delimiter/gi;
|
|
}
|
|
}
|
|
if ($delimiter eq "\\t") {
|
|
$output_str=join("\t", @row);
|
|
} else {
|
|
$output_str=join("$delimiter", @row);
|
|
}
|
|
if ($delimiter eq "\",\"") {
|
|
$output_str="\"$output_str\"";
|
|
}
|
|
$output_str.="\n";
|
|
print STORAGE $output_str;
|
|
}
|
|
close(STORAGE);
|
|
|
|
$end_time = time();
|
|
|
|
print "Elapsed time: ".($end_time-$start_time)." sec\n";
|