ViciDial/ViciDialSVN
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added the AST_lead_select_export.pl script

Browse Source 
git-svn-id: svn://192.168.202.10@2991 3d104415-ff17-0410-8863-d5cf3c621b8a
This commit is contained in:
mattf
2018-05-24 03:25:15 +00:00
parent 79c8cf8e03
commit 708d15fb33
1 changed files with 743 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
agc_2-X/trunk/bin/AST_lead_select_export.pl
+743
View File
@@ -0,0 +1,743 @@
#!/usr/bin/perl
#
# AST_lead_select_export.pl version: 2.14
#
# This script is designed to gather selected status lead data from call logs and
# dump into a tab-delimited text file
#
# /usr/share/astguiclient/AST_lead_select_export.pl --ingroups=---ALL--- --start-date=2016-01-01 --end-date=2016-06-30 --debug
#
# Copyright (C) 2018 Matt Florell <vicidial@gmail.com> LICENSE: AGPLv2
#
# CHANGES
# 180523-2005 - First version based upon AST_inbound_export.pl
#
$txt = '.txt';
$US = '_';
$MT[0] = '';
$Q=0;
$DB=0;
$use_archives=0;
$leadidLIST='|';
# default CLI values
$campaign = 'TESTCAMP';
$sale_statuses = 'SALE-UPSELL';
$outbound_calltime_ignore=0;
$totals_only=0;
$OUTcalls=0;
$OUTtalk=0;
$OUTtalkmin=0;
$INcalls=0;
$INtalk=0;
$INtalkmin=0;
$email_post_audio=0;
$did_only=0;
$vicidial_closer_log='vicidial_closer_log';
$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";}
$shipdate = "$year-$mon-$mday";
$shipdate_end = "$year-$mon-$mday";
$start_date = "$year$mon$mday";
$end_date = "$year$mon$mday";
$file_date = "$year$mon$mday-$hour$min$sec";
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";}
# 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
### 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 " [--start-date=YYYY-MM-DD] = Use date as the start\n";
print " [--end-date=YYYY-MM-DD] = For more than one day, use start-date as the start\n";
print " [--ingroups=XXX-YYY] = In-groups that sales will be pulled from. for all use ---ALL---. REQUIRED\n";
print " [--campaigns=XXX-YYY] = campaigns that sales will be pulled from. for all use ---ALL---. REQUIRED\n";
print " [--statusess=XXX-YYY] = statuses that will be pulled. for all use ---ALL---. REQUIRED\n";
print " [--temp-dir=XXX] = If running more than one instance at a time, specify a unique temp directory suffix\n";
print " [--archive] = also look in archive tables\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 =~ /--archive/i)
{
$use_archives=1;
if (!$Q) {print "\n----- ARCHIVE TABLES: ($use_archives) -----\n\n";}
}
if ($args =~ /--ingroups=/i)
{
# print "\n|$ARGS|\n\n";
@data_in = split(/--ingroups=/,$args);
$ingroups = $data_in[1];
$ingroups =~ s/ .*$//gi;
$ingroupsSQL = $ingroups;
if ($ingroupsSQL =~ /--ALL--/)
{
$ingroupsSQL='';
}
else
{
if ($ingroupsSQL =~ /-/)
{
$ingroupsSQL =~ s/-/','/gi;
}
$ingroupsSQL = "and campaign_id IN('$ingroupsSQL')";
}
}
else
{
print "no ingroups defined, exiting.\n";
exit;
}
if ($args =~ /--campaigns=/i)
{
# print "\n|$ARGS|\n\n";
@data_in = split(/--campaigns=/,$args);
$campaigns = $data_in[1];
$campaigns =~ s/ .*$//gi;
$campaignsSQL = $campaigns;
if ($campaignsSQL =~ /--ALL--/)
{
$campaignsSQL='';
}
else
{
if ($campaignsSQL =~ /-/)
{
$campaignsSQL =~ s/-/','/gi;
}
$campaignsSQL = "and campaign_id IN('$campaignsSQL')";
}
}
else
{
print "no campaigns defined, exiting.\n";
exit;
}
if ($args =~ /--statuses=/i)
{
# print "\n|$ARGS|\n\n";
@data_in = split(/--statuses=/,$args);
$statuses = $data_in[1];
$statuses =~ s/ .*$//gi;
$statusesSQL = $statuses;
if ($statusesSQL =~ /--ALL--/)
{
$statusesSQL='';
}
else
{
if ($statusesSQL =~ /-/)
{
$statusesSQL =~ s/-/','/gi;
}
$statusesSQL = "and status IN('$statusesSQL')";
}
}
else
{
print "no statuses defined, exiting.\n";
exit;
}
if ($args =~ /--start-date=/i)
{
@data_in = split(/--start-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]);
}
}
$start_date = $shipdate;
$start_date =~ s/-//gi;
if (!$Q) {print "\n----- DATE OVERRIDE: $shipdate($start_date) -----\n\n";}
}
if ($args =~ /--end-date=/i)
{
@data_in = split(/--end-date=/,$args);
$shipdate_end = $data_in[1];
$shipdate_end =~ s/ .*//gi;
if ($shipdate_end =~ /today/)
{
$shipdate_end="$year-$mon-$mday";
$time = $TWOAMsec;
}
else
{
if ($shipdate_end =~ /yesterday/)
{
$shipdate_end="$Tyear-$Tmon-$Tmday";
$year = $Tyear;
$mon = $Tmon;
$mday = $Tmday;
$time=$TWOAMsecY;
}
else
{
@cli_date = split("-",$shipdate_end);
$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]);
}
}
$end_date = $shipdate_end;
$end_date =~ s/-//gi;
if (!$Q) {print "\n----- END DATE OVERRIDE: $shipdate_end($end_date) -----\n\n";}
}
else
{
$shipdate_end = $shipdate;
$end_date = $start_date;
}
if ($args =~ /--test/i)
{
$T=1; $TEST=1;
print "\n----- TESTING -----\n\n";
}
}
}
else
{
print "no command line options set, exiting.\n";
exit;
}
### end parsing run-time options ###
if (length($ingroups) < 1)
{
print "no ingroups defined, exiting...";
exit;
}
if (!$Q)
{
print "\n\n\n\n\n\n\n\n\n\n\n\n-- AST_lead_select_export.pl --\n\n";
print "This script is designed to gather selected status lead data from call logs and dump into a tab-delimited text file. \n";
print "\n";
print "Ingroups: $ingroups $ingroupsSQL \n";
print "Campaigns: $campaigns $campaignsSQL \n";
print "Statuses: $statuses $statusesSQL \n";
print "Start Date: $shipdate \n";
print "End Date: $shipdate_end \n";
print "\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_CALLS=0;
$TOTAL_LEADS=0;
$SKIP_CALL=0;
$SKIP_LEAD=0;
$header_data = "LOG_lead_id\tLOG_call_date\tLOG_length_in_sec\tLOG_phone_number\tLOG_status\tLOG_user\tLOG_campaign_id\tLOG_list_id\tentry_date\tuser\tvendor_lead_code\tsource_id\tlist_id\tgmt_offset_now\ttitle\tfirst_name\tmiddle_initial\tlast_name\taddress1\taddress2\taddress3\tcity\tstate\tprovince\tpostal_code\tcountry_code\tgender\tdate_of_birth\talt_phone\temail\tsecurity_phrase\tcomments\tcalled_count\tlast_local_call_time\trank\towner\tentry_list_id\tcustom_fields_data\t";
open(Sout, ">>$PATHhome/LEAD_SELECT_EXPORT_$file_date$US$ingroups.txt")
|| die "Can't open LEAD_SELECT_EXPORT_$file_date$US$ingroups.txt: $!\n";
print Sout "$header_data\n";
close(Sout);
if (!$Q) {print "Starting pull of Inbound calls:\n";}
###########################################################################
########### CALL LOG GATHERING inbound vicidial_closer_log ######
###########################################################################
$stmtA = "SELECT lead_id,call_date,length_in_sec,phone_number,status,user,campaign_id,list_id from vicidial_closer_log where call_date >= \"$shipdate 00:00:00\" and call_date <= \"$shipdate_end 23:59:59\" $ingroupsSQL $statusesSQL;";
$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;
$L_lead_id = $aryA[0];
$L_call_date = $aryA[1];
$L_length_in_sec = $aryA[2];
$L_phone_number = $aryA[3];
$L_status = $aryA[4];
$L_user = $aryA[5];
$L_campaign_id = $aryA[6];
$L_list_id = $aryA[7];
if ($leadidLIST !~ /\|$L_lead_id\|/)
{
$leadidLIST .= "$L_lead_id|";
&select_format_loop;
$TOTAL_CALLS++;
}
else
{
$SKIP_CALL++;
}
$rec_count++;
}
$sthA->finish();
if ($use_archives > 0)
{
if (!$Q) {print "Starting pull of Inbound Archive calls:\n";}
###########################################################################
########### Inbound CALL LOG GATHERING inbound vicidial_closer_log_archive ######
###########################################################################
$stmtA = "SELECT lead_id,call_date,length_in_sec,phone_number,status,user,campaign_id,list_id from vicidial_closer_log_archive where call_date >= \"$shipdate 00:00:00\" and call_date <= \"$shipdate_end 23:59:59\" $ingroupsSQL $statusesSQL;";
$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;
$L_lead_id = $aryA[0];
$L_call_date = $aryA[1];
$L_length_in_sec = $aryA[2];
$L_phone_number = $aryA[3];
$L_status = $aryA[4];
$L_user = $aryA[5];
$L_campaign_id = $aryA[6];
$L_list_id = $aryA[7];
if ($leadidLIST !~ /\|$L_lead_id\|/)
{
$leadidLIST .= "$L_lead_id|";
&select_format_loop;
$TOTAL_CALLS++;
}
else
{
$SKIP_CALL++;
}
$rec_count++;
}
$sthA->finish();
}
if (!$Q) {print "Starting pull of Outbound calls:\n";}
###########################################################################
########### Outbound CALL LOG GATHERING inbound vicidial_log ######
###########################################################################
$stmtA = "SELECT lead_id,call_date,length_in_sec,phone_number,status,user,campaign_id,list_id from vicidial_log where call_date >= \"$shipdate 00:00:00\" and call_date <= \"$shipdate_end 23:59:59\" $campaignsSQL $statusesSQL;";
$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;
$L_lead_id = $aryA[0];
$L_call_date = $aryA[1];
$L_length_in_sec = $aryA[2];
$L_phone_number = $aryA[3];
$L_status = $aryA[4];
$L_user = $aryA[5];
$L_campaign_id = $aryA[6];
$L_list_id = $aryA[7];
if ($leadidLIST !~ /\|$L_lead_id\|/)
{
$leadidLIST .= "$L_lead_id|";
&select_format_loop;
$TOTAL_CALLS++;
}
else
{
$SKIP_CALL++;
}
$rec_count++;
}
$sthA->finish();
if ($use_archives > 0)
{
if (!$Q) {print "Starting pull of Outbound Archive calls:\n";}
###########################################################################
########### Outbound CALL LOG GATHERING inbound vicidial_log_archive ######
###########################################################################
$stmtA = "SELECT lead_id,call_date,length_in_sec,phone_number,status,user,campaign_id,list_id from vicidial_log_archive where call_date >= \"$shipdate 00:00:00\" and call_date <= \"$shipdate_end 23:59:59\" $campaignsSQL $statusesSQL;";
$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;
$L_lead_id = $aryA[0];
$L_call_date = $aryA[1];
$L_length_in_sec = $aryA[2];
$L_phone_number = $aryA[3];
$L_status = $aryA[4];
$L_user = $aryA[5];
$L_campaign_id = $aryA[6];
$L_list_id = $aryA[7];
if ($leadidLIST !~ /\|$L_lead_id\|/)
{
$leadidLIST .= "$L_lead_id|";
&select_format_loop;
$TOTAL_CALLS++;
}
else
{
$SKIP_CALL++;
}
$rec_count++;
}
$sthA->finish();
}
### calculate time to run script ###
$secY = time();
$secZ = ($secY - $secX);
$secZm = ($secZ /60);
if (!$Q) {print "SALES EXPORT FOR $ingroups ($PATHhome/LEAD_SELECT_EXPORT_$file_date$US$ingroups.txt)\n";}
if (!$Q) {print "Total records scanned: $rec_count\n";}
if (!$Q) {print "TOTAL CALLS: $TOTAL_CALLS\n";}
if (!$Q) {print "TOTAL LEADS: $TOTAL_LEADS\n";}
if (!$Q) {print "SKIPPED RECORDS: $SKIP_LEAD\n";}
if (!$Q) {print "script execution time in seconds: $secZ minutes: $secZm\n";}
### Subroutine for formatting of the output ###
sub select_format_loop
{
$str='';
$entry_date='';
$user='';
$vendor_lead_code='';
$source_id='';
$list_id='';
$gmt_offset_now='';
$title='';
$first_name='';
$middle_initial='';
$last_name='';
$address1='';
$address2='';
$address3='';
$city='';
$state='';
$province='';
$postal_code='';
$country_code='';
$gender='';
$date_of_birth='';
$alt_phone='';
$email='';
$security_phrase='';
$comments='';
$called_count='';
$last_local_call_time='';
$rank='';
$owner='';
$entry_list_id='';
$stmtB = "SELECT entry_date,user,vendor_lead_code,source_id,list_id,gmt_offset_now,title,first_name,middle_initial,last_name,address1,address2,address3,city,state,province,postal_code,country_code,gender,date_of_birth,alt_phone,email,security_phrase,comments,called_count,last_local_call_time,rank,owner,entry_list_id from vicidial_list where lead_id=$L_lead_id;";
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
$sthBrows=$sthB->rows;
if ($DBX) {print "$sthBrows|$stmtB|\n";}
if ($sthBrows > 0)
{
@aryB = $sthB->fetchrow_array;
$entry_date = $aryB[0];
$user = $aryB[1];
$vendor_lead_code = $aryB[2];
$source_id = $aryB[3];
$list_id = $aryB[4];
$gmt_offset_now = $aryB[5];
$title = $aryB[6];
$first_name = $aryB[7];
$middle_initial = $aryB[8];
$last_name = $aryB[9];
$address1 = $aryB[10];
$address2 = $aryB[11];
$address3 = $aryB[12];
$city = $aryB[13];
$state = $aryB[14];
$province = $aryB[15];
$postal_code = $aryB[16];
$country_code = $aryB[17];
$gender = $aryB[18];
$date_of_birth = $aryB[19];
$alt_phone = $aryB[20];
$email = $aryB[21];
$security_phrase = $aryB[22];
$comments = $aryB[23];
$called_count = $aryB[24];
$last_local_call_time = $aryB[25];
$rank = $aryB[26];
$owner = $aryB[27];
$entry_list_id = $aryB[28];
$TOTAL_LEADS++;
}
$sthB->finish();
$call_data = "$L_lead_id\t$L_call_date\t$L_length_in_sec\t$L_phone_number\t$L_status\t$L_user\t$L_campaign_id\t$L_list_id\t$entry_date\t$user\t$vendor_lead_code\t$source_id\t$list_id\t$gmt_offset_now\t$title\t$first_name\t$middle_initial\t$last_name\t$address1\t$address2\t$address3\t$city\t$state\t$province\t$postal_code\t$country_code\t$gender\t$date_of_birth\t$alt_phone\t$email\t$security_phrase\t$comments\t$called_count\t$last_local_call_time\t$rank\t$owner\t$entry_list_id\t";
##### BEGIN check for custom fields data #####
$custom_data = '';
$custom_columns = '';
if ( (length($entry_list_id) > 1 ) && ($entry_list_id >= 99) )
{
$stmtB = "SHOW TABLES LIKE \"custom_$entry_list_id\";";
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
$sthBcustrows=$sthB->rows;
if ($DBX) {print "$sthBcustrows|$stmtB|\n";}
$sthB->finish();
if ($sthBcustrows > 0)
{
$stmtB = "describe custom_$entry_list_id;";
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
$sthBcolrows=$sthB->rows;
if ($DBX) {print "$sthBcolrows|$stmtB|\n";}
$col_ct=0;
while ($sthBcolrows > $col_ct)
{
@aryB = $sthB->fetchrow_array;
$column_label = $aryB[0];
$columns[$col_ct] = $aryB[0];
if ($col_ct > 0)
{$custom_columns .= "$column_label,";}
$col_ct++;
}
$sthB->finish();
$custom_columns =~ s/,$//gi;
if ($col_ct > 0)
{
$stmtB = "SELECT $custom_columns from custom_$entry_list_id where lead_id=$L_lead_id;";
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
$sthBrows=$sthB->rows;
if ($DBX) {print "$sthBrows|$stmtB|\n";}
$rec_countB=0;
while ($sthBrows > $rec_countB)
{
@aryB = $sthB->fetchrow_array;
$field_ct=1;
while ($col_ct > $field_ct)
{
$custom_data .= "\t$columns[$field_ct]: $aryB[$field_ct]";
$field_ct++;
}
$rec_countB++;
if (length($custom_data) > 0)
{
if ($DBX) {print "Custom data for $L_lead_id found in $entry_list_id: |$custom_data|\n";}
$call_data .= "$custom_data";
$TOTAL_CUSTOM++;
}
}
$sthB->finish();
}
}
}
##### END custom field data lookup #####
$Ealert .= "$TOTAL_LEADS $rec_countB $call_data\n";
if ($DBX) {print "$TOTAL_LEADS $rec_countB $call_data\n";}
open(Sout, ">>$PATHhome/LEAD_SELECT_EXPORT_$file_date$US$ingroups.txt")
|| die "Can't open LEAD_SELECT_EXPORT_$file_date$US$ingroups.txt: $!\n";
print Sout "$call_data\n";
close(Sout);
if ($DB > 0)
{
if ($rec_count =~ /100$/i) {print STDERR " G*THER $rec_count\r";}
if ($rec_count =~ /200$/i) {print STDERR " GA*HER $rec_count\r";}
if ($rec_count =~ /300$/i) {print STDERR " GAT*ER $rec_count\r";}
if ($rec_count =~ /400$/i) {print STDERR " GATH*R $rec_count\r";}
if ($rec_count =~ /500$/i) {print STDERR " GATHE* $rec_count\r";}
if ($rec_count =~ /600$/i) {print STDERR " GATH*R $rec_count\r";}
if ($rec_count =~ /700$/i) {print STDERR " GAT*ER $rec_count\r";}
if ($rec_count =~ /800$/i) {print STDERR " GA*HER $rec_count\r";}
if ($rec_count =~ /900$/i) {print STDERR " G*THER $rec_count\r";}
if ($rec_count =~ /000$/i) {print STDERR " *ATHER $rec_count\r";}
if ($rec_count =~ /000$/i) {print " |$rec_count|$TOTAL_LEADS| |$L_lead_id|\n";}
}
}
exit;
# if ($DB > 0)
# {
# if ($rec_count =~ /10$/i) {print STDERR " * $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 " * $rec_count\r";}
# if ($rec_count =~ /00$/i) {print STDERR " * $rec_count\r";}
# if ($rec_count =~ /00$/i) {print " |$rec_count|$TOTAL_SALES|$CALLTIME_KICK|$TOTAL_RECORDINGS| |$L_lead_id|\n";}
# }