#!/usr/bin/perl

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


my $db1 = "hisdb";
my $host1 = "192.168.9.25";
my $db2 = "CAMDPAMS";
my $host2 = "192.168.9.10";
my $sth;
my $sth1;
my $sth2;
my $from = shift;
my $to  = shift;
my $off = shift;
#$dbh1 = DBI ->connect("dbi:Pg:dbname=$db1;host=$host1","okrotenko","lg414tnk",{AutoCommit=>0,RaiseError=>1,ChopBlanks=>1});
$dbh1 = DBI ->connect("dbi:Pg:dbname=$db1;host=$host1","flsuser","",{AutoCommit=>0,RaiseError=>1,ChopBlanks=>1});
$dbh2 = DBI ->connect("dbi:Pg:dbname=$db2;host=$host2","olegk","4Q2073gl",{AutoCommit=>0,RaiseError=>1,ChopBlanks=>1});
my $sql1 = "select hash from (select hash, frequency from (
		select hash, sum(distinct 1<<verdict_id) as verdict_id_flag, count(distinct ip) as frequency 
		from data where received between ? and ? group by hash) as topunknown where verdict_id_flag = 8 order 
		by frequency desc limit 500 offset ?) as sha1";
my $sql2 = "INSERT INTO \"WhiteListing\".\"FileSource\"(\"SHA1\", \"DateAdded\",\"SourceId\")
	    VALUES (?,now(),1)";
$sth1 = $dbh1->prepare($sql1);

$sth1->execute($from,$to,$off);
if ($sth1->rows >0)
{

  while(my @a=$sth1->fetchrow_array){
     $sth2 = $dbh2->prepare($sql2);
     $sth2->execute(@a[0]);
     $sth2->finish;	    
    # print "@a[0]\n";
  }
}  
$sth1->finish;
$dbh1->disconnect;
$dbh2->commit;

$sth2 = $dbh2->prepare("select \"WhiteListing\".get_file_info()");
$sth2->execute;
$sth2->finish;
$dbh2->commit;
$dbh2->disconnect;
# mikew: wtf?
#print "1\n";