populate issues from posud

diff --git a/ferlib2koha.pl b/ferlib2koha.pl
index 85f40d7..5c29826 100755 (executable)
--- a/ferlib2koha.pl
+++ b/ferlib2koha.pl
@@ -12,14 +12,14 @@ my $k = DBI->connect("dbi:mysql:database=koha_fer","","", { RaiseError => 1, Aut
 
 our $lookup;
 sub lookup {
-       my ($t, $k, $v, $s, $default ) = @_;
+       my ( $dbh, $t, $k, $v, $s, $default ) = @_;
        my $hash;
        my $key = "$t $k $v";
        if ( exists $lookup->{$key} ) {
                $hash = $lookup->{$key};
        } else {
                warn "# select $k,$v from $t";
-               my $sth = $f->prepare( "select $k,$v from $t" );
+               my $sth = $dbh->prepare( "select $k,$v from $t" );
                $sth->execute;
                while (my $row = $sth->fetchrow_hashref() ) {
                        $hash->{ $row->{$k} } = $row->{$v};
@@ -46,6 +46,11 @@ sub insert {
                        . join(',', map { '?' } keys %$row )
                        . ")"
        );
+
+       foreach my $c ( grep { /(date|timestamp)/ } keys %$row ) {
+               $row->{$c} =~ s/^(\d\d)\.(\d\d)\.(\d\d\d\d)/$3-$2-$1/;
+       }
+
        $insert->{$table}->execute( values %$row );
        warn "# inserted ", dump $row;
 
@@ -63,18 +68,15 @@ sub borrowers {
                warn dump $row;
 
                # poor man's (sqlite) outer join
-               $row->{'country'} = lookup('drzava', 'ozn_drzava', 'naz_drzava', $row->{'country'}, $row->{contry} );
-               $row->{'city'} = lookup('mjesto', 'post_ozn', 'naz_mjesto', $row->{'city'}, $row->{city} );
+               $row->{'country'} = lookup($f, 'drzava', 'ozn_drzava', 'naz_drzava', $row->{'country'}, $row->{contry} );
+               $row->{'city'}    = lookup($f, 'mjesto', 'post_ozn', 'naz_mjesto', $row->{'city'}, $row->{city} );
 
-               $row->{'B_country'} = lookup('drzava', 'ozn_drzava', 'naz_drzava', $row->{'B_country'}, $row->{B_country} );
-               $row->{'B_city'} = lookup('mjesto', 'post_ozn', 'naz_mjesto', $row->{'B_city'}, $row->{B_city} );
+               $row->{'B_country'} = lookup($f, 'drzava', 'ozn_drzava', 'naz_drzava', $row->{'B_country'}, $row->{B_country} );
+               $row->{'B_city'}    = lookup($f, 'mjesto', 'post_ozn', 'naz_mjesto', $row->{'B_city'}, $row->{B_city} );
 
-               $row->{'email'} = lookup('clanost', 'ozn_vrclan||ozn_clan', 'email', $row->{'cardnumber'}, undef);
-               $row->{'emailpro'} = lookup('clanost', 'ozn_vrclan||ozn_clan', 'email_k', $row->{'cardnumber'}, undef);
+               $row->{'email'}    = lookup($f, 'clanost', 'ozn_vrclan||ozn_clan', 'email', $row->{'cardnumber'}, undef);
+               $row->{'emailpro'} = lookup($f, 'clanost', 'ozn_vrclan||ozn_clan', 'email_k', $row->{'cardnumber'}, undef);
 
-               foreach my $c ( grep { /date/ } keys %$row ) {
-                       $row->{$c} =~ s/(\d\d)\.(\d\d)\.(\d\d\d\d)/$3-$2-$1/;
-               }
 
                $row->{sex} =~ s/\x{17D}/F/;
 
@@ -168,4 +170,34 @@ select
 from clost
 };
 
+
+sub issues {
+       my ($table,$sql) = @_;
+       my $sth = $f->prepare($sql);
+       $sth->execute;
+
+       $insert = undef;
+
+       while (my $row = $sth->fetchrow_hashref ) {
+               $row->{borrowernumber} = lookup($k, 'borrowers', 'cardnumber' => 'borrowernumber', $row->{borrowernumber});
+               $row->{itemnumber}     = lookup($k, 'items', 'barcode' => 'itemnumber', $row->{itemnumber});
+               insert $table => $row;
+       }
+}
+
+my $posud_sql = qq{
+select
+       ozn_vrclan||ozn_clan as borrowernumber,
+       sif_primj as itemnumber,
+       datum_do as date_due,
+       'SRE' as branchcode, -- FIXME
+       datum_vra as returndate,
+       datum_pos as issuedate,
+       datum_pos||' '||vrijeme_pos as timestamp
+from posud
+};
+
+issues 'old_issues' => qq{$posud_sql where datum_vra != ''};
+issues 'issues'     => qq{$posud_sql where datum_vra == ''};
+
 $k->commit;