From 772a97b2efcbd7d0d55fb5b0465afc14114c2202 Mon Sep 17 00:00:00 2001 From: Jonathan Druart Date: Mon, 25 Feb 2019 21:43:45 -0300 Subject: [PATCH] Bug 22417: Add Koha::BackgroundJob::BatchUpdateBiblio Signed-off-by: Tomas Cohen Arazi Signed-off-by: David Cook --- Koha/BackgroundJob/BatchUpdateBiblio.pm | 97 +++++++++++++++++++++++++++++++++ 1 file changed, 97 insertions(+) create mode 100644 Koha/BackgroundJob/BatchUpdateBiblio.pm diff --git a/Koha/BackgroundJob/BatchUpdateBiblio.pm b/Koha/BackgroundJob/BatchUpdateBiblio.pm new file mode 100644 index 0000000000..4e205bd187 --- /dev/null +++ b/Koha/BackgroundJob/BatchUpdateBiblio.pm @@ -0,0 +1,97 @@ +package Koha::BackgroundJob::BatchUpdateBiblio; + +use Modern::Perl; +use Koha::BackgroundJobs; +use Koha::DateUtils qw( dt_from_string ); +use JSON qw( encode_json decode_json ); +use Net::RabbitFoot; + +use base 'Koha::BackgroundJob'; + +our $channel; +sub process { + my ( $self, $args, $channel ) = @_; + + my $job_type = $args->{job_type}; + + return unless exists $args->{job_id}; + + my $job = Koha::BackgroundJobs->find( $args->{job_id} ); + + my $job_progress = 0; + $job->started_on(dt_from_string) + ->progress($job_progress) + ->status('started') + ->store; + + my $mmtid = $args->{mmtid}; + my $record_type = $args->{record_type}; + my @record_ids = @{ $args->{record_ids} }; + + my $report = { + total_records => 0, + total_success => 0, + }; + my @messages; + my $dbh = C4::Context->dbh; + $dbh->{RaiseError} = 1; + RECORD_IDS: for my $biblionumber ( sort { $a <=> $b } @record_ids ) { + $report->{total_records}++; + next unless $biblionumber; + + # Modify the biblio + my $error = eval { + my $record = C4::Biblio::GetMarcBiblio({ biblionumber => $biblionumber }); + C4::MarcModificationTemplates::ModifyRecordWithTemplate( $mmtid, $record ); + my $frameworkcode = C4::Biblio::GetFrameworkCode( $biblionumber ); + C4::Biblio::ModBiblio( $record, $biblionumber, $frameworkcode ); + }; + if ( $error and $error != 1 or $@ ) { # ModBiblio returns 1 if everything as gone well + push @messages, { + type => 'error', + code => 'biblio_not_modified', + biblionumber => $biblionumber, + error => ($@ ? $@ : $error), + }; + } else { + push @messages, { + type => 'success', + code => 'biblio_modified', + biblionumber => $biblionumber, + }; + $report->{total_success}++; + } + $job->progress( ++$job_progress )->store; + } + + my $job_data = decode_json $job->data; + $job_data->{messages} = \@messages; + $job_data->{report} = $report; + + $job->ended_on(dt_from_string) + ->status('finished') + ->data(encode_json $job_data) + ->store; + $channel->ack(); # FIXME Is that ok even on failure? +} + +sub enqueue { + my ( $self, $args) = @_; + + # TODO Raise exception instead + return unless exists $args->{mmtid}; + return unless exists $args->{record_type}; #FIXME RMME + return unless exists $args->{record_ids}; + + my $mmtid = $args->{mmtid}; + my $record_type = $args->{record_type}; + my @record_ids = @{ $args->{record_ids} }; + + $self->SUPER::enqueue({ + job_type => 'batch_biblio_record_modification', # FIXME Must be a global const + job_size => scalar @record_ids, + job_args => {mmtid => $mmtid, record_type => $record_type, record_ids => \@record_ids,} + }); +} + +1; -- 2.11.0