diff --git a/UPGRADE b/UPGRADE
index c1ab6de8..658eb001 100644
--- a/UPGRADE
+++ b/UPGRADE
@@ -27,6 +27,11 @@ NOTE: Upgrading from 1.1.12-3 to 2.0.1 is at the bottom
 
 5. Added RANDOM and LAST CALL TIME lead order options to campaigns
 
+6. Changed List Mix to be active by default, depricated the 
+	AST_VDhopper_MIXtest.pl script, if you use it change it to the
+	AST_VDhopper.pl in your crontab entries
+
+
 
 
 
diff --git a/bin/AST_VDhopper.pl b/bin/AST_VDhopper.pl
index 6f8e98ba..3b55f114 100644
--- a/bin/AST_VDhopper.pl
+++ b/bin/AST_VDhopper.pl
@@ -51,6 +51,7 @@
 # 80713-0028 - Changed Recycling methodology
 # 80909-1901 - Added support for campaign-specific DNC lists
 # 90430-0117 - Added last call time and random sorting options
+# 90430-1022 - Changed this script to allow for List Mix ability
 #
 
 # constants
@@ -415,6 +416,7 @@ while ($sthArows > $rec_count)
 	$adaptive_dropped_percentage[$rec_count] =	$aryA[48];
 	$adaptive_maximum_level[$rec_count] =		$aryA[49];
 	$dial_statuses[$rec_count] =				$aryA[61];
+	$list_order_mix[$rec_count] =				$aryA[64];
 	$use_campaign_dnc[$rec_count] =				$aryA[95];
 
 	$rec_count++;
