<?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 5
");

//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']);
        curl_setopt( $ch, CURLOPT_POST, 1 );
        curl_setopt( $ch, CURLOPT_POSTFIELDS, array('mail_id' => $message['message_id']));
        $result = curl_exec( $ch );
        curl_close($ch);

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

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