#!/usr/bin/perl

# - 

$botID = 2;


use DBI;

require "/etc/cherry/cherry.cfg";
require "/usr/lib/cherry/docflow/translate";

$dbh = DBI->connect("dbi:$CFG::DB_TYPE:dbname=$CFG::DB_NAME;host=$CFG::DB_HOST",
                    "$CFG::DB_USER",
                    "$CFG::DB_USER_PASSWORD",
                    { RaiseError => 1, AutoCommit => 1 });


$dbhRC = DBI->connect("dbi:Pg:dbname=rc;host=localhost",
                    "$CFG::DB_MASTER",
                    "$CFG::DB_MASTER_PASSWORD",
                    { RaiseError => 1, AutoCommit => 1 });



$sth=$dbh->prepare(qq{	
	SELECT DISTINCT docflow_docs.id ,
	docflow_types.name 
	FROM docflow_docs 
	LEFT JOIN docflow_bots ON docflow_docs.id=docflow_bots.doc  AND docflow_bots.bot=$botID
	JOIN docflow_types ON docflow_docs.type_=docflow_types.id
	JOIN docflow_states_run ON docflow_docs.current_state=docflow_states_run.state
	WHERE docflow_bots.doc IS NULL AND docflow_states_run.name=' ()   '
	AND docflow_types.name='   '
	});

$sth->execute;

while(my($doc,$doctypename)=$sth->fetchrow_array) {
	($log)=$dbh->selectrow_array(
		qq{SELECT MAX(docflow_logs.id)
		FROM docflow_logs  
		WHERE docflow_logs.doc=$doc 
		}
	);


        ($name)=$dbh->selectrow_array(
                qq{SELECT docflow_info_run.value
                FROM docflow_info_run WHERE doc=$doc AND name=' '
                }
        );


	($address)=$dbh->selectrow_array(
                qq{SELECT docflow_info_run.value
                FROM docflow_info_run WHERE doc=$doc AND name=' '
                }
        );


	$dbh->begin_work;

	open (DOC , "$CFG::BASE/docflow/bot2_act.tpl");
	while( <DOC>) {
		$tpl.=$_;
	}


	$tpl =~ s/\$name/$name/g;
	$tpl =~ s/\$address/$address/g;


        open (PIPE , "| /usr/lib/cherry/pglo \"host=$CFG::DB_HOST dbname=$CFG::DB_NAME user=$CFG::DB_USER password=$CFG::DB_USER_PASSWORD\" import") or die "Can't open pipe /usr/lib/cherry/pglo";
	
        print PIPE $tpl;
        close PIPE;

        $loid=$dbh->selectrow_array("SELECT MAX(loid) FROM pg_largeobject");
        $dbh->do("INSERT INTO docflow_data(name,log,data) VALUES ('-',$log,$loid)");

	$dbh->do("INSERT INTO docflow_bots(doc,bot) VALUES ($doc,$botID) ");

	$dbh->commit;


}
