1090 lines
33 KiB
Perl
1090 lines
33 KiB
Perl
#!/usr/bin/perl
|
|
#
|
|
# ADMIN_qm_sync.pl version 2.6
|
|
#
|
|
# DESCRIPTION:
|
|
# to be run frequently to sync the vicidial_users and remote agents to the QM
|
|
# agenti_noti table, also can sync dids, ivrs, in-groups and campaigns
|
|
#
|
|
# This program only needs to be run by one server
|
|
#
|
|
# Copyright (C) 2013 Matt Florell <vicidial@gmail.com> LICENSE: AGPLv2
|
|
#
|
|
# CHANGES
|
|
# 110425-0853 - First Build
|
|
# 110506-1516 - Added DIDs, IVRs, in-groups(queues), campaigns(queues) and all-alias to the sync options
|
|
# 111203-0737 - Added queue key options for in-group ID and ALLQ
|
|
# 121115-1908 - Added CLI options for alternate QM MySQL connection information
|
|
# 130131-2225 - Added key-id-wipe options
|
|
#
|
|
|
|
# constants
|
|
$version = '130131-2225';
|
|
$US='__';
|
|
$MT[0]='';
|
|
$CLIQMDB_host=0;
|
|
$CLIQMDB_dbname=0;
|
|
$CLIQMDB_user=0;
|
|
$CLIQMDB_pass=0;
|
|
|
|
### begin parsing run-time options ###
|
|
if (length($ARGV[0])>1)
|
|
{
|
|
$i=0;
|
|
while ($#ARGV >= $i)
|
|
{
|
|
$args = "$args $ARGV[$i]";
|
|
$i++;
|
|
}
|
|
if ($args =~ /--version/i)
|
|
{
|
|
print "version: $version\n";
|
|
exit;
|
|
}
|
|
elsif ($args =~ /--help/i)
|
|
{
|
|
print "allowed run time options:\n";
|
|
print " [--user] = will synchronize users\n";
|
|
print " [--remote-agents] = will check for remote agents and sync for the number of lines defined for each\n";
|
|
print " [--dids] = will sync did entries to dnis entries in QM\n";
|
|
print " [--ivrs] = will sync call menu entries to ivr entries in QM\n";
|
|
print " [--ingroups] = will sync in-group entries to queue entries in QM\n";
|
|
print " [--campaigns] = will sync campaign entries to queue entries in QM\n";
|
|
print " [--all-sync] = will sync all of the above in QM\n";
|
|
print " [--all-alias-sync] = will sync all queues in QM into the default \"00 All Queues\" alias\n";
|
|
print " [--key-id-ig] = will ensure that the queue has the in-group id set as a key\n";
|
|
print " [--key-id-allq] = will ensure that the queue has \"ALLQ\" id set as a key\n";
|
|
print " [--key-id-wipe] = will start with a blank queue key before the other key options\n";
|
|
print " [--qm-db-server=XXX] = alternate QM mysql server\n";
|
|
print " [--qm-db-dbname=XXX] = alternate QM mysql database name\n";
|
|
print " [--qm-db-login=XXX] = alternate QM mysql server login account\n";
|
|
print " [--qm-db-pass=XXX] = alternate QM mysql server password\n";
|
|
print " [--quiet] = quiet, no output\n";
|
|
print " [--test] = test\n";
|
|
print " [--version] = display version of this script\n";
|
|
print " [--debug] = verbose debug messages\n";
|
|
print " [--debugX] = Extra-verbose debug messages\n\n";
|
|
exit;
|
|
}
|
|
else
|
|
{
|
|
if ($args =~ /--quiet/i)
|
|
{
|
|
$Q=1; # quiet
|
|
}
|
|
if ($args =~ /--debug/i)
|
|
{
|
|
$DB=1; # Debug flag
|
|
if ($Q < 1) {print "\n----- DEBUGGING -----\n\n";}
|
|
}
|
|
if ($args =~ /--debugX/i)
|
|
{
|
|
$DBX=1;
|
|
if ($Q < 1) {print "\n----- SUPER-DUPER DEBUGGING -----\n\n";}
|
|
}
|
|
if ($args =~ /--test/i)
|
|
{
|
|
$TEST=1;
|
|
$T=1;
|
|
if ($Q < 1) {print "\n----- TEST RUN, NO UPDATES -----\n\n";}
|
|
}
|
|
if ($args =~ /--all-alias-sync/i)
|
|
{
|
|
$SYNC_all_alias=1;
|
|
if ($Q < 1) {print "\n----- ALL ALIAS SYNC -----\n\n";}
|
|
}
|
|
if ($args =~ /--all-sync/i)
|
|
{
|
|
$SYNC_user=1;
|
|
$SYNC_remoteagents=1;
|
|
$SYNC_dids=1;
|
|
$SYNC_ivrs=1;
|
|
$SYNC_ingroups=1;
|
|
$SYNC_campaigns=1;
|
|
if ($Q < 1) {print "\n----- ALL SYNC -----\n\n";}
|
|
}
|
|
if ($args =~ /--user/i)
|
|
{
|
|
$SYNC_user=1;
|
|
if ($Q < 1) {print "\n----- USER SYNC -----\n\n";}
|
|
}
|
|
if ($args =~ /--remote-agents/i)
|
|
{
|
|
$SYNC_remoteagents=1;
|
|
if ($Q < 1) {print "\n----- REMOTE AGENT SYNC -----\n\n";}
|
|
}
|
|
if ($args =~ /--dids/i)
|
|
{
|
|
$SYNC_dids=1;
|
|
if ($Q < 1) {print "\n----- DID SYNC -----\n\n";}
|
|
}
|
|
if ($args =~ /--ivrs/i)
|
|
{
|
|
$SYNC_ivrs=1;
|
|
if ($Q < 1) {print "\n----- IVR SYNC -----\n\n";}
|
|
}
|
|
if ($args =~ /--ingroups/i)
|
|
{
|
|
$SYNC_ingroups=1;
|
|
if ($Q < 1) {print "\n----- IN-GROUP SYNC -----\n\n";}
|
|
}
|
|
if ($args =~ /--campaigns/i)
|
|
{
|
|
$SYNC_campaigns=1;
|
|
if ($Q < 1) {print "\n----- CAMPAIGN SYNC -----\n\n";}
|
|
}
|
|
if ($args =~ /--key-id-wipe/i)
|
|
{
|
|
$KEY_wipe=1;
|
|
if ($Q < 1) {print "\n----- QUEUE KEY WIPE -----\n\n";}
|
|
}
|
|
if ($args =~ /--key-id-ig/i)
|
|
{
|
|
$KEY_ingroup=1;
|
|
if ($Q < 1) {print "\n----- QUEUE KEY INGROUP -----\n\n";}
|
|
}
|
|
if ($args =~ /--key-id-allq/i)
|
|
{
|
|
$KEY_allq=1;
|
|
if ($Q < 1) {print "\n----- QUEUE KEY ALLQ -----\n\n";}
|
|
}
|
|
if ($args =~ /--qm-db-server=/i)
|
|
{
|
|
my @data_in = split(/--qm-db-server=/,$args);
|
|
$VARQMDB_host = $data_in[1];
|
|
$VARQMDB_host =~ s/ .*//gi;
|
|
$CLIQMDB_host=1;
|
|
if ($DB > 0)
|
|
{print "\n----- QM DB SERVER: $VARQMDB_host -----\n\n";}
|
|
}
|
|
if ($args =~ /--qm-db-login=/i)
|
|
{
|
|
my @data_in = split(/--qm-db-login=/,$args);
|
|
$VARQMDB_user = $data_in[1];
|
|
$VARQMDB_user =~ s/ .*//gi;
|
|
$CLIQMDB_user=1;
|
|
if ($DB > 0)
|
|
{print "\n----- QM DB LOGIN: $VARQMDB_user -----\n\n";}
|
|
}
|
|
if ($args =~ /--qm-db-pass=/i)
|
|
{
|
|
my @data_in = split(/--qm-db-pass=/,$args);
|
|
$VARQMDB_pass = $data_in[1];
|
|
$VARQMDB_pass =~ s/ .*//gi;
|
|
$CLIQMDB_pass=1;
|
|
if ($DB > 0)
|
|
{print "\n----- QM DB PASS: $VARQMDB_pass -----\n\n";}
|
|
}
|
|
if ($args =~ /--qm-db-dbname=/i)
|
|
{
|
|
my @data_in = split(/--qm-db-dbname=/,$args);
|
|
$VARQMDB_dbname = $data_in[1];
|
|
$VARQMDB_dbname =~ s/ .*//gi;
|
|
$CLIQMDB_dbname=1;
|
|
if ($DB > 0)
|
|
{print "\n----- QM DB DBNAME: $VARQMDB_dbname -----\n\n";}
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
# print "no command line options set\n";
|
|
}
|
|
### end parsing run-time options ###
|
|
|
|
|
|
# default path to astguiclient configuration file:
|
|
$PATHconf = '/etc/astguiclient.conf';
|
|
|
|
open(conf, "$PATHconf") || die "can't open $PATHconf: $!\n";
|
|
@conf = <conf>;
|
|
close(conf);
|
|
$i=0;
|
|
foreach(@conf)
|
|
{
|
|
$line = $conf[$i];
|
|
$line =~ s/ |>|\n|\r|\t|\#.*|;.*//gi;
|
|
if ( ($line =~ /^PATHhome/) && ($CLIhome < 1) )
|
|
{$PATHhome = $line; $PATHhome =~ s/.*=//gi;}
|
|
if ( ($line =~ /^PATHlogs/) && ($CLIlogs < 1) )
|
|
{$PATHlogs = $line; $PATHlogs =~ s/.*=//gi;}
|
|
if ( ($line =~ /^PATHagi/) && ($CLIagi < 1) )
|
|
{$PATHagi = $line; $PATHagi =~ s/.*=//gi;}
|
|
if ( ($line =~ /^PATHweb/) && ($CLIweb < 1) )
|
|
{$PATHweb = $line; $PATHweb =~ s/.*=//gi;}
|
|
if ( ($line =~ /^PATHsounds/) && ($CLIsounds < 1) )
|
|
{$PATHsounds = $line; $PATHsounds =~ s/.*=//gi;}
|
|
if ( ($line =~ /^PATHmonitor/) && ($CLImonitor < 1) )
|
|
{$PATHmonitor = $line; $PATHmonitor =~ s/.*=//gi;}
|
|
if ( ($line =~ /^VARserver_ip/) && ($CLIserver_ip < 1) )
|
|
{$VARserver_ip = $line; $VARserver_ip =~ s/.*=//gi;}
|
|
if ( ($line =~ /^VARDB_server/) && ($CLIDB_server < 1) )
|
|
{$VARDB_server = $line; $VARDB_server =~ s/.*=//gi;}
|
|
if ( ($line =~ /^VARDB_database/) && ($CLIDB_database < 1) )
|
|
{$VARDB_database = $line; $VARDB_database =~ s/.*=//gi;}
|
|
if ( ($line =~ /^VARDB_user/) && ($CLIDB_user < 1) )
|
|
{$VARDB_user = $line; $VARDB_user =~ s/.*=//gi;}
|
|
if ( ($line =~ /^VARDB_pass/) && ($CLIDB_pass < 1) )
|
|
{$VARDB_pass = $line; $VARDB_pass =~ s/.*=//gi;}
|
|
if ( ($line =~ /^VARDB_port/) && ($CLIDB_port < 1) )
|
|
{$VARDB_port = $line; $VARDB_port =~ s/.*=//gi;}
|
|
$i++;
|
|
}
|
|
|
|
|
|
if (!$CLEANLOGfile) {$CLEANLOGfile = "$PATHlogs/qmsync.$Hyear-$Hmon-$Hmday";}
|
|
|
|
if (!$VARDB_port) {$VARDB_port='3306';}
|
|
|
|
use DBI;
|
|
|
|
$dbhA = DBI->connect("DBI:mysql:$VARDB_database:$VARDB_server:$VARDB_port", "$VARDB_user", "$VARDB_pass")
|
|
or die "Couldn't connect to database: " . DBI->errstr;
|
|
|
|
#############################################
|
|
##### START QUEUEMETRICS LOGGING LOOKUP #####
|
|
$stmtA = "SELECT enable_queuemetrics_logging,queuemetrics_server_ip,queuemetrics_dbname,queuemetrics_login,queuemetrics_pass,queuemetrics_log_id 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];
|
|
}
|
|
$sthA->finish();
|
|
##### END QUEUEMETRICS LOGGING LOOKUP #####
|
|
###########################################
|
|
|
|
if ($CLIQMDB_host > 0) {$queuemetrics_server_ip = $VARQMDB_host;}
|
|
if ($CLIQMDB_dbname > 0) {$queuemetrics_dbname = $VARQMDB_dbname;}
|
|
if ($CLIQMDB_user > 0) {$queuemetrics_login = $VARQMDB_user;}
|
|
if ($CLIQMDB_pass > 0) {$queuemetrics_pass = $VARQMDB_pass;}
|
|
|
|
|
|
$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 QM DATABASE: $queuemetrics_server_ip|$queuemetrics_dbname\n";}
|
|
|
|
|
|
|
|
|
|
##### BEGIN sync of vicidial_users to agenti_noti #####
|
|
if ($SYNC_user > 0)
|
|
{
|
|
if ($DBX) {print "\n\n";}
|
|
if ($DB) {print " - starting sync of vicidial_users to agenti_noti\n";}
|
|
$found_records=0;
|
|
$updated_records=0;
|
|
$added_records=0;
|
|
|
|
### Gather distinct users in vicidial_users
|
|
$stmtA = "SELECT user,full_name from vicidial_users limit 100000;";
|
|
if ($DBX) {print "$stmtA\n";}
|
|
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
|
|
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
|
|
$sthArowsU=$sthA->rows;
|
|
|
|
$i=0;
|
|
while ($sthArowsU > $i)
|
|
{
|
|
@aryA = $sthA->fetchrow_array;
|
|
$Vuser[$i] = $aryA[0];
|
|
$Vfullname[$i] = $aryA[1];
|
|
$i++;
|
|
}
|
|
$sthA->finish();
|
|
|
|
$i=0;
|
|
while ($sthArowsU > $i)
|
|
{
|
|
### Find if agent record exists with user id and fullname identical
|
|
$stmtB = "SELECT count(*) FROM agenti_noti where nome_agente='Agent/$Vuser[$i]' and descr_agente='$Vfullname[$i]';";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$AN_records=$sthB->rows;
|
|
if ($AN_records > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$AN_count = $aryB[0];
|
|
}
|
|
$sthB->finish();
|
|
|
|
if ($AN_count < 1)
|
|
{
|
|
### Find if agent record exists with user id identical
|
|
$stmtB = "SELECT count(*) FROM agenti_noti where nome_agente='Agent/$Vuser[$i]';";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$ANX_records=$sthB->rows;
|
|
if ($ANX_records > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$ANX_count = $aryB[0];
|
|
}
|
|
$sthB->finish();
|
|
|
|
if ($ANX_count < 1)
|
|
{
|
|
### add a new agenti_noti record
|
|
$stmtB = "INSERT INTO agenti_noti(nome_agente,descr_agente,location,current_terminal,xmpp_address,payroll_code,sys_dt_creazione,sys_user_creazione,sys_dt_modifica,sys_user_modifica,chiave_agente) values('agent/$Vuser[$i]','$Vfullname[$i]','7','-','','',NOW(),'32',NOW(),'32','');";
|
|
if ($TEST < 1)
|
|
{$Baffected_rows = $dbhB->do($stmtB);}
|
|
if ($DB) {print " AGENT record inserted: $Baffected_rows|$stmtB|\n";}
|
|
|
|
$event_string = "AGENT INSERT: $i|$Vuser[$i]|$Vfullname[$i]|$Baffected_rows|$stmtB";
|
|
&event_logger;
|
|
|
|
$added_records++;
|
|
}
|
|
else
|
|
{
|
|
### update agenti_noti record with proper name
|
|
$stmtB = "UPDATE agenti_noti SET descr_agente='$Vfullname[$i]' where nome_agente='agent/$Vuser[$i]' LIMIT 1;";
|
|
if ($TEST < 1)
|
|
{$Baffected_rows = $dbhB->do($stmtB);}
|
|
if ($DB) {print " AGENT record updated: $Baffected_rows|$stmtB|\n";}
|
|
|
|
$event_string = "AGENT UPDATE: $i|$Vuser[$i]|$Vfullname[$i]|$Baffected_rows|$stmtB";
|
|
&event_logger;
|
|
|
|
$updated_records++;
|
|
}
|
|
}
|
|
|
|
else
|
|
{
|
|
if ($DB) {print " agent exists: $Vuser[$i] - $Vfullname[$i]\n";}
|
|
$found_records++;
|
|
}
|
|
|
|
$i++;
|
|
}
|
|
|
|
if ($DB) {print " - finished user sync:\n";}
|
|
if ($DB) {print " records scanned: $i\n";}
|
|
if ($DB) {print " records found: $found_records\n";}
|
|
if ($DB) {print " records updated: $updated_records\n";}
|
|
if ($DB) {print " records added: $added_records\n";}
|
|
}
|
|
##### END sync of vicidial_users to agenti_noti #####
|
|
|
|
|
|
|
|
|
|
|
|
##### BEGIN sync of vicidial_remote_agents to agenti_noti #####
|
|
if ($SYNC_remoteagents > 0)
|
|
{
|
|
if ($DBX) {print "\n\n";}
|
|
if ($DB) {print " - starting sync of vicidial_remote_agents to agenti_noti\n";}
|
|
$found_records=0;
|
|
$updated_records=0;
|
|
$added_records=0;
|
|
|
|
### Gather distinct remote agents in vicidial_remote_agents
|
|
$stmtA = "SELECT user_start,number_of_lines,full_name from vicidial_remote_agents vra,vicidial_users vu where vu.user=vra.user_start and number_of_lines > 0 limit 100000;";
|
|
if ($DBX) {print "$stmtA\n";}
|
|
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
|
|
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
|
|
$sthArowsU=$sthA->rows;
|
|
$i=0;
|
|
while ($sthArowsU > $i)
|
|
{
|
|
@aryA = $sthA->fetchrow_array;
|
|
$Vuser[$i] = $aryA[0];
|
|
$Vnumber_of_lines[$i] = $aryA[1];
|
|
$Vfullname[$i] = $aryA[2];
|
|
$i++;
|
|
}
|
|
$sthA->finish();
|
|
|
|
$i=0;
|
|
while ($sthArowsU > $i)
|
|
{
|
|
$ra_count=0;
|
|
while ($ra_count < $Vnumber_of_lines[$i])
|
|
{
|
|
$Vuser[$i]++;
|
|
|
|
### Find if agent record exists with user id and fullname identical
|
|
$stmtB = "SELECT count(*) FROM agenti_noti where nome_agente='Agent/$Vuser[$i]' and descr_agente='$Vfullname[$i]';";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$AN_records=$sthB->rows;
|
|
if ($AN_records > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$AN_count = $aryB[0];
|
|
}
|
|
$sthB->finish();
|
|
|
|
if ($AN_count < 1)
|
|
{
|
|
### Find if agent record exists with user id identical
|
|
$stmtB = "SELECT count(*) FROM agenti_noti where nome_agente='Agent/$Vuser[$i]';";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$ANX_records=$sthB->rows;
|
|
if ($ANX_records > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$ANX_count = $aryB[0];
|
|
}
|
|
$sthB->finish();
|
|
|
|
if ($ANX_count < 1)
|
|
{
|
|
### add a new agenti_noti record
|
|
$stmtB = "INSERT INTO agenti_noti(nome_agente,descr_agente,location,current_terminal,xmpp_address,payroll_code,sys_dt_creazione,sys_user_creazione,sys_dt_modifica,sys_user_modifica,chiave_agente) values('agent/$Vuser[$i]','$Vfullname[$i]','7','-','','',NOW(),'32',NOW(),'32','');";
|
|
if ($TEST < 1)
|
|
{$Baffected_rows = $dbhB->do($stmtB);}
|
|
if ($DB) {print " AGENT record inserted: $Baffected_rows|$ra_count|$stmtB|\n";}
|
|
|
|
$event_string = "AGENT INSERT: $i|$ra_count|$Vuser[$i]|$Vfullname[$i]|$Baffected_rows|$stmtB";
|
|
&event_logger;
|
|
|
|
$added_records++;
|
|
}
|
|
else
|
|
{
|
|
### update agenti_noti record with proper name
|
|
$stmtB = "UPDATE agenti_noti SET descr_agente='$Vfullname[$i]' where nome_agente='agent/$Vuser[$i]' LIMIT 1;";
|
|
if ($TEST < 1)
|
|
{$Baffected_rows = $dbhB->do($stmtB);}
|
|
if ($DB) {print " AGENT record updated: $Baffected_rows|$ra_count|$stmtB|\n";}
|
|
|
|
$event_string = "AGENT UPDATE: $i|$ra_count|$Vuser[$i]|$Vfullname[$i]|$Baffected_rows|$stmtB";
|
|
&event_logger;
|
|
|
|
$updated_records++;
|
|
}
|
|
}
|
|
|
|
else
|
|
{
|
|
if ($DB) {print " agent exists: $Vuser[$i] - $Vfullname[$i]\n";}
|
|
$found_records++;
|
|
}
|
|
$ra_count++;
|
|
}
|
|
$i++;
|
|
}
|
|
|
|
if ($DB) {print " - finished remote agent sync:\n";}
|
|
if ($DB) {print " records scanned: $i\n";}
|
|
if ($DB) {print " records found: $found_records\n";}
|
|
if ($DB) {print " records updated: $updated_records\n";}
|
|
if ($DB) {print " records added: $added_records\n";}
|
|
}
|
|
##### END sync of vicidial_remote_agents to agenti_noti #####
|
|
|
|
|
|
|
|
|
|
|
|
##### BEGIN sync of vicidial_inbound_dids to dnis #####
|
|
if ($SYNC_dids > 0)
|
|
{
|
|
if ($DBX) {print "\n\n";}
|
|
if ($DB) {print " - starting sync of vicidial_inbound_dids to dnis\n";}
|
|
$found_records=0;
|
|
$updated_records=0;
|
|
$added_records=0;
|
|
|
|
### Gather distinct dids in vicidial_inbound_dids
|
|
$stmtA = "SELECT did_pattern,did_description from vicidial_inbound_dids limit 1000000;";
|
|
if ($DBX) {print "$stmtA\n";}
|
|
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
|
|
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
|
|
$sthArowsD=$sthA->rows;
|
|
|
|
$i=0;
|
|
while ($sthArowsD > $i)
|
|
{
|
|
@aryA = $sthA->fetchrow_array;
|
|
$Vdid[$i] = $aryA[0];
|
|
$Vdescription[$i] = $aryA[1];
|
|
$i++;
|
|
}
|
|
$sthA->finish();
|
|
|
|
$i=0;
|
|
while ($sthArowsD > $i)
|
|
{
|
|
### Find if dnis exists with did and description identical
|
|
$stmtB = "SELECT count(*) FROM dnis where dnis_k='$Vdid[$i]' and dnis_v='$Vdid[$i] - $Vdescription[$i]';";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$AN_records=$sthB->rows;
|
|
if ($AN_records > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$AN_count = $aryB[0];
|
|
}
|
|
$sthB->finish();
|
|
|
|
if ($AN_count < 1)
|
|
{
|
|
### Find if did record exists with did identical
|
|
$stmtB = "SELECT count(*) FROM dnis where dnis_k='$Vdid[$i]';";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$ANX_records=$sthB->rows;
|
|
if ($ANX_records > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$ANX_count = $aryB[0];
|
|
}
|
|
$sthB->finish();
|
|
|
|
if ($ANX_count < 1)
|
|
{
|
|
### add a new dnis record
|
|
$stmtB = "INSERT INTO dnis (dnis_k,dnis_v,sys_dt_creazione,sys_user_creazione,sys_dt_modifica,sys_user_modifica,sys_optilock) values('$Vdid[$i]','$Vdid[$i] - $Vdescription[$i]',NOW(),'32',NOW(),'32','82946');";
|
|
if ($TEST < 1)
|
|
{$Baffected_rows = $dbhB->do($stmtB);}
|
|
if ($DB) {print " DNIS record inserted: $Baffected_rows|$stmtB|\n";}
|
|
|
|
$event_string = "DNIS INSERT: $i|$Vdid[$i]|$Vdescription[$i]|$Baffected_rows|$stmtB";
|
|
&event_logger;
|
|
|
|
$added_records++;
|
|
}
|
|
else
|
|
{
|
|
### update dnis record with proper description
|
|
$stmtB = "UPDATE dnis SET dnis_v='$Vdid[$i] - $Vdescription[$i]' where dnis_k='$Vdid[$i]' LIMIT 1;";
|
|
if ($TEST < 1)
|
|
{$Baffected_rows = $dbhB->do($stmtB);}
|
|
if ($DB) {print " DNIS record updated: $Baffected_rows|$stmtB|\n";}
|
|
|
|
$event_string = "DNIS UPDATE: $i|$Vdid[$i]|$Vdescription[$i]|$Baffected_rows|$stmtB";
|
|
&event_logger;
|
|
|
|
$updated_records++;
|
|
}
|
|
}
|
|
|
|
else
|
|
{
|
|
if ($DB) {print " did exists: $Vdid[$i] - $Vdescription[$i]\n";}
|
|
$found_records++;
|
|
}
|
|
|
|
$i++;
|
|
}
|
|
|
|
if ($DB) {print " - finished did sync:\n";}
|
|
if ($DB) {print " records scanned: $i\n";}
|
|
if ($DB) {print " records found: $found_records\n";}
|
|
if ($DB) {print " records updated: $updated_records\n";}
|
|
if ($DB) {print " records added: $added_records\n";}
|
|
}
|
|
##### END sync of vicidial_inbound_dids to dnis #####
|
|
|
|
|
|
|
|
|
|
|
|
##### BEGIN sync of vicidial_call_menu to ivr #####
|
|
if ($SYNC_ivrs > 0)
|
|
{
|
|
if ($DBX) {print "\n\n";}
|
|
if ($DB) {print " - starting sync of vicidial_call_menu to ivr\n";}
|
|
$found_records=0;
|
|
$updated_records=0;
|
|
$added_records=0;
|
|
|
|
### Gather distinct dids in vicidial_call_menu
|
|
$stmtA = "SELECT menu_id,menu_name from vicidial_call_menu limit 1000000;";
|
|
if ($DBX) {print "$stmtA\n";}
|
|
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
|
|
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
|
|
$sthArowsD=$sthA->rows;
|
|
|
|
$i=0;
|
|
while ($sthArowsD > $i)
|
|
{
|
|
@aryA = $sthA->fetchrow_array;
|
|
$Vivr[$i] = $aryA[0];
|
|
$Vdescription[$i] = $aryA[1];
|
|
$i++;
|
|
}
|
|
$sthA->finish();
|
|
|
|
$i=0;
|
|
while ($sthArowsD > $i)
|
|
{
|
|
### Find if ivr exists with ivr and description identical
|
|
$stmtB = "SELECT count(*) FROM ivr where ivr_k='$Vivr[$i]' and ivr_v='$Vivr[$i] - $Vdescription[$i]';";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$AN_records=$sthB->rows;
|
|
if ($AN_records > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$AN_count = $aryB[0];
|
|
}
|
|
$sthB->finish();
|
|
|
|
if ($AN_count < 1)
|
|
{
|
|
### Find if ivr record exists with ivr identical
|
|
$stmtB = "SELECT count(*) FROM ivr where ivr_k='$Vivr[$i]';";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$ANX_records=$sthB->rows;
|
|
if ($ANX_records > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$ANX_count = $aryB[0];
|
|
}
|
|
$sthB->finish();
|
|
|
|
if ($ANX_count < 1)
|
|
{
|
|
### add a new ivr record
|
|
$stmtB = "INSERT INTO ivr (ivr_k,ivr_v,sys_dt_creazione,sys_user_creazione,sys_dt_modifica,sys_user_modifica,sys_optilock) values('$Vivr[$i]','$Vivr[$i] - $Vdescription[$i]',NOW(),'32',NOW(),'32','82946');";
|
|
if ($TEST < 1)
|
|
{$Baffected_rows = $dbhB->do($stmtB);}
|
|
if ($DB) {print " ivr record inserted: $Baffected_rows|$stmtB|\n";}
|
|
|
|
$event_string = "ivr INSERT: $i|$Vivr[$i]|$Vdescription[$i]|$Baffected_rows|$stmtB";
|
|
&event_logger;
|
|
|
|
$added_records++;
|
|
}
|
|
else
|
|
{
|
|
### update ivr record with proper description
|
|
$stmtB = "UPDATE ivr SET ivr_v='$Vivr[$i] - $Vdescription[$i]' where ivr_k='$Vivr[$i]' LIMIT 1;";
|
|
if ($TEST < 1)
|
|
{$Baffected_rows = $dbhB->do($stmtB);}
|
|
if ($DB) {print " ivr record updated: $Baffected_rows|$stmtB|\n";}
|
|
|
|
$event_string = "ivr UPDATE: $i|$Vivr[$i]|$Vdescription[$i]|$Baffected_rows|$stmtB";
|
|
&event_logger;
|
|
|
|
$updated_records++;
|
|
}
|
|
}
|
|
|
|
else
|
|
{
|
|
if ($DB) {print " ivr exists: $Vivr[$i] - $Vdescription[$i]\n";}
|
|
$found_records++;
|
|
}
|
|
|
|
$i++;
|
|
}
|
|
|
|
if ($DB) {print " - finished ivr sync:\n";}
|
|
if ($DB) {print " records scanned: $i\n";}
|
|
if ($DB) {print " records found: $found_records\n";}
|
|
if ($DB) {print " records updated: $updated_records\n";}
|
|
if ($DB) {print " records added: $added_records\n";}
|
|
}
|
|
##### END sync of vicidial_call_menu to ivr #####
|
|
|
|
|
|
|
|
|
|
|
|
##### BEGIN sync of vicidial_inbound_groups to code_possibili #####
|
|
if ($SYNC_ingroups > 0)
|
|
{
|
|
if ($DBX) {print "\n\n";}
|
|
if ($DB) {print " - starting sync of vicidial_inbound_groups to code_possibili\n";}
|
|
$found_records=0;
|
|
$updated_records=0;
|
|
$added_records=0;
|
|
|
|
### Gather distinct in-groups in vicidial_inbound_groups
|
|
$stmtA = "SELECT group_id,group_name from vicidial_inbound_groups limit 1000000;";
|
|
if ($DBX) {print "$stmtA\n";}
|
|
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
|
|
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
|
|
$sthArowsD=$sthA->rows;
|
|
|
|
$i=0;
|
|
while ($sthArowsD > $i)
|
|
{
|
|
@aryA = $sthA->fetchrow_array;
|
|
$Vid[$i] = $aryA[0];
|
|
$Vdescription[$i] = $aryA[1];
|
|
$i++;
|
|
}
|
|
$sthA->finish();
|
|
|
|
$i=0;
|
|
while ($sthArowsD > $i)
|
|
{
|
|
$visibility_keySEARCH='';
|
|
if ($KEY_ingroup > 0)
|
|
{$visibility_keySEARCH = " and visibility_key LIKE \"%$Vid[$i]%\"";}
|
|
if ($KEY_allq > 0)
|
|
{$visibility_keySEARCH .= " and visibility_key LIKE \"%ALLQ%\"";}
|
|
|
|
if ($KEY_wipe > 0)
|
|
{
|
|
$visibility_keySEARCH='';
|
|
if ( ($KEY_ingroup > 0) && ($KEY_allq > 0) )
|
|
{$visibility_keySEARCH = " and visibility_key = '$Vid[$i] ALLQ'";}
|
|
else
|
|
{
|
|
if ($KEY_ingroup > 0)
|
|
{$visibility_keySEARCH .= " and visibility_key ='$Vid[$i]'";}
|
|
if ($KEY_allq > 0)
|
|
{$visibility_keySEARCH .= " and visibility_key ='ALLQ'";}
|
|
}
|
|
}
|
|
|
|
### Find if queue exists with id and description identical
|
|
$stmtB = "SELECT count(*) FROM code_possibili where composizione_coda='$Vid[$i]' and nome_coda='$Vdescription[$i]' and q_direction='inbound' $visibility_keySEARCH;";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$AN_records=$sthB->rows;
|
|
if ($AN_records > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$AN_count = $aryB[0];
|
|
}
|
|
$sthB->finish();
|
|
|
|
if ($AN_count < 1)
|
|
{
|
|
### Find if queue record exists with id identical
|
|
$stmtB = "SELECT count(*) FROM code_possibili where composizione_coda='$Vid[$i]';";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$ANX_records=$sthB->rows;
|
|
if ($ANX_records > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$ANX_count = $aryB[0];
|
|
}
|
|
$sthB->finish();
|
|
|
|
if ($ANX_count < 1)
|
|
{
|
|
if ($KEY_ingroup > 0)
|
|
{
|
|
$PREvisibility_key=',visibility_key';
|
|
$POSTvisibility_key=",'$Vid[$i]'";
|
|
if ($KEY_allq > 0)
|
|
{$POSTvisibility_key=",'$Vid[$i] ALLQ'";}
|
|
}
|
|
else
|
|
{
|
|
if ($KEY_allq > 0)
|
|
{$PREvisibility_key=',visibility_key'; $POSTvisibility_key=",'ALLQ'";}
|
|
}
|
|
### add a new queue record in code_possibili
|
|
$stmtB = "INSERT INTO code_possibili (composizione_coda,nome_coda,q_direction,sys_dt_creazione,sys_user_creazione,sys_dt_modifica,sys_user_modifica $PREvisibility_key) values('$Vid[$i]','$Vdescription[$i]','inbound',NOW(),'32',NOW(),'32'$POSTvisibility_key);";
|
|
if ($TEST < 1)
|
|
{$Baffected_rows = $dbhB->do($stmtB);}
|
|
if ($DB) {print " code_possibili in-group record inserted: $Baffected_rows|$stmtB|\n";}
|
|
|
|
$event_string = "code_possibili INSERT: $i|$Vid[$i]|$Vdescription[$i]|$Baffected_rows|$stmtB";
|
|
&event_logger;
|
|
|
|
$added_records++;
|
|
}
|
|
else
|
|
{
|
|
if ( ($KEY_ingroup > 0) || ($KEY_allq > 0) )
|
|
{
|
|
$visibility_key='';
|
|
### gather the current visibility_key value for this queue
|
|
$stmtB = "SELECT visibility_key FROM code_possibili where composizione_coda='$Vid[$i]';";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$ANX_records=$sthB->rows;
|
|
if ($ANX_records > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$visibility_key = $aryB[0];
|
|
}
|
|
$sthB->finish();
|
|
|
|
if ($KEY_wipe > 0)
|
|
{$visibility_key='';}
|
|
|
|
if (length($visibility_key) < 2)
|
|
{
|
|
if ($KEY_ingroup > 0)
|
|
{
|
|
$visibility_keySQL=",visibility_key='$Vid[$i]'";
|
|
if ($KEY_allq > 0)
|
|
{$visibility_keySQL=",visibility_key='$Vid[$i] ALLQ'";}
|
|
}
|
|
else
|
|
{
|
|
if ($KEY_allq > 0)
|
|
{$visibility_keySQL=",visibility_key='ALLQ'";}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
$VKupdate=0;
|
|
if ($KEY_ingroup > 0)
|
|
{
|
|
$igcheck = $Vid[$i];
|
|
if ($visibility_key !~ /$igcheck/i)
|
|
{$visibility_key .= " $igcheck"; $VKupdate++;}
|
|
}
|
|
if ($KEY_allq > 0)
|
|
{
|
|
if ($visibility_key !~ /ALLQ/i)
|
|
{$visibility_key .= " ALLQ"; $VKupdate++;}
|
|
}
|
|
if ($VKupdate > 0)
|
|
{$visibility_keySQL=",visibility_key='$visibility_key'";}
|
|
}
|
|
}
|
|
### update queue record with proper description
|
|
$stmtB = "UPDATE code_possibili SET nome_coda='$Vdescription[$i]',q_direction='inbound' $visibility_keySQL where composizione_coda='$Vid[$i]' LIMIT 1;";
|
|
if ($TEST < 1)
|
|
{$Baffected_rows = $dbhB->do($stmtB);}
|
|
if ($DB) {print " code_possibili in-group record updated: $Baffected_rows|$stmtB|\n";}
|
|
|
|
$event_string = "code_possibili UPDATE: $i|$Vid[$i]|$Vdescription[$i]|$Baffected_rows|$stmtB";
|
|
&event_logger;
|
|
|
|
$updated_records++;
|
|
}
|
|
}
|
|
|
|
else
|
|
{
|
|
if ($DB) {print " code_possibili in-group exists: $Vid[$i] - $Vdescription[$i]\n";}
|
|
$found_records++;
|
|
}
|
|
|
|
$i++;
|
|
}
|
|
|
|
if ($DB) {print " - finished inbound queue sync:\n";}
|
|
if ($DB) {print " records scanned: $i\n";}
|
|
if ($DB) {print " records found: $found_records\n";}
|
|
if ($DB) {print " records updated: $updated_records\n";}
|
|
if ($DB) {print " records added: $added_records\n";}
|
|
}
|
|
##### END sync of vicidial_inbound_groups to code_possibili #####
|
|
|
|
|
|
|
|
|
|
|
|
##### BEGIN sync of vicidial_campaigns to code_possibili #####
|
|
if ($SYNC_campaigns > 0)
|
|
{
|
|
if ($DBX) {print "\n\n";}
|
|
if ($DB) {print " - starting sync of vicidial_campaigns to code_possibili\n";}
|
|
$found_records=0;
|
|
$updated_records=0;
|
|
$added_records=0;
|
|
|
|
### Gather distinct in-groups in vicidial_campaigns
|
|
$stmtA = "SELECT campaign_id,campaign_name from vicidial_campaigns limit 100000;";
|
|
if ($DBX) {print "$stmtA\n";}
|
|
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
|
|
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
|
|
$sthArowsD=$sthA->rows;
|
|
|
|
$i=0;
|
|
while ($sthArowsD > $i)
|
|
{
|
|
@aryA = $sthA->fetchrow_array;
|
|
$Vid[$i] = $aryA[0];
|
|
$Vdescription[$i] = $aryA[1];
|
|
$i++;
|
|
}
|
|
$sthA->finish();
|
|
|
|
$i=0;
|
|
while ($sthArowsD > $i)
|
|
{
|
|
### Find if queue exists with id and description identical
|
|
$stmtB = "SELECT count(*) FROM code_possibili where composizione_coda='$Vid[$i]' and nome_coda='$Vdescription[$i]' and q_direction='outbound';";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$AN_records=$sthB->rows;
|
|
if ($AN_records > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$AN_count = $aryB[0];
|
|
}
|
|
$sthB->finish();
|
|
|
|
if ($AN_count < 1)
|
|
{
|
|
### Find if queue record exists with id identical
|
|
$stmtB = "SELECT count(*) FROM code_possibili where composizione_coda='$Vid[$i]';";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$ANX_records=$sthB->rows;
|
|
if ($ANX_records > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$ANX_count = $aryB[0];
|
|
}
|
|
$sthB->finish();
|
|
|
|
if ($ANX_count < 1)
|
|
{
|
|
### add a new queue record in code_possibili
|
|
$stmtB = "INSERT INTO code_possibili (composizione_coda,nome_coda,q_direction,sys_dt_creazione,sys_user_creazione,sys_dt_modifica,sys_user_modifica) values('$Vid[$i]','$Vdescription[$i]','outbound',NOW(),'32',NOW(),'32');";
|
|
if ($TEST < 1)
|
|
{$Baffected_rows = $dbhB->do($stmtB);}
|
|
if ($DB) {print " code_possibili campaign record inserted: $Baffected_rows|$stmtB|\n";}
|
|
|
|
$event_string = "code_possibili INSERT: $i|$Vid[$i]|$Vdescription[$i]|$Baffected_rows|$stmtB";
|
|
&event_logger;
|
|
|
|
$added_records++;
|
|
}
|
|
else
|
|
{
|
|
### update queue record with proper description
|
|
$stmtB = "UPDATE code_possibili SET nome_coda='$Vdescription[$i]',q_direction='outbound' where composizione_coda='$Vid[$i]' LIMIT 1;";
|
|
if ($TEST < 1)
|
|
{$Baffected_rows = $dbhB->do($stmtB);}
|
|
if ($DB) {print " code_possibili campaign record updated: $Baffected_rows|$stmtB|\n";}
|
|
|
|
$event_string = "code_possibili UPDATE: $i|$Vid[$i]|$Vdescription[$i]|$Baffected_rows|$stmtB";
|
|
&event_logger;
|
|
|
|
$updated_records++;
|
|
}
|
|
}
|
|
|
|
else
|
|
{
|
|
if ($DB) {print " code_possibili campaign exists: $Vid[$i] - $Vdescription[$i]\n";}
|
|
$found_records++;
|
|
}
|
|
|
|
$i++;
|
|
}
|
|
|
|
if ($DB) {print " - finished campaign queue sync:\n";}
|
|
if ($DB) {print " records scanned: $i\n";}
|
|
if ($DB) {print " records found: $found_records\n";}
|
|
if ($DB) {print " records updated: $updated_records\n";}
|
|
if ($DB) {print " records added: $added_records\n";}
|
|
}
|
|
##### END sync of vicidial_campaigns to code_possibili #####
|
|
|
|
|
|
|
|
|
|
|
|
##### BEGIN sync of all alias entry in code_possibili #####
|
|
if ($SYNC_all_alias > 0)
|
|
{
|
|
if ($DBX) {print "\n\n";}
|
|
if ($DB) {print " - starting sync of code_possibili All Queues alias\n";}
|
|
$found_records=0;
|
|
$updated_records=0;
|
|
$added_records=0;
|
|
|
|
### Find if All Alias queue exists
|
|
$stmtB = "SELECT count(*) FROM code_possibili where nome_coda='00 All Queues';";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$AAQ_records=$sthB->rows;
|
|
if ($AAQ_records > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$AAQ_count = $aryB[0];
|
|
}
|
|
$sthB->finish();
|
|
|
|
if ($AAQ_count < 1)
|
|
{
|
|
if ($DB) {print " - All Alias queue does not exist\n";}
|
|
}
|
|
else
|
|
{
|
|
### Gather distinct code_possibili queues
|
|
$AAQ_list='';
|
|
$stmtB = "SELECT composizione_coda FROM code_possibili where nome_coda NOT IN('00 All Queues','00 All');";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$AAQD_records=$sthB->rows;
|
|
$i=0;
|
|
while ($AAQD_records > $i)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$AAQ_list .= "$aryB[0]|";
|
|
$i++;
|
|
}
|
|
$sthB->finish();
|
|
chop($AAQ_list);
|
|
|
|
### Find if queue exists with id and description identical
|
|
$stmtB = "SELECT count(*) FROM code_possibili where composizione_coda='$AAQ_list' and nome_coda='00 All Queues';";
|
|
$sthB = $dbhB->prepare($stmtB) or die "preparing: ",$dbhB->errstr;
|
|
$sthB->execute or die "executing: $stmtB ", $dbhB->errstr;
|
|
$AN_records=$sthB->rows;
|
|
if ($AN_records > 0)
|
|
{
|
|
@aryB = $sthB->fetchrow_array;
|
|
$AN_count = $aryB[0];
|
|
}
|
|
$sthB->finish();
|
|
|
|
if ($AN_count < 1)
|
|
{
|
|
### update queue record with proper description
|
|
$stmtB = "UPDATE code_possibili SET composizione_coda='$AAQ_list' where nome_coda='00 All Queues' LIMIT 1;";
|
|
if ($TEST < 1)
|
|
{$Baffected_rows = $dbhB->do($stmtB);}
|
|
if ($DB) {print " code_possibili all alias record updated: $Baffected_rows|$stmtB|\n";}
|
|
|
|
$event_string = "code_possibili UPDATE: $i|all alias|$Baffected_rows|$stmtB";
|
|
&event_logger;
|
|
|
|
$updated_records++;
|
|
}
|
|
|
|
if ($DB) {print " - finished All Alias queue sync:\n";}
|
|
if ($DB) {print " records scanned: $i\n";}
|
|
if ($DB) {print " records found: $AAQ_count\n";}
|
|
if ($DB) {print " records updated: $updated_records\n";}
|
|
}
|
|
}
|
|
##### END sync of all alias in code_possibili #####
|
|
|
|
|
|
|
|
|
|
if ($DB) {print STDERR "\nDONE\n";}
|
|
|
|
$dbhB->disconnect();
|
|
|
|
exit;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
sub event_logger
|
|
{
|
|
### open the log file for writing ###
|
|
open(Lout, ">>$CLEANLOGfile")
|
|
|| die "Can't open $CLEANLOGfile: $!\n";
|
|
print Lout "$HDSQLdate|$event_string|\n";
|
|
close(Lout);
|
|
$event_string='';
|
|
}
|