diff --git a/scripts/fiberplan/sync_preorder_qgis.php b/scripts/fiberplan/sync_preorder_qgis.php index 202058038..01b66d530 100644 --- a/scripts/fiberplan/sync_preorder_qgis.php +++ b/scripts/fiberplan/sync_preorder_qgis.php @@ -96,6 +96,10 @@ CREATE TABLE IF NOT EXISTS $targetSchema."$targetTable" ( type_label VARCHAR(100), strasse VARCHAR(255), hausnummer VARCHAR(50), + block VARCHAR(50), + stiege VARCHAR(50), + stock VARCHAR(50), + tuer VARCHAR(50), plz VARCHAR(10), ort VARCHAR(100), geom geometry(Point, 4326), @@ -104,6 +108,7 @@ CREATE TABLE IF NOT EXISTS $targetSchema."$targetTable" ( lastname VARCHAR(255), phone VARCHAR(100), email VARCHAR(255), + note TEXT, status_code INTEGER, status_id INTEGER, oaid VARCHAR(255), @@ -119,20 +124,29 @@ SQL; $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 note TEXT"); $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)"); + $pdo->exec("ALTER TABLE $targetSchema.\"$targetTable\" ADD COLUMN IF NOT EXISTS block VARCHAR(50)"); + $pdo->exec("ALTER TABLE $targetSchema.\"$targetTable\" ADD COLUMN IF NOT EXISTS stiege VARCHAR(50)"); + $pdo->exec("ALTER TABLE $targetSchema.\"$targetTable\" ADD COLUMN IF NOT EXISTS stock VARCHAR(50)"); + $pdo->exec("ALTER TABLE $targetSchema.\"$targetTable\" ADD COLUMN IF NOT EXISTS tuer VARCHAR(50)"); $sqlUpsert = << $po->type_label, ':strasse' => $po->adb_strasse, ':hausnummer' => $po->adb_hausnummer, + ':block' => $po->block, + ':stiege' => $po->stiege, + ':stock' => $po->stock, + ':tuer' => $po->tuer, ':plz' => $po->adb_plz, ':ort' => $po->adb_ort, ':company' => $po->company, @@ -198,6 +222,7 @@ SQL; ':lastname' => $po->lastname, ':phone' => $po->phone, ':email' => $po->email, + ':note' => $po->note, ':status_code' => $po->status_code, ':status_id' => $po->status_id, ':oaid' => $po->oaid, @@ -205,6 +230,7 @@ SQL; ':lon' => $lonVal ]; + $stmt->execute($params); $processedIds[] = $id; if ($stmt->rowCount() > 0) {