converted delete expired groupings hourly script
This commit is contained in:
parent
136a89ee7a
commit
741de69841
4 changed files with 103 additions and 38 deletions
|
|
@ -128,7 +128,8 @@ sub addWorkflow {
|
||||||
$session->config->set("workflowActivities", {
|
$session->config->set("workflowActivities", {
|
||||||
None=>["WebGUI::Workflow::Activity::DecayKarma", "WebGUI::Workflow::Activity::TrashClipboard", "WebGUI::Workflow::Activity::CleanTempStorage",
|
None=>["WebGUI::Workflow::Activity::DecayKarma", "WebGUI::Workflow::Activity::TrashClipboard", "WebGUI::Workflow::Activity::CleanTempStorage",
|
||||||
"WebGUI::Workflow::Activity::CleanFileCache", "WebGUI::Workflow::Activity::CleanLoginHistory", "WebGUI::Workflow::Activity::ArchiveOldThreads",
|
"WebGUI::Workflow::Activity::CleanFileCache", "WebGUI::Workflow::Activity::CleanLoginHistory", "WebGUI::Workflow::Activity::ArchiveOldThreads",
|
||||||
"WebGUI::Workflow::Activity::TrashExpiredEvents", "WebGUI::Workflow::Activity::CreateCronJob"],
|
"WebGUI::Workflow::Activity::TrashExpiredEvents", "WebGUI::Workflow::Activity::CreateCronJob",
|
||||||
|
"WebGUI::Workflow::Activity::DeleteExpiredGroupings"],
|
||||||
"WebGUI::User"=>["WebGUI::Workflow::Activity::CreateCronJob"],
|
"WebGUI::User"=>["WebGUI::Workflow::Activity::CreateCronJob"],
|
||||||
"WebGUI::VersionTag"=>["WebGUI::Workflow::Activity::CommitVersionTag", "WebGUI::Workflow::Activity::RollbackVersionTag",
|
"WebGUI::VersionTag"=>["WebGUI::Workflow::Activity::CommitVersionTag", "WebGUI::Workflow::Activity::RollbackVersionTag",
|
||||||
"WebGUI::Workflow::Activity::TrashVersionTag", "WebGUI::Workflow::Activity::CreateCronJob"]
|
"WebGUI::Workflow::Activity::TrashVersionTag", "WebGUI::Workflow::Activity::CreateCronJob"]
|
||||||
|
|
@ -150,6 +151,8 @@ sub addWorkflow {
|
||||||
$activity = $workflow->addActivity("WebGUI::Workflow::Activity::TrashExpiredEvents", "pbwfactivity0000000006");
|
$activity = $workflow->addActivity("WebGUI::Workflow::Activity::TrashExpiredEvents", "pbwfactivity0000000006");
|
||||||
$activity->set("title", "Trash old Events Calendar Events");
|
$activity->set("title", "Trash old Events Calendar Events");
|
||||||
$activity->set("trashAfter", 60*60*24*30);
|
$activity->set("trashAfter", 60*60*24*30);
|
||||||
|
$activity = $workflow->addActivity("WebGUI::Workflow::Activity::DeleteExpiredGroupings", "pbwfactivity0000000007");
|
||||||
|
$activity->set("title", "Delete groupings that have expired");
|
||||||
WebGUI::Workflow::Cron->create($session, {
|
WebGUI::Workflow::Cron->create($session, {
|
||||||
title=>'Daily Maintenance',
|
title=>'Daily Maintenance',
|
||||||
enabled=>1,
|
enabled=>1,
|
||||||
|
|
|
||||||
87
lib/WebGUI/Workflow/Activity/DeleteExpiredGroupings.pm
Normal file
87
lib/WebGUI/Workflow/Activity/DeleteExpiredGroupings.pm
Normal file
|
|
@ -0,0 +1,87 @@
|
||||||
|
package WebGUI::Workflow::Activity::DeleteExpiredGroupings;
|
||||||
|
|
||||||
|
|
||||||
|
=head1 LEGAL
|
||||||
|
|
||||||
|
-------------------------------------------------------------------
|
||||||
|
WebGUI is Copyright 2001-2006 Plain Black Corporation.
|
||||||
|
-------------------------------------------------------------------
|
||||||
|
Please read the legal notices (docs/legal.txt) and the license
|
||||||
|
(docs/license.txt) that came with this distribution before using
|
||||||
|
this software.
|
||||||
|
-------------------------------------------------------------------
|
||||||
|
http://www.plainblack.com info@plainblack.com
|
||||||
|
-------------------------------------------------------------------
|
||||||
|
|
||||||
|
=cut
|
||||||
|
|
||||||
|
use strict;
|
||||||
|
use base 'WebGUI::Workflow::Activity';
|
||||||
|
use WebGUI::Cache::FileCache;
|
||||||
|
|
||||||
|
=head1 NAME
|
||||||
|
|
||||||
|
Package WebGUI::Workflow::Activity::DeleteExpiredGroupings;
|
||||||
|
|
||||||
|
=head1 DESCRIPTION
|
||||||
|
|
||||||
|
Deletes user groupings that are past their expire date.
|
||||||
|
|
||||||
|
=head1 SYNOPSIS
|
||||||
|
|
||||||
|
See WebGUI::Workflow::Activity for details on how to use any activity.
|
||||||
|
|
||||||
|
=head1 METHODS
|
||||||
|
|
||||||
|
These methods are available from this class:
|
||||||
|
|
||||||
|
=cut
|
||||||
|
|
||||||
|
|
||||||
|
#-------------------------------------------------------------------
|
||||||
|
|
||||||
|
=head2 definition ( session, definition )
|
||||||
|
|
||||||
|
See WebGUI::Workflow::Activity::defintion() for details.
|
||||||
|
|
||||||
|
=cut
|
||||||
|
|
||||||
|
sub definition {
|
||||||
|
my $class = shift;
|
||||||
|
my $session = shift;
|
||||||
|
my $definition = shift;
|
||||||
|
my $i18n = WebGUI::International->new($session, "Workflow_Activity_DeleteExpiredGroupings");
|
||||||
|
push(@{$definition}, {
|
||||||
|
name=>$i18n->get("topicName"),
|
||||||
|
properties=> {}
|
||||||
|
});
|
||||||
|
return $class->SUPER::definition($session,$definition);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
#-------------------------------------------------------------------
|
||||||
|
|
||||||
|
=head2 execute ( )
|
||||||
|
|
||||||
|
See WebGUI::Workflow::Activity::execute() for details.
|
||||||
|
|
||||||
|
=cut
|
||||||
|
|
||||||
|
sub execute {
|
||||||
|
my $self = shift;
|
||||||
|
my $sth = $self->session->db->read("select groupId,deleteOffset,dbCacheTimeout from groups");
|
||||||
|
while (my $data = $sth->hashRef) {
|
||||||
|
if ($data->{dbCacheTimeout} > 0) {
|
||||||
|
# there is no need to wait deleteOffset days for expired external group cache data
|
||||||
|
$self->session->db->write("delete from groupings where groupId=? and expireDate < ?", [$data->{groupId}, time()]);
|
||||||
|
} else {
|
||||||
|
$self->session->db->write("delete from groupings where groupId=? and expireDate < ?", [$data->{groupId}, time()-(86400*$data->{deleteOffset})]);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
1;
|
||||||
|
|
||||||
|
|
||||||
|
|
@ -0,0 +1,12 @@
|
||||||
|
package WebGUI::i18n::English::Workflow_Activity_DeleteExpiredGroupings;
|
||||||
|
|
||||||
|
our $I18N = {
|
||||||
|
'topicName' => {
|
||||||
|
message => q|Delete Expired Groupings|,
|
||||||
|
context => q|The name of this workflow activity.|,
|
||||||
|
lastUpdated => 0,
|
||||||
|
},
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
1;
|
||||||
|
|
@ -1,37 +0,0 @@
|
||||||
package Hourly::DeleteExpiredGroupings;
|
|
||||||
|
|
||||||
#-------------------------------------------------------------------
|
|
||||||
# WebGUI is Copyright 2001-2006 Plain Black Corporation.
|
|
||||||
#-------------------------------------------------------------------
|
|
||||||
# Please read the legal notices (docs/legal.txt) and the license
|
|
||||||
# (docs/license.txt) that came with this distribution before using
|
|
||||||
# this software.
|
|
||||||
#-------------------------------------------------------------------
|
|
||||||
# http://www.plainblack.com info@plainblack.com
|
|
||||||
#-------------------------------------------------------------------
|
|
||||||
|
|
||||||
use strict;
|
|
||||||
use WebGUI::DateTime;
|
|
||||||
use WebGUI::Session;
|
|
||||||
use WebGUI::SQL;
|
|
||||||
|
|
||||||
#-----------------------------------------
|
|
||||||
sub process {
|
|
||||||
my @date = WebGUI::DateTime::localtime();
|
|
||||||
if ($date[3] == 3) { # only occurs at 3am on the day in question.
|
|
||||||
my $sth = WebGUI::SQL->read("select groupId,deleteOffset,dbCacheTimeout from groups");
|
|
||||||
while (my $data = $sth->hashRef) {
|
|
||||||
if ($data->{dbCacheTimeout} > 0) {
|
|
||||||
# there is no need to wait deleteOffset days for expired external group cache data
|
|
||||||
WebGUI::SQL->write("delete from groupings where groupId=".quote($data->{groupId})." and expireDate < ".WebGUI::DateTime::time());
|
|
||||||
} else {
|
|
||||||
WebGUI::SQL->write("delete from groupings where groupId=".quote($data->{groupId})." and expireDate < "
|
|
||||||
.(WebGUI::DateTime::time()-(86400*$data->{deleteOffset})));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
$sth->finish;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
1;
|
|
||||||
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue