<?php

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

date_default_timezone_set('Africa/Lagos'); 
$cnt = 1;
$cnt2=0;
while($cnt ==1){
    $query= "SELECT sn,message_id,status,status_code,status_text,error_code FROM clicksendlogs where flag ='0' order by sn limit 1";
    //echo $query;
    $con=mysqli_connect("127.0.0.1","smsEngine","guEnaR28T","smartsmsrouter");
       ///Check connection
    if (mysqli_connect_errno())
    {
         return '#';
         die();
    }
    if(!$result= mysqli_query($con,$query))
    {
       mysqli_close($con);
     return "#";
    }
    else
    {
        
       while ($row = mysqli_fetch_array($result))
        {
            
            $sn = $row[0];
            $message_id = $row[1];
            $status =  $row[2];
            $status_code =  Trim($row[3]);
            $status_text =  $row[4];
            $error_code =  $row[5];
            echo "Processing Status" ."\n";
            echo "Messageid ". $message_id."\n";
            echo "Status " .$status ."\n";
           
            //echo $status_code;
            //echo strlen($status_code);
             //update the messagesent
            if($status_code =="201"){
             
             //update the record
             $query = "update messagesent set status ='$status',failurereason='$status_text',failurecode='$error_code',track='2' where messageid = '$message_id' ";
             $queryresponse = updateQuery($query);
           
            //update the record
              $query = "update clicksendlogs set flag ='1' where sn = $sn ";
              $queryresponse = updateQuery($query);
              $cnt2++;             
 
            }else{
              //echo $query;
              $query = "update clicksendlogs set flag ='1' where sn = $sn ";
              $queryresponse = updateQuery($query);
              

              
            }
        
        sleep(5);
       
        }

      } //else
    
    


    echo "\nTotal Status Messages updated ... ".$cnt2 ."\n". date("Y-m-d h:i:s",time())."\n";
    sleep(15);
   
}//end main while


?>