`jN dZddlmZddlmZddlmZddlmZddl m Z ddl m Z m Z mZd dZdd Z dd Z dd Zy )aOC59 aggregation builder for Liguria ISTAT XML export. Transforms guest-night level data into aggregated C59 rows grouped by residence (Italian province or foreign country) for daily movement reporting. This module is fully isolated under xml_export/ and does not modify any existing TXT export, old ISTAT services, or API endpoints. ) annotations)date)Iterable)Booking)IstatC59RowPayload)build_daily_c59_rows"build_daily_c59_rows_for_structureresolve_c59_residence_codecF|xsdjjS)z?Normalize a province/country code to uppercase stripped string.)stripupper)values =/backend/istat/xml_export/builders/c59_aggregation_builder.py_normalize_coders KR   & & ((ct||S)N)r )countryprovinces r_resolve_residence_coders %gx 88rc\t|}|rt|dddnd}t|||S)zBuild daily C59 rows for the requested day. C59 files are daily. ``period_end`` is accepted for backward-compatible callers, but aggregation is intentionally performed for ``period_start``. r structureN)r target_datebookings)listgetattrr)r period_start period_end booking_listrs rbuild_c59_aggregation_payloadsr !s:>L?K Qd;QUI   rct||S)aBuild C59 aggregation payloads for a specific structure and date range. Convenience wrapper that fetches bookings for the structure and delegates to build_c59_aggregation_payloads. Args: structure_id: ID of the Structure to report on start_date: Start date (inclusive) for reporting period end_date: End date (inclusive) for reporting period Returns: List of IstatC59RowPayload sorted by (nazione, residenza) ) structure_idr)r )r" start_dateend_dates r,build_c59_aggregation_payloads_for_structurer%4s$ .! rN)r str | Nonereturnstr)rr(rr&r'ztuple[str, str])rzIterable[Booking]rrrrr'list[IstatC59RowPayload])r"intr#rr$rr'r))__doc__ __future__rdatetimertypingrbookings.modelsr#istat.xml_export.models.c59_payloadr1istat.xml_export.services.c59_aggregation_servicerr r rrr r%rrr3s##B) 9 & r