ViciDial/ViciDialSVN
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added Event handlers for new manager events, updates to the listen script

Browse Source 
git-svn-id: svn://192.168.202.10@3422 3d104415-ff17-0410-8863-d5cf3c621b8a
This commit is contained in:
mattf
2021-04-08 14:35:22 +00:00
parent 85d9fef3fd
commit 2f1319014b
5 changed files with 250 additions and 122 deletions
Download Patch File Download Diff File Expand all files Collapse all files
agc_2-X/trunk/bin/ADMIN_archive_log_tables.pl
+55
View File
@@ -60,6 +60,7 @@
# 200102-0846 - Added vicidial_vmm_counts archiving
# 201107-2206 - Added optional park_log archiving
# 210317-2104 - Added vicidial_agent_visibility_log archiving
# 210407-2023 - Added vicidial_peer_event_log archiving
#
$CALC_TEST=0;
@@ -2104,6 +2105,60 @@ if (!$T)
}
##### vicidial_peer_event_log
$vicidial_peer_event_log_count_mil=0;
$stmtA = "SELECT count(*) from vicidial_peer_event_log;";
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
$sthArows=$sthA->rows;
if ($sthArows > 0)
{
@aryA = $sthA->fetchrow_array;
$vicidial_peer_event_log_count = $aryA[0];
}
$sthA->finish();
$vicidial_peer_event_log_count_mil = ($vicidial_peer_event_log_count - 1000000);
$stmtA = "SELECT count(*) from vicidial_peer_event_log_archive;";
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
$sthArows=$sthA->rows;
if ($sthArows > 0)
{
@aryA = $sthA->fetchrow_array;
$vicidial_peer_event_log_archive_count = $aryA[0];
}
$sthA->finish();
if (!$Q) {print "\nProcessing vicidial_peer_event_log table... ($vicidial_peer_event_log_count|$vicidial_peer_event_log_archive_count)\n";}
$stmtA = "INSERT IGNORE INTO vicidial_peer_event_log_archive SELECT * from vicidial_peer_event_log;";
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
$sthArows = $sthA->rows;
if (!$Q) {print "$sthArows rows inserted into vicidial_peer_event_log_archive table \n";}
$rv = $sthA->err();
if ( (!$rv) && ($vicidial_peer_event_log_count_mil > 0) )
{
if ($wipe_all > 0)
{$stmtA = "DELETE FROM vicidial_peer_event_log;";}
else
{$stmtA = "DELETE FROM vicidial_peer_event_log WHERE event_date < '$del_time' order by peer_event_id limit $vicidial_peer_event_log_count_mil;";}
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
$sthArows = $sthA->rows;
if (!$Q) {print "$sthArows rows deleted from vicidial_peer_event_log table \n";}
$stmtA = "optimize table vicidial_peer_event_log;";
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
$stmtA = "optimize table vicidial_peer_event_log_archive;";
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
}
##### vicidial_inbound_survey_log
$stmtA = "SELECT count(*) from vicidial_inbound_survey_log;";