Google Vehicle Listings

				
					<?php

/**
 * Plugin Name: Autoactiva Vehicle Feed
 * Plugin URI:  https://autoactiva.de/
 * Description: Erstellt einen WooCommerce-Fahrzeug-Export als CSV und lädt ihn optional per SFTP (cURL) hoch. 
 *              Zusätzlich können Google Place IDs für verschiedene Autohäuser im Backend verwaltet werden.
 * Version:     1.3.0
 * Author:      Ivan Belovari
 * Author URI:  https://autoactiva.de/
 * License:     GPL2
 * Text Domain: autoactiva-vehicle-feed
 */

if (! defined('ABSPATH')) {
    exit; // Kein direkter Zugriff
}

/**
 * ==========================
 * 1) Einstellungen registrieren
 * ==========================
 */
function autoactiva_vehicle_feed_register_settings()
{
    // Bisherige SFTP-Optionen
    register_setting('autoactiva_vehicle_feed_settings_group', 'autoactiva_vehicle_feed_sftp_server');
    register_setting('autoactiva_vehicle_feed_settings_group', 'autoactiva_vehicle_feed_sftp_port');
    register_setting('autoactiva_vehicle_feed_settings_group', 'autoactiva_vehicle_feed_sftp_user');
    register_setting('autoactiva_vehicle_feed_settings_group', 'autoactiva_vehicle_feed_sftp_password');
    register_setting('autoactiva_vehicle_feed_settings_group', 'autoactiva_vehicle_feed_auto_upload_enabled');

    // Option für Google Place IDs
    register_setting('autoactiva_vehicle_feed_settings_group', 'autoactiva_vehicle_feed_place_ids');

    // Neue Option für Maßeinheit (Kilometer oder Meilen) mit Standard "miles"
    register_setting('autoactiva_vehicle_feed_settings_group', 'autoactiva_vehicle_feed_unit', array(
        'default' => 'miles'
    ));
}
add_action('admin_init', 'autoactiva_vehicle_feed_register_settings');

/**
 * ==========================
 * 2) Menüpunkt unter "Einstellungen"
 * ==========================
 */
function autoactiva_vehicle_feed_add_admin_menu()
{
    add_options_page(
        'Autoactiva Vehicle Feed',
        'Autoactiva Vehicle Feed',
        'manage_options',
        'autoactiva-vehicle-feed',
        'autoactiva_vehicle_feed_settings_page'
    );
}
add_action('admin_menu', 'autoactiva_vehicle_feed_add_admin_menu');

/**
 * ==========================
 * 3) Rendering der Einstellungsseite
 * ==========================
 */
