<?php

// If this file is called directly, abort.
if (!defined('WPINC')) {
    die;
}

/**
 * Install tools
 *
 * Create whole DB structure
 */
// phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals.NonPrefixedClassFound
class EAInstallTools
{

    /**
     * DB version
     */
    public $easy_app_db_version;

    /**
     * @var wpdb
     */
    protected $wpdb;

    /**
     * @var EADBModels
     */
    protected $models;

    /**
     * @var EAOptions
     */
    protected $options;

    /**
     * EAInstallTools constructor.
     * @param wpdb $wpdb
     * @param EADBModels $models
     * @param EAOptions $options
     */
    function __construct($wpdb, $models, $options)
    {
        $this->easy_app_db_version = EASY_APPOINTMENTS_VERSION;

        $this->wpdb = $wpdb;
        $this->models = $models;
        $this->options = $options;
    }

    /**
     * Create db
     */
    public function init_db()
    {

        global $wpdb;

        $table_prefix    = $wpdb->prefix;
        $charset_collate = $wpdb->get_charset_collate();

        $table_querys = array();
        $alter_querys = array();

        // ea_appointments
        $table_querys[] =
            'CREATE TABLE ' . $table_prefix . 'ea_appointments (
            id int(11) NOT NULL AUTO_INCREMENT,
            location int(11) NOT NULL,
            service int(11) NOT NULL,
            worker int(11) NOT NULL,
            name varchar(255) DEFAULT NULL,
            email varchar(255) DEFAULT NULL,
            phone varchar(45) DEFAULT NULL,
            date date DEFAULT NULL,
            start time DEFAULT NULL,
            end time DEFAULT NULL,
            end_date date DEFAULT NULL,
            description text,
            status varchar(45) DEFAULT NULL,
            user int(11) DEFAULT NULL,
            created timestamp NULL DEFAULT CURRENT_TIMESTAMP,
            price decimal(10,2) DEFAULT NULL,
            ip varchar(45) DEFAULT NULL,
            session varchar(32) DEFAULT NULL,
            customer_id int(11) DEFAULT NULL,
            recurrence_id varchar(255) DEFAULT NULL,
            PRIMARY KEY (id),
            KEY appointments_location (location),
            KEY appointments_service (service),
            KEY appointments_worker (worker)
        ) ' . $charset_collate . ';';

