use Oraperl;
use DBI;
use strict;
use DBD::Oracle qw(:ora_types);
use Time::Local;
use POSIX;


my @SharedPlanAccts=();
my $lda = "";
my $two_task = "";
my $pid=$$;
my $todays_date = `date +\%Y\%m\%d`;
my $curr_time = `date +\%H\%M\%S`;
my $noOfInputDomainsRunning = 0;
my $APIDomainIndex = 0;
my ($i1, $k1, $j1) = 0;
my @pids;
my $totalAccts = 0;
my $acctsPerChild = 0;
my $n = 10;

openLogFile();
LoginDB();
fetchAccounts();




for( $i1=1; $i1 <= $n; $i1++ )
{
    $pids[$k1] = fork();
    if ( $pids[$k1] == 0 ) 
    {
		$lda->{InactiveDestroy} = 1;
		ProcessRecords( @SharedPlanAccts, $i1, $n, $totalAccts );
		exit(0);
    }
    else
    {
        $k1++;
    }
}

foreach (@pids)
{
    #parent process waits here until all child process goes down
    waitpid($_,0);
}


LogoffDB();
sub openLogFile 
{
	my $p2klogs = $ENV{"LOGS"};

	my $log_file	= $p2klogs . "/" . $prog_name ."_" . $todays_date .	$curr_time ."_".$$.".log";	

	unless (	open (LOGF,">>$log_file") )
	{
		print ("Open append failed	for	log	file = $log_file\n");
		print ("$prog_name	process	terminated abnormally.\n");
		exit 1;
	}
}


sub	LoginDB()
{
	my ( $db_user, $db_pswd	);

	$two_task =	$ENV{"TWO_TASK"};
	$db_user = $ENV{"DB_USER_NAME"};
	$db_pswd = $ENV{"DB_PASSWORD"};

	#--	connect	to database
	if	( $db_user eq "/" ){
	$lda = DBI->connect("DBI:Oracle:" .	$two_task )
			   || logDBIError ("logon to Oracle	failed");
	}
	else{
	$lda	= DBI->connect("DBI:Oracle:" . $two_task, $db_user,	$db_pswd);
			
	}
}

sub LogoffDB()
{
	$lda->disconnect || logDBIError("Failed to disconnect database handle");

	logMessage ("The $prog_name process successfully completed ");

	close(LOGF);
}
sub fetchAccounts()
{
		my $res = $lda->prepare(" select distinct acct_nbr  acct_asgm ");
		if(defined($res))
		{

			$res->execute();
			while (my @row = $res->fetchrow_array()  ) 
			{
				push(@SharedPlanAccts,@row);
			}
		}
		else
		{
			logMessage("Could not execute the query!");
		}
		$totalAccts = @SharedPlanAccts;
		logMessage ( "Total Number of accts under validation : $totalAccts ");

$acctsPerChild =  floor ($totalAccts/$n );
logMessage ("Each child process around $acctsPerChild accounts ");

}
sub ProcessRecords()
{
		my ( @acctArray,$myNbr,$totalChilds,$totalAccts) = @_;
		my $begIndex = 0;
		my $endIndex = 0;
		my $acctsProcessed = 0;
		openLogFile();
		LoginDB();

		$begIndex = ($acctsPerChild * $myNbr ) - $acctsPerChild;
		$endIndex = ($acctsPerChild * $myNbr ) - 1;
	    
		if ( $myNbr == $n )
		{
			$endIndex = $totalAccts - 1;
		}

		my @acctList = @acctArray[$begIndex .. $endIndex];
		


		foreach   my $a   (@acctList) 
		{
			logMessage ("Acct Under Validation  : $a  ");
			if( defined ($a) )
			{
				my $found = 0;
				my ( $AcctNbr, $CycCd, $CycEndDt  );
				my $dly1 = $lda ->prepare("select acct_nbr,cycle_cd,cycle_end_dt  from Daily1 where acct_nbr= ? and rownum <2 order by cycle_end_dt ");
				my $dly2 = $lda ->prepare("select acct_nbr,cycle_cd,cycle_end_dt  from Daily2 where acct_nbr= ?  and rownum < 2  order by cycle_end_dt ");
				$dly1->bind_param(1,$a);
				$dly2->bind_param(1,$a);

				$dly1->execute();
				$dly1->bind_col(1,\$AcctNbr);
				$dly1->bind_col(2,\$CycCd);
				$dly1->bind_col(3,\$CycEndDt);
				$acctsProcessed=$acctsProcessed + 1;
				while ( $dly1->fetch) 
				{
					$found++;
					rerateandupdate($AcctNbr,$CycCd,$CycEndDt);
					last;
				}

				if ($found == 0) 
				{
					$dly2->execute();

					$dly2->bind_col(1,\$AcctNbr);
					$dly2->bind_col(2,\$CycCd);
					$dly2->bind_col(3,\$CycEndDt);

					while ( $dly2->fetch ) 
					{
						rerateandupdate($AcctNbr,$CycCd,$CycEndDt);
						last;
					}

				}
			}
		}
		logMessage ("Total Number of Accts processed : $acctsProcessed ");
		LogoffDB();
	
}
sub rerateandupdate 
{

logMessage ("Acct rerated ");
}
sub logMessage
{
	my($message) = shift;
	my $log_date = `date +%m/%d/%Y`;
	my $log_time = `date +%T`;
	chop($log_date,	$log_time);
	print LOGF ("$log_date:$log_time |	$message\n");
}