#!/usr/bin/perl
#/* ========================================
# * ███╗   ███╗██████╗ ██╗ █████╗ ██╗
# * ████╗ ████║██╔══██╗██║██╔══██╗██║
# * ██╔████╔██║██║  ██║██║███████║██║
# * ██║╚██╔╝██║██║  ██║██║██╔══██║██║
# * ██║ ╚═╝ ██║██████╔╝██║██║  ██║███████╗
# * ╚═╝     ╚═╝╚═════╝ ╚═╝╚═╝  ╚═╝╚══════╝
# * ========================================
# * mDial - Omni-Channel Contact Centre Suite.
# * Initially Written by Martin McCarthy.
# * Contributions welcome.
# * Active: 2020 - 2023.
# *
# * This software is licensed under AGPLv2.
# * You can find more information here;
# * https://www.gnu.org/licenses/agpl-3.0.en.html
# * A copy of the license is also shipped with this build.
# *
# * Important note: this software is provided to you free of charge.
# * If you paid for this software, you were ripped off.
# *
# * This project is a fork of the awesome FOSS project, ViCiDial.
# * ViCiDial is copyrighted by Matt Florell and the ViCiDial Group
# * under the AGPLv2 license.
# *
# * You can find out more about ViCiDial;
# * Web: https://www.vicidial.com/
# * Email: Matt Florell <vicidial@gmail.com>
# * IRC: Libera.Chat - ##vicidial
# *
# * Bug reports, feature requests and patches welcome!
# * ======================================== */
if ( length( $ARGV[0] ) > 1 ) {
    $i = 0;
    while ( $#ARGV >= $i ) {
        $args = "$args $ARGV[$i]";
        $i++;
    }
    if ( $args =~ /--help/i ) {
        print "allowed run time options:\n";
        print "  [--help] = this screen\n";
        print "  [--test] = test\n";
        print "  [--debug] = verbose debug messages\n";
        print "  [--debugX] = extra verbose debug messages\n";
        print
"  [--delay=XXX] = delay of XXX seconds per loop, default 2 seconds\n";
        print "\n";
        exit;
    }
    else {
        if ( $args =~ /--delay=/i ) {
            @data_in    = split( /--delay=/, $args );
            $loop_delay = $data_in[1];
            print "     LOOP DELAY OVERRIDE!!!!! = $loop_delay seconds\n\n";
            $loop_delay = ( $loop_delay * 1000 );
        }
        else {
            $loop_delay = '2000';
        }
        if ( $args =~ /--debug/i ) {
            $DB = 1;
            print "\n-----DEBUGGING -----\n\n";
        }
        if ( $args =~ /--debugX/i ) {
            $DBX = 1;
            print "\n----- SUPER-DUPER DEBUGGING -----\n\n";
        }
        if ( $args =~ /--test/i ) {
            $TEST = 1;
            $T    = 1;
        }
    }
}
else {
    print "no command line options set\n";
    $loop_delay = '2000';
}
$US                 = '__';
$MT[0]              = '';
$local_DEF          = 'Local/';
$conf_silent_prefix = '7';
$local_AMP          = '@';
$agents             = '@agents';
$run_check          = 1;                          # concurrency check
$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++;
}
$server_ip = $VARserver_ip;    # Asterisk server IP
&get_time_now;                 # update time/date variables
if ( !$VDRLOGfile ) { $VDRLOGfile = "$PATHlogs/remoteagent.$year-$mon-$mday"; }
if ( !$VARDB_port ) { $VARDB_port = '3306'; }
use Time::HiRes ( 'gettimeofday', 'usleep', 'sleep' )
  ;    # necessary to have perl sleep command of less than one second
