<?php

include "../general.php";
include "../connect.php";

date_default_timezone_set('Africa/Lagos'); 
$cnt = 1;
while($cnt ==1){


    $query= "SELECT sn,transid,username,bookname,message,domain,sender,flag FROM messagesentaddressbook where status ='0' limit 1";
    //echo $query;
     //$cnt ="#";

       $con=mysqli_connect("127.0.0.1","smsEngine","guEnaR28T","smartsmsrouter");
       ///Check connection
    if (mysqli_connect_errno())
    {
         // //echo mysqli_error($con);
         //echo "-1";
         return '#';
         die();
    }
    if(!$result= mysqli_query($con,$query))
    {
       mysqli_close($con);
     return "#";
    }
    else
    {
   
    while($row = mysqli_fetch_array($result))
    {
        
        $sn = $row[0];
        $transid = $row[1];
        $username = $row[2];
        $bookname = $row[3];
        $message =  $row[4];
        $domain = $row[5];
        $sender =  $row[6];
        $flag = $row[7];

        $books = explode(",",$bookname);

        $cnt2=0;
        foreach($books as $book){
            $transidsub = $transid . $cnt2;

            $temp = $domain;
            $temp = str_replace(".com", "",$temp) ;
            $query = "Select distinct phonenumber,field1,field2,field3,field4,field5 from addressbook".$temp." where username='$username' and bookname='$book' and domain='$domain'";
            $query = str_replace("'","^",$query);
            //insert into database.
        
            $query = "Insert into processaddressbook(query,transidsub,username,message,sender,flag,domain) values ('$query','$transidsub','$username','$message','$sender','$flag','$domain')";
            $queryresponse = updateQuery($query);

            //update the record

           //
           
           echo "\n".$query."\n";

           $cnt2++;
           sleep(15);
     
        }

         //update the record
        $query = "update messagesentaddressbook set status ='1' where sn = $sn ";
        $queryresponse = updateQuery($query);
        
        sleep(15);
       
    }//end  of while  loop 

} //else
    
    


    echo "\nWaiting next Addressbook operation...". date("Y-m-d h:i:s",time())."\n";
    sleep(15);
   
}//end main while


?>