Attachment 124410 Details for Bug 26080 – Bug 26080: Use the task queue for batch delete authorities

[patch] Bug 26080: Use the task queue for batch delete authorities

Bug-26080-Use-the-task-queue-for-batch-delete-auth.patch (text/plain), 10.73 KB, created by Tomás Cohen Arazi (tcohen) on 2021-09-01 16:25:51 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Tomás Cohen Arazi (tcohen)

Created: 2021-09-01 16:25:51 UTC

Size: 10.73 KB

patch

obsolete

>From 16ca7dcfcc27f8768b6ec13acd73249179b06a46 Mon Sep 17 00:00:00 2001
>From: Jonathan Druart <jonathan.druart@bugs.koha-community.org>
>Date: Wed, 29 Jul 2020 12:13:39 +0200
>Subject: [PATCH] Bug 26080: Use the task queue for batch delete authorities
>
>Same as the first patch, for authorities
>
>Test plan:
>Delete authority records using the batch record deletion tool
>Confirm that the job is now delegated to the task queue and that
>everything else is working as before
>
>Signed-off-by: Fridolin Somers <fridolin.somers@biblibre.com>
>Signed-off-by: Tomas Cohen Arazi <tomascohen@theke.io>
>---
> Koha/BackgroundJob.pm                         |   3 +
> Koha/BackgroundJob/BatchDeleteAuthority.pm    | 101 ++++++++++++++++++
> .../batch_authority_record_deletion.inc       |  42 ++++++++
> .../prog/en/modules/admin/background_jobs.tt  |   1 +
> .../en/modules/tools/batch_delete_records.tt  |  18 +---
> misc/background_jobs_worker.pl                |   1 +
> tools/batch_delete_records.pl                 |   1 +
> 7 files changed, 154 insertions(+), 13 deletions(-)
> create mode 100644 Koha/BackgroundJob/BatchDeleteAuthority.pm
> create mode 100644 koha-tmpl/intranet-tmpl/prog/en/includes/background_jobs/batch_authority_record_deletion.inc
>
>diff --git a/Koha/BackgroundJob.pm b/Koha/BackgroundJob.pm
>index d72263d0b6..1498f51de6 100644
>--- a/Koha/BackgroundJob.pm
>+++ b/Koha/BackgroundJob.pm
>@@ -27,6 +27,7 @@ use Koha::Exceptions;
> use Koha::BackgroundJob::BatchUpdateBiblio;
> use Koha::BackgroundJob::BatchUpdateAuthority;
> use Koha::BackgroundJob::BatchDeleteBiblio;
>+use Koha::BackgroundJob::BatchDeleteAuthority;
> 
> use base qw( Koha::Object );
> 
>@@ -158,6 +159,8 @@ sub process {
>       ? Koha::BackgroundJob::BatchUpdateAuthority->process($args)
>       : $job_type eq 'batch_biblio_record_deletion'
>       ? Koha::BackgroundJob::BatchDeleteBiblio->process($args)
>+      : $job_type eq 'batch_authority_record_deletion'
>+      ? Koha::BackgroundJob::BatchDeleteAuthority->process($args)
>       : Koha::Exceptions::Exception->throw('->process called without valid job_type');
> }
> 
>diff --git a/Koha/BackgroundJob/BatchDeleteAuthority.pm b/Koha/BackgroundJob/BatchDeleteAuthority.pm
>new file mode 100644
>index 0000000000..18a3202a6e
>--- /dev/null
>+++ b/Koha/BackgroundJob/BatchDeleteAuthority.pm
>@@ -0,0 +1,101 @@
>+package Koha::BackgroundJob::BatchDeleteAuthority;
>+
>+use Modern::Perl;
>+use JSON qw( encode_json decode_json );
>+
>+use Koha::BackgroundJobs;
>+use Koha::DateUtils qw( dt_from_string );
>+use C4::AuthoritiesMarc;
>+
>+use base 'Koha::BackgroundJob';
>+
>+sub job_type {
>+    return 'batch_authority_record_deletion';
>+}
>+
>+sub process {
>+    my ( $self, $args ) = @_;
>+
>+    my $job_type = $args->{job_type};
>+
>+    my $job = Koha::BackgroundJobs->find( $args->{job_id} );
>+
>+    if ( !exists $args->{job_id} || !$job || $job->status eq 'cancelled' ) {
>+        return;
>+    }
>+
>+    # FIXME If the job has already been started, but started again (worker has been restart for instance)
>+    # Then we will start from scratch and so double delete the same records
>+
>+    my $job_progress = 0;
>+    $job->started_on(dt_from_string)
>+        ->progress($job_progress)
>+        ->status('started')
>+        ->store;
>+
>+    my $mmtid = $args->{mmtid};
>+    my @record_ids = @{ $args->{record_ids} };
>+
>+    my $report = {
>+        total_records => scalar @record_ids,
>+        total_success => 0,
>+    };
>+    my @messages;
>+    my $schema = Koha::Database->new->schema;
>+    RECORD_IDS: for my $record_id ( sort { $a <=> $b } @record_ids ) {
>+
>+        last if $job->get_from_storage->status eq 'cancelled';
>+
>+        next unless $record_id;
>+
>+        $schema->storage->txn_begin;
>+
>+        my $authid = $record_id;
>+        eval { C4::AuthoritiesMarc::DelAuthority({ authid => $authid }) };
>+        if ( $@ ) {
>+            push @messages, {
>+                type => 'error',
>+                code => 'authority_not_deleted',
>+                authid => $authid,
>+                error => ($@ ? $@ : 0),
>+            };
>+            $schema->storage->txn_rollback;
>+            next;
>+        } else {
>+            push @messages, {
>+                type => 'success',
>+                code => 'authority_deleted',
>+                authid => $authid,
>+            };
>+            $report->{total_success}++;
>+            $schema->storage->txn_commit;
>+        }
>+
>+        $job->progress( ++$job_progress )->store;
>+    }
>+
>+    my $job_data = decode_json $job->data;
>+    $job_data->{messages} = \@messages;
>+    $job_data->{report} = $report;
>+
>+    $job->ended_on(dt_from_string)
>+        ->data(encode_json $job_data);
>+    $job->status('finished') if $job->status ne 'cancelled';
>+    $job->store;
>+}
>+
>+sub enqueue {
>+    my ( $self, $args) = @_;
>+
>+    # TODO Raise exception instead
>+    return unless exists $args->{record_ids};
>+
>+    my @record_ids = @{ $args->{record_ids} };
>+
>+    $self->SUPER::enqueue({
>+        job_size => scalar @record_ids,
>+        job_args => {record_ids => \@record_ids,}
>+    });
>+}
>+
>+1;
>diff --git a/koha-tmpl/intranet-tmpl/prog/en/includes/background_jobs/batch_authority_record_deletion.inc b/koha-tmpl/intranet-tmpl/prog/en/includes/background_jobs/batch_authority_record_deletion.inc
>new file mode 100644
>index 0000000000..f9e24aff39
>--- /dev/null
>+++ b/koha-tmpl/intranet-tmpl/prog/en/includes/background_jobs/batch_authority_record_deletion.inc
>@@ -0,0 +1,42 @@
>+[% BLOCK report %]
>+    [% SET report = job.report %]
>+    [% IF report %]
>+        [% IF report.total_records == report.total_success %]
>+            <div class="dialog message">
>+                All records have been deleted successfully!
>+            </div>
>+        [% ELSIF report.total_success == 0 %]
>+            <div class="dialog message">
>+                No record has been deleted. An error occurred.
>+            </div>
>+        [% ELSE %]
>+            <div class="dialog message">
>+                [% report.total_success | html %] / [% report.total_records | html %] records have been deleted successfully but some errors occurred.
>+            </div>
>+        [% END %]
>+    [% END %]
>+[% END %]
>+
>+[% BLOCK detail %]
>+    [% FOR m IN job.messages %]
>+        <div class="dialog message">
>+            [% IF m.type == 'success' %]
>+                <i class="fa fa-check success"></i>
>+            [% ELSIF m.type == 'warning' %]
>+                <i class="fa fa-warning warn"></i>
>+            [% ELSIF m.type == 'error' %]
>+                <i class="fa fa-exclamation error"></i>
>+            [% END %]
>+            [% IF m.code == 'authority_not_exists' %]
>+                The authority id [% m.authid | html %] does not exist in the database.
>+            [% ELSIF m.code == 'authority_not_deleted' %]
>+                Authority record [% m.authid | html %] was not deleted. An error occurred.
>+            [% ELSIF m.code == 'authority_deleted' %]
>+                Authority [% m.authid | html %] has been deleted successfully.
>+            [% END %]
>+        </div>
>+    [% END %]
>+[% END %]
>+
>+[% BLOCK js %]
>+[% END %]
>diff --git a/koha-tmpl/intranet-tmpl/prog/en/modules/admin/background_jobs.tt b/koha-tmpl/intranet-tmpl/prog/en/modules/admin/background_jobs.tt
>index 50cd37d740..ba12fc31c0 100644
>--- a/koha-tmpl/intranet-tmpl/prog/en/modules/admin/background_jobs.tt
>+++ b/koha-tmpl/intranet-tmpl/prog/en/modules/admin/background_jobs.tt
>@@ -111,6 +111,7 @@ Administration &rsaquo; Koha
>                         [% CASE 'batch_biblio_record_modification' %]Batch bibliographic record modification
>                         [% CASE 'batch_biblio_record_deletion' %]Batch bibliographic record record deletion
>                         [% CASE 'batch_authority_record_modification' %]Batch authority record modification
>+                        [% CASE 'batch_authority_record_deletion' %]Batch authority record deletion
>                         [% CASE %][% job.type | html %]
>                         [% END %]
>                     </td>
>diff --git a/koha-tmpl/intranet-tmpl/prog/en/modules/tools/batch_delete_records.tt b/koha-tmpl/intranet-tmpl/prog/en/modules/tools/batch_delete_records.tt
>index 0185e30e67..09738efa05 100644
>--- a/koha-tmpl/intranet-tmpl/prog/en/modules/tools/batch_delete_records.tt
>+++ b/koha-tmpl/intranet-tmpl/prog/en/modules/tools/batch_delete_records.tt
>@@ -43,13 +43,14 @@
>       The biblionumber [% message.biblionumber | html %] does not exist in the database.
>     [% ELSIF message.code == 'authority_not_exists' %]
>       The authority id [% message.authid | html %] does not exist in the database.
>-    [% ELSIF message.code == 'authority_not_deleted' %]
>-      Authority record [% message.authid | html %] was not deleted. An error occurred.
>-    [% ELSIF message.code == 'authority_deleted' %]
>-      Authority [% message.authid | html %] has been deleted successfully.
>     [% ELSIF message.code == 'cannot_enqueue_job' %]
>         Cannot enqueue this job.
>+    [% ELSIF message.code == 'biblio_not_exists' %]
>+        Bibliographic record [% message.biblionumber | html %] does not exist in the database.
>+    [% ELSIF message.code == 'authority_not_exists' %]
>+        Authority record [% message.authid | html %] does not exist in the database.
>     [% END %]
>+
>     [% IF message.error %]
>       (The error was: [% message.error | html %], see the Koha log file for more information).
>     [% END %]
>@@ -198,15 +199,6 @@
>     [% ELSE %]
>       There are no record ids defined.
>     [% END %]
>-  [% ELSIF op == 'report' %]
>-    [% IF report.total_records == report.total_success %]
>-      All records have been deleted successfully!
>-    [% ELSIF report.total_success == 0 %]
>-      No record has been deleted. An error occurred.
>-    [% ELSE %]
>-      [% report.total_success | html %] / [% report.total_records | html %] records have been deleted successfully but some errors occurred.
>-    [% END %]
>-    <p><a href="/cgi-bin/koha/tools/batch_delete_records.pl" title="New batch record deletion">New batch record deletion</a></p>
>   [% ELSIF op == 'enqueued' %]
>     <div class="dialog message">
>       <p>The job has been enqueued! It will be processed as soon as possible.</p>
>diff --git a/misc/background_jobs_worker.pl b/misc/background_jobs_worker.pl
>index 9a57501bf5..69dc324a4e 100755
>--- a/misc/background_jobs_worker.pl
>+++ b/misc/background_jobs_worker.pl
>@@ -32,6 +32,7 @@ my @job_types = qw(
>     batch_biblio_record_modification
>     batch_authority_record_modification
>     batch_biblio_record_deletion
>+    batch_authority_record_deletion
> );
> 
> if ( $conn ) {
>diff --git a/tools/batch_delete_records.pl b/tools/batch_delete_records.pl
>index 83768f9f61..b447134207 100755
>--- a/tools/batch_delete_records.pl
>+++ b/tools/batch_delete_records.pl
>@@ -35,6 +35,7 @@ use Koha::Authorities;
> use Koha::Biblios;
> use Koha::Items;
> use Koha::BackgroundJob::BatchDeleteBiblio;
>+use Koha::BackgroundJob::BatchDeleteAuthority;
> 
> my $input = CGI->new;
> my $op = $input->param('op') // q|form|;
>-- 
>2.30.2

Actions: View | Diff | Splinter Review

Attachments on bug 26080: 107483 | 107484 | 107485 | 122347 | 122348 | 122349 | 123214 | 123215 | 123216 | 123989 | 123990 | 123991 | 124408 | 124409 | 124410 | 124411 | 124412