use Time::Local;
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;
$stmtA =
"SELECT sip_event_logging,call_quota_lead_ranking,inbound_credits 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;
    $SSsip_event_logging       = $aryA[0];
    $SScall_quota_lead_ranking = $aryA[1];
    $SSinbound_credits         = $aryA[2];
}
$sthA->finish();
$stmtA =
"SELECT vd_server_logs,local_gmt,ext_context FROM servers where server_ip = '$VARserver_ip';";
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",        $dbhA->errstr;
$sthA->execute                 or die "executing: $stmtA ", $dbhA->errstr;
$sthArows = $sthA->rows;
if ( $sthArows > 0 ) {
    @aryA             = $sthA->fetchrow_array;
    $DBvd_server_logs = $aryA[0];
    $DBSERVER_GMT     = $aryA[1];
    $ext_context      = $aryA[2];
    if   ( $DBvd_server_logs =~ /Y/ ) { $SYSLOG = '1'; }
    else                              { $SYSLOG = '0'; }
    if ( length($DBSERVER_GMT) > 0 ) { $SERVER_GMT = $DBSERVER_GMT; }
}
$sthA->finish();
&get_time_now;    # update time/date variables
$event_string =
'PROGRAM STARTED||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||';
&event_logger;    # writes to the log and if debug flag is set prints to STDOUT
$event_string = 'LOGGED INTO MYSQL SERVER ON 1 CONNECTION|';
&event_logger;
if ( $run_check > 0 ) {
    my $grepout = `/bin/ps ax | grep $0 | grep -v grep | grep -v '/bin/sh'`;
    my $grepnum = 0;
    $grepnum++ while ( $grepout =~ m/\n/g );
    if ( $grepnum > 2 ) {
        if ($DB) {
            print "I am not alone! Another $0 is running! Exiting...\n";
        }
        $event_string = "I am not alone! Another $0 is running! Exiting...";
        &event_logger;
        exit;
    }
}
$one_day_interval = 1;    # 1 day
while ( $one_day_interval > 0 ) {
    $endless_loop = ( 86400 / ( $loop_delay / 1000 ) );    # 1 day
    while ( $endless_loop > 0 ) {
        &get_time_now;
        $VDRLOGfile = "$PATHlogs/remoteagent.$year-$mon-$mday";
        if ( $endless_loop =~ /0$|5$/ ) {
            $stmtA =
"SELECT vd_server_logs FROM servers where server_ip = '$VARserver_ip';";
            $sthA = $dbhA->prepare($stmtA) or die "preparing: ", $dbhA->errstr;
            $sthA->execute or die "executing: $stmtA ",          $dbhA->errstr;
            $sthArows = $sthA->rows;
            if ( $sthArows > 0 ) {
                @aryA             = $sthA->fetchrow_array;
                $DBvd_server_logs = $aryA[0];
                if   ( $DBvd_server_logs =~ /Y/ ) { $SYSLOG = '1'; }
                else                              { $SYSLOG = '0'; }
            }
            $sthA->finish();
            $stmtA =
"SELECT enable_queuemetrics_logging,queuemetrics_server_ip,queuemetrics_dbname,queuemetrics_login,queuemetrics_pass,queuemetrics_log_id,queuemetrics_loginout,queuemetrics_addmember_enabled,queuemetrics_pe_phone_append,queuemetrics_pause_type 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;
                $enable_queuemetrics_logging    = $aryA[0];
                $queuemetrics_server_ip         = $aryA[1];
                $queuemetrics_dbname            = $aryA[2];
                $queuemetrics_login             = $aryA[3];
                $queuemetrics_pass              = $aryA[4];
                $queuemetrics_log_id            = $aryA[5];
                $queuemetrics_loginout          = $aryA[6];
                $queuemetrics_addmember_enabled = $aryA[7];
                $queuemetrics_pe_phone_append   = $aryA[8];
                $queuemetrics_pause_type        = $aryA[9];
            }
            $sthA->finish();
            @VLApausedUSER = @MT;
            $stmtA =
"SELECT user FROM vicidial_live_agents where server_ip='$server_ip' and status IN('PAUSED') and extension LIKE \"R/%\";";
            $sthA = $dbhA->prepare($stmtA) or die "preparing: ", $dbhA->errstr;
            $sthA->execute or die "executing: $stmtA ",          $dbhA->errstr;
            $vla_PAUSED_ct = $sthA->rows;
            $r             = 0;

            while ( $vla_PAUSED_ct > $r ) {
                @aryA = $sthA->fetchrow_array;
                $VLApausedUSER[$r] = $aryA[0];
                $r++;
            }
            $sthA->finish();
            $r                      = 0;
            $VLAaffected_rows       = 0;
            $VLIAaffected_rows      = 0;
            $VLAaffected_rowsTOTAL  = 0;
            $VLIAaffected_rowsTOTAL = 0;
            while ( $vla_PAUSED_ct > $r ) {
                $stmtA =
"DELETE FROM vicidial_live_agents where user='$VLApausedUSER[$r]' and server_ip='$server_ip' and status IN('PAUSED') and extension LIKE \"R/%\";";
                $VLAaffected_rows = $dbhA->do($stmtA);
                $stmtA =
"DELETE FROM vicidial_live_inbound_agents where user='$VLApausedUSER[$r]';";
                $VLIAaffected_rows = $dbhA->do($stmtA);
                $VLAaffected_rowsTOTAL =
                  ( $VLAaffected_rows + $VLAaffected_rowsTOTAL );
                $VLIAaffected_rowsTOTAL =
                  ( $VLIAaffected_rows + $VLIAaffected_rowsTOTAL );
                $r++;
            }
            if (   ( $VLAaffected_rowsTOTAL > 0 )
                || ( $VLIAaffected_rowsTOTAL > 0 ) )
            {
                $event_string =
"|     lagged call vla agent DELETED:  $VLAaffected_rowsTOTAL|$VLIAaffected_rowsTOTAL";
                &event_logger;
            }
            @QHlive_agent_id = @MT;
            @QHlead_id       = @MT;
            @QHuniqueid      = @MT;
            @QHuser          = @MT;
            @QHcall_type     = @MT;
            @QHcampaign_id   = @MT;
            @QHphone_number  = @MT;
            @QHalt_dial      = @MT;
            @QHra_user       = @MT;
            $stmtA =
"SELECT vla.live_agent_id,vla.lead_id,vla.uniqueid,vla.user,vac.call_type,vac.campaign_id,vac.phone_number,vac.alt_dial,vac.callerid,vla.ra_user FROM vicidial_live_agents vla,vicidial_auto_calls vac where vla.server_ip='$server_ip' and vla.status IN('QUEUE') and vla.extension LIKE \"R/%\" and vla.uniqueid=vac.uniqueid and vla.channel=vac.channel;";
            $sthA = $dbhA->prepare($stmtA) or die "preparing: ", $dbhA->errstr;
            $sthA->execute or die "executing: $stmtA ",          $dbhA->errstr;
            $vla_qh_ct = $sthA->rows;
            $w         = 0;

            while ( $vla_qh_ct > $w ) {
                @aryA                = $sthA->fetchrow_array;
                $QHlive_agent_id[$w] = $aryA[0];
                $QHlead_id[$w]       = $aryA[1];
                $QHuniqueid[$w]      = $aryA[2];
                $QHuser[$w]          = $aryA[3];
                $QHcall_type[$w]     = $aryA[4];
                $QHcampaign_id[$w]   = $aryA[5];
                $QHphone_number[$w]  = $aryA[6];
                $QHalt_dial[$w]      = $aryA[7];
                $QHcall_id[$w]       = $aryA[8];
                $QHra_user[$w]       = $aryA[9];

                if ( length( $QHalt_dial[$w] ) < 1 ) {
                    $QHalt_dial[$w] = 'MAIN';
                }
                $w++;
            }
            $sthA->finish();
            $w = 0;
            while ( $vla_qh_ct > $w ) {
                $start_call_url = '';
                $licf_SQL       = '';
                if ( $QHcall_type[$w] =~ /IN/ ) {
                    $licf_SQL = ",last_inbound_call_time='$SQLdate'";
                }
                $stmtA =
"UPDATE vicidial_live_agents set status='INCALL',last_call_time='$SQLdate',last_inbound_call_time_filtered='$SQLdate',last_inbound_call_finish_filtered='$SQLdate',comments='REMOTE',calls_today=(calls_today + 1),last_state_change='$SQLdate' $licf_SQL where live_agent_id='$QHlive_agent_id[$w]';";
                $Aaffected_rows = $dbhA->do($stmtA);
                $stmtB =
"UPDATE vicidial_list set status='XFER',user='$QHuser[$w]' where lead_id='$QHlead_id[$w]';";
                $Baffected_rows = $dbhA->do($stmtB);
                if ( $QHcall_type[$w] =~ /IN/ ) {
                    $max_inbound_calls = 0;
                    $stmtJ =
"SELECT max_inbound_calls,max_inbound_filter_enabled,max_inbound_filter_ingroups,inbound_credits FROM vicidial_users where user='$QHuser[$w]';";
                    $sthA = $dbhA->prepare($stmtJ)
                      or die "preparing: ", $dbhA->errstr;
                    $sthA->execute or die "executing: $stmtJ ", $dbhA->errstr;
                    $sthArowsMIC = $sthA->rows;
                    if ( $sthArowsMIC > 0 ) {
                        @aryA                           = $sthA->fetchrow_array;
                        $VU_max_inbound_calls           = $aryA[0];
                        $VU_max_inbound_filter_enabled  = $aryA[1];
                        $VU_max_inbound_filter_ingroups = $aryA[2];
                        $VU_inbound_credits             = $aryA[3];
                    }
                    $channel_group = $QHcampaign_id[$w];
                    $calls_today_filteredSQL =
",calls_today_filtered=(calls_today_filtered + 1),last_call_time_filtered='$SQLdate'";
                    $calls_today_filteredSQLnew =
",calls_today_filtered='1',last_call_time_filtered='$SQLdate'";
                    $calls_today_filteredSQLnewIGA =
",calls_today_filtered='1' ON DUPLICATE KEY UPDATE calls_today_filtered=(calls_today_filtered + 1)";
                    if ( $VU_max_inbound_filter_enabled > 0 ) {
                        $calls_today_filteredSQL       = '';
                        $calls_today_filteredSQLnew    = '';
                        $calls_today_filteredSQLnewIGA = '';
                        $VU_max_inbound_filter_ingroupsTEST =
                          ",$VU_max_inbound_filter_ingroups,";
                        if ( $VU_max_inbound_filter_ingroupsTEST !~
                            /,$channel_group,/ )
                        {
                            $calls_today_filteredSQL =
",calls_today_filtered=(calls_today_filtered + 1),last_call_time_filtered='$SQLdate'";
                            $calls_today_filteredSQLnew =
",calls_today_filtered='1',last_call_time_filtered='$SQLdate'";
                            $calls_today_filteredSQLnewIGA =
",calls_today_filtered='1' ON DUPLICATE KEY UPDATE calls_today_filtered=(calls_today_filtered + 1)";
                        }
                    }
                    $stmtC =
"UPDATE vicidial_closer_log set status='XFER',user='$QHuser[$w]',comments='REMOTE' where lead_id='$QHlead_id[$w]' and uniqueid='$QHuniqueid[$w]' and campaign_id='$QHcampaign_id[$w]' order by closecallid desc limit 1;";
                    $Caffected_rows = $dbhA->do($stmtC);
                    $stmtD =
"INSERT IGNORE INTO vicidial_live_inbound_agents SET calls_today='1',last_call_time='$SQLdate',user='$QHuser[$w]', group_id='$QHcampaign_id[$w]' $calls_today_filteredSQLnew ON DUPLICATE KEY UPDATE calls_today=(calls_today + 1) $calls_today_filteredSQL;";
                    $Daffected_rows = $dbhA->do($stmtD);
                    $stmtE =
"INSERT IGNORE INTO vicidial_inbound_group_agents set calls_today=1,user='$QHuser[$w]',group_id='$QHcampaign_id[$w]' $calls_today_filteredSQLnewIGA;";
                    $Eaffected_rows = $dbhA->do($stmtE);
                    if ( length($calls_today_filteredSQL) > 10 ) {
                        $stmtF =
"UPDATE vicidial_live_agents set last_inbound_call_time_filtered='$SQLdate' where live_agent_id='$QHlive_agent_id[$w]';";
                        $Faffected_rows = $dbhA->do($stmtF);
                    }
                    $stmtJ =
"SELECT max_inbound_calls FROM vicidial_campaigns where campaign_id='$QHcampaign_id[$w]';";
                    $sthA = $dbhA->prepare($stmtJ)
                      or die "preparing: ", $dbhA->errstr;
                    $sthA->execute or die "executing: $stmtJ ", $dbhA->errstr;
                    $sthArowsMIC = $sthA->rows;
                    if ( $sthArowsMIC > 0 ) {
                        @aryA                 = $sthA->fetchrow_array;
                        $CP_max_inbound_calls = $aryA[0];
                    }
                    $max_inbound_triggered = 0;
                    if (   ( $VU_max_inbound_calls > 0 )
                        || ( $CP_max_inbound_calls > 0 ) )
                    {
                        $max_inbound_calls = $CP_max_inbound_calls;
                        if ( $VU_max_inbound_calls > 0 ) {
                            $max_inbound_calls = $VU_max_inbound_calls;
                        }
                        $max_inbound_count = 0;
                        $stmtJ =
"SELECT sum(calls_today),sum(calls_today_filtered) FROM vicidial_inbound_group_agents where user='$QHuser[$w]' and group_type='C';";
                        $sthA = $dbhA->prepare($stmtJ)
                          or die "preparing: ", $dbhA->errstr;
                        $sthA->execute
                          or die "executing: $stmtJ ", $dbhA->errstr;
                        $sthArowsVIGA = $sthA->rows;
                        if ( $sthArowsVIGA > 0 ) {
                            @aryA              = $sthA->fetchrow_array;
                            $max_inbound_count = $aryA[0];
                            if ( $VU_max_inbound_filter_enabled > 0 ) {
                                $max_inbound_count = $aryA[1];
                            }
                        }
                        if ( $max_inbound_count >= $max_inbound_calls ) {
                            $max_inbound_triggered++;
                            $stmtJ =
"UPDATE vicidial_live_agents set closer_campaigns='' where user='$QHuser[$w]';";
                            $affected_rows = $dbhA->do($stmtJ);
                            $stmtJ =
"DELETE FROM vicidial_live_inbound_agents where user='$QHuser[$w]';";
                            $affected_rows = $dbhA->do($stmtJ);
                            $stmtJ =
"UPDATE vicidial_remote_agents set closer_campaigns='' where user_start='$QHuser[$w]';";
                            $affected_rows = $dbhA->do($stmtJ);
                            $stmtJ =
"INSERT INTO vicidial_admin_log set event_date=NOW(), user='$QHuser[$w]', ip_address='$VARserver_ip', event_section='USERS', event_type='MODIFY', record_id='$QHuser[$w]', event_code='MAX IN CALLS MODIFY REMOTE AGENT', event_sql='DELETE FROM vicidial_live_inbound_agents where user=$QHuser[$w]', event_notes='|$max_inbound_count|$max_inbound_calls|$QHuser[$w]|$QHcall_id[$w]|RA|';";
                            $affected_rows = $dbhA->do($stmtJ);
                            $event_string =
"--    MAX INBOUND AGENT CALLS TRIGGER: |$max_inbound_count|$max_inbound_calls|$QHuser[$w]|$QHcall_id[$w]|";
                            &event_logger;
                        }
                    }
                    if ( $max_inbound_triggered < 1 ) {
                        if (   ( $VU_inbound_credits >= 0 )
                            && ( $VU_inbound_credits < 1 )
                            && ( $SSinbound_credits > 0 ) )
                        {
                            $max_inbound_triggered++;
                            $stmtJ =
"UPDATE vicidial_live_agents set closer_campaigns='' where user='$QHuser[$w]';";
                            $affected_rows = $dbhA->do($stmtJ);
                            $stmtJ =
"DELETE FROM vicidial_live_inbound_agents where user='$QHuser[$w]';";
                            $affected_rows = $dbhA->do($stmtJ);
                            $stmtJ =
"UPDATE vicidial_remote_agents set closer_campaigns='' where user_start='$QHuser[$w]';";
                            $affected_rows = $dbhA->do($stmtJ);
                            $stmtJ =
"INSERT INTO vicidial_admin_log set event_date=NOW(), user='$QHuser[$w]', ip_address='$VARserver_ip', event_section='USERS', event_type='MODIFY', record_id='$QHuser[$w]', event_code='INBOUND CREDITS REMOTE AGENT', event_sql='DELETE FROM vicidial_live_inbound_agents where user=$QHuser[$w]', event_notes='|$VU_inbound_credits|$QHuser[$w]|$QHcall_id[$w]|RA|';";
                            $affected_rows = $dbhA->do($stmtJ);
                            $event_string =
"--    INBOUND CALLS CREDITS TRIGGER: |$VU_inbound_credits|$QHuser[$w]|$QHcall_id[$w]|";
                            &event_logger;
                        }
                    }
                    $stmtG =
"SELECT start_call_url,'DISABLED' FROM vicidial_inbound_groups where group_id='$QHcampaign_id[$w]';";
                }
                else {
                    $stmtC =
"UPDATE vicidial_log set status='XFER',user='$QHuser[$w]',comments='REMOTE' where uniqueid='$QHuniqueid[$w]';";
                    $Caffected_rows = $dbhA->do($stmtC);
                    $Daffected_rows = 0;
                    $Eaffected_rows = 0;
                    $stmtG =
"SELECT start_call_url,call_quota_lead_ranking FROM vicidial_campaigns where campaign_id='$QHcampaign_id[$w]';";
                }
                $sthA = $dbhA->prepare($stmtG)
                  or die "preparing: ", $dbhA->errstr;
                $sthA->execute or die "executing: $stmtG ", $dbhA->errstr;
                $start_url_ct = $sthA->rows;
                if ( $start_url_ct > 0 ) {
                    @aryA                       = $sthA->fetchrow_array;
                    $start_call_url             = $aryA[0];
                    $VD_call_quota_lead_ranking = $aryA[1];
                }
                $sthA->finish();
                if (   ( $SScall_quota_lead_ranking > 0 )
                    && ( $VD_call_quota_lead_ranking !~ /^DISABLED$/i ) )
                {
                    $CIDlead_id  = $QHlead_id[$w];
                    $temp_status = 'XFER';
                    &call_quota_logging;
                }
                $concurrent_calls = 0;
                $incalls_count    = 0;
                $stmtA =
"SELECT count(*) FROM vicidial_live_agents where ra_user='$QHra_user[$w]' and extension LIKE \"R/%\" and status IN('QUEUE','INCALL','DONE');";
                $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;
                    $concurrent_calls = $aryA[0];
                    $incalls_count    = $aryA[0];
                }
                $sthA->finish();
                $STATSmax_ra = 0;
                $stmtA =
"SELECT max_calls from vicidial_daily_ra_stats where user='$QHra_user[$w]' and stats_flag='OPEN' order by update_time desc limit 1;";
                $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;
                    $STATSmax_ra = $aryA[0];
                    $sthA->finish();
                    $update_SQL = '';
                    if ( $STATSmax_ra < $incalls_count ) {
                        $update_SQL .= ",max_calls='$incalls_count'";
                    }
                    $stmtA =
"UPDATE vicidial_daily_ra_stats SET update_time=NOW(),total_calls=(total_calls + 1)$update_SQL where user='$QHra_user[$w]' and stats_flag='OPEN';";
                    $affected_rows = $dbhA->do($stmtA);
                    $event_string =
"DAILY STATS UPDATE $channel_group|$affected_rows|$stmtA|";
                    &event_logger;
                }
                else {
                    $sthA->finish();
                    $stmtA =
"INSERT INTO vicidial_daily_ra_stats SET stats_date='$YMD',update_time=NOW(),max_calls='$incalls_count',user='$QHra_user[$w]',stats_flag='OPEN',total_calls=1;";
                    $affected_rows = $dbhA->do($stmtA);
                    $event_string =
"DAILY STATS INSERT $channel_group|$affected_rows|$stmtA|";
                    &event_logger;
                }
                if ( length($start_call_url) > 5 ) {
                    $launch = $PATHhome . "/AST_send_URL.pl";
                    $launch .= " --SYSLOG" if ($SYSLOG);
                    $launch .= " --lead_id=" . $QHlead_id[$w];
                    $launch .= " --phone_number=" . $QHphone_number[$w];
                    $launch .= " --user=" . $QHuser[$w];
                    $launch .= " --call_type=" . $QHcall_type[$w];
                    $launch .= " --campaign=" . $QHcampaign_id[$w];
                    $launch .= " --uniqueid=" . $QHuniqueid[$w];
                    $launch .= " --alt_dial=" . $QHalt_dial[$w];
                    $launch .= " --call_id=" . $QHcall_id[$w];
                    $launch .= " --list_id=0";
                    $launch .= " --function=REMOTE_AGENT_START_CALL_URL";
                    system( $launch . ' &' );
                    $event_string = "$launch|";
                    &event_logger;
                }
                $event_string =
"|     QUEUEd listing UPDATEd:  |$Aaffected_rows|$Baffected_rows|$Caffected_rows|$Daffected_rows|$Eaffected_rows|     |$QHlive_agent_id[$w]|$QHlead_id[$w]|$QHuniqueid[$w]|$QHuser[$w]|$QHcall_type[$w]|$QHcampaign_id[$w]|";
                &event_logger;
                $w++;
            }
            @psoutput       = `/bin/ps -o "%p %a" --no-headers -A`;
            $running_listen = 0;
            $i              = 0;
            foreach (@psoutput) {
                chomp( $psoutput[$i] );
                @psline = split( /\/usr\/bin\/perl /, $psoutput[$i] );
                if ( $psline[1] =~ /AST_manager_li/ ) { $running_listen++; }
                $i++;
            }
            if ( !$running_listen ) {
                $endless_loop     = 0;
                $one_day_interval = 0;
                print "\nPROCESS KILLED NO LISTENER RUNNING... EXITING\n\n";
            }
            if ($DB) {
                print "checking to see if listener is dead |$running_listen|\n";
            }
        }
        $user_counter        = 0;
        $DELusers            = '';
        @DBuser_start        = @MT;
        @DBuser_level        = @MT;
        @DBremote_user       = @MT;
        @DBremote_server_ip  = @MT;
        @DBremote_campaign   = @MT;
        @DBremote_conf_exten = @MT;
        @DBremote_closer     = @MT;
        @DBremote_random     = @MT;
        @DBon_hook_agent     = @MT;
        @DBon_hook_ring_time = @MT;
        @loginexistsRANDOM   = @MT;
        @loginexistsALL      = @MT;
        @VD_user             = @MT;
        @VD_extension        = @MT;
        @VD_status           = @MT;
        @VD_uniqueid         = @MT;
        @VD_callerid         = @MT;
        @VD_random           = @MT;
        @autocallexists      = @MT;
        @calllogfinished     = @MT;
        $stmtA =
