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>.
20 use JSON qw( encode_json decode_json );
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;
66 started_on => \'NOW()',
67 progress => $job_progress,
72 my @biblio_ids = @{ $args->{biblio_id} };
75 total_biblios => scalar @biblio_ids,
79 my $use_transport_cost_matrix = C4::Context->preference("UseTransportCostMatrix");
80 my $transport_cost_matrix = $use_transport_cost_matrix ? TransportCostMatrix() : undef;
81 my $branches_to_use = load_branches_to_pull_from($use_transport_cost_matrix);
85 foreach my $biblio_id (@biblio_ids) {
88 $schema->storage->txn_begin;
90 my $result = update_queue_for_biblio(
92 biblio_id => $biblio_id,
93 branches_to_use => $branches_to_use,
95 transport_cost_matrix => $transport_cost_matrix
101 code => 'holds_queue_updated',
102 biblio_id => $biblio_id,
103 availabe_items => $result->{available_items},
104 mapped_items => $result->{mapped_items},
105 requests => $result->{requests},
107 $report->{total_success}++;
109 $schema->storage->txn_commit;
114 code => 'holds_queue_update_error',
115 biblio_id => $biblio_id,
119 $schema->storage->txn_rollback;
122 $self->progress( $job_progress++ )->store;
125 my $job_data = decode_json $self->data;
126 $job_data->{messages} = \@messages;
127 $job_data->{report} = $report;
131 ended_on => \'NOW()',
132 data => encode_json $job_data,
135 $self->status('finished')
136 unless $self->status ne 'cancelled';
148 my ( $self, $args ) = @_;
150 Koha::Exceptions::MissingParameter->throw(
151 "Missing biblio_ids parameter is mandatory")
152 unless exists $args->{biblio_ids};
154 my @biblio_ids = @{ $args->{biblio_ids} };
156 $self->SUPER::enqueue(
158 job_size => scalar @biblio_ids,
159 job_args => { biblio_ids => \@biblio_ids }
164 =head3 additional_report
166 Pass the biblio's title and patron's name
170 sub additional_report {
171 my ( $self, $args ) = @_;
173 my $messages = $self->messages;
174 for my $m (@$messages) {
175 $m->{biblio} = Koha::Biblios->find( $m->{biblio_id} );
177 return { report_messages => $messages };