<?php

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

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


    $query= "SELECT sn,query,transidsub,username,message,domain,sender,flag FROM processaddressbook 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))
    {
       
        //echo "Moses";
        $sn = $row[0];
        $query = $row[1];
        $transid = $row[2];
        $username = $row[3];
        $message =  $row[4];
        $domain = $row[5];
        $sender =  $row[6];
        $flag = $row[7];

        $query = str_replace("^","'",$query);
        //call a executequery function   
        //echo "after" ."\n";
        //echo $query;
        //executeQuery($query,);
        //sleep(5);
        //echo "Nosa.....".$query;
       
        if(!$result2= mysqli_query($con,$query))
        {
             echo "\nInner error****** ".  mysqli_error($con);
        }
        else
        {
          //    echo "Praise";
            while($row2 = mysqli_fetch_array($result2))
            {
               
            //    echo "Mon";
                $phone = $row2[0];
                $field1 = $row2[1];
                $field2 = $row2[2];
                $field3 = $row2[3];
                $field4 = $row2[4];
                $field5 = $row2[5];
                $phone = trim($phone);
                $mess1 = $message;
                if ($flag == "1")
                    {
                                
                        $mess1 = str_replace("#donteditinputfield1#", $field1,$mess1);
                        $mess1 = str_replace("#donteditinputfield2#", $field2,$mess1);
                        $mess1 = str_replace("#donteditinputfield3#", $field3,$mess1);
                        $mess1 = str_replace("#donteditinputfield14", $field4,$mess1);
                        $mess1 = str_replace("#donteditinputfield15", $field5,$mess1);
                    }
                    
              //      echo "Nosa";
                    $query = "insert into messagesent (transid,username,phonenumber,message,sender,domain,sentcode,billcode,messtype) values ('$transid','$username','$phone','$mess1','$sender','$domain','0','0','1')";
                //    echo $query;
                    $queryresponse = updateQuery($query);
                    echo "\n$query\n";
                    sleep(2);

            }//end while
        }//end else




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

} //else
    
    


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


?>