@@ -427,22 +429,25 @@ if ($DB) {print "CAMPAIGNS TO PROCESSES HOPPER FOR:  $rec_count|$#campaign_id\n"
 $i=0;
 foreach(@campaign_id)
 	{
-	### BEGIN - GATHER STATS FOR THE vicidial_campaign_stats TABLE ###
 	$vicidial_log = 'vicidial_log';
 	$VCSdialable_leads[$i]=0;
 
-	$dial_statuses[$i] =~ s/ -$//gi;
-	@Dstatuses = split(/ /,$dial_statuses[$i]);
-	$Ds_to_print = (($#Dstatuses) + 0);
-	$STATUSsql[$i]='';
-	$o=0;
-	while ($Ds_to_print > $o) 
+	if ($list_order_mix[$i] =~ /DISABLED/)
 		{
-		$o++;
-		$STATUSsql[$i] .= "'$Dstatuses[$o]',";
+		### BEGIN - GATHER STATS FOR THE vicidial_campaign_stats TABLE ###
+		$dial_statuses[$i] =~ s/ -$//gi;
+		@Dstatuses = split(/ /,$dial_statuses[$i]);
+		$Ds_to_print = (($#Dstatuses) + 0);
+		$STATUSsql[$i]='';
+		$o=0;
+		while ($Ds_to_print > $o) 
+			{
+			$o++;
+			$STATUSsql[$i] .= "'$Dstatuses[$o]',";
+			}
+		if (length($STATUSsql[$i])<3) {$STATUSsql[$i]="''";}
+		else {chop($STATUSsql[$i]);}
 		}
-	if (length($STATUSsql[$i])<3) {$STATUSsql[$i]="''";}
-	else {chop($STATUSsql[$i]);}
 
 	$stmtA = "SELECT dialable_leads from vicidial_campaign_stats where campaign_id='$campaign_id[$i]';";
 	$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
@@ -1115,6 +1120,43 @@ foreach(@campaign_id)
 		if ($DB) {print "     campaign lists count: $rec_countLISTS | $camp_lists[$i]\n";}
 		if ($DBX) {print "     |$stmtA|\n";}
 
+		if ($list_order_mix[$i] !~ /DISABLED/)
+			{
+			$stmtA = "SELECT vcl_id,vcl_name,list_mix_container,mix_method FROM vicidial_campaigns_list_mix where campaign_id='$campaign_id[$i]' and status='ACTIVE';";
+			$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;
+				$vcl_id[$i] =				"$aryA[0]";
+				$vcl_name[$i] =				"$aryA[1]";
+				$list_mix_container[$i] =	"$aryA[2]";
+				$mix_method[$i] =			"$aryA[3]";
+				$rec_count++;
+				}
+			$sthA->finish();
+
+			@list_mixARY=@MT;
+			$list_mix_dialableSQL='';
+			@list_mixARY = split(/:/,$list_mix_container[$i]);
+			$x=0;
+			foreach(@list_mixARY)
+				{
+				if ($x > 0) {$list_mix_dialableSQL .= " or ";}
+				@list_mix_stepARY = split(/\|/,$list_mixARY[$x]);
+				$list_mix_stepARY[3] =~ s/ /\',\'/gi;
+				$list_mix_stepARY[3] =~ s/^\',|,\'-//gi;
+				if ($DBX) {print "     LM $x ++$list_mixARY[$x]++ |$list_mix_stepARY[0]|$list_mix_stepARY[2]|$list_mix_stepARY[3]|\n";}
+				$list_mix_dialableSQL .= "(list_id='$list_mix_stepARY[0]' and status IN($list_mix_stepARY[3]))";
+
+				$x++;
+				}
+
+			if ($DB) {print "     campaign mix: $list_order_mix[$i] |$vcl_id[$i] - $vcl_name[$i]|$list_mix_container[$i]|$x|$mix_method[$i]|\n";}
+			}
+
 		if ( ($lead_filter_id[$i] !~ /NONE/) && (length($lead_filter_id[$i])>0) )
 			{
 			### Get SQL of lead filter for the campaign ###
@@ -1133,7 +1175,6 @@ foreach(@campaign_id)
 			$sthA->finish();
 			$lead_filter_sql[$i] =~ s/^and|and$|^or|or$|^ and|and $|^ or|or $//gi;
 			$lead_filter_sql[$i] = "and $lead_filter_sql[$i]";
-			if ($DB) {print "     campaign lists count: $rec_countLISTS | $camp_lists[$i]\n";}
 			if ($DB) {print "     lead filter $lead_filter_id[$i] defined for $campaign_id[$i]\n";}
 			if ($DBX) {print "     |$lead_filter_sql[$i]|\n";}
 			}
@@ -1144,7 +1185,15 @@ foreach(@campaign_id)
 			if ($DBX) {print "     |$lead_filter_id[$i]|\n";}
 			}
 
-		$stmtA = "SELECT count(*) FROM vicidial_list where called_since_last_reset='N' and status IN($STATUSsql[$i]) and list_id IN($camp_lists[$i]) and ($all_gmtSQL[$i]) $lead_filter_sql[$i];";
+		##### Get count of leads that are dialable #####
+		if ($list_order_mix[$i] =~ /DISABLED/)
+			{
+			$stmtA = "SELECT count(*) FROM vicidial_list where called_since_last_reset='N' and status IN($STATUSsql[$i]) and list_id IN($camp_lists[$i]) and ($all_gmtSQL[$i]) $lead_filter_sql[$i];";
+			}
+		else
+			{
+			$stmtA = "SELECT count(*) FROM vicidial_list where called_since_last_reset='N' and ($list_mix_dialableSQL) and ($all_gmtSQL[$i]) $lead_filter_sql[$i];";
+			}
 			if ($DBX) {print "     |$stmtA|\n";}
 		$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
 		$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
@@ -1160,7 +1209,7 @@ foreach(@campaign_id)
 			}
 		$sthA->finish();
 
-		if ($lead_order[$i] =~ / 2nd NEW$| 3rd NEW$| 4th NEW$| 5th NEW$| 6th NEW$/)
+		if ( ($lead_order[$i] =~ / 2nd NEW$| 3rd NEW$| 4th NEW$| 5th NEW$| 6th NEW$/) && ($list_order_mix[$i] =~ /DISABLED/) )
 			{
 			$stmtA = "SELECT count(*) FROM vicidial_list where called_since_last_reset='N' and status IN('NEW') and list_id IN($camp_lists[$i]) and ($all_gmtSQL[$i]) $lead_filter_sql[$i];";
 			$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
@@ -1179,7 +1228,7 @@ foreach(@campaign_id)
 			}
 
 		##### IF no NEW leads to be called, error out of this campaign #####
-		if ( ($lead_order[$i] =~ / 2nd NEW$| 3rd NEW$| 4th NEW$| 5th NEW$| 6th NEW$/) && ($NEW_campaign_leads_to_call[$i] > 0) ) {$GOOD=1;}
+		if ( ($lead_order[$i] =~ / 2nd NEW$| 3rd NEW$| 4th NEW$| 5th NEW$| 6th NEW$/) && ($NEW_campaign_leads_to_call[$i] > 0) && ($list_order_mix[$i] =~ /DISABLED/) ) {$GOOD=1;}
 		else
 			{
 			if ($lead_order[$i] !~ / 2nd NEW$| 3rd NEW$| 4th NEW$| 5th NEW$| 6th NEW$/)
@@ -1303,7 +1352,7 @@ foreach(@campaign_id)
 			@NEW_status_to_hopper=@MT;
 			@NEW_modify_to_hopper=@MT;
 			@NEW_user_to_hopper=@MT;
-			if ($NEW_count > 0)
+			if ( ($NEW_count > 0) && ($list_order_mix[$i] =~ /DISABLED/) )
 				{
 				$NEW_level = int($hopper_level[$i] / $NEW_count);   
 				$OTHER_level = ($hopper_level[$i] - $NEW_level);   
@@ -1350,63 +1399,155 @@ foreach(@campaign_id)
 			if ($campaign_leads_to_call[$i] > 0)
 				{
 				if ($DB) {print "     lead call order:      $order_stmt\n";}
-				$stmtA = "SELECT lead_id,list_id,gmt_offset_now,phone_number,state,status,modify_date,user FROM vicidial_list where called_since_last_reset='N' and status IN($STATUSsql[$i]) and list_id IN($camp_lists[$i]) and lead_id NOT IN($lead_id_lists) and ($all_gmtSQL[$i]) $lead_filter_sql[$i] $order_stmt limit $OTHER_level;";
-				if ($DBX) {print "     |$stmtA|\n";}
-				$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-				$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-				$sthArows=$sthA->rows;
-				while ($sthArows > $rec_count)
+
+				if ($list_order_mix[$i] =~ /DISABLED/)
 					{
-					@aryA = $sthA->fetchrow_array;
-					if ( ($NEW_count > 0) && ($NEW_rec_countLEADS > $NEW_in) )
+					$stmtA = "SELECT lead_id,list_id,gmt_offset_now,phone_number,state,status,modify_date,user FROM vicidial_list where called_since_last_reset='N' and status IN($STATUSsql[$i]) and list_id IN($camp_lists[$i]) and lead_id NOT IN($lead_id_lists) and ($all_gmtSQL[$i]) $lead_filter_sql[$i] $order_stmt limit $OTHER_level;";
+					if ($DBX) {print "     |$stmtA|\n";}
+					$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
+					$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
+					$sthArows=$sthA->rows;
+					while ($sthArows > $rec_count)
 						{
-						if ($DB_show_offset) {print "NEW_COUNT: $NEW_count|$NEW_dec|$NEW_in|$NEW_rec_countLEADS\n";}
-						if ($NEW_count > $NEW_dec) 
+						@aryA = $sthA->fetchrow_array;
+						if ( ($NEW_count > 0) && ($NEW_rec_countLEADS > $NEW_in) )
 							{
-							$NEW_dec++;
-							}
-						else
-							{
-							$leads_to_hopper[$rec_countLEADS] = "$NEW_leads_to_hopper[$NEW_in]";
-							$lists_to_hopper[$rec_countLEADS] = "$NEW_lists_to_hopper[$NEW_in]";
-							$gmt_to_hopper[$rec_countLEADS] = "$NEW_gmt_to_hopper[$NEW_in]";
-							$state_to_hopper[$rec_countLEADS] = "$NEW_state_to_hopper[$NEW_in]";
-							$phone_to_hopper[$rec_countLEADS] = "$NEW_phone_to_hopper[$NEW_in]";
-							$status_to_hopper[$rec_countLEADS] = "$NEW_status_to_hopper[$NEW_in]";
+							if ($DB_show_offset) {print "NEW_COUNT: $NEW_count|$NEW_dec|$NEW_in|$NEW_rec_countLEADS\n";}
+							if ($NEW_count > $NEW_dec) 
+								{
+								$NEW_dec++;
+								}
+							else
+								{
+								$leads_to_hopper[$rec_countLEADS] = "$NEW_leads_to_hopper[$NEW_in]";
+								$lists_to_hopper[$rec_countLEADS] = "$NEW_lists_to_hopper[$NEW_in]";
+								$gmt_to_hopper[$rec_countLEADS] = "$NEW_gmt_to_hopper[$NEW_in]";
+								$state_to_hopper[$rec_countLEADS] = "$NEW_state_to_hopper[$NEW_in]";
+								$phone_to_hopper[$rec_countLEADS] = "$NEW_phone_to_hopper[$NEW_in]";
+								$status_to_hopper[$rec_countLEADS] = "$NEW_status_to_hopper[$NEW_in]";
 							$modify_to_hopper[$rec_countLEADS] = "$NEW_modify_to_hopper[$NEW_in]";
 							$user_to_hopper[$rec_countLEADS] = "$NEW_user_to_hopper[$NEW_in]";
 							if ($DB_show_offset) {print "LEAD_ADD:    $NEW_leads_to_hopper[$NEW_in]   $NEW_phone_to_hopper[$NEW_in]\n";}
-							$rec_countLEADS++;
-							$NEW_in++;
-							$NEW_dec=2;
+								$rec_countLEADS++;
+								$NEW_in++;
+								$NEW_dec=2;
+								}
 							}
-						}
-					if ($REC_rec_countLEADS > $REC_insert_count)
-						{
-						$leads_to_hopper[$rec_countLEADS] = "$REC_leads_to_hopper[$REC_insert_count]";
-						$lists_to_hopper[$rec_countLEADS] = "$REC_lists_to_hopper[$REC_insert_count]";
-						$gmt_to_hopper[$rec_countLEADS] = "$REC_gmt_to_hopper[$REC_insert_count]";
-						$state_to_hopper[$rec_countLEADS] = "$REC_state_to_hopper[$REC_insert_count]";
-						$phone_to_hopper[$rec_countLEADS] = "$REC_phone_to_hopper[$REC_insert_count]";
-						$status_to_hopper[$rec_countLEADS] = "$REC_status_to_hopper[$REC_insert_count]";
+						if ($REC_rec_countLEADS > $REC_insert_count)
+							{
+							$leads_to_hopper[$rec_countLEADS] = "$REC_leads_to_hopper[$REC_insert_count]";
+							$lists_to_hopper[$rec_countLEADS] = "$REC_lists_to_hopper[$REC_insert_count]";
+							$gmt_to_hopper[$rec_countLEADS] = "$REC_gmt_to_hopper[$REC_insert_count]";
+							$state_to_hopper[$rec_countLEADS] = "$REC_state_to_hopper[$REC_insert_count]";
+							$phone_to_hopper[$rec_countLEADS] = "$REC_phone_to_hopper[$REC_insert_count]";
+							$status_to_hopper[$rec_countLEADS] = "$REC_status_to_hopper[$REC_insert_count]";
 						$modify_to_hopper[$rec_countLEADS] = "$REC_modify_to_hopper[$REC_insert_count]";
 						$user_to_hopper[$rec_countLEADS] = "$REC_user_to_hopper[$REC_insert_count]";
+							$rec_countLEADS++;
+							$REC_insert_count++;
+							}
+						$leads_to_hopper[$rec_countLEADS] = "$aryA[0]";
+						$lists_to_hopper[$rec_countLEADS] = "$aryA[1]";
+						$gmt_to_hopper[$rec_countLEADS] = "$aryA[2]";
+						$state_to_hopper[$rec_countLEADS] = "$aryA[4]";
+						$phone_to_hopper[$rec_countLEADS] = "$aryA[3]";
+						$status_to_hopper[$rec_countLEADS] = "$aryA[5]";
+						$modify_to_hopper[$rec_countLEADS] = "$aryA[6]";
+						$user_to_hopper[$rec_countLEADS] = "$aryA[7]";
+						if ($DB_show_offset) {print "LEAD_ADD: $aryA[2] $aryA[3] $aryA[4]\n";}
 						$rec_countLEADS++;
-						$REC_insert_count++;
+						$rec_count++;
+						}
+						$sthA->finish();
+					}
+
+			##### LIST MIX LEADS GRAB #####
+				else
+					{
+					$USX='_____';
+					$x=0;
+					$z=0;
+					@LM_results=@MT;
+					foreach(@list_mixARY)
+						{
+						$rec_count=0;
+						@list_mix_stepARY=@MT;
+
+						@list_mix_stepARY = split(/\|/,$list_mixARY[$x]);
+						$LM_step_goal[$x] = ( ($list_mix_stepARY[2] / 100) * $hopper_level[$i]);
+						$LM_step_even[$x] = ( (100 / $list_mix_stepARY[2]) * 100000);
+						$list_mix_stepARY[3] =~ s/ /','/gi;
+						$list_mix_stepARY[3] =~ s/^',|,'-//gi;
+						if ($DBX) {print "  LM $x |$list_mix_stepARY[0]|$list_mix_stepARY[2]|$LM_step_goal[$x]|$list_mix_stepARY[3]|\n";}
+						$list_mix_dialableSQL = "(list_id='$list_mix_stepARY[0]' and status IN($list_mix_stepARY[3]))";
+
+						$stmtA = "SELECT lead_id,list_id,gmt_offset_now,phone_number,state,status FROM vicidial_list where called_since_last_reset='N' and $list_mix_dialableSQL and lead_id NOT IN($lead_id_lists) and ($all_gmtSQL[$i]) $lead_filter_sql[$i] $order_stmt limit $LM_step_goal[$x];";
+						if ($DBX) {print "     |$stmtA|\n";}
+						$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
+						$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
+						$sthArows=$sthA->rows;
+						while ($sthArows > $rec_count)
+							{
+							@aryA = $sthA->fetchrow_array;
+							if ($mix_method[$i] =~ /RANDOM/) 
+								{
+								$order = int( rand(9999999)) + 10000000;
+								}
+							else 
+								{
+								if ($mix_method[$i] =~ /EVEN_MIX/) 
+									{
+									$order = ( ($rec_count * $LM_step_even[$x]) + $x);
+									}
+								else
+									{
+									$order = ( ($x * 1000000) + $rec_count);
+									}
+								}
+							$LM_results[$z] = "$order$USX$aryA[0]$USX$aryA[1]$USX$aryA[2]$USX$aryA[3]$USX$aryA[4]$USX$aryA[5]";
+						#	if ($DBX) {print "     $z|$LM_results[$z]\n";}
+
+							$rec_count++;
+							$z++;
+							}
+						$sthA->finish();
+
+						$x++;
+						}
+
+					@LM_results_SORT = sort { $a <=> $b } @LM_results;
+
+					$w=0;
+					while ($z > $w)
+						{
+						@aryA = split(/_____/,$LM_results_SORT[$w]);
+						if ($REC_rec_countLEADS > $REC_insert_count)
+							{
+							$leads_to_hopper[$rec_countLEADS] = "$REC_leads_to_hopper[$REC_insert_count]";
+							$lists_to_hopper[$rec_countLEADS] = "$REC_lists_to_hopper[$REC_insert_count]";
+							$gmt_to_hopper[$rec_countLEADS] = "$REC_gmt_to_hopper[$REC_insert_count]";
+							$state_to_hopper[$rec_countLEADS] = "$REC_state_to_hopper[$REC_insert_count]";
+							$phone_to_hopper[$rec_countLEADS] = "$REC_phone_to_hopper[$REC_insert_count]";
+							$status_to_hopper[$rec_countLEADS] = "$REC_status_to_hopper[$REC_insert_count]";
+						$modify_to_hopper[$rec_countLEADS] = "$REC_modify_to_hopper[$REC_insert_count]";
+						$user_to_hopper[$rec_countLEADS] = "$REC_user_to_hopper[$REC_insert_count]";
+							$rec_countLEADS++;
+							$REC_insert_count++;
+							}
+						$leads_to_hopper[$rec_countLEADS] = "$aryA[1]";
+						$lists_to_hopper[$rec_countLEADS] = "$aryA[2]";
+						$gmt_to_hopper[$rec_countLEADS] = "$aryA[3]";
+						$state_to_hopper[$rec_countLEADS] = "$aryA[4]";
+						$phone_to_hopper[$rec_countLEADS] = "$aryA[5]";
+						$status_to_hopper[$rec_countLEADS] = "$aryA[6]";
+						$modify_to_hopper[$rec_countLEADS] = "$aryA[6]";
+						$user_to_hopper[$rec_countLEADS] = "$aryA[7]";
+						if ($DB_show_offset) {print "LEAD_ADD: $aryA[3] $aryA[4] $aryA[5]\n";}
+						if ($DBX) {print "     $w|$LM_results[$w]\n";}
+						$rec_countLEADS++;
+						$w++;
 						}
-					$leads_to_hopper[$rec_countLEADS] = "$aryA[0]";
-					$lists_to_hopper[$rec_countLEADS] = "$aryA[1]";
-					$gmt_to_hopper[$rec_countLEADS] = "$aryA[2]";
-					$state_to_hopper[$rec_countLEADS] = "$aryA[4]";
-					$phone_to_hopper[$rec_countLEADS] = "$aryA[3]";
-					$status_to_hopper[$rec_countLEADS] = "$aryA[5]";
-					$modify_to_hopper[$rec_countLEADS] = "$aryA[6]";
-					$user_to_hopper[$rec_countLEADS] = "$aryA[7]";
-					if ($DB_show_offset) {print "LEAD_ADD: $aryA[2] $aryA[3] $aryA[4]\n";}
-					$rec_countLEADS++;
-					$rec_count++;
 					}
-					$sthA->finish();
 				}
 			### finish inserting any recycled leads if any
 			while ($REC_rec_countLEADS > $REC_insert_count)
@@ -1541,4 +1682,3 @@ if ($SYSLOG)
 	}
 $detail_string='';
 }
-
diff --git a/bin/AST_VDhopper_MIXtest.pl b/bin/AST_VDhopper_MIXtest.pl
deleted file mode 100644
index ef59d542..00000000
--- a/bin/AST_VDhopper_MIXtest.pl
+++ /dev/null
@@ -1,1664 +0,0 @@
-#!/usr/bin/perl
-#
-# AST_VDhopper.pl version 2.2.0   *TEST List Mix version*
-#
-# DESCRIPTION:
-# uses DBD::MySQL to update the VICIDIAL leads hopper for the streamlined 
-# approach of allocating leads to client machines. 
-#
-# SUMMARY:
-# This program was designed for people using the Asterisk PBX with VICIDIAL
-#
-# For the client to use VICIDIAL, this program must be in the cron running 
-# every minute
-# 
-# For this program to work you need to have the "asterisk" MySQL database 
-# created and create the tables listed in the CONF_MySQL.txt file, also make sure
-# that the machine running this program has read/write/update/delete access 
-# to that database
-# 
-# It is recommended that you run this program on the local Asterisk machine
-#
-# If this script is run ever minute and you are getting close to no leads after
-# a minute, you may want to play with the variables below to streamline for 
-# your usage
-#
-# Copyright (C) 2009  Matt Florell <vicidial@gmail.com>    LICENSE: AGPLv2
-#
-# CHANGELOG
-# 50810-1613 - Added database server variable definitions lookup
-# 60215-1106 - Added Scheduled Callback release functionality
-# 60228-1623 - Change Callback activation to set the called_since_last_reset=N
-# 60228-1735 - Added hopper gmt validation to remove gmt outside of time range
-# 60320-0932 - Added inactive lead list hopper deletion (Thanks Vic Jolin)
-# 60322-1030 - Added super debug output
-# 60418-0947 - Added lead filter per campaign
-# 60509-1416 - Rewrite of local_call_time functions
-# 60511-1150 - Added inserts into vicidial_campaign_stats table
-# 60609-1451 - Added ability to filter by DNC list vicidial_dnc
-# 60614-1159 - Added campaign lead recycling ability
-# 60715-2251 - Changed to use /etc/astguiclient.conf for configs
-# 60801-1634 - Fixed Callback activation bug 000008
-# 60814-1720 - Added option for no logging to file
-# 60822-1527 - Added campaign_stats and logging options for adaptive dialing
-# 60925-1330 - Fixed recycling leads issues
-# 61110-1513 - Changed Xth NEW to fill to hopper_level with standard if not enough NEW
-# 70219-1247 - Changed to use dial_statuses field instead of dial_status_x fields
-# 70708-1218 - Start of List-Mix-aware version of the hopper script
-# 70709-2033 - Functional Beta of List-Mix-aware version of the hopper script
-# 71029-1929 - Added 5th and 6th NEW to list order
-# 71030-2043 - Added hopper priority for callbacks
-# 80112-0221 - Added 2nd, 3rd,... NEW for LAST NAME/PHONE Sort
-# 80125-0821 - Added detail logging of each lead inserted
-# 80713-0028 - Changed Recycling methodology
-# 80909-1901 - Added support for campaign-specific DNC lists
-# 90430-0117 - Added last call time and random sorting options
-#
-
-# constants
-$DB=0;  # Debug flag, set to 0 for no debug messages, On an active system this will generate lots of lines of output per minute
-$US='__';
-$MT[0]='';
-#$vicidial_hopper='TEST_vicidial_hopper';	# for testing
-$vicidial_hopper='vicidial_hopper';
-
-# options
-$insert_auto_CB_to_hopper	= 1; # set to 1 to automatically insert ANYONE callbacks into the hopper
-
-
-$secT = time();
-$secX = time();
-($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) = localtime(time);
-$year = ($year + 1900);
-$mon++;
-$wtoday = $wday;
-if ($mon < 10) {$mon = "0$mon";}
-if ($mday < 10) {$mday = "0$mday";}
-if ($hour < 10) {$Fhour = "0$hour";}
-if ($min < 10) {$min = "0$min";}
-if ($sec < 10) {$sec = "0$sec";}
-$file_date = "$year-$mon-$mday";
-$now_date = "$year-$mon-$mday $hour:$min:$sec";
-$VDL_date = "$year-$mon-$mday 00:00:01";
-
-### get date-time of one hour ago ###
-	$VDL_hour = ($secX - (60 * 60));
-($Vsec,$Vmin,$Vhour,$Vmday,$Vmon,$Vyear,$Vwday,$Vyday,$Visdst) = localtime($VDL_hour);
-$Vyear = ($Vyear + 1900);
-$Vmon++;
-if ($Vmon < 10) {$Vmon = "0$Vmon";}
-if ($Vmday < 10) {$Vmday = "0$Vmday";}
-$VDL_hour = "$Vyear-$Vmon-$Vmday $Vhour:$Vmin:$Vsec";
-
-### get date-time of half hour ago ###
-	$VDL_halfhour = ($secX - (30 * 60));
-($Vsec,$Vmin,$Vhour,$Vmday,$Vmon,$Vyear,$Vwday,$Vyday,$Visdst) = localtime($VDL_halfhour);
-$Vyear = ($Vyear + 1900);
-$Vmon++;
-if ($Vmon < 10) {$Vmon = "0$Vmon";}
-if ($Vmday < 10) {$Vmday = "0$Vmday";}
-$VDL_halfhour = "$Vyear-$Vmon-$Vmday $Vhour:$Vmin:$Vsec";
-
-### get date-time of five minutes ago ###
-	$VDL_five = ($secX - (5 * 60));
-($Vsec,$Vmin,$Vhour,$Vmday,$Vmon,$Vyear,$Vwday,$Vyday,$Visdst) = localtime($VDL_five);
-$Vyear = ($Vyear + 1900);
-$Vmon++;
-if ($Vmon < 10) {$Vmon = "0$Vmon";}
-if ($Vmday < 10) {$Vmday = "0$Vmday";}
-$VDL_five = "$Vyear-$Vmon-$Vmday $Vhour:$Vmin:$Vsec";
-
-### get date-time of one minute ago ###
-	$VDL_one = ($secX - (1 * 60));
-($Vsec,$Vmin,$Vhour,$Vmday,$Vmon,$Vyear,$Vwday,$Vyday,$Visdst) = localtime($VDL_one);
-$Vyear = ($Vyear + 1900);
-$Vmon++;
-if ($Vmon < 10) {$Vmon = "0$Vmon";}
-if ($Vmday < 10) {$Vmday = "0$Vmday";}
-$VDL_one = "$Vyear-$Vmon-$Vmday $Vhour:$Vmin:$Vsec";
-
-### begin parsing run-time options ###
-if (length($ARGV[0])>1)
-{
-	$i=0;
-	while ($#ARGV >= $i)
-	{
-	$args = "$args $ARGV[$i]";
-	$i++;
-	}
-
-	if ($args =~ /--help/i)
-	{
-	print "allowed run time options(must stay in this order):\n  [--debug] = debug\n  [--debugX] = super debug\n  [--dbgmt] = show GMT offset of records as they are inserted into hopper\n  [--dbdetail] = additional level of logging the leads that are inserted into the hopper\n  [-t] = test\n  [--level=XXX] = force a hopper_level of XXX\n  [--campaign=XXX] = run for campaign XXX only\n\n";
-	exit;
-	}
-	else
-	{
-		if ($args =~ /--campaign=/i)
-		{
-		#	print "\n|$ARGS|\n\n";
-		@data_in = split(/--campaign=/,$args);
-			$CLIcampaign = $data_in[1];
-			$CLIcampaign =~ s/ .*$//gi;
-		}
-		else
-			{$CLIcampaign = '';}
-		if ($args =~ /--level=/i)
-		{
-		@data_in = split(/--level=/,$args);
-			$CLIlevel = $data_in[1];
-			$CLIlevel =~ s/ .*$//gi;
-			$CLIlevel =~ s/\D//gi;
-		print "\n-----HOPPER LEVEL OVERRIDE: $CLIlevel -----\n\n";
-		}
-		else
-			{$CLIlevel = '';}
-		if ($args =~ /--debug/i)
-		{
-		$DB=1;
-		print "\n----- DEBUG -----\n\n";
-		}
-		if ($args =~ /--debugX/i)
-		{
-		$DBX=1;
-		print "\n----- SUPER DEBUG -----\n\n";
-		}
-		if ($args =~ /--dbgmt/i)
-		{
-		$DB_show_offset=1;
-		print "\n-----DEBUG GMT -----\n\n";
-		}
-		if ($args =~ /--dbdetail/i)
-		{
-		$DB_detail=1;
-#		print "\n-----DEBUG DETAIL -----\n\n";
-		}
-		if ($args =~ /-t/i)
-		{
-		$T=1;   $TEST=1;
-		print "\n-----TESTING -----\n\n";
-		}
-		if ($args =~ /--wipe-hopper-clean/i)
-		{
-		$wipe_hopper_clean=1;
-		}
-	}
-}
-else
-{
-print "no command line options set\n";
-}
-
-# default path to astguiclient configuration file:
-$PATHconf =		'/etc/astguiclient.conf';
-
-open(conf, "$PATHconf") || die "can't open $PATHconf: $!\n";
-@conf = <conf>;
-close(conf);
-$i=0;
-foreach(@conf)
-	{
-	$line = $conf[$i];
-	$line =~ s/ |>|\n|\r|\t|\#.*|;.*//gi;
-	if ( ($line =~ /^PATHhome/) && ($CLIhome < 1) )
-		{$PATHhome = $line;   $PATHhome =~ s/.*=//gi;}
-	if ( ($line =~ /^PATHlogs/) && ($CLIlogs < 1) )
-		{$PATHlogs = $line;   $PATHlogs =~ s/.*=//gi;}
-	if ( ($line =~ /^PATHagi/) && ($CLIagi < 1) )
-		{$PATHagi = $line;   $PATHagi =~ s/.*=//gi;}
-	if ( ($line =~ /^PATHweb/) && ($CLIweb < 1) )
-		{$PATHweb = $line;   $PATHweb =~ s/.*=//gi;}
-	if ( ($line =~ /^PATHsounds/) && ($CLIsounds < 1) )
-		{$PATHsounds = $line;   $PATHsounds =~ s/.*=//gi;}
-	if ( ($line =~ /^PATHmonitor/) && ($CLImonitor < 1) )
-		{$PATHmonitor = $line;   $PATHmonitor =~ s/.*=//gi;}
-	if ( ($line =~ /^VARserver_ip/) && ($CLIserver_ip < 1) )
-		{$VARserver_ip = $line;   $VARserver_ip =~ s/.*=//gi;}
-	if ( ($line =~ /^VARDB_server/) && ($CLIDB_server < 1) )
-		{$VARDB_server = $line;   $VARDB_server =~ s/.*=//gi;}
-	if ( ($line =~ /^VARDB_database/) && ($CLIDB_database < 1) )
-		{$VARDB_database = $line;   $VARDB_database =~ s/.*=//gi;}
-	if ( ($line =~ /^VARDB_user/) && ($CLIDB_user < 1) )
-		{$VARDB_user = $line;   $VARDB_user =~ s/.*=//gi;}
-	if ( ($line =~ /^VARDB_pass/) && ($CLIDB_pass < 1) )
-		{$VARDB_pass = $line;   $VARDB_pass =~ s/.*=//gi;}
-	if ( ($line =~ /^VARDB_port/) && ($CLIDB_port < 1) )
-		{$VARDB_port = $line;   $VARDB_port =~ s/.*=//gi;}
-	$i++;
-	}
-
-if (!$VDHLOGfile) {$VDHLOGfile = "$PATHlogs/hopper.$year-$mon-$mday";}
-if (!$VDHDLOGfile) {$VDHDLOGfile = "$PATHlogs/hopper-detail.$year-$mon-$mday";}
-if (!$VARDB_port) {$VARDB_port='3306';}
-
-use DBI;	  
-
-$dbhA = DBI->connect("DBI:mysql:$VARDB_database:$VARDB_server:$VARDB_port", "$VARDB_user", "$VARDB_pass")
- or die "Couldn't connect to database: " . DBI->errstr;
-
-
-### Grab Server values from the database
-	$stmtA = "SELECT vd_server_logs,local_gmt FROM servers where server_ip = '$VARserver_ip';";
-	$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-	$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-	$sthArows=$sthA->rows;
-	$rec_count=0;
-	while ($sthArows > $rec_count)
-		{
-		 @aryA = $sthA->fetchrow_array;
-			$DBvd_server_logs =			"$aryA[0]";
-			$DBSERVER_GMT		=		"$aryA[1]";
-			if ($DBvd_server_logs =~ /Y/)	{$SYSLOG = '1';}
-				else {$SYSLOG = '0';}
-			if (length($DBSERVER_GMT)>0)	{$SERVER_GMT = $DBSERVER_GMT;}
-		 $rec_count++;
-		}
-	$sthA->finish();
-
-
-
-$secX = time();
-	($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) = localtime($secX);
-	$LOCAL_GMT_OFF = $SERVER_GMT;
-	$LOCAL_GMT_OFF_STD = $SERVER_GMT;
-	if ($isdst) {$LOCAL_GMT_OFF++;} 
-
-$GMT_now = ($secX - ($LOCAL_GMT_OFF * 3600));
-	($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) = localtime($GMT_now);
-	$mon++;
-	$year = ($year + 1900);
-	if ($mon < 10) {$mon = "0$mon";}
-	if ($mday < 10) {$mday = "0$mday";}
-	if ($hour < 10) {$hour = "0$hour";}
-	if ($min < 10) {$min = "0$min";}
-	if ($sec < 10) {$sec = "0$sec";}
-
-	if ($DB) {print "TIME DEBUG: $LOCAL_GMT_OFF_STD|$LOCAL_GMT_OFF|$isdst|   GMT: $hour:$min\n";}
-
-if ($wipe_hopper_clean)
-	{
-	$stmtA = "DELETE from $vicidial_hopper;";
-	$affected_rows = $dbhA->do($stmtA);
-	if ($DB) {print "Hopper Wiped Clean:  $affected_rows\n";}
-		$event_string = "|HOPPER WIPE CLEAN|";
-		&event_logger;
-
-	exit;
-	}
-### Delete leads from inactive lists if there are any
-$stmtA = "SELECT * FROM vicidial_lists where active='N';";
-if ($DB) {print $stmtA;}
-$inactive_lists='';
-$inactive_lists_count=0;
-$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-$sthArows=$sthA->rows;
-while ($sthArows > $inactive_lists_count)
-	{
-	@aryA = $sthA->fetchrow_array;
-	$inactive_list = $aryA[0];
-	$inactive_lists .= "'$inactive_list',";
-	$inactive_lists_count++;
-	}
-$sthA->finish();
-if ($DB) {print "Inactive Lists:  $inactive_lists_count\n";}
-
-if ($inactive_lists_count > 0)
-	{
-	chop($inactive_lists);
-	$stmtA = "DELETE from $vicidial_hopper where list_id IN($inactive_lists);";
-	$affected_rows = $dbhA->do($stmtA);
-	if ($DB) {print "Inactive List Leads Deleted:  $affected_rows |$stmtA|\n";}
-		$event_string = "|INACTIVE LIST DEL|$affected_rows|";
-		&event_logger;
-	}
-
-### BEGIN Change CBHOLD status leads to CALLBK if their vicidial_callbacks time has passed
-$stmtA = "SELECT count(*) FROM vicidial_callbacks where callback_time <= '$now_date' and status='ACTIVE';";
-$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-@aryA = $sthA->fetchrow_array;
-$CBHOLD_count = $aryA[0];
-	if ($DB) {print "CALLBACK HOLD: $CBHOLD_count|$stmtA|\n";}
-$sthA->finish();
-
-if ($CBHOLD_count > 0)
-	{
-	$update_leads='';
-	$cbc=0;
-	$cba=0;
-	$stmtA = "SELECT vicidial_callbacks.lead_id,recipient,campaign_id,vicidial_callbacks.list_id,gmt_offset_now,state FROM vicidial_callbacks,vicidial_list where callback_time <= '$now_date' and vicidial_callbacks.status='ACTIVE' and vicidial_callbacks.lead_id=vicidial_list.lead_id;";
-	$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-	$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-	$sthArows=$sthA->rows;
-	while ($sthArows > $cbc)
-		{
-		@aryA = $sthA->fetchrow_array;
-		$lead_ids[$cbc] = $aryA[0];
-		$recipient = $aryA[1];
-		$update_leads .= "'$lead_ids[$cbc]',";
-		if ($recipient =~ /ANYONE/)
-			{
-			$CA_lead_id[$cba] = $aryA[0];
-			$CA_campaign_id[$cba] = $aryA[2];
-			$CA_list_id[$cba] = $aryA[3];
-			$CA_gmt_offset_now[$cba] = $aryA[4];
-			$CA_state[$cba] = $aryA[5];
-			$cba++;
-			}
-		$cbc++;
-		}
-	$sthA->finish();
-	if ($cbc > 0)
-		{
-		chop($update_leads);
-
-		$stmtA = "UPDATE vicidial_callbacks set status='LIVE' where lead_id IN($update_leads) and status NOT IN('INACTIVE','DEAD','ARCHIVE');";
-		$affected_rows = $dbhA->do($stmtA);
-		if ($DB) {print "Scheduled Callbacks Activated:  $affected_rows\n";}
-			$event_string = "|CALLBACKS CB ACT |$affected_rows|";
-			&event_logger;
-
-		}
-	### INSERT ANYONE CALLBACKS INTO HOPPER DIRECTLY ###
-	if ( ($cba > 0) && ($insert_auto_CB_to_hopper) )
-		{
-		if ($DB) {print "ANYONE Scheduled Callbacks to Insert into hopper:  $cba\n";}
-			$event_string = "|ANYONE CB HOPPER |$cba|";
-			&event_logger;
-		$CAu=0;
-		foreach(@CA_lead_id)
-			{
-			$stmtA = "UPDATE vicidial_list set status='CALLBK', called_since_last_reset='N' where lead_id='$CA_lead_id[$CAu]';";
-			$affected_rows = $dbhA->do($stmtA);
-			if ($DB) {print "Scheduled Callbacks Activated:  $affected_rows\n";}
-				$event_string = "|CALLBACKS LISTACT|$affected_rows|";
-				&event_logger;
-
-			$stmtA = "INSERT INTO $vicidial_hopper SET lead_id='$CA_lead_id[$CAu]',campaign_id='$CA_campaign_id[$CAu]',list_id='$CA_list_id[$CAu]',gmt_offset_now='$CA_gmt_offset_now[$CAu]',user='',state='$CA_state[$CAu]',priority='50';";
-			$affected_rows = $dbhA->do($stmtA);
-			if ($DB) {print "ANYONE Scheduled Callback Inserted into hopper:  $affected_rows|$CA_lead_id[$CAu]\n";}
-			$CAu++;
-			}
-		}
-	}
-### END Change CBHOLD status leads to CALLBK if their vicidial_callbacks time has passed
-
-
-@campaign_id=@MT; 
-
-if ($CLIcampaign)
-	{
-	$stmtA = "SELECT * from vicidial_campaigns where campaign_id='$CLIcampaign'";
-	}
-else
-	{
-	$stmtA = "SELECT * from vicidial_campaigns where active='Y'";
-	}
-$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-$sthArows=$sthA->rows;
-$rec_count=0;
-while ($sthArows > $rec_count)
-	{
-	@aryA = $sthA->fetchrow_array;
-	$campaign_id[$rec_count] =		 "$aryA[0]";
-	$lead_order[$rec_count] =		 "$aryA[8]";
-	if (!$CLIlevel) 
-		{$hopper_level[$rec_count] = "$aryA[13]";}
-	else
-		{$hopper_level[$rec_count] = "$CLIlevel";}
-	$auto_dial_level[$rec_count] =	 "$aryA[14]";
-	$local_call_time[$rec_count] =	 "$aryA[16]";
-	$lead_filter_id[$rec_count] =	 "$aryA[35]";
-	$use_internal_dnc[$rec_count] =	 "$aryA[43]";
-	$dial_method[$rec_count] =					$aryA[46];
-	$available_only_ratio_tally[$rec_count] =	$aryA[47];
-	$adaptive_dropped_percentage[$rec_count] =	$aryA[48];
-	$adaptive_maximum_level[$rec_count] =		$aryA[49];
-	$dial_statuses[$rec_count] =				$aryA[61];
-	$list_order_mix[$rec_count] =				$aryA[64];
-	$use_campaign_dnc[$rec_count] =				$aryA[95];
-
-	$rec_count++;
-	}
-$sthA->finish();
-if ($DB) {print "CAMPAIGNS TO PROCESSES HOPPER FOR:  $rec_count|$#campaign_id\n";}
-
-
-##### LOOP THROUGH EACH CAMPAIGN AND PROCESS THE HOPPER #####
-$i=0;
-foreach(@campaign_id)
-	{
-	$vicidial_log = 'vicidial_log';
-	$VCSdialable_leads[$i]=0;
-
-	if ($list_order_mix[$i] =~ /DISABLED/)
-		{
-		### BEGIN - GATHER STATS FOR THE vicidial_campaign_stats TABLE ###
-		$dial_statuses[$i] =~ s/ -$//gi;
-		@Dstatuses = split(/ /,$dial_statuses[$i]);
-		$Ds_to_print = (($#Dstatuses) + 0);
-		$STATUSsql[$i]='';
-		$o=0;
-		while ($Ds_to_print > $o) 
-			{
-			$o++;
-			$STATUSsql[$i] .= "'$Dstatuses[$o]',";
-			}
-		if (length($STATUSsql[$i])<3) {$STATUSsql[$i]="''";}
-		else {chop($STATUSsql[$i]);}
-		}
-
-	$stmtA = "SELECT dialable_leads from vicidial_campaign_stats where campaign_id='$campaign_id[$i]';";
-	$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-	$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-	$sthArows=$sthA->rows;
-	$rec_count=0;
-	while ($sthArows > $rec_count)
-		{
-		@aryA = $sthA->fetchrow_array;
-		$VCSdialable_leads[$i] =		 "$aryA[0]";
-		$rec_count++;
-		}
-	$sthA->finish();
-	### END - GATHER STATS FOR THE vicidial_campaign_stats TABLE ###
-
-	##### BEGIN calculate what gmt_offset_now values are within the allowed local_call_time setting ###
-	$g=0;
-	$p='13';
-	$GMT_gmt[0] = '';
-	$GMT_hour[0] = '';
-	$GMT_day[0] = '';
-		if ($DBX) {print "\n   |GMT-DAY-HOUR|   ";}
-	while ($p > -13)
-		{
-		$pzone = ($GMT_now + ($p * 3600));
-			($psec,$pmin,$phour,$pmday,$pmon,$pyear,$pday,$pyday,$pisdst) = localtime($pzone);
-		$phour=($phour * 100);
-		$tz = sprintf("%.2f", $p);	
-		$GMT_gmt[$g] = "$tz";
-		$GMT_day[$g] = "$pday";
-		$GMT_hour[$g] = ($phour + $pmin);
-		$p = ($p - 0.25);
-			if ($DBX) {print "|$GMT_gmt[$g]-$GMT_day[$g]-$GMT_hour[$g]|";}
-		$g++;
-		}
-		if ($DBX) {print "\n";}
-
-	$stmtA = "SELECT * FROM vicidial_call_times where call_time_id='$local_call_time[$i]';";
-		if ($DBX) {print "   |$stmtA|\n";}
-	$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-	$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-	$sthArows=$sthA->rows;
-	$rec_count=0;
-	while ($sthArows > $rec_count)
-		{
-		@aryA = $sthA->fetchrow_array;
-		$Gct_default_start =	"$aryA[3]";
-		$Gct_default_stop =		"$aryA[4]";
-		$Gct_sunday_start =		"$aryA[5]";
-		$Gct_sunday_stop =		"$aryA[6]";
-		$Gct_monday_start =		"$aryA[7]";
-		$Gct_monday_stop =		"$aryA[8]";
-		$Gct_tuesday_start =	"$aryA[9]";
-		$Gct_tuesday_stop =		"$aryA[10]";
-		$Gct_wednesday_start =	"$aryA[11]";
-		$Gct_wednesday_stop =	"$aryA[12]";
-		$Gct_thursday_start =	"$aryA[13]";
-		$Gct_thursday_stop =	"$aryA[14]";
-		$Gct_friday_start =		"$aryA[15]";
-		$Gct_friday_stop =		"$aryA[16]";
-		$Gct_saturday_start =	"$aryA[17]";
-		$Gct_saturday_stop =	"$aryA[18]";
-		$Gct_state_call_times = "$aryA[19]";
-		$rec_count++;
-		}
-	$sthA->finish();
-
-
-	### BEGIN For lead recycling find out the no-call gap time and begin dial time for today
-	$lct_gap=0; # number of seconds from stopping of calling to starting of calling based on local call time
-	$lct_begin=0; # hour and minute of the begin time for the local call time
-	$lct_end=0; # hour and minute of the end time for the local call time
-
-	$secYESTERDAY = ($secX - (24 * 3600));
-		($ksec,$kmin,$khour,$kmday,$kmon,$kyear,$wyesterday,$kyday,$kisdst) = localtime($secYESTERDAY);
-
-	if ($wtoday < 1)	#### Sunday local time
-		{
-		if (($Gct_sunday_start < 1) && ($Gct_sunday_stop < 1)) {$lct_begin = $Gct_default_start;}
-		else {$lct_begin = $Gct_sunday_start;}
-		}
-	if ($wtoday==1)	#### Monday local time
-		{
-		if (($Gct_monday_start < 1) && ($Gct_monday_stop < 1)) {$lct_begin = $Gct_default_start;}
-		else {$lct_begin = $Gct_monday_start;}
-		}
-	if ($wtoday==2)	#### Tuesday local time
-		{
-		if (($Gct_tuesday_start < 1) && ($Gct_tuesday_stop < 1)) {$lct_begin = $Gct_default_start;}
-		else {$lct_begin = $Gct_tuesday_start;}
-		}
-	if ($wtoday==3)	#### Wednesday local time
-		{
-		if (($Gct_wednesday_start < 1) && ($Gct_wednesday_stop < 1)) {$lct_begin = $Gct_default_start;}
-		else {$lct_begin = $Gct_wednesday_start;}
-		}
-	if ($wtoday==4)	#### Thursday local time
-		{
-		if (($Gct_thursday_start < 1) && ($Gct_thursday_stop < 1)) {$lct_begin = $Gct_default_start;}
-		else {$lct_begin = $Gct_thursday_start;}
-		}
-	if ($wtoday==5)	#### Friday local time
-		{
-		if (($Gct_friday_start < 1) && ($Gct_friday_stop < 1)) {$lct_begin = $Gct_default_start;}
-		else {$lct_begin = $Gct_friday_start;}
-		}
-	if ($wtoday==6)	#### Saturday local time
-		{
-		if (($Gct_saturday_start < 1) && ($Gct_saturday_stop < 1)) {$lct_begin = $Gct_default_start;}
-		else {$lct_begin = $Gct_saturday_start;}
-		}
-
-
-	$dayBACKsec=0;
-	$weekBACK=0;
-	while ( ($lct_end < 1) && ($weekBACK <= 1) )
-		{
-		if ($wyesterday==6)	#### Saturday local time
-			{
-			if ($Gct_saturday_start > 2399) {$wyesterday = 0;   $dayBACKsec = ($dayBACKsec + 86400);   if ($DBX) {print "DayBACK: $wyesterday\n";}}
-			else
-				{
-				if (($Gct_saturday_start < 1) && ($Gct_saturday_stop < 1)) {$lct_end = $Gct_default_stop;}
-				else {$lct_end = $Gct_saturday_stop;}
-				}
-			}
-		if ($wyesterday==5)	#### Friday local time
-			{
-			if ($Gct_friday_start > 2399) {$wyesterday = 1;   $dayBACKsec = ($dayBACKsec + 86400);   if ($DBX) {print "DayBACK: $wyesterday\n";}}
-			else
-				{
-				if (($Gct_friday_start < 1) && ($Gct_friday_stop < 1)) {$lct_end = $Gct_default_stop;}
-				else {$lct_end = $Gct_friday_stop;}
-				}
-			}
-		if ($wyesterday==4)	#### Thursday local time
-			{
-			if ($Gct_thursday_start > 2399) {$wyesterday = 2;   $dayBACKsec = ($dayBACKsec + 86400);   if ($DBX) {print "DayBACK: $wyesterday\n";}}
-			else
-				{
-				if (($Gct_thursday_start < 1) && ($Gct_thursday_stop < 1)) {$lct_end = $Gct_default_stop;}
-				else {$lct_end = $Gct_thursday_stop;}
-				}
-			}
-		if ($wyesterday==3)	#### Wednesday local time
-			{
-			if ($Gct_wednesday_start > 2399) {$wyesterday = 3;   $dayBACKsec = ($dayBACKsec + 86400);   if ($DBX) {print "DayBACK: $wyesterday\n";}}
-			else
-				{
-				if (($Gct_wednesday_start < 1) && ($Gct_wednesday_stop < 1)) {$lct_end = $Gct_default_stop;}
-				else {$lct_end = $Gct_wednesday_stop;}
-				}
-			}
-		if ($wyesterday==2)	#### Tuesday local time
-			{
-			if ($Gct_tuesday_start > 2399) {$wyesterday = 4;   $dayBACKsec = ($dayBACKsec + 86400);   if ($DBX) {print "DayBACK: $wyesterday\n";}}
-			else
-				{
-				if (($Gct_tuesday_start < 1) && ($Gct_tuesday_stop < 1)) {$lct_end = $Gct_default_stop;}
-				else {$lct_end = $Gct_tuesday_stop;}
-				}
-			}
-		if ($wyesterday==1)	#### Monday local time
-			{
-			if ($Gct_monday_start > 2399) {$wyesterday = 5;   $dayBACKsec = ($dayBACKsec + 86400);   if ($DBX) {print "DayBACK: $wyesterday\n";}}
-			else
-				{
-				if (($Gct_monday_start < 1) && ($Gct_monday_stop < 1)) {$lct_end = $Gct_default_stop;}
-				else {$lct_end = $Gct_monday_stop;}
-				}
-			}
-		if ($wyesterday==0)	#### Sunday local time
-			{
-			if ($Gct_sunday_start > 2399) {$wyesterday = 6;   $dayBACKsec = ($dayBACKsec + 86400);   if ($DBX) {print "DayBACK: $wyesterday\n";}}
-			else
-				{
-				if (($Gct_sunday_start < 1) && ($Gct_sunday_stop < 1)) {$lct_end = $Gct_default_stop;}
-				else {$lct_end = $Gct_sunday_stop;}
-				}
-			}
-		$weekBACK++;
-		}
-
-	$lct_end = sprintf("%04d", $lct_end);
-	$lct_end_hour = substr($lct_end, 0, 2);
-	$lct_end_min = substr($lct_end, 2, 2);
-	$lct_begin = sprintf("%04d", $lct_begin);
-	$lct_begin_hour = substr($lct_begin, 0, 2);
-	$lct_begin_min = substr($lct_begin, 2, 2);
-
-	$lct_gap = ( ( ( ( ( (24 - $lct_end_hour) + $lct_begin_hour) * 3600) + ($lct_begin_min * 60) ) - ($lct_end_min * 60) ) + $dayBACKsec);
-
-	if ($DBX) {print "LocalCallTime No-Call Gap: |$lct_gap|$lct_end($lct_end_hour $lct_end_min)|$lct_begin($lct_begin_hour $lct_begin_min)|$wtoday|$wyesterday|\n";}
-
-	### END For lead recycling find out the no-call gap time and begin dial time for today
-
-
-	$ct_states = '';
-	$ct_state_gmt_SQL = '';
-	$del_state_gmt_SQL = '';
-	$ct_srs=0;
-	$b=0;
-	if (length($Gct_state_call_times)>2)
-		{
-		@state_rules = split(/\|/,$Gct_state_call_times);
-		$ct_srs = ($#state_rules - 2);
-		}
-	while($ct_srs >= $b)
-		{
-		if (length($state_rules[$b])>1)
-			{
-			$stmtA = "SELECT * from vicidial_state_call_times where state_call_time_id='$state_rules[$b]';";
-				if ($DBX) {print "   |$stmtA|\n";}
-			$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-			$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-			$sthArows=$sthA->rows;
-			$rec_count=0;
-			while ($sthArows > $rec_count)
-				{
-				@aryA = $sthA->fetchrow_array;
-				$Gstate_call_time_id =		"$aryA[0]";
-				$Gstate_call_time_state =	"$aryA[1]";
-				$Gsct_default_start =		"$aryA[4]";
-				$Gsct_default_stop =		"$aryA[5]";
-				$Gsct_sunday_start =		"$aryA[6]";
-				$Gsct_sunday_stop =			"$aryA[7]";
-				$Gsct_monday_start =		"$aryA[8]";
-				$Gsct_monday_stop =			"$aryA[9]";
-				$Gsct_tuesday_start =		"$aryA[10]";
-				$Gsct_tuesday_stop =		"$aryA[11]";
-				$Gsct_wednesday_start =		"$aryA[12]";
-				$Gsct_wednesday_stop =		"$aryA[13]";
-				$Gsct_thursday_start =		"$aryA[14]";
-				$Gsct_thursday_stop =		"$aryA[15]";
-				$Gsct_friday_start =		"$aryA[16]";
-				$Gsct_friday_stop =			"$aryA[17]";
-				$Gsct_saturday_start =		"$aryA[18]";
-				$Gsct_saturday_stop =		"$aryA[19]";
-				$ct_states .="'$Gstate_call_time_state',";
-				$rec_count++;
-				}
-			$sthA->finish();
-
-			$r=0;
-			$state_gmt='';
-			$del_state_gmt='';
-			while($r < $g)
-				{
-				if ($GMT_day[$r]==0)	#### Sunday local time
-					{
-					if (($Gsct_sunday_start==0) && ($Gsct_sunday_stop==0))
-						{
-						if ( ($GMT_hour[$r]>=$Gsct_default_start) && ($GMT_hour[$r]<$Gsct_default_stop) )
-							{$state_gmt.="'$GMT_gmt[$r]',";}
-						else
-							{$del_state_gmt.="'$GMT_gmt[$r]',";}
-						}
-					else
-						{
-						if ( ($GMT_hour[$r]>=$Gsct_sunday_start) && ($GMT_hour[$r]<$Gsct_sunday_stop) )
-							{$state_gmt.="'$GMT_gmt[$r]',";}
-						else
-							{$del_state_gmt.="'$GMT_gmt[$r]',";}
-						}
-					}
-				if ($GMT_day[$r]==1)	#### Monday local time
-					{
-					if (($Gsct_monday_start==0) && ($Gsct_monday_stop==0))
-						{
-						if ( ($GMT_hour[$r]>=$Gsct_default_start) && ($GMT_hour[$r]<$Gsct_default_stop) )
-							{$state_gmt.="'$GMT_gmt[$r]',";}
-						else
-							{$del_state_gmt.="'$GMT_gmt[$r]',";}
-						}
-					else
-						{
-						if ( ($GMT_hour[$r]>=$Gsct_monday_start) && ($GMT_hour[$r]<$Gsct_monday_stop) )
-							{$state_gmt.="'$GMT_gmt[$r]',";}
-						else
-							{$del_state_gmt.="'$GMT_gmt[$r]',";}
-						}
-					}
-				if ($GMT_day[$r]==2)	#### Tuesday local time
-					{
-					if (($Gsct_tuesday_start==0) && ($Gsct_tuesday_stop==0))
-						{
-						if ( ($GMT_hour[$r]>=$Gsct_default_start) && ($GMT_hour[$r]<$Gsct_default_stop) )
-							{$state_gmt.="'$GMT_gmt[$r]',";}
-						else
-							{$del_state_gmt.="'$GMT_gmt[$r]',";}
-						}
-					else
-						{
-						if ( ($GMT_hour[$r]>=$Gsct_tuesday_start) && ($GMT_hour[$r]<$Gsct_tuesday_stop) )
-							{$state_gmt.="'$GMT_gmt[$r]',";}
-						else
-							{$del_state_gmt.="'$GMT_gmt[$r]',";}
-						}
-					}
-				if ($GMT_day[$r]==3)	#### Wednesday local time
-					{
-					if (($Gsct_wednesday_start==0) && ($Gsct_wednesday_stop==0))
-						{
-						if ( ($GMT_hour[$r]>=$Gsct_default_start) && ($GMT_hour[$r]<$Gsct_default_stop) )
-							{$state_gmt.="'$GMT_gmt[$r]',";}
-						else
-							{$del_state_gmt.="'$GMT_gmt[$r]',";}
-						}
-					else
-						{
-						if ( ($GMT_hour[$r]>=$Gsct_wednesday_start) && ($GMT_hour[$r]<$Gsct_wednesday_stop) )
-							{$state_gmt.="'$GMT_gmt[$r]',";}
-						else
-							{$del_state_gmt.="'$GMT_gmt[$r]',";}
-						}
-					}
-				if ($GMT_day[$r]==4)	#### Thursday local time
-					{
-					if (($Gsct_thursday_start==0) && ($Gsct_thursday_stop==0))
-						{
-						if ( ($GMT_hour[$r]>=$Gsct_default_start) && ($GMT_hour[$r]<$Gsct_default_stop) )
-							{$state_gmt.="'$GMT_gmt[$r]',";}
-						else
-							{$del_state_gmt.="'$GMT_gmt[$r]',";}
-						}
-					else
-						{
-						if ( ($GMT_hour[$r]>=$Gsct_thursday_start) && ($GMT_hour[$r]<$Gsct_thursday_stop) )
-							{$state_gmt.="'$GMT_gmt[$r]',";}
-						else
-							{$del_state_gmt.="'$GMT_gmt[$r]',";}
-						}
-					}
-				if ($GMT_day[$r]==5)	#### Friday local time
-					{
-					if (($Gsct_friday_start==0) && ($Gsct_friday_stop==0))
-						{
-						if ( ($GMT_hour[$r]>=$Gsct_default_start) && ($GMT_hour[$r]<$Gsct_default_stop) )
-							{$state_gmt.="'$GMT_gmt[$r]',";}
-						else
-							{$del_state_gmt.="'$GMT_gmt[$r]',";}
-						}
-					else
-						{
-						if ( ($GMT_hour[$r]>=$Gsct_friday_start) && ($GMT_hour[$r]<$Gsct_friday_stop) )
-							{$state_gmt.="'$GMT_gmt[$r]',";}
-						else
-							{$del_state_gmt.="'$GMT_gmt[$r]',";}
-						}
-					}
-				if ($GMT_day[$r]==6)	#### Saturday local time
-					{
-					if (($Gsct_saturday_start==0) && ($Gsct_saturday_stop==0))
-						{
-						if ( ($GMT_hour[$r]>=$Gsct_default_start) && ($GMT_hour[$r]<$Gsct_default_stop) )
-							{$state_gmt.="'$GMT_gmt[$r]',";}
-						else
-							{$del_state_gmt.="'$GMT_gmt[$r]',";}
-						}
-					else
-						{
-						if ( ($GMT_hour[$r]>=$Gsct_saturday_start) && ($GMT_hour[$r]<$Gsct_saturday_stop) )
-							{$state_gmt.="'$GMT_gmt[$r]',";}
-						else
-							{$del_state_gmt.="'$GMT_gmt[$r]',";}
-						}
-					}
-				$r++;
-				}
-			$state_gmt = "$state_gmt'99'";
-			$del_state_gmt = "$del_state_gmt'99'";
-			$ct_state_gmt_SQL .= "or (state='$Gstate_call_time_state' && gmt_offset_now IN($state_gmt)) ";
-			$del_state_gmt_SQL .= "or (state='$Gstate_call_time_state' && gmt_offset_now IN($del_state_gmt)) ";
-			}
-
-		$b++;
-		}
-	if (length($ct_states)>2)
-		{
-		$ct_states =~ s/,$//gi;
-		$ct_statesSQL = "and state NOT IN($ct_states)";
-		}
-	else
-		{
-		$ct_statesSQL = "";
-		}
-
-	$r=0;
-	@default_gmt_ARY=@MT;
-	$dgA=0;
-	$default_gmt='';
-	$del_default_gmt='';
-	while($r < $g)
-		{
-		if ($GMT_day[$r]==0)	#### Sunday local time
-			{
-			if (($Gct_sunday_start==0) && ($Gct_sunday_stop==0))
-				{
-				if ( ($GMT_hour[$r]>=$Gct_default_start) && ($GMT_hour[$r]<$Gct_default_stop) )
-					{$default_gmt.="'$GMT_gmt[$r]',";   $default_gmt_ARY[$dgA] = "$GMT_gmt[$r]";   $dgA++;}
-				else
-					{$del_default_gmt.="'$GMT_gmt[$r]',";}
-				}
-			else
-				{
-				if ( ($GMT_hour[$r]>=$Gct_sunday_start) && ($GMT_hour[$r]<$Gct_sunday_stop) )
-					{$default_gmt.="'$GMT_gmt[$r]',";   $default_gmt_ARY[$dgA] = "$GMT_gmt[$r]";   $dgA++;}
-				else
-					{$del_default_gmt.="'$GMT_gmt[$r]',";}
-				}
-			}
-		if ($GMT_day[$r]==1)	#### Monday local time
-			{
-			if (($Gct_monday_start==0) && ($Gct_monday_stop==0))
-				{
-				if ( ($GMT_hour[$r]>=$Gct_default_start) && ($GMT_hour[$r]<$Gct_default_stop) )
-					{$default_gmt.="'$GMT_gmt[$r]',";   $default_gmt_ARY[$dgA] = "$GMT_gmt[$r]";   $dgA++;}
-				else
-					{$del_default_gmt.="'$GMT_gmt[$r]',";}
-				}
-			else
-				{
-				if ( ($GMT_hour[$r]>=$Gct_monday_start) && ($GMT_hour[$r]<$Gct_monday_stop) )
-					{$default_gmt.="'$GMT_gmt[$r]',";   $default_gmt_ARY[$dgA] = "$GMT_gmt[$r]";   $dgA++;}
-				else
-					{$del_default_gmt.="'$GMT_gmt[$r]',";}
-				}
-			}
-		if ($GMT_day[$r]==2)	#### Tuesday local time
-			{
-			if (($Gct_tuesday_start==0) && ($Gct_tuesday_stop==0))
-				{
-				if ( ($GMT_hour[$r]>=$Gct_default_start) && ($GMT_hour[$r]<$Gct_default_stop) )
-					{$default_gmt.="'$GMT_gmt[$r]',";   $default_gmt_ARY[$dgA] = "$GMT_gmt[$r]";   $dgA++;}
-				else
-					{$del_default_gmt.="'$GMT_gmt[$r]',";}
-				}
-			else
-				{
-				if ( ($GMT_hour[$r]>=$Gct_tuesday_start) && ($GMT_hour[$r]<$Gct_tuesday_stop) )
-					{$default_gmt.="'$GMT_gmt[$r]',";   $default_gmt_ARY[$dgA] = "$GMT_gmt[$r]";   $dgA++;}
-				else
-					{$del_default_gmt.="'$GMT_gmt[$r]',";}
-				}
-			}
-		if ($GMT_day[$r]==3)	#### Wednesday local time
-			{
-			if (($Gct_wednesday_start==0) && ($Gct_wednesday_stop==0))
-				{
-				if ( ($GMT_hour[$r]>=$Gct_default_start) && ($GMT_hour[$r]<$Gct_default_stop) )
-					{$default_gmt.="'$GMT_gmt[$r]',";   $default_gmt_ARY[$dgA] = "$GMT_gmt[$r]";   $dgA++;}
-				else
-					{$del_default_gmt.="'$GMT_gmt[$r]',";}
-				}
-			else
-				{
-				if ( ($GMT_hour[$r]>=$Gct_wednesday_start) && ($GMT_hour[$r]<$Gct_wednesday_stop) )
-					{$default_gmt.="'$GMT_gmt[$r]',";   $default_gmt_ARY[$dgA] = "$GMT_gmt[$r]";   $dgA++;}
-				else
-					{$del_default_gmt.="'$GMT_gmt[$r]',";}
-				}
-			}
-		if ($GMT_day[$r]==4)	#### Thursday local time
-			{
-			if (($Gct_thursday_start==0) && ($Gct_thursday_stop==0))
-				{
-				if ( ($GMT_hour[$r]>=$Gct_default_start) && ($GMT_hour[$r]<$Gct_default_stop) )
-					{$default_gmt.="'$GMT_gmt[$r]',";   $default_gmt_ARY[$dgA] = "$GMT_gmt[$r]";   $dgA++;}
-				else
-					{$del_default_gmt.="'$GMT_gmt[$r]',";}
-				}
-			else
-				{
-				if ( ($GMT_hour[$r]>=$Gct_thursday_start) && ($GMT_hour[$r]<$Gct_thursday_stop) )
-					{$default_gmt.="'$GMT_gmt[$r]',";   $default_gmt_ARY[$dgA] = "$GMT_gmt[$r]";   $dgA++;}
-				else
-					{$del_default_gmt.="'$GMT_gmt[$r]',";}
-				}
-			}
-		if ($GMT_day[$r]==5)	#### Friday local time
-			{
-			if (($Gct_friday_start==0) && ($Gct_friday_stop==0))
-				{
-				if ( ($GMT_hour[$r]>=$Gct_default_start) && ($GMT_hour[$r]<$Gct_default_stop) )
-					{$default_gmt.="'$GMT_gmt[$r]',";   $default_gmt_ARY[$dgA] = "$GMT_gmt[$r]";   $dgA++;}
-				else
-					{$del_default_gmt.="'$GMT_gmt[$r]',";}
-				}
-			else
-				{
-				if ( ($GMT_hour[$r]>=$Gct_friday_start) && ($GMT_hour[$r]<$Gct_friday_stop) )
-					{$default_gmt.="'$GMT_gmt[$r]',";   $default_gmt_ARY[$dgA] = "$GMT_gmt[$r]";   $dgA++;}
-				else
-					{$del_default_gmt.="'$GMT_gmt[$r]',";}
-				}
-			}
-		if ($GMT_day[$r]==6)	#### Saturday local time
-			{
-			if (($Gct_saturday_start==0) && ($Gct_saturday_stop==0))
-				{
-				if ( ($GMT_hour[$r]>=$Gct_default_start) && ($GMT_hour[$r]<$Gct_default_stop) )
-					{$default_gmt.="'$GMT_gmt[$r]',";   $default_gmt_ARY[$dgA] = "$GMT_gmt[$r]";   $dgA++;}
-				else
-					{$del_default_gmt.="'$GMT_gmt[$r]',";}
-				}
-			else
-				{
-				if ( ($GMT_hour[$r]>=$Gct_saturday_start) && ($GMT_hour[$r]<$Gct_saturday_stop) )
-					{$default_gmt.="'$GMT_gmt[$r]',";   $default_gmt_ARY[$dgA] = "$GMT_gmt[$r]";   $dgA++;}
-				else
-					{$del_default_gmt.="'$GMT_gmt[$r]',";}
-				}
-			}
-		$r++;
-		}
-
-	$default_gmt = "$default_gmt'99'";
-	$del_default_gmt = "$del_default_gmt'99'";
-	$all_gmtSQL[$i] = "(gmt_offset_now IN($default_gmt) $ct_statesSQL) $ct_state_gmt_SQL";
-	$del_gmtSQL[$i] = "(gmt_offset_now IN($del_default_gmt) $ct_statesSQL) $del_state_gmt_SQL";
-
-	##### END calculate what gmt_offset_now values are within the allowed local_call_time setting ###
-
-	##### BEGIN lead recycling parsing and prep ###
-
-	$stmtA = "SELECT * from vicidial_lead_recycle where campaign_id='$campaign_id[$i]' and active='Y';";
-	$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-	$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-	$sthArows=$sthA->rows;
-	@recycle_status=@MT;
-	@recycle_delay=@MT;
-	@recycle_maximum=@MT;
-	@RSQLdate=@MT;
-	$r_ct=0;
-	$rec_ct[$i]=0;
-	while ($sthArows > $r_ct)
-		{
-		@aryA = $sthA->fetchrow_array;
-		$recycle_status[$r_ct] =	 "$aryA[2]";
-		$recycle_delay[$r_ct] =		 "$aryA[3]";
-		$recycle_maximum[$r_ct] =	 "$aryA[4]";
-		$r_ct++;
-		$rec_ct[$i]++;
-		}
-	$sthA->finish();
-
-	if ($rec_ct[$i] > 0)
-		{
-		$rc=0;
-		$recycle_SQL[$i] = "( ";
-		while($rc < $rec_ct[$i])
-			{
-			$Y=1;
-			$recycle_Y = "'Y'";
-			while ($Y < $recycle_maximum[$rc])
-				{
-				$recycle_Y .= ",'Y$Y'";
-				$Y++;
-				}
-
-			if ($rc > 0) {$recycle_SQL[$i] .= " or ";}
-
-			$recycle_SQL[$i] .= "( (called_since_last_reset IN($recycle_Y)) and (status='$recycle_status[$rc]') and (";
-
-			$dgA=0;
-			foreach(@default_gmt_ARY)
-				{
-				$secX = time();
-				$LLCT_DATE_offset = ($LOCAL_GMT_OFF - $default_gmt_ARY[$dgA]);
-				$LLCT_DATE_offset_epoch = ( $secX - ($LLCT_DATE_offset * 3600) );
-				$Rtarget = ($LLCT_DATE_offset_epoch - $recycle_delay[$rc]);
-				($Rsec,$Rmin,$Rhour,$Rmday,$Rmon,$Ryear,$Rwday,$Ryday,$Risdst) = localtime($Rtarget);
-				$Ryear = ($Ryear + 1900);
-				$Rmon++;
-				if ($Rmon < 10) {$Rmon = "0$Rmon";}
-				if ($Rmday < 10) {$Rmday = "0$Rmday";}
-				if ($Rhour < 10) {$Rhour = "0$Rhour";}
-				if ($Rmin < 10) {$Rmin = "0$Rmin";}
-				if ($Rsec < 10) {$Rsec = "0$Rsec";}
-				$Rhourmin = "$Rhour$Rmin";
-				if ( ($Rhourmin < $lct_begin) || ($Rhourmin > $lct_end) ) 
-					{
-					$RGtarget = ($Rtarget - $lct_gap);
-					($Rsec,$Rmin,$Rhour,$Rmday,$Rmon,$Ryear,$Rwday,$Ryday,$Risdst) = localtime($RGtarget);
-					$Ryear = ($Ryear + 1900);
-					$Rmon++;
-					if ($Rmon < 10) {$Rmon = "0$Rmon";}
-					if ($Rmday < 10) {$Rmday = "0$Rmday";}
-					if ($Rhour < 10) {$Rhour = "0$Rhour";}
-					if ($Rmin < 10) {$Rmin = "0$Rmin";}
-					if ($Rsec < 10) {$Rsec = "0$Rsec";}
-					if ($DBX) {print "RECYCLE DELAY GAP: |$campaign_id[$i]|$Rhourmin|$RGtarget|Rtarget|($recycle_delay[$rc] $lct_gap)\n";}
-					}
-				$RSQLdate[$rc] = "$Ryear-$Rmon-$Rmday $Rhour:$Rmin:$Rsec";
-
-				if ($dgA > 0) {$recycle_SQL[$i] .= " or ";}
-
-				$recycle_SQL[$i] .= "( (gmt_offset_now='$default_gmt_ARY[$dgA]') and (last_local_call_time < \"$RSQLdate[$rc]\") )";
-
-				$dgA++;
-				}
-			if ($DBX) {print "RECYCLE: |$campaign_id[$i]|$recycle_status[$rc]|$recycle_delay[$rc]|$recycle_maximum[$rc]|$RSQLdate[$rc]|\n";}
-
-			$recycle_SQL[$i] .= " ) )";
-
-			$rc++;
-			}
-
-		$recycle_SQL[$i] .= " )";
-
-		if ($DBX) {print "RECYCLE SQL: |$recycle_SQL[$i]|\n";}
-		}
-	##### END lead recycling parsing and prep ###
-
-	if ($DB) {print "Starting hopper run for $campaign_id[$i] campaign- GMT: $local_call_time[$i]   HOPPER: $hopper_level[$i]   ORDER: $lead_order[$i]\n";}
-
-	### Delete the DONE leads if there are any
-	$stmtA = "DELETE from $vicidial_hopper where campaign_id='$campaign_id[$i]' and status IN('DONE');";
-	$affected_rows = $dbhA->do($stmtA);
-	if ($DB) {print "     hopper DONE cleared:  $affected_rows\n";}
-	if ($DBX) {print "     |$stmtA|\n";}
-
-	### Delete the leads that are out of GMT time range if there are any
-	$stmtA = "DELETE from $vicidial_hopper where campaign_id='$campaign_id[$i]' and ($del_gmtSQL[$i]);";
-	$affected_rows = $dbhA->do($stmtA);
-	if ($DB) {print "     hopper GMT BAD cleared:  $affected_rows\n";}
-	if ($DBX) {print "     |$stmtA|\n";}
-
- 	### Find out how many leads are in the hopper from a specific campaign
-	$hopper_ready_count=0;
-	$stmtA = "SELECT count(*) from $vicidial_hopper where campaign_id='$campaign_id[$i]' and status='READY';";
-	$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-	$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-	$sthArows=$sthA->rows;
-	$rec_count=0;
-	while ($sthArows > $rec_count)
-		{
-		@aryA = $sthA->fetchrow_array;
-		$hopper_ready_count = $aryA[0];
-		if ($DB) {print "     hopper READY count:   $hopper_ready_count\n";}
-		if ($DBX) {print "     |$stmtA|\n";}
-		$rec_count++;
-		}
-	$sthA->finish();
-	$event_string = "|$campaign_id[$i]|$hopper_level[$i]|$hopper_ready_count|$local_call_time[$i]||";
-	&event_logger;
-
-	##### IF hopper level is below set minimum, then try to add more leads #####
-	if ($hopper_ready_count < $hopper_level[$i])
-		{
-		if ($DB) {print "     hopper too low ($hopper_ready_count|$hopper_level[$i]) starting hopper dump\n";}
-
-		### Get list of the lists in the campaign ###
-		$stmtA = "SELECT list_id FROM vicidial_lists where campaign_id='$campaign_id[$i]' and active='Y';";
-		$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-		$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-		$sthArows=$sthA->rows;
-		$rec_countLISTS=0;
-		$camp_lists[$i] = '';
-		while ($sthArows > $rec_countLISTS)
-			{
-			@aryA = $sthA->fetchrow_array;
-			$camp_lists[$i] .= "'$aryA[0]',";
-			$rec_countLISTS++;
-			}
-		$sthA->finish();
-		if (length($camp_lists[$i])<3) {$camp_lists[$i]="''";}
-		   else {chop($camp_lists[$i]);}
-
-		if ($DB) {print "     campaign lists count: $rec_countLISTS | $camp_lists[$i]\n";}
-		if ($DBX) {print "     |$stmtA|\n";}
-
-		if ($list_order_mix[$i] !~ /DISABLED/)
-			{
-			$stmtA = "SELECT vcl_id,vcl_name,list_mix_container,mix_method FROM vicidial_campaigns_list_mix where campaign_id='$campaign_id[$i]' and status='ACTIVE';";
-			$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;
-				$vcl_id[$i] =				"$aryA[0]";
-				$vcl_name[$i] =				"$aryA[1]";
-				$list_mix_container[$i] =	"$aryA[2]";
-				$mix_method[$i] =			"$aryA[3]";
-				$rec_count++;
-				}
-			$sthA->finish();
-
-			@list_mixARY=@MT;
-			$list_mix_dialableSQL='';
-			@list_mixARY = split(/:/,$list_mix_container[$i]);
-			$x=0;
-			foreach(@list_mixARY)
-				{
-				if ($x > 0) {$list_mix_dialableSQL .= " or ";}
-				@list_mix_stepARY = split(/\|/,$list_mixARY[$x]);
-				$list_mix_stepARY[3] =~ s/ /\',\'/gi;
-				$list_mix_stepARY[3] =~ s/^\',|,\'-//gi;
-				if ($DBX) {print "     LM $x ++$list_mixARY[$x]++ |$list_mix_stepARY[0]|$list_mix_stepARY[2]|$list_mix_stepARY[3]|\n";}
-				$list_mix_dialableSQL .= "(list_id='$list_mix_stepARY[0]' and status IN($list_mix_stepARY[3]))";
-
-				$x++;
-				}
-
-			if ($DB) {print "     campaign mix: $list_order_mix[$i] |$vcl_id[$i] - $vcl_name[$i]|$list_mix_container[$i]|$x|$mix_method[$i]|\n";}
-			}
-
-		if ( ($lead_filter_id[$i] !~ /NONE/) && (length($lead_filter_id[$i])>0) )
-			{
-			### Get SQL of lead filter for the campaign ###
-			$stmtA = "SELECT lead_filter_sql FROM vicidial_lead_filters where lead_filter_id='$lead_filter_id[$i]';";
-			$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-			$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-			$sthArows=$sthA->rows;
-			$rec_count=0;
-			while ($sthArows > $rec_count)
-				{
-				@aryA = $sthA->fetchrow_array;
-				$lead_filter_sql[$i] = "$aryA[0]";
-				$lead_filter_sql[$i] =~ s/\\//gi;
-				$rec_count++;
-				}
-			$sthA->finish();
-			$lead_filter_sql[$i] =~ s/^and|and$|^or|or$|^ and|and $|^ or|or $//gi;
-			$lead_filter_sql[$i] = "and $lead_filter_sql[$i]";
-			if ($DB) {print "     lead filter $lead_filter_id[$i] defined for $campaign_id[$i]\n";}
-			if ($DBX) {print "     |$lead_filter_sql[$i]|\n";}
-			}
-		else
-			{
-			$lead_filter_sql[$i] = '';
-			if ($DB) {print "     no lead filter defined for campaign: $campaign_id[$i]\n";}
-			if ($DBX) {print "     |$lead_filter_id[$i]|\n";}
-			}
-
-		##### Get count of leads that are dialable #####
-		if ($list_order_mix[$i] =~ /DISABLED/)
-			{
-			$stmtA = "SELECT count(*) FROM vicidial_list where called_since_last_reset='N' and status IN($STATUSsql[$i]) and list_id IN($camp_lists[$i]) and ($all_gmtSQL[$i]) $lead_filter_sql[$i];";
-			}
-		else
-			{
-			$stmtA = "SELECT count(*) FROM vicidial_list where called_since_last_reset='N' and ($list_mix_dialableSQL) and ($all_gmtSQL[$i]) $lead_filter_sql[$i];";
-			}
-			if ($DBX) {print "     |$stmtA|\n";}
-		$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-		$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-		$sthArows=$sthA->rows;
-		$rec_count=0;
-		while ($sthArows > $rec_count)
-			{
-			@aryA = $sthA->fetchrow_array;
-			$campaign_leads_to_call[$i] = "$aryA[0]";
-			if ($DB) {print "     leads to call count:  $campaign_leads_to_call[$i]\n";}
-			if ($DBX) {print "     |$stmtA|\n";}
-			$rec_count++;
-			}
-		$sthA->finish();
-
-		if ( ($lead_order[$i] =~ / 2nd NEW$| 3rd NEW$| 4th NEW$| 5th NEW$| 6th NEW$/) && ($list_order_mix[$i] =~ /DISABLED/) )
-			{
-			$stmtA = "SELECT count(*) FROM vicidial_list where called_since_last_reset='N' and status IN('NEW') and list_id IN($camp_lists[$i]) and ($all_gmtSQL[$i]) $lead_filter_sql[$i];";
-			$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-			$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-			$sthArows=$sthA->rows;
-			$rec_count=0;
-			while ($sthArows > $rec_count)
-				{
-				@aryA = $sthA->fetchrow_array;
-				$NEW_campaign_leads_to_call[$i] = "$aryA[0]";
-				if ($DB) {print "     NEW leads to call count:  $NEW_campaign_leads_to_call[$i]\n";}
-				if ($DBX) {print "     |$stmtA|\n";}
-				$rec_count++;
-				}
-			$sthA->finish();
-			}
-
-		##### IF no NEW leads to be called, error out of this campaign #####
-		if ( ($lead_order[$i] =~ / 2nd NEW$| 3rd NEW$| 4th NEW$| 5th NEW$| 6th NEW$/) && ($NEW_campaign_leads_to_call[$i] > 0) && ($list_order_mix[$i] =~ /DISABLED/) ) {$GOOD=1;}
-		else
-			{
-			if ($lead_order[$i] !~ / 2nd NEW$| 3rd NEW$| 4th NEW$| 5th NEW$| 6th NEW$/)
-				{
-				if ($DB) {print "     NO SHUFFLE-NEW-LEADS INTO HOPPER DEFINED FOR LEAD ORDER\n";}
-				}
-			else
-				{
-				if ($DB) {print "     ERROR CANNOT ADD ANY NEW LEADS TO HOPPER\n";}
-				}
-			}
-
-		##### IF no leads to be called, error out of this campaign #####
-		if ( ($campaign_leads_to_call[$i] < 1) && ($rec_ct[$i] < 1) )
-			{
-			if ($DB) {print "     ERROR CANNOT ADD ANY LEADS TO HOPPER\n";}
-			if ($VCSdialable_leads[$i] > 0)
-				{
-				$stmtA = "UPDATE vicidial_campaign_stats SET dialable_leads='0' where campaign_id='$campaign_id[$i]';";
-				$affected_rows = $dbhA->do($stmtA);
-				if ($DBX) {print "CAMPAIGN STATS: $affected_rows|$stmtA|\n";}
-				}
-			}
-		else
-			{
-			if ($VCSdialable_leads[$i] != $campaign_leads_to_call[$i])
-				{
-				$stmtA = "UPDATE vicidial_campaign_stats SET dialable_leads='$campaign_leads_to_call[$i]' where campaign_id='$campaign_id[$i]';";
-				$affected_rows = $dbhA->do($stmtA);
-				if ($DBX) {print "CAMPAIGN STATS: $affected_rows|$stmtA|\n";}
-				}
-			if ($DB) {print "     Getting Leads to add to hopper\n";}
-			### grab leads already in hopper so we don't duplicate
-			$stmtA = "SELECT lead_id FROM $vicidial_hopper where campaign_id='$campaign_id[$i]';";
-			if ($DBX) {print "     |$stmtA|\n";}
-			$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-			$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-			$sthArows=$sthA->rows;
-			 $lead_id_lists = '';
-			$rec_countLISTS=0;
-			while ($sthArows > $rec_countLISTS)
-				{
-				@aryA = $sthA->fetchrow_array;
-				$lead_id_lists .= "'$aryA[0]',";
-				$rec_countLISTS++;
-				}
-			$sthA->finish();
-			$lead_id_lists .= "'0'";			
-			$order_stmt='';
-			$NEW_count = 0;
-			$NEW_level = 0;
-			$OTHER_level = $hopper_level[$i];   
-			if ($lead_order[$i] =~ /^DOWN/) {$order_stmt = 'order by lead_id asc';}
-			if ($lead_order[$i] =~ /^UP/) {$order_stmt = 'order by lead_id desc';}
-			if ($lead_order[$i] =~ /^UP LAST NAME/) {$order_stmt = 'order by last_name desc, lead_id asc';}
-			if ($lead_order[$i] =~ /^DOWN LAST NAME/) {$order_stmt = 'order by last_name, lead_id asc';}
-			if ($lead_order[$i] =~ /^UP PHONE/) {$order_stmt = 'order by phone_number desc, lead_id asc';}
-			if ($lead_order[$i] =~ /^DOWN PHONE/) {$order_stmt = 'order by phone_number, lead_id asc';}
-			if ($lead_order[$i] =~ /^UP COUNT/) {$order_stmt = 'order by called_count desc, lead_id asc';}
-			if ($lead_order[$i] =~ /^DOWN COUNT/) {$order_stmt = 'order by called_count, lead_id asc';}
-			if ($lead_order[$i] =~ /^UP LAST CALL TIME/) {$order_stmt = 'order by last_local_call_time desc, lead_id asc';}
-			if ($lead_order[$i] =~ /^DOWN LAST CALL TIME/) {$order_stmt = 'order by last_local_call_time, lead_id asc';}
-			if ($lead_order[$i] =~ /^RANDOM/) {$order_stmt = 'order by RAND()';}
-			if ($lead_order[$i] =~ / 2nd NEW$/) {$NEW_count = 2;}
-			if ($lead_order[$i] =~ / 3rd NEW$/) {$NEW_count = 3;}
-			if ($lead_order[$i] =~ / 4th NEW$/) {$NEW_count = 4;}
-			if ($lead_order[$i] =~ / 5th NEW$/) {$NEW_count = 5;}
-			if ($lead_order[$i] =~ / 6th NEW$/) {$NEW_count = 6;}
-
-		### BEGIN recycle grab leads ###
-			$REC_rec_countLEADS=0;
-			@REC_leads_to_hopper=@MT;
-			@REC_lists_to_hopper=@MT;
-			@REC_phone_to_hopper=@MT;
-			@REC_gmt_to_hopper=@MT;
-			@REC_state_to_hopper=@MT;
-			@REC_status_to_hopper=@MT;
-			if ($rec_ct[$i] > 0)
-				{
-				if ($DB) {print "     looking for RECYCLE leads, maximum of $hopper_level[$i]\n";}
-
-				$stmtA = "SELECT lead_id,list_id,gmt_offset_now,phone_number,state,status FROM vicidial_list where $recycle_SQL[$i] and list_id IN($camp_lists[$i]) and lead_id NOT IN($lead_id_lists) and ($all_gmtSQL[$i]) $lead_filter_sql[$i] limit $hopper_level[$i];";
-				if ($DBX) {print "     |$stmtA|\n";}
-				$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-				$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-				$sthArows=$sthA->rows;
-				if ($DB) {print "     RECYCLE leads to call count:  $sthArows\n";}
-				if ($DBX) {print "     |$stmtA|\n";}
-				while ($sthArows > $REC_rec_countLEADS)
-					{
-					@aryA = $sthA->fetchrow_array;
-					$REC_leads_to_hopper[$REC_rec_countLEADS] = "$aryA[0]";
-					$REC_lists_to_hopper[$REC_rec_countLEADS] = "$aryA[1]";
-					$REC_gmt_to_hopper[$REC_rec_countLEADS] = "$aryA[2]";
-					$REC_phone_to_hopper[$REC_rec_countLEADS] = "$aryA[3]";
-					$REC_state_to_hopper[$REC_rec_countLEADS] = "$aryA[4]";
-					$REC_status_to_hopper[$REC_rec_countLEADS] = "$aryA[5]";
-					if ($DB_show_offset) {print "LEAD_ADD: $aryA[2] $aryA[3] $aryA[4]\n";}
-					$REC_rec_countLEADS++;
-					}
-				$sthA->finish();
-				}
-			else
-				{
-				if ($DB) {print "     NO RECYCLE-LEADS INTO HOPPER DEFINED\n";}
-				}
-		### END recycle grab leads ###
-
-
-		### BEGIN NEW grab leads ###
-			$NEW_rec_countLEADS=0;
-			@NEW_leads_to_hopper=@MT;
-			@NEW_lists_to_hopper=@MT;
-			@NEW_phone_to_hopper=@MT;
-			@NEW_gmt_to_hopper=@MT;
-			@NEW_state_to_hopper=@MT;
-			@NEW_status_to_hopper=@MT;
-			if ( ($NEW_count > 0) && ($list_order_mix[$i] =~ /DISABLED/) )
-				{
-				$NEW_level = int($hopper_level[$i] / $NEW_count);   
-				$OTHER_level = ($hopper_level[$i] - $NEW_level);   
-			#	$order_stmt = 'order by called_count, lead_id asc';
-				if ($DB) {print "     looking for $NEW_level NEW leads mixed in with $OTHER_level other leads\n";}
-
-				$stmtA = "SELECT lead_id,list_id,gmt_offset_now,phone_number,state,status FROM vicidial_list where called_since_last_reset='N' and status IN('NEW') and list_id IN($camp_lists[$i]) and lead_id NOT IN($lead_id_lists) and ($all_gmtSQL[$i]) $lead_filter_sql[$i] $order_stmt limit $NEW_level;";
-				if ($DBX) {print "     |$stmtA|\n";}
-				$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-				$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-				$sthArows=$sthA->rows;
-				while ($sthArows > $NEW_rec_countLEADS)
-					{
-					@aryA = $sthA->fetchrow_array;
-					$NEW_leads_to_hopper[$NEW_rec_countLEADS] = "$aryA[0]";
-					$NEW_lists_to_hopper[$NEW_rec_countLEADS] = "$aryA[1]";
-					$NEW_gmt_to_hopper[$NEW_rec_countLEADS] = "$aryA[2]";
-					$NEW_phone_to_hopper[$NEW_rec_countLEADS] = "$aryA[3]";
-					$NEW_state_to_hopper[$NEW_rec_countLEADS] = "$aryA[4]";
-					$NEW_status_to_hopper[$NEW_rec_countLEADS] = "$aryA[5]";
-					if ($DB_show_offset) {print "LEAD_ADD: $aryA[2] $aryA[3] $aryA[4]\n";}
-					$NEW_rec_countLEADS++;
-					}
-				$OTHER_level = ($hopper_level[$i] - $NEW_rec_countLEADS);
-				$sthA->finish();
-				}
-
-		### BEGIN standard grab leads ###
-			$rec_countLEADS=0;
-			$NEW_dec=99;
-			$NEW_in=0;
-			$rec_count=0;
-			$REC_insert_count=0;
-			@leads_to_hopper=@MT;
-			@lists_to_hopper=@MT;
-			@gmt_to_hopper=@MT;
-			@state_to_hopper=@MT;
-			@phone_to_hopper=@MT;
-			@status_to_hopper=@MT;
-			if ($campaign_leads_to_call[$i] > 0)
-				{
-				if ($DB) {print "     lead call order:      $order_stmt\n";}
-
-				if ($list_order_mix[$i] =~ /DISABLED/)
-					{
-					$stmtA = "SELECT lead_id,list_id,gmt_offset_now,phone_number,state,status FROM vicidial_list where called_since_last_reset='N' and status IN($STATUSsql[$i]) and list_id IN($camp_lists[$i]) and lead_id NOT IN($lead_id_lists) and ($all_gmtSQL[$i]) $lead_filter_sql[$i] $order_stmt limit $OTHER_level;";
-					if ($DBX) {print "     |$stmtA|\n";}
-					$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-					$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-					$sthArows=$sthA->rows;
-					while ($sthArows > $rec_count)
-						{
-						@aryA = $sthA->fetchrow_array;
-						if ( ($NEW_count > 0) && ($NEW_rec_countLEADS > $NEW_in) )
-							{
-							if ($DB_show_offset) {print "NEW_COUNT: $NEW_count|$NEW_dec|$NEW_in|$NEW_rec_countLEADS\n";}
-							if ($NEW_count > $NEW_dec) 
-								{
-								$NEW_dec++;
-								}
-							else
-								{
-								$leads_to_hopper[$rec_countLEADS] = "$NEW_leads_to_hopper[$NEW_in]";
-								$lists_to_hopper[$rec_countLEADS] = "$NEW_lists_to_hopper[$NEW_in]";
-								$gmt_to_hopper[$rec_countLEADS] = "$NEW_gmt_to_hopper[$NEW_in]";
-								$state_to_hopper[$rec_countLEADS] = "$NEW_state_to_hopper[$NEW_in]";
-								$phone_to_hopper[$rec_countLEADS] = "$NEW_phone_to_hopper[$NEW_in]";
-								$status_to_hopper[$rec_countLEADS] = "$NEW_status_to_hopper[$NEW_in]";
-								if ($DB_show_offset) {print "LEAD_ADD:    $NEW_leads_to_hopper[$NEW_in]   $NEW_phone_to_hopper[$NEW_in]\n";}
-								$rec_countLEADS++;
-								$NEW_in++;
-								$NEW_dec=2;
-								}
-							}
-						if ($REC_rec_countLEADS > $REC_insert_count)
-							{
-							$leads_to_hopper[$rec_countLEADS] = "$REC_leads_to_hopper[$REC_insert_count]";
-							$lists_to_hopper[$rec_countLEADS] = "$REC_lists_to_hopper[$REC_insert_count]";
-							$gmt_to_hopper[$rec_countLEADS] = "$REC_gmt_to_hopper[$REC_insert_count]";
-							$state_to_hopper[$rec_countLEADS] = "$REC_state_to_hopper[$REC_insert_count]";
-							$phone_to_hopper[$rec_countLEADS] = "$REC_phone_to_hopper[$REC_insert_count]";
-							$status_to_hopper[$rec_countLEADS] = "$REC_status_to_hopper[$REC_insert_count]";
-							$rec_countLEADS++;
-							$REC_insert_count++;
-							}
-						$leads_to_hopper[$rec_countLEADS] = "$aryA[0]";
-						$lists_to_hopper[$rec_countLEADS] = "$aryA[1]";
-						$gmt_to_hopper[$rec_countLEADS] = "$aryA[2]";
-						$state_to_hopper[$rec_countLEADS] = "$aryA[4]";
-						$phone_to_hopper[$rec_countLEADS] = "$aryA[3]";
-						$status_to_hopper[$rec_countLEADS] = "$aryA[5]";
-						if ($DB_show_offset) {print "LEAD_ADD: $aryA[2] $aryA[3] $aryA[4]\n";}
-						$rec_countLEADS++;
-						$rec_count++;
-						}
-						$sthA->finish();
-					}
-
-			##### LIST MIX LEADS GRAB #####
-				else
-					{
-					$USX='_____';
-					$x=0;
-					$z=0;
-					@LM_results=@MT;
-					foreach(@list_mixARY)
-						{
-						$rec_count=0;
-						@list_mix_stepARY=@MT;
-
-						@list_mix_stepARY = split(/\|/,$list_mixARY[$x]);
-						$LM_step_goal[$x] = ( ($list_mix_stepARY[2] / 100) * $hopper_level[$i]);
-						$LM_step_even[$x] = ( (100 / $list_mix_stepARY[2]) * 100000);
-						$list_mix_stepARY[3] =~ s/ /','/gi;
-						$list_mix_stepARY[3] =~ s/^',|,'-//gi;
-						if ($DBX) {print "  LM $x |$list_mix_stepARY[0]|$list_mix_stepARY[2]|$LM_step_goal[$x]|$list_mix_stepARY[3]|\n";}
-						$list_mix_dialableSQL = "(list_id='$list_mix_stepARY[0]' and status IN($list_mix_stepARY[3]))";
-
-						$stmtA = "SELECT lead_id,list_id,gmt_offset_now,phone_number,state,status FROM vicidial_list where called_since_last_reset='N' and $list_mix_dialableSQL and lead_id NOT IN($lead_id_lists) and ($all_gmtSQL[$i]) $lead_filter_sql[$i] $order_stmt limit $LM_step_goal[$x];";
-						if ($DBX) {print "     |$stmtA|\n";}
-						$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-						$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-						$sthArows=$sthA->rows;
-						while ($sthArows > $rec_count)
-							{
-							@aryA = $sthA->fetchrow_array;
-							if ($mix_method[$i] =~ /RANDOM/) 
-								{
-								$order = int( rand(9999999)) + 10000000;
-								}
-							else 
-								{
-								if ($mix_method[$i] =~ /EVEN_MIX/) 
-									{
-									$order = ( ($rec_count * $LM_step_even[$x]) + $x);
-									}
-								else
-									{
-									$order = ( ($x * 1000000) + $rec_count);
-									}
-								}
-							$LM_results[$z] = "$order$USX$aryA[0]$USX$aryA[1]$USX$aryA[2]$USX$aryA[3]$USX$aryA[4]$USX$aryA[5]";
-						#	if ($DBX) {print "     $z|$LM_results[$z]\n";}
-
-							$rec_count++;
-							$z++;
-							}
-						$sthA->finish();
-
-						$x++;
-						}
-
-					@LM_results_SORT = sort { $a <=> $b } @LM_results;
-
-					$w=0;
-					while ($z > $w)
-						{
-						@aryA = split(/_____/,$LM_results_SORT[$w]);
-						if ($REC_rec_countLEADS > $REC_insert_count)
-							{
-							$leads_to_hopper[$rec_countLEADS] = "$REC_leads_to_hopper[$REC_insert_count]";
-							$lists_to_hopper[$rec_countLEADS] = "$REC_lists_to_hopper[$REC_insert_count]";
-							$gmt_to_hopper[$rec_countLEADS] = "$REC_gmt_to_hopper[$REC_insert_count]";
-							$state_to_hopper[$rec_countLEADS] = "$REC_state_to_hopper[$REC_insert_count]";
-							$phone_to_hopper[$rec_countLEADS] = "$REC_phone_to_hopper[$REC_insert_count]";
-							$status_to_hopper[$rec_countLEADS] = "$REC_status_to_hopper[$REC_insert_count]";
-							$rec_countLEADS++;
-							$REC_insert_count++;
-							}
-						$leads_to_hopper[$rec_countLEADS] = "$aryA[1]";
-						$lists_to_hopper[$rec_countLEADS] = "$aryA[2]";
-						$gmt_to_hopper[$rec_countLEADS] = "$aryA[3]";
-						$state_to_hopper[$rec_countLEADS] = "$aryA[4]";
-						$phone_to_hopper[$rec_countLEADS] = "$aryA[5]";
-						$status_to_hopper[$rec_countLEADS] = "$aryA[6]";
-						if ($DB_show_offset) {print "LEAD_ADD: $aryA[3] $aryA[4] $aryA[5]\n";}
-						if ($DBX) {print "     $w|$LM_results[$w]\n";}
-						$rec_countLEADS++;
-						$w++;
-						}
-					}
-				}
-			### finish inserting any recycled leads if any
-			while ($REC_rec_countLEADS > $REC_insert_count)
-				{
-				$leads_to_hopper[$rec_countLEADS] = "$REC_leads_to_hopper[$REC_insert_count]";
-				$lists_to_hopper[$rec_countLEADS] = "$REC_lists_to_hopper[$REC_insert_count]";
-				$gmt_to_hopper[$rec_countLEADS] = "$REC_gmt_to_hopper[$REC_insert_count]";
-				$state_to_hopper[$rec_countLEADS] = "$REC_state_to_hopper[$REC_insert_count]";
-				$phone_to_hopper[$rec_countLEADS] = "$REC_phone_to_hopper[$REC_insert_count]";
-				$status_to_hopper[$rec_countLEADS] = "$REC_status_to_hopper[$REC_insert_count]";
-				$rec_countLEADS++;
-				$REC_insert_count++;
-				}
-
-			if ($DB) {print "     Adding to hopper:     $rec_countLEADS\n";}
-			$event_string = "|$campaign_id[$i]|Added to hopper $rec_countLEADS|";
-			&event_logger;
-
-			$h=0;
-			foreach(@leads_to_hopper)
-				{
-				if ($leads_to_hopper[$h] != '0')
-					{
-					$DNClead=0;
-					if ($use_internal_dnc[$i] =~ /Y/)
-						{
-						if ($DB) {print "     Doing DNC Check: $phone_to_hopper[$h] - $use_internal_dnc[$i]\n";}
-						$stmtA = "SELECT count(*) from vicidial_dnc where phone_number='$phone_to_hopper[$h]';";
-						$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;
-							$DNClead =		 "$aryA[0]";
-							$rec_count++;
-							}
-						$sthA->finish();
-						if ($DNClead != '0')
-							{
-							$stmtA = "UPDATE vicidial_list SET status='DNCL' where lead_id='$leads_to_hopper[$h]';";
-							$affected_rows = $dbhA->do($stmtA);
-							if ($DBX) {print "Flagging DNC lead:     $affected_rows  $phone_to_hopper[$h]\n";}
-							}
-						}
-					if ( ($use_campaign_dnc[$i] =~ /Y/) && ($DNClead == '0') )
-						{
-						if ($DB) {print "Doing CAMP DNC Check: $phone_to_hopper[$h] - $use_campaign_dnc[$i]\n";}
-						$stmtA = "SELECT count(*) from vicidial_campaign_dnc where phone_number='$phone_to_hopper[$h]' and campaign_id='$campaign_id[$i]';";
-						$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
-						$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
-						$sthArows=$sthA->rows;
-						$rec_count=0;
-						while ($sthArows > $rec_count)
-							{
-							@aryA = $sthA->fetchrow_array;
-							$DNClead =		 "$aryA[0]";
-							$rec_count++;
-							}
-						$sthA->finish();
-						if ($DNClead != '0')
-							{
-							$stmtA = "UPDATE vicidial_list SET status='DNCC' where lead_id='$leads_to_hopper[$h]';";
-							$affected_rows = $dbhA->do($stmtA);
-							if ($DBX) {print "Flagging DNC lead:     $affected_rows  $phone_to_hopper[$h] $campaign_id[$i]\n";}
-							}
-						}
-					if ($DNClead == '0')
-						{
-						$stmtA = "INSERT INTO $vicidial_hopper (lead_id,campaign_id,status,user,list_id,gmt_offset_now,state,priority) values('$leads_to_hopper[$h]','$campaign_id[$i]','READY','','$lists_to_hopper[$h]','$gmt_to_hopper[$h]','$state_to_hopper[$h]','0');";
-						$affected_rows = $dbhA->do($stmtA);
-						if ($DBX) {print "LEAD INSERTED: $affected_rows|$leads_to_hopper[$h]|\n";}
-						if ($DB_detail) 
-							{
-							$detail_string = "|$campaign_id[$i]|$leads_to_hopper[$h]|$phone_to_hopper[$h]|$state_to_hopper[$h]|$gmt_to_hopper[$h]|$status_to_hopper[$h]|";
-							&detail_logger;
-							}
-						}
-					}
-				$h++;
-				}
-				if ($DB) {print "     DONE with this campaign\n";}
-
-			}
-		}
-	
-	
-	$i++;
-	}
-
-
-$dbhA->disconnect();
-
-if($DB)
-{
-### calculate time to run script ###
-$secY = time();
-$secZ = ($secY - $secT);
-
-if (!$q) {print "DONE. Script execution time in seconds: $secZ\n";}
-}
-
-exit;
-
-
-
-sub event_logger
-{
-if ($SYSLOG)
-	{
-	### open the log file for writing ###
-	open(Lout, ">>$VDHLOGfile")
-			|| die "Can't open $VDHLOGfile: $!\n";
-	print Lout "$now_date|$event_string|\n";
-	close(Lout);
-	}
-$event_string='';
-}
-
-sub detail_logger
-{
-if ($SYSLOG)
-	{
-	### open the log file for writing ###
-	open(LDout, ">>$VDHDLOGfile")
-			|| die "Can't open $VDHDLOGfile: $!\n";
-	print LDout "$now_date|$detail_string|\n";
-	close(LDout);
-	}
-$detail_string='';
-}
-