|
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 |
- |
|
|