1 package Koha::BackgroundJob::BatchUpdateBiblioHoldsQueue;
3 # This file is part of Koha.
5 # Koha is free software; you can redistribute it and/or modify it
6 # under the terms of the GNU General Public License as published by
7 # the Free Software Foundation; either version 3 of the License, or
8 # (at your option) any later version.
10 # Koha is distributed in the hope that it will be useful, but
11 # WITHOUT ANY WARRANTY; without even the implied warranty of
12 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 # GNU General Public License for more details.
15 # You should have received a copy of the GNU General Public License
16 # along with Koha; if not, see <http://www.gnu.org/licenses>.
26 qw(load_branches_to_pull_from TransportCostMatrix update_queue_for_biblio);
28 use base 'Koha::BackgroundJob';
32 Koha::BackgroundJob::BatchUpdateBiblioHoldsQueue - Update the holds queue
33 for a specified list of biblios.
35 This is a subclass of Koha::BackgroundJob.
43 Returns a string representing the job type. In this case I<update_holds_queue_for_biblios>.
48 return 'update_holds_queue_for_biblios';
53 Perform the expected action.
58 my ( $self, $args ) = @_;
60 my $schema = Koha::Database->new->schema;
64 started_on => \'NOW()',
70 my @biblio_ids = @{ $args->{biblio_ids} };
73 total_biblios => scalar @biblio_ids,
77 my $use_transport_cost_matrix = C4::Context->preference("UseTransportCostMatrix");
78 my $transport_cost_matrix = $use_transport_cost_matrix ? TransportCostMatrix() : undef;
79 my $branches_to_use = load_branches_to_pull_from($use_transport_cost_matrix);
83 foreach my $biblio_id (@biblio_ids) {
86 $schema->storage->txn_begin;
88 my $result = update_queue_for_biblio(
90 biblio_id => $biblio_id,
91 branches_to_use => $branches_to_use,
93 transport_cost_matrix => $transport_cost_matrix
99 code => 'holds_queue_updated',
100 biblio_id => $biblio_id,
102 $report->{total_success}++;
104 $schema->storage->txn_commit;
111 code => 'holds_queue_update_error',
112 biblio_id => $biblio_id,
116 $schema->storage->txn_rollback;
119 $self->progress( $self->progress + 1 )->store;
122 my $json = $self->json;
123 my $job_data = $json->decode($self->data);
124 $job_data->{messages} = \@messages;
125 $job_data->{report} = $report;
129 ended_on => \'NOW()',
130 data => $json->encode($job_data),
131 status => 'finished',
143 my ( $self, $args ) = @_;
145 Koha::Exceptions::MissingParameter->throw(
146 "Missing biblio_ids parameter is mandatory")
147 unless exists $args->{biblio_ids};
149 my @biblio_ids = @{ $args->{biblio_ids} };
151 $self->SUPER::enqueue(
153 job_size => scalar @biblio_ids,
154 job_args => { biblio_ids => \@biblio_ids }
159 =head3 additional_report
161 Pass the biblio's title and patron's name
165 sub additional_report {
166 my ( $self, $args ) = @_;
168 my $messages = $self->messages;
169 for my $m (@$messages) {
170 $m->{biblio} = Koha::Biblios->find( $m->{biblio_id} );
172 return { report_messages => $messages };