From: Bill Erickson <berick@esilibrary.com>
Date: Mon, 18 Feb 2013 22:00:23 +0000 (-0500)
Subject: Z39 Batch ML
X-Git-Url: https://old-git.evergreen-ils.org/?a=commitdiff_plain;h=f73f75584d8b4cf6bf421a8d7036a60fa0082998;p=evergreen%2Fequinox.git

Z39 Batch ML

Signed-off-by: Bill Erickson <berick@esilibrary.com>
---

diff --git a/Open-ILS/src/perlmods/lib/OpenILS/Application/Search/Z3950.pm b/Open-ILS/src/perlmods/lib/OpenILS/Application/Search/Z3950.pm
index bf8c31bb3e..0011dd9f6f 100644
--- a/Open-ILS/src/perlmods/lib/OpenILS/Application/Search/Z3950.pm
+++ b/Open-ILS/src/perlmods/lib/OpenILS/Application/Search/Z3950.pm
@@ -606,9 +606,11 @@ sub create_z39_bucket_queue {
 
 # sets the 901c value to the Z39 service and 
 # adds the record to the growing vandelay queue
+# returns the number of successfully queued records
 sub stamp_and_queue_results {
     my ($e, $queue, $service, $bre_id, $result) = @_;
     $logger->info("z3950 got bucket response for $bre_id");
+    my $qcount = 0;
 
     for my $rec (@{$result->{records}}) {
         $logger->info("z39: got result for $bre_id : $rec");
@@ -628,11 +630,14 @@ sub stamp_and_queue_results {
         $e->xact_begin;
         if ($e->create_vandelay_queued_bib_record($qrec)) {
             $e->commit;
+            $qcount++;
         } else {
             my $evt = $e->die_event;
             $logger->error("z39: unable to queue record: $evt");
         }
     }
+
+    return $qcount;
 }
 
 sub send_and_queue_bucket_searches {
@@ -665,7 +670,8 @@ sub send_and_queue_bucket_searches {
             $response->{search_complete}++;
             my $result = $resp->content or next;
             my $service = $result->{service};
-            stamp_and_queue_results($e, $queue, $service, $bre_id, $result);
+            $response->{queue_count} += 
+                stamp_and_queue_results($e, $queue, $service, $bre_id, $result);
         }
 
         $conn->respond($response);