#!/usr/bin/perl
use DBI;
use Time::Local;
use POSIX ":sys_wait_h";

$SIG{CHLD} = sub {wait ()};

#$num = "10";
my @childs;
#my $m = "mishu";

#pipe (B_IN, B_OUT);
#my $pid2 = fork();


   ###################### DATABASE CONNECTION #########################
   my $dbName = "abc";
   my $userName = "root";
   my $password = "";
   my $dbpath = "dbi:mysql:database=$dbName;host=localhost";
   my $dbh = DBI->connect($dbpath, $userName, $password) or die "Can't open database: $DBI::errstr";
   #####################################################################

   my %alreadyVisited;
   my $messageID;

   while(1)
   {
      my $query = "SELECT * FROM `transaction_log` WHERE status = '2'";
      my $qh = $dbh->prepare($query);
      $qh->execute();

      while(my $row = $qh->fetchrow_hashref())
      {
         $messageID = $row->{message_id};

         if(exists $alreadyVisited{$messageID})
         {
            #print $messageID." already exists in HASH \n";
            next;
         }
         else
         {
            #print $messageID." is a new one \n";
         }

         my $pid = fork();

         if($pid)
         {
            #parent
            #print "Child created with PID : ".$pid."\n";
            push(@childs, $pid);
         }
         elsif($pid == 0)
         {
            #child
            print $messageID."  is in child\n";
            sleep(10);
            updateStatus($messageID);
            #print "%%%%%%%%%%%%%%%%%%%%%%%%%%	\n";
            exit(0);
         }
         else
         {
            print "Could not fork \n";
         }
         $alreadyVisited{$messageID} = $row->{name};
      }
      sleep(1);
      
      foreach (@childs)
      {
         waitpid($_, WNOHANG);
      }
   }

   print "LAST MSG ID is : ".$messageID."\n";

   if($dbh->disconnect())
   {
      print "hello \n";
   }
   print "going to terminate child one \n";
   #exit(0);

sub updateStatus
{
   ###################### DATABASE CONNECTION #########################
   my $dbName = "abc";
   my $userName = "root";
   my $password = "";
   my $dbpath = "dbi:mysql:database=$dbName;host=localhost";
   my $dbh2 = DBI->connect($dbpath, $userName, $password) or die "Can't open database: $DBI::errstr";
   #####################################################################

   my $ID = $_[0];

   print $ID."****\n";
   my $query2 = "UPDATE `transaction_log` SET status = '7' WHERE status = '2' AND message_id = '".$ID."'";
   my $qh2 = $dbh2->prepare($query2);
   if($qh2->execute() eq 1)
   {
      print $ID." has been updated to 7\n";
   }
   else
   {
      print "Failed to update ID is : ".$ID."\n";
   }


   $dbh2->disconnect();
}

use strict;
use warnings;

#!/usr/bin/perl

use strict;