use Koha::BackgroundJob::BatchDeleteAuthority;

      : $job_type eq 'batch_authority_record_deletion'

      ? Koha::BackgroundJob::BatchDeleteAuthority->process($args)

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;

[% 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 %]

                        [% CASE 'batch_authority_record_deletion' %]Batch authority record deletion

    [% 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.

    batch_authority_record_deletion

use Koha::BackgroundJob::BatchDeleteAuthority;