function autoactiva_vehicle_feed_settings_page()
{
    if (! current_user_can('manage_options')) {
        return;
    }

    // Hole den aktuellen Wert der Checkbox (Default 'no')
    $auto_upload_enabled = get_option('autoactiva_vehicle_feed_auto_upload_enabled', 'no');
    // Hole die bevorzugte Einheit (Default 'miles')
    $unit = get_option('autoactiva_vehicle_feed_unit', 'miles');

    // Aktion auswerten (CSV oder CSV + SFTP)
    if (isset($_POST['autoactiva_action']) && check_admin_referer('autoactiva_vehicle_feed_action', 'autoactiva_vehicle_feed_nonce')) {
        $action_type = sanitize_text_field($_POST['autoactiva_action']);

        if ($action_type === 'create_csv') {
            // Nur CSV
            $export_result = autoactiva_vehicle_feed_run_export(false);
            if ($export_result === true) {
                echo '<div class="notice notice-success"><p>CSV wurde erfolgreich erstellt.</p></div>';
            } else {
                echo '<div class="notice notice-error"><p>Fehler beim Erstellen der CSV: ' . esc_html($export_result) . '</p></div>';
            }
        } elseif ($action_type === 'export_vehicle_listings') {
            // CSV + SFTP
            $export_result = autoactiva_vehicle_feed_run_export(true);
            if ($export_result === true) {
                echo '<div class="notice notice-success"><p>Export zu Vehicle Listings (SFTP) wurde erfolgreich durchgeführt.</p></div>';
            } else {
                echo '<div class="notice notice-error"><p>Fehler beim Export zu Vehicle Listings: ' . esc_html($export_result) . '</p></div>';
            }
        }
    }
    ?>
    <div class="wrap">
        <h1>Autoactiva Vehicle Feed – Einstellungen</h1>

        <form method="post" action="options.php">
            <?php
            // Bindet die Settings-Fields etc. ein
            settings_fields('autoactiva_vehicle_feed_settings_group');
            do_settings_sections('autoactiva_vehicle_feed_settings_group');
            ?>

            <table class="form-table">
                <tr>
                    <th scope="row"><label for="autoactiva_vehicle_feed_sftp_server">SFTP-Server</label></th>
                    <td>
                        <input type="text" name="autoactiva_vehicle_feed_sftp_server" id="autoactiva_vehicle_feed_sftp_server"
                            value="<?php echo esc_attr(get_option('autoactiva_vehicle_feed_sftp_server')); ?>"
                            style="width: 300px;">
                    </td>
                </tr>
                <tr>
                    <th scope="row"><label for="autoactiva_vehicle_feed_sftp_port">SFTP-Port</label></th>
                    <td>
                        <input type="number" name="autoactiva_vehicle_feed_sftp_port" id="autoactiva_vehicle_feed_sftp_port"
                            value="<?php echo esc_attr(get_option('autoactiva_vehicle_feed_sftp_port', 22)); ?>"
                            style="width: 100px;">
                        <p class="description">
                            Standard für SFTP ist 22. Dein Hoster/Server kann aber auch andere Ports nutzen.
                        </p>
                    </td>
                </tr>
                <tr>
                    <th scope="row"><label for="autoactiva_vehicle_feed_sftp_user">SFTP-Benutzer</label></th>
                    <td>
                        <input type="text" name="autoactiva_vehicle_feed_sftp_user" id="autoactiva_vehicle_feed_sftp_user"
                            value="<?php echo esc_attr(get_option('autoactiva_vehicle_feed_sftp_user')); ?>"
                            style="width: 300px;">
                    </td>
                </tr>
                <tr>
                    <th scope="row"><label for="autoactiva_vehicle_feed_sftp_password">SFTP-Passwort</label></th>
                    <td>
                        <input type="password" name="autoactiva_vehicle_feed_sftp_password" id="autoactiva_vehicle_feed_sftp_password"
                            value="<?php echo esc_attr(get_option('autoactiva_vehicle_feed_sftp_password')); ?>"
                            style="width: 300px;">
                    </td>
                </tr>
            </table>

            <hr>
            <h2>Google Place IDs pro Autohaus</h2>
            <p>Trage hier die Google Place IDs für deine Autohäuser ein. Diese werden später im CSV automatisch zugeordnet.</p>
            <?php
            // Gespeicherte Werte holen (Array)
            $saved_place_ids = get_option('autoactiva_vehicle_feed_place_ids', array());
            if (! is_array($saved_place_ids)) {
                $saved_place_ids = array();
            }

            // Alle Begriffe aus WooCommerce-Attribut "pa_autohaus" holen
            $autohaus_terms = get_terms(array(
                'taxonomy'   => 'pa_autohaus',  // Taxonomie-Name bei WooCommerce-Attribut "autohaus"
                'hide_empty' => false,
            ));

            if (! is_wp_error($autohaus_terms) && ! empty($autohaus_terms)) {
                echo '<table class="form-table"><tbody>';
                foreach ($autohaus_terms as $term) {
                    $autohaus_name = $term->name;
                    $value = isset($saved_place_ids[$autohaus_name]) ? $saved_place_ids[$autohaus_name] : '';
                    ?>
                    <tr>
                        <th scope="row">
                            <?php echo esc_html($autohaus_name); ?>
                        </th>
                        <td>
                            <input type="text"
                                name="autoactiva_vehicle_feed_place_ids[<?php echo esc_attr($autohaus_name); ?>]"
                                value="<?php echo esc_attr($value); ?>"
                                style="width: 400px;" />
                            <br><small>Place ID für <?php echo esc_html($autohaus_name); ?></small>
                        </td>
                    </tr>
                    <?php
                }
                echo '</tbody></table>';
            } else {
                echo '<p><em>Keine Autohaus-Begriffe gefunden (pa_autohaus leer?).</em></p>';
            }
            ?>

            <hr>
            <h2>Maßeinheit für den Kilometerstand</h2>
            <table class="form-table">
                <tr>
                    <th scope="row">Bevorzugte Einheit</th>
                    <td>
                        <label>
                            <input type="radio" name="autoactiva_vehicle_feed_unit" value="miles" <?php checked($unit, 'miles'); ?>>
                            Meilen
                        </label><br>
                        <label>
                            <input type="radio" name="autoactiva_vehicle_feed_unit" value="km" <?php checked($unit, 'km'); ?>>
                            Kilometer
                        </label>
                        <p class="description">
                            Wähle die Maßeinheit, die im CSV-Export verwendet werden soll.
                        </p>
                    </td>
                </tr>
            </table>

            <hr>
            <h2>Automatischer Upload</h2>
            <table class="form-table">
                <tr>
                    <th scope="row">Fahrzeuge automatisch hochladen</th>
                    <td>
                        <label for="autoactiva_vehicle_feed_auto_upload_enabled">
                            <input type="checkbox"
                                name="autoactiva_vehicle_feed_auto_upload_enabled"
                                id="autoactiva_vehicle_feed_auto_upload_enabled"
                                value="yes"
                                <?php checked($auto_upload_enabled, 'yes'); ?> />
                            Fahrzeuge täglich um 08:00 Uhr hochladen
                        </label>
                        <p class="description">
                            Wenn aktiviert, wird jeden Tag um 08:00 Uhr automatisch eine CSV erstellt und via SFTP hochgeladen.
                        </p>
                    </td>
                </tr>
            </table>

            <?php submit_button('SFTP- und Place-ID-Daten speichern'); ?>
        </form>

        <hr>

        <h2>Manueller Export</h2>
        <p>
            <strong>CSV erstellen:</strong> Erzeugt nur die CSV im <code>uploads</code>-Ordner.<br>
            <strong>Export zu Vehicle Listings durchführen:</strong> Erzeugt die CSV <em>und</em> lädt sie via SFTP hoch (mit den oben gespeicherten Zugangsdaten).
        </p>

        <form method="post">
            <?php wp_nonce_field('autoactiva_vehicle_feed_action', 'autoactiva_vehicle_feed_nonce'); ?>

            <!-- Button: CSV erstellen -->
            <button type="submit" name="autoactiva_action" value="create_csv" class="button button-secondary">
                CSV erstellen
            </button>

            <!-- Button: Export zu Vehicle Listings (SFTP) -->
            <button type="submit" name="autoactiva_action" value="export_vehicle_listings" class="button button-primary">
                Export zu Vehicle Listings durchführen (SFTP)
            </button>
        </form>
    </div>
    <?php
}

