<?php

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

date_default_timezone_set('Africa/Lagos'); 
$cnt = 1;
$cnt2=0;
//$mfrom = "info@chatme24.com";
//$mfromname = "Chatme24 Team";
while($cnt ==1){
    $query= "SELECT sn,emailsubject,emailbody,mailfrom,fromname FROM emaildetails where status ='0'  order by sn limit 1";
    $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
    {
      
      if($row = mysqli_fetch_array($result)){
      $sn = $row[0];
      $subject = $row[1];
      $emailbody =  $row[2];
      $mfrom = $row[3];
      $mfromname = $row[4];
      //$mfrom = "noreply@247sms.com";
      //$mfromname = "247sms Team";


       //$message =  str_replace('^',"'",$message);
       //echo "processing record" ."\n";
       //echo "email ". $email."\n";
       ///echo "subject " .$subject ."\n";
       //echo "body " .$emailbody ."\n";
      
      //check for individual emails
      
      //$query= "SELECT sn,email FROM emailrecipients where status ='0'  order by sn";
      
      $query= "SELECT sn,email,username FROM userlogin where sn =140 order by sn";
      //$query= "SELECT sn,email,username FROM userlogin where domain ='247sms.com' order by sn";
      $con2=mysqli_connect("127.0.0.1","smsEngine","guEnaR28T","smartsmsrouter");
        ///Check connection
      if (mysqli_connect_errno())
      {
           return '#';
           die();
      }
      if(!$result2= mysqli_query($con2,$query))
      {
         mysqli_close($con2);
        return "#";
      }
      else
      {
         
     
        while ($row2 = mysqli_fetch_array($result2))
        {
            
            $sn2 = $row2[0];
            $email = $row2[1];
            $username = $row2[2];
            //$message =  str_replace('^',"'",$message);
            $emailbody =  str_replace('#user#',$username,$emailbody);
            echo "processing record" ."\n";
            echo "email ". $email."\n";
            echo "subject " .$subject ."\n";
            echo "body " .$emailbody ."\n";
            
            //$email="jackson@tickwaves.co.uk";
            //send email
            echo "nosa " .$mfrom ."\n";
            $mymail = sendmailtoclient($email,$emailbody,$emailbody,$subject,$mfrom,$mfromname);

            //update the record
            $query = "update emaillastrecord set status ='$sn2'";
            $queryresponse = updateQuery($query);
            $cnt2++;
            echo "\nTotal email sents ... ".$cnt2 ."\n". date("Y-m-d h:i:s",time())."\n";
            sleep(60);

        }

      
      }
           
        // update the emaildetails
        $query = "update emaildetails set status ='1' where sn = $sn ";
        $queryresponse = updateQuery($query);
    }

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



?>