|
Lines 1-7
Link Here
|
| 1 |
#!/usr/bin/perl |
1 |
#!/usr/bin/perl |
| 2 |
|
2 |
|
| 3 |
use strict; |
3 |
use Modern::Perl; |
| 4 |
use warnings; |
4 |
|
|
|
5 |
BEGIN { |
| 6 |
# find Koha's Perl modules |
| 7 |
# test carefully before changing this |
| 8 |
use FindBin (); |
| 9 |
eval { require "$FindBin::Bin/kohalib.pl" }; |
| 10 |
} |
| 5 |
|
11 |
|
| 6 |
use Koha::Script; |
12 |
use Koha::Script; |
| 7 |
use C4::Context; |
13 |
use C4::Context; |
|
Lines 39-46
if ($list_batches) {
Link Here
|
| 39 |
# in future, probably should tie to a real user account |
45 |
# in future, probably should tie to a real user account |
| 40 |
C4::Context->set_userenv(0, 'batch', 0, 'batch', 'batch', 'batch', 'batch'); |
46 |
C4::Context->set_userenv(0, 'batch', 0, 'batch', 'batch', 'batch', 'batch'); |
| 41 |
|
47 |
|
| 42 |
my $dbh = C4::Context->dbh; |
|
|
| 43 |
$dbh->{AutoCommit} = 0; |
| 44 |
if ($batch_number =~ /^\d+$/ and $batch_number > 0) { |
48 |
if ($batch_number =~ /^\d+$/ and $batch_number > 0) { |
| 45 |
my $batch = GetImportBatch($batch_number); |
49 |
my $batch = GetImportBatch($batch_number); |
| 46 |
die "$0: import batch $batch_number does not exist in database\n" unless defined $batch; |
50 |
die "$0: import batch $batch_number does not exist in database\n" unless defined $batch; |
|
Lines 53-59
if ($batch_number =~ /^\d+$/ and $batch_number > 0) {
Link Here
|
| 53 |
unless $batch->{'import_status'} eq "staged" or $batch->{'import_status'} eq "reverted"; |
57 |
unless $batch->{'import_status'} eq "staged" or $batch->{'import_status'} eq "reverted"; |
| 54 |
process_batch($batch_number); |
58 |
process_batch($batch_number); |
| 55 |
} |
59 |
} |
| 56 |
$dbh->commit(); |
|
|
| 57 |
} else { |
60 |
} else { |
| 58 |
die "$0: please specify a numeric batch ID\n"; |
61 |
die "$0: please specify a numeric batch ID\n"; |
| 59 |
} |
62 |
} |
|
Lines 80-86
sub process_batch {
Link Here
|
| 80 |
|
83 |
|
| 81 |
print "... importing MARC records -- please wait\n"; |
84 |
print "... importing MARC records -- please wait\n"; |
| 82 |
my ($num_added, $num_updated, $num_items_added, $num_items_replaced, $num_items_errored, $num_ignored) = |
85 |
my ($num_added, $num_updated, $num_items_added, $num_items_replaced, $num_items_errored, $num_ignored) = |
| 83 |
BatchCommitRecords($import_batch_id, $framework, 100, \&print_progress_and_commit); |
86 |
BatchCommitRecords($import_batch_id, $framework, 100, \&print_progress); |
| 84 |
print "... finished importing MARC records\n"; |
87 |
print "... finished importing MARC records\n"; |
| 85 |
|
88 |
|
| 86 |
print <<_SUMMARY_; |
89 |
print <<_SUMMARY_; |
|
Lines 105-111
sub revert_batch {
Link Here
|
| 105 |
|
108 |
|
| 106 |
print "... reverting batch -- please wait\n"; |
109 |
print "... reverting batch -- please wait\n"; |
| 107 |
my ($num_deleted, $num_errors, $num_reverted, $num_items_deleted, $num_ignored) = |
110 |
my ($num_deleted, $num_errors, $num_reverted, $num_items_deleted, $num_ignored) = |
| 108 |
BatchRevertRecords($import_batch_id, 100, \&print_progress_and_commit); |
111 |
BatchRevertRecords( $import_batch_id ); |
| 109 |
print "... finished reverting batch\n"; |
112 |
print "... finished reverting batch\n"; |
| 110 |
|
113 |
|
| 111 |
print <<_SUMMARY_; |
114 |
print <<_SUMMARY_; |
|
Lines 117-132
Number of records deleted: $num_deleted
Link Here
|
| 117 |
Number of errors: $num_errors |
120 |
Number of errors: $num_errors |
| 118 |
Number of records reverted: $num_reverted |
121 |
Number of records reverted: $num_reverted |
| 119 |
Number of records ignored: $num_ignored |
122 |
Number of records ignored: $num_ignored |
| 120 |
Number of items added: $num_items_deleted |
123 |
Number of items deleted: $num_items_deleted |
| 121 |
|
124 |
|
| 122 |
_SUMMARY_ |
125 |
_SUMMARY_ |
| 123 |
} |
126 |
} |
| 124 |
|
127 |
|
| 125 |
|
128 |
|
| 126 |
sub print_progress_and_commit { |
129 |
sub print_progress { |
| 127 |
my $recs = shift; |
130 |
my ( $recs ) = @_; |
| 128 |
print "... processed $recs records\n"; |
131 |
print "... processed $recs records\n"; |
| 129 |
$dbh->commit(); |
|
|
| 130 |
} |
132 |
} |
| 131 |
|
133 |
|
| 132 |
sub print_usage { |
134 |
sub print_usage { |