#!/usr/bin/perl
#
# AST_CRON_audio_1_move_VDonly.pl
#
# This is a STEP-1 program in the audio archival process
#
# IMPORTANT!!! ONLY TO BE USED WHEN ONLY VICIDIAL RECORDINGS ARE ON THE SYSTEM!
#
# runs every 3 minutes and copies the -in recordings in the monitor to the DONE
# directory for further processing. Very important for RAM-drive usage
# 
# put an entry into the cron of of your asterisk machine to run this script 
# every 3 minutes or however often you desire
#
# ### recording mixing/compressing/ftping scripts
##0,3,6,9,12,15,18,21,24,27,30,33,36,39,42,45,48,51,54,57 * * * * /usr/share/astguiclient/AST_CRON_audio_1_move_mix.pl
# 0,3,6,9,12,15,18,21,24,27,30,33,36,39,42,45,48,51,54,57 * * * * /usr/share/astguiclient/AST_CRON_audio_1_move_VDonly.pl
# 1,4,7,10,13,16,19,22,25,28,31,34,37,40,43,46,49,52,55,58 * * * * /usr/share/astguiclient/AST_CRON_audio_2_compress.pl --MP3
# 2,5,8,11,14,17,20,23,26,29,32,35,38,41,44,47,50,53,56,59 * * * * /usr/share/astguiclient/AST_CRON_audio_3_ftp.pl --MP3
#
# make sure that the following directories exist:
# /var/spool/asterisk/monitor		# default Asterisk recording directory
# /var/spool/asterisk/monitorDONE	# where the moved -in files are put
# 
# This program assumes that recordings are saved by Asterisk as .wav
# should be easy to change this code if you use .gsm instead
# 
# Copyright (C) 2025  Matt Florell <vicidial@gmail.com>    LICENSE: AGPLv2
#
# 
# 80302-1958 - First Build
# 80731-2253 - Changed size comparisons for more efficiency
# 130805-1450 - Added check for length and gather length of recording for database record
# 160523-0654 - Added --HTTPS option to use https instead of http in local location
# 160731-2103 - Added --POST options to change filename with variable lookups
# 190311-0105 - Added code to check for agent-muted recordings
# 231019-2202 - Changed sleep time between directory scans from 5 to 15 seconds
# 250430-0850 - Added --POST options for skipping over recordings for leads with active calls, and using logs for statuss
# 250909-0845 - Added trigger for stereo recording script, if enabled and raw audio files present
#

$HTTPS=0;
$status_post_logs=0;
$delay_post_live=0;
$now_epoch = int(time());

