ezh7@SSKrSSKrSSKJr SSKJr "SS5rg)N)Medicion)DatabaseConnectioncB\rSrSrSrSrSrSrSrSr Sr S r S r g ) MessageProcessorz$Procesador principal de mensajes IoTc"[5Ulg)N)rdb)selfs B/var/www/ev-aguas/ev-aguas-proceso/processors/message_processor.py__init__MessageProcessor.__init__ s $&c[R"UR55nSU;d US(d[R"S5 g[ U5nUR U5nU(d[R"S5 g[R"SU35 URU5nUc[R"SU35 gXSl URU5nUS$![Ra#n[R"S U35 SnAgSnAf[a#n[R"S U35 SnAgSnAff=f) u:Procesa una sola línea de mensaje JSON (método original) objectJSONz!Mensaje sin objectJSON, omitiendoF0No se pudo obtener identificador del dispositivo$Buscando medidor con identificador: NMedidor no encontrado: successzError decodificando JSON: zError procesando mensaje: )jsonloadsstriploggingwarningrget_device_identifierinfo_get_medidor_id id_medidor _insert_medicion_and_tiempo_realJSONDecodeErrorerror Exception)r message_linemessagemediciondevice_identifierrresultes r process_single_message'MessageProcessor.process_single_message s'$ jj!3!3!56G7*',2G CD (H!) > >w G $ RS LL?@Q?RS T--.?@J!"9:K9L MN", ::8DF)$ $##  MM6qc: ;  MM6qc: ; s7A C* 9C*AC*C**E >D E )EE c[R"UR55nSU;d US(dSSSS.$[R"US5nU(a[ U[ 5(dSSSS.$/S QnUVs/sH ofU;dM UPM nnU(aSSS S RU53S.$[U5nURU5n U (dSSS S.$[R"SU 35 URU 5n U S(dU SS:Xa SSSU 3S.$SSSU S3S.$U SUlURUR5n U bbU b [!U 5OSn [#UR$U - S5Ul[R"SUR$SU SUR&35 OSUl[R"S5 UR)U5n U $![RanSSS[ U53S.sSnA$SnAff=fs snf![R[4anSSS [ U53S.sSnA$SnAff=f![*anSSS[ U53S.sSnA$SnAff=f)uMProcesa una sola línea de mensaje JSON con información detallada de erroresF data_erroruJSON inválido: r error_type error_reasonNrzMensaje sin objectJSONuobjectJSON vacío o inválido)addresscumulativeValue innerTimez'objectJSON no tiene campos esenciales: z, uobjectJSON inválido: rrrr- not_foundr system_errorzError de base de datos: r.rgzDelta calculado: z - z = u+Primera medición del medidor, delta = NonezError inesperado: )rrrrstr isinstancedictjoin TypeErrorrrrr_get_medidor_id_detailedr_get_last_cumul_flow_valuefloatroundcumul_flow_valuedelta_acumuladorr!)r r"r#r' object_datarequired_fieldsfieldmissing_fieldsr$r%id_medidor_resultlast_cumul_valuelast_cumul_float insert_results r process_single_message_detailed0MessageProcessor.process_single_message_detailed4sc  **\%7%7%9:7*',2G$".$< "jj)>? "*[$*G*G#(&2(G#N5D!a_EU`H`%_!a!#(&2*QRVR[R[\jRkQl(m" (H!) > >w G $$".$V LL?@Q?RS T $ = =>O P $Y/$\2kA#(&2*ABSAT(U$)&4*BCTUcCdBe(f #4L"AH  $>>x?R?RS +>N>Z5)9#:`c +01J1JM]1]_`+a( 01J1J0K3O_N``cdld|d|c}~+/( JK!AA(KM q'' $".&6s1vh$? 8"b(()4 $".&HHIHIH""I<I IIII J%I<6J<JcURR5(dgURR5nSnURX145 UR 5nU(a;[ R "SUS35 USURR5 $[ R"SU35 URR5 g![a=n[ R"SU35 SnAURR5 gSnAff=f!URR5 f=f)u=Busca el ID del medidor por eui (comparación en mayúsculas)N SELECT idMedidor FROM medidores WHERE UPPER(eui) = UPPER(%s) AND deleted_at IS NULL LIMIT 1 Medidor encontrado con ID: rMedidor no encontrado en DB: Error buscando medidor: ) r connect get_cursorexecutefetchonerr disconnectrr!r r r%cursorqueryr&r's r r MessageProcessor._get_medidor_idsww   !WW'')FE NN5"6 7__&F :6!9+FGay GG   "?@Q?R ST GG     MM4QC8 9 GG     GG   s0A%C"C D!D:D!DD!!D=cURR5(dSSSS.$URR5nSnURX145 UR 5nU(a@[ R "SUS35 SUSS S S .URR5 $[ R"S U35 SS S U3S.URR5 $![aLn[ R"SU35 SS[U5S.sS nAURR5 $S nAff=f!URR5 f=f)u=Busca el ID del medidor con información detallada de erroresFconnection_error&No se pudo conectar a la base de datosr,rKrLrTN)rrr-r.rMr2rrNdatabase_error) r rOrPrQrRrrrSrr!r r5rTs r r:)MessageProcessor._get_medidor_id_detailedsFww   0 H  ' !WW'')FE NN5"6 7__&F :6!9+FG#"()"&$( , GG   "?@Q?R ST$"-&=>O=P$Q GG     MM4QC8 9 . #A  GG     GG   s6A*C(,!C(( D>2'D9D>E9D>>EEc URR5(dSSSS.$URR5nSnURX1R 55 [ R "SUR35 [ R "SUR 535 SnURUURURURUR(a UROS UR(a UROS URURURUR4 5 [ R "S UR35 URR!5 S S S S.URR#5 $![$anURR&(a$URR&R)5 [ R*"S U35 SS[-U5S.sS nAURR#5 $S nAff=f!URR#5 f=f)u>Inserta medición en ambas tablas usando una sola transacciónFr3rZr,aC INSERT INTO mediciones (idMedidor, nserie, fecha_recepcion, meter_time, rssi, cumul_flow_value, daily_flow_value, reverse_flow_value, flow_rate_value, temperatura, delta_acumulado, status) VALUES (%(idMedidor)s, %(nserie)s, %(fecha_recepcion)s, %(meter_time)s, %(rssi)s, %(cumul_flow_value)s, %(daily_flow_value)s, %(reverse_flow_value)s, %(flow_rate_value)s, %(temperatura)s, %(delta_acumulado)s, %(status)s) u9Medición insertada en tabla mediciones para medidor ID: zDatos insertados: a INSERT INTO tiempo_real (idMedidor, lastReporte, estado, acumulado, diario, rssi, temperatura, cumulFlowUnit, dailyFlowUnit) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s) ON DUPLICATE KEY UPDATE lastReporte = VALUES(lastReporte), estado = VALUES(estado), acumulado = VALUES(acumulado), diario = VALUES(diario), rssi = VALUES(rssi), temperatura = VALUES(temperatura), cumulFlowUnit = VALUES(cumulFlowUnit), dailyFlowUnit = VALUES(dailyFlowUnit) rz)Tiempo real actualizado para medidor ID: TNu*Error insertando medición y tiempo real: )r rOrPrQto_dictrrrfecha_recepcionstatusr>daily_flow_valuerssi temperaturacumul_flow_unitdaily_flow_unitcommitrSr! connectionrollbackr r5)r r$rUmediciones_querytiempo_real_queryr's r r1MessageProcessor._insert_medicion_and_tiempo_realsww   , H  J !WW'')F   NN+-=-=-? @ LLTU]UhUhTij k LL-h.>.>.@-AB C! " NN,##((-5-F-F))A-5-F-F))A $$(((( /  LLDXEXEXDYZ [ GGNN  " $" GG    ww!!""++- MMFqcJ K , #A  GG     GG   s1E$F&& H;0A&H6H;H>6H;;H>>IcURR5(dgURR5nSnURX145 UR 5nU(aUSURR 5 $URR 5 g![ a=n[R"SU35 SnAURR 5 gSnAff=f!URR 5 f=f)u<Obtiene el último cumul_flow_value del medidor especificadoNz SELECT cumul_flow_value FROM mediciones WHERE idMedidor = %s ORDER BY fecha_recepcion DESC, id DESC LIMIT 1 ru+Error obteniendo último cumul_flow_value: ) r rOrPrQrRrSr!rr )r rrUrVr&r's r r;+MessageProcessor._get_last_cumul_flow_valueCsww   !WW'')FE NN5- 0__&Fay GG    GG     MMGsK L GG     GG   s*A B"" C),C$C,$C))C,,D)r N) __name__ __module__ __qualname____firstlineno____doc__r r(rHrr:rr;__static_attributes__rr rrs/.'&PeN!B0!dS!j!rr)rrmodels.medicionrdatabase.connectionrrrtrr rws $2Y!Y!r