X-Git-Url: http://wagnertech.de/git?a=blobdiff_plain;f=SL%2FDB%2FBackgroundJob.pm;h=1fc8d992da858ee2d337e3b721015a44b85c97dd;hb=feb6f563968f53e59511578429b1dd61fda52008;hp=f5c4b21f68d2d4b3b67c071c91856b3b2d89b978;hpb=7c60c2423f6fd27a78cf89ca62821ea1e41e85f5;p=kivitendo-erp.git diff --git a/SL/DB/BackgroundJob.pm b/SL/DB/BackgroundJob.pm index f5c4b21f6..1fc8d992d 100644 --- a/SL/DB/BackgroundJob.pm +++ b/SL/DB/BackgroundJob.pm @@ -5,10 +5,15 @@ use strict; use DateTime::Event::Cron; use English qw(-no_match_vars); +use Rose::DB::Object::Helpers qw(as_tree); + use SL::DB::MetaSetup::BackgroundJob; use SL::DB::Manager::BackgroundJob; use SL::System::Process; +use SL::YAML; + +__PACKAGE__->meta->initialize; __PACKAGE__->before_save('_before_save_set_next_run_at'); @@ -43,7 +48,7 @@ sub run { $history = SL::DB::BackgroundJobHistory ->new(package_name => $self->package_name, run_at => $run_at, - status => 'success', + status => SL::DB::BackgroundJobHistory::SUCCESS(), result => $result, data => $self->data); $history->save; @@ -56,7 +61,7 @@ sub run { $history = SL::DB::BackgroundJobHistory ->new(package_name => $self->package_name, run_at => $run_at, - status => 'failure', + status => SL::DB::BackgroundJobHistory::FAILURE(), error_col => $error, data => $self->data); $history->save; @@ -71,18 +76,22 @@ sub run { sub data_as_hash { my $self = shift; + + $self->data(SL::YAML::Dump($_[0])) if @_; + return {} if !$self->data; return $self->data if ref($self->{data}) eq 'HASH'; - return YAML::Load($self->{data}) if !ref($self->{data}); + return SL::YAML::Load($self->{data}) if !ref($self->{data}); return {}; } sub set_data { my ($self, %data) = @_; - my $data = YAML::Load($self->data); - $data->{$_} = $data{$_} for keys %data; - $self->data(YAML::Dump($data)); + $self->data(SL::YAML::Dump({ + %{ $self->data_as_hash }, + %data, + })); $self; }