<?php
if( !isset( $_GET['token'] ) || ( isset( $_GET['token'] ) && $_GET['token'] != "eFD6dx2G4RFBkrYS7Z87" ) ) die();

require_once("../includes/config.inc.php");

global $oData;

$mysql = new MysqliDb( MYSQL_HOST, MYSQL_USER, MYSQL_PASS, MYSQL_DB );


$arrMails = $oData->rawQuery("
    SELECT
        message_id,
        message_invoice,
        message_template
    FROM pacim_messages
    WHERE message_status = 0
        AND message_template IN (1,3,4,5,8,9,10)
    LIMIT 1
");

//print_r($arrMails);
//die();

if(!empty($arrMails)) {
    foreach($arrMails as $message) {


        sleep(1);
        if( in_array( $message['message_template'], array(3,4,5) ) ) {
            $oData->dataset( $message['message_invoice'] );
            sleep(1.5);
        }

        //open connection
        //$ch = curl_init(SITE_URL . "/ajax_request.php?token=" . $_GET['token'] . "&mail_id=" . $message['message_id']);
        //curl_setopt( $ch, CURLOPT_POST, 1 );
        //curl_setopt( $ch, CURLOPT_POSTFIELDS, array('mail_id' => $message['message_id']));
        //$result = curl_exec( $ch );
        //curl_close($ch);

	$callURL = SITE_URL . "/ajax_request.php?token=" . $_GET['token'] . "&mail_id=" . $message['message_id'];
	//$result = file_get_contents( $callURL );
	//$callURL = SITE_URL . "/testpage.php";


//open connection
//$ch = curl_init( $callURL );
//curl_setopt( $ch, CURLOPT_POST, count( $mailData ) );
//curl_setopt( $ch, CURLOPT_POSTFIELDS, $mailData );

//execute post
//$result = curl_exec( $ch );

//close connection
//curl_close($ch);



        //$mysql->where('message_id', $message['message_id']);
        //$mysql->update('pacim_messages', array('message_status' => 1));
    }

    echo $callURL . "<hr />" . $result . "<hr />";
    echo count($arrMails) . " Mails versendet";
} else {
    echo "keine Mails zu versenden";
}