Lines 20-26
use JSON qw( decode_json encode_json );
Link Here
|
20 |
use Try::Tiny; |
20 |
use Try::Tiny; |
21 |
|
21 |
|
22 |
use Koha::Biblios; |
22 |
use Koha::Biblios; |
23 |
use Koha::DateUtils qw( dt_from_string ); |
|
|
24 |
use Koha::ERM::EHoldings::Titles; |
23 |
use Koha::ERM::EHoldings::Titles; |
25 |
use Koha::ERM::EHoldings::Resources; |
24 |
use Koha::ERM::EHoldings::Resources; |
26 |
|
25 |
|
Lines 61-71
sub process {
Link Here
|
61 |
return; |
60 |
return; |
62 |
} |
61 |
} |
63 |
|
62 |
|
64 |
my $job_progress = 0; |
63 |
$self->start; |
65 |
$self->started_on(dt_from_string) |
|
|
66 |
->progress($job_progress) |
67 |
->status('started') |
68 |
->store; |
69 |
|
64 |
|
70 |
my @messages; |
65 |
my @messages; |
71 |
my @record_ids = @{ $args->{record_ids} }; |
66 |
my @record_ids = @{ $args->{record_ids} }; |
Lines 181-197
sub process {
Link Here
|
181 |
error => $_, |
176 |
error => $_, |
182 |
}; |
177 |
}; |
183 |
}; |
178 |
}; |
184 |
$self->progress( ++$job_progress )->store; |
179 |
$self->step; |
185 |
} |
180 |
} |
186 |
|
181 |
|
187 |
my $job_data = decode_json $self->data; |
|
|
188 |
$job_data->{messages} = \@messages; |
189 |
$job_data->{report} = $report; |
190 |
|
182 |
|
191 |
$self->ended_on(dt_from_string) |
183 |
my $data = $self->decoded_data; |
192 |
->data(encode_json $job_data); |
184 |
$data->{messages} = \@messages; |
193 |
$self->status('finished') if $self->status ne 'cancelled'; |
185 |
$data->{report} = $report; |
194 |
$self->store; |
186 |
|
|
|
187 |
$self->finish( $data ); |
195 |
} |
188 |
} |
196 |
|
189 |
|
197 |
=head3 enqueue |
190 |
=head3 enqueue |
198 |
- |
|
|