123 lines
3.5 KiB
Perl
123 lines
3.5 KiB
Perl
package WebGUI::Workflow::Activity::CleanupEMSSubmissions;
|
|
|
|
|
|
=head1 LEGAL
|
|
|
|
-------------------------------------------------------------------
|
|
WebGUI is Copyright 2001-2008 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::Asset;
|
|
use WebGUI::International;
|
|
|
|
=head1 NAME
|
|
|
|
Package WebGUI::Workflow::Activity::CleanupEMSSubmissions
|
|
|
|
=head1 DESCRIPTION
|
|
|
|
Uses the settings in the help desk to determine whether the resolved tickets should be closed or not.
|
|
|
|
=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, "Asset_EMSSubmissionForm" );
|
|
push(@{$definition}, {
|
|
name => $i18n->get("activity title cleanup submissions"),
|
|
properties => {}
|
|
});
|
|
return $class->SUPER::definition($session,$definition);
|
|
}
|
|
|
|
|
|
#-------------------------------------------------------------------
|
|
|
|
=head2 execute ( )
|
|
|
|
See WebGUI::Workflow::Activity::execute() for details.
|
|
|
|
=cut
|
|
|
|
sub execute {
|
|
my $self = shift;
|
|
my $session = $self->session;
|
|
my $root = WebGUI::Asset->getRoot($session);
|
|
|
|
# keep track of how much time it's taking
|
|
my $start = time;
|
|
my $limit = 2_500;
|
|
my $timeLimit = $self->getTTL;
|
|
|
|
my $emsFormIter = $root->getLineageIterator( ['descendants'], {
|
|
includeOnlyClasses => ['WebGUI::Asset::EMSSubmissionForm'],
|
|
} );
|
|
|
|
while ( 1 ) {
|
|
my $emsForm;
|
|
eval { $emsForm = $emsFormIter->() };
|
|
if ( my $x = WebGUI::Error->caught('WebGUI::Error::ObjectNotFound') ) {
|
|
$session->log->error($x->full_message);
|
|
next;
|
|
}
|
|
last unless $emsForm;
|
|
my $daysBeforeCleanup = $emsForm->get('daysBeforeCleanup') ;
|
|
next if ! $daysBeforeCleanup;
|
|
my $whereClause = q{ submissionStatus='denied' };
|
|
if( $emsForm->get('deleteCreatedItems') ) {
|
|
$whereClause = ' ( ' . $whereClause . q{ or submissionStatus='created' } . ' ) ';
|
|
}
|
|
my $checkDate = time - ( 60*60*24* $daysBeforeCleanup );
|
|
$whereClause .= q{ and assetData.lastModified < } . $checkDate;
|
|
my $submissionIter = $emsForm->getLineageIterator(['children'],{
|
|
joinClass => 'WebGUI::Asset::EMSSubmission',
|
|
includeOnlyClasses => ['WebGUI::Asset::EMSSubmission'],
|
|
whereClause => $whereClause,
|
|
} );
|
|
while ( 1 ) {
|
|
my $submission;
|
|
eval { $submission = $submissionIter->() };
|
|
if ( my $x = WebGUI::Error->caught('WebGUI::Error::ObjectNotFound') ) {
|
|
$session->log->error($x->full_message);
|
|
next;
|
|
}
|
|
last unless $submission;
|
|
$submission->purge;
|
|
$limit--;
|
|
return $self->WAITING(1) if ! $limit or time > $start + $timeLimit;
|
|
}
|
|
}
|
|
return $self->COMPLETE;
|
|
}
|
|
|
|
1;
|
|
|