"SELECT remote_agent_id,user_start,number_of_lines,server_ip,conf_exten,status,campaign_id,closer_campaigns,on_hook_agent,on_hook_ring_time FROM vicidial_remote_agents where status IN('ACTIVE') and server_ip='$server_ip' order by user_start;";
        $sthA = $dbhA->prepare($stmtA) or die "preparing: ", $dbhA->errstr;
        $sthA->execute or die "executing: $stmtA ",          $dbhA->errstr;
        $sthArows  = $sthA->rows;
        $TESTrun   = 0;
        $rec_count = 0;

        while ( $sthArows > $rec_count ) {
            @aryA              = $sthA->fetchrow_array;
            $user_start        = $aryA[1];
            $number_of_lines   = $aryA[2];
            $conf_exten        = $aryA[4];
            $campaign_id       = $aryA[6];
            $closer_campaigns  = $aryA[7];
            $on_hook_agent     = $aryA[8];
            $on_hook_ring_time = $aryA[9];
            $y                 = 0;

            while ( $y < $number_of_lines ) {
                $random                       = int( rand(9999999) ) + 10000000;
                $user_id                      = ( $user_start + $y );
                $DBuser_start[$user_counter]  = $user_start;
                $DBremote_user[$user_counter] = $user_id;
                $DBremote_server_ip[$user_counter]  = $server_ip;
                $DBremote_campaign[$user_counter]   = $campaign_id;
                $DBremote_conf_exten[$user_counter] = $conf_exten;
                if ( $conf_exten =~ /999999999999/ ) {
                    $TESTrun++;
                    $DBremote_conf_exten[$user_counter] =
                      ( $user_counter + 8600051 );
                }
                $DBremote_closer[$user_counter]     = $closer_campaigns;
                $DBremote_random[$user_counter]     = $random;
                $DBon_hook_agent[$user_counter]     = $on_hook_agent;
                $DBon_hook_ring_time[$user_counter] = $on_hook_ring_time;
                $y++;
                $user_counter++;
            }
            $rec_count++;
        }
        $sthA->finish();
        if ($DB) { print STDERR "$user_counter live remote agents ACTIVE\n"; }
        $stmtA =
"SELECT remote_agent_id,user_start,number_of_lines,server_ip,conf_exten,status,campaign_id,closer_campaigns FROM vicidial_remote_agents where status IN('INACTIVE') and server_ip='$server_ip' order by user_start;";
        $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;
            $Duser_start      = $aryA[1];
            $Dnumber_of_lines = $aryA[2];
            $w                = 0;
            while ( $w < $Dnumber_of_lines ) {
                $Duser_id = ( $Duser_start + $w );
                $DELusers .= "R/$Duser_id|";
                $w++;
            }
            $rec_count++;
        }
        $sthA->finish();
        $h = 0;
        foreach (@DBremote_user) {
            if ( length( $DBremote_user[$h] ) > 1 ) {
                $CAMPAIGN_autodial[$h]                       = 'Y';
                $CAMPAIGN_queuemetrics_phone_environment[$h] = '';
                $stmtA =
"SELECT dial_method,queuemetrics_phone_environment FROM vicidial_campaigns where campaign_id='$DBremote_campaign[$h]';";
                if ($DBX) { print STDERR "|$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;
                    $CAMPAIGN_dial_method[$h] = $aryA[0];
                    $CAMPAIGN_queuemetrics_phone_environment[$h] = $aryA[1];
                    if ( $CAMPAIGN_dial_method[$h] =~ /MANUAL|INBOUND_MAN/ ) {
                        $CAMPAIGN_autodial[$h] = 'N';
                    }
                }
                $sthA->finish();
                $DBon_hook_agent[$user_counter]     = $on_hook_agent;
                $DBon_hook_ring_time[$user_counter] = $on_hook_ring_time;
                $stmtA =
"SELECT count(*) FROM vicidial_live_agents where user='$DBremote_user[$h]' and server_ip='$server_ip' and campaign_id='$DBremote_campaign[$h]' and conf_exten='$DBremote_conf_exten[$h]' and closer_campaigns='$DBremote_closer[$h]' and outbound_autodial='$CAMPAIGN_autodial[$h]' and on_hook_agent='$DBon_hook_agent[$h]' and on_hook_ring_time='$DBon_hook_ring_time[$h]';";
                if ($DBX) { print STDERR "|$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;
                    $loginexistsRANDOM[$h] = $aryA[0];
                }
                $sthA->finish();
                if ( $loginexistsRANDOM[$h] > 0 ) {
                    $stmtA =
"UPDATE vicidial_live_agents set random_id='$DBremote_random[$h]' where user='$DBremote_user[$h]' and server_ip='$server_ip' and campaign_id='$DBremote_campaign[$h]' and conf_exten='$DBremote_conf_exten[$h]' and closer_campaigns='$DBremote_closer[$h]';";
                    $affected_rows = $dbhA->do($stmtA);
                    if ($DBX) {
                        print STDERR
"$DBremote_user[$h] $DBremote_campaign[$h] ONLY RANDOM ID UPDATE: $affected_rows\n";
                    }
                }
                else {
                    $stmtA =
"SELECT count(*) FROM vicidial_live_agents where user='$DBremote_user[$h]' and server_ip='$server_ip'";
                    if ($DBX) { print STDERR "|$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;
                        $loginexistsALL[$h] = $aryA[0];
                    }
                    $sthA->finish();
                    if ( $loginexistsALL[$h] > 0 ) {
                        $stmtA =
"UPDATE vicidial_live_agents set random_id='$DBremote_random[$h]',campaign_id='$DBremote_campaign[$h]',conf_exten='$DBremote_conf_exten[$h]',closer_campaigns='$DBremote_closer[$h]',status='READY',last_state_change='$SQLdate',outbound_autodial='$CAMPAIGN_autodial[$h]',on_hook_agent='$DBon_hook_agent[$h]',on_hook_ring_time='$DBon_hook_ring_time[$h]' where user='$DBremote_user[$h]' and server_ip='$server_ip';";
                        $affected_rows = $dbhA->do($stmtA);
                        if ($DBX) {
                            print STDERR
                              "$DBremote_user[$h] ALL UPDATE: $affected_rows\n";
                        }
                    }
                    else {
                        $DBuser_level[$h] = '1';
                        $stmtA =
"SELECT user_level FROM vicidial_users where user='$DBuser_start[$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;
                            $DBuser_level[$h] = $aryA[0];
                            $rec_count++;
                        }
                        $sthA->finish();
                        $stmtA =
"INSERT INTO vicidial_live_agents (user,server_ip,conf_exten,extension,status,campaign_id,random_id,last_call_time,last_update_time,last_call_finish,closer_campaigns,channel,uniqueid,callerid,user_level,comments,last_state_change,outbound_autodial,ra_user,on_hook_agent,on_hook_ring_time,last_inbound_call_time,last_inbound_call_finish,lead_id) values('$DBremote_user[$h]','$server_ip','$DBremote_conf_exten[$h]','R/$DBremote_user[$h]','READY','$DBremote_campaign[$h]','$DBremote_random[$h]','$SQLdate','$FDtsSQLdate','$SQLdate','$DBremote_closer[$h]','','','','$DBuser_level[$h]','REMOTE','$SQLdate','$CAMPAIGN_autodial[$h]','$DBuser_start[$h]','$DBon_hook_agent[$h]','$DBon_hook_ring_time[$h]','$SQLdate','$SQLdate','0');";
                        $affected_rows = $dbhA->do($stmtA);
                        if ($DBX) {
                            print STDERR "$DBremote_user[$h] NEW INSERT\n";
                        }
                        if ( $TESTrun > 0 ) {
                            $stmtA =
"SELECT count(*) FROM live_sip_channels where extension LIKE \"%999999999999\" and 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;
                                $LSC_count = $aryA[0];
                            }
                            $sthA->finish();
                            if ( $number_of_lines > $LSC_count ) {
                                $SIqueryCID =
                                  "T$CIDdate$DBremote_conf_exten[$h]";
                                $stmtA =
"INSERT INTO vicidial_manager set uniqueid = '', entry_date = '$SQLdate', status = 'NEW', response = 'N', server_ip = '$server_ip', channel = '', action = 'Originate', callerid = '$SIqueryCID', cmd_line_b = 'Channel: $local_DEF$DBremote_conf_exten[$h]$local_AMP$ext_context', cmd_line_c = 'Context: $ext_context', cmd_line_d = 'Exten: 999999999999', cmd_line_e = 'Priority: 1', cmd_line_f = 'Callerid: $SIqueryCID', cmd_line_g = '', cmd_line_h = '', cmd_line_i = '', cmd_line_j = '', cmd_line_k = '';";
                                $affected_rows = $dbhA->do($stmtA);
                                if ($DBX) {
                                    print STDERR
"   TESTrun CALL PLACED: 999999999999 $DBremote_conf_exten[$h] $DBremote_user[$h] NEW INSERT: |$affected_rows|\n";
                                }
                            }
                            else {
                                print STDERR
"Agent test calls already adequate $number_of_lines !> $LSC_count\n";
                            }
                        }
                        if ( $affected_rows > 0 ) {
                            if ( $enable_queuemetrics_logging > 0 ) {
                                $QM_LOGIN = 'AGENTLOGIN';
                                if ( $queuemetrics_loginout =~ /CALLBACK/ ) {
                                    $QM_LOGIN = 'AGENTCALLBACKLOGIN';
                                }
                                $dbhB = DBI->connect(
"DBI:mysql:$queuemetrics_dbname:$queuemetrics_server_ip:3306",
                                    "$queuemetrics_login",
                                    "$queuemetrics_pass"
                                  )
                                  or die "Couldn't connect to database: "
                                  . DBI->errstr;
                                if ($DBX) {
                                    print
"CONNECTED TO DATABASE:  $queuemetrics_server_ip|$queuemetrics_dbname\n";
                                }
                                $pe_append = '';
                                if (
                                    ( $queuemetrics_pe_phone_append > 0 )
                                    && (
                                        length(
                                            $CAMPAIGN_queuemetrics_phone_environment
                                              [
                                              $h]
                                        ) > 0
                                    )
                                  )
                                {
                                    $pe_append = "-$DBremote_conf_exten[$h]";
                                }
                                if ( $queuemetrics_loginout !~ /NONE/ ) {
                                    $stmtB =
"INSERT INTO queue_log SET `partition`='P01',time_id='$secX',call_id='NONE',queue='$DBremote_campaign[$h]',agent='Agent/$DBremote_user[$h]',verb='$QM_LOGIN',data1='$DBremote_user[$h]$agents',serverid='$queuemetrics_log_id',data4='$CAMPAIGN_queuemetrics_phone_environment[$h]$pe_append';";
                                    $Baffected_rows = $dbhB->do($stmtB);
                                }
                                $pause_typeSQL = '';
                                if ( $queuemetrics_pause_type > 0 ) {
                                    $pause_typeSQL = ",data5='SYSTEM'";
                                }
                                $stmtB =
"INSERT INTO queue_log SET `partition`='P01',time_id='$secX',call_id='NONE',queue='$DBremote_campaign[$h]',agent='Agent/$DBremote_user[$h]',verb='UNPAUSE',serverid='$queuemetrics_log_id',data4='$CAMPAIGN_queuemetrics_phone_environment[$h]$pe_append' $pause_typeSQL;";
                                $Baffected_rows = $dbhB->do($stmtB);
                                if ( $queuemetrics_addmember_enabled > 0 ) {
                                    $stmtB =
"INSERT INTO queue_log SET `partition`='P01',time_id='$secX',call_id='NONE',queue='$DBremote_campaign[$h]',agent='Agent/$DBremote_user[$h]',verb='ADDMEMBER2',data1='$DBremote_user[$h]$agents',serverid='$queuemetrics_log_id',data4='$CAMPAIGN_queuemetrics_phone_environment[$h]$pe_append';";
                                    $Baffected_rows = $dbhB->do($stmtB);
                                }
                                $dbhB->disconnect();
                            }
                        }
                    }
                }
                @TEMPingroups      = @MT;
                $TEMPagentINGROUPS = '';
                if ( length( $DBremote_closer[$h] ) > 1 ) {
                    if (   ( $enable_queuemetrics_logging > 0 )
                        && ( $queuemetrics_addmember_enabled > 0 ) )
                    {
                        $dbhB = DBI->connect(
"DBI:mysql:$queuemetrics_dbname:$queuemetrics_server_ip:3306",
                            "$queuemetrics_login",
                            "$queuemetrics_pass"
                          )
                          or die "Couldn't connect to database: " . DBI->errstr;
                    }
                    $TEMPagentINGROUPS = $DBremote_closer[$h];
                    $TEMPagentINGROUPS =~ s/-$//gi;
                    @TEMPingroups = split( / /, $TEMPagentINGROUPS );
                    $s            = 0;
                    foreach (@TEMPingroups) {
                        if ( length( $TEMPingroups[$s] ) > 1 ) {
                            $TEMPagentWEIGHT  = 0;
                            $TEMPagentCALLS   = 0;
                            $TEMPexistsVLIA   = 0;
                            $DBuser_level[$h] = '1';
                            $stmtA =
"SELECT group_weight,calls_today,group_grade,calls_today_filtered FROM vicidial_inbound_group_agents where user='$DBuser_start[$h]' and group_id='$TEMPingroups[$s]';";
                            $sthA = $dbhA->prepare($stmtA)
                              or die "preparing: ", $dbhA->errstr;
                            $sthA->execute
                              or die "executing: $stmtA ", $dbhA->errstr;
                            $sthArowsVIGA = $sthA->rows;

                            if ( $sthArowsVIGA > 0 ) {
                                @aryA              = $sthA->fetchrow_array;
                                $TEMPagentWEIGHT   = $aryA[0];
                                $TEMPagentCALLS    = $aryA[1];
                                $TEMPagentGRADE    = $aryA[2];
                                $TEMPagentCALLSftl = $aryA[3];
                            }
                            $sthA->finish();
                            $stmtA =
"SELECT count(*) FROM vicidial_live_inbound_agents where user='$DBremote_user[$h]' and group_id='$TEMPingroups[$s]' and group_weight='$TEMPagentWEIGHT' and group_grade='$TEMPagentGRADE';";
                            $sthA = $dbhA->prepare($stmtA)
                              or die "preparing: ", $dbhA->errstr;
                            $sthA->execute
                              or die "executing: $stmtA ", $dbhA->errstr;
                            $sthArowsVLIA = $sthA->rows;
                            if ( $sthArowsVLIA > 0 ) {
                                @aryA           = $sthA->fetchrow_array;
                                $TEMPexistsVLIA = $aryA[0];
                            }
                            $sthA->finish();
                            $pe_append = '';
                            if (
                                ( $queuemetrics_pe_phone_append > 0 )
                                && (
                                    length(
                                        $CAMPAIGN_queuemetrics_phone_environment
                                          [
                                          $h]
                                    ) > 0
                                )
                              )
                            {
                                $pe_append = "-$DBremote_conf_exten[$h]";
                            }
                            if ( $TEMPexistsVLIA < 1 ) {
                                $stmtA =
"INSERT IGNORE INTO vicidial_live_inbound_agents SET user='$DBremote_user[$h]', group_id='$TEMPingroups[$s]', group_weight='$TEMPagentWEIGHT', calls_today='$TEMPagentCALLS', calls_today_filtered='$TEMPagentCALLSftl', last_call_time='$SQLdate', last_call_time_filtered='$SQLdate', last_call_finish='$SQLdate', group_grade='$TEMPagentGRADE' ON DUPLICATE KEY UPDATE group_weight='$TEMPagentWEIGHT',group_grade='$TEMPagentGRADE';";
                                $affected_rows = $dbhA->do($stmtA);
                                if ( ($DBX) && ( $affected_rows > 0 ) ) {
                                    print STDERR
"$DBremote_user[$h] VLIA UPDATE: $affected_rows|$TEMPingroups[$s]|$TEMPagentWEIGHT\n";
                                }
                                if (   ( $enable_queuemetrics_logging > 0 )
                                    && ( $queuemetrics_addmember_enabled > 0 ) )
                                {
                                    $stmtB =
"INSERT INTO queue_log SET `partition`='P01',time_id='$secX',call_id='NONE',queue='$TEMPingroups[$s]',agent='Agent/$DBremote_user[$h]',verb='ADDMEMBER2',data1='$DBremote_user[$h]$agents',serverid='$queuemetrics_log_id',data4='$CAMPAIGN_queuemetrics_phone_environment[$h]$pe_append';";
                                    $Baffected_rows = $dbhB->do($stmtB);
                                }
                            }
                        }
                        $s++;
                    }
                    if (   ( $enable_queuemetrics_logging > 0 )
                        && ( $queuemetrics_addmember_enabled > 0 ) )
                    {
                        $dbhB->disconnect();
                    }
                }
            }
            $h++;
        }
        $stmtA =
