<?

include "../classes/db.class.php";
include "../classes/email.class.php";

$db = new db();
$email_class = new email();

$res = $db->exec_query('warning_events', ['*'], '', '', '', '', "sent = 0");
if ($res->num_rows > 0) {

    while ($event = $res->fetch_assoc()) {

        echo $event_type = $event['event_type'];
        echo $message = $event['event_message'];
        echo $asset_record_id = $event['asset_id'];

        $farm_find = $db->exec_query('assets', ['*'], '', '', '', '', "record_id = $asset_record_id");
        $asset_info = $farm_find->fetch_assoc();
        $farm_id = $asset_info['farm_id'];

        $email_list = $db->exec_query('emails', ['*'], '', '', '', '', "(farm_id = $farm_id OR farm_id = 0) AND (event_types = 'ALL' OR event_types = 'WARNINGS')");
        while ($email = $email_list->fetch_assoc()) {

            $emails[] =  $email['email'];
            $names[] =  $email['name'];
        }

        if($email_class->send_mail($emails, $names, $message)){
            $db->Update('warning_events',['sent'],['1'],"record_id = {$event['record_id']}");
            echo 'SENT';
        }else{
            echo $email_class->send_mail($emails, $names, $message);
        }
    }
}