/**
 * ==========================
 * 4) Helper-Funktion: Hole Place ID aus gespeicherten Daten
 * ==========================
 *
 * @param string $dealership_name z.B. "Toyota Offenbach"
 * @return string (z.B. "ChIJlzW6MgYSvUcR4gBn6foFnlM") oder leer
 */
function get_place_id_by_dealership($dealership_name)
{
    $all_place_ids = get_option('autoactiva_vehicle_feed_place_ids', array());
    if (! is_array($all_place_ids)) {
        $all_place_ids = array();
    }
    return isset($all_place_ids[$dealership_name]) ? $all_place_ids[$dealership_name] : '';
}

/**
 * ==========================
 * 5) Export-Funktion (CSV + optionaler SFTP-Upload)
 * ==========================
 *
 * @param bool $do_sftp Gibt an, ob SFTP-Upload durchgeführt werden soll.
 * @return true|string  true = Erfolg, string = Fehlermeldung
 */
function autoactiva_vehicle_feed_run_export($do_sftp = false)
{
    // WooCommerce-Check
    if (! function_exists('wc_get_products')) {
        return 'WooCommerce ist nicht aktiv oder nicht verfügbar.';
    }

    // SFTP-Daten aus den Settings
    $sftp_server   = get_option('autoactiva_vehicle_feed_sftp_server', '');
    $sftp_port     = get_option('autoactiva_vehicle_feed_sftp_port', 22);
    $sftp_user     = get_option('autoactiva_vehicle_feed_sftp_user', '');
    $sftp_password = get_option('autoactiva_vehicle_feed_sftp_password', '');

    // Pfad zur CSV im Uploads-Verzeichnis
    $upload_dir      = wp_upload_dir();
    $local_file_path = trailingslashit($upload_dir['basedir']) . 'woocommerce_export.csv';

    // Produkte abrufen (nur veröffentlichte)
    $args = array(
        'status' => array('publish'),
        'limit'  => -1,
    );
    $products = wc_get_products($args);
    if (! $products) {
        return 'Keine Produkte gefunden.';
    }

    // CSV-Header
    $header = array(
        'store_code',
        'place_id',
        'id',
        'post_id',
        'VIN',
        'year',
        'make',
        'model',
        'trim',
        'exterior_color',
        'interior_color',
        'mileage',
        'fuel_efficiency',
        'fuel',
        'ev_range',
        'ev_battery',
        'co2_emission',
        'condition',
        'price',
        'dealership_name',
        'dealership_address',
        'link',
        'image_link',
        'additional_image_link',
        'vehicle_option',
        'vehicle_fulfillment',
        'legal_disclaimer'
    );

    // CSV-Datei erstellen
    $fp = fopen($local_file_path, 'w');
    if (! $fp) {
        return "Konnte CSV nicht erstellen unter: $local_file_path";
    }

    // Kopfzeile in CSV
    fputcsv($fp, $header);

    // Beispiel-Store-Code (ggf. dynamisch anpassbar)
    $store_code = '1';

    // Einheitseinstellung abfragen
    $unit = get_option('autoactiva_vehicle_feed_unit', 'miles');

    // Produkte durchgehen
    foreach ($products as $product) {
        $product_id = $product->get_id();

        // Attribute abfragen
        $pa_vinfull         = $product->get_attribute('pa_vinfull');
        $pa_erstzulassung   = $product->get_attribute('pa_erstzulassung');
        $pa_marke           = $product->get_attribute('pa_marke');
        $pa_modell          = $product->get_attribute('pa_modell');
        $pa_trim            = $product->get_attribute('pa_trim');
        $pa_farbe           = $product->get_attribute('pa_farbe');
        $pa_innenfarbe      = $product->get_attribute('pa_innenfarbe');
        $pa_kilometerstand  = $product->get_attribute('pa_kilometerstand');
        $pa_kraftstoff      = $product->get_attribute('pa_kraftstoff');
        $pa_fahrzeugzustand = $product->get_attribute('pa_fahrzeugzustand');
        $pa_autohaus        = $product->get_attribute('pa_autohaus');
        $pa_adresse         = $product->get_attribute('pa_adresse');

        // Optionale Attribute
        $pa_vehicle_option      = $product->get_attribute('pa_vehicle_option');
        $pa_vehicle_fulfillment = $product->get_attribute('pa_vehicle_fulfillment');
        $pa_legal_disclaimer    = $product->get_attribute('pa_legal_disclaimer');

        // VIN
        $vin = $pa_vinfull ? $pa_vinfull : '';

        // Jahr aus "08.2021" extrahieren
        $year = '';
        if (!empty($pa_erstzulassung)) {
            $year = substr($pa_erstzulassung, -4);
        }

        // Kilometerstand bearbeiten
        $mileage = '';
        if (!empty($pa_kilometerstand)) {
            // Entfernung von Einheiten (z.B. " km")
            $pa_kilometerstand = str_ireplace(array(' km', 'km'), '', $pa_kilometerstand);
            
            // Als Zahl parsen
            $km_value = floatval(trim($pa_kilometerstand));
            
            if ($unit === 'miles') {
                // Umrechnung in Meilen
                $value = $km_value * 0.621371;
                $value = round($value, 2);
                $mileage = $value . ' miles';
            } else {
                // Kilometer beibehalten
                $value = round($km_value, 2);
                $mileage = $value . ' km';
            }
        }

        // Fahrzeugzustand
        $condition = 'used';
        if (strtolower($pa_fahrzeugzustand) === 'neuwagen') {
            $condition = 'new';
        }

        // Preis
        $price = $product->get_price() . ' ' . get_woocommerce_currency();

        // Fuel, EV-Daten, CO2 etc. (nicht genutzt)
        $fuel_efficiency = '';
        $ev_range        = '';
        $ev_battery      = '';
        $co2_emission    = '';
        $fuel           = $pa_kraftstoff;

        // Place ID zum Autohaus-Namen
        $place_id = get_place_id_by_dealership($pa_autohaus);

        // Links
        $link = get_permalink($product_id);

        // Bilder
        $image_id   = $product->get_image_id();
        $image_link = $image_id ? wp_get_attachment_url($image_id) : '';

        $gallery_ids = $product->get_gallery_image_ids();
        $additional_image_link = array();
        if (! empty($gallery_ids)) {
            foreach ($gallery_ids as $gid) {
                $additional_image_link[] = wp_get_attachment_url($gid);
            }
        }
        $additional_image_link_str = implode(',', $additional_image_link);

        // CSV-Zeile
        $data = array(
            $store_code,
            $place_id,
            $product_id,
            $product_id,
            $vin,
            $year,
            $pa_marke,
            $pa_modell,
            $pa_trim,
            $pa_farbe,
            $pa_innenfarbe,
            $mileage,
            $fuel_efficiency,
            $fuel,
            $ev_range,
            $ev_battery,
            $co2_emission,
            $condition,
            $price,
            $pa_autohaus,
            $pa_adresse,
            $link,
            $image_link,
            $additional_image_link_str,
            $pa_vehicle_option,
            $pa_vehicle_fulfillment,
            $pa_legal_disclaimer
        );

        fputcsv($fp, $data);
    }

    fclose($fp);

    // Wenn kein SFTP gewünscht, fertig
    if (! $do_sftp) {
        return true;
    }

    // SFTP nur, wenn Daten vorhanden
    if (empty($sftp_server) || empty($sftp_user) || empty($sftp_password)) {
        return 'SFTP-Daten sind unvollständig. Kein Upload.';
    }

    // Ziel-Dateiname auf dem SFTP-Server
    $remote_file_path = 'woocommerce_export.csv';

    // cURL-Upload
    $upload_res = autoactiva_vehicle_feed_sftp_upload(
        $sftp_server,
        (int) $sftp_port,
        $sftp_user,
        $sftp_password,
        $local_file_path,
        $remote_file_path
    );

    if ($upload_res === true) {
        return true;
    } else {
        return $upload_res; // Fehlermeldung
    }
}

