gdZddlZddlmZmZddlmZmZddlZddlZddl m Z m Z eje ZdZdZd d Zd Zd Zy) uL Módulo de acceso a datos - MVP v1.0 Implementa todas las operaciones de base de datos del sistema: - Conexión y gestión de sesiones - Consultas de mediciones y sensores - Operaciones de actualización - Gestión de transacciones Este módulo centraliza el acceso a datos para mantener consistencia y facilitar optimizaciones. N)Errorconnect)datetime timedelta) DB_CONFIG BATCH_SIZEcd}|tdkry tjjtdtdtdtd|}|j rt j d||S |tdkryt jdy #t$rI}t jd |d zd ||d z }tjtd Yd }~pd }~wwxYw)u Establece conexión con la base de datos con reintentos. Args: db_name (str): Nombre de la base de datos Returns: Connection: Objeto de conexión o None si falla rretry_attemptshostportuserpassword)r r rrdatabasezConectado a la base de datos: zIntento z fallido: retry_delayNu2No se pudo establecer conexión a la base de datos) rmysql connectorr is_connectedloggerinforerrortimesleep)db_name retry_count connectiones 6/Users/jma/desarrollo/EV-Temp_rev04/src/db/database.pyrrsK  "23 3 100v&v&v&":. 1J&&( ?     s/2A BB+B,B BB Bc&|sgSd} |r;tjdtjd|j|jd}|rtjd |j |rtjd|j |rtjd d }|r|d |z }|rtjd ||j||j}|r!tjd t||ru|Dcgc]}|d }}djdjdgt|z} |r"tjdt|d|j| ||j|rtjd||r)|j|rtjdSSS#t $r%}|rtjd|Yd}~d}~wwxYwcc}w#t$r}tjd||rtjdd |j |rtjdn#|rtjdYnxYwgcYd}~|r)|j|rtjdSSSd}~wwxYw#|r)|j|rtjdwwwxYw)u Obtiene mediciones no procesadas. Args: conn: Conexión a la base de datos debug (bool): Flag para modo debug limit (int, opcional): Límite de registros a obtener Nz&Iniciando get_unprocessed_measurementsuEstado conexión: Tbufferedz Cursor creadozRollback previo ejecutadozError en rollback previo: uNueva transacción iniciadaaf SELECT b.id, b.dmac, b.temp/10.0 as temp, b.fecha, e.idEntrada FROM bandeja_blue b JOIN modbus m ON b.dmac = m.dmac JOIN entradas e ON e.idModbus = m.idModBus WHERE b.procesado_el IS NULL AND b.temp IS NOT NULL ORDER BY b.fecha ASC z LIMIT zEjecutando query: zResultados obtenidos: rz UPDATE bandeja_blue SET procesado_el = NOW() WHERE id IN ({}) AND procesado_el IS NULL ,%sz Ejecutando marca de procesados: z registroszCommit ejecutado exitosamentezCursor cerradozError obteniendo mediciones: zStack trace completo:)exc_infou$Rollback ejecutado después de errorz$Error ejecutando rollback post-error)rdebugrr!rollback Exceptionstart_transactionr"r#lenformatjoincommitr$rr) r%r.limitr!rr&resultsrowids mark_querys rget_unprocessed_measurementsr;Us  FV/  LLA B LL-d.?.?.A-BC Dd+  LL ) ? MMO 89   LL6 7    wug& &E  LL-eW5 6u//#  LL1#g,@ A %,-c3q6-C- sxxS 123  ?CzTU NN:s +  LL8 9  LLN -. K ? 9!=> ?J.&   4QC89  LL04L @ E MMO CD E CD  LLN -.    LLN -. sA&H(/'G2BH(- H#9B H(2 H ;HH(H  H(( K 11K#'J  K J&$K*K +K#K  K##-Lc|r|syd} |jd}|jdjdgt|z}d|d}|j |||j  |r|j yy#t$rE}|jtjd |Yd}~|r|j yyd}~wwxYw#|r|j wwxYw) z6 Marca un lote de mediciones como procesadas. FNTr)r+r,zT UPDATE bandeja_blue SET procesado_el = NOW() WHERE id IN (z+) AND procesado_el IS NULL z*Error marcando registros como procesados: ) r!r1r4r2r"r5r$rr/rr)r%r9r! placeholdersr&rs rmark_as_processed_batchr>s s Fd+  xxS 12 #^$   uc"   LLN    A!EF  LLN    LLN s*A(B C(C7CCCC,c`|r|sy |j}d}|j|||j |jy#t$rB}t j d||jYd}~jyd}~wwxYw#jwxYw)u Inserta lote de registros estadísticos. Args: conn: Conexión a base de datos registros (list): Lista de tuplas (idSistema, idEntrada, fecha, ...) Returns: bool: True si la operación fue exitosa Fz INSERT INTO registros (idSistema, idEntrada, fecha, medio, maximo, minimo, desvio) VALUES (%s, %s, %s, %s, %s, %s, %s) Tu*Error insertando registros estadísticos: N)r! executemanyr5r$rrrr/)r% registrosr!r&rs rinsert_registros_batchrBs y  5),     A!EF     s)4A B(B>BBBB-)FN)__doc__mysql.connectorrrrrrrloggingconfig.settingsrr getLogger__name__rr'r;r>rBrrKsK *( 3   8 $>