<?php

require_once("/var/www/thetool/config/config.php");

define('FRONKDB_SQLDEBUG', false);
error_reporting(E_ALL & ~(E_NOTICE | E_STRICT | E_DEPRECATED));

require_once(LIBDIR . "/mvcfronk/mfRouter/mfRouter.php");
require_once(LIBDIR . "/mvcfronk/mfBase/mfBaseModel.php");
require_once(LIBDIR . "/mvcfronk/mfBase/mfBaseController.php");

$pgHost = QGIS_DBHOST;
$pgPort = '5432';
$pgDb   = QGIS_DBNAME;
$pgUser = QGIS_DBUSER;
$pgPass = QGIS_DBPASS;
$targetSchema = '"ON Leibnitz"';
$targetTable  = 'Preorders';

define("INTERNAL_USER_ID", 154);

class PreorderSyncWrapper extends PreorderController {
    public static $capturedResult = null;

    protected function init() {
        $this->me = new User(INTERNAL_USER_ID);
        $this->layout()->setTemplate(null);
    }

    public static function returnJson($data) {
        self::$capturedResult = $data;
    }
}

$apiParams = [
    'mod' => 'Preorder',
    'action' => 'api',
    'do' => 'getFilteredPreorders',
    'filter' => [
        'preordercampaign_id' => 99
    ]
];

new PreorderSyncWrapper($apiParams);
$response = PreorderSyncWrapper::$capturedResult;

if (!$response || !isset($response['status']) || $response['status'] !== 'OK') {
    die("Fehler beim Abrufen der Daten oder keine Daten erhalten.\n");
}

$preorders = $response['result']['preorders'] ?? [];

try {
    $dsn = "pgsql:host=$pgHost;port=$pgPort;dbname=$pgDb";
    $pdo = new PDO($dsn, $pgUser, $pgPass, [PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION]);
} catch (PDOException $e) {
    die("Verbindung zu PostgreSQL fehlgeschlagen: " . $e->getMessage() . "\n");
}

$pdo->exec("CREATE SCHEMA IF NOT EXISTS $targetSchema");

$createTableSql = <<<SQL
CREATE TABLE IF NOT EXISTS $targetSchema."$targetTable" (
    id INTEGER PRIMARY KEY,
    type VARCHAR(50),
    type_label VARCHAR(100),
    strasse VARCHAR(255),
    hausnummer VARCHAR(50),
    plz VARCHAR(10),
    ort VARCHAR(100),
    geom geometry(Point, 4326),
    company VARCHAR(255),
    firstname VARCHAR(255),
    lastname VARCHAR(255),
    phone VARCHAR(100),
    email VARCHAR(255),
    status_code INTEGER,
    status_id INTEGER,
    oaid VARCHAR(255),
    updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);
CREATE INDEX IF NOT EXISTS idx_preorders_geom ON $targetSchema."$targetTable" USING GIST (geom);
SQL;

$pdo->exec($createTableSql);

$pdo->exec("ALTER TABLE $targetSchema.\"$targetTable\" ADD COLUMN IF NOT EXISTS company VARCHAR(255)");
$pdo->exec("ALTER TABLE $targetSchema.\"$targetTable\" ADD COLUMN IF NOT EXISTS firstname VARCHAR(255)");
$pdo->exec("ALTER TABLE $targetSchema.\"$targetTable\" ADD COLUMN IF NOT EXISTS lastname VARCHAR(255)");
$pdo->exec("ALTER TABLE $targetSchema.\"$targetTable\" ADD COLUMN IF NOT EXISTS phone VARCHAR(100)");
$pdo->exec("ALTER TABLE $targetSchema.\"$targetTable\" ADD COLUMN IF NOT EXISTS email VARCHAR(255)");
$pdo->exec("ALTER TABLE $targetSchema.\"$targetTable\" ADD COLUMN IF NOT EXISTS status_code INTEGER");
$pdo->exec("ALTER TABLE $targetSchema.\"$targetTable\" ADD COLUMN IF NOT EXISTS status_id INTEGER");
$pdo->exec("ALTER TABLE $targetSchema.\"$targetTable\" ADD COLUMN IF NOT EXISTS oaid VARCHAR(255)");