/**
 * ==========================
 * 6) SFTP-Upload mit cURL
 * ==========================
 *
 * @param string $server  SFTP-Server
 * @param int    $port    Port
 * @param string $user    Benutzername
 * @param string $pass    Passwort
 * @param string $local   Pfad zur lokalen Datei
 * @param string $remote  Zielpfad auf dem SFTP-Server
 *
 * @return true|string  true = Erfolg, string = Fehlermeldung
 */
function autoactiva_vehicle_feed_sftp_upload($server, $port, $user, $pass, $local, $remote)
{
    if (! function_exists('curl_init')) {
        return 'cURL ist nicht verfügbar oder nicht aktiviert.';
    }

    // Lokale Datei öffnen
    $fp = @fopen($local, 'r');
    if (! $fp) {
        return "Konnte lokale Datei nicht öffnen: $local";
    }

    // SFTP-URL
    $url = "sftp://{$server}:{$port}/{$remote}";

    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_USERPWD, "{$user}:{$pass}");
    curl_setopt($ch, CURLOPT_UPLOAD, 1);
    curl_setopt($ch, CURLOPT_PROTOCOLS, CURLPROTO_SFTP); // SFTP-Protokoll aktivieren
    curl_setopt($ch, CURLOPT_INFILE, $fp);
    curl_setopt($ch, CURLOPT_INFILESIZE, filesize($local));

    // Timeouts
    curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
    curl_setopt($ch, CURLOPT_TIMEOUT, 300);

    // SSL-Überprüfung ggf. anpassen
    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
    curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);

    // Upload ausführen
    $result  = curl_exec($ch);
    $err_no  = curl_errno($ch);
    $err_msg = curl_error($ch);

    curl_close($ch);
    fclose($fp);

    if ($result === false || $err_no) {
        return "Fehler beim SFTP-Upload: [{$err_no}] {$err_msg}";
    }

    // Upload erfolgreich
    return true;
}

