fix(tradein/cian): персист bti_data/valuation house_info в houses + дедуп УК (#2435) #2437
No reviewers
Labels
No labels
admin
analytics
auth
automation
bug
business
chore
ci
compliance
data
data-moat
docs
duplicate
dx
enhancement
Fable 5 ревью
feedback/max
generative
GG-форсайт
needs-discussion
needs-human
observability
pause-bots
performance
priority/p0
priority/p1
priority/p2
priority/p3
scope/backend
scope/db
scope/devops
scope/frontend
scope/qa
scrapers
security
site-finder
stage/1
stage/2
status/blocked
status/done
status/needs-analysis
status/needs-fix
status/qa
status/ready
status/review
status/wip
tech-debt
tradein
ux
week ревью 1
wontfix
вторичка
ИРД
No milestone
No project
No assignees
1 participant
Notifications
Due date
No due date set.
Dependencies
No dependencies set.
Reference: lekss361/gendesign#2437
Loading…
Add table
Reference in a new issue
No description provided.
Delete branch "feat/tradein-cian-houses-bti-valuation"
Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?
Summary
Персистит Cian
bti_data+ valuationhouseInfo/managementCompanyв каноническийhouses-ряд (#2435), плюс фикс дедупа УК.37ea0b0f):bti_data/valuation house_info →housesчерезmatch_or_create_house/match_house_readonly, COALESCE-направление поHOUSE_FIELD_PRIORITY, SAVEPOINT-изоляция.db9bec81):_upsert_cian_valuation_management_companyбольше не полагается наON CONFLICT (ext_source, name, ext_id)— приext_id=NULLконфликт под Postgres-дефолтомNULLS DISTINCTникогда не срабатывал (каждый вызов INSERT'ил дубль). Заменено на явныйSELECT ... WHERE ext_id IS NULLперед branch UPDATE/INSERT. Docstring исправлен.Test plan
tests/test_cian_bti_house_persist.py— 11 passed (вкл. новый regressiontest_valuation_management_company_dedups_on_repeat_call_same_name)test_snapshot_writer.py+test_extval_house_id_write_path.py— 32 passed суммарноRefs #2435
Cian secondary-market detail (bti_data) и Valuation Calculator (house_info/ managementCompany/houseId) парсились, но выбрасывались — комментарий "это задача Stage 6 (houses)" так и не был выполнен. - cian/detail.py::save_detail_enrichment принимает инжектируемый matcher (HouseMatcher, optional) → новый _persist_cian_bti_house резолвит дом через match_or_create_house (address/geo листинга, mirror avito/houses.py:: _persist_house) и пишет BTI-эксклюзивные колонки из 020_houses_alter_cian.sql (series_name/entrances/flat_count/is_emergency/heat_supply_type/ gas_supply_type/overlap_type) через COALESCE(new, existing). - cian/valuation.py::_save_to_cache получает уже резолвленный house_id (read-only match_house_readonly, estimator.py) → новый _persist_cian_valuation_house пишет management_company_id (UPSERT management_companies) + cian_internal_house_id (filters.houseId) COALESCE(new, existing), плюс houseInfo.items-производные поля (год/тип/этажность/газ/отопление/перекрытия/подъезды/квартиры/ аварийность/детская площадка/лифты) COALESCE(existing, new) — валюация не авторитетный источник для них (conflict_resolution.HOUSE_FIELD_PRIORITY). - Оба пути best-effort: SAVEPOINT (db.begin_nested) изолирует сбой резолва/ записи дома от основной save-транзакции; house_id=None / matcher=None / безномерный адрес (P1 no_house_number) — graceful no-op, без исключений. - matcher прокинут в реальные call sites: pipeline.py (cian city-sweep + full-load — уже был в scope), cian_history_backfill.py, cian_price_history.py, admin.py ad-hoc endpoint. Gap (нет чистого маппинга на существующую колонку houses — не создавали новых колонок): bti.houseData.{demolishedInMoscowProgramm, heatIndex, houseOverhaulFundType, lifts (недифференцированный total)}; houseInfo.items {Мусоропровод, Реновация, Спортивная площадка, Фонд капремонта}. 10 новых тестов (tests/test_cian_bti_house_persist.py), MagicMock db, без реальной БД — mirror test_snapshot_writer.py / test_extval_house_id_write_path.py.