use Hudson Square project geometry source data

to correct a ZAP project until we use the lates ZAP data

Author: damonmcc

products/knownprojects/bash/01_dataloading.sh

@@ -21,6 +21,7 @@ python3 -m python.extractors dcp_n_study_projected
 python3 -m python.extractors hpd_rfp
 python3 -m python.extractors dcp_planneradded
 python3 -m python.extractors dcp_knownprojects
+python3 -m python.extractors dcp_hudsonsquare
 
 # Load corrections tables
 run_sql_file sql/create_corrections.sql

products/knownprojects/python/__init__.py

@@ -33,6 +33,7 @@
     "dcp_n_study_projected": "past_neighborhoodstudies_20260305.zip",
     "hpd_rfp": "HPD_RFPs_20250110.xlsx",
     "dcp_planneradded": "dcp_planneradded_2025_04_30.csv",
+    "dcp_hudsonsquare": "HudsonSquare_P2012M0255_4326.zip",
 }
 DCP_HOUSING_CORRECTIONS_FILENAMES = {
     "corrections_dob": "corrections_dob.csv",

products/knownprojects/python/extractors.py

@@ -72,6 +72,17 @@ def dcp_n_study_projected(filename: str) -> gpd.GeoDataFrame:
     return df
 
 
+@ETL
+def dcp_hudsonsquare(filename: str) -> gpd.GeoDataFrame:
+    # df = gpd.read_file(f"zip://{RAW_DATA_PATH}/{filename}")
+
+    filename_prefix = f"{filename}".split(".")[0]
+    with zipfile.ZipFile(f"{RAW_DATA_PATH}/{filename}", "r") as zip_ref:
+        zip_ref.extractall(f"{RAW_DATA_PATH}")
+    df = gpd.read_file(f"{RAW_DATA_PATH}/{filename_prefix}/{filename_prefix}.shp")
+    return df
+
+
 @ETL
 def hpd_rfp(filename: str) -> pd.DataFrame:
     df = pd.read_excel(f"{RAW_DATA_PATH}/{filename}", dtype=str)

products/knownprojects/sql/dcp_application.sql

@@ -347,6 +347,20 @@ geom_ulurp AS (
     ) AS a LEFT JOIN dcp_zoningmapamendments AS zma
         ON a.dcp_ulurpnumber = zma.ulurpno
     GROUP BY a.record_id, a.geom
+),
+
+-- Correcting geometry for Hudson Square project (P2012M0255) while using old ZAP data
+geom_corrections AS (
+    SELECT
+        a.record_id,
+        CASE
+            WHEN a.record_id = 'P2012M0255'
+                THEN b.geometry
+            ELSE a.geom
+        END AS geom
+    FROM geom_ulurp AS a
+    LEFT JOIN dcp_hudsonsquare AS b
+        ON a.record_id = b.projectid
 )
 
 -- Main table with the geometry lookup
@@ -355,5 +369,5 @@ SELECT
     b.geom
 INTO dcp_application
 FROM _dcp_application AS a
-LEFT JOIN geom_ulurp AS b
+LEFT JOIN geom_corrections AS b
     ON a.record_id = b.record_id;