feat(tradein): estimator deals tier (PR M, #564 Phase 3) (#600)

tradein-mvp/backend/app/schemas/trade_in.py

@@ -44,6 +44,12 @@ class AnalogLot(BaseModel):
     source: str | None = None          # 'avito' / 'cian' / 'domklik' / 'rosreestr'
     source_url: str | None = None      # ссылка на оригинальное объявление / сделку
     distance_m: int | None = None      # расстояние до целевой квартиры в метрах
+    # ── Confidence tier (PR M / #564 Phase 3) ──
+    # Только для rosreestr-сделок: T0_per_house (kadastr_num exact match),
+    # T1_per_street (street-level only). Open dataset Росреестра не имеет
+    # kadastr_num — все ДКП-сделки сейчас T1. Поле зарезервировано на случай
+    # будущего enrichment data feed (ЕГРН direct).
+    tier: str | None = None
 
 
 class CianChartPoint(BaseModel):

tradein-mvp/backend/app/services/estimator.py

@@ -575,9 +575,12 @@ def _save_yandex_history_items(
 async def estimate_quality(payload: TradeInEstimateInput, db: Session) -> AggregatedEstimate:
     """Главная функция — оценка квартиры по реальным данным.
 
-    NOTE 2026-05-24: rosreestr_deals temporarily NOT included in actual_deals
-    output (they contain ДДУ first-market data that skews secondary-market
-    median). See Decision_TradeIn_DataQuality_8PR_Roadmap.
+    PR M / #564 Phase 3: rosreestr_deals **included** в actual_deals output.
+    Stale NOTE 2026-05-24 (про ДДУ contamination) устарел — importer
+    `import-rosreestr.sh` после PR-A 2026-05-24 фильтрует doc_type='ДКП',
+    ДДУ первички исключены. Deals идут в `actual_deals` JSONB поле
+    AggregatedEstimate с tier classification (T0_per_house / T1_per_street)
+    — frontend может разделять confidence в UI.
 
     Returns:
         AggregatedEstimate с estimate_id, медианой, диапазоном, аналогами.
@@ -1582,6 +1585,7 @@ def _fetch_deals(
                 rooms, area_m2, floor, total_floors,
                 price_rub, price_per_m2,
                 deal_date, days_on_market,
+                kadastr_num,
                 ST_Distance(geom::geography, ST_MakePoint(:lon, :lat)::geography) AS distance_m
             FROM deals
             WHERE ST_DWithin(geom::geography, ST_MakePoint(:lon, :lat)::geography, :radius)
@@ -1736,7 +1740,16 @@ def _listing_to_analog(row: dict[str, Any]) -> AnalogLot:
 
 
 def _deal_to_analog(row: dict[str, Any]) -> AnalogLot:
-    """deals не имеют photo_url — упрощённо."""
+    """deals не имеют photo_url — упрощённо.
+
+    Tier classification (PR M / #564 Phase 3):
+        T0_per_house — kadastr_num exact match (НЕ доступно в open dataset Росреестра)
+        T1_per_street — street-level only (default для всех ДКП open dataset)
+    """
+    kad = row.get("kadastr_num")
+    # Per-house tier требует kadastr_num типа "66:41:0204016:10" (с участком).
+    # Street-only patterns: "66:41:0000000:0" или NULL → T1.
+    tier = "T0_per_house" if kad and not kad.endswith(":0") else "T1_per_street"
     return AnalogLot(
         address=row.get("address") or "",
         area_m2=float(row.get("area_m2") or 0),
@@ -1751,6 +1764,7 @@ def _deal_to_analog(row: dict[str, Any]) -> AnalogLot:
         source=row.get("source"),
         source_url=None,  # rosreestr сделки без публичной ссылки
         distance_m=int(row["distance_m"]) if row.get("distance_m") is not None else None,
+        tier=tier,
     )