Attachment #16887 for bug #7131

View | Details | Raw Unified | Return to bug 7131
Collapse All | Expand All





=head2 BatchCommitRecords

  my ($num_added, $num_updated, $num_items_added, $num_items_replaced, $num_items_errored, $num_ignored) =
        BatchCommitRecords($batch_id, $framework,
        $progress_interval, $progress_callback);


    my $num_added = 0;
    my $num_updated = 0;
    my $num_items_added = 0;
    my $num_items_replaced = 0;
    my $num_items_errored = 0;
    my $num_ignored = 0;
    # commit (i.e., save, all records in the batch)

                my $biblioitemnumber;
                ($recordid, $biblioitemnumber) = AddBiblio($marc_record, $framework);
                $query = "UPDATE import_biblios SET matched_biblionumber = ? WHERE import_record_id = ?";
                if ($item_result eq 'create_new' || $item_result eq 'replace') {
                    my ($bib_items_added, $bib_items_replaced, $bib_items_errored) = BatchCommitItems($rowref->{'import_record_id'}, $recordid, $item_result);
                    $num_items_added += $bib_items_added;
                    $num_items_replaced += $bib_items_replaced;
                    $num_items_errored += $bib_items_errored;
                }
            } else {

                ModBiblio($marc_record, $recordid, $oldbiblio->{'frameworkcode'});
                $query = "UPDATE import_biblios SET matched_biblionumber = ? WHERE import_record_id = ?";

                if ($item_result eq 'create_new' || $item_result eq 'replace') {
                    my ($bib_items_added, $bib_items_replaced, $bib_items_errored) = BatchCommitItems($rowref->{'import_record_id'}, $recordid, $item_result);
                    $num_items_added += $bib_items_added;
                    $num_items_replaced += $bib_items_replaced;
                    $num_items_errored += $bib_items_errored;
                }
            } else {

        } elsif ($record_result eq 'ignore') {
            $num_ignored++;
            if ($record_type eq 'biblio' and defined $recordid and $item_result eq 'create_new') {
                my ($bib_items_added, $bib_items_replaced, $bib_items_errored) = BatchCommitItems($rowref->{'import_record_id'}, $recordid, $item_result);
                $num_items_added += $bib_items_added;
         $num_items_replaced += $bib_items_replaced;
                $num_items_errored += $bib_items_errored;
                # still need to record the matched biblionumber so that the
                # items can be reverted

    }
    $sth->finish();
    SetImportBatchStatus($batch_id, 'imported');
    return ($num_added, $num_updated, $num_items_added, $num_items_replaced, $num_items_errored, $num_ignored);
}

=head2 BatchCommitItems

=cut

