Preorder Sync Script ins Qgis
Achtung config erweitert QGIS_DBHOST usw.
This commit is contained in:
Daniel Spitzer
204
scripts/fiberplan/sync_preorder_qgis.php
Normal file
204
scripts/fiberplan/sync_preorder_qgis.php
Normal file
@@ -0,0 +1,204 @@
|
||||
<?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";
|
||||
Reference in New Issue
Block a user