Koha/OAI/Server/GetRecord.pm

   1 # Copyright Tamil s.a.r.l. 2008-2015
   2 # Copyright Biblibre 2008-2015
   3 #
   4 # This file is part of Koha.
   5 #
   6 # Koha is free software; you can redistribute it and/or modify it
   7 # under the terms of the GNU General Public License as published by
   8 # the Free Software Foundation; either version 3 of the License, or
   9 # (at your option) any later version.
  10 #
  11 # Koha is distributed in the hope that it will be useful, but
  12 # WITHOUT ANY WARRANTY; without even the implied warranty of
  13 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  14 # GNU General Public License for more details.
  15 #
  16 # You should have received a copy of the GNU General Public License
  17 # along with Koha; if not, see <http://www.gnu.org/licenses>.
  18
  19 package Koha::OAI::Server::GetRecord;
  20
  21 use Modern::Perl;
  22 use HTTP::OAI;
  23 use C4::OAI::Sets qw( GetOAISetsBiblio );
  24 use MARC::File::XML;
  25
  26 use base ("HTTP::OAI::GetRecord");
  27
  28
  29 sub new {
  30     my ($class, $repository, %args) = @_;
  31
  32     my $self = HTTP::OAI::GetRecord->new(%args);
  33
  34     my $prefix = $repository->{koha_identifier} . ':';
  35     my ($biblionumber) = $args{identifier} =~ /^$prefix(.*)/;
  36     my $items_included = $repository->items_included( $args{metadataPrefix} );
  37     my $dbh = C4::Context->dbh;
  38     my $sql = "
  39         SELECT timestamp
  40         FROM   biblioitems
  41         WHERE  biblionumber=?
  42     ";
  43     my @bind_params = ($biblionumber);
  44     if ( $items_included ) {
  45         # Take latest timestamp of biblio and any items
  46         # Or timestamp of deleted items where bib not deleted
  47         $sql .= "
  48             UNION
  49             SELECT deleteditems.timestamp FROM deleteditems JOIN biblio USING (biblionumber)
  50             WHERE deleteditems.biblionumber=?
  51             UNION
  52             SELECT timestamp from items
  53             WHERE biblionumber=?
  54         ";
  55         push @bind_params, $biblionumber;
  56         push @bind_params, $biblionumber;
  57         $sql = "
  58             SELECT max(timestamp)
  59             FROM ($sql) bib
  60         ";
  61     }
  62
  63     my $sth = $dbh->prepare( $sql ) || die( 'Could not prepare statement: ' . $dbh->errstr );
  64     $sth->execute( @bind_params ) || die( 'Could not execute statement: ' . $sth->errstr );
  65     my ($timestamp, $deleted);
  66     unless ( ($timestamp = $sth->fetchrow) ) {
  67         $sql = "
  68             SELECT timestamp
  69             FROM deletedbiblio
  70             WHERE biblionumber=?
  71         ";
  72         @bind_params = ($biblionumber);
  73
  74         if ( $items_included ) {
  75             # Take latest timestamp among biblio and items
  76             $sql .= "
  77                 UNION
  78                 SELECT timestamp from deleteditems
  79                 WHERE biblionumber=?
  80             ";
  81             push @bind_params, $biblionumber;
  82             $sql = "
  83                 SELECT max(timestamp)
  84                 FROM ($sql) bib
  85             ";
  86         }
  87
  88         $sth = $dbh->prepare($sql) || die('Could not prepare statement: ' . $dbh->errstr);
  89         $sth->execute( @bind_params ) || die('Could not execute statement: ' . $sth->errstr);
  90         unless ( ($timestamp = $sth->fetchrow) )
  91         {
  92             return HTTP::OAI::Response->new(
  93              requestURL  => $repository->self_url(),
  94              errors      => [ HTTP::OAI::Error->new(
  95                 code    => 'idDoesNotExist',
  96                 message => "There is no biblio record with this identifier",
  97                 ) ],
  98             );
  99         }
 100         $deleted = 1;
 101     }
 102
 103     my $oai_sets = GetOAISetsBiblio($biblionumber);
 104     my @setSpecs;
 105     foreach (@$oai_sets) {
 106         push @setSpecs, $_->{spec};
 107     }
 108
 109     if ($deleted) {
 110         $self->record(
 111             Koha::OAI::Server::DeletedRecord->new($timestamp, \@setSpecs, %args)
 112         );
 113     } else {
 114         # We fetch it using this method, rather than the database directly,
 115         # so it'll include the item data
 116         my $marcxml;
 117         $marcxml = $repository->get_biblio_marcxml($biblionumber, $args{metadataPrefix})
 118             unless $deleted;
 119
 120         $self->record(
 121             Koha::OAI::Server::Record->new($repository, $marcxml, $timestamp, \@setSpecs, %args)
 122         );
 123     }
 124     return $self;
 125 }
 126
 127 1;