1243 lines
44 KiB
Perl
1243 lines
44 KiB
Perl
#!/usr/bin/perl
|
|
#
|
|
# AST_VDsales_export.pl version: 2.2.0
|
|
#
|
|
# This script is designed to gather sales for a VICIDIAL Outbound-only campaign and
|
|
# post them to a directory
|
|
#
|
|
# /usr/share/astguiclient/AST_VDsales_export.pl --campaign=GOODB-GROUP1-GROUP3-GROUP4-SPECIALS-DNC_BEDS --output-format=fixed-as400 --sale-statuses=SALE --debug --filename=BEDSsaleMMDD.txt --date=yesterday --email-list=test@gmail.com --email-sender=test@test.com
|
|
#
|
|
# Copyright (C) 2009 Matt Florell <vicidial@gmail.com> LICENSE: AGPLv2
|
|
#
|
|
# CHANGES
|
|
# 61219-1118 - First version
|
|
# 70503-2137 - Added upsell
|
|
# 70611-1154 - Added CLI options
|
|
# 70709-1411 - Added FTP transfer option
|
|
# 71005-0054 - Altered script to use astguiclient.conf for settings
|
|
# 90105-1155 - Added AS400 export formats and changed around date override
|
|
# 90106-2309 - Added email sending
|
|
# 90620-0900 - Formatting fixes
|
|
# 90627-0757 - Added time addition when transfer recordings is enabled
|
|
# 90710-0514 - Fixes for data output formatting changes
|
|
# 90721-1314 - Added rank and owner as vicidial_list fields
|
|
# 90731-0555 - Added call time scheme restriction
|
|
# 90807-1632 - Fixed call time bug and call length bug
|
|
# 90825-1249 - Added without-camp and without-in options
|
|
# 90902-0437 - Added outbound-calltime-ignore and ftp-norun options
|
|
# 90909-2322 - Added totals-only option
|
|
#
|
|
|
|
$txt = '.txt';
|
|
$US = '_';
|
|
$MT[0] = '';
|
|
$Q=0;
|
|
$DB=0;
|
|
$uniqueidLIST='|';
|
|
|
|
# Default FTP account variables
|
|
$VARREPORT_host = '10.0.0.4';
|
|
$VARREPORT_user = 'cron';
|
|
$VARREPORT_pass = 'test';
|
|
$VARREPORT_port = '21';
|
|
$VARREPORT_dir = 'REPORTS';
|
|
|
|
# default CLI values
|
|
$campaign = 'TESTCAMP';
|
|
$sale_statuses = 'SALE-UPSELL';
|
|
$output_format = 'pipe-standard';
|
|
$outbound_calltime_ignore=0;
|
|
$totals_only=0;
|
|
$OUTcalls=0;
|
|
$OUTtalk=0;
|
|
$OUTtalkmin=0;
|
|
$INcalls=0;
|
|
$INtalk=0;
|
|
$INtalkmin=0;
|
|
|
|
$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";
|
|
$filedate = "$year$mon$mday";
|
|
$ABIfiledate = "$mon-$mday-$year$us$hour$min$sec";
|
|
$shipdate = "$year-$mon-$mday";
|
|
$start_date = "$year$mon$mday";
|
|
$datestamp = "$year/$mon/$mday $hour:$min";
|
|
|
|
|
|
use Time::Local;
|
|
|
|
### find epoch of 2AM today
|
|
$TWOAMsec = ( ($secX - ($sec + ($min * 60) + ($hour * 3600) ) ) + 7200);
|
|
### find epoch of 2AM yesterday
|
|
$TWOAMsecY = ($TWOAMsec - 86400);
|
|
|
|
($Tsec,$Tmin,$Thour,$Tmday,$Tmon,$Tyear,$Twday,$Tyday,$Tisdst) = localtime($TWOAMsecY);
|
|
$Tyear = ($Tyear + 1900);
|
|
$Tmon++;
|
|
if ($Tmon < 10) {$Tmon = "0$Tmon";}
|
|
if ($Tmday < 10) {$Tmday = "0$Tmday";}
|
|
if ($Thour < 10) {$Thour = "0$Thour";}
|
|
if ($Tmin < 10) {$Tmin = "0$Tmin";}
|
|
if ($Tsec < 10) {$Tsec = "0$Tsec";}
|
|
|
|
|
|
### 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 " [--date=YYYY-MM-DD] = date override\n";
|
|
print " [--filename=XXX] = Name to be used for file\n";
|
|
print " [--campaign=XXX] = Campaign that sales will be pulled from\n";
|
|
print " [--without-camp=XXX] = Campaign that will be excluded from ALL\n";
|
|
print " [--sale-statuses=XXX-XXY] = Statuses that are deemed to be \"Sales\". Default SALE\n";
|
|
print " NOTE: To include all statuses in the export, use \"--sale-statuses=---ALL---\"\n";
|
|
print " [--output-format=XXX] = Format of file. Default \"pipe-standard\"\n";
|
|
print " [--with-inbound=XXX-XXY] = include the following inbound groups\n";
|
|
print " [--without-in=XXX-XXY] = inbound groups that will be excluded from ALL\n";
|
|
print " [--calltime=XXX] = filter results to only include those calls during this call time\n";
|
|
print " [--outbound-calltime-ignore] = for outbound calls ignores call time\n";
|
|
print " [--totals-only] = print totals of time and calls only\n";
|
|
print " [--ftp-transfer] = Send results file by FTP to another server\n";
|
|
print " [--ftp-audio-transfer] = Send associated audio files to FTP server, dated directories\n";
|
|
print " [--ftp-norun] = Stop program when you get to the FTP transfer\n";
|
|
print " [--with-transfer-audio] = Different method for finding audio, also grabs transfer audio filenames\n";
|
|
print " [--with-did-lookup] = Looks up the DID pattern and name the call came in on if possible\n";
|
|
print " [--email-list=test@test.com:test2@test.com] = send email results to these addresses\n";
|
|
print " [--email-sender=vicidial@localhost] = sender for the email results\n";
|
|
print " [--quiet] = quiet\n";
|
|
print " [--test] = test\n";
|
|
print " [--debug] = debugging messages\n";
|
|
print " [--debugX] = Super debugging messages\n";
|
|
print "\n";
|
|
|
|
exit;
|
|
}
|
|
else
|
|
{
|
|
if ($args =~ /--debug/i)
|
|
{
|
|
$DB=1;
|
|
print "\n----- DEBUG MODE -----\n\n";
|
|
}
|
|
if ($args =~ /--debugX/i)
|
|
{
|
|
$DBX=1;
|
|
print "\n----- SUPER DEBUG MODE -----\n\n";
|
|
}
|
|
if ($args =~ /-quiet/i)
|
|
{
|
|
$q=1; $Q=1;
|
|
}
|
|
if ($args =~ /-totals-only/i)
|
|
{$totals_only=1;}
|
|
|
|
if ($args =~ /--date=/i)
|
|
{
|
|
@data_in = split(/--date=/,$args);
|
|
$shipdate = $data_in[1];
|
|
$shipdate =~ s/ .*//gi;
|
|
if ($shipdate =~ /today/)
|
|
{
|
|
$shipdate="$year-$mon-$mday";
|
|
$time = $TWOAMsec;
|
|
}
|
|
else
|
|
{
|
|
if ($shipdate =~ /yesterday/)
|
|
{
|
|
$shipdate="$Tyear-$Tmon-$Tmday";
|
|
$year = $Tyear;
|
|
$mon = $Tmon;
|
|
$mday = $Tmday;
|
|
$time=$TWOAMsecY;
|
|
}
|
|
else
|
|
{
|
|
@cli_date = split("-",$shipdate);
|
|
$year = $cli_date[0];
|
|
$mon = $cli_date[1];
|
|
$mday = $cli_date[2];
|
|
$cli_date[1] = ($cli_date[1] - 1);
|
|
$time = timelocal(0,0,2,$cli_date[2],$cli_date[1],$cli_date[0]);
|
|
}
|
|
}
|
|
if (!$Q) {print "\n----- DATE OVERRIDE: $shipdate -----\n\n";}
|
|
}
|
|
else
|
|
{
|
|
$time=$TWOAMsec;
|
|
}
|
|
|
|
|
|
if ($args =~ /--campaign=/i)
|
|
{
|
|
# print "\n|$ARGS|\n\n";
|
|
@data_in = split(/--campaign=/,$args);
|
|
$campaign = $data_in[1];
|
|
$campaign =~ s/ .*$//gi;
|
|
$campaignSQL = $campaign;
|
|
if ($campaignSQL =~ /-/)
|
|
{
|
|
$campaignSQL =~ s/-/','/gi;
|
|
}
|
|
$campaignSQL = "'$campaignSQL'";
|
|
}
|
|
if ($args =~ /--without-camp=/i)
|
|
{
|
|
# print "\n|$ARGS|\n\n";
|
|
@data_in = split(/--without-camp=/,$args);
|
|
$NOTcampaign = $data_in[1];
|
|
$NOTcampaign =~ s/ .*$//gi;
|
|
$NOTcampaignSQL = $NOTcampaign;
|
|
if ($NOTcampaignSQL =~ /-/)
|
|
{
|
|
$NOTcampaignSQL =~ s/-/','/gi;
|
|
}
|
|
$NOTcampaignSQL = "'$NOTcampaignSQL'";
|
|
}
|
|
if ($args =~ /--filename=/i)
|
|
{
|
|
# print "\n|$ARGS|\n\n";
|
|
@data_in = split(/--filename=/,$args);
|
|
$filename = $data_in[1];
|
|
$filename =~ s/ .*$//gi;
|
|
$filename =~ s/YYYY/$year/gi;
|
|
$filename =~ s/MM/$mon/gi;
|
|
$filename =~ s/DD/$mday/gi;
|
|
$filename_override=1;
|
|
}
|
|
if ($args =~ /--sale-statuses=/i)
|
|
{
|
|
@data_in = split(/--sale-statuses=/,$args);
|
|
$sale_statuses = $data_in[1];
|
|
$sale_statuses =~ s/ .*$//gi;
|
|
if ($sale_statuses =~ /---ALL---/)
|
|
{if (!$Q) {print "\n----- EXPORT ALL STATUSES -----\n\n";} }
|
|
}
|
|
if ($args =~ /--output-format=/i)
|
|
{
|
|
@data_in = split(/--output-format=/,$args);
|
|
$output_format = $data_in[1];
|
|
$output_format =~ s/ .*$//gi;
|
|
}
|
|
if ($args =~ /--with-inbound=/i)
|
|
{
|
|
@data_in = split(/--with-inbound=/,$args);
|
|
$with_inbound = $data_in[1];
|
|
$with_inbound =~ s/ .*$//gi;
|
|
}
|
|
if ($args =~ /--without-in=/i)
|
|
{
|
|
@data_in = split(/--without-in=/,$args);
|
|
$NOTwith_inbound = $data_in[1];
|
|
$NOTwith_inbound =~ s/ .*$//gi;
|
|
}
|
|
if ($args =~ /--calltime=/i)
|
|
{
|
|
# print "\n|$ARGS|\n\n";
|
|
@data_in = split(/--calltime=/,$args);
|
|
$call_time = $data_in[1];
|
|
$call_time =~ s/ .*$//gi;
|
|
}
|
|
if ($args =~ /--outbound-calltime-ignore/i)
|
|
{
|
|
$outbound_calltime_ignore=1;
|
|
if (!$Q)
|
|
{print "\n----- IGNORE CALLTIME FOR OUTBOUND -----\n\n";}
|
|
}
|
|
if ($args =~ /-ftp-transfer/i)
|
|
{
|
|
if (!$Q)
|
|
{print "\n----- FTP TRANSFER MODE -----\n\n";}
|
|
$ftp_transfer=1;
|
|
}
|
|
if ($args =~ /-ftp-audio-transfer/i)
|
|
{
|
|
if (!$Q)
|
|
{print "\n----- FTP AUDIO TRANSFER MODE -----\n\n";}
|
|
$ftp_audio_transfer=1;
|
|
|
|
### find wget binary
|
|
$wgetbin = '';
|
|
if ( -e ('/bin/wget')) {$wgetbin = '/bin/wget';}
|
|
else
|
|
{
|
|
if ( -e ('/usr/bin/wget')) {$wgetbin = '/usr/bin/wget';}
|
|
else
|
|
{
|
|
if ( -e ('/usr/local/bin/wget')) {$wgetbin = '/usr/local/bin/wget';}
|
|
else
|
|
{
|
|
print "Can't find wget binary! Exiting...\n";
|
|
exit
|
|
}
|
|
}
|
|
}
|
|
### find find binary
|
|
$findbin = '';
|
|
if ( -e ('/bin/find')) {$findbin = '/bin/find';}
|
|
else
|
|
{
|
|
if ( -e ('/usr/bin/find')) {$findbin = '/usr/bin/find';}
|
|
else
|
|
{
|
|
if ( -e ('/usr/local/bin/find')) {$findbin = '/usr/local/bin/find';}
|
|
else
|
|
{
|
|
print "Can't find find binary! Exiting...\n";
|
|
exit
|
|
}
|
|
}
|
|
}
|
|
$tempdir = '/root/tempaudioexport';
|
|
if (!-e "$tempdir")
|
|
{`mkdir -p $tempdir`;}
|
|
## remove old audio files from directory
|
|
`$findbin $tempdir/ -maxdepth 1 -type f -mtime +0 -print | xargs rm -f`;
|
|
}
|
|
if ($args =~ /-ftp-norun/i)
|
|
{
|
|
if (!$Q)
|
|
{print "\n----- FTP NORUN MODE -----\n\n";}
|
|
$ftp_norun=1;
|
|
}
|
|
if ($args =~ /-with-transfer-audio/i)
|
|
{
|
|
if (!$Q)
|
|
{print "\n----- AUDIO TRANSFER LOOKUP MODE -----\n\n";}
|
|
$with_transfer_audio=1;
|
|
}
|
|
if ($args =~ /-with-did-lookup/i)
|
|
{
|
|
if (!$Q)
|
|
{print "\n----- DID LOOKUP ENABLED -----\n\n";}
|
|
$with_did_lookup=1;
|
|
}
|
|
if ($args =~ /--test/i)
|
|
{
|
|
$T=1; $TEST=1;
|
|
print "\n----- TESTING -----\n\n";
|
|
}
|
|
if ($args =~ /--email-list=/i)
|
|
{
|
|
@data_in = split(/--email-list=/,$args);
|
|
$email_list = $data_in[1];
|
|
$email_list =~ s/ .*//gi;
|
|
$email_list =~ s/:/,/gi;
|
|
print "\n----- EMAIL NOTIFICATION: $email_list -----\n\n";
|
|
}
|
|
else
|
|
{$email_list = '';}
|
|
|
|
if ($args =~ /--email-sender=/i)
|
|
{
|
|
@data_in = split(/--email-sender=/,$args);
|
|
$email_sender = $data_in[1];
|
|
$email_sender =~ s/ .*//gi;
|
|
$email_sender =~ s/:/,/gi;
|
|
print "\n----- EMAIL NOTIFICATION SENDER: $email_sender -----\n\n";
|
|
}
|
|
else
|
|
{$email_sender = 'vicidial@localhost';}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
print "no command line options set, using defaults.\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;}
|
|
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++;
|
|
}
|
|
|
|
# Customized Variables
|
|
$server_ip = $VARserver_ip; # Asterisk server IP
|
|
|
|
if ($output_format =~ /^pipe-standard$/)
|
|
{$DLT = '|'; $txt='.txt'; print "---- pipe-standard ----\n";}
|
|
if ($output_format =~ /^csv-standard$/)
|
|
{$DLT = "','"; $txt='.csv'; print "---- csv-standard ----\n";}
|
|
if ($output_format =~ /^tab-standard$/)
|
|
{$DLT = "\t"; $txt='.txt'; print "---- tab-standard ----\n";}
|
|
if ($output_format =~ /^pipe-triplep$/)
|
|
{$DLT = ''; $txt='.txt'; print "---- pipe-triplep ----\n";}
|
|
if ($output_format =~ /^pipe-vici$/)
|
|
{$DLT = '|'; $txt='.txt'; print "---- pipe-vici ----\n";}
|
|
if ($output_format =~ /^html-rec$/)
|
|
{$DLT = ' '; $txt='.html'; print "---- html-rec ----\n";}
|
|
if ($output_format =~ /^fixed-as400$/)
|
|
{$DLT = ''; $txt='.txt'; print "---- fixed-as400 ----\n";}
|
|
|
|
if ($sale_statuses =~ /---ALL---/)
|
|
{
|
|
$sale_statusesSQL='';
|
|
$close_statusesSQL='';
|
|
}
|
|
else
|
|
{
|
|
$sale_statusesSQL = $sale_statuses;
|
|
$sale_statusesSQL =~ s/-/','/gi;
|
|
$sale_statusesSQL = "'$sale_statusesSQL'";
|
|
$close_statusesSQL = $sale_statusesSQL;
|
|
$sale_statusesSQL = " and vicidial_log.status IN($sale_statusesSQL)";
|
|
$close_statusesSQL = " and vicidial_closer_log.status IN($close_statusesSQL)";
|
|
}
|
|
|
|
|
|
if (length($with_inbound) < 2)
|
|
{
|
|
if (length($NOTwith_inbound) < 2)
|
|
{$with_inboundSQL = '';}
|
|
else
|
|
{
|
|
$with_inboundSQL = $NOTwith_inbound;
|
|
$with_inboundSQL =~ s/-/','/gi;
|
|
$with_inboundSQL = "vicidial_closer_log.campaign_id NOT IN('$with_inboundSQL')";
|
|
}
|
|
}
|
|
else
|
|
{
|
|
$with_inboundSQL = $with_inbound;
|
|
$with_inboundSQL =~ s/-/','/gi;
|
|
$with_inboundSQL = "vicidial_closer_log.campaign_id IN('$with_inboundSQL')";
|
|
}
|
|
|
|
if (length($campaignSQL) < 2)
|
|
{
|
|
if (length($NOTcampaignSQL) < 2)
|
|
{$campaignSQL = "vicidial_log.campaign_id NOT IN('')";}
|
|
else
|
|
{$campaignSQL = "vicidial_log.campaign_id NOT IN($NOTcampaignSQL)";}
|
|
}
|
|
else
|
|
{$campaignSQL = "vicidial_log.campaign_id IN($campaignSQL)";}
|
|
|
|
if (!$Q)
|
|
{
|
|
print "\n\n\n\n\n\n\n\n\n\n\n\n-- AST_VDsales_export.pl --\n\n";
|
|
print "This program is designed to gather sales from a VICIDIAL outbound-only campaign and post them to a file. \n";
|
|
print "\n";
|
|
print "Campaign: $campaign $campaignSQL\n";
|
|
print "Sale Statuses: $sale_statuses $sale_statusesSQL\n";
|
|
print "Output Format: $output_format\n";
|
|
print "With Inbound: $with_inbound $with_inboundSQL\n";
|
|
print "\n";
|
|
}
|
|
|
|
$outfile = "$campaign$US$filedate$US$sale_statuses$txt";
|
|
if ($filename_override > 0) {$outfile = $filename;}
|
|
|
|
### open the X out file for writing ###
|
|
$PATHoutfile = "$PATHweb/vicidial/server_reports/$outfile";
|
|
open(out, ">$PATHoutfile")
|
|
|| die "Can't open $PATHoutfile: $!\n";
|
|
|
|
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;
|
|
|
|
$dbhB = DBI->connect("DBI:mysql:$VARDB_database:$VARDB_server:$VARDB_port", "$VARDB_user", "$VARDB_pass")
|
|
or die "Couldn't connect to database: " . DBI->errstr;
|
|
|
|
$TOTAL_SALES=0;
|
|
|
|
|
|
|
|
$stmtA = "SELECT call_time_id,call_time_name,call_time_comments,ct_default_start,ct_default_stop,ct_sunday_start,ct_sunday_stop,ct_monday_start,ct_monday_stop,ct_tuesday_start,ct_tuesday_stop,ct_wednesday_start,ct_wednesday_stop,ct_thursday_start,ct_thursday_stop,ct_friday_start,ct_friday_stop,ct_saturday_start,ct_saturday_stop,ct_state_call_times FROM vicidial_call_times where call_time_id='$call_time';";
|
|
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
|
|
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
|
|
$sthArows=$sthA->rows;
|
|
if ($DBX) {print " $sthArows|$stmtA|\n";}
|
|
if ($sthArows > 0)
|
|
{
|
|
@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]";
|
|
$sthA->finish();
|
|
}
|
|
else
|
|
{
|
|
if ($DB > 0) {print "CALL TIME NOT FOUND: $call_time\n";}
|
|
$call_time='';
|
|
}
|
|
|
|
|
|
###########################################################################
|
|
########### CURRENT DAY SALES GATHERING outbound-only: vicidial_log ######
|
|
###########################################################################
|
|
$stmtA = "select vicidial_log.user,first_name,last_name,address1,address2,city,state,postal_code,vicidial_list.phone_number,vicidial_list.email,security_phrase,vicidial_list.comments,call_date,vicidial_list.lead_id,vicidial_users.full_name,vicidial_log.status,vicidial_list.vendor_lead_code,vicidial_list.source_id,vicidial_log.list_id,title,address3,last_local_call_time,uniqueid,length_in_sec,vicidial_list.list_id,vicidial_list.list_id,UNIX_TIMESTAMP(vicidial_log.call_date),vicidial_campaigns.campaign_name,vicidial_campaigns.campaign_cid from vicidial_list,vicidial_log,vicidial_users,vicidial_campaigns where $campaignSQL $sale_statusesSQL and call_date > '$shipdate 00:00:01' and call_date < '$shipdate 23:59:59' and vicidial_log.lead_id=vicidial_list.lead_id and vicidial_users.user=vicidial_log.user and vicidial_log.campaign_id=vicidial_campaigns.campaign_id order by call_date;";
|
|
if ($output_format =~ /^tab-QMcustomUSA$/)
|
|
{
|
|
$stmtA = "select vicidial_log.user,8,8,8,8,8,8,8,vicidial_log.phone_number,8,8,8,call_date,vicidial_log.lead_id,vicidial_users.full_name,vicidial_log.status,8,8,vicidial_log.list_id,8,8,call_date,uniqueid,length_in_sec,vicidial_log.list_id,vicidial_log.list_id,UNIX_TIMESTAMP(vicidial_log.call_date),vicidial_campaigns.campaign_name,vicidial_campaigns.campaign_cid from vicidial_log,vicidial_users,vicidial_campaigns where $campaignSQL $sale_statusesSQL and call_date > '$shipdate 00:00:01' and call_date < '$shipdate 23:59:59' and vicidial_users.user=vicidial_log.user and vicidial_log.campaign_id=vicidial_campaigns.campaign_id order by call_date;";
|
|
}
|
|
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
|
|
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
|
|
$sthArows=$sthA->rows;
|
|
$rec_count=0;
|
|
if ($DB) {print "$sthArows|$stmtA|\n";}
|
|
while ($sthArows > $rec_count)
|
|
{
|
|
@aryA = $sthA->fetchrow_array;
|
|
$user = $aryA[0];
|
|
$first_name = $aryA[1];
|
|
$last_name = $aryA[2];
|
|
$address1 = $aryA[3];
|
|
$address2 = $aryA[4];
|
|
$city = $aryA[5];
|
|
$state = $aryA[6];
|
|
$postal_code = $aryA[7];
|
|
$phone_number = $aryA[8];
|
|
$email = $aryA[9];
|
|
$security = $aryA[10];
|
|
$comments = $aryA[11];
|
|
$call_date = $aryA[12];
|
|
$lead_id = $aryA[13];
|
|
$agent_name = $aryA[14];
|
|
$status = $aryA[15];
|
|
$vendor_id = $aryA[16];
|
|
$source_id = $aryA[17];
|
|
$list_id = $aryA[18];
|
|
$title = $aryA[19];
|
|
$address3 = $aryA[20];
|
|
$last_local_call_time = $aryA[21];
|
|
$vicidial_id = $aryA[22];
|
|
$uniqueid = $aryA[22];
|
|
$length_in_sec = $aryA[23];
|
|
$rank = $aryA[24];
|
|
$owner = $aryA[25];
|
|
$epoch = $aryA[26];
|
|
$did_name = $aryA[27];
|
|
$did_pattern = $aryA[28];
|
|
|
|
$outbound = 'Y';
|
|
$domestic = 'Y';
|
|
$queue_seconds = '0';
|
|
$closer='';
|
|
|
|
&select_format_loop;
|
|
|
|
$TOTAL_SALES++;
|
|
}
|
|
$sthA->finish();
|
|
|
|
if (length($with_inboundSQL)>3)
|
|
{
|
|
###########################################################################
|
|
########### CURRENT DAY SALES GATHERING inbound-only: vicidial_closer_log ######
|
|
###########################################################################
|
|
$stmtA = "select vicidial_closer_log.user,first_name,last_name,address1,address2,city,state,postal_code,vicidial_list.phone_number,vicidial_list.email,security_phrase,vicidial_list.comments,call_date,vicidial_list.lead_id,vicidial_users.full_name,vicidial_closer_log.status,vicidial_list.vendor_lead_code,vicidial_list.source_id,vicidial_closer_log.list_id,campaign_id,title,address3,last_local_call_time,xfercallid,closecallid,uniqueid,length_in_sec,queue_seconds,vicidial_list.list_id,vicidial_list.list_id,UNIX_TIMESTAMP(vicidial_closer_log.call_date),agent_alert_delay from vicidial_list,vicidial_closer_log,vicidial_users,vicidial_inbound_groups where $with_inboundSQL $close_statusesSQL and call_date > '$shipdate 00:00:01' and call_date < '$shipdate 23:59:59' and vicidial_closer_log.lead_id=vicidial_list.lead_id and vicidial_users.user=vicidial_closer_log.user and vicidial_inbound_groups.group_id=vicidial_closer_log.campaign_id order by call_date;";
|
|
if ($output_format =~ /^tab-QMcustomUSA$/)
|
|
{
|
|
$stmtA = "select vicidial_closer_log.user,8,8,8,8,8,8,8,vicidial_closer_log.phone_number,8,8,8,call_date,vicidial_closer_log.lead_id,vicidial_users.full_name,vicidial_closer_log.status,8,8,vicidial_closer_log.list_id,campaign_id,8,8,call_date,xfercallid,closecallid,uniqueid,length_in_sec,queue_seconds,vicidial_closer_log.list_id,vicidial_closer_log.list_id,UNIX_TIMESTAMP(vicidial_closer_log.call_date),agent_alert_delay from vicidial_closer_log,vicidial_users,vicidial_inbound_groups where $with_inboundSQL $close_statusesSQL and call_date > '$shipdate 00:00:01' and call_date < '$shipdate 23:59:59' and vicidial_users.user=vicidial_closer_log.user and vicidial_inbound_groups.group_id=vicidial_closer_log.campaign_id order by call_date;";
|
|
}
|
|
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
|
|
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
|
|
$sthArows=$sthA->rows;
|
|
if ($DB) {print "$sthArows|$stmtA|\n";}
|
|
$rec_count=0;
|
|
while ($sthArows > $rec_count)
|
|
{
|
|
@aryA = $sthA->fetchrow_array;
|
|
$closer = $aryA[0];
|
|
$first_name = $aryA[1];
|
|
$last_name = $aryA[2];
|
|
$address1 = $aryA[3];
|
|
$address2 = $aryA[4];
|
|
$city = $aryA[5];
|
|
$state = $aryA[6];
|
|
$postal_code = $aryA[7];
|
|
$phone_number = $aryA[8];
|
|
$email = $aryA[9];
|
|
$security = $aryA[10];
|
|
$comments = $aryA[11];
|
|
$call_date = $aryA[12];
|
|
$lead_id = $aryA[13];
|
|
$closer_name = $aryA[14];
|
|
$status = $aryA[15];
|
|
$vendor_id = $aryA[16];
|
|
$source_id = $aryA[17];
|
|
$list_id = $aryA[18];
|
|
$campaign_id = $aryA[19];
|
|
$title = $aryA[20];
|
|
$address3 = $aryA[21];
|
|
$last_local_call_time = $aryA[22];
|
|
$xfercallid = $aryA[23];
|
|
$vicidial_id = $aryA[24];
|
|
$uniqueid = $aryA[25];
|
|
$length_in_sec = $aryA[26];
|
|
$queue_seconds = $aryA[27];
|
|
$rank = $aryA[28];
|
|
$owner = $aryA[29];
|
|
$epoch = $aryA[30];
|
|
$agent_alert_delay = int($aryA[31] / 1000);
|
|
|
|
$outbound = 'N';
|
|
$domestic = 'Y';
|
|
$user = '';
|
|
$agent_name='';
|
|
|
|
$stmtB = "select vicidial_xfer_log.user,full_name from vicidial_xfer_log,vicidial_users where lead_id='$lead_id' and closer='$closer' and xfercallid='$xfercallid' and call_date > '$shipdate 00:00:01' and call_date < '$shipdate 23:59:59' and vicidial_users.user=vicidial_xfer_log.user order by call_date desc limit 1;";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$sthBrows=$sthB->rows;
|
|
if ($sthBrows > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$user = $aryB[0];
|
|
$agent_name = $aryB[1];
|
|
}
|
|
$sthB->finish();
|
|
|
|
&select_format_loop;
|
|
|
|
$TOTAL_SALES++;
|
|
}
|
|
$sthA->finish();
|
|
}
|
|
|
|
close(out);
|
|
|
|
|
|
###### EMAIL SECTION
|
|
|
|
if ( (length($Ealert)>5) && (length($email_list) > 3) )
|
|
{
|
|
print "Sending email: $email_list\n";
|
|
|
|
use MIME::QuotedPrint;
|
|
use MIME::Base64;
|
|
use Mail::Sendmail;
|
|
|
|
$mailsubject = "VICIDIAL Lead Export $outfile";
|
|
|
|
%mail = ( To => "$email_list",
|
|
From => "$email_sender",
|
|
Subject => "$mailsubject",
|
|
);
|
|
$boundary = "====" . time() . "====";
|
|
$mail{'content-type'} = "multipart/mixed; boundary=\"$boundary\"";
|
|
|
|
$message = encode_qp( "VICIDIAL Lead Export:\n\n Attachment: $outfile\n Total Records: $TOTAL_SALES\n" );
|
|
|
|
$Zfile = "$PATHoutfile";
|
|
|
|
open (F, $Zfile) or die "Cannot read $Zfile: $!";
|
|
binmode F; undef $/;
|
|
$attachment = encode_base64(<F>);
|
|
close F;
|
|
|
|
$boundary = '--'.$boundary;
|
|
$mail{body} .= "$boundary\n";
|
|
$mail{body} .= "Content-Type: text/plain; charset=\"iso-8859-1\"\n";
|
|
$mail{body} .= "Content-Transfer-Encoding: quoted-printable\n\n";
|
|
$mail{body} .= "$message\n";
|
|
$mail{body} .= "$boundary\n";
|
|
$mail{body} .= "Content-Type: application/octet-stream; name=\"$outfile\"\n";
|
|
$mail{body} .= "Content-Transfer-Encoding: base64\n";
|
|
$mail{body} .= "Content-Disposition: attachment; filename=\"$outfile\"\n\n";
|
|
$mail{body} .= "$attachment\n";
|
|
$mail{body} .= "$boundary";
|
|
$mail{body} .= "--\n";
|
|
|
|
sendmail(%mail) or die $mail::Sendmail::error;
|
|
print "ok. log says:\n", $mail::sendmail::log; ### print mail log for status
|
|
|
|
}
|
|
|
|
|
|
|
|
# FTP overrides-
|
|
# $VARREPORT_host = '10.0.0.4';
|
|
# $VARREPORT_port = '21';
|
|
# $VARREPORT_user = 'cron';
|
|
# $VARREPORT_pass = 'test';
|
|
# $VARREPORT_dir = '';
|
|
|
|
$NODATEDIR = 0; # Don't use dated directories for audio
|
|
$YEARDIR = 1; # put dated directories in a year directory first
|
|
|
|
if ($ftp_transfer > 0)
|
|
{
|
|
use Net::FTP;
|
|
|
|
if (!$Q) {print "Sending File Over FTP: $outfile\n";}
|
|
$ftp = Net::FTP->new("$VARREPORT_host", Port => $VARREPORT_port);
|
|
$ftp->login("$VARREPORT_user","$VARREPORT_pass");
|
|
$ftp->cwd("$VARREPORT_dir");
|
|
$ftp->put("$PATHweb/vicidial/server_reports/$outfile", "$outfile");
|
|
$ftp->quit;
|
|
}
|
|
|
|
if ( ( ($DB) || ($totals_only > 0) ) && ($output_format =~ /^tab-QMcustomUSA$/) )
|
|
{
|
|
if ($OUTtalk > 0) {$OUTtalkmin = ($OUTtalk / 60);}
|
|
if ($INtalk > 0) {$INtalkmin = ($INtalk / 60);}
|
|
$OUTtalkmin = sprintf("%10.2f",$OUTtalkmin);
|
|
$INtalkmin = sprintf("%10.2f",$INtalkmin);
|
|
$OUTcalls = sprintf("%10s",$OUTcalls);
|
|
$INcalls = sprintf("%10s",$INcalls);
|
|
$OUTtalk = sprintf("%10s",$OUTtalk);
|
|
$INtalk = sprintf("%10s",$INtalk);
|
|
print "OUTBOUND CALLS: $OUTcalls\n";
|
|
print "OUTBOUND SECONDS: $OUTtalk\n";
|
|
print "OUTBOUND MINUTES: $OUTtalkmin\n";
|
|
print "INBOUND CALLS: $INcalls\n";
|
|
print "INBOUND SECONDS: $INtalk\n";
|
|
print "INBOUND MINUTES: $INtalkmin\n";
|
|
}
|
|
|
|
if ($ftp_audio_transfer > 0)
|
|
{
|
|
use Net::FTP;
|
|
opendir(FILE, "$tempdir/");
|
|
@FILES = readdir(FILE);
|
|
|
|
if (!$Q) {print "Sending Audio Over FTP: $#FILES\n";}
|
|
|
|
if ($ftp_norun > 0)
|
|
{exit;}
|
|
|
|
$i=0;
|
|
foreach(@FILES)
|
|
{
|
|
if ( (length($FILES[$i]) > 4) && (!-d "$tempdir/$FILES[$i]") )
|
|
{
|
|
$ftp = Net::FTP->new("$VARREPORT_host", Port => "$VARREPORT_port", Debug => "$DB", Passive => "1");
|
|
$ftp->login("$VARREPORT_user","$VARREPORT_pass");
|
|
if (length($VARREPORT_dir) > 0)
|
|
{$ftp->cwd("$VARREPORT_dir");}
|
|
if ($NODATEDIR < 1)
|
|
{
|
|
if ($YEARDIR > 0)
|
|
{
|
|
$ftp->mkdir("$year");
|
|
$ftp->cwd("$year");
|
|
}
|
|
$ftp->mkdir("$start_date");
|
|
$ftp->cwd("$start_date");
|
|
}
|
|
$start_date_PATH = "$start_date/";
|
|
$ftp->binary();
|
|
$ftp->put("$tempdir/$FILES[$i]", "$FILES[$i]");
|
|
$ftp->quit;
|
|
}
|
|
$i++;
|
|
}
|
|
}
|
|
|
|
|
|
### calculate time to run script ###
|
|
$secY = time();
|
|
$secZ = ($secY - $secX);
|
|
$secZm = ($secZ /60);
|
|
|
|
if (!$Q) {print "SALES EXPORT FOR $shipdate: $outfile\n";}
|
|
if (!$Q) {print "TOTAL SALES: $TOTAL_SALES\n";}
|
|
if (!$Q) {print "TOTAL EXCLUDED BY CALLTIME: $CALLTIME_KICK\n";}
|
|
if (!$Q) {print "script execution time in seconds: $secZ minutes: $secZm\n";}
|
|
|
|
exit;
|
|
|
|
|
|
|
|
|
|
|
|
### Subroutine for formatting of the output ###
|
|
sub select_format_loop
|
|
{
|
|
$within_calltime = 1;
|
|
|
|
if (length($call_time) > 0)
|
|
{
|
|
$CTtarget = ($secX - 10);
|
|
($Csec,$Cmin,$Chour,$Cmday,$Cmon,$Cyear,$Cwday,$Cyday,$Cisdst) = localtime($epoch);
|
|
if ($Chour < 10) {$Chour = "0$Chour";}
|
|
if ($Cmin < 10) {$Cmin = "0$Cmin";}
|
|
$CThourminute = "$Chour$Cmin";
|
|
|
|
$CTstart = $Gct_default_start;
|
|
$CTstop = $Gct_default_stop;
|
|
|
|
if ( ($Cwday == 0) && ( ($Gct_sunday_start > 0) && ($Gct_sunday_stop > 0) ) )
|
|
{$CTstart = $Gct_sunday_start; $CTstop = $Gct_sunday_stop;}
|
|
if ( ($Cwday == 1) && ( ($Gct_monday_start > 0) && ($Gct_monday_stop > 0) ) )
|
|
{$CTstart = $Gct_monday_start; $CTstop = $Gct_monday_stop;}
|
|
if ( ($Cwday == 2) && ( ($Gct_tuesday_start > 0) && ($Gct_tuesday_stop > 0) ) )
|
|
{$CTstart = $Gct_tuesday_start; $CTstop = $Gct_tuesday_stop;}
|
|
if ( ($Cwday == 3) && ( ($Gct_wednesday_start > 0) && ($Gct_wednesday_stop > 0) ) )
|
|
{$CTstart = $Gct_wednesday_start; $CTstop = $Gct_wednesday_stop;}
|
|
if ( ($Cwday == 4) && ( ($Gct_thursday_start > 0) && ($Gct_thursday_stop > 0) ) )
|
|
{$CTstart = $Gct_thursday_start; $CTstop = $Gct_thursday_stop;}
|
|
if ( ($Cwday == 5) && ( ($Gct_friday_start > 0) && ($Gct_friday_stop > 0) ) )
|
|
{$CTstart = $Gct_friday_start; $CTstop = $Gct_friday_stop;}
|
|
if ( ($Cwday == 6) && ( ($Gct_saturday_start > 0) && ($Gct_saturday_stop > 0) ) )
|
|
{$CTstart = $Gct_saturday_start; $CTstop = $Gct_saturday_stop;}
|
|
|
|
if ( ($CThourminute < $CTstart) || ($CThourminute > $CTstop) )
|
|
{
|
|
if ($DB > 0) {print "Call is outside of defined call time: $CThourminute|$Cwday| |$CTstart|$CTstop| \n";}
|
|
$within_calltime=0;
|
|
}
|
|
}
|
|
|
|
if ( ($within_calltime > 0) || ( ($outbound_calltime_ignore > 0) && ($outbound =~ /Y/) ) )
|
|
{
|
|
$str='';
|
|
if ($T)
|
|
{
|
|
# $user = '1234';
|
|
$agent_name = 'Joe Agent';
|
|
# $closer = '4321';
|
|
$closer_name = 'Jane Closer';
|
|
$security = '4111111111111111';
|
|
$comments = 'VISA';
|
|
$phone_number =~ s/^\d\d\d\d\d/23456/gi;
|
|
$address1 =~ s/^..../1234 /gi
|
|
}
|
|
|
|
##### BEGIN standard audio lookup #####
|
|
if ($with_transfer_audio < 1)
|
|
{
|
|
$ivr_id = '0';
|
|
$ivr_filename = '';
|
|
|
|
$stmtB = "select recording_id,filename,location from recording_log where lead_id='$lead_id' and start_time > '$shipdate 00:00:01' and start_time < '$shipdate 23:59:59' order by length_in_sec desc limit 1;";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$sthBrows=$sthB->rows;
|
|
$rec_countB=0;
|
|
while ($sthBrows > $rec_countB)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$ivr_id = $aryB[0];
|
|
$ivr_filename = $aryB[1];
|
|
$ivr_location = $aryB[2];
|
|
$rec_countB++;
|
|
}
|
|
$sthB->finish();
|
|
|
|
if (length($ivr_id)<3)
|
|
{
|
|
$stmtB = "select recording_id,filename,location from recording_log where lead_id='$lead_id' order by length_in_sec desc limit 1;";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$sthBrows=$sthB->rows;
|
|
$rec_countB=0;
|
|
while ($sthBrows > $rec_countB)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$ivr_id = $aryB[0];
|
|
$ivr_filename = $aryB[1];
|
|
$ivr_location = $aryB[2];
|
|
$rec_countB++;
|
|
}
|
|
$sthB->finish();
|
|
|
|
if (length($ivr_id)<3)
|
|
{
|
|
$stmtB = "select recording_id,filename,location from recording_log where filename LIKE \"%$phone_number%\" order by length_in_sec desc limit 1;";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$sthBrows=$sthB->rows;
|
|
$rec_countB=0;
|
|
while ($sthBrows > $rec_countB)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$ivr_id = $aryB[0];
|
|
$ivr_filename = $aryB[1];
|
|
$ivr_location = $aryB[2];
|
|
$rec_countB++;
|
|
}
|
|
$sthB->finish();
|
|
}
|
|
}
|
|
|
|
if ( ($ftp_audio_transfer > 0) && (length($ivr_filename) > 3) && (length($ivr_location) > 5) )
|
|
{
|
|
@ivr_path = split(/\//,$ivr_location);
|
|
$path_file = $ivr_path[$#ivr_path];
|
|
`$wgetbin -q --output-document=$tempdir/$path_file $ivr_location `;
|
|
}
|
|
}
|
|
##### END standard audio lookup #####
|
|
|
|
##### BEGIN transfer audio lookup #####
|
|
else
|
|
{
|
|
$ivr_id = '0';
|
|
$ivr_filename = '';
|
|
$ivr_location = '';
|
|
|
|
$stmtB = "select recording_id,filename,location from recording_log where vicidial_id='$vicidial_id' and start_time > '$shipdate 00:00:01' and start_time < '$shipdate 23:59:59' order by start_time limit 10;";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$sthBrows=$sthB->rows;
|
|
$rec_countB=0;
|
|
while ($sthBrows > $rec_countB)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
if ($rec_countB > 0)
|
|
{
|
|
$ivr_id .= "|";
|
|
$ivr_filename .= "|";
|
|
}
|
|
$ivr_id .= "$aryB[0]";
|
|
$ivr_location = "$aryB[2]";
|
|
@ivr_path = split(/\//,$ivr_location);
|
|
$path_file = $ivr_path[$#ivr_path];
|
|
$ivr_filename .= "$path_file";
|
|
$rec_countB++;
|
|
if ($ftp_audio_transfer > 0)
|
|
{
|
|
`$wgetbin -q --output-document=$tempdir/$path_file $aryB[2] `;
|
|
}
|
|
}
|
|
$sthB->finish();
|
|
|
|
### Look for other closer calls after this call
|
|
$more_calls[0]='';
|
|
$stmtB = "select closecallid,length_in_sec,queue_seconds,agent_alert_delay from vicidial_closer_log,vicidial_inbound_groups where lead_id='$lead_id' and call_date > '$call_date' and call_date < '$shipdate 23:59:59' and campaign_id=group_id order by call_date limit 10;";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$sthBrows=$sthB->rows;
|
|
if ($DBX > 0) {print "$sthBrows|$stmtB\n";}
|
|
$rec_countB=0;
|
|
while ($sthBrows > $rec_countB)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$more_calls[$rec_countB] = "$aryB[0]";
|
|
$Xagent_alert_delay = int($aryB[3] / 1000);
|
|
$length_in_sec = (($length_in_sec + $aryB[1]) - $Xagent_alert_delay);
|
|
$queue_seconds = ($queue_seconds + $aryB[2]);
|
|
$rec_countB++;
|
|
}
|
|
$sthB->finish();
|
|
|
|
$u=0;
|
|
while ($sthBrows > $u)
|
|
{
|
|
$closecallid = $more_calls[$u];
|
|
|
|
$stmtB = "select recording_id,filename,location from recording_log where vicidial_id='$closecallid' and start_time > '$shipdate 00:00:01' and start_time < '$shipdate 23:59:59' order by start_time limit 10;";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$sthBrowsR=$sthB->rows;
|
|
if ($DBX > 0) {print "$sthBrowsR|$stmtB\n";}
|
|
$rec_countBR=0;
|
|
while ($sthBrowsR > $rec_countBR)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
if (length($ivr_id) > 1)
|
|
{
|
|
$ivr_id .= "|";
|
|
$ivr_filename .= "|";
|
|
}
|
|
$ivr_id .= "$aryB[0]";
|
|
$ivr_location = "$aryB[2]";
|
|
@ivr_path = split(/\//,$ivr_location);
|
|
$path_file = $ivr_path[$#ivr_path];
|
|
$ivr_filename .= "$path_file";
|
|
$rec_countBR++;
|
|
if ($ftp_audio_transfer > 0)
|
|
{
|
|
`$wgetbin -q --output-document=$tempdir/$path_file $aryB[2] `;
|
|
}
|
|
}
|
|
$sthB->finish();
|
|
|
|
$u++;
|
|
}
|
|
}
|
|
##### END transfer audio lookup #####
|
|
|
|
##### BEGIN DID lookup #####
|
|
if ( ($with_did_lookup > 0) && ($outbound =~ /N/) )
|
|
{
|
|
$did_pattern = '';
|
|
$did_name = '';
|
|
$did_date = '';
|
|
|
|
$stmtB = "select did_pattern,did_description,call_date from vicidial_inbound_dids vid,vicidial_did_log vdl where uniqueid='$uniqueid' and call_date > '$shipdate 00:00:01' and call_date <= '$call_date' and vid.did_id=vdl.did_id order by call_date desc limit 1;";
|
|
if ($DBX > 0) {print "$stmtB\n";}
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$sthBrows=$sthB->rows;
|
|
if ($sthBrows > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$did_pattern = "$aryB[0]";
|
|
$did_name = "$aryB[1]";
|
|
$did_date = "$aryB[2]";
|
|
$sthB->finish();
|
|
}
|
|
else
|
|
{
|
|
$stmtB = "select vc.campaign_cid,vc.campaign_name,call_date from vicidial_campaigns vc,vicidial_log vl where lead_id='$lead_id' and call_date > '$shipdate 00:00:01' and call_date <= '$call_date' and vc.campaign_id=vl.campaign_id order by call_date desc limit 1;";
|
|
if ($DBX > 0) {print "$stmtB\n";}
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$sthBrows=$sthB->rows;
|
|
if ($sthBrows > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$did_pattern = "$aryB[0]";
|
|
$did_name = "$aryB[1]";
|
|
$did_date = "$aryB[2]";
|
|
$sthB->finish();
|
|
}
|
|
##### UNCOMMENT IF USING LIST ID NAME FOR DID_NAME
|
|
# $stmtB = "select list_name,campaign_cid_override from vicidial_lists where list_id='$list_id' limit 1;";
|
|
# if ($DBX > 0) {print "$stmtB\n";}
|
|
# $sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
# $sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
# $sthBrows=$sthB->rows;
|
|
# if ($sthBrows > 0)
|
|
# {
|
|
# @aryB = $sthB->fetchrow_array;
|
|
# $did_name = $aryB[0];
|
|
# $did_pattern = $aryB[1];
|
|
# $sthB->finish();
|
|
# }
|
|
}
|
|
}
|
|
##### END DID lookup #####
|
|
|
|
if ($status =~ /UPSELL/) {$UPSELL='L5';}
|
|
else {$UPSELL='N';}
|
|
|
|
if ($output_format =~ /^pipe-standard$/)
|
|
{
|
|
$str = "$first_name|$last_name|$address1|$address2|$city|$state|$postal_code|$phone_number|$email|$security|$comments|$call_date|$lead_id|$list_id|$user|$agent_name|$status|$vendor_id|$source_id|$campaign|$campaign_id|$ivr_id|$closer|$closer_name|$rank|$owner|\n";
|
|
}
|
|
|
|
if ($output_format =~ /^csv-standard$/)
|
|
{
|
|
$str = "\"$first_name\",\"$last_name\",\"$address1\",\"$address2\",\"$city\",\"$state\",\"$postal_code\",\"$phone_number\",\"$email\",\"$security\",\"$comments\",\"$call_date\",\"$lead_id\",\"$list_id\",\"$user\",\"$agent_name\",\"$status\",\"$vendor_id\",\"$source_id\",\"$campaign\",\"$campaign_id\",\"$ivr_id\",\"$closer\",\"$closer_name\",\"$rank\",\"$owner\"\r\n";
|
|
}
|
|
|
|
if ($output_format =~ /^tab-standard$/)
|
|
{
|
|
$str = "$first_name\t$last_name\t$address1\t$address2\t$city\t$state\t$postal_code\t$phone_number\t$email\t$security\t$comments\t$call_date\t$lead_id\t$list_id\t$user\t$agent_name\t$status\t$vendor_id\t$source_id\t$campaign\t$campaign_id\t$ivr_id\t$closer\t$closer_name\t$rank\t$owner\t\n";
|
|
}
|
|
|
|
if ($output_format =~ /^pipe-triplep$/)
|
|
{
|
|
$str = "$user|$agent_name|$closer|$closer_name|$call_date|$status|$first_name|$last_name|$phone_number|$address1|$address2|$city|$state|$postal_code|$comments|$security|$email|$vendor_id|$source_id|$lead_id|$list_id|$campaign|$campaign_id|$ivr_id|\n";
|
|
}
|
|
|
|
if ($output_format =~ /^pipe-vici$/)
|
|
{
|
|
$str = "VDAD|$agent_name|$first_name|$last_name|$address1|$address2|$city|$state|$postal_code|$phone_number|$ivr_id|DU|$UPSELL|N|||$security|$comments||||||$call_date|CBDISC|$email\r\n";
|
|
}
|
|
|
|
if ($output_format =~ /^html-rec$/)
|
|
{
|
|
$str = "$user|$agent_name|$closer|$closer_name|$call_date|$status|$first_name|$last_name|$phone_number|$address1|$address2|$city|$state|$postal_code|$comments|$security|$email|$vendor_id|$source_id|$lead_id|$list_id|$campaign|$campaign_id|<a href=\"$ivr_location\">$ivr_id</a>|\n";
|
|
}
|
|
|
|
if ($output_format =~ /^fixed-as400$/)
|
|
{
|
|
# 16884259 MRS. JEAN BROWN RISALPUR BROMSBERROW HEATYH LEDBURY HEREFORDSHIRE ENGLAND HR8 1PQ 01531650052 1209200809:52NI 3205UK
|
|
$vendor_id = sprintf("%-10s",$vendor_id); while(length($vendor_id)>10) {$vendor_id =~ s/.$//gi;}
|
|
$title = sprintf("%-10s",$title); while(length($title)>10) {$title =~ s/.$//gi;}
|
|
$first_name = sprintf("%-15s",$first_name); while(length($first_name)>15) {$first_name =~ s/.$//gi;}
|
|
$last_name = sprintf("%-20s",$last_name); while(length($last_name)>20) {$last_name =~ s/.$//gi;}
|
|
$address1 = sprintf("%-30s",$address1); while(length($address1)>30) {$address1 =~ s/.$//gi;}
|
|
$address2 = sprintf("%-30s",$address2); while(length($address2)>30) {$address2 =~ s/.$//gi;}
|
|
$address3 = sprintf("%-30s",$address3); while(length($address3)>30) {$address3 =~ s/.$//gi;}
|
|
$city = sprintf("%-50s",$city); while(length($city)>50) {$city =~ s/.$//gi;}
|
|
$postal_code = sprintf("%-9s",$postal_code); while(length($postal_code)>9) {$postal_code =~ s/.$//gi;}
|
|
$phone_number = sprintf("%-20s",$phone_number); while(length($phone_number)>20) {$phone_number =~ s/.$//gi;}
|
|
@dtsplit = split(" ",$last_local_call_time);
|
|
@datesplit = split("-",$dtsplit[0]);
|
|
$timesplit = substr($dtsplit[1], 0, 5);
|
|
$formatted_date = "$datesplit[1]$datesplit[2]$datesplit[0]$timesplit";
|
|
$user = sprintf("%-4s",$user);
|
|
if ($status =~ /^AA$/) {$status = 'A';}
|
|
if ($status =~ /^A$/) {$status = 'A';}
|
|
if ($status =~ /^B$/) {$status = 'B';}
|
|
if ($status =~ /^N$/) {$status = 'N';}
|
|
if ($status =~ /^NA$/) {$status = 'N';}
|
|
if ($status =~ /^NP$/) {$status = 'N';}
|
|
if ($status =~ /^PU$/) {$status = 'N';}
|
|
if ($status =~ /^DROP$/) {$status = 'N';}
|
|
if ($status =~ /^SALE$/) {$status = 'AP';}
|
|
if ($status =~ /^A6$/) {$status = 'A6';}
|
|
if ($status =~ /^DC$/) {$status = 'D';}
|
|
if ($status =~ /^DNC$/) {$status = 'DC';}
|
|
if ($status =~ /^DNCL$/) {$status = 'DC';}
|
|
if ($status =~ /^DIED$/) {$status = 'DD';}
|
|
if ($status =~ /^COMP$/) {$status = 'DD';}
|
|
if ($status =~ /^DEC$/) {$status = 'DD';}
|
|
if ($status =~ /^ERI$/) {$status = 'DD';}
|
|
if ($status =~ /^INCALL$/) {$status = 'DD';}
|
|
if ($status =~ /^SP$/) {$status = 'DD';}
|
|
if ($status =~ /^WRON$/) {$status = 'DD';}
|
|
if ($status =~ /^HBED$/) {$status = 'DD';}
|
|
if ($status =~ /^CALLBK$/) {$status = 'A6';}
|
|
if ($status =~ /^HAP1$/) {$status = 'NI';}
|
|
if ($status =~ /^HAP2$/) {$status = 'NI';}
|
|
if ($status =~ /^NI$/) {$status = 'NI';}
|
|
|
|
$status = sprintf("%-16s",$status); while(length($status)>16) {$status =~ s/.$//gi;}
|
|
$user =~ s/VDAD/ /gi;
|
|
$UK = 'UK';
|
|
|
|
$str = "$vendor_id$title$first_name$last_name$address1$address2$address3$city$postal_code$phone_number$formatted_date$status$user$UK\r\n";
|
|
}
|
|
|
|
if ($output_format =~ /^tab-QMcustomUSA$/)
|
|
{
|
|
# 1245328655100219 2009-06-18 05:37:35 937 9375551212 8185551223 8106 35 255 0 DSAW - q8187-20090618-053939-1245328655.100219.WAV|q8186-20090618-053735-1245328655.100219.WAV
|
|
# 1- unique number (digits only)
|
|
# 2- date
|
|
# 3- time
|
|
# 4- CID arecode
|
|
# 5- CID full
|
|
# 6- DID
|
|
# 7- user
|
|
# 8- hold time (seconds)
|
|
# 9- talk time (seconds)
|
|
# 10- after call work time (seconds)
|
|
# 11- application name, 4 characters
|
|
# 12- order number (just a dash for now '-')
|
|
# 13- call recording filenames
|
|
|
|
$uniqueid =~ s/\.00000//gi;
|
|
$uniqueid =~ s/\.0000//gi;
|
|
$uniqueid =~ s/\.000//gi;
|
|
$uniqueid =~ s/\.00//gi;
|
|
$uniqueid =~ s/\.0//gi;
|
|
$uniqueid =~ s/\D//gi;
|
|
@call_date_array = split(/ /,$call_date);
|
|
while (length($phone_number)>10) {$phone_number =~ s/^.//gi;}
|
|
$phone_areacode = substr($phone_number, 0, 3);
|
|
if (length($closer) < 1) {$closer = $user;}
|
|
if ($closer =~ /VDCL|VDAD/) {$closer='-';}
|
|
$application = substr($did_name, 0, 4);
|
|
$queue_seconds = int($queue_seconds + .5);
|
|
$talk_seconds = ( ($length_in_sec - $queue_seconds) - $agent_alert_delay);
|
|
if ($talk_seconds < 0) {$talk_seconds=0;}
|
|
$dispo_time = 0;
|
|
|
|
if ($uniqueidLIST !~ /\|$uniqueid\|/)
|
|
{
|
|
$str = "103$uniqueid\t$call_date_array[0]\t$call_date_array[1]\t$phone_areacode\t$phone_number\t$did_pattern\t$closer\t$queue_seconds\t$talk_seconds\t$dispo_time\t$application\t-\t$ivr_filename\t$outbound\t$domestic\t\n";
|
|
|
|
$uniqueidLIST .= "$uniqueid|";
|
|
if ($DBX > 0) {print "UNIQUE: -----$uniqueidLIST-----$uniqueid";}
|
|
# if ($DBX > 0) {print "$uniqueid|$talk_seconds|$outbound|$INcalls|$OUTcalls\n";}
|
|
|
|
if ($outbound =~ /Y/) {$OUTtalk = ($OUTtalk + $talk_seconds); $OUTcalls++;}
|
|
else {$INtalk = ($INtalk + $talk_seconds); $INcalls++;}
|
|
}
|
|
|
|
}
|
|
|
|
$Ealert .= "$str";
|
|
|
|
print out "$str";
|
|
if ($DBX) {print "$str\n";}
|
|
}
|
|
else
|
|
{$CALLTIME_KICK++;}
|
|
|
|
if ($DB > 0)
|
|
{
|
|
if ($rec_count =~ /10$/i) {print STDERR "0 $rec_count\r";}
|
|
if ($rec_count =~ /20$/i) {print STDERR "+ $rec_count\r";}
|
|
if ($rec_count =~ /30$/i) {print STDERR "| $rec_count\r";}
|
|
if ($rec_count =~ /40$/i) {print STDERR "\\ $rec_count\r";}
|
|
if ($rec_count =~ /50$/i) {print STDERR "- $rec_count\r";}
|
|
if ($rec_count =~ /60$/i) {print STDERR "/ $rec_count\r";}
|
|
if ($rec_count =~ /70$/i) {print STDERR "| $rec_count\r";}
|
|
if ($rec_count =~ /80$/i) {print STDERR "+ $rec_count\r";}
|
|
if ($rec_count =~ /90$/i) {print STDERR "0 $rec_count\r";}
|
|
if ($rec_count =~ /00$/i) {print "$rec_count|$TOTAL_SALES|$CALLTIME_KICK| |$phone_number|\n";}
|
|
}
|
|
$rec_count++;
|
|
|
|
}
|
|
|