X-Git-Url: http://wagnertech.de/git?a=blobdiff_plain;f=SL%2FController%2FBackgroundJob.pm;h=7e16a1772a2753168d70cab732c308042e9fe04e;hb=e83fcf3aa3394efdf2293ea60d5510fcfbf41b52;hp=57ec5c377bac1876bdcbbddacd12665037ca430b;hpb=5f49de40a2c8c6eca92bb3fd88c1ee0126264bd1;p=kivitendo-erp.git diff --git a/SL/Controller/BackgroundJob.pm b/SL/Controller/BackgroundJob.pm index 57ec5c377..7e16a1772 100644 --- a/SL/Controller/BackgroundJob.pm +++ b/SL/Controller/BackgroundJob.pm @@ -4,19 +4,20 @@ use strict; use parent qw(SL::Controller::Base); +use SL::BackgroundJob::Base; +use SL::Controller::Helper::GetModels; use SL::DB::BackgroundJob; use SL::Helper::Flash; +use SL::Locale::String; use SL::System::TaskServer; use Rose::Object::MakeMethods::Generic ( - scalar => [ qw(background_job) ], - 'scalar --get_set_init' => [ qw(task_server) ], + 'scalar --get_set_init' => [ qw(task_server back_to models background_job) ], ); __PACKAGE__->run_before('check_auth'); __PACKAGE__->run_before('check_task_server'); -__PACKAGE__->run_before('load_background_job', only => [ qw(edit update destroy execute) ]); # # actions @@ -25,21 +26,48 @@ __PACKAGE__->run_before('load_background_job', only => [ qw(edit update destroy sub action_list { my ($self) = @_; + $self->setup_list_action_bar; $self->render('background_job/list', title => $::locale->text('Background jobs'), - BACKGROUND_JOBS => SL::DB::Manager::BackgroundJob->get_all_sorted); + BACKGROUND_JOBS => $self->models->get, + MODELS => $self->models); } sub action_new { my ($self) = @_; - $self->background_job(SL::DB::BackgroundJob->new(cron_spec => '* * * * *')); - $self->render('background_job/form', title => $::locale->text('Create a new background job')); + $self->background_job(SL::DB::BackgroundJob->new(cron_spec => '* * * * *', package_name => 'Test')) unless $self->background_job; + $self->setup_form_action_bar; + $self->render('background_job/form', + title => $::locale->text('Create a new background job'), + JOB_CLASSES => [ SL::BackgroundJob::Base->get_known_job_classes ]); } sub action_edit { my ($self) = @_; - $self->render('background_job/form', title => $::locale->text('Edit background job')); + + $self->setup_form_action_bar; + $self->render('background_job/form', + title => $::locale->text('Edit background job'), + JOB_CLASSES => [ SL::BackgroundJob::Base->get_known_job_classes ]); +} + +sub action_edit_as_new { + my ($self) = @_; + + delete $::form->{background_job}->{id}; + $self->background_job(SL::DB::BackgroundJob->new(%{ $::form->{background_job} })); + $self->action_new; +} + +sub action_show { + my ($self) = @_; + + if ($::request->type eq 'json') { + $self->render(\ SL::JSON::to_json($self->background_job->as_tree), { type => 'json' }); + } else { + $self->action_edit; + } } sub action_create { @@ -63,12 +91,13 @@ sub action_destroy { flash_later('error', $::locale->text('The background job could not be destroyed.')); } - $self->redirect_to(action => 'list'); + $self->redirect_to($self->back_to); } sub action_save_and_execute { my ($self) = @_; + $self->background_job(SL::DB::BackgroundJob->new) if !$self->background_job; return unless $self->create_or_update; $self->action_execute; } @@ -123,12 +152,11 @@ sub create_or_update { flash_later('info', $is_new ? $::locale->text('The background job has been created.') : $::locale->text('The background job has been saved.')); return if $return; - $self->redirect_to(action => 'list'); + $self->redirect_to($self->back_to); } -sub load_background_job { - my ($self) = @_; - $self->background_job(SL::DB::BackgroundJob->new(id => $::form->{id})->load); +sub init_background_job { + return $::form->{id} ? SL::DB::BackgroundJob->new(id => $::form->{id})->load : undef; } sub init_task_server { @@ -140,4 +168,94 @@ sub check_task_server { flash('warning', $::locale->text('The task server does not appear to be running.')) if !$self->task_server->is_running; } +sub init_back_to { + my ($self) = @_; + return $::form->{back_to} || $self->url_for(action => 'list'); +} + +sub init_models { + SL::Controller::Helper::GetModels->new( + controller => $_[0], + filtered => 0, + sorted => { + package_name => t8('Package name'), + type => t8('Execution type'), + active => t8('Active'), + cron_spec => t8('Execution schedule'), + last_run_at => t8('Last run at'), + next_run_at => t8('Next run at'), + }, + query => [ + package_name => [ SL::BackgroundJob::Base->get_known_job_classes ], + ], + ); +} + +sub setup_list_action_bar { + my ($self) = @_; + + for my $bar ($::request->layout->get('actionbar')) { + $bar->add( + link => [ + t8('Add'), + link => $self->url_for(action => 'new'), + accesskey => 'enter', + ], + link => [ + t8('Server control'), + link => $self->url_for(controller => 'TaskServer', action => 'show'), + ], + link => [ + t8('Job history'), + link => $self->url_for(controller => 'BackgroundJobHistory', action => 'list'), + ], + ); + } +} + +sub setup_form_action_bar { + my ($self) = @_; + + my $is_new = !$self->background_job->id; + + for my $bar ($::request->layout->get('actionbar')) { + $bar->add( + combobox => [ + action => [ + t8('Save'), + submit => [ '#form', { action => 'BackgroundJob/' . ($is_new ? 'create' : 'update') } ], + accesskey => 'enter', + ], + action => [ + t8('Save and execute'), + submit => [ '#form', { action => 'BackgroundJob/save_and_execute' } ], + ], + action => [ + t8('Use as new'), + submit => [ '#form', { action => 'BackgroundJob/edit_as_new' } ], + disabled => $is_new ? t8('The object has not been saved yet.') : undef, + ], + ], # end of combobox "Save" + + action => [ + t8('Delete'), + submit => [ '#form', { action => 'BackgroundJob/destroy' } ], + confirm => t8('Do you really want to delete this object?'), + disabled => $is_new ? t8('This object has not been saved yet.') : undef, + ], + + link => [ + t8('Abort'), + link => $self->url_for(action => 'list'), + ], + + link => [ + t8('Job history'), + link => $self->url_for(controller => 'BackgroundJobHistory', action => 'list', 'filter.package_name:substr::ilike' => $self->background_job->package_name), + disabled => $is_new ? t8('This object has not been saved yet.') : undef, + ], + ); + } +} + 1;