sub BatchCommitItems {
    my ($import_record_id, $biblionumber, $action) = @_;

    my $dbh = C4::Context->dbh;

    my ($num_items_added, $num_items_errored, $num_items_replaced) = 0;
    my $num_items_errored = 0;
    my $sth = $dbh->prepare("SELECT import_items_id, import_items.marcxml, encoding
                             FROM import_items
                             JOIN import_records USING (import_record_id)

    $sth->execute();
    while (my $row = $sth->fetchrow_hashref()) {
        my $item_marc = MARC::Record->new_from_xml(StripNonXmlChars($row->{'marcxml'}), 'UTF-8', $row->{'encoding'});
    #delete date_due subfield as to not accidentally delete item checkout due dates
        my ($MARCfield,$MARCsubfield) = GetMarcFromKohaField('items.onloan', GetFrameworkCode($biblionumber));
 $item_marc->field($MARCfield)->delete_subfield(code => $MARCsubfield);
        # FIXME - duplicate barcode check needs to become part of AddItemFromMarc()
        my $item = TransformMarcToKoha($dbh, $item_marc);
        my $duplicate_barcode = exists($item->{'barcode'}) && GetItemnumberFromBarcode($item->{'barcode'});
        my $duplicate_itemnumber = exists($item->{'itemnumber'});
     my $updsth = $dbh->prepare("UPDATE import_items SET status = ?, itemnumber = ? WHERE import_items_id = ?");
    if($action eq "replace" && $duplicate_itemnumber){
         ModItemFromMarc($item_marc, $biblionumber, $item->{itemnumber});
            $updsth->bind_param(1, 'imported');
            $updsth->bind_param(2, $item->{itemnumber});
            $updsth->bind_param(3, $row->{'import_items_id'});
            $updsth->execute();
            $updsth->finish();
        $num_items_replaced++;
     }
        elsif ($duplicate_barcode) {
            $updsth->bind_param(1, 'error');
            $updsth->bind_param(2, 'duplicate item barcode');
            $updsth->bind_param(3, $row->{'import_items_id'});

            $num_items_errored++;
        } else {
            my ($item_biblionumber, $biblioitemnumber, $itemnumber) = AddItemFromMarc($item_marc, $biblionumber);
            my $updsth = $dbh->prepare("UPDATE import_items SET status = ?, itemnumber = ? WHERE import_items_id = ?");
            $updsth->bind_param(1, 'imported');
            $updsth->bind_param(2, $itemnumber);
            $updsth->bind_param(3, $row->{'import_items_id'});

        }
    }
    $sth->finish();
    return ($num_items_added, $num_items_replaced, $num_items_errored);
}

=head2 BatchRevertRecords

            } elsif ($overlay_action eq 'ignore') {
                $bib_result  = 'ignore';
            }
         if($item_action eq 'always_add' or $item_action eq 'add_only_for_matches'){
                $item_result = 'create_new';
       }
      elsif($item_action eq 'replace'){
          $item_result = 'replace';
          }
      else {
             $item_result = 'ignore';
           }
        } else {
            $bib_result = $nomatch_action;
            $item_result = ($item_action eq 'always_add' or $item_action eq 'add_only_for_new')     ? 'create_new' : 'ignore';

Lines 863-869 CREATE TABLE `import_batches` ( -- information about batches of marc records tha Link Here

(-)a/installer/data/mysql/kohastructure.sql (-1 / +1 lines)
863	`upload_timestamp` timestamp NOT NULL default CURRENT_TIMESTAMP, -- date and time the file was uploaded	863	`upload_timestamp` timestamp NOT NULL default CURRENT_TIMESTAMP, -- date and time the file was uploaded
864	`overlay_action` enum('replace', 'create_new', 'use_template', 'ignore') NOT NULL default 'create_new', -- how to handle duplicate records	864	`overlay_action` enum('replace', 'create_new', 'use_template', 'ignore') NOT NULL default 'create_new', -- how to handle duplicate records
865	`nomatch_action` enum('create_new', 'ignore') NOT NULL default 'create_new', -- how to handle records where no match is found	865	`nomatch_action` enum('create_new', 'ignore') NOT NULL default 'create_new', -- how to handle records where no match is found
866	`item_action` enum('always_add', 'add_only_for_matches', 'add_only_for_new', 'ignore') NOT NULL default 'always_add', -- what to do with item records	866	`item_action` enum('always_add', 'add_only_for_matches', 'add_only_for_new', 'ignore', 'replace') NOT NULL default 'always_add', -- what to do with item records
867	`import_status` enum('staging', 'staged', 'importing', 'imported', 'reverting', 'reverted', 'cleaned') NOT NULL default 'staging', -- the status of the imported file	867	`import_status` enum('staging', 'staged', 'importing', 'imported', 'reverting', 'reverted', 'cleaned') NOT NULL default 'staging', -- the status of the imported file
868	`batch_type` enum('batch', 'z3950', 'webservice') NOT NULL default 'batch', -- where this batch has come from	868	`batch_type` enum('batch', 'z3950', 'webservice') NOT NULL default 'batch', -- where this batch has come from
869	`record_type` enum('biblio', 'auth', 'holdings') NOT NULL default 'biblio', -- type of record in the batch	869	`record_type` enum('biblio', 'auth', 'holdings') NOT NULL default 'biblio', -- type of record in the batch

Lines 17-22 Link Here

(-)a/koha-tmpl/intranet-tmpl/prog/en/includes/tools-item-action.inc (+6 lines)
17	<option value="add_only_for_new">	17	<option value="add_only_for_new">
18	[% END %]	18	[% END %]
19	Add items only if no matching bib was found</option>	19	Add items only if no matching bib was found</option>
		20	[% IF ( item_action_replace ) %]
		21	<option value="replace" selected="selected">
		22	[% ELSE %]
		23	<option value="replace">
		24	[% END %]
		25	Replace items if matching bib was found (only for existing items)</option>
20	[% IF ( item_action_ignore ) %]	26	[% IF ( item_action_ignore ) %]
21	<option value="ignore" selected="selected">	27	<option value="ignore" selected="selected">
22	[% ELSE %]	28	[% ELSE %]

Lines 222-227 $(document).ready(function(){ Link Here

(-)a/koha-tmpl/intranet-tmpl/prog/en/modules/tools/manage-marc-import.tt (+1 lines)
222	<tr><td>Number of records updated</td><td>[% num_updated %]</td></tr>	222	<tr><td>Number of records updated</td><td>[% num_updated %]</td></tr>
223	<tr><td>Number of records ignored</td><td>[% num_ignored %]</td></tr>	223	<tr><td>Number of records ignored</td><td>[% num_ignored %]</td></tr>
224	<tr><td>Number of items added</td><td>[% num_items_added %]</td></tr>	224	<tr><td>Number of items added</td><td>[% num_items_added %]</td></tr>
		225	<tr><td>Number of items replaced</td><td>[% num_items_replaced %]</td></tr>
225	<tr><td>Number of items ignored because of duplicate barcode</td><td>[% num_items_errored %]</td></tr>	226	<tr><td>Number of items ignored because of duplicate barcode</td><td>[% num_items_errored %]</td></tr>
226	</table>	227	</table>
227	[% END %]	228	[% END %]

Lines 241-247 sub commit_batch { Link Here

(-)a/tools/manage-marc-import.pl (-2 / +2 lines)
241	$job = put_in_background($import_batch_id);	241	$job = put_in_background($import_batch_id);
242	$callback = progress_callback($job, $dbh);	242	$callback = progress_callback($job, $dbh);
243	}	243	}
244	my ($num_added, $num_updated, $num_items_added, $num_items_errored, $num_ignored) =	244	my ($num_added, $num_updated, $num_items_added, $num_items_replaced, $num_items_errored, $num_ignored) =
245	BatchCommitRecords($import_batch_id, $framework, 50, $callback);	245	BatchCommitRecords($import_batch_id, $framework, 50, $callback);
246	$dbh->commit();	246	$dbh->commit();
247		247
Lines 250-255 sub commit_batch { Link Here
250	num_added => $num_added,	250	num_added => $num_added,
251	num_updated => $num_updated,	251	num_updated => $num_updated,
252	num_items_added => $num_items_added,	252	num_items_added => $num_items_added,
		253	num_items_replaced => $num_items_replaced,
253	num_items_errored => $num_items_errored,	254	num_items_errored => $num_items_errored,
254	num_ignored => $num_ignored	255	num_ignored => $num_ignored
255	};	256	};
256	-

Return to bug 7131

Lines 514-520 sub BatchFindDuplicates { Link Here

(-)a/C4/ImportBatch.pm (-15 / +38 lines)
514		514
515	=head2 BatchCommitRecords	515	=head2 BatchCommitRecords
516		516
517	my ($num_added, $num_updated, $num_items_added, $num_items_errored, $num_ignored) =	517	my ($num_added, $num_updated, $num_items_added, $num_items_replaced, $num_items_errored, $num_ignored) =
518	BatchCommitRecords($batch_id, $framework,	518	BatchCommitRecords($batch_id, $framework,
519	$progress_interval, $progress_callback);	519	$progress_interval, $progress_callback);
520		520
Lines 539-544 sub BatchCommitRecords { Link Here
539	my $num_added = 0;	539	my $num_added = 0;
540	my $num_updated = 0;	540	my $num_updated = 0;
541	my $num_items_added = 0;	541	my $num_items_added = 0;
		542	my $num_items_replaced = 0;
542	my $num_items_errored = 0;	543	my $num_items_errored = 0;
543	my $num_ignored = 0;	544	my $num_ignored = 0;
544	# commit (i.e., save, all records in the batch)	545	# commit (i.e., save, all records in the batch)
Lines 598-606 sub BatchCommitRecords { Link Here
598	my $biblioitemnumber;	599	my $biblioitemnumber;
599	($recordid, $biblioitemnumber) = AddBiblio($marc_record, $framework);	600	($recordid, $biblioitemnumber) = AddBiblio($marc_record, $framework);
600	$query = "UPDATE import_biblios SET matched_biblionumber = ? WHERE import_record_id = ?";	601	$query = "UPDATE import_biblios SET matched_biblionumber = ? WHERE import_record_id = ?";
601	if ($item_result eq 'create_new') {	602	if ($item_result eq 'create_new' \|\| $item_result eq 'replace') {
602	my ($bib_items_added, $bib_items_errored) = BatchCommitItems($rowref->{'import_record_id'}, $recordid);	603	my ($bib_items_added, $bib_items_replaced, $bib_items_errored) = BatchCommitItems($rowref->{'import_record_id'}, $recordid, $item_result);
603	$num_items_added += $bib_items_added;	604	$num_items_added += $bib_items_added;
		605	$num_items_replaced += $bib_items_replaced;
604	$num_items_errored += $bib_items_errored;	606	$num_items_errored += $bib_items_errored;
605	}	607	}
606	} else {	608	} else {
Lines 631-639 sub BatchCommitRecords { Link Here
631	ModBiblio($marc_record, $recordid, $oldbiblio->{'frameworkcode'});	633	ModBiblio($marc_record, $recordid, $oldbiblio->{'frameworkcode'});
632	$query = "UPDATE import_biblios SET matched_biblionumber = ? WHERE import_record_id = ?";	634	$query = "UPDATE import_biblios SET matched_biblionumber = ? WHERE import_record_id = ?";
633		635
634	if ($item_result eq 'create_new') {	636	if ($item_result eq 'create_new' \|\| $item_result eq 'replace') {
635	my ($bib_items_added, $bib_items_errored) = BatchCommitItems($rowref->{'import_record_id'}, $recordid);	637	my ($bib_items_added, $bib_items_replaced, $bib_items_errored) = BatchCommitItems($rowref->{'import_record_id'}, $recordid, $item_result);
636	$num_items_added += $bib_items_added;	638	$num_items_added += $bib_items_added;
		639	$num_items_replaced += $bib_items_replaced;
637	$num_items_errored += $bib_items_errored;	640	$num_items_errored += $bib_items_errored;
638	}	641	}
639	} else {	642	} else {
Lines 653-660 sub BatchCommitRecords { Link Here
653	} elsif ($record_result eq 'ignore') {	656	} elsif ($record_result eq 'ignore') {
654	$num_ignored++;	657	$num_ignored++;
655	if ($record_type eq 'biblio' and defined $recordid and $item_result eq 'create_new') {	658	if ($record_type eq 'biblio' and defined $recordid and $item_result eq 'create_new') {
656	my ($bib_items_added, $bib_items_errored) = BatchCommitItems($rowref->{'import_record_id'}, $recordid);	659	my ($bib_items_added, $bib_items_replaced, $bib_items_errored) = BatchCommitItems($rowref->{'import_record_id'}, $recordid, $item_result);
657	$num_items_added += $bib_items_added;	660	$num_items_added += $bib_items_added;
		661	$num_items_replaced += $bib_items_replaced;
658	$num_items_errored += $bib_items_errored;	662	$num_items_errored += $bib_items_errored;
659	# still need to record the matched biblionumber so that the	663	# still need to record the matched biblionumber so that the
660	# items can be reverted	664	# items can be reverted
Lines 667-673 sub BatchCommitRecords { Link Here
667	}	671	}
668	$sth->finish();	672	$sth->finish();
669	SetImportBatchStatus($batch_id, 'imported');	673	SetImportBatchStatus($batch_id, 'imported');
670	return ($num_added, $num_updated, $num_items_added, $num_items_errored, $num_ignored);	674	return ($num_added, $num_updated, $num_items_added, $num_items_replaced, $num_items_errored, $num_ignored);
671	}	675	}
672		676
673	=head2 BatchCommitItems	677	=head2 BatchCommitItems
Lines 678-689 sub BatchCommitRecords { Link Here
678	=cut	682	=cut
679		683
680	sub BatchCommitItems {	684	sub BatchCommitItems {
681	my ($import_record_id, $biblionumber) = @_;	685	my ($import_record_id, $biblionumber, $action) = @_;
682		686
683	my $dbh = C4::Context->dbh;	687	my $dbh = C4::Context->dbh;
684		688
685	my $num_items_added = 0;	689	my ($num_items_added, $num_items_errored, $num_items_replaced) = 0;
686	my $num_items_errored = 0;
687	my $sth = $dbh->prepare("SELECT import_items_id, import_items.marcxml, encoding	690	my $sth = $dbh->prepare("SELECT import_items_id, import_items.marcxml, encoding
688	FROM import_items	691	FROM import_items
689	JOIN import_records USING (import_record_id)	692	JOIN import_records USING (import_record_id)
Lines 693-703 sub BatchCommitItems { Link Here
693	$sth->execute();	696	$sth->execute();
694	while (my $row = $sth->fetchrow_hashref()) {	697	while (my $row = $sth->fetchrow_hashref()) {
695	my $item_marc = MARC::Record->new_from_xml(StripNonXmlChars($row->{'marcxml'}), 'UTF-8', $row->{'encoding'});	698	my $item_marc = MARC::Record->new_from_xml(StripNonXmlChars($row->{'marcxml'}), 'UTF-8', $row->{'encoding'});
		699	#delete date_due subfield as to not accidentally delete item checkout due dates
		700	my ($MARCfield,$MARCsubfield) = GetMarcFromKohaField('items.onloan', GetFrameworkCode($biblionumber));
		701	$item_marc->field($MARCfield)->delete_subfield(code => $MARCsubfield);
696	# FIXME - duplicate barcode check needs to become part of AddItemFromMarc()	702	# FIXME - duplicate barcode check needs to become part of AddItemFromMarc()
697	my $item = TransformMarcToKoha($dbh, $item_marc);	703	my $item = TransformMarcToKoha($dbh, $item_marc);
698	my $duplicate_barcode = exists($item->{'barcode'}) && GetItemnumberFromBarcode($item->{'barcode'});	704	my $duplicate_barcode = exists($item->{'barcode'}) && GetItemnumberFromBarcode($item->{'barcode'});
699	if ($duplicate_barcode) {	705	my $duplicate_itemnumber = exists($item->{'itemnumber'});
700	my $updsth = $dbh->prepare("UPDATE import_items SET status = ?, import_error = ? WHERE import_items_id = ?");	706	my $updsth = $dbh->prepare("UPDATE import_items SET status = ?, itemnumber = ? WHERE import_items_id = ?");
		707	if($action eq "replace" && $duplicate_itemnumber){
		708	ModItemFromMarc($item_marc, $biblionumber, $item->{itemnumber});
		709	$updsth->bind_param(1, 'imported');
		710	$updsth->bind_param(2, $item->{itemnumber});
		711	$updsth->bind_param(3, $row->{'import_items_id'});
		712	$updsth->execute();
		713	$updsth->finish();
		714	$num_items_replaced++;
		715	}
		716	elsif ($duplicate_barcode) {
701	$updsth->bind_param(1, 'error');	717	$updsth->bind_param(1, 'error');
702	$updsth->bind_param(2, 'duplicate item barcode');	718	$updsth->bind_param(2, 'duplicate item barcode');
703	$updsth->bind_param(3, $row->{'import_items_id'});	719	$updsth->bind_param(3, $row->{'import_items_id'});
Lines 705-711 sub BatchCommitItems { Link Here
705	$num_items_errored++;	721	$num_items_errored++;
706	} else {	722	} else {
707	my ($item_biblionumber, $biblioitemnumber, $itemnumber) = AddItemFromMarc($item_marc, $biblionumber);	723	my ($item_biblionumber, $biblioitemnumber, $itemnumber) = AddItemFromMarc($item_marc, $biblionumber);
708	my $updsth = $dbh->prepare("UPDATE import_items SET status = ?, itemnumber = ? WHERE import_items_id = ?");
709	$updsth->bind_param(1, 'imported');	724	$updsth->bind_param(1, 'imported');
710	$updsth->bind_param(2, $itemnumber);	725	$updsth->bind_param(2, $itemnumber);
711	$updsth->bind_param(3, $row->{'import_items_id'});	726	$updsth->bind_param(3, $row->{'import_items_id'});
Lines 715-721 sub BatchCommitItems { Link Here
715	}	730	}
716	}	731	}
717	$sth->finish();	732	$sth->finish();
718	return ($num_items_added, $num_items_errored);	733	return ($num_items_added, $num_items_replaced, $num_items_errored);
719	}	734	}
720		735
721	=head2 BatchRevertRecords	736	=head2 BatchRevertRecords
Lines 1461-1467 sub _get_commit_action { Link Here
1461	} elsif ($overlay_action eq 'ignore') {	1476	} elsif ($overlay_action eq 'ignore') {
1462	$bib_result = 'ignore';	1477	$bib_result = 'ignore';
1463	}	1478	}
1464	$item_result = ($item_action eq 'always_add' or $item_action eq 'add_only_for_matches') ? 'create_new' : 'ignore';	1479	if($item_action eq 'always_add' or $item_action eq 'add_only_for_matches'){
		1480	$item_result = 'create_new';
		1481	}
		1482	elsif($item_action eq 'replace'){
		1483	$item_result = 'replace';
		1484	}
		1485	else {
		1486	$item_result = 'ignore';
		1487	}
1465	} else {	1488	} else {
1466	$bib_result = $nomatch_action;	1489	$bib_result = $nomatch_action;
1467	$item_result = ($item_action eq 'always_add' or $item_action eq 'add_only_for_new') ? 'create_new' : 'ignore';	1490	$item_result = ($item_action eq 'always_add' or $item_action eq 'add_only_for_new') ? 'create_new' : 'ignore';