<?php

if (!class_exists('wpmlHistory')) {
    class wpmlHistory extends wpmlDbHelper
    {
        public $id;
        public $subject;
        public $message;
        public $list_id;
        public $theme_id = 0;
        public $group;
        public $attachment;
        public $attachmentfile;
        public $error = array();
        public $model = 'History';
        public $controller = 'history';
        public $table_name = 'wpmlhistory';
        public $from;
        public $fromname;
        public $text;
        public $language;
        public $preheader;
        public $spamscore;
        public $mailinglists;
        public $status;
        public $state;
        public $groups;
        public $roles;
        public $condquery;
        public $conditions;
        public $conditionsscope;
        public $daterange;
        public $daterangefrom;
        public $daterangeto;
        public $countries;
        public $selectedcountries;
        public $sent;
        public $post_id;
        public $p_id;
        public $user_id;
        public $senddate;
        public $recurring;
        public $recurringvalue;
        public $recurringinterval;
        public $recurringdate;
        public $recurringlimit;
        public $recurringsent;
        public $scheduled;
        public $format;
        public $builderon;
        public $grapejs_content;
        public $using_grapeJS;
        public $created;
        public $modified;
        public $attachments;
        public $recursive;

        public $table_fields = array(
            'id'				=> 	"INT(11) NOT NULL AUTO_INCREMENT",
            'from'				=>	"VARCHAR(150) NOT NULL DEFAULT ''",
            'fromname'			=> 	"VARCHAR(150) NOT NULL DEFAULT ''",
            'subject'			=>	"VARCHAR(255) NOT NULL DEFAULT ''",
            'message'			=>	"LONGTEXT NOT NULL",
            'text'				=>	"LONGTEXT NOT NULL",
            'language'			=>	"VARCHAR(20) NOT NULL DEFAULT ''",
            'preheader'			=>	"VARCHAR(100) NOT NULL DEFAULT ''",
            'spamscore'			=>	"VARCHAR(20) NOT NULL DEFAULT ''",
            'mailinglists'		=>	"TEXT NOT NULL",
            'status'			=>	"VARCHAR(50) NOT NULL DEFAULT 'active'",	// subscriber status
            'state'				=>	"VARCHAR(50) NOT NULL DEFAULT 'created'",
            'groups'			=>	"TEXT NOT NULL",
            'roles'				=>	"TEXT NOT NULL",
            'theme_id'			=>	"INT(11) NOT NULL DEFAULT '0'",
            'condquery'			=>	"TEXT NOT NULL",
            'conditions'		=>	"TEXT NOT NULL",
            'conditionsscope'	=>	"VARCHAR(50) NOT NULL DEFAULT 'all'",
            'daterange'			=>	"ENUM('Y','N') NOT NULL DEFAULT 'N'",
            'daterangefrom'		=>	"VARCHAR(50) NOT NULL DEFAULT ''",
            'daterangeto'		=>	"VARCHAR(50) NOT NULL DEFAULT ''",
            'countries'			=>	"INT(1) NOT NULL DEFAULT '0'",
            'selectedcountries'	=>	"TEXT NOT NULL",
            'sent'				=>	"INT(11) NOT NULL DEFAULT '0'",
            'post_id'			=>	"INT(11) NOT NULL DEFAULT '0'",
            'p_id'				=>	"INT(11) NOT NULL DEFAULT '0'",
            'user_id'			=>	"INT(11) NOT NULL DEFAULT '0'",
            'senddate'			=>	"DATETIME NOT NULL DEFAULT '0000-00-00 00:00:00'",
            'recurring'			=>	"ENUM('Y','N') NOT NULL DEFAULT 'N'",
            'recurringvalue'	=>	"INT(11) NOT NULL DEFAULT '0'",
            'recurringinterval'	=>	"VARCHAR(20) NOT NULL DEFAULT ''",
            'recurringdate'		=>	"DATETIME NOT NULL DEFAULT '0000-00-00 00:00:00'",
            'recurringlimit'	=>	"INT(11) NOT NULL DEFAULT '0'",
            'recurringsent'		=>	"INT(11) NOT NULL DEFAULT '0'",
            'scheduled'			=>	"ENUM('Y','N') NOT NULL DEFAULT 'N'",
            'format'			=>	"ENUM('html','text') NOT NULL DEFAULT 'html'",
            'builderon'         =>  "INT(1) NOT NULL DEFAULT '0'",
            'grapejs_content'	=>	"LONGTEXT NULL",
            'using_grapeJS'	    =>	"INT(1) NOT NULL DEFAULT '0'",
            'created'			=>	"DATETIME NOT NULL DEFAULT '0000-00-00 00:00:00'",
            'modified'			=>	"DATETIME NOT NULL DEFAULT '0000-00-00 00:00:00'",
            'key'				=>	"PRIMARY KEY (`id`), INDEX(`theme_id`), INDEX(`sent`), INDEX(`post_id`), INDEX(`user_id`)",
        );

        public $tv_fields = array(
            'id'				=> 	array("INT(11)", "NOT NULL AUTO_INCREMENT"),
            'from'				=>	array("VARCHAR(150)", "NOT NULL DEFAULT ''"),
            'fromname'			=>	array("VARCHAR(150)", "NOT NULL DEFAULT ''"),
            'subject'			=>	array("VARCHAR(255)", "NOT NULL DEFAULT ''"),
            'message'			=>	array("LONGTEXT", "NOT NULL"),
            'text'				=>	array("LONGTEXT", "NOT NULL"),
            'language'			=>	array("VARCHAR(20)", "NOT NULL DEFAULT ''"),
            'preheader'			=>	array("VARCHAR(100)", "NOT NULL DEFAULT ''"),
            'spamscore'			=>	array("VARCHAR(20)", "NOT NULL DEFAULT ''"),
            'mailinglists'		=>	array("TEXT", "NOT NULL"),
            'status'			=>	array("VARCHAR(50)", "NOT NULL DEFAULT 'active'"),
            'state'				=>	array("VARCHAR(50)", "NOT NULL DEFAULT 'created'"),
            'groups'			=>	array("TEXT", "NOT NULL"),
            'roles'				=>	array("TEXT", "NOT NULL"),
            'theme_id'			=>	array("INT(11)", "NOT NULL DEFAULT '0'"),
            'condquery'			=>	array("TEXT", "NOT NULL"),
            'conditions'		=>	array("TEXT", "NOT NULL"),
            'conditionsscope'	=>	array("VARCHAR(50)", "NOT NULL DEFAULT 'all'"),
            'daterange'			=>	array("ENUM('Y','N')", "NOT NULL DEFAULT 'N'"),
            'daterangefrom'		=>	array("VARCHAR(50)", "NOT NULL DEFAULT ''"),
            'daterangeto'		=>	array("VARCHAR(50)", "NOT NULL DEFAULT ''"),
            'countries'			=>	array("INT(1)", "NOT NULL DEFAULT '0'"),
            'selectedcountries'	=>	array("TEXT", "NOT NULL"),
            'sent'				=>	array("INT(11)", "NOT NULL DEFAULT '0'"),
            'post_id'			=>	array("INT(11)", "NOT NULL DEFAULT '0'"),
            'p_id'				=>	array("INT(11)", "NOT NULL DEFAULT '0'"),
            'user_id'			=>	array("INT(11)", "NOT NULL DEFAULT '0'"),
            'senddate'			=>	array("DATETIME", "NOT NULL DEFAULT '0000-00-00 00:00:00'"),
            'recurring'			=>	array("ENUM('Y','N')", "NOT NULL DEFAULT 'N'"),
            'recurringvalue'	=>	array("INT(11)", "NOT NULL DEFAULT '0'"),
            'recurringinterval'	=>	array("VARCHAR(20)", "NOT NULL DEFAULT ''"),
            'recurringdate'		=>	array("DATETIME", "NOT NULL DEFAULT '0000-00-00 00:00:00'"),
            'recurringlimit'	=>	array("INT(11)", "NOT NULL DEFAULT '0'"),
            'recurringsent'		=>	array("INT(11)", "NOT NULL DEFAULT '0'"),
            'scheduled'			=>	array("ENUM('Y','N')", "NOT NULL DEFAULT 'N'"),
            'format'			=>	array("ENUM('html','text')", "NOT NULL DEFAULT 'html'"),
            'builderon'         =>  array("INT(1)", "NOT NULL DEFAULT '0'"),
            'grapejs_content'	=>	array("LONGTEXT", "NULL"),
            'using_grapeJS'	    =>	array("INT(1)", "NOT NULL DEFAULT '0'"),
            'created'			=>	array("DATETIME", "NOT NULL DEFAULT '0000-00-00 00:00:00'"),
            'modified'			=>	array("DATETIME", "NOT NULL DEFAULT '0000-00-00 00:00:00'"),
            'key'				=>	"PRIMARY KEY (`id`), INDEX(`theme_id`), INDEX(`sent`), INDEX(`post_id`), INDEX(`user_id`)",
        );

        public $indexes = array('theme_id', 'sent', 'post_id', 'user_id');

        public function __construct($data = array())
        {
            global $Db, $HistoriesList, $Mailinglist, $HistoriesAttachment;

            parent::__construct();

            $this -> table = $this -> pre . $this -> controller;

            if (!empty($data)) {
                foreach ($data as $key => $val) {
                    $this -> {$key} = stripslashes_deep($val);

                    switch ($key) {
                        case 'groups':
                            $this -> groups = maybe_unserialize($val);
                            break;
                    }
                }

                /* Attachments */
                $this -> attachments = array();
                $Db -> model = $HistoriesAttachment -> model;
                if ($attachments = $Db -> find_all(array('history_id' => $this -> id))) {
                    foreach ($attachments as $attachment) {
                        $this -> attachments[] = array(
                            'id'					=>	$attachment -> id,
                            'title'					=>	$attachment -> title,
                            'filename'				=>	$attachment -> filename,
                            'subdir'				=>	$attachment -> subdir,
                        );
                    }
                }

                /* Mailing Lists */
                $this -> mailinglists = array();
                $Db -> model = $HistoriesList -> model;

                if ($historieslists = $Db -> find_all(array('history_id' => $this -> id))) {
                    foreach ($historieslists as $hl) {
                        $Db -> model = $Mailinglist -> model;

                        if ($list = $Db -> find(array('id' => $hl -> list_id))) {
                            $this -> mailinglists[] = $hl -> list_id;
                        }
                    }
                }
            }

            $Db -> model = $this -> model;
            return true;
        }

        public function queue_recurring()
        {
            global $wpdb, $Db, $Field, $Mailinglist, $Subscriber, $Unsubscribe, $Bounce, $SubscribersList;

            $recurring_queued = 0;

            $query = "SELECT * FROM " . $wpdb -> prefix . $this -> table . " WHERE `recurring` = 'Y' 
			AND (`recurringlimit` = '' OR `recurringlimit` = '0' OR `recurringlimit` > `recurringsent`) 
			AND (`recurringdate` <= '" . date_i18n("Y-m-d H:i:s") . "')";

            $query_hash = md5($query);
            if ($ob_histories = $this -> get_cache($query_hash)) {
                $histories = $ob_histories;
            } else {
                $histories = $wpdb -> get_results($query);
                $this -> set_cache($query_hash, $histories);
            }

            do_action('newsletters_queue_recurring_start', $histories);

            if (!empty($histories)) {
                foreach ($histories as $history) {
                    $this -> remove_server_limits();
                    $mailinglists = maybe_unserialize($history -> mailinglists);
                    $roles = maybe_unserialize($history -> roles);
                    $fieldsconditions = maybe_unserialize($history -> conditions);
                    $condquery = maybe_unserialize($history -> condquery);
                    $subscriberids = array();
                    $subscriberemails = array();

                    if (!empty($mailinglists) || !empty($roles)) {
                        $m = 1;
                        if (!empty($mailinglists)) {
                            $mailinglistscondition = "(";
                            foreach ($mailinglists as $mailinglist_id) {
                                $mailinglistscondition .= "list_id = '" . esc_sql($mailinglist_id) . "'";
                                if ($m < count($mailinglists)) {
                                    $mailinglistscondition .= " OR ";
                                }
                                $m++;
                            }
                        }

                        $fields = array_filter($fieldsconditions);
                        $scopeall = (empty($history -> conditionsscope) || $history -> conditionsscope == "all") ? true : false;
                        $fieldsquery = $Subscriber -> get_segmented_query($fields, $scopeall, $condquery);

                        if (!empty($history -> daterange) && $history -> daterange == "Y") {
                            if (!empty($history -> daterangefrom) && !empty($history -> daterangeto)) {
                                $daterangefrom = date_i18n("Y-m-d H:i:s", strtotime($history -> daterangefrom));
                                $daterangeto = date_i18n("Y-m-d H:i:s", strtotime($history -> daterangeto));
                                $fieldsquery .= " AND (" . $wpdb -> prefix . $Subscriber -> table . ".created >= '" . $daterangefrom . "' AND " . $wpdb -> prefix . $Subscriber -> table . ".created <= '" . $daterangeto . "')";
                            }
                        }

                        // Countries
                        if (!empty($history -> countries)) {
                            if (!empty($history -> selectedcountries) && is_array($history -> selectedcountries)) {
                                $countries = implode("', '", $history -> selectedcountries);
                                $fieldsquery .= " AND (" . $wpdb -> prefix . $Subscriber -> table . ".country IN ('" . $countries . "'))";
                            }
                        }

                        /* Attachments */
                        $Db -> model = $this -> model;
                        $history = $Db -> find(array('id' => $history -> id));

                        $query = "SELECT DISTINCT " . $wpdb -> prefix . $Subscriber -> table . ".id, "
                            . $wpdb -> prefix . $Subscriber -> table . ".email FROM "
                            . $wpdb -> prefix . $Subscriber -> table . " LEFT JOIN "
                            . $wpdb -> prefix . $SubscribersList -> table . " ON "
                            . $wpdb -> prefix . $Subscriber -> table . ".id = " . $wpdb -> prefix . $SubscribersList -> table . ".subscriber_id";

                        if (!empty($mailinglistscondition)) {
                            $query .= " WHERE " . $mailinglistscondition . ")";
                        }

                        $query .= " AND " . $wpdb -> prefix . $SubscribersList -> table . ".active = 'Y'"
                            . str_replace(" AND ()", "", $fieldsquery);

                        $recurringdate = date_i18n("Y-m-d H:i:s", strtotime($history -> recurringdate . " +" . $history -> recurringvalue . " " . $history -> recurringinterval));
                        $recurringsent = ($history -> recurringsent + 1);
                        $sent = ($history -> sent + 1);

                        $Db -> model = $this -> model;
                        $Db -> save_field('scheduled', "N", array('id' => $history -> id));
                        $Db -> model = $this -> model;
                        $Db -> save_field('recurringdate', $recurringdate, array('id' => $history -> id));
                        $Db -> model = $this -> model;
                        $Db -> save_field('recurringsent', $recurringsent, array('id' => $history -> id));
                        $Db -> model = $this -> model;
                        $Db -> save_field('sent', $sent, array('id' => $history -> id));

                        $queue_process_counter_1 = 0;
                        $queue_process_counter_2 = 0;
                        $queue_process_counter_3 = 0;
                        $queue_process = 1;
                        $this -> qp_reset_data();

                        // Send to user roles?
                        if (!empty($roles)) {
                            $exclude_users_query = "SELECT GROUP_CONCAT(`user_id`) FROM `" . $wpdb -> prefix . $Unsubscribe -> table . "` WHERE `user_id` != '0'";
                            $exclude_users = $wpdb -> get_var($exclude_users_query);
                            $exclude_users = (!empty($exclude_users)) ? array_filter(array_map('intval', explode(',', $exclude_users))) : array();

                            $role_chunk_size = (int) apply_filters('newsletters_queue_role_chunk_size', 200);
                            $role_chunk_size = max(50, $role_chunk_size);

                            foreach ($roles as $role_key) {
                                $role_offset = 0;

                                do {
                                    $users_arguments = array(
                                        'blog_id'  => $GLOBALS['blog_id'],
                                        'role'     => $role_key,
                                        'exclude'  => $exclude_users,
                                        'fields'   => array('ID', 'user_email', 'user_login'),
                                        'number'   => $role_chunk_size,
                                        'offset'   => $role_offset,
                                    );

                                    $role_users = get_users($users_arguments);

                                    if (empty($role_users)) {
                                        break;
                                    }

                                    foreach ($role_users as $user) {
                                        $this -> remove_server_limits();

                                        $queue_process_data = array(
                                            'user_id'    => (int) $user -> ID,
                                            'history_id' => (int) $history -> id,
                                        );

                                        $this -> {'queue_process_' . $queue_process} -> push_to_queue($queue_process_data);

                                        ${'queue_process_counter_' . $queue_process}++;
                                        if (${'queue_process_counter_' . $queue_process} >= $this -> {'queue_process_' . $queue_process} -> counter_reset) {
                                            $this -> {'queue_process_' . $queue_process} -> save();
                                            $this -> {'queue_process_' . $queue_process} -> reset_data();
                                            ${'queue_process_counter_' . $queue_process} = 0;
                                        }

                                        $queue_process++;
                                        if ($queue_process > $this -> newsletters_get_number_of_emails_on_intervals_statement()) {
                                            $queue_process = 1;
                                        }
                                    }

                                    if (function_exists('gc_collect_cycles')) {
                                        gc_collect_cycles();
                                    }

                                    $role_offset += $role_chunk_size;

                                } while (count($role_users) === $role_chunk_size);
                            }
                        }

                        if (!empty($mailinglists)) {
                            $subscriber_chunk_size = (int) apply_filters('newsletters_queue_subscriber_chunk_size', 200);
                            $subscriber_chunk_size = max(100, $subscriber_chunk_size);

                            $base_query = $query . " ORDER BY " . $wpdb -> prefix . $Subscriber -> table . ".id ASC";
                            $subscriber_offset = 0;

                            do {
                                $limited_query = $base_query . sprintf(
                                    " LIMIT %d OFFSET %d",
                                    $subscriber_chunk_size,
                                    $subscriber_offset
                                );

                                $subscribers = $wpdb -> get_results($limited_query);

                                if (empty($subscribers)) {
                                    break;
                                }

                                foreach ($subscribers as $subscriber) {
                                    $this -> remove_server_limits();

                                    $queue_process_data = array(
                                        'subscriber_id' => (int) $subscriber -> id,
                                        'history_id'    => (int) $history -> id,
                                    );

                                    $this -> {'queue_process_' . $queue_process} -> push_to_queue($queue_process_data);

                                    ${'queue_process_counter_' . $queue_process}++;
                                    if (${'queue_process_counter_' . $queue_process} >= $this -> {'queue_process_' . $queue_process} -> counter_reset) {
                                        $this -> {'queue_process_' . $queue_process} -> save();
                                        $this -> {'queue_process_' . $queue_process} -> reset_data();
                                        ${'queue_process_counter_' . $queue_process} = 0;
                                    }

                                    $queue_process++;
                                    if ($queue_process > $this -> newsletters_get_number_of_emails_on_intervals_statement()) {
                                        $queue_process = 1;
                                    }

                                    $recurring_queued++;
                                }

                                if (function_exists('gc_collect_cycles')) {
                                    gc_collect_cycles();
                                }

                                if (function_exists('gc_mem_caches')) {
                                    gc_mem_caches();
                                }

                                unset($subscribers);

                                $subscriber_offset += $subscriber_chunk_size;

                            } while (count($subscribers ?? array()) === $subscriber_chunk_size);
                        }

                        $this -> qp_save();
                        $this -> qp_dispatch();
                    }
                }
            }

            echo sprintf(__('%s recurring emails queued', 'wp-mailinglist'), $recurring_queued) . '<br/>';

            return true;
        }

        public function queue_scheduled()
        {
            global $wpdb, $Db, $Field, $Mailinglist, $Unsubscribe, $Bounce, $Subscriber, $SubscribersList;

            $query = "SELECT * FROM " . $wpdb -> prefix . $this -> table . " WHERE `senddate` <= '" . date_i18n("Y-m-d H:i:s") . "' AND `scheduled` = 'Y'";

            $query_hash = md5($query);
            if ($ob_histories = $this -> get_cache($query_hash)) {
                $histories = $ob_histories;
            } else {
                $histories = $wpdb -> get_results($query);
                $this -> set_cache($query_hash, $histories);
            }

            $scheduled_queued = 0;

            if (!empty($histories)) {
                foreach ($histories as $history) {
                    $this -> remove_server_limits();
                    $mailinglists = maybe_unserialize($history -> mailinglists);
                    $roles = maybe_unserialize($history -> roles);
                    $fieldsconditions = maybe_unserialize($history -> conditions);
                    $condquery = maybe_unserialize($history -> condquery);
                    $subscriberids = array();
                    $subscriberemails = array();

                    if (!empty($mailinglists) || !empty($roles)) {
                        $mailinglistscondition = "(";
                        $m = 1;

                        foreach ($mailinglists as $mailinglist_id) {
                            $mailinglistscondition .= "list_id = '" . esc_sql($mailinglist_id) . "'";
                            if ($m < count($mailinglists)) {
                                $mailinglistscondition .= " OR ";
                            }
                            $m++;
                        }
                        $fields = (empty($fieldsconditions) ? array() : array_filter($fieldsconditions));
                        $scopeall = (empty($history -> conditionsscope) || $history -> conditionsscope == "all") ? true : false;
                        $fieldsquery = $Subscriber -> get_segmented_query($fields, $scopeall, $condquery);

                        if (!empty($history -> daterange) && $history -> daterange == "Y") {
                            if (!empty($history -> daterangefrom) && !empty($history -> daterangeto)) {
                                $daterangefrom = date_i18n("Y-m-d H:i:s", strtotime($history -> daterangefrom));
                                $daterangeto = date_i18n("Y-m-d H:i:s", strtotime($history -> daterangeto));
                                $fieldsquery .= " AND (" . $wpdb -> prefix . $Subscriber -> table . ".created >= '" . $daterangefrom . "' AND " . $wpdb -> prefix . $Subscriber -> table . ".created <= '" . $daterangeto . "')";
                            }
                        }

                        // Countries
                        if (!empty($history -> countries)) {
                            if (!empty($history -> selectedcountries) && is_array($history -> selectedcountries)) {
                                $countries = implode("', '", $history -> selectedcountries);
                                $fieldsquery .= " AND (" . $wpdb -> prefix . $Subscriber -> table . ".country IN ('" . $countries . "'))";
                            }
                        }

                        /* Attachments */
                        $Db -> model = $this -> model;
                        $history = $Db -> find(array('id' => $history -> id));

                        $query = "SELECT DISTINCT " . $wpdb -> prefix . $Subscriber -> table . ".id, "
                            . $wpdb -> prefix . $Subscriber -> table . ".email FROM "
                            . $wpdb -> prefix . $Subscriber -> table . " LEFT JOIN "
                            . $wpdb -> prefix . $SubscribersList -> table . " ON "
                            . $wpdb -> prefix . $Subscriber -> table . ".id = " . $wpdb -> prefix . $SubscribersList -> table . ".subscriber_id WHERE "
                            . $mailinglistscondition . ") AND " . $wpdb -> prefix . $SubscribersList -> table . ".active = 'Y'"
                            . str_replace(" AND ()", "", $fieldsquery);

                        $Db -> model = $this -> model;
                        $Db -> save_field('scheduled', "N", array('id' => $history -> id));

                        $sent = ($history -> sent + 1);
                        $Db -> model = $this -> model;
                        $Db -> save_field('sent', $sent, array('id' => $history -> id));

                        $queue_process_counter_1 = 0;
                        $queue_process_counter_2 = 0;
                        $queue_process_counter_3 = 0;
                        $queue_process = 1;
                        $this -> qp_reset_data();

                        // Send to user roles?
                        if (!empty($roles)) {
                            $exclude_users_query = "SELECT GROUP_CONCAT(`user_id`) FROM `" . $wpdb -> prefix . $Unsubscribe -> table . "` WHERE `user_id` != '0'";
                            $exclude_users = $wpdb -> get_var($exclude_users_query);
                            $exclude_users = (!empty($exclude_users)) ? array_filter(array_map('intval', explode(',', $exclude_users))) : array();

                            $role_chunk_size = (int) apply_filters('newsletters_queue_role_chunk_size', 200);
                            $role_chunk_size = max(50, $role_chunk_size);

                            foreach ($roles as $role_key) {
                                $role_offset = 0;

                                do {
                                    $users_arguments = array(
                                        'blog_id'  => $GLOBALS['blog_id'],
                                        'role'     => $role_key,
                                        'exclude'  => $exclude_users,
                                        'fields'   => array('ID', 'user_email', 'user_login'),
                                        'number'   => $role_chunk_size,
                                        'offset'   => $role_offset,
                                    );

                                    $role_users = get_users($users_arguments);

                                    if (empty($role_users)) {
                                        break;
                                    }

                                    foreach ($role_users as $user) {
                                        $this -> remove_server_limits();

                                        $queue_process_data = array(
                                            'user_id'    => (int) $user -> ID,
                                            'history_id' => (int) $history -> id,
                                        );

                                        $this -> {'queue_process_' . $queue_process} -> push_to_queue($queue_process_data);

                                        ${'queue_process_counter_' . $queue_process}++;
                                        if (${'queue_process_counter_' . $queue_process} >= $this -> {'queue_process_' . $queue_process} -> counter_reset) {
                                            $this -> {'queue_process_' . $queue_process} -> save();
                                            $this -> {'queue_process_' . $queue_process} -> reset_data();
                                            ${'queue_process_counter_' . $queue_process} = 0;
                                        }

                                        $queue_process++;
                                        if ($queue_process > $this -> newsletters_get_number_of_emails_on_intervals_statement()) {
                                            $queue_process = 1;
                                        }

                                        $scheduled_queued++;
                                    }

                                    if (function_exists('gc_collect_cycles')) {
                                        gc_collect_cycles();
                                    }

                                    if (function_exists('gc_mem_caches')) {
                                        gc_mem_caches();
                                    }

                                    unset($role_users);

                                    $role_offset += $role_chunk_size;

                                } while (count($role_users ?? array()) === $role_chunk_size);
                            }
                        }

                        if (!empty($mailinglists)) {
                            $subscriber_chunk_size = (int) apply_filters('newsletters_queue_subscriber_chunk_size', 200);
                            $subscriber_chunk_size = max(100, $subscriber_chunk_size);

                            $base_query = $query . " ORDER BY " . $wpdb -> prefix . $Subscriber -> table . ".id ASC";
                            $subscriber_offset = 0;

                            do {
                                $limited_query = $base_query . sprintf(
                                    " LIMIT %d OFFSET %d",
                                    $subscriber_chunk_size,
                                    $subscriber_offset
                                );

                                $subscribers = $wpdb -> get_results($limited_query);

                                if (empty($subscribers)) {
                                    break;
                                }

                                foreach ($subscribers as $subscriber) {
                                    $this -> remove_server_limits();

                                    $queue_process_data = array(
                                        'subscriber_id' => (int) $subscriber -> id,
                                        'history_id'    => (int) $history -> id,
                                    );

                                    $this -> {'queue_process_' . $queue_process} -> push_to_queue($queue_process_data);

                                    ${'queue_process_counter_' . $queue_process}++;
                                    if (${'queue_process_counter_' . $queue_process} >= $this -> {'queue_process_' . $queue_process} -> counter_reset) {
                                        $this -> {'queue_process_' . $queue_process} -> save();
                                        $this -> {'queue_process_' . $queue_process} -> reset_data();
                                        ${'queue_process_counter_' . $queue_process} = 0;
                                    }

                                    $queue_process++;
                                    if ($queue_process > $this -> newsletters_get_number_of_emails_on_intervals_statement()) {
                                        $queue_process = 1;
                                    }

                                    $scheduled_queued++;
                                }

                                if (function_exists('gc_collect_cycles')) {
                                    gc_collect_cycles();
                                }

                                if (function_exists('gc_mem_caches')) {
                                    gc_mem_caches();
                                }

                                unset($subscribers);

                                $subscriber_offset += $subscriber_chunk_size;

                            } while (count($subscribers ?? array()) === $subscriber_chunk_size);
                        }

                        $this -> qp_save();
                        $this -> qp_dispatch();
                    }
                }
            }

            echo sprintf(__('%s scheduled emails queued', 'wp-mailinglist'), $scheduled_queued) . '<br/>';
            return true;
        }

        /**
         * Saves a history record.
         * Used for both INSERT and UPDATE queries
         * @param ARRAY. An array of posted data
         * @param BOOLEAN. Determines whether $data should be validated or not
         *
         */
        public function save($data = array(), $validate = true, $insertpost = true)
        {
            global $wpdb, $Html, $Db, $HistoriesList, $user_ID;

            $errors = false;

            $defaults = array(
                'theme_id' => 0,
                'attachment' => "N",
                'attachmentfile' => "",
                'sent' => 0,
                'created' => $Html->gen_date(),
                'modified' => $Html->gen_date()
            );

            $data = (empty($data[$this->model])) ? $data : $data[$this->model];
            $data = apply_filters('newsletters_db_data_before_validate', $data, $this->model);

            $r = wp_parse_args($data, $defaults);
            $this->data = (array) $this->data;
            $this->data = (object) $r;
            extract($r, EXTR_SKIP);

            if ($validate == true) {
                if (empty($subject)) {
                    $this->errors['subject'] = __('No subject specified', 'wp-mailinglist');
                }
                if (empty($message)) {
                    $this->errors['message'] = __('No message specified', 'wp-mailinglist');
                }
            }

            if (empty($this->errors)) {
                $this->table_fields = apply_filters('newsletters_db_table_fields', $this->table_fields, $this->model);

                if (!empty($id)) {
                    $query = "UPDATE `" . $wpdb->prefix . $this->table_name . "` SET ";
                    $fields = [];
                    unset($this->table_fields['key']);
                    unset($this->table_fields['created']);
                    unset($this->table_fields['spamscore']);
                    unset($this->table_fields['p_id']);

                    foreach (array_keys($this->table_fields) as $field) {
                        switch ($field) {
                            case 'user_id':
                                if (empty($user_id)) {
                                    $user_id = get_current_user_id();
                                }
                                break;
                            case 'mailinglists':
                                if (!empty($mailinglists) && is_array($mailinglists)) {
                                    $mailinglists = maybe_serialize($mailinglists);
                                }
                                break;
                            case 'modified':
                                ${$field} = $Html->gen_date();
                                break;
                        }
                        if (isset(${$field}) && !is_array(${$field})) {
                            $fields[] = "`" . $field . "` = '" . esc_sql(${$field}) . "'";
                        }
                    }
                    $query .= implode(", ", $fields);
                    $query .= " WHERE `id` = '" . $id . "'";
                } else {
                    $fields = [];
                    $values = [];
                    unset($this->table_fields['key']);
                    unset($this->table_fields['id']);
                    unset($this->table_fields['spamscore']);
                    unset($this->table_fields['p_id']);

                    foreach (array_keys($this->table_fields) as $field) {
                        switch ($field) {
                            case 'mailinglists':
                                if (!empty($mailinglists) && is_array($mailinglists)) {
                                    $mailinglists = maybe_serialize($mailinglists);
                                }
                                break;
                            case 'user_id':
                                if (empty($user_id)) {
                                    $user_id = get_current_user_id();
                                }
                                break;
                        }
                        if (isset(${$field}) && !is_array(${$field})) {
                            $fields[] = "`" . $field . "`";
                            $values[] = "'" . esc_sql(${$field}) . "'";
                        }
                    }

                    $query = "INSERT INTO `" . $wpdb->prefix . $this->table_name . "` (" . implode(", ", $fields) . ") VALUES (" . implode(", ", $values) . ")";
                }

                $result = $wpdb->query($query);

                if ($result !== false && $result >= 0) {
                    $this->insertid = (empty($id)) ? $wpdb->insert_id : $id;
                    $history_id = $this->insertid;

                    /* attachments */
                    if (!empty($newattachments)) {
                        global $Db, $HistoriesAttachment;
                        foreach ($newattachments as $akey => $newattachment) {
                            $newattachment['history_id'] = $this->insertid;
                            $Db->model = $HistoriesAttachment->model;
                            $Db->save($newattachment, true);
                        }
                    }

                    /* Custom post type */
                    $this->delete_all_cache();
                    if ($history = $this->get($history_id, false)) {
                        if (isset($insertpost) && $insertpost == true) {
                            $custompostslug = $this->get_option('custompostslug');
                            $post_status = (empty($history->sent)) ? 'draft' : 'publish';

                            $post_data = array(
                                'ID' => ((empty($history->p_id)) ? false : $history->p_id),
                                'post_content' => $history->message,
                                'post_title' => $history->subject,
                                'post_status' => $post_status,
                                'post_type' => $custompostslug,
                                'post_author' => $user_ID,
                                'post_date' => $Html->gen_date(),
                                'post_date_gmt' => get_gmt_from_date($Html->gen_date()),
                            );

                            if ($contents = $this->Content()->find_all(array('history_id' => $history->id))) {
                                foreach ($contents as $content) {
                                    $post_data['post_content'] .= "\r\n\r\n" . $content->content;
                                }
                            }

                            $p_id = wp_insert_post($post_data, true);

                            if (!is_wp_error($p_id)) {
                                $imagespost = $this->get_option('imagespost');
                                if ($p_id != $imagespost) {
                                    update_post_meta($p_id, '_newsletters_history_id', $history_id);
                                    update_post_meta($p_id, 'grapejs_content', isset($data['grapejs_content']) ? $data['grapejs_content'] : '');
                                    update_post_meta($p_id, 'using_grapeJS', isset($data['using_grapeJS']) ? $data['using_grapeJS'] : '');
                                }
                                $Db->model = $this->model;
                                $Db->save_field('p_id', $p_id, array('id' => $history_id));
                                do_action('newsletters_history_post_updated', $p_id, $history, $post_data);
                            } else {
                                $error = $p_id->get_error_message();
                                $this->log_error($error);
                            }
                        }
                    }

                    /* mailing lists */
                    $Db->model = $HistoriesList->model;
                    $Db->delete_all(array('history_id' => $this->insertid));
                    $mailinglists = maybe_unserialize(isset($mailinglists) ? $mailinglists : '');
                    if (!empty($mailinglists) && is_array($mailinglists)) {
                        foreach ($mailinglists as $list_id) {
                            $Db->model = $HistoriesList->model;
                            if (!$Db->find(array('history_id' => $this->insertid, 'list_id' => $list_id))) {
                                $hl_data = array(
                                    'HistoriesList' => array(
                                        'history_id' => $this->insertid,
                                        'list_id' => $list_id,
                                    )
                                );
                                $Db->save($hl_data, true);
                            }
                        }
                    }

                    return true;
                }

                return false;
            }
        }

        /**
         * Retrieves a single history record by ID.
         * @param INT. The ID of the record to fetch
         * @param BOOLEAN/OBJ.
         *
         */
        public function get($history_id = null, $assign = true)
        {
            global $wpdb;

            if (!empty($history_id)) {
                $query = "SELECT * FROM `" . $wpdb -> prefix . "" . $this -> table_name . "` WHERE `id` = '" . esc_sql($history_id) . "' LIMIT 1";

                $query_hash = md5($query);
                if ($ob_history = $this -> get_cache($query_hash)) {
                    return $ob_history;
                }

                if ($history = $wpdb -> get_row($query)) {
                    $history = $this -> init_class($this -> model, $history);

                    if ($assign == true) {
                        $this -> data = (array) $this -> data;
                        //$this -> data[$this -> model] = $history;
                        $this -> data = $history;
                    }

                    $this -> set_cache($query_hash, $history);
                    return $history;
                }
            }

            return false;
        }

        /**
         * Retrieves the very first history email ever created.
         * Simply orders records by "created" date in an ascending manner.
         * @return OBJ an object with the history email's values.
         *
         */
        public function get_first($assign = true)
        {
            global $wpdb;

            $query = "SELECT * FROM `" . $wpdb -> prefix . "" . $this -> table_name . "` ORDER BY `created` ASC LIMIT 1";

            $query_hash = md5($query);
            if ($ob_history = $this -> get_cache($query_hash)) {
                return $ob_history;
            }

            if ($email = $wpdb -> get_row($query)) {
                $history = $this -> init_class($this -> model, $email);

                if ($assign == true) {
                    //$this -> data[$this -> model] = $history;
                    $this -> data = $history;
                }

                $this -> set_cache($query_hash, $history);
                return $history;
            }

            return false;
        }

        public function get_latest($assign = true)
        {
            global $wpdb;

            $query = "SELECT * FROM `" . $wpdb -> prefix . "" . $this -> table_name . "` ORDER BY `created` DESC LIMIT 1";

            $query_hash = md5($query);
            if ($ob_history = $this -> get_cache($query_hash)) {
                return $ob_history;
            }

            if ($email = $wpdb -> get_row($query)) {
                $history = $this -> init_class($this -> model, $email);

                if ($assign == true) {
                    //$this -> data[$this -> model] = $history;
                    $this -> data = $history;
                }

                $this -> set_cache($query_hash, $history);
                return $history;
            }

            return false;
        }

        /**
         * Removes multiple history email records.
         * Makes use of the History::delete() method to delete records.
         * @param $data ARRAY an array of history ID values.
         * @return BOOLEAN either true or false depending on whether the operation was successful or not.
         *
         */
        public function delete_array($data = array())
        {
            global $wpdb;

            if (!empty($data)) {
                foreach ($data as $history_id) {
                    $this -> delete($history_id);
                }

                return true;
            }

            return false;
        }

        public function truncate()
        {
            global $wpdb, $Email;

            if ($histories = $this -> History() -> find_all()) {
                foreach ($histories as $history) {
                    $this -> History() -> delete($history -> id);
                }

                return true;
            }

            return false;
        }

        public function select($limit = false)
        {
            global $Db;
            $historyselect = array();
            $Db -> model = $this -> model;

            if ($histories = $Db -> find_all(false, false, array('modified', "DESC"), $limit)) {
                foreach ($histories as $history) {
                    $historyselect[$history -> id] = $history -> id . ' - ' . __($history -> subject) . ' (' . date_i18n("Y-m-d", strtotime($history -> modified)) . ')';
                }
            }

            return $historyselect;
        }
    }
}
