X-Git-Url: http://wagnertech.de/git?a=blobdiff_plain;f=SL%2FDB%2FBackgroundJob.pm;h=c83868502a7022d955f330376c293dfb95fc05d9;hb=4f15333b8cc0ae1b0b4089adc2e516ba002b298b;hp=743a6b5eac5dd55f4f9724abbeecd03d5be0845e;hpb=89c9ff022d3f13e27ba6bda085df15707fcfb0eb;p=kivitendo-erp.git diff --git a/SL/DB/BackgroundJob.pm b/SL/DB/BackgroundJob.pm index 743a6b5ea..c83868502 100644 --- a/SL/DB/BackgroundJob.pm +++ b/SL/DB/BackgroundJob.pm @@ -5,12 +5,21 @@ use strict; use DateTime::Event::Cron; use English qw(-no_match_vars); -use SL::DB::MetaSetup::BackgroundJob; -use SL::DB::Manager::BackgroundJob; +require SL::DB::MetaSetup::BackgroundJob; +require SL::DB::Manager::BackgroundJob; -use SL::DB::BackgroundJobHistory; +require SL::DB::BackgroundJobHistory; -use SL::BackgroundJob::Test; +use SL::System::Process; + +__PACKAGE__->before_save('_before_save_set_next_run_at'); + +sub _before_save_set_next_run_at { + my ($self) = @_; + + $self->update_next_run_at if !$self->next_run_at; + return 1; +} sub update_next_run_at { my $self = shift; @@ -28,6 +37,7 @@ sub run { my $history; my $ok = eval { + eval "require $package" or die $@; my $result = $package->new->run($self); $history = SL::DB::BackgroundJobHistory @@ -67,4 +77,34 @@ sub data_as_hash { return {}; } +sub set_data { + my ($self, %data) = @_; + + my $data = YAML::Load($self->data); + $data->{$_} = $data{$_} for keys %data; + $self->data(YAML::Dump($data)); + + $self; +} + +sub validate { + my ($self) = @_; + + my @errors; + + push @errors, $::locale->text('The execution type is invalid.') if ($self->type || '') !~ m/^(?: once | interval )$/x; + + if ( (($self->package_name || '') !~ m/^ [A-Z][A-Za-z0-9]+ $/x) + || ! -f (SL::System::Process::exe_dir() . "/SL/BackgroundJob/" . $self->package_name . ".pm")) { + push @errors, $::locale->text('The package name is invalid.'); + } + + eval { + DateTime::Event::Cron->new_from_cron($self->cron_spec || '* * * * *')->next(DateTime->now_local); + 1; + } or push @errors, $::locale->text('The execution schedule is invalid.'); + + return @errors; +} + 1;