#!/usr/bin/perl
#
# AST_VDauto_dial_FILL.pl version 2.14
#
# DESCRIPTION:
# Places auto_dial calls on the VICIDIAL dialer system across all servers only 
# for campaigns that have a shortfall in number of lines dialed.
#
# Script needs to be started by ADMIN_keepalive_ALL.pl script (option 7)
#
# Not for use in systems with only one Asterisk/VICIDIAL server
#
# Should only be run on one server in a multi-server Asterisk/VICIDIAL cluster
#
# Copyright (C) 2026  Matt Florell <vicidial@gmail.com>    LICENSE: AGPLv2
#
# CHANGELOG:
# 61115-1246 - First build, framework setup, non-functional
# 61120-2008 - second alpha version, functional and tested in production
# 70205-1425 - Added code for last called date update
# 71030-2054 - Added hopper priority sorting
# 71111-2349 - fixed overdialing bug
# 80227-0406 - fixed auto-alt-dial and added queue_priority
# 80713-0624 - Added vicidial_list_last_local_call_time field
# 80831-0400 - Added new alt-dial options
# 81210-1938 - Fixed callerIDnumber bug
# 90306-1844 - Added configurable calls-per-second option
# 90729-0611 - Added vicidial_balance_rank option
# 90924-1519 - Added List callerid override option
# 100205-1245 - Added optional stagger sending of calls across all available servers in each rank
# 100903-0041 - Changed lead_id max length to 10 digits
# 101207-0713 - Added more info to Originate for rare VDAC issue
# 110901-1127 - Added campaign areacode cid function
# 110922-1203 - Added logging of last calltime to campaign
# 120831-1502 - Added vicidial_dial_log outbound call logging
# 130227-1604 - Cleanup of staggered code, resetting of variables and arrays
# 130706-2024 - Added disable_auto_dial system option
# 131016-0658 - Fix for disable_auto_dial system option
# 131122-1237 - Formatting fixes and missing sthA->finish
# 151006-0937 - Changed campaign_cid_areacodes to operate with 2-5 digit areacodes
# 170915-1915 - Added support for per server routing prefix needed for Asterisk 13+
# 171205-2022 - Fix for double-dialing issue on high-volume systems
# 180214-1558 - Added CID Group functionality
# 180812-1025 - Added code for scheduled_callbacks_auto_reschedule campaign feature
# 180910-1759 - Small fix for data validation
# 191108-1023 - Added Dial Timeout Lead override function
# 200108-1314 - Added CID Group type of NONE
# 200122-1850 - Added code for CID Group auto-rotate feature
# 201122-0932 - Added code for dialy call count limits
# 201220-1034 - Changes for shared agent campaigns
# 210715-1335 - Added call_limit_24hour feature support, also fix for variable issue
# 210731-0951 - Added cid_group_id_two campaign option
# 220311-1922 - Added List CID Group Override option
# 220623-1622 - Added List dial_prefix override
# 230830-1056 - Changed outbound_calls_per_second max to allow up to 1000 CPS
# 231116-0916 - Added hopper_hold_inserts option
# 231129-0905 - Added vicidial_phone_number_call_daily_counts updates/inserts
# 260515-1941 - Added internal logging
#

### begin parsing run-time options ###
if (length($ARGV[0])>1)
	{
	$i=0;
	while ($#ARGV >= $i)
		{
		$args = "$args $ARGV[$i]";
		$i++;
		}

	if ($args =~ /--help/i)
		{
		print "allowed run time options:\n";
		print "  [--help] = this screen\n";
		print "  [--test] = test\n";
		print "  [--debug] = verbose debug messages\n";
		print "  [--staggered] = experimental staggering of placing calls on large multi-server systems\n";
		print "  [--delay=XXX] = delay of XXX seconds per loop, default 2.5 seconds\n";
		print "\n";
		exit;
		}
	else
		{
		if ($args =~ /-debug/i)
			{
			$DB=1; # Debug flag, set to 0 for no debug messages
			print "\n-- DEBUG --\n\n";
			}
		if ($args =~ /--test/i)
			{
			$TEST=1;
			$T=1;
			}
		if ($args =~ /-staggered/i) 
			{
			$staggered=1;
			print "\n-- STAGGERED MULTI-SERVER DIAL MODE --\n\n";
			}
		else
			{$staggered=0;}
		if ($args =~ /--delay=/i)
			{
			@data_in = split(/--delay=/,$args);
			$loop_delay = $data_in[1];
			print "     LOOP DELAY OVERRIDE!!!!! = $loop_delay seconds\n\n";
			$loop_delay = ($loop_delay * 1000);
			}
		else
			{
			$loop_delay = '2500';
			}
		}
	}
else
	{
	print "no command line options set\n";
	$loop_delay = '2500';
	$DB=1;
	}
### end parsing run-time options ###


# constants
$US='__';
$MT[0]='';
$RECcount=''; ### leave blank for no REC count
$RECprefix='7'; ### leave blank for no REC prefix
$script_name = 'AST_VDauto_dial_FILL.pl';


# default path to astguiclient configuration file:
$PATHconf =	'/etc/astguiclient.conf';

open(conf, "$PATHconf") || die "can't open $PATHconf: $!\n";
@conf = <conf>;
close(conf);
$i=0;
foreach(@conf)
	{
	$line = $conf[$i];
	$line =~ s/ |>|\n|\r|\t|\#.*|;.*//gi;
	if ( ($line =~ /^PATHhome/) && ($CLIhome < 1) )
		{$PATHhome = $line;   $PATHhome =~ s/.*=//gi;}
	if ( ($line =~ /^PATHlogs/) && ($CLIlogs < 1) )
		{$PATHlogs = $line;   $PATHlogs =~ s/.*=//gi;}
	if ( ($line =~ /^PATHagi/) && ($CLIagi < 1) )
		{$PATHagi = $line;   $PATHagi =~ s/.*=//gi;}
	if ( ($line =~ /^PATHweb/) && ($CLIweb < 1) )
		{$PATHweb = $line;   $PATHweb =~ s/.*=//gi;}
	if ( ($line =~ /^PATHsounds/) && ($CLIsounds < 1) )
		{$PATHsounds = $line;   $PATHsounds =~ s/.*=//gi;}
	if ( ($line =~ /^PATHmonitor/) && ($CLImonitor < 1) )
		{$PATHmonitor = $line;   $PATHmonitor =~ s/.*=//gi;}
	if ( ($line =~ /^VARserver_ip/) && ($CLIserver_ip < 1) )
		{$VARserver_ip = $line;   $VARserver_ip =~ s/.*=//gi;}
	if ( ($line =~ /^VARDB_server/) && ($CLIDB_server < 1) )
		{$VARDB_server = $line;   $VARDB_server =~ s/.*=//gi;}
	if ( ($line =~ /^VARDB_database/) && ($CLIDB_database < 1) )
		{$VARDB_database = $line;   $VARDB_database =~ s/.*=//gi;}
	if ( ($line =~ /^VARDB_user/) && ($CLIDB_user < 1) )
		{$VARDB_user = $line;   $VARDB_user =~ s/.*=//gi;}
	if ( ($line =~ /^VARDB_pass/) && ($CLIDB_pass < 1) )
		{$VARDB_pass = $line;   $VARDB_pass =~ s/.*=//gi;}
	if ( ($line =~ /^VARDB_port/) && ($CLIDB_port < 1) )
		{$VARDB_port = $line;   $VARDB_port =~ s/.*=//gi;}
	$i++;
	}

# Customized Variables
$server_ip = $VARserver_ip;		# Asterisk server IP

if (!$VARDB_port) {$VARDB_port='3306';}

&get_time_now;	# update time/date variables

if (!$VDADLOGfile) {$VDADLOGfile = "$PATHlogs/vdautodial_FILL.$year-$mon-$mday";}

use Time::HiRes ('gettimeofday','usleep','sleep');  # necessary to have perl sleep command of less than one second
use DBI;
	
### connect to MySQL database defined in the conf file
$dbhA = DBI->connect("DBI:mysql:$VARDB_database:$VARDB_server:$VARDB_port", "$VARDB_user", "$VARDB_pass")
or die "Couldn't connect to database: " . DBI->errstr;

$action='start';   $stage='LOGGED INTO MYSQL SERVER';   &internal_logger;

### Grab Server values from the database
$stmtA = "SELECT telnet_host,telnet_port,ASTmgrUSERNAME,ASTmgrSECRET,ASTmgrUSERNAMEupdate,ASTmgrUSERNAMElisten,ASTmgrUSERNAMEsend,max_vicidial_trunks,answer_transfer_agent,local_gmt,ext_context,vd_server_logs FROM servers where server_ip = '$server_ip';";
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
$sthArows=$sthA->rows;
if ($sthArows > 0)
	{
	@aryA = $sthA->fetchrow_array;
	$DBtelnet_host	=			$aryA[0];
	$DBtelnet_port	=			$aryA[1];
	$DBASTmgrUSERNAME	=		$aryA[2];
	$DBASTmgrSECRET	=			$aryA[3];
	$DBASTmgrUSERNAMEupdate	=	$aryA[4];
	$DBASTmgrUSERNAMElisten	=	$aryA[5];
	$DBASTmgrUSERNAMEsend	=	$aryA[6];
	$DBmax_vicidial_trunks	=	$aryA[7];
	$DBanswer_transfer_agent=	$aryA[8];
	$DBSERVER_GMT		=		$aryA[9];
	$DBext_context	=			$aryA[10];
	$DBvd_server_logs =			$aryA[11];
	if ($DBtelnet_host)				{$telnet_host = $DBtelnet_host;}
	if ($DBtelnet_port)				{$telnet_port = $DBtelnet_port;}
	if ($DBASTmgrUSERNAME)			{$ASTmgrUSERNAME = $DBASTmgrUSERNAME;}
	if ($DBASTmgrSECRET)			{$ASTmgrSECRET = $DBASTmgrSECRET;}
	if ($DBASTmgrUSERNAMEupdate)	{$ASTmgrUSERNAMEupdate = $DBASTmgrUSERNAMEupdate;}
	if ($DBASTmgrUSERNAMElisten)	{$ASTmgrUSERNAMElisten = $DBASTmgrUSERNAMElisten;}
	if ($DBASTmgrUSERNAMEsend)		{$ASTmgrUSERNAMEsend = $DBASTmgrUSERNAMEsend;}
	if ($DBmax_vicidial_trunks)		{$max_vicidial_trunks = $DBmax_vicidial_trunks;}
	if ($DBanswer_transfer_agent)	{$answer_transfer_agent = $DBanswer_transfer_agent;}
	if ($DBSERVER_GMT)				{$SERVER_GMT = $DBSERVER_GMT;}
	if ($DBext_context)				{$ext_context = $DBext_context;}
	if ($DBvd_server_logs =~ /Y/)	{$SYSLOG = '1';}
	else {$SYSLOG = '0';}
	}
$sthA->finish();

$event_string='LOGGED INTO MYSQL SERVER ON 1 CONNECTION|';
&event_logger;

### Grab system_settings values from the database
$stmtA = "SELECT use_non_latin,call_limit_24hour,hopper_hold_inserts FROM system_settings;";
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
$sthArows=$sthA->rows;
if ($sthArows > 0)
	{
	@aryA = $sthA->fetchrow_array;
	$non_latin = 						$aryA[0];
	$SScall_limit_24hour =				$aryA[1];
	$SShopper_hold_inserts =			$aryA[2];
	}
$sthA->finish();

if ($non_latin > 0) 
	{
	$stmtA = "SET NAMES 'UTF8';";
	$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
	$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
	$sthA->finish();
	}

$iLog_ct=0;
$one_day_interval = 12;		# 1 month loops for one year 
while($one_day_interval > 0)
	{
	$endless_loop=5760000;		# 30 days minutes at XXX seconds per loop
	$stat_count=1;

	while($endless_loop > 0)
		{
		&get_time_now;

		$VDADLOGfile = "$PATHlogs/vdautodial_FILL.$year-$mon-$mday";

		###############################################################################
		###### first figure out how many calls should be placed for each campaign per server
		###############################################################################
		@DBfill_campaign=@MT;
		@DBfill_shortage=@MT;
		@DBfill_tally=@MT;
		@DBfill_needed=@MT;
		@DBfill_current_balance=@MT;
		@DBlive_campaign=@MT;
		@DBlive_conf_exten=@MT;
		@DBlive_status=@MT;
		@DBcampaigns=@MT;
		@DBIPaddress=@MT;
		@DBIPcampaign=@MT;
		@DBIPactive=@MT;
		@DBIPvdadexten=@MT;
		@DBIPcount=@MT;
		@DBIPACTIVEcount=@MT;
		@DBIPINCALLcount=@MT;
		@DBIPadlevel=@MT;
		@DBIPdialtimeout=@MT;
		@DBIPdialprefix=@MT;
		@DBIPcampaigncid=@MT;
		@DBIPexistcalls=@MT;
		@DBIPgoalcalls=@MT;
		@DBIPmakecalls=@MT;
		@DBIPlivecalls=@MT;
		@DBIPclosercamp=@MT;
		@DBIPomitcode=@MT;
		@DBIPtrunk_shortage=@MT;
		@DBIPold_trunk_shortage=@MT;
		@DBIPserver_trunks_limit=@MT;
		@DBIPserver_trunks_other=@MT;
		@DBIPserver_trunks_allowed=@MT;
		@DBIPqueue_priority=@MT;
		@DBIPuse_custom_cid=@MT;
		@DBIPcid_group_id=@MT;
		@DBIPcid_group_id_two=@MT;

		$active_line_counter=0;
		$camp_counter=0;
		$total_shortage=0;
		$balance_servers=0;
		$lists_update = '';
		$LUcount=0;
		$staggered_ct=0;

		$stmtA = "SELECT count(*) FROM servers where vicidial_balance_active = 'Y';";
		$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
		$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
		$sthArows=$sthA->rows;
		if ($sthArows > 0)
			{
			@aryA = $sthA->fetchrow_array;
			$balance_servers =	$aryA[0];
			}
		$sthA->finish();

		##### Get a listing of the campaigns that have shortages of trunks
		$stmtA = "SELECT campaign_id,sum(local_trunk_shortage) FROM vicidial_campaign_server_stats where update_time > '$XDSQLdate' and local_trunk_shortage > 0 group by campaign_id;";
		$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;
			$DBfill_campaign[$camp_counter] =	$aryA[0];
			$DBfill_shortage[$camp_counter] =	$aryA[1];
			$total_shortage = ($total_shortage + $aryA[1]);
			if($DB) {print "$DBfill_campaign[$camp_counter]: $DBfill_shortage[$camp_counter]\n";}

			$camp_counter++;
			$rec_count++;
			}
		$sthA->finish();

		##### Get maximum calls per second that this process can send out
		$stmtA = "SELECT outbound_calls_per_second,outbound_autodial_active,disable_auto_dial FROM system_settings;";
		$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
		$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
		$sthArows=$sthA->rows;
		if ($sthArows > 0)
			{
			@aryA = $sthA->fetchrow_array;
			$outbound_calls_per_second =	$aryA[0];
			$outbound_autodial_active =		$aryA[1];
			$disable_auto_dial =			$aryA[2];
			}
		$sthA->finish();

		if ( ($outbound_calls_per_second > 0) && ($outbound_calls_per_second < 1001) )
			{$per_call_delay = (1000 / $outbound_calls_per_second);}
		else
			{$per_call_delay = '25';}

		$event_string ="SERVER CALLS PER SECOND MAXIMUM SET TO: $outbound_calls_per_second |$per_call_delay|\n";
		$event_string.="SERVERS WITH TRUNK BALANCE: $balance_servers\n";
		$event_string.="CAMPAIGNS WITH TRUNK SHORTAGE: $camp_counter| TOTAL SHORTAGE: $total_shortage";
		&event_logger;

		if (($outbound_autodial_active < 1) || ($disable_auto_dial > 0) )
			{
			$event_string="SYSTEM AUTO-DIAL DISABLED, NO DIALING: |$outbound_autodial_active|$disable_auto_dial|";
			&event_logger;
			}
		else
			{
			##################################################################################
			##### START LOOP IF THERE ARE BALANCE SERVERS AND THERE ARE SHORTAGES
			##################################################################################
			if ( ($balance_servers > 0) && ($camp_counter > 0) )
				{
				$camp_CIPct = 0;
				foreach(@DBfill_campaign)
					{
					$calls_placed=0;
					$camp_counter=0;
					$DB_balance_fill=0;
					$VAC_balance_fill=0;
					$AVAIL_balance_servers=0;
					$DBfill_tally[$camp_CIPct]=0;

					### grab the dial_level and multiply by active agents to get your goalcalls
					$DBIPadlevel[$camp_CIPct]=0;
					$stmtA = "SELECT dial_timeout,dial_prefix,campaign_cid,active,campaign_vdad_exten,omit_phone_code,auto_alt_dial,queue_priority,use_custom_cid,cid_group_id,scheduled_callbacks_auto_reschedule,dial_timeout_lead_container,cid_group_id_two FROM vicidial_campaigns where campaign_id='$DBfill_campaign[$camp_CIPct]';";
					$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
					$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
					$sthArows=$sthA->rows;
					$rec_count=0;
					$active_only=0;
					while ($sthArows > $rec_count)
						{
						@aryA = $sthA->fetchrow_array;
						$DBIPdialtimeout[$camp_CIPct] =		$aryA[0];
						$DBIPdialprefix[$camp_CIPct] =		$aryA[1];
						$DBIPcampaigncid[$camp_CIPct] =		$aryA[2];
						$DBIPactive[$camp_CIPct] =			$aryA[3];
						$DBIPvdadexten[$camp_CIPct] =		$aryA[4];
						$omit_phone_code =					$aryA[5];
						$DBIPautoaltdial[$camp_CIPct] =		$aryA[6];
						$DBIPqueue_priority[$camp_CIPct] =	$aryA[7];
						$DBIPuse_custom_cid[$camp_CIPct] =	$aryA[8];
						$DBIPcid_group_id[$camp_CIPct] =	$aryA[9];
						$DBIPscheduled_callbacks_auto_reschedule[$camp_CIPct] =	$aryA[10];
						$DBIPdial_timeout_lead_container[$camp_CIPct] =	$aryA[11];
						$DBIPcid_group_id_two[$camp_CIPct] =	$aryA[12];
						$DBIPhopper_hold_inserts[$camp_CIPct] =	$aryA[13];
						if ($SShopper_hold_inserts < 1) {$DBIPhopper_hold_inserts[$camp_CIPct] = 'DISABLED';}

						if ($omit_phone_code =~ /Y/) {$DBIPomitcode[$camp_CIPct] = 1;}
						else {$DBIPomitcode[$camp_CIPct] = 0;}

						$rec_count++;
						}
					$sthA->finish();

					$stmtA = "SELECT balance_trunk_fill FROM vicidial_campaign_stats where campaign_id='$DBfill_campaign[$camp_CIPct]';";
					$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
					$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
					$sthArows=$sthA->rows;
					if ($sthArows > 0)
						{
						@aryA = $sthA->fetchrow_array;
						$DB_balance_fill =	$aryA[0];
						}
					$sthA->finish();

					$stmtA = "SELECT count(*) FROM vicidial_auto_calls where campaign_id='$DBfill_campaign[$camp_CIPct]' and call_type='OUTBALANCE';";
					$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
					$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
					$sthArows=$sthA->rows;
					if ($sthArows > 0)
						{
						@aryA = $sthA->fetchrow_array;
						$VAC_balance_fill =	$aryA[0];
						}
					$sthA->finish();

					$DBfill_current_balance[$camp_CIPct] = "$VAC_balance_fill";

					$event_string="               CAMPAIGN: $DBfill_campaign[$camp_CIPct]\n";
					$event_string.="DB_balance_fill: $DB_balance_fill   VAC_balance_fill: $VAC_balance_fill\n";

					$DBfill_needed[$camp_CIPct] = ($DBfill_shortage[$camp_CIPct] - $VAC_balance_fill);
					$event_string.="Additional Balance Calls Needed For This Campaign: $DBfill_needed[$camp_CIPct]\n";


					##### Get a listing of the servers in the campaign that have shortages of trunks
					$full_servers='|';
					$full_serversSQL='';
					$stmtA = "SELECT server_ip FROM vicidial_campaign_server_stats where update_time > '$XDSQLdate' and local_trunk_shortage > 0 and campaign_id='$DBfill_campaign[$camp_CIPct]';";
					$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;
						$full_servers .=	"$aryA[0]|";
						$full_serversSQL .=	"'$aryA[0]',";
						$rec_count++;
						}
					$sthA->finish();

					chop($full_serversSQL);
					if (length($full_serversSQL)<6) {$full_serversSQL="''";}
					$event_string.="SERVERS WITH TRUNK FULL for $DBfill_campaign[$camp_CIPct]: $full_servers |$full_serversSQL|";
					&event_logger;

					##### Check if there are any balance-enabled servers outside of the ones with trunk shortage
					$stmtA = "SELECT count(*) FROM servers where vicidial_balance_active = 'Y' and server_ip NOT IN($full_serversSQL);";
					$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
					$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
					$sthArows=$sthA->rows;
					if ($sthArows > 0)
						{
						@aryA = $sthA->fetchrow_array;
						$AVAIL_balance_servers =	$aryA[0];
						}
					$sthA->finish();

					##################################################################################
					##### CONTINUE IF THERE ARE BALANCE SERVERS AVAILABLE THAT ARE NOT IN TRUNK SHORTAGE, AND ADDITIONAL FILL CALLS ARE NEEDED
					##################################################################################
					if ( ($AVAIL_balance_servers > 0) && ($DBfill_needed[$camp_CIPct] > 0) )
						{
						$event_string="Balance Servers available: $AVAIL_balance_servers";
						&event_logger;

						$DB_camp_servers=0;
						$DB_camp_servers_calls_placed=0;
						@DB_camp_server_server_ip=@MT;
						@DB_camp_server_max_vicidial_trunks=@MT;
						@DB_camp_server_balance_trunks_offlimits=@MT;
						@DB_camp_server_dedicated_trunks=@MT;
						@DB_camp_server_trunk_restriction=@MT;
						@DB_NONcamp_server_dedicated_trunks=@MT;
						@DB_camp_server_available=@MT;
						@DB_camp_server_trunks_to_dial=@MT;
						##### Get the trunk settings for the campaign across all servers
						$stmtA = "SELECT server_ip,max_vicidial_trunks,balance_trunks_offlimits,vicidial_balance_rank,asterisk_version,routing_prefix FROM servers where vicidial_balance_active = 'Y' and server_ip NOT IN($full_serversSQL) order by vicidial_balance_rank desc, server_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;
							$DB_camp_server_server_ip[$DB_camp_servers] =					$aryA[0];
							$DB_camp_server_max_vicidial_trunks[$DB_camp_servers] =			$aryA[1];
							$DB_camp_server_balance_trunks_offlimits[$DB_camp_servers] =	$aryA[2];
							$DB_camp_server_asterisk_version[$DB_camp_servers] =			$aryA[4];
							$DB_camp_server_routing_prefix[$DB_camp_servers] =				$aryA[5];
							$DB_camp_servers++;
							$rec_count++;
							}
						$sthA->finish();


						##################################################################################
						##### LOOP THROUGH SERVERS, CALCULATE TRUNKS FOR EACH FOR THIS CAMPAIGN
						##################################################################################
						$server_CIPct = 0;
						foreach(@DB_camp_server_server_ip)
							{
							$DB_camp_server_dedicated_trunks[$server_CIPct]=0;
							$DB_camp_server_trunk_restriction[$server_CIPct]=0;
							$DB_NONcamp_server_dedicated_trunks[$server_CIPct]=0;
							$SERVER_CAMP_temp_avail[$server_CIPct]=0;
							$SERVER_CAMP_temp_tally[$server_CIPct]=0;
							##### Get the campaign-specific trunk settings for the campaign on this server
							$stmtA = "SELECT dedicated_trunks,trunk_restriction FROM vicidial_server_trunks where server_ip='$DB_camp_server_server_ip[$server_CIPct]' and campaign_id='$DBfill_campaign[$camp_CIPct]';";
							$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
							$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
							$sthArows=$sthA->rows;
							if ($sthArows > 0)
								{
								@aryA = $sthA->fetchrow_array;
								$DB_camp_server_dedicated_trunks[$server_CIPct] =	$aryA[0];
								$DB_camp_server_trunk_restriction[$server_CIPct] =	$aryA[1];
								}
							$sthA->finish();

							##### Get the campaign-specific dedicated trunks count for other campaigns on this server
							$stmtA = "SELECT sum(dedicated_trunks) FROM vicidial_server_trunks where server_ip='$DB_camp_server_server_ip[$server_CIPct]' and campaign_id NOT IN('$DBfill_campaign[$camp_CIPct]');";
							$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
							$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
							$sthArows=$sthA->rows;
							if ($sthArows > 0)
								{
								@aryA = $sthA->fetchrow_array;
								$DB_NONcamp_server_dedicated_trunks[$server_CIPct] =	$aryA[0];
								}
							$sthA->finish();

							$VAC_server_camp=0;
							$VAC_server_NONcamp=0;

							$stmtA = "SELECT count(*) FROM vicidial_auto_calls where server_ip='$DB_camp_server_server_ip[$server_CIPct]' and campaign_id='$DBfill_campaign[$camp_CIPct]' and call_type='OUTBALANCE';";
							$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
							$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
							$sthArows=$sthA->rows;
							if ($sthArows > 0)
								{
								@aryA = $sthA->fetchrow_array;
								$VAC_server_BALcamp =	$aryA[0];
								}
							$sthA->finish();

							$stmtA = "SELECT count(*) FROM vicidial_auto_calls where server_ip='$DB_camp_server_server_ip[$server_CIPct]' and campaign_id='$DBfill_campaign[$camp_CIPct]';";
							$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
							$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
							$sthArows=$sthA->rows;
							if ($sthArows > 0)
								{
								@aryA = $sthA->fetchrow_array;
								$VAC_server_camp =	$aryA[0];
								}
							$sthA->finish();

							$stmtA = "SELECT count(*) FROM vicidial_auto_calls where server_ip='$DB_camp_server_server_ip[$server_CIPct]' and campaign_id!='$DBfill_campaign[$camp_CIPct]';";
							$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
							$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
							$sthArows=$sthA->rows;
							if ($sthArows > 0)
								{
								@aryA = $sthA->fetchrow_array;
								$VAC_server_NONcamp =	$aryA[0];
								}
							$sthA->finish();

							if($DB) {print "VAC CALLS: |$VAC_server_camp|$VAC_server_NONcamp|$VAC_server_BALcamp|\n";}
							if($DB) {print "SETTINGS:  |$DB_camp_server_dedicated_trunks[$server_CIPct]|$DB_camp_server_max_vicidial_trunks[$server_CIPct]|$DB_camp_server_balance_trunks_offlimits[$server_CIPct]||\n";}

							if ($DB_camp_server_trunk_restriction[$server_CIPct] =~ /MAXIMUM_LIMIT/)
								{
								$DB_camp_server_available[$server_CIPct] = $DB_camp_server_dedicated_trunks[$server_CIPct];
								}
							else
								{
								$DB_camp_server_available[$server_CIPct] = ( ($DB_camp_server_max_vicidial_trunks[$server_CIPct] - $DB_camp_server_balance_trunks_offlimits[$server_CIPct]) -  $DB_NONcamp_server_dedicated_trunks[$server_CIPct]);
								}
							$SERVER_CAMP_temp_tally[$server_CIPct] = ($DBfill_needed[$camp_CIPct] - $DBfill_tally[$camp_CIPct]);
							$SERVER_CAMP_temp_avail[$server_CIPct] = ( ($DB_camp_server_max_vicidial_trunks[$server_CIPct] - $VAC_server_camp) -  $VAC_server_NONcamp);
							$DB_camp_server_available[$server_CIPct] = ($DB_camp_server_available[$server_CIPct] - $VAC_server_BALcamp);
							if ($DB_camp_server_available[$server_CIPct] < 0) {$DB_camp_server_available[$server_CIPct]=0;}

							if($DB) {print "TEMPVALS:  |$SERVER_CAMP_temp_tally[$server_CIPct]|$SERVER_CAMP_temp_avail[$server_CIPct]|$DB_camp_server_available[$server_CIPct]||\n";}
							if ($DB_camp_server_available[$server_CIPct] >= $SERVER_CAMP_temp_tally[$server_CIPct])
								{$DB_camp_server_trunks_to_dial[$server_CIPct] = $SERVER_CAMP_temp_tally[$server_CIPct];}
							else
								{$DB_camp_server_trunks_to_dial[$server_CIPct] = $DB_camp_server_available[$server_CIPct];}

							if ($SERVER_CAMP_temp_avail[$server_CIPct] < $DB_camp_server_trunks_to_dial[$server_CIPct]) 
								{$DB_camp_server_trunks_to_dial[$server_CIPct] = $SERVER_CAMP_temp_avail[$server_CIPct];}

							$DBfill_tally[$camp_CIPct] = ($DBfill_tally[$camp_CIPct] + $DB_camp_server_trunks_to_dial[$server_CIPct]);

							$event_string="     Server: $DB_camp_server_server_ip[$server_CIPct]   AVAIL: $DB_camp_server_available[$server_CIPct]   DIAL: $DB_camp_server_trunks_to_dial[$server_CIPct]";
							$event_string.="     Campaign Dial Fill tally: $DBfill_tally[$camp_CIPct]/$DBfill_needed[$camp_CIPct]";
							&event_logger;

							$stmtA = "SELECT count(*) FROM vicidial_live_agents where ( (campaign_id='$DBfill_campaign[$camp_CIPct]') or (dial_campaign_id='$DBfill_campaign[$camp_CIPct]') ) and status NOT IN('PAUSED');";
							$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
							$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
							$sthArows=$sthA->rows;
							$LVA_count=0;
							if ($sthArows > 0)
								{
								@aryA = $sthA->fetchrow_array;
								$LVA_count =	$aryA[0];
								}
							$sthA->finish();

							if ($LVA_count > 0)
								{
								##################################################################################
								##### PLACE THE CALLS
								##################################################################################
								$event_string="$DBfill_campaign[$camp_CIPct] $DB_camp_server_server_ip[$server_CIPct]: CALLING";
								&event_logger;
								$call_CMPIPct=0;
								$lead_id_call_list='|';
								my $UDaffected_rows=0;
								$VALIDATEcalls_to_place = ($DBfill_needed[$camp_CIPct] - $DB_camp_servers_calls_placed);
								if ($VALIDATEcalls_to_place < 0) {$VALIDATEcalls_to_place=0;}
								if ($DB_camp_server_trunks_to_dial[$server_CIPct] > $VALIDATEcalls_to_place) 
									{
									$event_string="Calls-to-place VALIDATE OVERRIDE: |$DB_camp_server_trunks_to_dial[$server_CIPct]|$VALIDATEcalls_to_place|$DBfill_needed[$camp_CIPct]|$DB_camp_servers_calls_placed|";
									&event_logger;
									$DB_camp_server_trunks_to_dial[$server_CIPct] = $VALIDATEcalls_to_place;
									}
								if ($call_CMPIPct < $DB_camp_server_trunks_to_dial[$server_CIPct])
									{
									$stmtA = "UPDATE vicidial_hopper set status='QUEUE', user='VDFC_$DB_camp_server_server_ip[$server_CIPct]' where campaign_id='$DBfill_campaign[$camp_CIPct]' and status='READY' order by priority desc,hopper_id LIMIT $DB_camp_server_trunks_to_dial[$server_CIPct];";
									print "|$stmtA|\n";
									$UDaffected_rows = $dbhA->do($stmtA);
									print "hopper rows updated to QUEUE: |$UDaffected_rows|\n";

									if ($UDaffected_rows)
										{
										$lead_id=''; $phone_code=''; $phone_number=''; $called_count='';
										while ($call_CMPIPct < $UDaffected_rows)
											{
											$stmtA = "SELECT lead_id,alt_dial,source FROM vicidial_hopper where campaign_id='$DBfill_campaign[$camp_CIPct]' and status='QUEUE' and user='VDFC_$DB_camp_server_server_ip[$server_CIPct]' order by priority desc,hopper_id LIMIT 1;";
											print "|$stmtA|\n";
											$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
											$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
											$sthArows=$sthA->rows;
											$rec_countCUSTDATA=0;
											if ($sthArows > 0)
												{
												@aryA = $sthA->fetchrow_array;
												$lead_id =			$aryA[0];
												$alt_dial =			$aryA[1];
												$hopper_source =	$aryA[2];
												}
											$sthA->finish();

											if ($lead_id_call_list =~ /\|$lead_id\|/)
												{
												print "!!!!!!!!!!!!!!!!duplicate lead_id for this run: |$lead_id|     $lead_id_call_list\n";
												if ($SYSLOG)
													{
													open(DUPout, ">>$PATHlogs/VDFC_DUPLICATE.$file_date")
															|| die "Can't open $PATHlogs/VDFC_DUPLICATE.$file_date: $!\n";
													print DUPout "$now_date-----$lead_id_call_list-----$lead_id\n";
													close(DUPout);
													}
												}
											else
												{
												$stmtA = "UPDATE vicidial_hopper set status='INCALL' where lead_id='$lead_id';";
											#	print "|$stmtA|\n";
												$UQaffected_rows = $dbhA->do($stmtA);
											#	print "hopper row updated to INCALL: |$UQaffected_rows|$lead_id|\n";

												$stmtA = "SELECT list_id,gmt_offset_now,called_since_last_reset,phone_code,phone_number,address3,alt_phone,called_count,security_phrase,state,vendor_lead_code,source_id,title,first_name,middle_initial,last_name,address1,address2,city,province,postal_code,country_code,date_of_birth,email,comments,rank,owner FROM vicidial_list where lead_id='$lead_id';";
												$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
												$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
												$sthArows=$sthA->rows;
												$rec_countCUSTDATA=0;
												if ($sthArows > 0)
													{
													@aryA = $sthA->fetchrow_array;
													$list_id =					$aryA[0];
													$gmt_offset_now	=			$aryA[1];
													$called_since_last_reset =	$aryA[2];
													$phone_code	=				$aryA[3];
													$phone_number =				$aryA[4];
													$address3 =					$aryA[5];
													$alt_phone =				$aryA[6];
													$called_count =				$aryA[7];
													$security_phrase =			$aryA[8];
													$state =					$aryA[9];
													$vendor_id =				$aryA[10];
													$source_id =				$aryA[11];
													$title =					$aryA[12];
													$first_name =				$aryA[13];
													$middle_initial =			$aryA[14];
													$last_name =				$aryA[15];
													$address1 =					$aryA[16];
													$address2 =					$aryA[17];
													$city =						$aryA[18];
													$province =					$aryA[19];
													$postal_code =				$aryA[20];
													$country_code =				$aryA[21];
													$date_of_birth =			$aryA[22];
													$email =					$aryA[23];
													$comments =					$aryA[24];
													$rank =						$aryA[25];
													$owner =					$aryA[26];

													$rec_countCUSTDATA++;
													}
												$sthA->finish();

												if ($rec_countCUSTDATA)
													{
													### BEGIN check for Dial Timeout Lead override for this lead ###
													$DTL_override=0;
													if ( (length($DBIPdial_timeout_lead_container[$camp_CIPct]) > 1) && ($DBIPdial_timeout_lead_container[$camp_CIPct] !~ /^DISABLED$/i) )
														{
														# Gather settings container for Call Quota Lead Ranking
														$stmtA = "SELECT container_entry FROM vicidial_settings_containers where container_id='$DBIPdial_timeout_lead_container[$camp_CIPct]';";
														$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
														$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
														$sthArows=$sthA->rows;
														if ($sthArows > 0)
															{
															@aryA = $sthA->fetchrow_array;
															$DBIPdial_timeout_lead_container_entry[$camp_CIPct] = $aryA[0];
															$DBIPdial_timeout_lead_container_entry[$camp_CIPct] =~ s/\r|\t|\'|\"|\\//gi;
															}
														$sthA->finish();

														$AD_field='';
														$skip_line=0;   $DTLOset=0;
														$temp_DTL = $DBIPdial_timeout_lead_container_entry[$camp_CIPct];
														if (length($temp_DTL) > 5) 
															{
															@container_lines = split(/\n/,$temp_DTL);
															$c=0;
															foreach(@container_lines)
																{
																$container_lines[$c] =~ s/;.*|\r|\t//gi;
																$container_lines[$c] =~ s/ => |=> | =>/=>/gi;
																if (length($container_lines[$c]) > 3)
																	{
																	# define core settings
																	if ($container_lines[$c] =~ /^auto_dial_field/i)
																		{
																		$container_lines[$c] =~ s/auto_dial_field=>//gi;
																		$AD_field = $container_lines[$c];
																		}
																	else
																		{
																		if ($container_lines[$c] =~ /^manual_dial_field|^;/i)
																			{$skip_line++;}
																		else
																			{
																			# define dial timeouts
																			@temp_key_value = split(/=>/,$container_lines[$c]);
																			if ( ($AD_field eq 'vendor_lead_code') and ($vendor_id eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'source_id') and ($source_id eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'list_id') and ($list_id eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'gmt_offset_now') and ($gmt_offset_now eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'phone_code') and ($phone_code eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'title') and ($title eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'first_name') and ($first_name eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'middle_initial') and ($middle_initial eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'last_name') and ($last_name eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'address1') and ($address1 eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'address2') and ($address2 eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'address3') and ($address3 eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'city') and ($city eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'state') and ($state eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'province') and ($province eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'postal_code') and ($postal_code eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'country_code') and ($country_code eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'date_of_birth') and ($date_of_birth eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'alt_phone') and ($alt_phone eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'email') and ($email eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'security_phrase') and ($security_phrase eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'comments') and ($comments eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'called_count') and ($called_count eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'rank') and ($rank eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}
																			if ( ($AD_field eq 'owner') and ($owner eq $temp_key_value[0]) ) 
																				{$DTL_override = $temp_key_value[1];   $DTLOset++;}

																		#	$event_string = "|     Dial Timeout Lead DEBUG: $c|$DTLOset|$AD_field|$lead_id|$temp_key_value[0]|$temp_key_value[1]|$DTL_override|$skip_line|$source_id|";
																		#	 &event_logger;

																			}
																		}
																	}
																$c++;
																}
															# Dial Timeout Lead debug logging
															$event_string = "|     Dial Timeout Lead override: $DTLOset|$AD_field|$lead_id|$temp_key_value[0]|$temp_key_value[1]|$DTL_override|$skip_line|$c|";
															 &event_logger;
															}
														}
													### END check for Dial Timeout Lead override for this lead ###
													
													$campaign_cid_override='';
													$LIST_cid_group_override='';
													$LIST_dial_prefix_override='';
													### gather list_id overrides
													$stmtA = "SELECT campaign_cid_override,cid_group_id,dial_prefix FROM vicidial_lists where list_id='$list_id';";
													$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
													$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
													$sthArowsL=$sthA->rows;
													if ($sthArowsL > 0)
														{
														@aryA = $sthA->fetchrow_array;
														$campaign_cid_override =		$aryA[0];
														$LIST_cid_group_override =		$aryA[1];
														$LIST_dial_prefix_override =	$aryA[2];
														}
													$sthA->finish();

													### update called_count
													$called_count++;
													if ($called_since_last_reset =~ /^Y/)
														{
														if ($called_since_last_reset =~ /^Y$/) {$CSLR = 'Y1';}
														else
															{
															$called_since_last_reset =~ s/^Y//gi;
															$called_since_last_reset++;
															$CSLR = "Y$called_since_last_reset";
															}
														}
													else {$CSLR = 'Y';}

													$LLCT_DATE_offset = ($LOCAL_GMT_OFF - $gmt_offset_now);
													$LLCT_DATE_offset_epoch = ( $secX - ($LLCT_DATE_offset * 3600) );
													($Lsec,$Lmin,$Lhour,$Lmday,$Lmon,$Lyear,$Lwday,$Lyday,$Lisdst) = localtime($LLCT_DATE_offset_epoch);
													$Lyear = ($Lyear + 1900);
													$Lmon++;
													if ($Lmon < 10) {$Lmon = "0$Lmon";}
													if ($Lmday < 10) {$Lmday = "0$Lmday";}
													if ($Lhour < 10) {$Lhour = "0$Lhour";}
													if ($Lmin < 10) {$Lmin = "0$Lmin";}
													if ($Lsec < 10) {$Lsec = "0$Lsec";}
													$LLCT_DATE = "$Lyear-$Lmon-$Lmday $Lhour:$Lmin:$Lsec";

													if ( ($alt_dial =~ /ALT|ADDR3|X/) && ($DBIPautoaltdial[$camp_CIPct] =~ /ALT|ADDR|X/) )
														{
														if ( ($alt_dial =~ /ALT/) && ($DBIPautoaltdial[$camp_CIPct] =~ /ALT/) )
															{
															$alt_phone =~ s/\D//gi;
															$phone_number = $alt_phone;
															}
														if ( ($alt_dial =~ /ADDR3/) && ($DBIPautoaltdial[$camp_CIPct] =~ /ADDR3/) )
															{
															$address3 =~ s/\D//gi;
															$phone_number = $address3;
															}
														if  ( ($alt_dial =~ /^X/) && ($DBIPautoaltdial[$camp_CIPct] =~ /^X/) )
															{
															if ($alt_dial =~ /LAST/) 
																{
																$stmtA = "SELECT phone_code,phone_number FROM vicidial_list_alt_phones where lead_id='$lead_id' order by alt_phone_count desc limit 1;";
																}
															else
																{
																$Talt_dial = $alt_dial;
																$Talt_dial =~ s/\D//gi;
																$stmtA = "SELECT phone_code,phone_number FROM vicidial_list_alt_phones where lead_id='$lead_id' and alt_phone_count='$Talt_dial';";										
																}
															$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
															$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
															$sthArows=$sthA->rows;
															if ($sthArows > 0)
																{
																@aryA = $sthA->fetchrow_array;
																$phone_code	=	$aryA[0];
																$phone_number =	$aryA[1];
																$phone_number =~ s/\D//gi;
																}
															$sthA->finish();
															}

														$stmtA = "UPDATE vicidial_list set called_since_last_reset='$CSLR', called_count='$called_count',user='VDAD',last_local_call_time='$LLCT_DATE' where lead_id='$lead_id';";
														}
													else
														{
														$stmtA = "UPDATE vicidial_list set called_since_last_reset='$CSLR', called_count='$called_count',user='VDAD',last_local_call_time='$LLCT_DATE' where lead_id='$lead_id';";
														}
													# update daily called counts for this lead
													$stmtDC = "INSERT IGNORE INTO vicidial_lead_call_daily_counts SET lead_id='$lead_id',modify_date=NOW(),list_id='$PSCBlist_id',called_count_total='1',called_count_auto='1' ON DUPLICATE KEY UPDATE modify_date=NOW(),list_id='$PSCBlist_id',called_count_total=(called_count_total + 1),called_count_auto=(called_count_auto + 1);";
													# update daily called counts for this phone_number
													$stmtPDC = "INSERT IGNORE INTO vicidial_phone_number_call_daily_counts SET phone_number='$phone_number',modify_date=NOW(),called_count='1' ON DUPLICATE KEY UPDATE modify_date=NOW(),called_count=(called_count + 1);";
													if ($staggered < 1)
														{
														$affected_rows = $dbhA->do($stmtA);
														$affected_rowsDC = $dbhA->do($stmtDC);
														$affected_rowsPDC = $dbhA->do($stmtPDC);
														if ($DB) {print "LEAD UPDATE: $affected_rows|$stmtA|\n";}
														if ($DB) {print "LEAD CALL COUNT UPDATE: $affected_rowsDC|$stmtDC|\n";}
														if ($DB) {print "PHONE CALL COUNT UPDATE: $affected_rowsPDC|$stmtPDC|\n";}
														}
													else
														{
														$vl_updates[$staggered_ct] = $stmtA;
														$vdc_updates[$staggered_ct] = $stmtDC;
														$vdcp_updates[$staggered_ct] = $stmtPDC;
														}

													$PADlead_id = sprintf("%010s", $lead_id);	while (length($PADlead_id) > 10) {chop($PADlead_id);}
													# VmddhhmmssLLLLLLLLLL Set the callerIDname to a unique call_id string
													$VqueryCID = "V$CIDdate$PADlead_id";

													if ( ( ($DBIPscheduled_callbacks_auto_reschedule[$camp_CIPct] !~ /DISABLED/) && (length($DBIPscheduled_callbacks_auto_reschedule[$camp_CIPct]) > 0) ) || ($hopper_source eq 'C') )
														{
														### gather vicidial_callbacks information for this lead, if any
														$stmtA = "SELECT callback_id,callback_time,lead_status,list_id FROM vicidial_callbacks where lead_id='$lead_id' and status='LIVE' and recipient='ANYONE' order by callback_id limit 1;";
														$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
														$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
														$sthArowsPSCB=$sthA->rows;
														if ($sthArowsPSCB > 0)
															{
															@aryA = $sthA->fetchrow_array;
															$PSCBcallback_id =		$aryA[0];
															$PSCBcallback_time =	$aryA[1];
															$PSCBlead_status =		$aryA[2];
															$PSCBlist_id =			$aryA[3];
															}
														$sthA->finish();
														### insert record in recent callbacks table
														if ($sthArowsPSCB > 0)
															{
															$stmtA = "INSERT INTO vicidial_recent_ascb_calls SET call_date=NOW(),callback_date='$PSCBcallback_time',callback_id='$PSCBcallback_id',caller_code='$VqueryCID',lead_id='$lead_id',server_ip='$DB_camp_server_server_ip[$server_CIPct]',orig_status='$PSCBlead_status',reschedule='$DBIPscheduled_callbacks_auto_reschedule[$camp_CIPct]',list_id='$PSCBlist_id',rescheduled='U';";
															$affected_rows = $dbhA->do($stmtA);
															}
														}

													$stmtA = "DELETE FROM vicidial_hopper where lead_id='$lead_id';";
													$affected_rows = $dbhA->do($stmtA);

													$CCID_on=0;   $CCID='';   $CCIDtype='';
													$local_DEF = 'Local/';
													$local_AMP = '@';
													$Local_out_prefix = '9';
													$Local_dial_timeout = '60';
													if ($DBIPdialtimeout[$camp_CIPct] > 4) {$Local_dial_timeout = $DBIPdialtimeout[$camp_CIPct];}
													if ($DTL_override > 4) {$Local_dial_timeout = $DTL_override;}
													$Local_dial_timeout = ($Local_dial_timeout * 1000);
													if (length($DBIPdialprefix[$camp_CIPct]) > 0) {$Local_out_prefix = "$DBIPdialprefix[$camp_CIPct]";}
													if (length($LIST_dial_prefix_override) > 0) {$Local_out_prefix = "$LIST_dial_prefix_override";}
													if (length($DBIPvdadexten[$camp_CIPct]) > 0) {$VDAD_dial_exten = "$DBIPvdadexten[$camp_CIPct]";}
													else {$VDAD_dial_exten = "$answer_transfer_agent";}

													if (length($DBIPcampaigncid[$camp_CIPct]) > 6) 
														{$CCID = "$DBIPcampaigncid[$camp_CIPct]";   $CCID_on++;   $CCIDtype='CAMPAIGN_CID';}

													$temp_CID='';
													if ( (length($LIST_cid_group_override) > 0) && ($LIST_cid_group_override !~ /\-\-\-DISABLED\-\-\-/) )
														{
														$stmtA = "SELECT cid_group_type FROM vicidial_cid_groups where cid_group_id='$LIST_cid_group_override';";
														$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
														$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
														$sthArows=$sthA->rows;
														if ($sthArows > 0)
															{
															@aryA = $sthA->fetchrow_array;
															$cid_group_type =	$aryA[0];
															$temp_CID='';
															$temp_vcca='';
															$temp_ac='';

															if ($cid_group_type =~ /AREACODE/)
																{
																$temp_ac_two = substr("$phone_number", 0, 2);
																$temp_ac_three = substr("$phone_number", 0, 3);
																$temp_ac_four = substr("$phone_number", 0, 4);
																$temp_ac_five = substr("$phone_number", 0, 5);
																$stmtA = "SELECT outbound_cid,areacode FROM vicidial_campaign_cid_areacodes where campaign_id='$LIST_cid_group_override' and areacode IN('$temp_ac_two','$temp_ac_three','$temp_ac_four','$temp_ac_five') and active='Y' order by CAST(areacode as SIGNED INTEGER) asc, call_count_today desc limit 100000;";
																}
															if ($cid_group_type =~ /STATE/)
																{
																$temp_state = $state;
																$stmtA = "SELECT outbound_cid,areacode FROM vicidial_campaign_cid_areacodes where campaign_id='$LIST_cid_group_override' and areacode IN('$temp_state') and active='Y' order by call_count_today desc limit 100000;";
																}
															if ($cid_group_type =~ /NONE/)
																{
																$stmtA = "SELECT outbound_cid,areacode FROM vicidial_campaign_cid_areacodes where campaign_id='$LIST_cid_group_override' and active='Y' order by call_count_today desc limit 100000;";
																}
															$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
															$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
															$sthArows=$sthA->rows;
															$act=0;
															while ($sthArows > $act)
																{
																@aryA = $sthA->fetchrow_array;
																$temp_vcca =	$aryA[0];
																$temp_ac =		$aryA[1];
																$act++;
																}
															if ($act > 0) 
																{
																$sthA->finish();
																$stmtA="UPDATE vicidial_campaign_cid_areacodes set call_count_today=(call_count_today + 1) where campaign_id='$LIST_cid_group_override' and areacode='$temp_ac' and outbound_cid='$temp_vcca';";
																$affected_rows = $dbhA->do($stmtA);

																if ($cid_group_type =~ /NONE/)
																	{
																	$stmtA="UPDATE vicidial_cid_groups set cid_auto_rotate_calls=(cid_auto_rotate_calls + 1) where cid_group_id='$LIST_cid_group_override';";
																	$affected_rows = $dbhA->do($stmtA);
																	}
																}
															else
																{$sthA->finish();}
															$temp_CID = $temp_vcca;
															$temp_CID =~ s/\D//gi;
															}
														}
													if ( (length($campaign_cid_override) > 6) || (length($temp_CID) > 6) )
														{
														if (length($temp_CID) > 6) 
															{$CCID = "$temp_CID";   $CCID_on++;   $CCIDtype='LIST_CID_GROUP';}
														else
															{$CCID = "$campaign_cid_override";   $CCID_on++;   $CCIDtype='LIST_CID';}
														}
													else
														{
														if ($DBIPuse_custom_cid[$camp_CIPct] =~ /Y/) 
															{
															$temp_CID = $security_phrase;
															$temp_CID =~ s/\D//gi;
															if (length($temp_CID) > 6) 
																{$CCID = "$temp_CID";   $CCID_on++;   $CCIDtype='CUSTOM_CID';}
															}
														$CIDG_set=0;
														if ($DBIPcid_group_id[$camp_CIPct] !~ /\-\-\-DISABLED\-\-\-/) 
															{
															$stmtA = "SELECT cid_group_type FROM vicidial_cid_groups where cid_group_id='$DBIPcid_group_id[$camp_CIPct]';";
															$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
															$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
															$sthArows=$sthA->rows;
															if ($sthArows > 0)
																{
																@aryA = $sthA->fetchrow_array;
																$cid_group_type =	$aryA[0];
																$temp_CID='';
																$temp_vcca='';
																$temp_ac='';

																if ($cid_group_type =~ /AREACODE/)
																	{
																	$temp_ac_two = substr("$phone_number", 0, 2);
																	$temp_ac_three = substr("$phone_number", 0, 3);
																	$temp_ac_four = substr("$phone_number", 0, 4);
																	$temp_ac_five = substr("$phone_number", 0, 5);
																	$stmtA = "SELECT outbound_cid,areacode FROM vicidial_campaign_cid_areacodes where campaign_id='$DBIPcid_group_id[$camp_CIPct]' and areacode IN('$temp_ac_two','$temp_ac_three','$temp_ac_four','$temp_ac_five') and active='Y' order by CAST(areacode as SIGNED INTEGER) asc, call_count_today desc limit 100000;";
																	}
																if ($cid_group_type =~ /STATE/)
																	{
																	$temp_state = $state;
																	$stmtA = "SELECT outbound_cid,areacode FROM vicidial_campaign_cid_areacodes where campaign_id='$DBIPcid_group_id[$camp_CIPct]' and areacode IN('$temp_state') and active='Y' order by call_count_today desc limit 100000;";
																	}
																if ($cid_group_type =~ /NONE/)
																	{
																	$stmtA = "SELECT outbound_cid,areacode FROM vicidial_campaign_cid_areacodes where campaign_id='$DBIPcid_group_id[$camp_CIPct]' and active='Y' order by call_count_today desc limit 100000;";
																	}
																$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
																$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
																$sthArows=$sthA->rows;
																$act=0;
																while ($sthArows > $act)
																	{
																	@aryA = $sthA->fetchrow_array;
																	$temp_vcca =	$aryA[0];
																	$temp_ac =		$aryA[1];
																	$act++;
																	}
																if ($act > 0) 
																	{
																	$sthA->finish();
																	$stmtA="UPDATE vicidial_campaign_cid_areacodes set call_count_today=(call_count_today + 1) where campaign_id='$DBIPcid_group_id[$camp_CIPct]' and areacode='$temp_ac' and outbound_cid='$temp_vcca';";
																	$affected_rows = $dbhA->do($stmtA);

																	if ($cid_group_type =~ /NONE/)
																		{
																		$stmtA="UPDATE vicidial_cid_groups set cid_auto_rotate_calls=(cid_auto_rotate_calls + 1) where cid_group_id='$DBIPcid_group_id[$camp_CIPct]';";
																		$affected_rows = $dbhA->do($stmtA);
																		}
																	}
																else
																	{$sthA->finish();}
																$temp_CID = $temp_vcca;
																$temp_CID =~ s/\D//gi;
																if (length($temp_CID) > 6) 
																	{$CCID = "$temp_CID";   $CCID_on++;   $CIDG_set++;   $CCIDtype='CID_GROUP';}
																}
															}
														if ( ($DBIPcid_group_id_two[$camp_CIPct] !~ /\-\-\-DISABLED\-\-\-/) && ($CIDG_set < 1) )
															{
															$stmtA = "SELECT cid_group_type FROM vicidial_cid_groups where cid_group_id='$DBIPcid_group_id_two[$camp_CIPct]';";
															$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
															$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
															$sthArows=$sthA->rows;
															if ($sthArows > 0)
																{
																@aryA = $sthA->fetchrow_array;
																$cid_group_type =	$aryA[0];
																$temp_CID='';
																$temp_vcca='';
																$temp_ac='';

																if ($cid_group_type =~ /AREACODE/)
																	{
																	$temp_ac_two = substr("$phone_number", 0, 2);
																	$temp_ac_three = substr("$phone_number", 0, 3);
																	$temp_ac_four = substr("$phone_number", 0, 4);
																	$temp_ac_five = substr("$phone_number", 0, 5);
																	$stmtA = "SELECT outbound_cid,areacode FROM vicidial_campaign_cid_areacodes where campaign_id='$DBIPcid_group_id_two[$camp_CIPct]' and areacode IN('$temp_ac_two','$temp_ac_three','$temp_ac_four','$temp_ac_five') and active='Y' order by CAST(areacode as SIGNED INTEGER) asc, call_count_today desc limit 100000;";
																	}
																if ($cid_group_type =~ /STATE/)
																	{
																	$temp_state = $state;
																	$stmtA = "SELECT outbound_cid,areacode FROM vicidial_campaign_cid_areacodes where campaign_id='$DBIPcid_group_id_two[$camp_CIPct]' and areacode IN('$temp_state') and active='Y' order by call_count_today desc limit 100000;";
																	}
																if ($cid_group_type =~ /NONE/)
																	{
																	$stmtA = "SELECT outbound_cid,areacode FROM vicidial_campaign_cid_areacodes where campaign_id='$DBIPcid_group_id_two[$camp_CIPct]' and active='Y' order by call_count_today desc limit 100000;";
																	}
																$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
																$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
																$sthArows=$sthA->rows;
																$act=0;
																while ($sthArows > $act)
																	{
																	@aryA = $sthA->fetchrow_array;
																	$temp_vcca =	$aryA[0];
																	$temp_ac =		$aryA[1];
																	$act++;
																	}
																if ($act > 0) 
																	{
																	$sthA->finish();
																	$stmtA="UPDATE vicidial_campaign_cid_areacodes set call_count_today=(call_count_today + 1) where campaign_id='$DBIPcid_group_id_two[$camp_CIPct]' and areacode='$temp_ac' and outbound_cid='$temp_vcca';";
																	$affected_rows = $dbhA->do($stmtA);

																	if ($cid_group_type =~ /NONE/)
																		{
																		$stmtA="UPDATE vicidial_cid_groups set cid_auto_rotate_calls=(cid_auto_rotate_calls + 1) where cid_group_id='$DBIPcid_group_id_two[$camp_CIPct]';";
																		$affected_rows = $dbhA->do($stmtA);
																		}
																	}
																else
																	{$sthA->finish();}
																$temp_CID = $temp_vcca;
																$temp_CID =~ s/\D//gi;
																if (length($temp_CID) > 6) 
																	{$CCID = "$temp_CID";   $CCID_on++;   $CIDG_set++;   $CCIDtype='CID_GROUP_TWO';}
																}
															}
														if ( ($DBIPuse_custom_cid[$camp_CIPct] =~ /AREACODE/) && ($CIDG_set < 1) )
															{
															$temp_CID='';
															$temp_vcca='';
															$temp_ac='';
															$temp_ac_two = substr("$phone_number", 0, 2);
															$temp_ac_three = substr("$phone_number", 0, 3);
															$temp_ac_four = substr("$phone_number", 0, 4);
															$temp_ac_five = substr("$phone_number", 0, 5);
															$stmtA = "SELECT outbound_cid,areacode FROM vicidial_campaign_cid_areacodes where campaign_id='$DBfill_campaign[$camp_CIPct]' and areacode IN('$temp_ac_two','$temp_ac_three','$temp_ac_four','$temp_ac_five') and active='Y' order by CAST(areacode as SIGNED INTEGER) asc, call_count_today desc limit 100000;";
															$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
															$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
															$sthArows=$sthA->rows;
															$act=0;
															while ($sthArows > $act)
																{
																@aryA = $sthA->fetchrow_array;
																$temp_vcca =	$aryA[0];
																$temp_ac =		$aryA[1];
																$act++;
																}
															if ($act > 0) 
																{
																$sthA->finish();
																$stmtA="UPDATE vicidial_campaign_cid_areacodes set call_count_today=(call_count_today + 1) where campaign_id='$DBfill_campaign[$camp_CIPct]' and areacode='$temp_ac' and outbound_cid='$temp_vcca';";
																$affected_rows = $dbhA->do($stmtA);
																}
															else
																{$sthA->finish();}
															$temp_CID = $temp_vcca;
															$temp_CID =~ s/\D//gi;
															if (length($temp_CID) > 6) 
																{$CCID = "$temp_CID";   $CCID_on++;   $CCIDtype='AC_CID';}
															}
														}

													if ($Local_out_prefix =~ /x/i) {$Local_out_prefix = '';}

													if ($RECcount)
														{
														if ( (length($RECprefix)>0) && ($called_count < $RECcount) )
														   {$Local_out_prefix .= "$RECprefix";}
														}

													if ($lists_update !~ /'$list_id'/) {$lists_update .= "'$list_id',"; $LUcount++;}

													$lead_id_call_list .= "$lead_id|";

													if (length($alt_dial)<1) {$alt_dial='MAIN';}

													### whether to omit phone_code or not
													if ($DBIPomitcode[$camp_CIPct] > 0) 
														{$Ndialstring = "$Local_out_prefix$phone_number";}
													else
														{$Ndialstring = "$Local_out_prefix$phone_code$phone_number";}

													$TFhourSTATE='';
													if ($SScall_limit_24hour > 0) 
														{
														$TFH_areacode = substr($phone_number, 0, 3);
														$stmtY = "SELECT state,country FROM vicidial_phone_codes where country_code='$phone_code' and areacode='$TFH_areacode';";
														$sthY = $dbhA->prepare($stmtY) or die "preparing: ",$dbhA->errstr;
														$sthY->execute or die "executing: $stmtY", $dbhA->errstr;
														$sthYrows=$sthY->rows;
														if ($sthYrows > 0)
															{
															@aryY = $sthY->fetchrow_array;
															$TFhourSTATE =		$aryY[0];
															$TFhourCOUNTRY =	$aryY[1];
															}
														$sthA->finish();
														}

													if (length($ext_context) < 1) {$ext_context='default';}
													### use manager middleware-app to connect the next call to the meetme room
													if ($CCID_on) {$CIDstring = "\"$VqueryCID\" <$CCID>";}
													else {$CIDstring = "$VqueryCID";}

													if ($staggered < 1)
														{
														%ast_ver_str = parse_asterisk_version($DB_camp_server_asterisk_version[$server_CIPct]);
														if (( $ast_ver_str{major} = 1 ) && ($ast_ver_str{minor} > 11))
															{ 
															$VDAD_dial_exten = "$DB_camp_server_routing_prefix[$server_CIPct]$VDAD_dial_exten"; 
															$event_string = "|VDAD_dial_exten = $VDAD_dial_exten|";
															&event_logger;
															}

														### insert a NEW record to the vicidial_manager table to be processed
														$stmtA = "INSERT INTO vicidial_manager values('','','$SQLdate','NEW','N','$DB_camp_server_server_ip[$server_CIPct]','','Originate','$VqueryCID','Exten: $VDAD_dial_exten','Context: $ext_context','Channel: $local_DEF$Ndialstring$local_AMP$ext_context','Priority: 1','Callerid: $CIDstring','Timeout: $Local_dial_timeout','','','','VDACnote: $DBfill_campaign[$camp_CIPct]|$lead_id|$phone_code|$phone_number|OUTBALANCE|$alt_dial|$DBIPqueue_priority[$camp_CIPct]|$server_ip|$CCIDtype')";
														$affected_rows = $dbhA->do($stmtA);

														$event_string = "|     number call dialed|$DBfill_campaign[$camp_CIPct]|$VqueryCID|$stmtA|$gmt_offset_now|$alt_dial|$DB_camp_server_server_ip[$server_CIPct]|$DB_camp_server_asterisk_version[$server_CIPct]|$CCIDtype";
														 &event_logger;

													### insert a SENT record to the vicidial_auto_calls table 
														$stmtA = "INSERT INTO vicidial_auto_calls (server_ip,campaign_id,status,lead_id,callerid,phone_code,phone_number,call_time,call_type,alt_dial,queue_priority) values('$DB_camp_server_server_ip[$server_CIPct]','$DBfill_campaign[$camp_CIPct]','SENT','$lead_id','$VqueryCID','$phone_code','$phone_number','$SQLdate','OUTBALANCE','$alt_dial','$DBIPqueue_priority[$camp_CIPct]')";
														$affected_rows = $dbhA->do($stmtA);
														$calls_placed++;

													### insert log record into vicidial_dial_log table 
														$stmtA = "INSERT INTO vicidial_dial_log SET caller_code='$VqueryCID',lead_id='$lead_id',server_ip='$DB_camp_server_server_ip[$server_CIPct]',call_date='$SQLdate',extension='$VDAD_dial_exten',channel='$local_DEF$Ndialstring$local_AMP$ext_context',timeout='$Local_dial_timeout',outbound_cid='$CIDstring',context='$ext_context';";
														$affected_rows = $dbhA->do($stmtA);

													### insert log record into vicidial_lead_24hour_calls table 
														$stmtD = "INSERT INTO vicidial_lead_24hour_calls SET lead_id='$lead_id',list_id='$list_id',call_date=NOW(),phone_number='$phone_number',phone_code='$phone_code',state='$TFhourSTATE',call_type='AUTO';";
														$affected_rowsD = $dbhA->do($stmtD);

													### insert log record into vicidial_dial_cid_log table 
														$stmtE = "INSERT INTO vicidial_dial_cid_log SET caller_code='$VqueryCID',call_date='$SQLdate',call_type='OUTBALANCE',call_alt='$alt_dial',outbound_cid='$CCID',outbound_cid_type='$CCIDtype';";
														$affected_rowsE = $dbhA->do($stmtE);
														}
													else
														{
														##### create dummy records to have their server_ip filled in at the stagger section
														$vm_inserts[$staggered_ct] = "INSERT INTO vicidial_manager values('','','$SQLdate','NEW','N','XXXXXXXXXXXXXXX','','Originate','$VqueryCID','Exten: $VDAD_dial_exten','Context: $ext_context','Channel: $local_DEF$Ndialstring$local_AMP$ext_context','Priority: 1','Callerid: $CIDstring','Timeout: $Local_dial_timeout','','','','VDACnote: $DBfill_campaign[$camp_CIPct]|$lead_id|$phone_code|$phone_number|OUTBALANCE|$alt_dial|$DBIPqueue_priority[$camp_CIPct]|$server_ip|$CCIDtype')";

														$vac_inserts[$staggered_ct] = "INSERT INTO vicidial_auto_calls (server_ip,campaign_id,status,lead_id,callerid,phone_code,phone_number,call_time,call_type,alt_dial,queue_priority) values('XXXXXXXXXXXXXXX','$DBfill_campaign[$camp_CIPct]','SENT','$lead_id','$VqueryCID','$phone_code','$phone_number','$SQLdate','OUTBALANCE','$alt_dial','$DBIPqueue_priority[$camp_CIPct]')";

														$st_logged[$staggered_ct] = "$phone_number|$DBfill_campaign[$camp_CIPct]|$VqueryCID|$gmt_offset_now|$alt_dial|$CCIDtype|";

														$vddl_inserts[$staggered_ct] = "INSERT INTO vicidial_dial_log SET caller_code='$VqueryCID',lead_id='$lead_id',server_ip='XXXXXXXXXXXXXXX',call_date='$SQLdate',extension='$VDAD_dial_exten',channel='$local_DEF$Ndialstring$local_AMP$ext_context',timeout='$Local_dial_timeout',outbound_cid='$CIDstring',context='$ext_context';";

														$vltfh_inserts[$staggered_ct] = "INSERT INTO vicidial_lead_24hour_calls SET lead_id='$lead_id',list_id='$list_id',call_date=NOW(),phone_number='$phone_number',phone_code='$phone_code',state='$TFhourSTATE',call_type='AUTO';";

														$vdcl_inserts[$staggered_ct] = "INSERT INTO vicidial_dial_cid_log SET caller_code='$VqueryCID',call_date='$SQLdate',call_type='OUTBALANCE',call_alt='$alt_dial',outbound_cid='$CCID',outbound_cid_type='$CCIDtype';";

														$DB_camp_servers_calls_placed++;
														$calls_placed++;
														$staggered_ct++;
														}

													if ($staggered < 1)
														{
														### sleep for 2.5 hundredths of a second to not flood the server with new calls
													#	usleep(1*25*1000);
														usleep(1*$per_call_delay*1000);
														}
													}
												}
											$call_CMPIPct++;
											}
										}
									}
								}
							else
								{
								$event_string.="No Agents logged in, not dialing";
								&event_logger;
								}

							$server_CIPct++;
							}
						}
					else
						{
						$event_string.="No Balance Servers available that do not have a shortage, or no fill calls required";
						&event_logger;
						}


					###############################################################################
					###### BEGIN - experimental balanced FILL dialing ($staggered)
					###############################################################################
					if ( ($staggered > 0) && ($staggered_ct > 0) )
						{
						$staggered_fill=0;
						$stmtA = "SELECT count(*),vicidial_balance_rank FROM servers where vicidial_balance_active = 'Y' group by vicidial_balance_rank order by vicidial_balance_rank desc;";
						$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
						$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
						$sthArows=$sthA->rows;
						$st_ct=0;
						while ($sthArows > $st_ct)
							{
							@aryA = $sthA->fetchrow_array;
							$ST_count[$st_ct] =	$aryA[0];
							$ST_rank[$st_ct] =	$aryA[1];
							$st_ct++;
							}
						$sthA->finish();

						##### gather available trunks on all servers and place calls
						$staggered_rank_ct=0;
						while ( ($st_ct > $staggered_rank_ct) && ($staggered_ct > $staggered_fill) )
							{
							$stmtA = "SELECT server_ip,asterisk_version,routing_prefix FROM servers where vicidial_balance_rank='$ST_rank[$staggered_rank_ct]' and vicidial_balance_active = 'Y' order by server_ip LIMIT $ST_count[$staggered_rank_ct];";
							$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
							$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
							$sthArowsSIPS=$sthA->rows;
							$TOTAL_available=0;
							$st_si_ct=0;
							while ($sthArowsSIPS > $st_si_ct)
								{
								@aryA = $sthA->fetchrow_array;
								$ST_server_ip[$st_si_ct] =			$aryA[0];
								$ST_asterisk_version[$st_si_ct] =	$aryA[1];
								$ST_routing_prefix[$st_si_ct] =		$aryA[2];

								$io=0;
								foreach(@DB_camp_server_server_ip)
									{
									if ( ($DB_camp_server_server_ip[$io] =~ /$ST_server_ip[$st_si_ct]/) && (length($DB_camp_server_server_ip[$io]) == length($ST_server_ip[$st_si_ct])) ) 
										{
										$ST_available[$st_si_ct] = $SERVER_CAMP_temp_avail[$io];
										$ST_tally[$st_si_ct] = $SERVER_CAMP_temp_tally[$io];
										$TOTAL_available = ($TOTAL_available + $ST_available[$st_si_ct]);
										}
									$io++;
									}
								$st_si_ct++;
								}
							$sthA->finish();

							##### place calls
							$failsafe_ct=0;
							$RANK_calls_placed=0;
							$st_si_loop=0;
							$TEMP_server_ip = '';
							$TEMP_asterisk_version = '';
							$TEMP_routing_prefix = '';
							$TEMP_vm_insert = '';
							$TEMP_vac_insert = '';
							$TEMP_vl_update = '';
							$TEMP_st_logged = '';
							$TEMP_vddl_inserts = '';
							$TEMP_vltfh_inserts = '';
							$TEMP_vdcl_inserts = '';
							$TEMP_vm_insert = '';
							$TEMP_vac_insert = '';
							$TEMP_vddl_inserts = '';

							while ( ($TOTAL_available > $RANK_calls_placed) && ($failsafe_ct < 99999) && ($staggered_fill <= $staggered_ct) )
								{
								$TEMP_server_ip = $ST_server_ip[$st_si_loop];
								$TEMP_asterisk_version = $ST_asterisk_version[$st_si_loop];
								$TEMP_routing_prefix = $ST_routing_prefix[$st_si_loop];

								$TEMP_vm_insert = $vm_inserts[$staggered_fill];
								$TEMP_vac_insert = $vac_inserts[$staggered_fill];
								$TEMP_vl_update = $vl_updates[$staggered_fill];
								$TEMP_vdc_update = $vdc_updates[$staggered_fill];
								$TEMP_vdcp_update = $vdcp_updates[$staggered_fill];
								$TEMP_st_logged = $st_logged[$staggered_fill];
								$TEMP_vddl_inserts = $vddl_inserts[$staggered_fill];
								$TEMP_vltfh_inserts = $vltfh_inserts[$staggered_fill];
								$TEMP_vdcl_inserts = $vdcl_inserts[$staggered_fill];

								$TEMP_vm_insert =~ s/XXXXXXXXXXXXXXX/$TEMP_server_ip/gi;
								$TEMP_vac_insert =~ s/XXXXXXXXXXXXXXX/$TEMP_server_ip/gi;
								$TEMP_vddl_inserts =~ s/XXXXXXXXXXXXXXX/$TEMP_server_ip/gi;

								# add the routing prefix for Asterisk 13+ systems
								%ast_ver_str = parse_asterisk_version($TEMP_asterisk_version);
					                        if (( $ast_ver_str{major} = 1 ) && ($ast_ver_str{minor} > 11))
									{ $TEMP_vm_insert =~ s/Exten: /Exten: $TEMP_routing_prefix/gi; }

								if (length($TEMP_vm_insert) > 20)
									{
									$affected_rows_vl = $dbhA->do($TEMP_vl_update);
									$affected_rows_vdc = $dbhA->do($TEMP_vdc_update);
									$affected_rows_vdcp = $dbhA->do($TEMP_vdcp_update);
									$affected_rows_vm = $dbhA->do($TEMP_vm_insert);
									$affected_rows_vac = $dbhA->do($TEMP_vac_insert);
									$affected_rows_vddl = $dbhA->do($TEMP_vddl_inserts);
									$affected_rows_vltfh = $dbhA->do($TEMP_vltfh_inserts);
									$affected_rows_vdcl = $dbhA->do($TEMP_vdcl_inserts);

									if ($DB) {print "LEAD UPDATE: $affected_rows_vl|$TEMP_vl_update|\n";}
									if ($DB) {print "LEAD CALL COUNT UPDATE: $affected_rows_vdc|$TEMP_vdc_update|\n";}
									if ($DB) {print "PHONE CALL COUNT UPDATE: $affected_rows_vdcp|$TEMP_vdcp_update|\n";}
									if ($DB) {print "VICIDIAL_MANAGER INSERT: $affected_rows_vm|$TEMP_vm_insert|\n";}
									if ($DB) {print "VICIDIAL_AUTO_CALLS INSERT: $affected_rows_vac|$TEMP_vac_insert|\n";}
									if ($DB) {print "VICIDIAL_DIAL_LOG INSERT: $affected_rows_vddl|$TEMP_vddl_inserts|\n";}
									if ($DB) {print "VICIDIAL_LEAD_24HOUR_CALLS INSERT: $affected_rows_vltfh|$TEMP_vltfh_inserts|\n";}
									if ($DB) {print "VICIDIAL_DIAL_CID_LOG INSERT: $affected_rows_vdcl|$TEMP_vdcl_inserts|\n";}
									}

								$event_string = "|     number call stagger dialed|$TEMP_vm_insert|$TEMP_server_ip|$staggered_fill|$staggered_ct|$affected_rows_vm|$affected_rows_vac|$affected_rows_vl|$affected_rows_vddl|$affected_rows_vltfh|$affected_rows_vdcl   $TEMP_st_logged";
								 &event_logger;

								### sleep for 2.5 hundredths of a second to not flood the server with new calls
							#	usleep(1*25*1000);
								usleep(1*$per_call_delay*1000);

								$RANK_calls_placed++;
								$staggered_fill++;
								$failsafe_ct++;
								$st_si_loop++;
								if ($st_si_loop >= $st_si_ct)
									{$st_si_loop=0;}
								}

							$staggered_rank_ct++;
							}
						}
					$staggered_ct=0;
					@ST_server_ip=@MT;
					@ST_available=@MT;
					@ST_tally=@MT;
					@vm_inserts=@MT;
					@vac_inserts=@MT;
					@vl_updates=@MT;
					@vdc_updates=@MT;
					@vdcp_updates=@MT;
					@st_logged=@MT;
					@vddl_inserts=@MT;
					###############################################################################
					###### END - experimental balanced FILL dialing ($staggered)
					###############################################################################


					$temp_balance_total = ($DBfill_current_balance[$camp_CIPct] + $DBfill_tally[$camp_CIPct]);
					if ($DB) {print "CURRENT FILL: $temp_balance_total = ($DBfill_current_balance[$camp_CIPct] + $DBfill_tally[$camp_CIPct])\n";}
					$stmtA = "UPDATE vicidial_campaign_stats SET balance_trunk_fill='$temp_balance_total' where campaign_id='$DBfill_campaign[$camp_CIPct]';";
					$affected_rows = $dbhA->do($stmtA);

					if ($calls_placed > 0)
						{
						$stmtA="UPDATE vicidial_campaigns SET campaign_calldate='$now_date' where campaign_id='$DBfill_campaign[$camp_CIPct]';";
						$affected_rows = $dbhA->do($stmtA);
						$calls_placed=0;
						}

					$camp_CIPct++;
					}
				}
		##################################################################################
		##### END LOOP IF THERE ARE BALANCE SERVERS AND THERE ARE SHORTAGES
		##################################################################################
			else
				{
				if ($DB) {print "No Balance servers or no shortages\n";}
				$stmtA = "UPDATE vicidial_campaign_stats SET balance_trunk_fill='0';";
				$affected_rows = $dbhA->do($stmtA);

				$event_string.="No Balance Servers available or No Shortages";
				&event_logger;
				}
			}



	&get_time_now;


		if ($LUcount > 0)
			{
			chop($lists_update);
			$stmtA = "UPDATE vicidial_lists SET list_lastcalldate='$SQLdate' where list_id IN($lists_update);";
			$affected_rows = $dbhA->do($stmtA);
			$event_string = "|     lastcalldate UPDATED $affected_rows|$lists_update|";
			 &event_logger;
			}



	###############################################################################
	###### last, wait for a little bit and repeat the loop
	###############################################################################

		### sleep for 2 and a half seconds before beginning the loop again
		usleep(1*$loop_delay*1000);

		$endless_loop--;
		if($DB){print STDERR "\nloop counter: |$endless_loop|\n";}

		### putting a blank file called "VDADfull.kill" in the directory will automatically safely kill this program
		if (-e "$PATHhome/VDADfull.kill")
			{
			unlink("$PATHhome/VDADfull.kill");
			$endless_loop=0;
			$one_day_interval=0;
			print "\nPROCESS KILLED MANUALLY... EXITING\n\n"
			}
		if ($endless_loop =~ /0$/)	# run every ten cycles (about 25 seconds)
			{
			### Grab Server values from the database
			$stmtA = "SELECT vd_server_logs 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;
			if ($sthArows > 0)
				{
				@aryA = $sthA->fetchrow_array;
				$DBvd_server_logs =			$aryA[0];
				if ($DBvd_server_logs =~ /Y/)	{$SYSLOG = '1';}
				else {$SYSLOG = '0';}
				}
			$sthA->finish();

			### Grab Server values from the database in case they've changed
			$stmtA = "SELECT max_vicidial_trunks,answer_transfer_agent,local_gmt,ext_context FROM servers where server_ip = '$server_ip';";
			$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
			$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
			$sthArows=$sthA->rows;
			if ($sthArows > 0)
				{
				@aryA = $sthA->fetchrow_array;
				$DBmax_vicidial_trunks	=	$aryA[0];
				$DBanswer_transfer_agent=	$aryA[1];
				$DBSERVER_GMT		=		$aryA[2];
				$DBext_context	=			$aryA[3];
				if ($DBmax_vicidial_trunks)		{$max_vicidial_trunks = $DBmax_vicidial_trunks;}
				if ($DBanswer_transfer_agent)	{$answer_transfer_agent = $DBanswer_transfer_agent;}
				if ($DBSERVER_GMT)				{$SERVER_GMT = $DBSERVER_GMT;}
				if ($DBext_context)				{$ext_context = $DBext_context;}
				}
			$sthA->finish();

			$event_string = "|     updating server parameters $max_vicidial_trunks|$answer_transfer_agent|$SERVER_GMT|$ext_context|$DBvd_server_logs|$SYSLOG|";
			&event_logger;
			&get_time_now;
			}

		# update internal process log
		$iLog_ct++;
		if ($iLog_ct =~ /00$/) 
			{
			$stmtA = "UPDATE vicidial_internal_log SET up_time=NOW(), action='running', stage='Loops: $iLog_ct' WHERE process='$script_name' and server_ip='$server_ip' order by db_time desc limit 1;";
			if($DB){print STDERR "|$stmtA|";}
			my $affected_rows = $dbhA->do($stmtA);
			if($DB){print STDERR "$affected_rows|\n";}
			}

		$stat_count++;
		}


	if($DB){print "DONE... Exiting... Goodbye... See you later... Not really, initiating next loop...\n";}

	$event_string='HANGING UP|';
	&event_logger;

	$one_day_interval--;
	}

$event_string='CLOSING DB CONNECTION|';
&event_logger;


$dbhA->disconnect();


if($DB){print "DONE... Exiting... Goodbye... See you later... Really I mean it this time\n";}


exit;













sub get_time_now	#get the current date and time and epoch for logging call lengths and datetimes
	{
	$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);
		if ($hour < 10) {$hour = "0$hour";}
		if ($min < 10) {$min = "0$min";}

		if ($DB) {print "TIME DEBUG: $LOCAL_GMT_OFF_STD|$LOCAL_GMT_OFF|$isdst|   GMT: $hour:$min\n";}

	($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";}

	$now_date_epoch = time();
	$now_date = "$year-$mon-$mday $hour:$min:$sec";
	$file_date = "$year-$mon-$mday";
	$CIDdate = "$mon$mday$hour$min$sec";
	$tsSQLdate = "$year$mon$mday$hour$min$sec";
	$SQLdate = "$year-$mon-$mday $hour:$min:$sec";
		while (length($CIDdate) > 9) {$CIDdate =~ s/^.//gi;} # 0902235959 changed to 902235959

	$BDtarget = ($secX - 10);
	($Bsec,$Bmin,$Bhour,$Bmday,$Bmon,$Byear,$Bwday,$Byday,$Bisdst) = localtime($BDtarget);
	$Byear = ($Byear + 1900);
	$Bmon++;
	if ($Bmon < 10) {$Bmon = "0$Bmon";}
	if ($Bmday < 10) {$Bmday = "0$Bmday";}
	if ($Bhour < 10) {$Bhour = "0$Bhour";}
	if ($Bmin < 10) {$Bmin = "0$Bmin";}
	if ($Bsec < 10) {$Bsec = "0$Bsec";}
		$BDtsSQLdate = "$Byear$Bmon$Bmday$Bhour$Bmin$Bsec";

	$PDtarget = ($secX - 30);
	($Psec,$Pmin,$Phour,$Pmday,$Pmon,$Pyear,$Pwday,$Pyday,$Pisdst) = localtime($PDtarget);
	$Pyear = ($Pyear + 1900);
	$Pmon++;
	if ($Pmon < 10) {$Pmon = "0$Pmon";}
	if ($Pmday < 10) {$Pmday = "0$Pmday";}
	if ($Phour < 10) {$Phour = "0$Phour";}
	if ($Pmin < 10) {$Pmin = "0$Pmin";}
	if ($Psec < 10) {$Psec = "0$Psec";}
		$PDtsSQLdate = "$Pyear$Pmon$Pmday$Phour$Pmin$Psec";
		$halfminSQLdate = "$Pyear-$Pmon-$Pmday $Phour:$Pmin:$Psec";

	$XDtarget = ($secX - 1200);
	($Xsec,$Xmin,$Xhour,$Xmday,$Xmon,$Xyear,$Xwday,$Xyday,$Xisdst) = localtime($XDtarget);
	$Xyear = ($Xyear + 1900);
	$Xmon++;
	if ($Xmon < 10) {$Xmon = "0$Xmon";}
	if ($Xmday < 10) {$Xmday = "0$Xmday";}
	if ($Xhour < 10) {$Xhour = "0$Xhour";}
	if ($Xmin < 10) {$Xmin = "0$Xmin";}
	if ($Xsec < 10) {$Xsec = "0$Xsec";}
		$XDSQLdate = "$Xyear-$Xmon-$Xmday $Xhour:$Xmin:$Xsec";

	$TDtarget = ($secX - 600);
	($Tsec,$Tmin,$Thour,$Tmday,$Tmon,$Tyear,$Twday,$Tyday,$Tisdst) = localtime($TDtarget);
	$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";}
		$TDSQLdate = "$Tyear-$Tmon-$Tmday $Thour:$Tmin:$Tsec";
	}


sub event_logger
	{
	if ($DB) {print "$now_date|$event_string|\n";}
	if ($SYSLOG)
		{
		### open the log file for writing ###
		open(Lout, ">>$VDADLOGfile")
				|| die "Can't open $VDADLOGfile: $!\n";
		print Lout "$now_date|$event_string|\n";
		close(Lout);
		}
	$event_string='';
	}



# subroutine to parse the asterisk version
# and return a hash with the various part
sub parse_asterisk_version
{
        # grab the arguments
        my $ast_ver_str = $_[0];

        # get everything after the - and put it in $ast_ver_postfix
        my @hyphen_parts = split( /-/ , $ast_ver_str );

        my $ast_ver_postfix = $hyphen_parts[1];

        # now split everything before the - up by the .
        my @dot_parts = split( /\./ , $hyphen_parts[0] );

        my %ast_ver_hash;

        if ( $dot_parts[0] <= 1 )
                {
                        %ast_ver_hash = (
                                "major" => $dot_parts[0],
                                "minor" => $dot_parts[1],
                                "build" => $dot_parts[2],
                                "revision" => $dot_parts[3],
                                "postfix" => $ast_ver_postfix
                        );
                }

        # digium dropped the 1 from asterisk 10 but we still need it
        if ( $dot_parts[0] > 1 )
                {
                        %ast_ver_hash = (
                                "major" => 1,
                                "minor" => $dot_parts[0],
                                "build" => $dot_parts[1],
                                "revision" => $dot_parts[2],
                                "postfix" => $ast_ver_postfix
                        );
                }

        return ( %ast_ver_hash );
}


sub internal_logger
	{
	$stmtA = "INSERT INTO vicidial_internal_log SET db_time=NOW(), up_time=NOW(), process='$script_name', server_ip='$server_ip', action='$action', stage='$stage';";
	if($DB){print STDERR "|$stmtA|";}
	my $affected_rows = $dbhA->do($stmtA);
	if($DB){print STDERR "$affected_rows|\n";}
	}