`jJdZddlmZddlZddlmZmZddlmZddl m Z ddl m Z m Z ddlmZdd lmZdd lmZmZdd lmZdd lmZej2eZd ZdZGddeZGddeZGddeZ GddeZ!Gdde!Z" ddZ#y)uRoss1000 export orchestration service. Implements the strategy pattern for two output modes: - "xml" → plain UTF-8 XML (default) - "soap" → SOAP 1.1 envelope wrapping the XML payload Architecture: Ross1000ExportService ├── XmlExportStrategy → serialize_movement_days_xml() └── SoapEnvelopeStrategy → build_soap_envelope(xml_payload) This service is the single entry point for the Ross1000 export pipeline. It does NOT touch TXT export, C59, or Alloggiati pipelines. ) annotationsN)ABCabstractmethod)date)Ross1000ValidationError)Ross1000ExportResultRoss1000MovementDayPayload)build_movement_days)build_soap_envelope)validate_date_rangevalidate_structure)serialize_movement_days_xml) Structurezapplication/xml; charset=utf-8ztext/xml; charset=utf-8c6eZdZdZe ddZy)BaseMovementExportStrategyz4Abstract strategy for Ross1000 export serialization.cy)z3Serialize movement days to (content, content_type).N)selfdaysstructure_code start_dateend_dates 2/backend/istat/ross1000/services/export_service.py serializez$BaseMovementExportStrategy.serialize/N rz list[Ross1000MovementDayPayload]rstrrrrrreturnztuple[str, str])__name__ __module__ __qualname____doc__rrrrrrr,sN>B.B B  B  B BBrrc,eZdZdZ ddZy)XmlExportStrategyzSerialize to plain UTF-8 XML.c0t||||}|tfS)Nrrr)rROSS1000_XML_CONTENT_TYPE)rrrrrcontents rrzXmlExportStrategy.serialize>s(. )!   111rNr)r r!r"r#rrrrr%r%;s:'2.2 2  2  2 2rr%c<eZdZdZdddddZ ddZy) SoapEnvelopeStrategyz>Serialize to SOAP 1.1 envelope wrapping the plain XML payload.usernamepasswordc ||_||_y)N) _username _password)rr.r/s r__init__zSoapEnvelopeStrategy.__init__Rs!!rctt||||}t||j|j}|tfS)Nr'r-)rr r1r2ROSS1000_SOAP_CONTENT_TYPE)rrrrr xml_payload soap_contents rrzSoapEnvelopeStrategy.serializeVsE2 )!  + ^^^^ 777rN)r.rr/rrNoner)r r!r"r#r3rrrrr+r+OsDH*,b"8.8 8  8  8 8rr+c6eZdZdZe ddZy)BaseTourismExportServicez3Abstract base for regional tourism export services.cy)z3Generate an export result for the given parameters.Nr)r structure_idrrmodes rexportzBaseTourismExportService.exportsrrN) r<intrrrrr=rrr)r r!r"r#rr>rrrr:r:psP=BB B  B  B BBrr:c^eZdZdZdddd ddZe d dZy) Ross1000ExportServicea6Production-grade Ross1000 export service for Regione Liguria. Usage: service = Ross1000ExportService() result = service.export( structure_id=1, start_date=date(2026, 4, 1), end_date=date(2026, 4, 30), mode="xml", # or "soap" ) xmlr,)r= soap_username soap_passwordc Ht||\}}tjj|j } | t d|dt | t| jj} |j|||} t| ||} | j| | ||\} }t| |||}tjd|| |j!|j!|t#| |d d  t%|| |t#| | S) aGenerate a Ross1000 export for a structure and date range. Args: structure_id: ID of the Structure to export start_date: First day of the reporting period (inclusive) end_date: Last day of the reporting period (inclusive) mode: "xml" (default) or "soap" soap_username: ISTAT credential username (SOAP mode only) soap_password: ISTAT credential password (SOAP mode only) Returns: Ross1000ExportResult with filename, content, content_type, day_count, mode Raises: Ross1000ValidationError: On invalid inputs or missing data )idz Structure z not foundr=r.r/) structurerrr')rrrr=zRoss1000 export generatedsuccess)r<rrrr= day_countfilenamestatus)extra)rKr) content_typerJr=)r robjectsfilterfirstrr r istat_codestrip _get_strategyr r_build_filenameloggerinfo isoformatlenr)rr<rrr=rCrD valid_start valid_endrHrstrategyrr)rNrKs rr>zRoss1000ExportService.exportsR4"5Z!J Y%%,, ,=CCE  )J|nJ*OP P9%Y11288:%%""& #"  !) 2 2 )" !3! #)"    ' ,"0)335%//1 Y$#   $%$i   rcb|dk(r t||S|dk(r tStd|d)Nsoapr-rBzUnknown export mode 'z'. Valid modes: 'xml', 'soap')r+r%rrGs rrTz#Ross1000ExportService._get_strategysB 6>'HM M 5=$& &%#D6)F G  rN)r<r?rrrrr=rrCrrDrrr)r=rr.rr/rrr)r r!r"r#r> staticmethodrTrrrrArAs $S S  S  S  S S S  S j         $    rrAc|jddjdd}d}d|d|jdd|jdd|S) z&Build a descriptive download filename./- _rB Ross1000_z%Y%m%d.)replacestrftime)rrrr= safe_codeexts rrUrUsd&&sC088cBI C I;a 3 3H => H  h ' (# 0r) rrrrrrr=rrr)$r# __future__rloggingabcrrdatetimeristat.ross1000.exceptionsr&istat.ross1000.models.movement_payloadrr (istat.ross1000.services.movement_builderr $istat.ross1000.soap.envelope_builderr +istat.ross1000.validators.payload_validatorr r &istat.ross1000.xml.movement_serializerrstructures.modelsr getLoggerr rVr(r5rr%r+r:rArUrrrrws ##=ID_N'   8 $<6 B B222(858B Bs B&n 4n b        r