my $queue = shift;
my $marc = shift;
my $purpose = shift;
+ my $bib_source = shift;
my $e = new_editor(authtoken => $auth, xact => 1);
($e->allowed('CREATE_BIB_IMPORT_QUEUE', undef, $queue) ||
$e->allowed('CREATE_BIB_IMPORT_QUEUE'));
- my $new_rec = _add_bib_rec($e, $marc, $queue->id, $purpose);
+ my $new_rec = _add_bib_rec($e, $marc, $queue->id, $purpose, $bib_source);
return $e->die_event unless ($new_rec);
$e->commit;
my $marc = shift;
my $queue = shift;
my $purpose = shift;
+ my $bib_source = shift;
my $rec = new Fieldmapper::vandelay::queued_bib_record();
$rec->marc( $marc );
$rec->queue( $queue );
$rec->purpose( $purpose ) if ($purpose);
+ $rec->bib_source($bib_source);
return $e->create_vandelay_queued_bib_record( $rec );
}
my $data = $cache->get_cache('vandelay_import_spool_' . $fingerprint);
my $purpose = $data->{purpose};
my $filename = $data->{path};
+ my $bib_source = $data->{bib_source};
unless(-r $filename) {
$logger->error("unable to read MARC file $filename");
$xml =~ s/[\x00-\x1f]//go;
if ($type eq 'bib') {
- _add_bib_rec( $e, $xml, $queue_id, $purpose ) or return $e->die_event;
+ _add_bib_rec( $e, $xml, $queue_id, $purpose, $bib_source ) or return $e->die_event;
} else {
_add_auth_rec( $e, $xml, $queue_id, $purpose ) or return $e->die_event;
}
my $data_fingerprint = '';
my $purpose = $cgi->param('purpose');
my $infile = $cgi->param('marc_upload');
+ my $bib_source = $cgi->param('bib_source');
my $conf = OpenSRF::Utils::SettingsClient->new;
my $dir = $conf->config_value(
OpenSRF::Utils::Cache->new->put_cache(
'vandelay_import_spool_' . $data_fingerprint,
- { purpose => $purpose, path => $outfile }
+ { purpose => $purpose,
+ path => $outfile,
+ bib_source => $bib_source
+ }
);
}