use CGI;
use List::MoreUtils qw( uniq );
+use JSON qw( encode_json );
+use Try::Tiny;
use C4::Auth qw( get_template_and_user );
use C4::Output qw( output_html_with_http_headers );
use C4::AuthoritiesMarc qw( BuildSummary ModAuthority );
-use C4::BackgroundJob;
use C4::Biblio qw( GetMarcBiblio ModBiblio );
-use C4::MarcModificationTemplates qw( GetModificationTemplateActions GetModificationTemplates ModifyRecordWithTemplate );
+use C4::MarcModificationTemplates qw( GetModificationTemplateActions GetModificationTemplates );
use Koha::Biblios;
+use Koha::BackgroundJob::BatchUpdateBiblio;
+use Koha::BackgroundJob::BatchUpdateAuthority;
use Koha::MetadataRecord::Authority;
+use Koha::Virtualshelves;
-my $input = new CGI;
+my $input = CGI->new;
our $dbh = C4::Context->dbh;
my $op = $input->param('op') // q|form|;
my $recordtype = $input->param('recordtype') // 'biblio';
template_name => 'tools/batch_record_modification.tt',
query => $input,
type => "intranet",
- authnotrequired => 0,
flagsrequired => { tools => 'records_batchmod' },
});
-
my $sessionID = $input->cookie("CGISESSID");
-my $runinbackground = $input->param('runinbackground');
-my $completedJobID = $input->param('completedJobID');
-if ( $completedJobID ) {
- my $job = C4::BackgroundJob->fetch($sessionID, $completedJobID);
- my $report = $job->get('report');
- my $messages = $job->get('messages');
- $template->param(
- report => $report,
- messages => $messages,
- view => 'report',
- );
- output_html_with_http_headers $input, $cookie, $template->output;
- $job->clear();
- exit;
-}
-
my @templates = GetModificationTemplates( $mmtid );
unless ( @templates ) {
$op = 'error';
$content =~ s/[\r\n]*$//;
push @record_ids, $content if $content;
}
+ } elsif ( my $shelf_number = $input->param('shelf_number') ) {
+ my $shelf = Koha::Virtualshelves->find($shelf_number);
+ my $contents = $shelf->get_contents;
+ while ( my $content = $contents->next ) {
+ my $biblionumber = $content->biblionumber;
+ push @record_ids, $biblionumber;
+ }
} else {
# The user enters manually the list of id
push @record_ids, split( /\s\n/, $input->param('recordnumber_list') );
# We want to modify selected records!
my @record_ids = $input->multi_param('record_id');
- my ( $job );
- if ( $runinbackground ) {
- my $job_size = scalar( @record_ids );
- $job = C4::BackgroundJob->new( $sessionID, "FIXME", '/cgi-bin/koha/tools/batch_record_modification.pl', $job_size );
- my $job_id = $job->id;
- if (my $pid = fork) {
- $dbh->{InactiveDestroy} = 1;
-
- my $reply = CGI->new("");
- print $reply->header(-type => 'text/html');
- print '{"jobID":"' . $job_id . '"}';
- exit 0;
- } elsif (defined $pid) {
- close STDOUT;
- } else {
- warn "fork failed while attempting to run tools/batch_record_modification.pl as a background job";
- exit 0;
- }
- }
-
- my $report = {
- total_records => 0,
- total_success => 0,
- };
- my $progress = 0;
- $dbh->{RaiseError} = 1;
- RECORD_IDS: for my $record_id ( sort { $a <=> $b } @record_ids ) {
- $report->{total_records}++;
- next unless $record_id;
-
- if ( $recordtype eq 'biblio' ) {
- # Biblios
- my $biblionumber = $record_id;
-
- # Finally, modify the biblio
- my $error = eval {
- my $record = GetMarcBiblio({ biblionumber => $biblionumber });
- ModifyRecordWithTemplate( $mmtid, $record );
- my $frameworkcode = C4::Biblio::GetFrameworkCode( $biblionumber );
- ModBiblio( $record, $biblionumber, $frameworkcode );
- };
- if ( $error and $error != 1 or $@ ) { # ModBiblio returns 1 if everything as gone well
- push @messages, {
- type => 'error',
- code => 'biblio_not_modified',
- biblionumber => $biblionumber,
- error => ($@ ? $@ : $error),
- };
- } else {
- push @messages, {
- type => 'success',
- code => 'biblio_modified',
- biblionumber => $biblionumber,
- };
- $report->{total_success}++;
- }
- } else {
- # Authorities
- my $authid = $record_id;
- my $error = eval {
- my $authority = Koha::MetadataRecord::Authority->get_from_authid( $authid );
- my $record = $authority->record;
- ModifyRecordWithTemplate( $mmtid, $record );
- ModAuthority( $authid, $record, $authority->authtypecode );
- };
- if ( $error and $error != $authid or $@ ) {
- push @messages, {
- type => 'error',
- code => 'authority_not_modified',
- authid => $authid,
- error => ($@ ? $@ : 0),
- };
- } else {
- push @messages, {
- type => 'success',
- code => 'authority_modified',
- authid => $authid,
- };
- $report->{total_success}++;
- }
- }
+ try {
+ my $params = {
+ mmtid => $mmtid,
+ record_ids => \@record_ids,
+ };
- $job->set({
- view => 'report',
- report => $report,
- messages => \@messages,
- });
- $job->progress( ++$progress ) if $runinbackground;
- }
+ my $job_id =
+ $recordtype eq 'biblio'
+ ? Koha::BackgroundJob::BatchUpdateBiblio->new->enqueue($params)
+ : Koha::BackgroundJob::BatchUpdateAuthority->new->enqueue($params);
- if ($runinbackground) {
- $job->finish if defined $job;
- } else {
$template->param(
- view => 'report',
- report => $report,
- messages => \@messages,
+ view => 'enqueued',
+ job_id => $job_id,
);
- }
+ } catch {
+ push @messages, {
+ type => 'error',
+ code => 'cannot_enqueue_job',
+ error => $_,
+ };
+ $template->param( view => 'errors' );
+ };
}
$template->param(
projects / srvgit / blobdiff