use Koha::BackgroundJob::BatchDeleteBiblio;

      : $job_type eq 'batch_biblio_record_deletion'

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

package Koha::BackgroundJob::BatchDeleteBiblio;

use Modern::Perl;

use JSON qw( encode_json decode_json );

use Koha::BackgroundJobs;

use Koha::DateUtils qw( dt_from_string );

use C4::Biblio;

use base 'Koha::BackgroundJob';

sub job_type {

    return 'batch_biblio_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 $biblionumber = $record_id;

        # First, checking if issues exist.

        # If yes, nothing to do

        my $biblio = Koha::Biblios->find( $biblionumber );

        # TODO Replace with $biblio->get_issues->count

        if ( C4::Biblio::CountItemsIssued( $biblionumber ) ) {

            push @messages, {

                type => 'warning',

                code => 'item_issued',

                biblionumber => $biblionumber,

            };

            $schema->storage->txn_rollback;

            $job->progress( ++$job_progress )->store;

            next;

        }

        # Cancel reserves

        my $holds = $biblio->holds;

        while ( my $hold = $holds->next ) {

            eval{

                $hold->cancel;

            };

            if ( $@ ) {

                push @messages, {

                    type => 'error',

                    code => 'reserve_not_cancelled',

                    biblionumber => $biblionumber,

                    reserve_id => $hold->reserve_id,

                    error => $@,

                };

                $schema->storage->txn_rollback;

                $job->progress( ++$job_progress )->store;

                next RECORD_IDS;

            }

        }

        # Delete items

        my $items = Koha::Items->search({ biblionumber => $biblionumber });

        while ( my $item = $items->next ) {

            my $error = $item->safe_delete;

            if(ref($error) ne 'Koha::Item'){

                push @messages, {

                    type => 'error',

                    code => 'item_not_deleted',

                    biblionumber => $biblionumber,

                    itemnumber => $item->itemnumber,

                    error => $error,

                };

                $schema->storage->txn_rollback;

                $job->progress( ++$job_progress )->store;

                next RECORD_IDS;

            }

        }

        # Finally, delete the biblio

        my $error = eval {

            C4::Biblio::DelBiblio( $biblionumber );

        };

        if ( $error or $@ ) {

            push @messages, {

                type => 'error',

                code => 'biblio_not_deleted',

                biblionumber => $biblionumber,

                error => ($@ ? $@ : $error),

            };

            $schema->storage->txn_rollback;

            $job->progress( ++$job_progress )->store;

            next;

        }

        push @messages, {

            type => 'success',

            code => 'biblio_deleted',

            biblionumber => $biblionumber,

        };

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

                [% CASE 'batch_biblio_record_deletion' %]

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

                [% CASE 'batch_biblio_record_deletion' %]

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

                            [% SWITCH m.code %]

                            [% CASE 'biblio_not_exists' %]

                                The biblionumber [% m.biblionumber | html %] does not exist in the database.

                            [% CASE 'item_issued' %]

                                At least one item is checked out on bibliographic record [% m.biblionumber | html %].

                            [% CASE 'reserve_not_cancelled' %]

                                Bibliographic record [% m.biblionumber | html %] was not deleted. A hold could not be canceled (reserve_id [% m.reserve_id | html %]).

                            [% CASE 'item_not_deleted' %]

                                The bibliographic record [% m.biblionumber | html %] was not deleted. An error was encountered when deleting an item (itemnumber [% m.itemnumber | html %]).

                            [% CASE 'biblio_not_deleted' %]

                                Bibliographic record [% m.biblionumber | html %] was not deleted. An error occurred.

                            [% CASE 'biblio_deleted' %]

                                Bibliographic record [% m.biblionumber | html %] has been deleted successfully.

                            [% END %]

                        </div>

                    [% END %]

    [% ELSIF message.code == 'cannot_enqueue_job' %]

        Cannot enqueue this job.

  [% ELSIF op == 'enqueued' %]

    <div class="dialog message">

      <p>The job has been enqueued! It will be processed as soon as possible.</p>

      <p><a href="/cgi-bin/koha/admin/background_jobs.pl?op=view&id=[% job_id | uri %]" title="View detail of the enqueued job">View detail of the enqueued job</a>

      | <a href="/cgi-bin/koha/tools/batch_delete_records.pl" title="New batch record deletion">New batch record deletion</a></p>

    </div>

use Try::Tiny;

use Koha::BackgroundJob::BatchDeleteBiblio;