// ---(C) Cron-Intervall definieren + Hook auf Option-Update---
function autoactiva_vehicle_feed_add_cron_schedules($schedules)
{
    if (!isset($schedules['every_24_hours'])) {
        $schedules['every_24_hours'] = array(
            'interval' => 24 * 60 * 60,  // 24 Stunden
            'display'  => __('Alle 24 Stunden (täglich)'),
        );
    }
    return $schedules;
}
add_filter('cron_schedules', 'autoactiva_vehicle_feed_add_cron_schedules');

add_action('update_option_autoactiva_vehicle_feed_auto_upload_enabled', 'autoactiva_vehicle_feed_update_auto_upload_schedule', 10, 2);

function autoactiva_vehicle_feed_update_auto_upload_schedule()
{
    $enabled = get_option('autoactiva_vehicle_feed_auto_upload_enabled', 'no');

    if ($enabled === 'yes') {
        // Einplanen, falls nicht bereits geplant
        if (!wp_next_scheduled('autoactiva_vehicle_feed_daily_cron_event')) {
            // Zeitpunkt: heute um 08:00 oder morgen um 08:00 (falls heute schon vorbei ist)
            $today_8am = strtotime(date('Y-m-d') . ' 08:00:00');
            if (time() > $today_8am) {
                $scheduled_time = strtotime('tomorrow 08:00');
            } else {
                $scheduled_time = $today_8am;
            }
            wp_schedule_event($scheduled_time, 'every_24_hours', 'autoactiva_vehicle_feed_daily_cron_event');
        }
    } else {
        // Deaktivieren: Cron-Event löschen
        $timestamp = wp_next_scheduled('autoactiva_vehicle_feed_daily_cron_event');
        if ($timestamp) {
            wp_unschedule_event($timestamp, 'autoactiva_vehicle_feed_daily_cron_event');
        }
    }
}

// ---(D) Die eigentliche Cron-Callback-Funktion---
add_action('autoactiva_vehicle_feed_daily_cron_event', 'autoactiva_vehicle_feed_daily_cron_callback');
function autoactiva_vehicle_feed_daily_cron_callback()
{
    // Automatisch SFTP-Upload ausführen
    autoactiva_vehicle_feed_run_export(true);
}