$sqlUpsert = <<<SQL
INSERT INTO $targetSchema."$targetTable" 
(id, type, type_label, strasse, hausnummer, plz, ort, geom, company, firstname, lastname, phone, email, status_code, status_id, oaid, updated_at)
VALUES 
(:id, :type, :type_label, :strasse, :hausnummer, :plz, :ort, ST_SetSRID(ST_MakePoint(:lon, :lat), 4326), :company, :firstname, :lastname, :phone, :email, :status_code, :status_id, :oaid, NOW())
ON CONFLICT (id) DO UPDATE SET
    type = EXCLUDED.type,
    type_label = EXCLUDED.type_label,
    strasse = EXCLUDED.strasse,
    hausnummer = EXCLUDED.hausnummer,
    plz = EXCLUDED.plz,
    ort = EXCLUDED.ort,
    geom = EXCLUDED.geom,
    company = EXCLUDED.company,
    firstname = EXCLUDED.firstname,
    lastname = EXCLUDED.lastname,
    phone = EXCLUDED.phone,
    email = EXCLUDED.email,
    status_code = EXCLUDED.status_code,
    status_id = EXCLUDED.status_id,
    oaid = EXCLUDED.oaid,
    updated_at = NOW()
WHERE
    "$targetTable".type IS DISTINCT FROM EXCLUDED.type OR
    "$targetTable".type_label IS DISTINCT FROM EXCLUDED.type_label OR
    "$targetTable".strasse IS DISTINCT FROM EXCLUDED.strasse OR
    "$targetTable".hausnummer IS DISTINCT FROM EXCLUDED.hausnummer OR
    "$targetTable".plz IS DISTINCT FROM EXCLUDED.plz OR
    "$targetTable".ort IS DISTINCT FROM EXCLUDED.ort OR
    "$targetTable".geom IS DISTINCT FROM EXCLUDED.geom OR
    "$targetTable".company IS DISTINCT FROM EXCLUDED.company OR
    "$targetTable".firstname IS DISTINCT FROM EXCLUDED.firstname OR
    "$targetTable".lastname IS DISTINCT FROM EXCLUDED.lastname OR
    "$targetTable".phone IS DISTINCT FROM EXCLUDED.phone OR
    "$targetTable".email IS DISTINCT FROM EXCLUDED.email OR
    "$targetTable".status_code IS DISTINCT FROM EXCLUDED.status_code OR
    "$targetTable".status_id IS DISTINCT FROM EXCLUDED.status_id OR
    "$targetTable".oaid IS DISTINCT FROM EXCLUDED.oaid;
SQL;

$stmt = $pdo->prepare($sqlUpsert);

$processedIds = [];
$countUpsert = 0;
$countUnchanged = 0;
$countSkipped = 0;

$pdo->beginTransaction();

foreach ($preorders as $po) {
    $id = $po->id;
    $gps_lat = $po->gps_lat;
    $gps_long = $po->gps_long;

    if (empty($gps_lat) || empty($gps_long)) {
        $countSkipped++;
        continue;
    }

    $latVal = str_replace(',', '.', $gps_lat);
    $lonVal = str_replace(',', '.', $gps_long);

    $params = [
        ':id' => $id,
        ':type' => $po->type,
        ':type_label' => $po->type_label,
        ':strasse' => $po->adb_strasse,
        ':hausnummer' => $po->adb_hausnummer,
        ':plz' => $po->adb_plz,
        ':ort' => $po->adb_ort,
        ':company' => $po->company,
        ':firstname' => $po->firstname,
        ':lastname' => $po->lastname,
        ':phone' => $po->phone,
        ':email' => $po->email,
        ':status_code' => $po->status_code,
        ':status_id' => $po->status_id,
        ':oaid' => $po->oaid,
        ':lat' => $latVal,
        ':lon' => $lonVal
    ];

    $stmt->execute($params);
    $processedIds[] = $id;
    if ($stmt->rowCount() > 0) {
        $countUpsert++;
    } else {
        $countUnchanged++;
    }
}

$deletedCount = 0;
if (!empty($processedIds)) {
    $inQuery = implode(',', array_map('intval', $processedIds));
    $deleteSql = "DELETE FROM $targetSchema.\"$targetTable\" WHERE id NOT IN ($inQuery)";
    $deletedCount = $pdo->exec($deleteSql);
} else {

    if (count($preorders) == 0) {
    }
}

$pdo->commit();

//echo "Sync fertig.\n";
//echo "Neu erstellt oder aktualisiert: $countUpsert\n";
//echo "Unverändert (kein Update nötig): $countUnchanged\n";
//echo "Ohne Koordinaten (übersprungen): $countSkipped\n";
//echo "Gelöscht (nicht mehr in Quelle): $deletedCount\n";