U ^j @sdZddlZddlmZmZddlmZddlmZddl m Z m Z ddd Z e eZd Zd Zd Zeeeeeed ddZefeeeeeeeedddZeeeeed ddZeeeedddZedkrededdS)u =============================================================================== Archivo: email_notifications.py Autor: EsteBandurria Fecha creación: 2026-02-03 Versión: 1.0.0 =============================================================================== Descripción: Módulo de utilidades para la gestión de listas de correos de emergencia en MongoDB. Contiene lógica para lectura y escritura atómica (bulk write) de arrays de emails basados en identificadores compuestos (Región-Área-Centro). =============================================================================== Copyright: © 2026 ITG Chile. Todos los derechos reservados. Este archivo es parte del proyecto ITG Service Manager y se distribuye bajo los términos de la licencia Privada/Corporativa. =============================================================================== Interface Change List: Versión Fecha Autor Descripción del cambio --------- ---------- ------------------ --------------------------- v1.0.0 2026-02-03 EsteBandurria Implementación inicial lógica Mongo =============================================================================== N)ListDict) UpdateOne) Collection) PyMongoErrorBulkWriteErrorFINFO)debugZ log_leveladdremoveset) db_collectionregionareacentroreturnc Csz8t|||}|d|iddd}|r4|dgngWStk r}z>|jrX|jjnd}td|d|td t |W5d }~XYnXd S) z'Busca los emails asociados a un centro._idr)emailsrrUnknownError en linea zDatabase Read Error: N) _generate_composite_idfind_onegetr __traceback__ tb_linenologgererror RuntimeErrorstr)r rrrZ search_iddocerr#=/var/www/itgmanager/itgmanager/modules/email_notifications.pyfetch_emails_by_locationGs r%)r rrrr operationrc Cszzt|||}|tkr,ddd|iii}d}nZ|tkrJddd|iii}d}n<|tkrddd|ii}d}n"td |d td td td td|i||dg} |j| dd} | j| j| j dWSt k r} z<| j r| j j nd} t d| d| td| jW5d} ~ XYn`tk rt} z@| j r8| j j nd} t d| d| tdt| W5d} ~ XYnXdS)z Actualiza la lista de emails. operation='set': Reemplaza la lista actual por la nueva (Snapshot). operation='add': Agrega elementos. operation='remove': Elimina elementos. z $addToSetrz$eachTz$pullz$inFz$setuOperación inválida 'z'. Use 'z', 'z' o 'z'.r)upsert)ordered)matchedmodifiedupsertedrzError BulkWrite rzBulk Write Error: NrzDatabase Write Error: )rOP_ADD OP_REMOVEOP_SET ValueErrorr bulk_write matched_countmodified_countupserted_countrrrrrrdetailsrr )r rrrrr&doc_id update_queryZ do_upsertrequestsresultbwerr"r#r#r$ update_emailsRs4  " r:c Csdz&t|||}|d|i}|jdkWStk r^}ztd|WYdSd}~XYnXdS)u{ Elimina físicamente el documento de emails asociado al centro. Usar cuando se elimina el centro del sistema. rrz%Error eliminando lista de contactos: FN)r delete_one deleted_countrrr)r rrrr5r8r"r#r#r$delete_contact_list}s  r=)rrrrcCs,|d|d|S)u Descripción: Función auxiliar privada para generar y normalizar el ID compuesto. Aplica formato Title Case y elimina espacios extra. Formato: Region-Area-Centro (ej. "Norte-Operaciones-Bodega1") Verbo estándar: generate (Generación) Parámetros: region (str): Input región. area (str): Input área. centro (str): Input centro. Retorna: str: ID compuesto normalizado. -)striptitle)rrrr#r#r$rsr__main__u,Este módulo es una librería de utilidades.z>Funciones disponibles: fetch_emails_by_location, update_emails)__doc__loggingtypingrrpymongorpymongo.collectionrpymongo.errorsrrZDEFAULT_CONFIG getLogger__name__rr,r-r.r r%r:boolr=rprintr#r#r#r$s&      "+