bot-backend
7cde3b8eaa
All checks were successful
CI Trade-In / changes (pull_request) Successful in 8s
CI / changes (pull_request) Successful in 10s
CI Trade-In / backend-tests (pull_request) Has been skipped
CI Trade-In / browser-tests (pull_request) Has been skipped
CI Trade-In / frontend-checks (pull_request) Has been skipped
CI / frontend-tests (pull_request) Has been skipped
CI / openapi-codegen-check (pull_request) Successful in 2m31s
CI / backend-tests (pull_request) Successful in 17m27s
Шесть функций в site_finder работают на ОБЩЕЙ с analyze_parcel сессии и глотают (OperationalError, ProgrammingError) вокруг db.execute. Без SAVEPOINT проглоченная ошибка оставляет транзакцию в aborted-состоянии: сам lookup возвращает пустой результат «штатно», а падает следующий за ним запрос — в другом месте отчёта и с другой причиной в логе. Соседний ppt_tep_lookup — та же семья, та же таблица planning_projects — SAVEPOINT имел. Правка сводит шесть отставших к нему: planning_lookup, granddoc_lookup, ird_overlay_lookup, functional_zone_lookup, reservation_lookup — по одному db.execute zone_regulation — upsert был защищён, SELECT нет Тест параметризован по всем шести именам, плюс два контроля: «без SAVEPOINT сессия травится» и «здоровый путь по-прежнему читает строки». На origin/main шесть падают с AbortedTransactionError, оба контроля зелёные. Стабы _FakeDB/_DB в пяти существующих тестах получили no-op begin_nested — без него 28 тестов падали на AttributeError. В шапке каждого стаба указано, где SAVEPOINT проверяется по-настоящему, чтобы no-op не читался как покрытие. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
62 lines
3.1 KiB
Python
62 lines
3.1 KiB
Python
"""ППТ/ПМТ planning-overlay lookup для analyze_parcel (#1085 analyze-wiring).
|
||
|
||
Читает ``planning_projects`` (м.134, наполняется planning_harvest #1085) и отдаёт проекты
|
||
планировки/межевания, пересекающие участок: что/где утверждено к застройке (future-supply).
|
||
Комплементарно ИРД-overlay (``ird_overlay_lookup``): тот — ограничения участка, этот — граддоки.
|
||
|
||
Graceful: если таблица ``planning_projects`` ещё не задеплоена (pre-migration) или БД-ошибка —
|
||
возвращает пустой список (analyze не падает). Wiring в analyze — за тем же флагом, что ИРД (D9b).
|
||
"""
|
||
|
||
from __future__ import annotations
|
||
|
||
import logging
|
||
from typing import Any
|
||
|
||
from sqlalchemy import text
|
||
from sqlalchemy.exc import OperationalError, ProgrammingError
|
||
from sqlalchemy.orm import Session
|
||
|
||
logger = logging.getLogger(__name__)
|
||
|
||
# ППТ/ПМТ overlap по участку: ST_Intersects через GIST idx_planning_projects_geom. geom уже 4326
|
||
# (harvest стор WFS geoloc как 4326). Участок — WKT в 4326. CAST psycopg v3.
|
||
_PLANNING_OVERLAP_SQL = text(
|
||
"""
|
||
SELECT project_type, doc_status_name, full_name, project_name, dmd_actual_year
|
||
FROM planning_projects
|
||
WHERE ST_Intersects(geom, ST_GeomFromText(CAST(:parcel_wkt AS text), 4326))
|
||
ORDER BY project_type, dmd_actual_year DESC NULLS LAST
|
||
"""
|
||
)
|
||
|
||
|
||
def parcel_planning_overlaps(db: Session, parcel_wkt: str | None) -> list[dict[str, Any]]:
|
||
"""ППТ/ПМТ, пересекающие участок.
|
||
|
||
Args:
|
||
db: сессия.
|
||
parcel_wkt: геометрия участка в WKT (EPSG:4326). None → пустой список.
|
||
|
||
Returns:
|
||
list[{project_type, doc_status_name, full_name, project_name, dmd_actual_year}].
|
||
Пусто при отсутствии участка/таблицы/пересечений (analyze не падает).
|
||
"""
|
||
if not parcel_wkt:
|
||
return []
|
||
try:
|
||
# #2464: SAVEPOINT перед проглатыванием ошибки. Сессия ОБЩАЯ с analyze_parcel
|
||
# (build_ird_analyze_block зовёт шесть таких lookup'ов подряд в одном словаре),
|
||
# и на Postgres упавший запрос оставляет транзакцию в aborted-состоянии —
|
||
# падают все следующие, включая запись прогона. Образец рядом:
|
||
# ppt_tep_lookup.py делает ровно так же.
|
||
with db.begin_nested():
|
||
rows = db.execute(_PLANNING_OVERLAP_SQL, {"parcel_wkt": parcel_wkt}).mappings().all()
|
||
except (OperationalError, ProgrammingError) as exc:
|
||
# Таблица ещё не задеплоена / БД-ошибка — graceful degrade.
|
||
logger.warning("parcel_planning_overlaps: planning_projects недоступна, skip: %s", exc)
|
||
return []
|
||
return [dict(r) for r in rows]
|
||
|
||
|
||
__all__ = ["parcel_planning_overlaps"]
|