h3gSrSSKrSSKrSSKJrJr SSKJr SSKJr \R"\ 5r 0r S\ 4SjrS\ 4S jrSS \ 4S jjrS \ S \4S jrSrSSjrSrSSjrSSjrg)uW Módulo de Base de Datos - MVP v1.0 Maneja conexiones y operaciones de base de datos N)Errorpooling) DB_CONFIG)datetimedb_namec~U[;a|SU3S[S[S[S[SUS.n[RRR "S 0UD6[U'[ RSU35 [U$[U$![a"n[ RS U35 S nAg S nAff=f) z Obtiene o crea un pool de conexiones para una base de datos Args: db_name: Nombre de la base de datos Returns: MySQLConnectionPool: Pool de conexiones pool_hostportuserpassword) pool_name pool_sizer r rrdatabasezPool de conexiones creado para z"Error creando pool de conexiones: N) connection_poolsrmysql connectorrMySQLConnectionPoolloggerinforerror)r pool_configes ./var/www/blue/EV-Temp_rev04/src/db/database.pyget_connection_poolrs&& $WI.!&)!&)!&)%j1#K).(?(?(S(S(bVa(b W % KK9'C D G $$ G $$   LL=aSA B sA2B B<B77B<c[U5nU(aUR5$g![a"n[R SU35 SnAgSnAff=f)u Obtiene una conexión del pool Args: db_name: Nombre de la base de datos Returns: MySQLConnection: Conexión a la base de datos u%Error obteniendo conexión del pool: N)rget_connectionrrrrpoolrs rconnectr#/sY w 'D  F&&( (  F LL@D E E  Fs% AA  AquerycFSnURSS9nURX=(d S5 U(a6UR5 SUR4U(aUR 5 $$SUR 54U(aUR 5 $$![ aen[RSU35 U(aU(aUR5 S[U54sSnAU(aUR 5 $$SnAff=f!U(aUR 5 ff=f)u Ejecuta una query con manejo de errores Args: connection: Conexión a la base de datos query: Query SQL params: Parámetros para la query commit: Si se debe hacer commit Returns: tuple: (success, result/error_message) NT) dictionaryrzError ejecutando query: F) cursorexecutecommitrowcountclosefetchallrrrrollbackstr) connectionr$paramsr)r'rs r execute_queryr1AsF""d"3ul+     (  LLN **  LLN   /s34 &    !c!f}  LLN   LLN s7A B*B DAC> D!D>DDD  params_listcSnUR5nURX5 UR5 SUR4U(aUR 5 $$![ a^n[ RSU35 U(aUR5 S[U54sSnAU(aUR 5 $$SnAff=f!U(aUR 5 ff=f)u Ejecuta una query múltiple veces con diferentes parámetros Args: connection: Conexión a la base de datos query: Query SQL params_list: Lista de parámetros Returns: tuple: (success, rowcount/error_message) NTzError en executemany: F) r' executemanyr)r*r+rrrr-r.)r/r$r2r'rs r execute_manyr5csF""$5.V__$  LLN   -aS12     !c!f}  LLN   LLN s/>A C%;B> C!C>CCC c[R5H.upUR5 [R SU35 M0 [R5 g![ a&n[R SUSU35 SnAMrSnAff=f)z$Cierra todos los pools de conexioneszPool cerrado para zError cerrando pool z: N)ritemsr+rrrrclearr!s rclose_all_poolsr9sy)//1  @ JJL KK,WI6 72 @ LL/y1#> ? ? @s(A B &BB cUR5nSnURU5 UR5nU(a"[R S[ U5S35 US[ 5;aUR5 $$![aCn[RSU35 /sSnAS[ 5;aWR5 $$SnAff=f!S[ 5;aWR5 ff=f)zz Obtiene mediciones no procesadas de la tabla bandeja_blue Returns: list: [(id, dmac, temp, fecha, id_entrada), ...] a SELECT bb.id, bb.dmac, bb.temp, bb.fecha, e.idEntrada FROM bandeja_blue bb JOIN modbus m ON bb.dmac = m.dmac JOIN entradas e ON m.idModbus = e.idModbus WHERE bb.procesado_el IS NULL ORDER BY bb.fecha LIMIT 1000 z Obtenidas z mediciones sin procesarr'z*Error obteniendo mediciones sin procesar: N) r'r(r,rdebuglenlocalsr+rr)connr;r'r$ measurementsrs rget_unprocessed_measurementsr@s   u(  LL:c,&7%88PQ R vx  LLN  A!EF vx  LLN  vx  LLN s0AA?? C  C"C #CC  C!C0cUR5nSnURU5 UR5S[5;aUR 5 $$![ aCn[ RSU35 /sSnAS[5;aWR 5 $$SnAff=f!S[5;aWR 5 ff=f)z\ Obtiene lista de sensores activos Returns: list: [(sensor_id, dmac, id_entrada), ...] z SELECT m.idModbus, m.dmac, e.idEntrada FROM modbus m JOIN entradas e ON m.idModbus = e.idModbus WHERE m.estado = 1 r'z#Error obteniendo sensores activos: N)r'r(r,r=r+rrr)r>r'r$rs rget_active_sensorsrBs  u vx  LLN  :1#>? vx  LLN  vx  LLN s/2A B!B7B!8B$B!!B$$!CcHU(dgUR5nSRS/[U5-5nSUS3n[R"5/U-nUR XV5 UR 5 U(a"[RS[U5S35 S [5;aWR5 gg![a2nUR5 [RSU35 SnANWSnAff=f!S [5;aWR5 ff=f) z_ Marca un lote de mediciones como procesadas Args: ids (list): Lista de IDs de mediciones N,z%sz] UPDATE bandeja_blue SET procesado_el = %s WHERE id IN (z ) z Marcadas z mediciones como procesadasz+Error marcando mediciones como procesadas: r')r'joinr<rnowr(r)rr;rr-rr=r+)r>idsr;r' placeholdersr$r0rs rmark_as_processed_batchrIs xxS 12 '(   ,,.!C'u%  LL9SXJ.IJ K vx  LLN H  B1#FGGH vx  LLN s*BC C= (C83D8C==D!D!cU(dgUR5nSnURXA5 UR5 U(a"[R S[ U5S35 S[5;aWR5 gg![ a2nUR5 [RSU35 SnANWSnAff=f!S[5;aWR5 ff=f)u Inserta un lote de registros estadísticos Args: registros (list): Lista de tuplas (idSistema, idEntrada, fecha, medio, maximo, minimo, desvio) Nz INSERT IGNORE INTO registros (idSistema, idEntrada, fecha, medio, maximo, minimo, desvio) VALUES (%s, %s, %s, %s, %s, %s, %s) z Insertados u registros estadísticoszError insertando registros: r') r'r4r)rr;r<rr-rr=r+)r> registrosr;r'r$rs rinsert_registros_batchrLs   5,  LL;s9~&66NO P vx  LLN 9  3A37889 vx  LLN s*AB C(B=8C=CC!C&)NF)F)__doc__loggingmysql.connectorrrrconfig.settingsrr getLogger__name__rrr.rr#r1listr5r9r@rBrIrLrrrUs *'   8 $%%:S$ S DCd:  $L8BrT