lookup now supports max(column)

[ferlib2koha.git] / ferlib2koha.pl

diff --git a/ferlib2koha.pl b/ferlib2koha.pl
index 47e1a3c..cb39683 100755 (executable)
--- a/ferlib2koha.pl
+++ b/ferlib2koha.pl
@@ -4,14 +4,15 @@ use strict;
 use DBI;
 use Data::Dump qw/dump/;
 use Algorithm::CheckDigits;
+use Text::Unaccent;
 
-# sudo apt-get install libdbd-sqlite3-perl libdbd-csv-perl
+# sudo apt-get install libdbd-sqlite3-perl libdbd-csv-perl libtext-unaccent-perl
 
 $|++;
 
 my $import = {
        borrowers => $ENV{FULL} || 0,
-       issues    => $ENV{FULL} || 1,
+       issues    => $ENV{FULL} || 0,
        reserves  => $ENV{FULL} || 0,
        barcode   => $ENV{FULL} || 0,
 };
@@ -26,15 +27,25 @@ sub lookup {
        my ( $dbh, $t, $k, $v, $s, $default ) = @_;
        my $hash;
        my $key = "$t $k $v";
+       my $max = $v =~ s/max\((\w+)\)/$1/;
        if ( exists $lookup->{$key} ) {
                $hash = $lookup->{$key};
        } else {
                warn "# select $k,$v from $t";
                my $sth = $dbh->prepare( "select $k,$v from $t" );
                $sth->execute;
+               my @non_unique;
                while (my $row = $sth->fetchrow_hashref() ) {
+                       if ( ! $max && exists $hash->{ $row->{$k} } ) {
+                               push @non_unique, $row->{$k};
+                               next;
+                       }
                        $hash->{ $row->{$k} } = $row->{$v};
                }
+               if ( @non_unique ) {
+                       warn "# remove non-unique ", dump(@non_unique);
+                       delete $hash->{$_} foreach @non_unique;
+               }
                $lookup->{$key} = $hash;
                warn "# lookup $key = ",dump($hash);
        }
@@ -107,12 +118,29 @@ sub borrowers {
 
                insert 'borrowers' => $row;
 
+               my $borrowernumber = $k->{mysql_insertid};
+
                insert 'borrower_attributes' => {
-                       borrowernumber => $k->{mysql_insertid},
+                       borrowernumber => $borrowernumber,
                        code => 'JMBG',
                        attribute => $jmbg,
                } if $jmbg;
 
+               foreach my $id ( 6,1,4,5,2 ) {
+
+                       insert 'borrower_message_preferences' => {
+                               borrowernumber => $borrowernumber,
+                               message_attribute_id => $id,
+                               days_in_advance => $id == 2 ? 0 : undef,
+                       };
+
+                       insert 'borrower_message_transport_preferences' => {
+                               borrower_message_preference_id => $k->{mysql_insertid},
+                               message_transport_type => 'email',
+                       } if $id == 4;
+
+               }
+
        }
 }
 
@@ -132,6 +160,8 @@ delete from borrowers;
 alter table borrowers auto_increment = 1;
 delete from borrower_attributes;
 alter table borrower_attributes auto_increment = 1;
+delete from borrower_message_preferences where borrowernumber is not null ;
+alter table borrower_message_preferences auto_increment = 1;
 };
 
 
@@ -322,7 +352,7 @@ sub reserves {
                        $row->{itemnumber} ? 'W' : undef;
 
                $row->{borrowernumber} = lookup($k, 'borrowers', 'cardnumber' => 'borrowernumber', $row->{borrowernumber});
-               $row->{biblionumber}   = lookup($k, 'biblioitems', 'collectionvolume' => 'biblionumber', $row->{biblionumber});
+               $row->{biblionumber}   = lookup($k, 'biblioitems', 'collectionvolume' => 'max(biblionumber)', $row->{biblionumber});
                $row->{itemnumber}     = lookup($k, 'items', 'barcode' => 'itemnumber', $row->{itemnumber});
 
                insert $table => $row;
@@ -371,6 +401,40 @@ while( my $row = $sth->fetchrow_hashref ) {
 } # import->{barcode}
 
 
+sub aqbooksellers {
+       my ($sql) = @_;
+       my $sth = $f->prepare($sql);
+       $sth->execute;
+
+       $insert = undef;
 
+       while (my $row = $sth->fetchrow_hashref ) {
+               insert 'aqbooksellers' => $row;
+       }
+}
+
+sql $k => qq{
+delete from aqbooksellers;
+alter table aqbooksellers auto_increment = 1;
+};
+aqbooksellers qq{
+select
+       ozn_nacdob as notes,
+       opis_nacdob as name,
+       'HRK' as currency
+from nacdob
+};
+
+=for later
+               if ( $row->{categorycode} eq 'D' && ! $row->{email} ) {
+                       my $email = lc unac_string( 'utf-8', $row->{firstname} . '.' . $row->{surname} . '@fer.hr' );
+                       if ( my $nick = lookup($u, 'users', 'email', 'nick', $email, undef) ) {
+                               $row->{email}  = $email;
+                               $row->{userid} = $nick;
+                               $row->{cardnumber} = lookup($u, 'users', 'email', 'jmbag', $email, 'X-' . $row->{cardnumber});
+                               warn "# FIXED nick $nick $email $row->{cardnumber}\n";
+                       }
+               }
+=cut
 
 $k->commit;