`jdZddlmZddlZddlmZddlmZddlm Z ddl m Z erddl m Z ejeZd d Z dd Z dd Z dd Zy)arGuestStay synchronization service. This service ensures that GuestStay rows exist for every (booking, guest) pair, with proper idswh generation and lifecycle management. Architecture: - GuestStay is the canonical regulatory identity root - idswh is generated once at creation and never recomputed - Exports (Ross1000, C59, ISTAT) only READ stored identities - This service is the ONLY place where GuestStay rows are created/updated/deleted Usage: from guests.services.guest_stay_service import sync_guest_stays_for_booking # After creating/updating a booking with guests: sync_guest_stays_for_booking(booking) ) annotationsN)date) TYPE_CHECKING) transaction) GuestStay)Bookingc |j}t|jjdd}|sKtj j |j\}}|rtjd||yttj j |jd}|Dcic]}|j|}}t|j}||z } ||z} ||z } | r t|| | r t|| || r t!|| tjd|t#| t#| t#| ycc}w) aSynchronize GuestStay rows for a booking and its guests. This function ensures that: 1. A GuestStay exists for every guest currently linked to the booking 2. Existing GuestStay rows are preserved (idswh never changes) 3. Check-in/check-out dates are synced from the booking 4. Orphan GuestStay rows (for removed guests) are deleted 5. The operation is idempotent (safe to run multiple times) Business rules: - idswh is generated automatically by GuestStay.save() on first creation - Once generated, idswh is NEVER modified or regenerated - GuestStay lifecycle is tied to booking guest membership, not check-in status - Identity exists for the entire stay lifecycle (from booking creation onward) Args: booking: The Booking instance to sync GuestStay rows for. Performance: - Single query to fetch existing GuestStay rows - Single query to fetch current guests - Bulk delete for orphan rows - No N+1 queries Example: >>> booking = Booking.objects.create(...) >>> sync_booking_guests(booking=booking, guests_data=[...]) >>> sync_guest_stays_for_booking(booking) # Creates GuestStay rows idT)flat)bookingz=GuestStay: removed %d orphan stays for booking %d (no guests)NguestuCGuestStay: synced booking %d — created=%d, updated=%d, deleted=%d)r setguests values_listrobjectsfilterdeleteloggerinfolistselect_relatedguest_idkeys_create_guest_stays_update_guest_stay_dates_delete_orphan_guest_stayslen) r booking_idcurrent_guest_ids deleted_count_existing_staysstayexisting_by_guest_idexisting_guest_idsguest_ids_to_createguest_ids_to_updateguest_ids_to_deletes ./backend/guests/services/guest_stay_service.pysync_guest_stays_for_bookingr*$sm<J""4d"3 $,,33G3DKKM q  KKO     1@@IN=KKNDDMM4/NK16689,.@@+.@@,/@@G%89    "7,?@ KKM      1Ls<Ec8|j}|j}|j}d}|D]+} tjj |||||dz }-|rtjd||yy#t $r}tjd|||d}~wwxYw)aCreate GuestStay rows for new guests. Each GuestStay is created individually to trigger the save() method, which auto-generates the idswh token. Args: booking: The parent booking. guest_ids: Set of guest IDs that need GuestStay rows created. r)r r check_in_datecheck_out_datez>GuestStay: failed to create stay for guest %d / booking %d: %sNz.GuestStay: created %d new stays for booking %d) r r,r-rrcreate Exceptionrerrorr)r guest_idsrcheck_in check_out created_countrexcs r)rrysJ$$H&&IM     $ $!&( %  Q M$ <     LLP    s(A22 B;BBc|j}|j}|j}g}|D]T}|j|}||j|k7s|j|k7s6||_||_|j |V|rDt j j|gdtjdt||yy)ufUpdate check-in/check-out dates on existing GuestStay rows. This preserves the idswh token while keeping dates in sync with the booking. Args: booking: The parent booking (source of truth for dates). guest_ids: Set of guest IDs that need date updates. existing_by_guest_id: Dict mapping guest_id → GuestStay instance. N)r,r- updated_at)fieldsz3GuestStay: updated dates for %d stays on booking %d) r r,r-getappendrr bulk_updaterrr) r r2r$rr3r4stays_to_updaterr#s r)rrsJ$$H&&IO#''1 <     )T-@-@I-M!)D "+D   " "4 (%% D &   A   c|j}tjj||j \}}|r"t j d||t|yy)zDelete GuestStay rows for guests that were removed from the booking. Args: booking: The parent booking. guest_ids: Set of guest IDs whose GuestStay rows should be deleted. )r guest_id__inz>GuestStay: deleted %d orphan stays for booking %d (guests: %s)N)r rrrrrrsorted)r r2rr r!s r)rrsgJ!((//0 fhM1  L   9   r>)r 'Booking'returnNone)r rBr2set[int]rCrD)r rBr2rEr$zdict[int, GuestStay]rCrD)__doc__ __future__rloggingdatetimertypingr django.dbr guests.modelsrbookings.modelsr getLogger__name__rr*rrrr>r)rQs$# !#'   8 $Rj) ) )  ) X( ( ( /(  ( V     r>