"SELECT user,extension,status,uniqueid,callerid,lead_id,campaign_id,call_server_ip FROM vicidial_live_agents where extension LIKE \"R/%\" and server_ip='$server_ip' and uniqueid > 10;";
        $sthA = $dbhA->prepare($stmtA) or die "preparing: ", $dbhA->errstr;
        $sthA->execute or die "executing: $stmtA ",          $dbhA->errstr;
        $sthArows  = $sthA->rows;
        $rec_count = 0;
        $z         = 0;
        while ( $sthArows > $rec_count ) {
            @aryA                  = $sthA->fetchrow_array;
            $VDuser                = $aryA[0];
            $VDextension           = $aryA[1];
            $VDstatus              = $aryA[2];
            $VDuniqueid            = $aryA[3];
            $VDcallerid            = $aryA[4];
            $VDlead_id             = $aryA[5];
            $VDcampaign_id         = $aryA[6];
            $VDcall_server_ip      = $aryA[7];
            $VDrandom              = int( rand(9999999) ) + 10000000;
            $VD_user[$z]           = $VDuser;
            $VD_extension[$z]      = $VDextension;
            $VD_status[$z]         = $VDstatus;
            $VD_uniqueid[$z]       = $VDuniqueid;
            $VD_callerid[$z]       = $VDcallerid;
            $VD_lead_id[$z]        = $VDlead_id;
            $VD_campaign_id[$z]    = $VDcampaign_id;
            $VD_call_server_ip[$z] = $VDcall_server_ip;
            $VD_random[$z]         = $VDrandom;
            $USER_queuemetrics_phone_environment[$z] = '';
            $z++;
            $rec_count++;
        }
        $sthA->finish();
        if ($DB) { print STDERR "$z remote agents on calls\n"; }
        $z = 0;
        foreach (@VD_user) {
            $stmtA =
"SELECT count(*) FROM vicidial_auto_calls where uniqueid='$VD_uniqueid[$z]' and server_ip IN('$server_ip','$VD_call_server_ip[$z]');";
            $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;
                $autocallexists[$z] = $aryA[0];
            }
            $sthA->finish();
            $stmtA =
