#!/usr/bin/perl

use DBI;
use IO::File;
use strict;

my $arg;
#my @proc = `ps aux | grep pl | grep -v grep`;
#foreach $arg(@proc){
#if($_){exit;}
#}
my $log = "/home/camdpams_www/WhiteListing/pl/log/log";
my ($sec,$min,$hour,$mday,$mon,$year,
           $wday,$yday,$isdst) = localtime time;
$year += 1900;           
my $db = "CAMDPAMS";
my $host = "192.168.9.10";
my $sth;
my $sth1;
my $sth2;
my $dbh = DBI ->connect("dbi:Pg:dbname=$db;host=$host","olegk","4Q2073gl",{AutoCommit=>0,RaiseError=>1,ChopBlanks=>1});
#my $t_start = "2004-01-01";
#my $t_stop = "2009-12-31";
my $t_start = "yesterday";
my $t_stop = "today";
my $camdpams = "select count(distinct \"SampleSha1\") from samples 
		join view_samples_authcodes on (samples.\"SampleId\"= view_samples_authcodes.\"SampleId\" 
		and \"VerdictId\" is null and \"IsValidOverall\" is not null) where \"TimeStampedAt\" between 'yesterday' and 'today';";
my $sql1 = "SELECT uploaded from \"WhiteListing\".counter_uploads where daydate = 'today'::date and src =2";
my $sql = "select \"WhiteListing\".get_camdpams_source(?, ?)";
$sth2= $dbh->prepare($sql1);
$sth2->execute;
my $cnt =$sth2->fetchrow_array;
#print "cnt in WL: $cnt\n ";
$sth= $dbh->prepare($camdpams);
$sth->execute;
my $cnt_c = $sth->fetchrow_array;
$sth->finish;
$sth = $dbh->prepare($sql);
#print "cnt in camdpams:$cnt_c; cnt in WL: $cnt\n ";
if ($cnt_c<$cnt){
$sql1 = "SELECT uploaded from \"WhiteListing\".counter_uploads where daydate = 'yesterday'::date and src =2";
$sth2= $dbh->prepare($sql1);
$sth2->execute;
my $cnt_new =$sth2->fetchrow_array;
#print "new:$cnt_new\n";
if($cnt_new>$cnt){
#$dbh->do("update \"WhiteListing\".counter_uploads set uploaded = $cnt_new where daydate = 'today'::date and src =2;");
}
#print "$t_start\n";
$sth->execute($t_start,$t_stop);}
else{$sth->execute('yesterday','today');}
$sth->finish;
$dbh->commit;

$sth2->finish;
$dbh->commit;
$dbh->disconnect;
($sec,$min,$hour,$mday,$mon,$year,
           $wday,$yday,$isdst) = localtime time;
$year += 1900;           
my $stop = "$mday/$mon/$year $hour:$min:$sec";
open(OF,">>",$log);
print OF "$stop\timport_sha1_camdpams.pl complete\n";
close(OF);           
# mikew: wtf?
#print "1\n";