|
Lines 81-88
sub process {
Link Here
|
| 81 |
|
81 |
|
| 82 |
$self->start; |
82 |
$self->start; |
| 83 |
|
83 |
|
| 84 |
my @record_ids = @{ $args->{record_ids} }; |
84 |
my @record_ids = @{ $args->{record_ids} }; |
| 85 |
my $delete_biblios = $args->{delete_biblios}; |
85 |
my $delete_biblios = $args->{delete_biblios}; |
|
|
86 |
my $delete_serial_issues = $args->{delete_serial_issues}; |
| 86 |
|
87 |
|
| 87 |
my $report = { |
88 |
my $report = { |
| 88 |
total_records => scalar @record_ids, |
89 |
total_records => scalar @record_ids, |
|
Lines 106-112
sub process {
Link Here
|
| 106 |
|
107 |
|
| 107 |
my $item = Koha::Items->find($record_id) || next; |
108 |
my $item = Koha::Items->find($record_id) || next; |
| 108 |
|
109 |
|
| 109 |
my $return = $item->safe_delete( { skip_record_index => 1, skip_holds_queue => 1 } ); |
110 |
my $return = $item->safe_delete( |
|
|
111 |
{ |
| 112 |
skip_record_index => 1, skip_holds_queue => 1, |
| 113 |
delete_serial_issues => $delete_serial_issues |
| 114 |
} |
| 115 |
); |
| 110 |
unless ($return) { |
116 |
unless ($return) { |
| 111 |
|
117 |
|
| 112 |
# FIXME Do we need to rollback the whole transaction if a deletion failed? |
118 |
# FIXME Do we need to rollback the whole transaction if a deletion failed? |
|
Lines 221-235
sub enqueue {
Link Here
|
| 221 |
# TODO Raise exception instead |
227 |
# TODO Raise exception instead |
| 222 |
return unless exists $args->{record_ids}; |
228 |
return unless exists $args->{record_ids}; |
| 223 |
|
229 |
|
| 224 |
my @record_ids = @{ $args->{record_ids} }; |
230 |
my @record_ids = @{ $args->{record_ids} }; |
| 225 |
my $delete_biblios = $args->{delete_biblios} || 0; |
231 |
my $delete_biblios = $args->{delete_biblios} || 0; |
|
|
232 |
my $delete_serial_issues = $args->{delete_serial_issues} || 0; |
| 226 |
|
233 |
|
| 227 |
$self->SUPER::enqueue( |
234 |
$self->SUPER::enqueue( |
| 228 |
{ |
235 |
{ |
| 229 |
job_size => scalar @record_ids, |
236 |
job_size => scalar @record_ids, |
| 230 |
job_args => { |
237 |
job_args => { |
| 231 |
record_ids => \@record_ids, |
238 |
record_ids => \@record_ids, |
| 232 |
delete_biblios => $delete_biblios, |
239 |
delete_biblios => $delete_biblios, |
|
|
240 |
delete_serial_issues => $delete_serial_issues, |
| 233 |
}, |
241 |
}, |
| 234 |
job_queue => 'long_tasks', |
242 |
job_queue => 'long_tasks', |
| 235 |
} |
243 |
} |