### 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 "  [--quiet] = suppress output, if possible\n";
		print "  [--debug] = debug\n";
		print "  [--debugX] = super debug\n";
		print "  [--test] = test\n";
		print "  [--HTTPS] = use https instead of http in local location\n";
		print "  [--POST] = post call variable filename replacement, MUST define STATUS and CAMP below\n";
		print "  [--STATUS-POST=X] = only run post call variable filename replacement on specific status calls\n";
		print "                      If multiple statuses, use --- delimiting, i.e.: SALE---PRESALE\n";
		print "                      For status wildcards, use * flag, i.e.: S* to match SALE and SQUAL\n";
		print "                      For all statuses, use ----ALL----\n";
		print "                      \n";
		print "  [--CAMP-POST=X] = only run post call variable filename replacement on specific campaigns or ingroups\n";
		print "                      If multiple campaigns or ingroups, use --- delimiting, i.e.: TESTCAMP---TEST_IN2\n";
		print "                      For all calls, use ----ALL----\n";
		print "  [--CLEAR-POST-NO-MATCH] = clear POST filename variables if no match is found\n";
		print "  [--STATUS-POST-LOGS] = use the call logs for POST filename status variable, if found\n";
		print "  [--DELAY-POST-LIVE-CALLS] = delay processing of recordings using POST filename variables if any live calls/agents for lead\n";
		print "\n";
		exit;
		}
	else
		{
		if ($args =~ /--quiet/)
			{
			$q=1;
			}
		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 =~ /--test/)
			{
			$T=1;   $TEST=1;
			if ($q < 1) {print "\n-----TESTING -----\n\n";}
			}
		if ($args =~ /--HTTPS/i)
			{
			$HTTPS=1;
			if ($DB) {print "HTTPS location option enabled\n";}
			}
		if ($args =~ /--POST/i)
			{
			$POST=1;
			if ($DB) {print "POST post call variable filename replacement\n";}

			if ($args =~ /--STATUS-POST=/i)
				{
				@data_in = split(/--STATUS-POST=/,$args);
				$status_post = $data_in[1];
				$status_post =~ s/ .*//gi;
				if ($q < 1) {print "\n----- STATUS POST SET: $status_post -----\n\n";}
				}
			else
				{
				$POST=0;
				if ($q < 1) {print "\n----- POST disabled, no status set -----\n\n";}
				}

			if ($args =~ /--CAMP-POST=/i)
				{
				@data_in = split(/--CAMP-POST=/,$args);
				$camp_post = $data_in[1];
				$camp_post =~ s/ .*//gi;
				if ($q < 1) {print "\n----- CAMP POST SET: $camp_post -----\n\n";}
				}
			else
				{
				$POST=0;
				if ($q < 1) {print "\n----- POST disabled, no campaigns set -----\n\n";}
				}
			if ($args =~ /--STATUS-POST-LOGS/i)
				{
				$status_post_logs=1;
				if ($q < 1) {print "\n----- STATUS POST LOGS SET: $status_post_logs -----\n\n";}
				}
			if ($args =~ /--DELAY-POST-LIVE-CALLS/i)
				{
				$delay_post_live=1;
				if ($q < 1) {print "\n----- DELAY POST LIVE SET: $delay_post_live -----\n\n";}
				}
			}
		if ($args =~ /--CLEAR-POST-NO-MATCH/i)
			{
			$CLEAR_POST=1;
			if ($DB) {print "--- CLEAR-POST-NO-MATCH ENABLED ---\n";}
			}
		}

	if ( ($POST > 0) && ( (length($camp_post) < 1) || (length($status_post) < 1) ) ) 
		{
		$POST=0;
		if ($q < 1) {print "\n----- POST disabled, status or campaign invalid: |$camp_post|$status_post| -----\n\n";}
		}
	}
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 =~ /^PATHDONEmonitor/) && ($CLIDONEmonitor < 1) )
		{$PATHDONEmonitor = $line;   $PATHDONEmonitor =~ s/.*=//gi;}
	if ( ($line =~ /^VARserver_ip/) && ($CLIserver_ip < 1) )
		{$VARserver_ip = $line;   $VARserver_ip =~ s/.*=//gi;}
	if ( ($line =~ /^VARDB_server/) && ($CLIDB_server < 1) )
		{$VARDB_server = $line;   $VARDB_server =~ s/.*=//gi;}
	if ( ($line =~ /^VARDB_database/) && ($CLIDB_database < 1) )
		{$VARDB_database = $line;   $VARDB_database =~ s/.*=//gi;}
	if ( ($line =~ /^VARDB_user/) && ($CLIDB_user < 1) )
		{$VARDB_user = $line;   $VARDB_user =~ s/.*=//gi;}
	if ( ($line =~ /^VARDB_pass/) && ($CLIDB_pass < 1) )
		{$VARDB_pass = $line;   $VARDB_pass =~ s/.*=//gi;}
	if ( ($line =~ /^VARDB_port/) && ($CLIDB_port < 1) )
		{$VARDB_port = $line;   $VARDB_port =~ s/.*=//gi;}
	if ( ($line =~ /^VARFTP_host/) && ($CLIFTP_host < 1) )
		{$VARFTP_host = $line;   $VARFTP_host =~ s/.*=//gi;}
	if ( ($line =~ /^VARFTP_user/) && ($CLIFTP_user < 1) )
		{$VARFTP_user = $line;   $VARFTP_user =~ s/.*=//gi;}
	if ( ($line =~ /^VARFTP_pass/) && ($CLIFTP_pass < 1) )
		{$VARFTP_pass = $line;   $VARFTP_pass =~ s/.*=//gi;}
	if ( ($line =~ /^VARFTP_port/) && ($CLIFTP_port < 1) )
		{$VARFTP_port = $line;   $VARFTP_port =~ s/.*=//gi;}
	if ( ($line =~ /^VARFTP_dir/) && ($CLIFTP_dir < 1) )
		{$VARFTP_dir = $line;   $VARFTP_dir =~ s/.*=//gi;}
	if ( ($line =~ /^VARHTTP_path/) && ($CLIHTTP_path < 1) )
		{$VARHTTP_path = $line;   $VARHTTP_path =~ s/.*=//gi;}
	$i++;
	}

# Customized Variables
$server_ip = $VARserver_ip;		# Asterisk server IP
if (!$VARDB_port) {$VARDB_port='3306';}

use Time::HiRes ('gettimeofday','usleep','sleep');  # necessary to have perl sleep command of less than one second
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;

##### Get the settings from system_settings #####
$SSmute_recordings=0;
$stmtA = "SELECT mute_recordings,stereo_recording,stereo_parallel_recording 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;
	$SSmute_recordings =			$aryA[0];
	$SSstereo_recording =			$aryA[1];
	$SSstereo_parallel_recording =	$aryA[2];
	}
$sthA->finish();

##### Get the settings from servers #####
$vicidial_recording_limit=0;
$stmtA = "SELECT vicidial_recording_limit 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;
	$vicidial_recording_limit =	$aryA[0];
	$start_epoch_test = ($now_epoch - ( ($vicidial_recording_limit * 2) * 60) );
	}
$sthA->finish();

### find soxi to gather the length info if needed
$soxibin = '';
if ( -e ('/usr/bin/soxi')) {$soxibin = '/usr/bin/soxi';}
else 
	{
	if ( -e ('/usr/local/bin/soxi')) {$soxibin = '/usr/local/bin/soxi';}
	else
		{
		if ( -e ('/usr/sbin/soxi')) {$soxibin = '/usr/sbin/soxi';}
		else 
			{
			if ($DB) {print "Can't find soxi binary! No length calculations will be available...\n";}
			}
		}
	}

# time variable definitions
($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) {$hour = "0$hour";}
if ($min < 10) {$min = "0$min";}
if ($sec < 10) {$sec = "0$sec";}
$now_date = "$year-$mon-$mday $hour:$min:$sec";
$dateint = "$year$mon$mday$hour$min$sec";
$today_start = "$year-$mon-$mday 00:00:00";
$today_date = "$year-$mon-$mday";
$hm = "$hour$min";

### directory where in/out recordings are saved to by Asterisk
$dir1 = "$PATHmonitor";
$dir2 = "$PATHDONEmonitor";

opendir(FILE, "$dir1/");
@FILES = readdir(FILE);


### Loop through files first to gather filesizes
$i=0;
foreach(@FILES)
	{
	$FILEsize1[$i] = 0;
	if ( (length($FILES[$i]) > 4) && (!-d "$dir1/$FILES[$i]") )
		{
		$FILEsize1[$i] = (-s "$dir1/$FILES[$i]");
		if ($DBX) {print "$FILES[$i] $FILEsize1[$i]\n";}
		}
	$i++;
	}

sleep(15);


### Loop through files a second time to gather filesizes again 5 seconds later
$i=0;
$active_recordings=0;
$delay_ct=0;
$processed_ct=0;
$post_status_change_ct=0;
foreach(@FILES)
	{
	$lead_id=0;
	$vicidial_id='';
	$FILEsize2[$i] = 0;

	if ( (length($FILES[$i]) > 4) && (!-d "$dir1/$FILES[$i]") )
		{
		$FILEsize2[$i] = (-s "$dir1/$FILES[$i]");
		if ($DBX) {print "$FILES[$i] $FILEsize2[$i]\n\n";}

		if ( ($FILES[$i] !~ /out\.wav|out\.gsm|lost\+found/i) && ($FILEsize1[$i] eq $FILEsize2[$i]) && (length($FILES[$i]) > 4))
			{
			$INfile = $FILES[$i];
			$OUTfile = $FILES[$i];
			$OUTfile =~ s/-in\.wav/-out.wav/gi;
			$OUTfile =~ s/-in\.gsm/-out.gsm/gi;
			$ALLfile = $FILES[$i];
			$ALLfile =~ s/-in\.wav/-all.wav/gi;
			$ALLfile =~ s/-in\.gsm/-all.gsm/gi;
			$SQLFILE = $FILES[$i];
			$SQLFILE =~ s/-in\.wav|-in\.gsm//gi;
			$filenameSQL='';

			$length_in_sec=0;
			$rec_ended=0;
			$start_epoch=0;
			$stmtA = "SELECT recording_id,length_in_sec,lead_id,vicidial_id,start_time,end_time,user,UNIX_TIMESTAMP(start_time) from recording_log where filename='$SQLFILE' order by recording_id desc LIMIT 1;";
			if($DBX){print STDERR "\n|$stmtA|\n";}
			$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;
				$recording_id =		$aryA[0];
				$length_in_sec =	$aryA[1];
				$lead_id =			$aryA[2];
				$vicidial_id =		$aryA[3];
				$start_time =		$aryA[4];
				$end_time =			$aryA[5];
				$user =				$aryA[6];
				$start_epoch =		$aryA[7];
				if (length($end_time) > 15) {$rec_ended=1;}
				}
			$sthA->finish();

			$process_recording=1;
			### check for muted recordings, if found then delay processing
			if ( ($SSmute_recordings > 0) && ($rec_ended < 1) )
				{
				### check for active muted recordings
				$rec_on_ct=0;   $rec_off_ct=0;
				$stmtA = "SELECT count(*),stage from vicidial_agent_function_log where lead_id='$lead_id' and event_time >= \"$start_time\" and user='$user' and function='mute_rec' group by stage;";
				if($DBX){print STDERR "\n|$stmtA|\n";}
				$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
				$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
				$sthArows=$sthA->rows;
				$rs=0;
				while ($sthArows > $rs)
					{
					@aryA = $sthA->fetchrow_array;
					if ($aryA[1] =~ /on/i) {$rec_on_ct = $aryA[0];}
					if ($aryA[1] =~ /off/i) {$rec_off_ct = $aryA[0];}
					$rs++;
					}
				$sthA->finish();

				if ($rec_on_ct > $rec_off_ct) 
					{
					if ($DBX > 0) {print "DEBUG: recording muting on for this call: ($rec_on_ct > $rec_off_ct) |$SQLFILE|ended: $rec_ended|\n";}

					$rs_recent_on=0;
					if ($rec_ended < 1) 
						{
						### check if muting started in last 15 minutes
						$stmtA = "SELECT count(*) from vicidial_agent_function_log where lead_id='$lead_id' and event_time >= \"$start_time\" and event_time > DATE_SUB(NOW(),INTERVAL 15 MINUTE) and user='$user' and function='mute_rec' and stage='on';";
						if($DBX){print STDERR "\n|$stmtA|\n";}
						$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;
							$rs_recent_on = $aryA[0];
							}
						$sthA->finish();
						}

					if ($rs_recent_on > 0) 
						{
						if ($DBX > 0) {print "DEBUG2: recording muting recently for this call, do not process: ($rs_recent_on) |$SQLFILE|ended: $rec_ended|\n";}
						$process_recording=0;
						$delay_ct++;
						}
					else
						{
						if ($DBX > 0) {print "DEBUG3: recording muting started over 15 minutes ago, OK to process: ($rs_recent_on) |$SQLFILE|ended: $rec_ended|\n";}
						}
					}
				}

			### check for POST variables, and delay setting
			if ( ($delay_post_live > 0) && ($POST > 0) && ($ALLfile =~ /POSTVLC|POSTSP|POSTADDR3|POSTSTATUS/) )
				{
				if ($lead_id > 0) 
					{
					$VLA_count=0;
					$VAC_count=0;
					if ( ($start_epoch > 0) && ($start_epoch < $start_epoch_test) ) 
						{
						if ($DBX > 0) {print "DEBUG6: delay processing past server limit, process now: ($start_epoch|$start_epoch_test) |$SQLFILE|ended: $rec_ended|\n";}
						}
					else
						{
						if ($DBX > 0) {print "DEBUG7: delay processing not past server limit yet: ($start_epoch|$start_epoch_test) |$SQLFILE|ended: $rec_ended|\n";}

						### check if any live agents are connected to this lead_id right now
						$stmtA = "SELECT count(*) from vicidial_live_agents where lead_id='$lead_id';";
						if($DBX){print STDERR "\n|$stmtA|\n";}
						$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;
							$VLA_count = $aryA[0];
							}
						$sthA->finish();

						### check if any live calls are tied to this lead_id right now
						$stmtA = "SELECT count(*) from vicidial_auto_calls where lead_id='$lead_id';";
						if($DBX){print STDERR "\n|$stmtA|\n";}
						$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_count = $aryA[0];
							}
						$sthA->finish();
						}

					if ( ($VLA_count > 0) || ($VAC_count > 0) ) 
						{
						if ($DBX > 0) {print "DEBUG4: delay processing active, do not process: ($VLA_count|$VAC_count) |$SQLFILE|ended: $rec_ended|\n";}
						$process_recording=0;
						$delay_ct++;
						}
					else
						{
						if ($DBX > 0) {print "DEBUG5: delay processing - no calls or agents found, OK to process: ($VLA_count|$VAC_count) |$SQLFILE|ended: $rec_ended|\n";}
						}
					}
				}

			### process the recording files
			if ($process_recording > 0) 
				{
				if ($DB) {print "|$recording_id|$length_in_sec|$INfile|     |$ALLfile|\n";}

				if (!$T)
					{
					`mv -f "$dir1/$INfile" "$dir2/$ALLfile"`;
					`rm -f "$dir1/$OUTfile"`;
					}
				else
					{
					`cp -f "$dir1/$INfile" "$dir2/$ALLfile"`;
					}

				$lengthSQL='';
				if ( ( ($length_in_sec < 1) || ($length_in_sec =~ /^NULL$/i) || (length($length_in_sec)<1) ) && (length($soxibin) > 3) )
					{
					@soxi_output = `$soxibin -D $dir2/$ALLfile`;
					$soxi_sec = $soxi_output[0];
					$soxi_sec =~ s/\..*|\n|\r| //gi;
					$soxi_min = ($soxi_sec / 60);
					$soxi_min = sprintf("%.2f", $soxi_min);
					$lengthSQL = ",length_in_sec='$soxi_sec',length_in_min='$soxi_min'";
					}

				##### BEGIN post call variable replacement #####
				if ($POST > 0) 
					{
					if ($ALLfile =~ /POSTVLC|POSTSP|POSTADDR3|POSTSTATUS/)
						{
						$origALLfile = $ALLfile;
						$origSQLFILE = $SQLFILE;
						$vendor_lead_code='';   $security_phrase='';   $address3='';   $status='';
						$status_ALL=0;
						$camp_ALL=0;
						$camp_status_selected=0;

						if ($status_post =~ /----ALL----/)
							{
							$status_ALL++;
							if($DBX){print "All Statuses:  |$status_post|$status_ALL|\n";} 
							}

						if ($camp_post =~ /----ALL----/)
							{
							$camp_ALL++;
							if($DBX){print "All Campaigs and Ingroups:  |$camp_post|$camp_ALL|\n";} 
							}

						if ( ($camp_ALL < 1) || ($status_ALL < 1) ) 
							{
							$camp_postSQL='';
							if ($camp_ALL < 1)
								{
								$camp_postSQL = $camp_post;
								$camp_postSQL =~ s/---/','/gi;
								$camp_postSQL = "and campaign_id IN('$camp_postSQL')";
								}
							if ($vicidial_id =~ /\./) 
								{
								$log_lookupSQL = "SELECT status from vicidial_log where uniqueid='$vicidial_id' and lead_id='$lead_id' $camp_postSQL;";
								}
							else
								{
								$log_lookupSQL = "SELECT status from vicidial_closer_log where closecallid='$vicidial_id' and lead_id='$lead_id' $camp_postSQL;";
								}
							if($DBX){print STDERR "\n|$log_lookupSQL|\n";}
							$sthA = $dbhA->prepare($log_lookupSQL) or die "preparing: ",$dbhA->errstr;
							$sthA->execute or die "executing: $log_lookupSQL ", $dbhA->errstr;
							$sthArows=$sthA->rows;
							if ($sthArows > 0)
								{
								@aryA = $sthA->fetchrow_array;
								$lead_status =		$aryA[0];
								if ($status_ALL > 0) 
									{$camp_status_selected++;}
								else
									{
									@status_vars = split(/---/,$status_post);
									$fc=0;
									foreach(@status_vars)
										{
										$status_temp = $status_vars[$fc];
										if ($status_vars[$fc] =~ /\*/) 
											{
											$status_temp =~ s/\*/.*/gi;
											if ( ($lead_status =~ /^$status_temp/) && ($status_vars[$fc] =~ /\*$/) )
												{$camp_status_selected++;}
											if ( ($lead_status =~ /$status_temp$/) && ($status_vars[$fc] =~ /^\*/) )
												{$camp_status_selected++;}
											}
										else
											{
											if ($lead_status =~ /^$status_temp$/) 
												{$camp_status_selected++;}
											}
										if ($DBX) {print "    POST processing DEBUG: $fc|$status_temp|$lead_status|$lead_id|$vicidial_id|$ALLfile|\n";}
										$fc++;
										}
									}
								if ($DB) {print "    POST processing SELECT: |$camp_status_selected|$sthArows|$camp_postSQL|$camp_ALL|$status_post|$status_ALL|$ALLfile|\n";}
								}
							else
								{if ($DB) {print "    POST processing ERROR: lead not found: |$lead_id|$ALLfile|\n";} }
							$sthA->finish();
							}

						if ( ( ($camp_ALL > 0) && ($status_ALL > 0) ) || ($camp_status_selected > 0) )
							{
							$stmtA = "SELECT vendor_lead_code,security_phrase,address3,status from vicidial_list where lead_id='$lead_id' LIMIT 1;";
							if($DBX){print STDERR "\n|$stmtA|\n";}
							$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;
								$vendor_lead_code =		$aryA[0];
								$security_phrase =		$aryA[1];
								$address3 =				$aryA[2];
								$status =				$aryA[3];

								$vendor_lead_code =~	s/[^a-zA-Z0-9_-]//gi;
								$security_phrase =~		s/[^a-zA-Z0-9_-]//gi;
								$address3 =~			s/[^a-zA-Z0-9_-]//gi;
								$status =~				s/[^a-zA-Z0-9_-]//gi;
								}
							else
								{if ($DB) {print "    POST processing ERROR: lead not found: |$lead_id|$ALLfile|\n";} }
							$sthA->finish();

							if ( ($status_post_logs > 0) && ($ALLfile =~ /POSTSTATUS/) )
								{
								$log_status = $status;
								if ($vicidial_id =~ /\./) 
									{
									$log_lookupSQL = "SELECT status from vicidial_log where uniqueid='$vicidial_id' and lead_id='$lead_id' and user='$user' order by call_date desc limit 1;";
									}
								else
									{
									$log_lookupSQL = "SELECT status from vicidial_closer_log where closecallid='$vicidial_id' and lead_id='$lead_id' and user='$user' order by call_date desc limit 1;";
									}
								if($DBX){print STDERR "\n|$log_lookupSQL|\n";}
								$sthA = $dbhA->prepare($log_lookupSQL) or die "preparing: ",$dbhA->errstr;
								$sthA->execute or die "executing: $log_lookupSQL ", $dbhA->errstr;
								$sthArows=$sthA->rows;
								if ($sthArows > 0)
									{
									@aryA = $sthA->fetchrow_array;
									$log_status =		$aryA[0];
									}
								
								if ($log_status ne $status) 
									{$post_status_change_ct++;}
								if ($DB) {print "    POST processing Log status override: lead: |$status| log: |$log_status|   $post_status_change_ct \n";}
								$status = $log_status;
								}
							$ALLfile =~ s/POSTVLC/$vendor_lead_code/gi;
							$ALLfile =~ s/POSTSP/$security_phrase/gi;
							$ALLfile =~ s/POSTADDR3/$address3/gi;
							$ALLfile =~ s/POSTSTATUS/$status/gi;
							$SQLFILE =~ s/POSTVLC/$vendor_lead_code/gi;
							$SQLFILE =~ s/POSTSP/$security_phrase/gi;
							$SQLFILE =~ s/POSTADDR3/$address3/gi;
							$SQLFILE =~ s/POSTSTATUS/$status/gi;
							$filenameSQL = ",filename='$SQLFILE'";

							`mv -f "$dir2/$origALLfile" "$dir2/$ALLfile"`;

							if ($DB) {print "    POST processing COMPLETE: old: |$origALLfile| new: |$ALLfile|\n";}
							}
						else
							{
							if ($DB) {print "    POST processing SKIPPED: |$camp_ALL|$status_ALL|$camp_status_selected|$lead_id|$vicidial_id|$ALLfile|\n";}

							if ($CLEAR_POST > 0) 
								{
								$ALLfile =~ s/POSTVLC//gi;
								$ALLfile =~ s/POSTSP//gi;
								$ALLfile =~ s/POSTADDR3//gi;
								$ALLfile =~ s/POSTSTATUS//gi;
								$SQLFILE =~ s/POSTVLC//gi;
								$SQLFILE =~ s/POSTSP//gi;
								$SQLFILE =~ s/POSTADDR3//gi;
								$SQLFILE =~ s/POSTSTATUS//gi;
								$filenameSQL = ",filename='$SQLFILE'";

								`mv -f "$dir2/$origALLfile" "$dir2/$ALLfile"`;

								if ($DB) {print "    CLEAR POST COMPLETE: old: |$origALLfile| new: |$ALLfile|\n";}
								}
							}
						}
					else
						{if ($DB) {print "    POST processing ERROR: No variables found: |$ALLfile|\n";} }
					}
				##### END post call variable replacement #####

				$HTTP='http';
				if ($HTTPS > 0) {$HTTP='https';}
				$stmtA = "UPDATE recording_log set location='$HTTP://$server_ip/RECORDINGS/$ALLfile' $filenameSQL $lengthSQL where recording_id='$recording_id';";
					if($DBX){print STDERR "\n|$stmtA|\n";}
				$affected_rows = $dbhA->do($stmtA); #  or die  "Couldn't execute query:|$stmtA|\n";

				$stmtA = "UPDATE recording_live set end_time=NOW(),recording_status='FINISHED FILE-MERGE' where recording_id='$recording_id' and recording_status='STARTED';";
					if($DBX){print STDERR "\n|$stmtA|\n";}
				$affected_rows = $dbhA->do($stmtA); #  or die  "Couldn't execute query:|$stmtA|\n";

				### sleep for twenty hundredths of a second to not flood the server with disk activity
				usleep(1*200*1000);

				$processed_ct++;
				}
			}
		else
			{$active_recordings++;}
		}
	$i++;
	}

if($DBX)
	{
	$end_epoch = int(time());
	$run_length = ($end_epoch - $now_epoch);

	print "\nDebug output:\n";
	print "Total files:               $i \n";
	print "     Active recordings:    $active_recordings \n";
	print "     Delayed processing:   $delay_ct \n";
	print "     Processed files:      $processed_ct \n";
	print "     POST log status diff: $post_status_change_ct \n";
	print "\n";
	print "Run time: $run_length seconds \n";
	}

if ($SSstereo_recording > 0) 
	{
	$PATHmonitorS =	$PATHmonitor.'S';
	$PATHmonitorP =	$PATHmonitor.'P';

	if($DBX)
		{print "Checking for Stereo Call Recordings in $PATHmonitorS \n";}

	opendir(sFILE, "$PATHmonitorS/");
	@sFILES = readdir(sFILE);

	### Loop through files first to gather filesizes
	$trigger_stereo=0;
	$i=0;
	foreach(@sFILES)
		{
		if ( (length($sFILES[$i]) > 4) && (!-d "$dir1/$sFILES[$i]") && ($sFILES[$i] =~ /\.wav$/i) )
			{
			$trigger_stereo++;
			if ($DBX) {print "Stereo file found!   $sFILES[$i] \n";}
			last;
			}
		$i++;
		}

	if ( ($SSstereo_parallel_recording > 0) && ($trigger_stereo < 1) ) 
		{
		if($DBX)
			{print "Checking for Stereo Parallel Call Recordings in $PATHmonitorP \n";}

		opendir(pFILE, "$PATHmonitorP/");
		@pFILES = readdir(pFILE);

		### Loop through files first to gather filesizes
		$trigger_stereo=0;
		$i=0;
		foreach(@pFILES)
			{
			if ( (length($pFILES[$i]) > 4) && (!-d "$dir1/$pFILES[$i]") && ($pFILES[$i] =~ /\.wav$/i) )
				{
				$trigger_stereo++;
				if ($DBX) {print "Stereo Parallel file found!   $pFILES[$i] \n";}
				last;
				}
			$i++;
			}
		}
	
	if ($trigger_stereo > 0) 
		{
		# command to trigger stereo call file processing, preserving flags from this script:
		$stereo_command = "$PATHhome/AST_CRON_audio_1_stereo.pl $args ";
		if ($DBX) {print "Triggering Stereo call file processing...   |$stereo_command| \n";}
		`/usr/bin/screen -d -m -S SP$hm $stereo_command `;
		}
	}

if ($DB) {print "DONE... EXITING\n\n";}

$sthA->finish();
$dbhA->disconnect();


exit;