diff --git a/eprints1.pl b/eprints1.pl index a7d13481c1f1b23da685a1e0d392509d24dba546..fc37e44e775de064e362408ab64e3b92aae8ddbe 100755 --- a/eprints1.pl +++ b/eprints1.pl @@ -60,6 +60,7 @@ use strict; use DBI; use DBD::mysql; use JSON -convert_blessed_universally; +use Redis; use Util::ts; use Util::JSON; @@ -114,8 +115,8 @@ my $op_mode= 'unknown'; # ====================================================================== # BEGIN OT2UT: Othes to Utheses # my $ot2ut_context= 'ot2ut-entw'; # TODO: parametrize -# my $ot2ut_context= 'ot2ut-test'; # TODO: parametrize -my $ot2ut_context= 'ot2ut-prod'; # TODO: parametrize + my $ot2ut_context= 'ot2ut-test'; # TODO: parametrize +# my $ot2ut_context= 'ot2ut-prod'; # TODO: parametrize my $oma_sleep_time= 10; my %map_ot2ut_roles= @@ -2808,6 +2809,8 @@ sub ot2ut my $col_att= $db_ot2ut->get_collection('attachments'); my $col_policy_utheses= $db_ot2ut->get_collection('policy.utheses'); + my $redis_connection= get_redis_db($upload_cnf);; + # find items to upload if (!@eprint_ids) { @@ -3038,6 +3041,15 @@ sub ot2ut $out_row->{error_code}= $upload_success= 'ok'; $out_row->{error_cnt}= 0; $cnt_upload_ok++; + + # REDIS Update + if (defined ($redis_connection)) + { + my $ut_url= $upload_cnf->{utheses_public_base_url} . $utheses_id1; + my $rc= $redis_connection->set( $eprint_id => $ut_url ); + print __LINE__, " updated redis: eprint_id=[$eprint_id] ut_url=[$ut_url]\n"; + # sleep(10); + } } else { @@ -4458,6 +4470,24 @@ sub debug_stkz } } +sub get_redis_db +{ + my $ctx_cnf= shift; + + if (exists ($ctx_cnf->{redis})) + { + my $redis_connection= new Redis(server => $ctx_cnf->{redis}->{server}); + $redis_connection->select($ctx_cnf->{redis}->{database}); + print __LINE__, " connected to redis database\n"; + print "cnf: ", Dumper($ctx_cnf->{redis}); + print "con: ", Dumper($redis_connection); + # sleep(30); + return $redis_connection; + } + + undef; +} + sub export_redirect { # $cnf is global