Aggiunta migrazione campi valutazione motornet

2026-04-29 09:04:23 +02:00
parent 79817a6c9c
commit 39396362af
1 changed files with 63 additions and 0 deletions
@@ -0,0 +1,63 @@
+"""add motornet_valuations table
+
+Revision ID: 0002
+Revises: 0001
+Create Date: 2026-04-28 18:00:00.000000
+
+"""
+from typing import Sequence, Union
+from alembic import op
+import sqlalchemy as sa
+
+revision: str = "0002"
+down_revision: Union[str, None] = "0001"
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    op.execute("""
+        CREATE TABLE IF NOT EXISTS motornet_valuations (
+            id SERIAL PRIMARY KEY,
+            valuation_id INTEGER NOT NULL REFERENCES valuations(id),
+            plate VARCHAR(10) NOT NULL,
+            motornet_code VARCHAR(20),
+            fetched_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+
+            registration_year INTEGER,
+            registration_month INTEGER,
+            mileage INTEGER,
+
+            motornet_id INTEGER,
+            ediz_dati VARCHAR(20),
+            brand_name VARCHAR(100),
+            model_description VARCHAR(200),
+            allestimento VARCHAR(255),
+            alimentazione VARCHAR(100),
+            immagine_url VARCHAR(500),
+            xml_url VARCHAR(500),
+            percorrenza_media_km INTEGER,
+
+            quotazione_blu NUMERIC(12,2),
+            quotazione_blu_km NUMERIC(12,2),
+            quotazione_giallo NUMERIC(12,2),
+            quotazione_giallo_km NUMERIC(12,2),
+            quotazione_blu_totale NUMERIC(12,2),
+            quotazione_giallo_totale NUMERIC(12,2),
+            variazione_km NUMERIC(12,2),
+
+            prezzo_listino NUMERIC(12,2),
+            prezzo_accessori NUMERIC(12,2),
+            totale_riparazioni_carrozzeria NUMERIC(12,2),
+            totale_riparazioni_meccanica NUMERIC(12,2),
+
+            raw_response JSONB
+        );
+
+        CREATE INDEX IF NOT EXISTS ix_motornet_valuations_valuation_id ON motornet_valuations(valuation_id);
+        CREATE INDEX IF NOT EXISTS ix_motornet_valuations_plate ON motornet_valuations(plate);
+    """)
+
+
+def downgrade() -> None:
+    op.execute("DROP TABLE IF EXISTS motornet_valuations;")