U ^jyX@s ddlmZddlmZddlmZzddlmZWn ek rTddlmZYnXddlmZeedZ e e ddZ dd Z d d Z d d ZddZddlmZmZddlmZddZd#ddZgddddfddZddZd$ddZd%eed d!d"ZdS)&) MongoClient)datetime)pprint)ZoneInfoAmerica/SantiagocCst|d|d|dSNZ02int) region_idarea_id centro_idr 2/var/www/itgmanager/itgmanager/nanoox/save_data.pygenerate_centro_idsrc Csz|d}|ddi}|sBdiiiidddddd}|||}|||krh|||WS|d|d}||||<||d|<|ddi||WStk r}ztd |d |jjd W5d }~XYnXd S) z nombre: string (ej: 'LosLagos') tipo: uno de 'clientes', 'regiones', 'areas', 'centros' db: MongoClient().your_db Z catalogos_idZmapas_idr)clientesregionesareascentros)rrrrrcontadorrError z (line )N) find_one insert_onestriplower replace_one Exceptionprint __traceback__ tb_lineno)nombretipodbcoldocZnuevo_ider r rget_or_create_id!s4     r(cCs@t|}t|}t|}t|}t|d|d|d|dSrr)moduloZ aviot_idxcan_idx bomba_posmacbr r rgenerate_numeric_idMs r0c Cs4z|d|dd}||}|dkrX||td|dddt|nd|kr|dd }||d d|ii}|jrtd |dddt|qtd |ddd n&td|dddt|dWn<tk r.}ztd|j j d|W5d}~XYnXdS)Nrr rr u🟢 Insertado r# control_versionrz$setu(🟣 Campo 'control_version' agregado a u🟠 No se modificó u+, ya tenía el campo o coincidía el valor.u🟡 z% ya existe y tiene 'control_version'.u2❌ Error en insert_metadata_si_no_existe: línea u — ) getrrrupper_id_centro_string update_onemodified_countrr r!) collectionr&filtro existing_docZcontrol_version_valueresultr'r r rinsert_metadata_si_no_existens$  &  &*r>cCs|dd|dddS)Nrz (r z sin centro_idr)r5)r&r r rr7sr7) timedeltatimezoner)as_boolcCs||}dSN)r)r: documentoresr r rinsertar_dato_timeseriessrENcsd\}}}|d} || } fdd} t|} t|} t|}|d}dk r| | } | | } | |}| |}| jrddnddird| d nd| d d d | jrd dndd ird | dnd | dd d | jrddnddird|dnd|dd d | jrBddnddirZd|dnd|dd d tr~ddnddS)N-Z_estructura_logicacs|D] }|d<q|S)Nr r )Z lista_docsr&r r ragregar_centro_ids z7actualizar_estructura_logica..agregar_centro_idbombasmodulosr1r)rrJr )rrJT)upsertaviots)rrLr )rrLcans)rrMr )rrM)rrIr rrIz"Estructura logica actualizada con .zEstructura logica actualizada.)splitlistvaluesrr)r$ modulo_map aviot_mapcan_map bombas_docr regionareacentroZestructura_col_nameZestructura_colrHrJrLrMrIr rGractualizar_estructura_logicasD         rZPSFc+Cstdz|d\}}} Wn:tk rV} ztd| d| jjW5d} ~ XYnXt|d} t|djtj d} z | d} | d}| d }| d }|| }||}||}||}|| kr|j |d d d dd|| kr |j |d dd dd|| kr0|j |d dd ddiii}}}dgd}|D]} t | dddD]z\}}z8|d}|d}|d}|dd}t |||d}WnFtk r} z&td| d| jjWYqdW5d} ~ XYnX|d|||d|||d} |r|| d <t|| |d!}!| ||d"|d#|!|d$|d%|d&|||dd' }"|rv||"d <t||"|||d(|gd)|||d*kr||d*||||||gd+|||dkr||d||||||gd,t |dddD]\}#}$t ||||#}%|%d-||||#|$d.|$d/||d0 }&|rh||&d <t||&|$}'|'| |%|!d1|r||'d <t||'||d|%|d|%|$d.|$d/|d2qqdqNzt||||||Wn<tk r8}(ztd|(d|(jjW5d}(~(XYnX|D]Z\})}*zt|||)|*Wn<tk r} ztd| d| jjW5d} ~ XYnXq>Wn<tk r} ztd3| jjd| W5d} ~ XYnXdS)4Nz en guardar_estructura_en_mongodbrFrr3%Y-%m-%d %H:%M:%Stzinfo _metadataZ _sensoresZ_cansZ_generador_timeseries timestampbomba_idseconds) timeField metaField granularity) timeseriescan_id generador_idrIrNrMr)startZ ipAddressaviotr)rOrz en can)rr#r)ip_aviotrlip_cancontrolr4r presionvoltaje corrientesalestadosource) r`rgrqrrrprsrtrur)rjrluMódulo ) modulo_idr"rLrL)aviot_idiprvrM)rgrxrwrIbombar"alias) rr#r)rmrnZposicionr"rzror4)r`raZPresion)rar"rzrgz.Error en guardar_estructura_en_mongodb: linea )rrPrr r!rstrptimereplacer@utclist_collection_namescreate_collection enumerater0r>r5rE setdefaultappendcopyupdaterZ_save_one_generator_data)+r$datagenerators_datar ro new_versionr`rWrXrYr'dtZformatted_timestampmetadata_col_nameZsensores_col_nameZ cans_col_nameZgenerador_ts_col_name metadata_colZsensores_ts_colZ can_ts_colZgenerador_ts_colrSrTrUrVr*rlrnrmr)Z aviot_indexrgZ can_metadataZ can_pressureZ can_ts_docr+ryraZbomba_metadataZ bomba_ts_docZergenerator_namegenerator_datar r rguardar_estructura_en_mongodbs *                * 2rcCs$|d|dt|ddkfS)a Clave que decide si un snapshot aporta informacion nueva. Comparar solo STATE descartaba la transicion entre linea principal ("110") y respaldo ("011"): con control por falla activo ocurre sin que STATE cambie, y es justo el evento que este contrato viene a comunicar. control_generator_back entra en la clave para que un cambio de modo quede registrado. Ausente y False se normalizan al mismo valor, asi que pasar de "no reportado" a False no genera fila. STATEdigital_outputs_statecontrol_generator_backT)r5rA)snapshotr r r_comparison_keys rc Cs tdz|rt|ts,td|WdStdd|DrVtd|WdS|d}t|}||d<t|}|||d|jd|id d d d d d gd }|rt |t |krtdWdS| |tdWn<t k r} ztd| d| j j W5d} ~ XYnXdS)Nzen _save_one_generator_datau/La información sobre generador no es válida: css|]}|dkVqdSrBr ).0valuer r r sz+_save_one_generator_data..u0Todos los datos sobre generador son inválidos: r`)generador_namerhrrr)rrrr)r`rk)sortzGSnapshot sin cambios (STATE/salidas/control por falla) -> no se guarda.u=Nuevo documento insertado (cambió la clave de comparación).ru en línea )r isinstancedictallrRr5_to_utc_datetimerrrrrr r!) r$Zgenerators_colrrr Zreceived_timestampZparsed_to_isodate_timestampZ generator_docr<r'r r rrs8    r)local_tzreturncCst|tr(|jdkr|n |t|}nNt|trdzt|}Wqvtk r`t|d}YqvXnt dt ||jdkr|j t|d}n|}|tdS)z Convierte un timestamp (str o datetime) a datetime UTC timezone-aware. Acepta: - datetime con o sin tz - string "%Y-%m-%d %H:%M:%S" - string ISO8601 con tz: "2025-10-02T18:57:11+00:00" Nr\z"Tipo no soportado para timestamp: r]UTC) rrr^ astimezonerstr fromisoformat ValueErrorr{ TypeErrortyper|)tsrZdt_naiveZdt_localr r rrs   r)N)N)r)pymongorrrzoneinfor ImportErrorZbackports.zoneinfonowrrrr(r0r>r7r?r@Zgenerator_outputsrArErZrrrrrr r r rs.    ,!!  B8 /