        // ea_connections
        $table_querys[] =
            'CREATE TABLE ' . $table_prefix . 'ea_connections (
            id int(11) NOT NULL AUTO_INCREMENT,
            group_id int(11) DEFAULT NULL,
            location int(11) DEFAULT NULL,
            service int(11) DEFAULT NULL,
            worker int(11) DEFAULT NULL,
            slot_count int(11) DEFAULT 1,
            day_of_week varchar(60) DEFAULT NULL,
            time_from time DEFAULT NULL,
            time_to time DEFAULT NULL,
            day_from date DEFAULT NULL,
            day_to date DEFAULT NULL,
            is_working smallint(3) DEFAULT NULL,
            repeat_week smallint(3) DEFAULT NULL,
            repeat_booking smallint(3) DEFAULT NULL,
            PRIMARY KEY (id),
            KEY location_to_connection (location),
            KEY service_to_location (service),
            KEY worker_to_connection (worker)
        ) ' . $charset_collate . ';';

        // ea_locations
        $table_querys[] =
            'CREATE TABLE ' . $table_prefix . 'ea_locations (
            id int(11) NOT NULL AUTO_INCREMENT,
            name varchar(255) NOT NULL,
            address text NOT NULL,
            location varchar(255) DEFAULT NULL,
            cord varchar(255) DEFAULT NULL,
            PRIMARY KEY (id)
        ) ' . $charset_collate . ';';

        // ea_options
        $table_querys[] =
            'CREATE TABLE ' . $table_prefix . 'ea_options (
            id int(11) NOT NULL AUTO_INCREMENT,
            ea_key varchar(45) DEFAULT NULL,
            ea_value text,
            type varchar(45) DEFAULT NULL,
            PRIMARY KEY (id)
        ) ' . $charset_collate . ';';

        // ea_staff
        $table_querys[] =
            'CREATE TABLE ' . $table_prefix . 'ea_staff (
            id int(11) NOT NULL AUTO_INCREMENT,
            name varchar(100) DEFAULT NULL,
            description text,
            email varchar(100) DEFAULT NULL,
            phone varchar(45) DEFAULT NULL,
            PRIMARY KEY (id)
        ) ' . $charset_collate . ';';

        // ea_services
        $table_querys[] =
            'CREATE TABLE ' . $table_prefix . 'ea_services (
            id int(11) NOT NULL AUTO_INCREMENT,
            name varchar(255) NOT NULL,
            service_color varchar(7) DEFAULT \'#0693E3\',
            sequence int(11) NOT NULL,
            duration int(11) NOT NULL,
            slot_step int(11) DEFAULT NULL,
            block_before int(11) DEFAULT 0,
            block_after int(11) DEFAULT 0,
            daily_limit int(11) DEFAULT 0,
            price decimal(10,2) DEFAULT NULL,
            advance_booking_days int(4) DEFAULT 0,
            description TEXT NULL,
            PRIMARY KEY (id)
        ) ' . $charset_collate . ';';

        // ea_meta_fields
        $table_querys[] =
            'CREATE TABLE ' . $table_prefix . 'ea_meta_fields (
            id int(11) NOT NULL AUTO_INCREMENT,
            type varchar(50) NOT NULL,
            slug varchar(255) NOT NULL,
            label varchar(255) NOT NULL,
            mixed text NOT NULL,
            default_value varchar(50) NOT NULL,
            visible tinyint(4) NOT NULL,
            required tinyint(4) NOT NULL,
            validation varchar(50) DEFAULT NULL,
            position int(11) NOT NULL,
            PRIMARY KEY (id)
        ) ' . $charset_collate . ';';

        // ea_fields
        $table_querys[] =
            'CREATE TABLE ' . $table_prefix . 'ea_fields (
            id int(11) NOT NULL AUTO_INCREMENT,
            app_id int(11) NOT NULL,
            field_id int(11) NOT NULL,
            value varchar(500) DEFAULT NULL,
            PRIMARY KEY (id)
        ) ' . $charset_collate . ';';

        // ea_error_logs
        $table_querys[] =
            'CREATE TABLE ' . $table_prefix . 'ea_error_logs (
            id int(11) NOT NULL AUTO_INCREMENT,
            error_type varchar(50) DEFAULT NULL,
            errors text,
            errors_data text,
            PRIMARY KEY (id)
        ) ' . $charset_collate . ';';

        // Foreign keys (dbDelta does NOT handle these)
        $alter_querys[] =
            'ALTER TABLE ' . $table_prefix . 'ea_appointments
            ADD CONSTRAINT ' . $table_prefix . 'ea_appointments_ibfk_1 FOREIGN KEY (location) REFERENCES ' . $table_prefix . 'ea_locations (id) ON DELETE CASCADE,
            ADD CONSTRAINT ' . $table_prefix . 'ea_appointments_ibfk_2 FOREIGN KEY (service) REFERENCES ' . $table_prefix . 'ea_services (id) ON DELETE CASCADE,
            ADD CONSTRAINT ' . $table_prefix . 'ea_appointments_ibfk_3 FOREIGN KEY (worker) REFERENCES ' . $table_prefix . 'ea_staff (id) ON DELETE CASCADE';

        $alter_querys[] =
            'ALTER TABLE ' . $table_prefix . 'ea_connections
            ADD CONSTRAINT ' . $table_prefix . 'ea_connections_ibfk_1 FOREIGN KEY (location) REFERENCES ' . $table_prefix . 'ea_locations (id) ON DELETE CASCADE,
            ADD CONSTRAINT ' . $table_prefix . 'ea_connections_ibfk_2 FOREIGN KEY (service) REFERENCES ' . $table_prefix . 'ea_services (id) ON DELETE CASCADE,
            ADD CONSTRAINT ' . $table_prefix . 'ea_connections_ibfk_3 FOREIGN KEY (worker) REFERENCES ' . $table_prefix . 'ea_staff (id) ON DELETE CASCADE';

        $alter_querys[] = 'ALTER TABLE ' . $table_prefix . 'ea_services ADD COLUMN description TEXT NULL';

        require_once ABSPATH . 'wp-admin/includes/upgrade.php';

        foreach ($table_querys as $query) {
            dbDelta($query);
        }

        foreach ($alter_querys as $query) {
            // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter, WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching
            $wpdb->query($query);
        }

        $this->ea_create_customers_table();

        update_option('easy_app_db_version', $this->easy_app_db_version);
    }


    /**
     * Insert start data into options
     */
    public function init_data()
    {
        // safety check if we already have meta fields
        // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
        $count_query = $this->wpdb->prepare('SELECT COUNT(*) FROM ' . $this->wpdb->prefix . 'ea_meta_fields' );
        // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
        $num = (int) $this->wpdb->get_var($count_query);
        if ($num > 0) {
            return;
        }

        // options table
        $table_name = $this->wpdb->prefix . 'ea_options';

        // rows data
        $wp_ea_options = $this->options->get_insert_options();

        // insert options
        foreach ($wp_ea_options as $row) {
            $this->wpdb->insert(
                $table_name,
                $row
            );
        }

        // create custom form fields
        $default_fields = $this->migrateFormFields();

        $table_name = $this->wpdb->prefix . 'ea_meta_fields';

        foreach ($default_fields as $row) {
            $this->wpdb->insert(
                $table_name,
                $row
            );
        }

        // Set default UI mode to 'new' for fresh installation
        if (get_option('easy_ea_ui_mode') === false) {
            add_option('easy_ea_ui_mode', 'new');
        }
    }

    public function update()
    {

        // get table prefix
        $table_prefix = $this->wpdb->prefix;

        $charset_collate = $this->wpdb->get_charset_collate();

        $version = get_option('easy_app_db_version', '1.0');

        // For upgrades from versions prior to 4.0.0, default UI mode to 'old' (classic) if not explicitly set
        if (version_compare($version, '4.0.0', '<')) {
            if (get_option('easy_ea_ui_mode') === false) {
                add_option('easy_ea_ui_mode', 'old');
            }
        }

        // if it is already latest version
        if (version_compare($version, $this->easy_app_db_version, '=')) {
            return;
        }

        // Migrate from 1.0 > 1.1
        if (version_compare($version, '1.1', '<')) {

            $this->init_db();

            // options table
            $table_name = $this->wpdb->prefix . 'ea_options';
            // rows data
            $wp_ea_options = array(
                array('ea_key' => 'pending.email', 'ea_value' => '', 'type' => 'default'),
                array('ea_key' => 'price.hide', 'ea_value' => '0', 'type' => 'default')
            );
            // insert options
            foreach ($wp_ea_options as $row) {
                $this->wpdb->insert($table_name, $row);
            }

            $version = '1.1';
        }

        // Migrate from 1.2.1- > 1.2.2
        if (version_compare($version, '1.2.2', '<')) {
            $version = '1.2.2';

            $alter_querys = array();

            $alter_querys[] = 'ALTER TABLE ' . $table_prefix . 'ea_appointments DROP FOREIGN KEY ' . $table_prefix . 'ea_appointments_ibfk_1;';
            $alter_querys[] = 'ALTER TABLE ' . $table_prefix . 'ea_appointments DROP FOREIGN KEY ' . $table_prefix . 'ea_appointments_ibfk_2;';
            $alter_querys[] = 'ALTER TABLE ' . $table_prefix . 'ea_appointments DROP FOREIGN KEY ' . $table_prefix . 'ea_appointments_ibfk_3;';
            $alter_querys[] = 'ALTER TABLE ' . $table_prefix . 'ea_connections DROP FOREIGN KEY ' . $table_prefix . 'ea_connections_ibfk_1;';
            $alter_querys[] = 'ALTER TABLE ' . $table_prefix . 'ea_connections DROP FOREIGN KEY ' . $table_prefix . 'ea_connections_ibfk_2;';
            $alter_querys[] = 'ALTER TABLE ' . $table_prefix . 'ea_connections DROP FOREIGN KEY ' . $table_prefix . 'ea_connections_ibfk_3;';

            $alter_querys[] =
                'DELETE FROM ' . $table_prefix . 'ea_connections
             WHERE location NOT IN (SELECT id FROM ' . $table_prefix . 'ea_locations)
                OR service NOT IN (SELECT id FROM ' . $table_prefix . 'ea_services)
                OR worker NOT IN (SELECT id FROM ' . $table_prefix . 'ea_staff);';

            $alter_querys[] =
                'DELETE FROM ' . $table_prefix . 'ea_appointments
             WHERE location NOT IN (SELECT id FROM ' . $table_prefix . 'ea_locations)
                OR service NOT IN (SELECT id FROM ' . $table_prefix . 'ea_services)
                OR worker NOT IN (SELECT id FROM ' . $table_prefix . 'ea_staff);';

            // add relations
            foreach ($alter_querys as $alter_query) {
                // phpcs:ignore PluginCheck.Security.DirectDB.UnescapedDBParameter, WordPress.DB.PreparedSQL.NotPrepared
                $this->wpdb->query($alter_query);
            }

            $this->init_db();
        }

        // Migrate from 1.2.2 > 1.2.3
        if (version_compare($version, '1.2.3', '<')) {
            $version = '1.2.3';
        }

        // Migrate form 1.2.3 > 1.2.4
        if (version_compare($version, '1.2.4', '<')) {
            $option = array('ea_key' => 'datepicker', 'ea_value' => 'en-US', 'type' => 'default');

            $table_name = $this->wpdb->prefix . 'ea_options';

            $this->wpdb->insert($table_name, $option);

            $version = '1.2.4';
        }

        // Migrate form 1.2.4 > 1.2.7
        if (version_compare($version, '1.2.7', '<')) {
            $version = '1.2.7';
        }

        // Migrate form 1.2.7 > 1.2.8
        if (version_compare($version, '1.2.8', '<')) {
            $option = array('ea_key' => 'send.user.email', 'ea_value' => '0', 'type' => 'default');

            $table_name = $this->wpdb->prefix . 'ea_options';

            $this->wpdb->insert($table_name, $option);

            $version = '1.2.8';
        }

        // Migrate form 1.2.8 > 1.2.9
        if (version_compare($version, '1.2.9', '<')) {
            $option = array('ea_key' => 'custom.css', 'ea_value' => '', 'type' => 'default');

            $table_name = $this->wpdb->prefix . 'ea_options';

            $this->wpdb->insert($table_name, $option);

            $version = '1.2.9';
        }

        if (version_compare($version, '1.3.0', '<')) {

            $wp_ea_options = array(
                array('ea_key' => 'show.iagree', 'ea_value' => '0', 'type' => 'default'),
                array('ea_key' => 'cancel.scroll', 'ea_value' => 'calendar', 'type' => 'default')
            );

            $table_name = $this->wpdb->prefix . 'ea_options';

            foreach ($wp_ea_options as $row) {
                $this->wpdb->insert($table_name, $row);
            }

            $version = '1.3.0';
        }

        if (version_compare($version, '1.4.0', '<')) {
            $version = '1.4.0';
        }

        // Migrate to last version
        if (version_compare($version, '1.5.0', '<')) {
            $version = '1.5.0';
            $table_querys = array();

            $table_querys[] =
                'CREATE TABLE ' . $table_prefix . 'ea_fields (
                id int(11) NOT NULL AUTO_INCREMENT,
                app_id int(11) NOT NULL,
                field_id int(11) NOT NULL,
                value varchar(500) DEFAULT NULL,
                PRIMARY KEY (id)
            ) ' . $charset_collate . ';';

            $table_querys[] =
                'CREATE TABLE ' . $table_prefix . 'ea_meta_fields (
                id int(11) NOT NULL AUTO_INCREMENT,
                type varchar(50) NOT NULL,
                slug varchar(255) NOT NULL,
                label varchar(255) NOT NULL,
                mixed text NOT NULL,
                default_value varchar(50) NOT NULL,
                visible tinyint(4) NOT NULL,
                required tinyint(4) NOT NULL,
                validation varchar(50) DEFAULT NULL,
                position int(11) NOT NULL,
                PRIMARY KEY (id)
            ) ' . $charset_collate . ';';

            require_once(ABSPATH . 'wp-admin/includes/upgrade.php');

            foreach ($table_querys as $table) {
                dbDelta($table);
            }

            $default_fields = $this->migrateFormFields();
            $table_name = $this->wpdb->prefix . 'ea_meta_fields';

            $ids = array();

            foreach ($default_fields as $row) {
                $this->wpdb->insert($table_name, $row);
                $ids[$row['slug']] = $this->wpdb->insert_id;
            }

            $this->migrateOldFormValues($ids);
        }

        if (version_compare($version, '1.9.3', '<')) {
            $table_queries = array();

            $table_queries[] =
                'CREATE TABLE ' . $table_prefix . 'ea_error_logs (
                id int(11) NOT NULL AUTO_INCREMENT,
                error_type varchar(50) DEFAULT NULL,
                errors text,
                errors_data text,
                PRIMARY KEY (id)
            ) ' . $charset_collate . ';';

            require_once(ABSPATH . 'wp-admin/includes/upgrade.php');

            foreach ($table_queries as $table) {
                dbDelta($table);
            }

            $version = '1.9.3';
        }

        update_option('easy_app_db_version', $version);
    }


    public function update_email_options($type = 'user')
    {
        global $wpdb;
        $table_name = $wpdb->prefix . 'ea_options';

        // Define parent key and children based on type
        if ($type === 'user') {
            $parent_key = 'send.user.email';
            $children = [
                'send.user.pending_email',
                'send.user.reservation_email',
                'send.user.cancelled_email',
                'send.user.confirmed_email',
            ];
        } elseif ($type === 'worker') {
            $parent_key = 'send.worker.email';
            $children = [
                'send.worker.pending_email',
                'send.worker.reservation_email',
                'send.worker.cancelled_email',
                'send.worker.confirmed_email',
            ];
        } else {
            return false; // Invalid type
        }

        // Check if parent is enabled
        // phpcs:ignore PluginCheck.Security.DirectDB.UnescapedDBParameter, WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching, WordPress.DB.PreparedSQL.InterpolatedNotPrepared
        $parent_value = $wpdb->get_var($wpdb->prepare( "SELECT ea_value FROM $table_name WHERE ea_key = %s", $parent_key ));

        if ($parent_value !== '1') {
            return false; // Parent not enabled, do nothing
        }

        // Insert or update each child key
        foreach ($children as $key) {
            // phpcs:ignore PluginCheck.Security.DirectDB.UnescapedDBParameter, WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching, WordPress.DB.PreparedSQL.InterpolatedNotPrepared
            $existing = $wpdb->get_var($wpdb->prepare( "SELECT COUNT(*) FROM $table_name WHERE ea_key = %s", $key ));

            if ($existing) {
                // Update to 1
                // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching
                $wpdb->update(
                    $table_name,
                    ['ea_value' => '1'],
                    ['ea_key'   => $key],
                    ['%s'],
                    ['%s']
                );
            } else {
                // Insert as 1
                // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery
                $wpdb->insert(
                    $table_name,
                    [
                        'ea_key'   => $key,
                        'ea_value' => '1',
                    ],
                    ['%s', '%s']
                );
            }
        }

        return true;
    }


    function ea_create_customers_table()
    {
        global $wpdb;

        $table_name = $wpdb->prefix . 'ea_customers';

        $charset_collate = $wpdb->get_charset_collate();

        $sql = "CREATE TABLE $table_name (
            id BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
            user_id BIGINT(20) UNSIGNED DEFAULT NULL,
            name VARCHAR(255) NOT NULL,
            email VARCHAR(255) DEFAULT '',
            mobile VARCHAR(50) DEFAULT '',
            dob VARCHAR(50) DEFAULT '',
            address TEXT,
            PRIMARY KEY (id)
        ) $charset_collate;";

        require_once ABSPATH . 'wp-admin/includes/upgrade.php';
        dbDelta($sql);
    }


    private function migrateFormFields()
    {
        $email = __('EMail', 'easy-appointments');
        $name = __('Name', 'easy-appointments');
        $phone = __('Phone', 'easy-appointments');
        $comment = __('Description', 'easy-appointments');

        $data = array();

        // email
        $data[] = array(
            'type'          => 'EMAIL',
            'slug'          => str_replace('-', '_', sanitize_title('email')),
            'label'         => $email,
            'default_value' => '',
            'validation'    => 'email',
            'mixed'         => '',
            'visible'       => 1,
            'required'      => 1,
            'position'      => 1
        );

        $data[] = array(
            'type'          => 'INPUT',
            'slug'          => str_replace('-', '_', sanitize_title('name')),
            'label'         => $name,
            'default_value' => '',
            'validation'    => 'minlength-3',
            'mixed'         => '',
            'visible'       => 1,
            'required'      => 1,
            'position'      => 2
        );

        $data[] = array(
            'type'          => 'INPUT',
            'slug'          => str_replace('-', '_', sanitize_title('phone')),
            'label'         => $phone,
            'default_value' => '',
            'validation'    => 'minlength-3',
            'mixed'         => '',
            'visible'       => 1,
            'required'      => 1,
            'position'      => 3
        );

        $data[] = array(
            'type'          => 'TEXTAREA',
            'slug'          => str_replace('-', '_', sanitize_title('description')),
            'label'         => $comment,
            'default_value' => '',
            'validation'    => NULL,
            'mixed'         => '',
            'visible'       => 1,
            'required'      => 0,
            'position'      => 4
        );

        return $data;
    }

    /**
     * Insert all the old values from appointments
     * @param $ids
     */
    private function migrateOldFormValues($ids)
    {
        $table_name = 'ea_appointments';

        $apps = $this->models->get_all_rows($table_name);

        $chunks = array_chunk($apps, 100);

        $rows = array();
        $keys = array('email', 'name', 'phone', 'description');

        $table_name = $this->wpdb->prefix . 'ea_fields';

        foreach ($chunks as $chunk) {
            // helpers
            $values = array();
            $place_holders = array();

            $query = "INSERT INTO $table_name (app_id, field_id, value) VALUES ";

            // all appointments
            foreach ($chunk as $app) {
                // set insert for every key email, name, phone, description
                foreach ($keys as $key) {
                    array_push($values, $app->id, $ids[$key], $app->{$key});
                    $place_holders[] = "('%d', '%d', '%s')";
                }
            }

            $query .= implode(', ', $place_holders);
            // phpcs:ignore PluginCheck.Security.DirectDB.UnescapedDBParameter, WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.PreparedSQL.InterpolatedNotPrepared, WordPress.DB.PreparedSQLPlaceholders.UnfinishedPrepare
            $this->wpdb->query($this->wpdb->prepare("$query ", $values));
        }
    }

    /**
     *
     */
    public function set_demo_data()
    {

        $data = array(
            'ea_staff' => array(
                array('id' => 1, 'name' => 'John Smit', 'description' => 'Worker 1', 'email' => 'someemail@email.com', 'phone' => '123456'),
                array('id' => 2, 'name' => 'Peter Dalas', 'description' => 'Worker 2', 'email' => 'dummy@email.com', 'phone' => '112233')
            ),
            'ea_locations' => array(
                array('id' => 1, 'name' => 'New York', 'address' => 'Street 1', 'location' => 'New York', 'cord' => ''),
                array('id' => 2, 'name' => 'Washington DC', 'address' => 'Street 10', 'location' => 'Wasington DC', 'cord' => '')
            ),
            'ea_services' => array(
                array('id' => 1, 'name' => 'Car wash', 'duration' => 60, 'price' => 25, 'service_color' => '#0693E3'),
                array('id' => 2, 'name' => 'Car polishing', 'duration' =>  45, 'price' => 10, 'service_color' => '#FF6900')
            ),
        );

        foreach ($data as $table => $rows) {
            $tableName = $this->wpdb->prefix . $table;

            foreach ($rows as $row) {
                $this->wpdb->insert(
                    $tableName,
                    $row
                );
            }
        }
    }

    function ea_sync_customers_from_appointments()
    {
        global $wpdb;
        // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching
        $oldest_appointment = $wpdb->get_row("
            SELECT * 
            FROM {$wpdb->prefix}ea_appointments 
            ORDER BY date ASC 
            LIMIT 1
        ", ARRAY_A);

        if ($oldest_appointment) {
            $start_date =  $oldest_appointment['date'];
            $end_date = gmdate('Y-m-d');
            $appointments =  $this->models->get_all_appointments(['from' => $start_date, 'to' => $end_date]);
            foreach ($appointments as $appointment) {
                $app_id  = (int) $appointment->id;
                $name    = $appointment->name;
                $email   = $appointment->email;
                $mobile  = $appointment->phone;
                $user_id  = $appointment->user;

                if (empty($email)) {
                    continue;
                }
                // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching
                $customer_id = $wpdb->get_var($wpdb->prepare(
                    "SELECT id FROM {$wpdb->prefix}ea_customers WHERE email = %s",
                    $email
                ));

                // Insert new customer if not found
                if (!$customer_id) {
                    // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery
                    $inserted = $wpdb->insert("{$wpdb->prefix}ea_customers", [
                        'name'    => $name,
                        'email'   => $email,
                        'mobile'  => $mobile,
                        'user_id' => $user_id ? (int)$user_id : null,
                    ], ['%s', '%s', '%s', '%d']);

                    if ($inserted) {
                        $customer_id = $wpdb->insert_id;
                        if (empty($appointment->customer_id) && $customer_id) {
                            // phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching
                            $wpdb->update(
                                "{$wpdb->prefix}ea_appointments",
                                ['customer_id' => $customer_id],
                                ['id' => $app_id],
                                ['%d'],
                                ['%d']
                            );
                        }
                    }
                }
            }
        }
    }
}