1 package OpenILS::Application::Search::Serial;
2 use base qw/OpenILS::Application/;
3 use strict; use warnings;
6 use OpenSRF::Utils::JSON;
7 use OpenILS::Utils::Fieldmapper;
8 use OpenILS::Utils::MFHDParser;
9 use OpenSRF::Utils::SettingsClient;
10 use OpenILS::Utils::CStoreEditor q/:funcs/;
11 use OpenSRF::Utils::Cache;
14 use OpenSRF::Utils::Logger qw/:logger/;
18 use Time::HiRes qw(time);
19 use OpenSRF::EX qw(:try);
20 use Digest::MD5 qw(md5_hex);
25 use OpenILS::Const qw/:const/;
27 use OpenILS::Application::AppUtils;
28 my $U = "OpenILS::Application::AppUtils";
30 my $pfx = "open-ils.search_";
38 Takes an MFHD record ID and returns a hash of holdings statements
43 my ($self, $client, $id) = @_;
45 my $session = OpenSRF::AppSession->create("open-ils.cstore");
46 my $request = $session->request(
47 "open-ils.cstore.direct.serial.record_entry.retrieve", $id )->gather(1);
49 my $u = OpenILS::Utils::MFHDParser->new();
50 my $mfhd_hash = $u->generate_svr( $request->id, $request->marc, $request->owning_lib );
52 $session->disconnect();
56 __PACKAGE__->register_method(
57 method => "mfhd_to_hash",
58 api_name => "open-ils.search.serial.record.mfhd.retrieve",
60 note => "Given a serial record ID, return MFHD holdings"
65 =item * bib_to_mfhd_hash
69 Given a bib record ID, returns a hash of holdings statements
74 #sub bib_to_mfhd_hash {
75 # my ($self, $client, $bib) = @_;
79 # # XXX perhaps this? --miker
80 ## my $e = OpenILS::Utils::CStoreEditor->new();
81 ## my $mfhd = $e->search_serial_record_entry({ record => $bib });
82 ## return $u->generate_svr( $mfhd->[0] ) if (ref $mfhd);
85 # my @mfhd = $U->cstorereq( "open-ils.cstore.json_query.atomic", {
86 # select => { sre => 'marc' },
88 # where => { record => $bib, deleted => 'f' },
92 # if (!@mfhd or scalar(@mfhd) == 0) {
96 # my $u = OpenILS::Utils::MFHDParser->new();
97 # $mfhd_hash = $u->generate_svr( $mfhd[0][0]->{id}, $mfhd[0][0]->{marc}, $mfhd[0][0]->{owning_lib} );
102 #__PACKAGE__->register_method(
103 # method => "bib_to_mfhd_hash",
104 # api_name => "open-ils.search.serial.record.bib_to_mfhd.retrieve",
106 # note => "Given a bibliographic record ID, return MFHD holdings"
110 my ($self, $client, $bib) = @_;
114 my $e = OpenILS::Utils::CStoreEditor->new();
115 # TODO: 'deleted' ssub support
116 my $sdists = $e->search_serial_distribution([{ "+ssub" => {"record_entry" => $bib} }, { "flesh" => 1, "flesh_fields" => {'sdist' => [ "record_entry", "holding_lib", "basic_summary", "supplement_summary", "index_summary" ]}, "join" => {"ssub" => {}} }]);
117 my $sres = $e->search_serial_record_entry([{ record => $bib, deleted => 'f', "+sdist" => {"id" => undef} }, { "join" => {"sdist" => { 'type' => 'left' }} }]);
118 if (!ref $sres and !ref $sdists) {
122 my $mfhd_parser = OpenILS::Utils::MFHDParser->new();
125 if (ref $_->record_entry and $_->summary_method ne 'use_sdist_only') {
126 my $skip_all_computable = 0;
127 if ($_->summary_method eq 'merge_with_sre') { # 'computable' (85x/86x combos) are handled by generated_coverage when attempting to merge
128 $skip_all_computable = 1;
130 $svr = $mfhd_parser->generate_svr($_->record_entry->id, $_->record_entry->marc, $_->record_entry->owning_lib, $skip_all_computable);
132 $svr = Fieldmapper::serial::virtual_record->new;
134 $svr->location($_->holding_lib->name);
135 $svr->owning_lib($_->holding_lib);
136 $svr->basic_holdings([]);
137 $svr->supplement_holdings([]);
138 $svr->index_holdings([]);
139 $svr->basic_holdings_add([]);
140 $svr->supplement_holdings_add([]);
141 $svr->index_holdings_add([]);
144 $svr->incomplete([]);
146 if ($_->summary_method ne 'use_sre_only') {
147 if (ref $_->basic_summary) { #TODO: 'show-generated' boolean on summaries
148 if ($_->basic_summary->generated_coverage) {
149 push(@{$svr->basic_holdings}, OpenSRF::Utils::JSON->JSON2perl($_->basic_summary->generated_coverage));
151 if ($_->basic_summary->textual_holdings) {
152 push(@{$svr->basic_holdings_add}, $_->basic_summary->textual_holdings);
155 if (ref $_->supplement_summary) {
156 if ($_->supplement_summary->generated_coverage) {
157 push(@{$svr->supplement_holdings}, OpenSRF::Utils::JSON->JSON2perl($_->supplement_summary->generated_coverage));
159 if ($_->supplement_summary->textual_holdings) {
160 push(@{$svr->supplement_holdings_add}, $_->supplement_summary->textual_holdings);
163 if (ref $_->index_summary) {
164 if ($_->index_summary->generated_coverage) {
165 push(@{$svr->index_holdings}, OpenSRF::Utils::JSON->JSON2perl($_->index_summary->generated_coverage));
167 if ($_->index_summary->textual_holdings) {
168 push(@{$svr->index_holdings_add}, $_->index_summary->textual_holdings);
175 push(@$svrs, $mfhd_parser->generate_svr($_->id, $_->marc, $_->owning_lib));
178 # do a basic location sort for simple predictability
179 @$svrs = sort { $a->location cmp $b->location } @$svrs;
184 __PACKAGE__->register_method(
185 method => "bib_to_svr",
186 api_name => "open-ils.search.serial.record.bib.retrieve",
188 note => "Given a bibliographic record ID, return holdings in svr form"