"SELECT queuemetrics_phone_environment FROM vicidial_campaigns where campaign_id='$VD_campaign_id[$z]';";
            $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;
                $USER_queuemetrics_phone_environment[$z] = $aryA[0];
            }
            $sthA->finish();
            if ( $autocallexists[$z] < 1 ) {
                $pe_append = '';
                if (
                    ( $queuemetrics_pe_phone_append > 0 )
                    && (
                        length( $USER_queuemetrics_phone_environment[$z] ) > 0 )
                  )
                {
                    $pe_append = "-$VD_extension[$z]";
                }
                if ( $DELusers =~ /R\/$VD_user[$z]\|/ ) {
                    $stmtA =
"UPDATE vicidial_live_agents set random_id='$VD_random[$z]',status='PAUSED', last_call_finish='$SQLdate',lead_id='',uniqueid='',callerid='',channel='',last_state_change='$SQLdate' where user='$VD_user[$z]' and server_ip='$server_ip';";
                    $affected_rows = $dbhA->do($stmtA);
                    if ($DB) {
                        print STDERR
"$VD_user[$z] CALL WIPE DELETE UPDATE: $affected_rows|PAUSED|$VD_uniqueid[$z]|$VD_user[$z]|\n";
                    }
                    if ( $affected_rows > 0 ) {
                        if ( $enable_queuemetrics_logging > 0 ) {
                            $logintime = 0;
                            $QM_LOGOFF = 'AGENTLOGOFF';
                            if ( $queuemetrics_loginout =~ /CALLBACK/ ) {
                                $QM_LOGOFF = 'AGENTCALLBACKLOGOFF';
                            }
                            $dbhB = DBI->connect(
"DBI:mysql:$queuemetrics_dbname:$queuemetrics_server_ip:3306",
                                "$queuemetrics_login",
                                "$queuemetrics_pass"
                              )
                              or die "Couldn't connect to database: "
                              . DBI->errstr;
                            if ($DBX) {
                                print
"CONNECTED TO DATABASE:  $queuemetrics_server_ip|$queuemetrics_dbname\n";
                            }
                            $pause_typeSQL = '';
                            if ( $queuemetrics_pause_type > 0 ) {
                                $pause_typeSQL = ",data5='SYSTEM'";
                            }
                            $stmtB =
"INSERT INTO queue_log SET `partition`='P01',time_id='$secX',call_id='NONE',queue='NONE',agent='Agent/$VD_user[$z]',verb='PAUSEALL',serverid='$queuemetrics_log_id',data4='$USER_queuemetrics_phone_environment[$z]$pe_append' $pause_typeSQL;";
                            $Baffected_rows = $dbhB->do($stmtB);
                            $stmtB =
"SELECT time_id,data1 FROM queue_log where agent='Agent/$VD_user[$z]' and verb IN('AGENTLOGIN','AGENTCALLBACKLOGIN') and time_id > $check_time order by time_id desc limit 1;";
                            $sthB = $dbhB->prepare($stmtB)
                              or die "preparing: ", $dbhB->errstr;
                            $sthB->execute
                              or die "executing: $stmtB ", $dbhB->errstr;
                            $sthBrows  = $sthB->rows;
                            $rec_count = 0;

                            while ( $sthBrows > $rec_count ) {
                                @aryB            = $sthB->fetchrow_array;
                                $logintime       = $aryB[0];
                                $phone_logged_in = $aryB[1];
                                $rec_count++;
                            }
                            $sthB->finish();
                            if ($DBX) {
                                print
"LOGOFF TIME LOG:  $logintime|$secX|$stmtB|\n";
                            }
                            $time_logged_in = ( $secX - $logintime );
                            if ( $time_logged_in > 1000000 ) {
                                $time_logged_in = 1;
                            }
                            if ( $queuemetrics_addmember_enabled > 0 ) {
                                if (   ( length($logintime) < 1 )
                                    || ( $queuemetrics_loginout =~ /NONE/ ) )
                                {
                                    $stmtB =
"SELECT time_id,data3 FROM queue_log where agent='Agent/$VD_user[$z]' and verb='PAUSEREASON' and data1='LOGIN' order by time_id desc limit 1;";
                                    $sthB = $dbhB->prepare($stmtB)
                                      or die "preparing: ", $dbhB->errstr;
                                    $sthB->execute
                                      or die "executing: $stmtA ",
                                      $dbhB->errstr;
                                    $sthBrows = $sthB->rows;
                                    if ( $sthBrows > 0 ) {
                                        @aryB      = $sthB->fetchrow_array;
                                        $logintime = $aryB[0];
                                        $phone_logged_in = $aryB[1];
                                    }
                                    $sthB->finish();
                                }
                                if ( $queuemetrics_loginout =~ /NONE/ ) {
                                    $pause_typeSQL = '';
                                    if ( $queuemetrics_pause_type > 0 ) {
                                        $pause_typeSQL = ",data5='SYSTEM'";
                                    }
                                    $stmtB =
"INSERT INTO queue_log SET `partition`='P01',time_id='$secX',call_id='NONE',queue='NONE',agent='Agent/$VD_user[$z]',verb='PAUSEREASON',serverid='$queuemetrics_log_id',data1='LOGOFF' $pause_typeSQL;";
                                    $Baffected_rows = $dbhB->do($stmtB);
                                }
                                $stmtB =
"SELECT distinct queue FROM queue_log where time_id >= $logintime and agent='Agent/$VD_user[$z]' and verb IN('ADDMEMBER','ADDMEMBER2') and queue != '$VD_campaign_id[$z]' order by time_id desc;";
                                $sthB = $dbhB->prepare($stmtB)
                                  or die "preparing: ", $dbhB->errstr;
                                $sthB->execute
                                  or die "executing: $stmtB ", $dbhB->errstr;
                                $sthBrows  = $sthB->rows;
                                $rec_count = 0;
                                while ( $sthBrows > $rec_count ) {
                                    @aryB = $sthB->fetchrow_array;
                                    $AM_queue[$rec_count] = $aryB[0];
                                    $rec_count++;
                                }
                                $sthB->finish();
                                $AM_queue[$rec_count] = $VD_campaign_id[$z];
                                $rec_count++;
                                $sthBrows++;
                                $rec_count = 0;
                                while ( $sthBrows > $rec_count ) {
                                    $stmtB =
"INSERT INTO queue_log SET `partition`='P01',time_id='$secX',call_id='NONE',queue='$AM_queue[$rec_count]',agent='Agent/$VD_user[$z]',verb='REMOVEMEMBER',data1='$phone_logged_in',serverid='$queuemetrics_log_id',data4='$USER_queuemetrics_phone_environment[$z]$pe_append';";
                                    $Baffected_rows = $dbhB->do($stmtB);
                                    $rec_count++;
                                }
                            }
                            if ( $queuemetrics_loginout !~ /NONE/ ) {
                                $stmtB =
"INSERT INTO queue_log SET `partition`='P01',time_id='$secX',call_id='NONE',queue='$VD_campaign_id[$z]',agent='Agent/$VD_user[$z]',verb='$QM_LOGOFF',data1='$phone_logged_in',data2='$time_logged_in',serverid='$queuemetrics_log_id',data4='$USER_queuemetrics_phone_environment[$z]$pe_append';";
                                $Baffected_rows = $dbhB->do($stmtB);
                            }
                            $dbhB->disconnect();
                        }
                    }
                }
                else {
                    $stmtA =
"UPDATE vicidial_live_agents set random_id='$VD_random[$z]', last_call_finish='$SQLdate',lead_id='',uniqueid='',callerid='',channel='',last_state_change='$SQLdate' where user='$VD_user[$z]' and server_ip='$server_ip';";
                    $affected_rows = $dbhA->do($stmtA);
                    if ($DB) {
                        print STDERR
"$VD_user[$z] CALL WIPE UPDATE: $affected_rows|READY|$VD_uniqueid[$z]|$VD_user[$z]|\n";
                    }
                    $stmtA =
"UPDATE vicidial_live_agents set status='READY' where user='$VD_user[$z]' and server_ip='$server_ip';";
                    $affected_rows = $dbhA->do($stmtA);
                    if ($DB) {
                        print STDERR
"$VD_user[$z] CALL WIPE UPDATE: $affected_rows|READY|$VD_uniqueid[$z]|$VD_user[$z]|\n";
                    }
                    if ( $affected_rows > 0 ) {
                        if ( $enable_queuemetrics_logging > 0 ) {
                            $dbhB = DBI->connect(
"DBI:mysql:$queuemetrics_dbname:$queuemetrics_server_ip:3306",
                                "$queuemetrics_login",
                                "$queuemetrics_pass"
                              )
                              or die "Couldn't connect to database: "
                              . DBI->errstr;
                            if ($DBX) {
                                print
"CONNECTED TO DATABASE:  $queuemetrics_server_ip|$queuemetrics_dbname\n";
                            }
                            $pause_typeSQL = '';
                            if ( $queuemetrics_pause_type > 0 ) {
                                $pause_typeSQL = ",data5='SYSTEM'";
                            }
                            $stmtB =
"INSERT INTO queue_log SET `partition`='P01',time_id='$secX',call_id='NONE',queue='NONE',agent='Agent/$VD_user[$z]',verb='PAUSEALL',serverid='$queuemetrics_log_id',data4='$USER_queuemetrics_phone_environment[$z]$pe_append' $pause_typeSQL;";
                            $Baffected_rows = $dbhB->do($stmtB);
                            $stmtB =
"INSERT INTO queue_log SET `partition`='P01',time_id='$secX',call_id='NONE',queue='NONE',agent='Agent/$VD_user[$z]',verb='UNPAUSEALL',serverid='$queuemetrics_log_id',data4='$USER_queuemetrics_phone_environment[$z]$pe_append' $pause_typeSQL;";
                            $Baffected_rows = $dbhB->do($stmtB);
                            $dbhB->disconnect();
                        }
                    }
                }
            }
            $z++;
        }
        usleep( 1 * $loop_delay * 1000 );
        $endless_loop--;
        if ($DB) {
            print STDERR
"\nloop counter: |$endless_loop|$one_day_interval|     |$loop_delay|\n";
        }
        if ( -e "$PATHhome/VDAD.kill" ) {
            unlink("$PATHhome/VDAD.kill");
            $endless_loop     = 0;
            $one_day_interval = 0;
            print "\nPROCESS KILLED MANUALLY... EXITING\n\n";
        }
        $bad_grabber_counter = 0;
    }
    if ($DB) {
        print
"DONE... Exiting... Goodbye... See you later... Not really, initiating next loop...\n";
    }
    $event_string = 'HANGING UP|';
    &event_logger;
    $one_day_interval--;
}
$event_string = 'CLOSING DB CONNECTION|';
&event_logger;
$dbhA->disconnect();
if ($DB) {
    print
"DONE... Exiting... Goodbye... See you later... Really I mean it this time\n";
}
exit;

sub get_time_now #get the current date and time and epoch for logging call lengths and datetimes
{
    $secX = time();
    ( $sec, $min, $hour, $mday, $mon, $year, $wday, $yday, $isdst ) =
      localtime($secX);
    $LOCAL_GMT_OFF     = $SERVER_GMT;
    $LOCAL_GMT_OFF_STD = $SERVER_GMT;
    if ($isdst) { $LOCAL_GMT_OFF++; }
    $check_time = ( $secX - 86400 );
    $GMT_now    = ( $secX - ( $LOCAL_GMT_OFF * 3600 ) );
    ( $sec, $min, $hour, $mday, $mon, $year, $wday, $yday, $isdst ) =
      localtime($GMT_now);
    if ( $hour < 10 ) { $hour = "0$hour"; }
    if ( $min < 10 )  { $min  = "0$min"; }

    if ($DB) {
        print
"TIME DEBUG: $LOCAL_GMT_OFF_STD|$LOCAL_GMT_OFF|$isdst|   GMT: $hour:$min\n";
    }
    ( $sec, $min, $hour, $mday, $mon, $year, $wday, $yday, $isdst ) =
      localtime(time);
    $year = ( $year + 1900 );
    $mon++;
    if ( $mon < 10 )  { $mon  = "0$mon"; }
    if ( $mday < 10 ) { $mday = "0$mday"; }
    if ( $hour < 10 ) { $hour = "0$hour"; }
    if ( $min < 10 )  { $min  = "0$min"; }
    if ( $sec < 10 )  { $sec  = "0$sec"; }
    $now_date_epoch = time();
    $now_date       = "$year-$mon-$mday $hour:$min:$sec";
    $CIDdate        = "$mon$mday$hour$min$sec";
    $tsSQLdate      = "$year$mon$mday$hour$min$sec";
    $SQLdate        = "$year-$mon-$mday $hour:$min:$sec";
    $filedate       = "$year-$mon-$mday";
    $YMD            = "$year-$mon-$mday";
    $FDtarget       = ( $secX + 10 );
    ( $Fsec, $Fmin, $Fhour, $Fmday, $Fmon, $Fyear, $Fwday, $Fyday, $Fisdst ) =
      localtime($FDtarget);
    $Fyear = ( $Fyear + 1900 );
    $Fmon++;
    if ( $Fmon < 10 )  { $Fmon  = "0$Fmon"; }
    if ( $Fmday < 10 ) { $Fmday = "0$Fmday"; }
    if ( $Fhour < 10 ) { $Fhour = "0$Fhour"; }
    if ( $Fmin < 10 )  { $Fmin  = "0$Fmin"; }
    if ( $Fsec < 10 )  { $Fsec  = "0$Fsec"; }
    $FDtsSQLdate = "$Fyear$Fmon$Fmday$Fhour$Fmin$Fsec";
    $BDtarget    = ( $secX - 10 );
    ( $Bsec, $Bmin, $Bhour, $Bmday, $Bmon, $Byear, $Bwday, $Byday, $Bisdst ) =
      localtime($BDtarget);
    $Byear = ( $Byear + 1900 );
    $Bmon++;
    if ( $Bmon < 10 )  { $Bmon  = "0$Bmon"; }
    if ( $Bmday < 10 ) { $Bmday = "0$Bmday"; }
    if ( $Bhour < 10 ) { $Bhour = "0$Bhour"; }
    if ( $Bmin < 10 )  { $Bmin  = "0$Bmin"; }
    if ( $Bsec < 10 )  { $Bsec  = "0$Bsec"; }
    $BDtsSQLdate = "$Byear$Bmon$Bmday$Bhour$Bmin$Bsec";
    $PDtarget    = ( $secX - 30 );
    ( $Psec, $Pmin, $Phour, $Pmday, $Pmon, $Pyear, $Pwday, $Pyday, $Pisdst ) =
      localtime($PDtarget);
    $Pyear = ( $Pyear + 1900 );
    $Pmon++;
    if ( $Pmon < 10 )  { $Pmon  = "0$Pmon"; }
    if ( $Pmday < 10 ) { $Pmday = "0$Pmday"; }
    if ( $Phour < 10 ) { $Phour = "0$Phour"; }
    if ( $Pmin < 10 )  { $Pmin  = "0$Pmin"; }
    if ( $Psec < 10 )  { $Psec  = "0$Psec"; }
    $PDtsSQLdate = "$Pyear$Pmon$Pmday$Phour$Pmin$Psec";
    $XDtarget    = ( $secX - 120 );
    ( $Xsec, $Xmin, $Xhour, $Xmday, $Xmon, $Xyear, $Xwday, $Xyday, $Xisdst ) =
      localtime($XDtarget);
    $Xyear = ( $Xyear + 1900 );
    $Xmon++;
    if ( $Xmon < 10 )  { $Xmon  = "0$Xmon"; }
    if ( $Xmday < 10 ) { $Xmday = "0$Xmday"; }
    if ( $Xhour < 10 ) { $Xhour = "0$Xhour"; }
    if ( $Xmin < 10 )  { $Xmin  = "0$Xmin"; }
    if ( $Xsec < 10 )  { $Xsec  = "0$Xsec"; }
    $XDSQLdate = "$Xyear-$Xmon-$Xmday $Xhour:$Xmin:$Xsec";
    $TDtarget  = ( $secX - 600 );
    ( $Tsec, $Tmin, $Thour, $Tmday, $Tmon, $Tyear, $Twday, $Tyday, $Tisdst ) =
      localtime($TDtarget);
    $Tyear = ( $Tyear + 1900 );
    $Tmon++;
    if ( $Tmon < 10 )  { $Tmon  = "0$Tmon"; }
    if ( $Tmday < 10 ) { $Tmday = "0$Tmday"; }
    if ( $Thour < 10 ) { $Thour = "0$Thour"; }
    if ( $Tmin < 10 )  { $Tmin  = "0$Tmin"; }
    if ( $Tsec < 10 )  { $Tsec  = "0$Tsec"; }
    $TDSQLdate = "$Tyear-$Tmon-$Tmday $Thour:$Tmin:$Tsec";
}

