query("event_handler", "SELECT * FROM `event_handler` WHERE `sent` = 0"); while ($row = $res->fetch_assoc()) { $email = new email(); $users_involved = explode(",", $row['user_ids']); $emails = []; $names = []; foreach ($users_involved as $user_id) { $user_data = $db->query("users", "SELECT * FROM `users` WHERE `record_id` = '$user_id'"); if ($user_data->num_rows > 0) { $user_data = $user_data->fetch_assoc(); $emails[] = $user_data['email']; $names[] = $user_data['username']; } } $email->send_mail( $emails, $names, "" . $row['body'] . "", $row['subject'], ); $db->query("event_handler", "UPDATE `event_handler` SET `sent` = 1, `date_time_sent` = NOW() WHERE `record_id` = '{$row['record_id']}'"); }