diff --git a/solution/backend/crud/place_itinerary_crud.py b/solution/backend/crud/place_itinerary_crud.py new file mode 100644 index 0000000..d6ea49a --- /dev/null +++ b/solution/backend/crud/place_itinerary_crud.py @@ -0,0 +1,41 @@ +from sqlalchemy import select +from sqlalchemy.dialects.postgresql import insert as pg_insert + +from common.database.db_session_manager import DB_SESSION_MNG +from common.database.model.models import place_itineraries +from common.utils.gtime import GTime + + +class PlaceItineraryCRUD: + async def list_by_place(self, db, place_id): + """업장의 일정 전부(기간별 한 행). 정렬은 기간 이름 순이 아니라 저장 순이 아니다 — + 화면 탭 순서는 읽는 쪽(`snapshot._local_contents`)이 DURATIONS 순으로 정한다.""" + return await DB_SESSION_MNG.execute( + db, + select(place_itineraries).where( + place_itineraries.place_id == place_id, + place_itineraries.deleted == False, # noqa: E712 + ), + ) + + async def upsert(self, db, values: dict): + """업장 × 기간 한 행의 삽입/갱신. + + ★ `uq_place_itineraries`(place_id, duration — deleted = false)에 태운다. + ON CONFLICT 술어는 인덱스 술어와 **글자 그대로** 같아야 한다. 아니면 포스트그레스가 + "no unique or exclusion constraint matching" 으로 거절한다 — 표도 컬럼도 멀쩡해서 + 눈으로는 원인이 안 보인다(`local_content_crud.upsert_kind` 주석과 같은 함정). + """ + stmt = pg_insert(place_itineraries).values(**values) + stmt = stmt.on_conflict_do_update( + index_elements=[place_itineraries.place_id, place_itineraries.duration], + index_where=(place_itineraries.deleted == False), # noqa: E712 + set_={ + "body": stmt.excluded.body, + "generated_by": stmt.excluded.generated_by, + "model": stmt.excluded.model, + "generated_at": stmt.excluded.generated_at, + "updated_at": GTime.UTC(), + }, + ) + return await DB_SESSION_MNG.add(db, stmt) diff --git a/solution/backend/tests/test_place_itinerary_crud.py b/solution/backend/tests/test_place_itinerary_crud.py new file mode 100644 index 0000000..273d8f2 --- /dev/null +++ b/solution/backend/tests/test_place_itinerary_crud.py @@ -0,0 +1,90 @@ +"""place_itineraries 읽기·덮어쓰기. + +이 표가 지켜야 하는 것: + - 업장 × 기간 = 한 행. 다시 생성하면 그 행을 덮어쓴다(행이 늘지 않는다) + - 다른 업장·다른 기간은 서로를 건드리지 않는다 +""" +import uuid + +from common.database.db_session_manager import DB_SESSION_MNG +from common.database.model.models import place_itineraries +from common.enums import DBWRType, ErrorType, SourceType +from common.utils.gtime import GTime +from crud.place_itinerary_crud import PlaceItineraryCRUD + +_CRUD = PlaceItineraryCRUD() + + +def _values(place_id, duration: str, names: list[str]) -> dict: + return { + "place_itinerary_id": uuid.uuid4(), + "place_id": place_id, + "duration": duration, + "body": [{"name": n, "duration": duration, "days": [{"label": "1일차", "stops": [{"name": "가"}]}]} + for n in names], + "generated_by": SourceType.LLM.value, + "model": "perplexity:sonar", + "generated_at": GTime.UTC(), + } + + +async def _upsert(values: dict) -> ErrorType: + return await DB_SESSION_MNG.execute_lambda_run( + [place_itineraries.DBType()], [lambda s: _CRUD.upsert(s, values)], + ) + + +async def _rows(place_id): + err, rows = await DB_SESSION_MNG.execute_lambda( + place_itineraries.DBType(), DBWRType.DB_READ.value, + lambda s: _CRUD.list_by_place(s, place_id), + ) + assert err == ErrorType.SUCCESS + return list(rows or []) + + +async def test_upsert_then_read(db_engine): + """검증: 넣고 읽는다. + 기대결과: body 가 그대로 돌아온다 — 렌더러 계약을 그 자리에서 담는다.""" + pid = uuid.uuid4() + assert await _upsert(_values(pid, "1박 2일", ["코스A", "코스B"])) == ErrorType.SUCCESS + + rows = await _rows(pid) + assert len(rows) == 1 + assert rows[0].duration == "1박 2일" + assert [c["name"] for c in rows[0].body] == ["코스A", "코스B"] + assert rows[0].generated_by == SourceType.LLM.value + + +async def test_upsert_overwrites_same_place_and_duration(db_engine): + """검증: 같은 업장·같은 기간을 다시 넣는다. + 기대결과: 행이 늘지 않고 body 가 바뀐다(uq_place_itineraries).""" + pid = uuid.uuid4() + await _upsert(_values(pid, "1박 2일", ["옛 코스"])) + await _upsert(_values(pid, "1박 2일", ["새 코스1", "새 코스2"])) + + rows = await _rows(pid) + assert len(rows) == 1 + assert [c["name"] for c in rows[0].body] == ["새 코스1", "새 코스2"] + + +async def test_two_durations_live_side_by_side(db_engine): + """검증: 같은 업장의 두 기간. + 기대결과: 각각 한 행 — 1박2일이 2박3일을 덮지 않는다.""" + pid = uuid.uuid4() + await _upsert(_values(pid, "1박 2일", ["짧은 코스"])) + await _upsert(_values(pid, "2박 3일", ["긴 코스"])) + + rows = await _rows(pid) + assert {r.duration for r in rows} == {"1박 2일", "2박 3일"} + + +async def test_other_place_is_untouched(db_engine): + """검증: 다른 업장. + 기대결과: 서로 안 보인다 — 키가 place_id 다.""" + mine, other = uuid.uuid4(), uuid.uuid4() + await _upsert(_values(mine, "1박 2일", ["내 코스"])) + await _upsert(_values(other, "1박 2일", ["남의 코스"])) + + assert [c["name"] for c in (await _rows(mine))[0].body] == ["내 코스"] + assert [c["name"] for c in (await _rows(other))[0].body] == ["남의 코스"]