sub event_logger {
    if ($DB) { print "$now_date|$event_string|\n"; }
    if ($SYSLOG) {
        open( Lout, ">>$VDRLOGfile" )
          || die "Can't open $VDRLOGfile: $!\n";
        print Lout "$now_date|$event_string|\n";
        close(Lout);
    }
    $event_string = '';
}

sub call_quota_logging {
    $CQcontainer_entry = '';
    $stmtA =
"SELECT container_entry FROM vicidial_settings_containers where container_id='$VD_call_quota_lead_ranking';";
    $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;
        $CQcontainer_entry = $aryA[0];
        $CQcontainer_entry =~ s/\\//gi;
    }
    $sthA->finish();
    $session_one            = '';
    $session_two            = '';
    $session_three          = '';
    $session_four           = '';
    $session_five           = '';
    $session_six            = '';
    $settings_session_score = 0;
    $zero_rank_after_call   = 0;

    if ( length($CQcontainer_entry) > 5 ) {
        @container_lines = split( /\n/, $CQcontainer_entry );
        $c               = 0;
        foreach (@container_lines) {
            $container_lines[$c] =~ s/;.*|\r|\t| //gi;
            if ( length( $container_lines[$c] ) > 5 ) {
                if ( $container_lines[$c] =~ /^zero_rank_after_call/i ) {
                    $container_lines[$c] =~ s/zero_rank_after_call=>//gi;
                    if (   ( $container_lines[$c] >= 0 )
                        && ( $container_lines[$c] <= 1 ) )
                    {
                        $zero_rank_after_call = $container_lines[$c];
                    }
                }
                if ( $container_lines[$c] =~ /^session_one/i ) {
                    $session_one_valid = 0;
                    $session_one_start = '';
                    $session_one_end   = '';
                    $session_one       = $container_lines[$c];
                    $session_one =~ s/session_one=>//gi;
                    if (   ( length($session_one) > 0 )
                        && ( length($session_one) <= 9 )
                        && ( $session_one =~ /,/ ) )
                    {
                        @session_oneARY    = split( /,/, $session_one );
                        $session_one_start = $session_oneARY[0];
                        $session_one_end   = $session_oneARY[1];
                        if (   ( length($session_one_start) >= 4 )
                            && ( length($session_one_end) >= 4 )
                            && ( $session_one_start < $session_one_end )
                            && ( $session_one_end <= 2400 ) )
                        {
                            $settings_session_score++;
                            $session_one_valid++;
                        }
                    }
                }
                if ( $container_lines[$c] =~ /^session_two/i ) {
                    $session_two_valid = 0;
                    $session_two_start = '';
                    $session_two_end   = '';
                    $session_two       = $container_lines[$c];
                    $session_two =~ s/session_two=>//gi;
                    if (   ( length($session_two) > 0 )
                        && ( length($session_two) <= 9 )
                        && ( $session_two =~ /,/ ) )
                    {
                        @session_twoARY    = split( /,/, $session_two );
                        $session_two_start = $session_twoARY[0];
                        $session_two_end   = $session_twoARY[1];
                        if (   ( length($session_two_start) >= 4 )
                            && ( length($session_two_end) >= 4 )
                            && ( $session_one_valid > 0 )
                            && ( $session_one_end <= $session_two_start )
                            && ( $session_two_start < $session_two_end )
                            && ( $session_two_end <= 2400 ) )
                        {
                            $settings_session_score++;
                            $session_two_valid++;
                        }
                    }
                }
                if ( $container_lines[$c] =~ /^session_three/i ) {
                    $session_three_valid = 0;
                    $session_three_start = '';
                    $session_three_end   = '';
                    $session_three       = $container_lines[$c];
                    $session_three =~ s/session_three=>//gi;
                    if (   ( length($session_three) > 0 )
                        && ( length($session_three) <= 9 )
                        && ( $session_three =~ /,/ ) )
                    {
                        @session_threeARY    = split( /,/, $session_three );
                        $session_three_start = $session_threeARY[0];
                        $session_three_end   = $session_threeARY[1];
                        if (   ( length($session_three_start) >= 4 )
                            && ( length($session_three_end) >= 4 )
                            && ( $session_two_valid > 0 )
                            && ( $session_two_end <= $session_three_start )
                            && ( $session_three_start < $session_three_end )
                            && ( $session_three_end <= 2400 ) )
                        {
                            $settings_session_score++;
                            $session_three_valid++;
                        }
                    }
                }
                if ( $container_lines[$c] =~ /^session_four/i ) {
                    $session_four_valid = 0;
                    $session_four_start = '';
                    $session_four_end   = '';
                    $session_four       = $container_lines[$c];
                    $session_four =~ s/session_four=>//gi;
                    if (   ( length($session_four) > 0 )
                        && ( length($session_four) <= 9 )
                        && ( $session_four =~ /,/ ) )
                    {
                        @session_fourARY    = split( /,/, $session_four );
                        $session_four_start = $session_fourARY[0];
                        $session_four_end   = $session_fourARY[1];
                        if (   ( length($session_four_start) >= 4 )
                            && ( length($session_four_end) >= 4 )
                            && ( $session_three_valid > 0 )
                            && ( $session_three_end <= $session_four_start )
                            && ( $session_four_start < $session_four_end )
                            && ( $session_four_end <= 2400 ) )
                        {
                            $settings_session_score++;
                            $session_four_valid++;
                        }
                    }
                }
                if ( $container_lines[$c] =~ /^session_five/i ) {
                    $session_five_valid = 0;
                    $session_five_start = '';
                    $session_five_end   = '';
                    $session_five       = $container_lines[$c];
                    $session_five =~ s/session_five=>//gi;
                    if (   ( length($session_five) > 0 )
                        && ( length($session_five) <= 9 )
                        && ( $session_five =~ /,/ ) )
                    {
                        @session_fiveARY    = split( /,/, $session_five );
                        $session_five_start = $session_fiveARY[0];
                        $session_five_end   = $session_fiveARY[1];
                        if (   ( length($session_five_start) >= 4 )
                            && ( length($session_five_end) >= 4 )
                            && ( $session_four_valid > 0 )
                            && ( $session_four_end <= $session_five_start )
                            && ( $session_five_start < $session_five_end )
                            && ( $session_five_end <= 2400 ) )
                        {
                            $settings_session_score++;
                            $session_five_valid++;
                        }
                    }
                }
                if ( $container_lines[$c] =~ /^session_six/i ) {
                    $session_six_valid = 0;
                    $session_six_start = '';
                    $session_six_end   = '';
                    $session_six       = $container_lines[$c];
                    $session_six =~ s/session_six=>//gi;
                    if (   ( length($session_six) > 0 )
                        && ( length($session_six) <= 9 )
                        && ( $session_six =~ /,/ ) )
                    {
                        @session_sixARY    = split( /,/, $session_six );
                        $session_six_start = $session_sixARY[0];
                        $session_six_end   = $session_sixARY[1];
                        if (   ( length($session_six_start) >= 4 )
                            && ( length($session_six_end) >= 4 )
                            && ( $session_five_valid > 0 )
                            && ( $session_five_end <= $session_six_start )
                            && ( $session_six_start < $session_six_end )
                            && ( $session_six_end <= 2400 ) )
                        {
                            $settings_session_score++;
                            $session_six_valid++;
                        }
                    }
                }
            }
            else {
                if ( $DBX > 0 ) {
                    print "     blank line: $c|$container_lines[$c]|\n";
                }
            }
            $c++;
        }
        if ( $settings_session_score >= 1 ) {
            $stmtA =
"SELECT list_id,called_count,rank FROM vicidial_list where lead_id='$CIDlead_id';";
            $event_string = "|$stmtA|";
            &event_logger;
            $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;
                $VLlist_id      = $aryA[0];
                $VLcalled_count = $aryA[1];
                $VLrank         = $aryA[2];
                $tempVLrank     = $VLrank;
                if ( ( $zero_rank_after_call > 0 ) && ( $VLrank > 0 ) ) {
                    $tempVLrank = 0;
                }
            }
            $sthA->finish();
            $secX     = time();
            $CQtarget = ( $secX - 14400 );    # look back 4 hours
            (
                $CQsec,  $CQmin,  $CQhour, $CQmday, $CQmon,
                $CQyear, $CQwday, $CQyday, $CQisdst
            ) = localtime($CQtarget);
            $CQyear = ( $CQyear + 1900 );
            $CQmon++;
            if ( $CQmon < 10 )  { $CQmon  = "0$CQmon"; }
            if ( $CQmday < 10 ) { $CQmday = "0$CQmday"; }
            if ( $CQhour < 10 ) { $CQhour = "0$CQhour"; }
            if ( $CQmin < 10 )  { $CQmin  = "0$CQmin"; }
            if ( $CQsec < 10 )  { $CQsec  = "0$CQsec"; }
            $CQSQLdate         = "$CQyear-$CQmon-$CQmday $CQhour:$CQmin:$CQsec";
            $VDL_call_datetime = '';
            $stmtA =
"SELECT call_date from vicidial_dial_log where lead_id='$CIDlead_id' and call_date > \"$CQSQLdate\" and caller_code LIKE \"%$CIDlead_id\" order by call_date desc limit 1;";
            $event_string = "|$stmtA|";
            &event_logger;
            $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;
                $VDLcall_datetime    = $aryA[0];
                @VDLcall_datetimeARY = split( / /, $VDLcall_datetime );
                @VDLcall_timeARY     = split( /:/, $VDLcall_datetimeARY[1] );
                $VDLcall_hourmin     = "$VDLcall_timeARY[0]$VDLcall_timeARY[1]";
                if (    ( $session_one_start <= $VDLcall_hourmin )
                    and ( $session_one_end > $VDLcall_hourmin ) )
                {
                    $call_in_session = 1;
                    $session_newSQL =
                      ",session_one_calls='1',session_one_today_calls='1'";
                    $session_updateSQL =
",session_one_calls=(session_one_calls + 1),session_one_today_calls=(session_one_today_calls + 1)";
                }
                if (    ( $session_two_start <= $VDLcall_hourmin )
                    and ( $session_two_end > $VDLcall_hourmin ) )
                {
                    $call_in_session = 2;
                    $session_newSQL =
                      ",session_two_calls='1',session_two_today_calls='1'";
                    $session_updateSQL =
",session_two_calls=(session_two_calls + 1),session_two_today_calls=(session_two_today_calls + 1)";
                }
                if (    ( $session_three_start <= $VDLcall_hourmin )
                    and ( $session_three_end > $VDLcall_hourmin ) )
                {
                    $call_in_session = 3;
                    $session_newSQL =
                      ",session_three_calls='1',session_three_today_calls='1'";
                    $session_updateSQL =
",session_three_calls=(session_three_calls + 1),session_three_today_calls=(session_three_today_calls + 1)";
                }
                if (    ( $session_four_start <= $VDLcall_hourmin )
                    and ( $session_four_end > $VDLcall_hourmin ) )
                {
                    $call_in_session = 4;
                    $session_newSQL =
                      ",session_four_calls='1',session_four_today_calls='1'";
                    $session_updateSQL =
",session_four_calls=(session_four_calls + 1),session_four_today_calls=(session_four_today_calls + 1)";
                }
                if (    ( $session_five_start <= $VDLcall_hourmin )
                    and ( $session_five_end > $VDLcall_hourmin ) )
                {
                    $call_in_session = 5;
                    $session_newSQL =
                      ",session_five_calls='1',session_five_today_calls='1'";
                    $session_updateSQL =
",session_five_calls=(session_five_calls + 1),session_five_today_calls=(session_five_today_calls + 1)";
                }
                if (    ( $session_six_start <= $VDLcall_hourmin )
                    and ( $session_six_end > $VDLcall_hourmin ) )
                {
                    $call_in_session = 6;
                    $session_newSQL =
                      ",session_six_calls='1',session_six_today_calls='1'";
                    $session_updateSQL =
",session_six_calls=(session_six_calls + 1),session_six_today_calls=(session_six_today_calls + 1)";
                }
                $event_string =
"CQ-Debug 2: $VDLcall_datetime|$VDLcall_hourmin|$timeclock_end_of_day|$session_one_start|$session_one_end|$call_in_session|";
                &event_logger;
                if ( $call_in_session > 0 ) {
                    if ( length($timeclock_end_of_day) < 1 ) {
                        $timeclock_end_of_day = '0000';
                    }
                    $timeclock_end_of_day_hour =
                      ( substr( $timeclock_end_of_day, 0, 2 ) + 0 );
                    $timeclock_end_of_day_min =
                      ( substr( $timeclock_end_of_day, 2, 2 ) + 0 );
                    $today_start_epoch =
                      timelocal( '0', $timeclock_end_of_day_min,
                        $timeclock_end_of_day_hour, $mday, ( $mon - 1 ),
                        $year );
                    if ( $timeclock_end_of_day > $VDLcall_hourmin ) {
                        $today_start_epoch = ( $today_start_epoch - 86400 );
                    }
                    $day_two_start_epoch =
                      ( $today_start_epoch - ( 86400 * 1 ) );
                    $day_three_start_epoch =
                      ( $today_start_epoch - ( 86400 * 2 ) );
                    $day_four_start_epoch =
                      ( $today_start_epoch - ( 86400 * 3 ) );
                    $day_five_start_epoch =
                      ( $today_start_epoch - ( 86400 * 4 ) );
                    $day_six_start_epoch =
                      ( $today_start_epoch - ( 86400 * 5 ) );
                    $day_seven_start_epoch =
                      ( $today_start_epoch - ( 86400 * 6 ) );
                    $stmtA =
"SELECT first_call_date,UNIX_TIMESTAMP(first_call_date),last_call_date from vicidial_lead_call_quota_counts where lead_id='$CIDlead_id' and list_id='$VLlist_id';";
                    $event_string = "|$stmtA|";
                    &event_logger;
                    $sthA = $dbhA->prepare($stmtA)
                      or die "preparing: ", $dbhA->errstr;
                    $sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
                    $VLCQCinfo_ct = $sthA->rows;

                    if ( $VLCQCinfo_ct > 0 ) {
                        @aryA                     = $sthA->fetchrow_array;
                        $VLCQCfirst_call_datetime = $aryA[0];
                        $VLCQCfirst_call_epoch    = $aryA[1];
                        $VLCQClast_call_date      = $aryA[2];
                        if ( $VDLcall_datetime ne $VLCQClast_call_date ) {
                            if ( $VLCQCfirst_call_epoch >= $today_start_epoch )
                            {
                                $day_updateSQL =
                                  ',day_one_calls=(day_one_calls+1)';
                            }
                            if (
                                (
                                    $VLCQCfirst_call_epoch >=
                                    $day_two_start_epoch
                                )
                                and
                                ( $VLCQCfirst_call_epoch < $today_start_epoch )
                              )
                            {
                                $day_updateSQL =
                                  ',day_two_calls=(day_two_calls+1)';
                            }
                            if (
                                (
                                    $VLCQCfirst_call_epoch >=
                                    $day_three_start_epoch
                                )
                                and ( $VLCQCfirst_call_epoch <
                                    $day_two_start_epoch )
                              )
                            {
                                $day_updateSQL =
                                  ',day_three_calls=(day_three_calls+1)';
                            }
                            if (
                                (
                                    $VLCQCfirst_call_epoch >=
                                    $day_four_start_epoch
                                )
                                and ( $VLCQCfirst_call_epoch <
                                    $day_three_start_epoch )
                              )
                            {
                                $day_updateSQL =
                                  ',day_four_calls=(day_four_calls+1)';
                            }
                            if (
                                (
                                    $VLCQCfirst_call_epoch >=
                                    $day_five_start_epoch
                                )
                                and ( $VLCQCfirst_call_epoch <
                                    $day_four_start_epoch )
                              )
                            {
                                $day_updateSQL =
                                  ',day_five_calls=(day_five_calls+1)';
                            }
                            if (
                                (
                                    $VLCQCfirst_call_epoch >=
                                    $day_six_start_epoch
                                )
                                and ( $VLCQCfirst_call_epoch <
                                    $day_five_start_epoch )
                              )
                            {
                                $day_updateSQL =
                                  ',day_six_calls=(day_six_calls+1)';
                            }
                            if (
                                (
                                    $VLCQCfirst_call_epoch >=
                                    $day_seven_start_epoch
                                )
                                and ( $VLCQCfirst_call_epoch <
                                    $day_six_start_epoch )
                              )
                            {
                                $day_updateSQL =
                                  ',day_seven_calls=(day_seven_calls+1)';
                            }
                            $stmtA =
"UPDATE vicidial_lead_call_quota_counts SET last_call_date='$VDLcall_datetime',status='$temp_status',called_count='$VLcalled_count',rank='$tempVLrank',modify_date=NOW() $session_updateSQL $day_updateSQL where lead_id='$CIDlead_id' and list_id='$VLlist_id';";
                        }
                        else {
                            $stmtA =
"UPDATE vicidial_lead_call_quota_counts SET status='$temp_status',called_count='$VLcalled_count',rank='$tempVLrank',modify_date=NOW() where lead_id='$CIDlead_id' and list_id='$VLlist_id';";
                        }
                        $VLCQCaffected_rows_update = $dbhA->do($stmtA);
                        $event_string =
"--    VLCQC record updated: |$VLCQCaffected_rows_update|   |$stmtA|";
                        &event_logger;
                    }
                    else {
                        $stmtA =
"INSERT INTO vicidial_lead_call_quota_counts SET lead_id='$CIDlead_id',list_id='$VLlist_id',first_call_date='$VDLcall_datetime',last_call_date='$VDLcall_datetime',status='$temp_status',called_count='$VLcalled_count',day_one_calls='1',rank='$tempVLrank',modify_date=NOW() $session_newSQL;";
                        $VLCQCaffected_rows_update = $dbhA->do($stmtA);
                        $event_string =
"--    VLCQC record inserted: |$VLCQCaffected_rows_update|   |$stmtA|";
                        &event_logger;
                    }
                    if ( ( $zero_rank_after_call > 0 ) && ( $VLrank > 0 ) ) {
                        $stmtA =
"UPDATE vicidial_list SET rank='0' where lead_id='$CIDlead_id';";
                        $VLCQCaffected_rows_zero_rank = $dbhA->do($stmtA);
                        $event_string =
"--    VLCQC lead rank zero: |$VLCQCaffected_rows_zero_rank|   |$stmtA|";
                        &event_logger;
                    }
                }
            }
            $sthA->finish();
        }
    }
}