U ^js@sddlmZddlmZddlmZmZddlZddlZddlZddl Z ddl m Z ddl Z ddl mZddlmZmZmZmZmZmZdd lmZmZdd lmZdd lmZdd l mZmZdd lm Z ddl!Z!ddl!m"Z"ddl#m$Z$dZ%ddddddgZ&ddddddgZ'dZ(ddZ)ddZ*ddZ+dId d!Z,dJd&d'Z-d(d)Z.d*d+Z/d,d-Z0e1e e1d.d/d0Z2d1d2Z3d3d4Z4d5d6Z5dKd7d8Z6d9d:Z7d;d<Z8d=d>Z9d?d@Z:dAdBZ;dCdDZdS)L)guardar_estructura_en_mongodb)save_comap_datadatetime timedeltaN)Optionalget_column_letter)BorderSide PatternFillFont GradientFill Alignment) LineChart ReferenceImage)CharacterProperties)r column_index_from_string)WorkbookProtection)create_unicode_buffer)PathZ itg123chilehoraO2SO2TEMPZRLYZStartZTemp2cCsvtd||d}tdt|d|i|d|iD]0}t|d|krjtd|dSdSq@dS) NzEN get_control_by_centro_id metadataz2list(metadata_col.find({'centro_id': centro_id}))= centro_idcontrolzENCONTRE EL CONTROLZVDFPS)printlistfindget) nanoox_dbr metadata_coldocr*:/var/www/itgmanager/itgmanager/nanoox/nanoox_timeseries.pyget_control_by_centro_id:sr,cCsP||}|jd|idddd}td|t||rLd|krL|dSdS) zADevuelve control_version para el centro dado o None si no existe.r rr)control_version_id) projectionz%EN get_control_version_by_centro_id r-N)find_oner#r&)r'metadata_col_namer r(r)r*r*r+ get_control_version_by_centro_id[sr2cCs*|d}t|trdSt|tr&dSdS)z Determina el formato de 'data' dentro del JSON recibido. Retorna: - "0" si 'data' es un diccionario (formato simple). - "nested" si 'data' es una lista (formato anidado). - None en otros casos. datadictnestedN)r& isinstancer4r$)datosr3r*r*r+ tipo_de_datosjs   r8Fc Cstddddt|d|d||d}td||dd }z|d }|rt|||d g||||d ntd |dtddddtd|d|dg}|rt|||td|s|d}td||rt|||Wn<tk rN} ztd| jj d| W5d} ~ XYnXz6|dp`i} | rvt ||| ntd|Wn<tk r} ztd| jj d| W5d} ~ XYnXdS)u] Procesa un único registro de datos extrayendo cada bloque y guardándolo en la BD.  zestamos en process_sensor_dataz*^100 z, new_version=rz timestamp=r!r"modulos generators timestampzSin bloque 'modulos' para z#: no se actualiza estructura logicaz" # Procesar historial de control z*^60zdata.get('historial_control')=historial_controlzantes de revisar generadores generadorz generador=zerror en linea Ngenerators_comapzSin datos COMAP para zError procesando COMAP linea z: ) r#upperkeysr&rsave_one_historial_datasave_one_generator_data Exception __traceback__ tb_linenor) dbr3r new_versionr>r!r;logsr@eZ comap_blockr*r*r+process_sensor_datas<       *rMCc Cst|}t|D]}|||}|dkrt|d}|d}|rXt|d}|d} i|d<|rp||dd<|r| |dd<||} i} | D]&} | d} | dg}|r|| | <q| sWd S| WStk r}ztd |d |jj W5d }~XYnXd S) u  Obtiene todos los logs de la colección 'historial_control' y los organiza en un diccionario. Las llaves del diccionario son las fechas (en formato 'YYYY-MM-DD') y los valores son listas de logs. Si se proporciona 'rango_fechas', se espera un diccionario con: {'startDate': '27/02/2025', 'endDate': '27/02/2025'} y se realiza la conversión para filtrar los documentos entre ambas fechas. :return: Diccionario con las fechas como llaves y listas de logs como valores, o None si no se encuentran datos. startDateendDate%d/%m/%Y%Y-%m-%drez$gtez$lterKNrr:) r?r&rrstrftimer%rFr#rGrH)rI rango_fechasrrnZstart_date_inputZend_date_inputZdt_startZstart_date_strZdt_endZ end_date_strrrr)rerKrLr*r*r+ get_historial_control_as_dict_sms<             rc CszR|j}td}|||d}g}|D]}|d}|dg}|}q.|WStk r} ztd| d| jj W5d} ~ XYnXdS)rrr rererKrr:N) r?rnowrr%r&rFr#rGrH) rIr rrdrrr)rerKrLr*r*r+get_historial_controls  rc> Csltdt|dd}t|dd}tt||ddkrntt||ddd}td|d nd}d }zt|}d } d } d } d g| d} d} | | d}t }g}t }i}| D]\}}t | d}t | | }t | d}|||t|td| t|tt|d | d||<|D]f}||krLg||<|ddkrn|| |dn,|ddkr|| dn|| dq6qt|D]}t|t|dddd}d|}||krbd}||}| |t| D]}| gqd g| dg}| |d g| dddg}| |||}t|} t|D]\}!}"g}#|# d |# d z\|"dd }$|$d}!|"ddd}%|$d|!d}&|$|!dd}'|#|%|&|'g7}#Wn<tk r"}(ztd|(d |(jjW5d}(~(XYnX| |#qjzXtjtjt})tj|)d!d"}*tj|*sttd#|*t ||*d$d%d d&d'Wn2tk r}(ztd(|(W5d}(~(XYnXt!dd)d*}+t"d+d,d,d-},t"d+d.d.d-}-t"d+d/d/d-}.t#t$d0d1d2t$d0d1d2t$d0d1d2t$d0d1d2d3}/t | d}0t | d }1t | d}2||0t| d}3|+|3_%|,|3_&||0t| d }4||1t| d }5||2t| d }6|+|4_%|+|5_%|+|6_%|,|4_&|,|5_&|,|6_&|j'| d| d| d| dd4|||d5||d6}7|7D]}8|8D] }9|/|9_(qq t|j)| d| | d d7D]6\}!}8|8D]&}9t!|||!ddd8|9_%}+qNqBt|j)| d| | d d7D](\}!}8|8D]}9t*d9d9dd d:|9_+qq|j,D]v}:d};|:D]B}9z.|9j-dk rtt|9j-|;krt|9j-};Wn YnXq|;d }<|Wd Stj||}=td?|=tj|std@|dA|j6kr|7|dAt5|j8_9d|j8_:|;|=|<tdB|=WdSWnDtk rf}(z$tdC|(dD|(jjdEWYdSd}(~(XYnXdS)FNz1********ENTRANDO A GENERAR HISTORIAL ************rrrr:rrzSe han seleccionado z diasFrrrP)Z L_InicialZL_FinalZL_Graph celdaInicial celdaFinalcolorz#FFFFFFz#E6E6FAz#000000days-TzHistorial de controlZHorau Categoríau Descripciónmsg]rezError: z imagesLogo_Reportes.pngNo se encuentra la imagen en: rNrOrQrYrZr[r\#Error al agregar la marca de agua: ZFFFFFF)brsolidZe84e0e) fill_type start_color end_colorZa2ff00ZC8C8C8thin000000)Z border_stylerleftrighttopbottom)rZrYZend_rowZ end_columnrr)min_rowmax_row)rcenter) horizontalverticalZ shrink_to_fit wrap_text"DEBUG: No se generará hoja para ' ' (sin datos)z/DEBUG: Finalizado el for. hay_hoja_con_datos = &DEBUG: No hubo datos en todo el rango.z)DEBUG: A punto de guardar el Workbook en No existe la carpeta destino: Sheet/DEBUG: Archivo Excel guardado correctamente en z"DEBUG: Error en gen_reporte_data: (línea ))=r#rrrzstrrwintropenpyxlWorkbookr4ryr rxrRrjoinrC create_sheet enumerater&r%rFrGrHospathdirnameabspath__file__existsFileNotFoundErrorr^rr r r fontfillZ merge_cellsborder iter_rowsr alignmentcolumnsracolumn_dimensionsZ column_letterrTZ protectionZsheetZobjectsZ scenariospassword sheetnamesremovesecurityZworkbookPasswordZ lockStructuresaveclose)>rIr save_path file_namestartend diasEntrehay_hoja_con_datosZ dicc_logsZv_offsetZh_offsetZ tablas_distZ tablas_spaceZcant_keys_tablaZ space_titlesworkbookZws_namesZcolorsZRangoskeyraZcell_inicial_LetraZcell_final_LetraZ cell_graphregr]dia fecha_formatrWZ estructuraZfilaZsheet_data_srcZ max_columnidxrZ nueva_filarZ ts_hh_mm_sscatdecrLbase_dirrXrrZ fill_errorZfill_vdfrZLetra1ZLetra2ZLetra3Z cell_mergeZcell_1Zcell_2Zcell_3Z cell_rangerowcellcolumn max_lengthadjusted_width dest_pathr*r*r+gen_reporte_historialsD      "          *            &(&        rcB Csddl}ddl}ddlm}ddlm}m}m} ddlm} m } ddl m } ddd d d g} d d dddg}| dd}z|j }| |dd}| |dd}||jd}|dkrtdWdStd|d|}d|jkr||dd}d}d}| ddd}|||||d }t|D]N}|| |d!}|d"}t|||d}td#|d$t||rbt|dkrbd%}td&|d'||}d(g||}t|dD]} |gq|||d)D]P}!d(g||!dd(|!dd(|!d d(|!d d(|!d d(g}"||"qt|d)|}#|#rT| |#}$||$d*t|d)}%|}&||%}'|d}(|t| })|j|&|'|(|)d+D]&}*|*D]}+||+_|d,d,d-|+_qqt|(|)dD]v},||,}-d}.t|&|'dD]:}/|j |/|,d.j!}0|0rtt"|0|.krtt"|0}.qt#|.dd/}1|1|j$|-_%qdd0lm&}2|2d1d1d2d3}3|2d4d4d2d3}4|2d5d5d2d3}5|| 'dd}6|| 'd d}7|j|d|'|(|)d+D]}8|8|6|(}9|8|7|(}:zt(|9j!};t(|:j!}|j,2|>d|?t3||?d?d@ddAdBWn2t4k r"}@ztdC|@W5d}@~@XYnX|j,2||}A|5|A|6tdD|AWd%StdEWdSWnDt4k r}@z$tdF|@dG|@j7j8dHWYdSd}@~@XYnXdS)Iu Genera un reporte en Excel dentro del rango de fechas (rango_fechas['startDate'], rango_fechas['endDate']). Se apoya en la colección 'generadores' dentro de la BD 'db'. Retorna: - True => si al menos un día tuvo datos y se generó el archivo exitosamente. - False => si no hubo datos en ningún día (no se genera archivo). - None => si ocurre un error no controlado (excepción). Parámetros visuales: - La tabla de cada hoja comienza en la fila 18 - Deja siempre 2 columnas en blanco (inicio en la columna C) - Aplica bordes 'thin' a toda la tabla - Ajuste automático de columnas con un ancho máximo de 50 rNr )rr r rrr> plc_statusZ hf_statuspartidaZ detencion Timestampz PLC Statusz HF StatusPartidau Detenciónz-reporterrrru/DEBUG: Rango de fechas inválido (end < start).FzDEBUG: Se han seleccionado u día(s)rrrr)stylerrrrzDEBUG: Fecha 'z': documentos hallados = Tz"DEBUG: Creando hoja de Excel para z...rrr@ZC2)rrZmin_colZmax_colr)rr)rrr)r ZFF296F4Dr)rrrZFF7F1D1DZFFD7592A<drrrrrrrrNrOrQrrrrz)DEBUG: Error en gen_reporte_generadores: rr)9rropenpyxl.utilsr openpyxl.stylesrr r rropenpyxl.drawing.imagerrw generadoresrrr#rrrrRr get_documentos_fecha_generadoresrzrrxr&create_boolean_plotrVrrrrrarminrrTr indexrr TypeErrorrrrrrrrrr^rFrrrGrH)BrIrrrrrr rr r rrZ ExcelImageZLLAVESZHEADERSr Zgeneradores_collectionrrrrrZ START_ROWZ BLANK_COLSZthin_border_sideZ thin_borderr] fecha_actualrdocumentos_fecharW header_row_r)Zdata_rowimg_dataZ img_for_excelZ total_filasZfirst_data_rowZ last_data_rowZfirst_data_colZ last_data_colZ row_cellsrZcol_idxZ col_letterrZrow_idxZ cell_valuerr Z fill_greenZfill_redZ fill_orangeZcol_plc_statusZcol_partida_statusrZplc_cellZ partida_cellZplc_valZ partida_valrrrXrLrr*r*r+gen_reporte_generadores?s                               rc CstdzD|j}td}|||d}d}|D]}|dd}q6|WStk r}z$td|d|d |jjW5d}~XYnXdS) rz En GET generator version antiguarrNr@rz0Error al obtener datos de generador para centro z': r:) r#r rrrr%rFrGrH)rIr rrerZgenerador_datar)rLr*r*r+legacy_get_generator/src CszV|j}td}|||ddddii}|rRd|krR|drR|ddWSWdStk r}ztd|WYdSd}~XYnXdS) z< Optimizado para no iterar cursor innecesariamente. rrr@z$slicerrNzError get_generator: )r rrrr0rFr#)rIr rrer)rLr*r*r+ get_generatorIs rc Cs||d}t|j|}g}|D]\}z$|d}t|gs>n ||Wq"tk r|}ztd|jj |W5d}~XYq"Xq"|S)Nrr@uOcurrió un error:) r$r r%r&allrxrFr#rGrH) rIr rdr documentosZfiltered_documentsrr@rLr*r*r+r `s   r cCsddl}|dddlm}ddlm}ddlm}ddlm}g}g}|D]} | | dd} | dd kr| d d kr| d | | q| d| | qN| dd kr|gkr| |d | | qN| d| | qN|j dd d\} } | d|| d| d| j|d| j|| | j||dddd| dd g| ddg| ||} |j| dd ddd|| | d| S)u= Crea una gráfica de los valores booleanos 'detencion' y 'partida' a lo largo del tiempo (eje X). Parámetros: ----------- documentos_fecha : list Lista de documentos (diccionarios) que contienen los campos: - timestamp (str) - detencion (bool) - partida (bool) fecha_str : str String representando la fecha (por ejemplo, "YYYY-MM-DD") que se usará para el título de la gráfica. Retorna: -------- image_data : BytesIO Objeto BytesIO con la imagen en formato PNG. rNAgg)r)BytesIOr>z%Y-%m-%d %H:%M:%Srrrrrr)r)figsizedpiuGenerador: Arranques día ZTiempozEstado Generadorz%H:%Mz#296f4drpost)rlabelwhereOFFONpngZtightg?)formatrZ bbox_inchesZ pad_inches) matplotlibusematplotlib.pyplotpyplotZmatplotlib.datesdatesriorrr&rxsubplots set_title set_xlabel set_ylabelZxaxisZset_major_formatterZ DateFormatterZset_major_locatorZAutoDateLocatorZ autofmt_xdater\Z set_yticksZset_yticklabelslegendZ tight_layoutZsavefigrseek)r fecha_strr%pltZmdatesrrtimesZ partida_valsr)tfigaxZ image_datar*r*r+r sN                r c Csvz>|r*td|td}||d}|j|ddi}|r |dd}dd |D}||krtd |d id d|ii}z*|j |g} td | j d | j WnBt k r} z$td|d| j jd| dW5d} ~ XYnXnt|dn|j|||gdtdntd|WdSWn0t k rp} zt| j jW5d} ~ XYnXdS)Nzsave_one_generator_data data=rrzgenerador.timestampFr@rcSsi|]\}}|dkr||qSr=r*).0kvr*r*r+ sz+save_one_generator_data..r.rgz*Upsert realizado. Documentos modificados: z, documentos insertados: z.Error al guardar datos de generador en centro r:z: z5: Datos de generador sin cambios, no se actualiza BD.)r rer@zNuevo documento insertado.zNo hay datos de generadores: )r#rrrr r0ryr{r|r}modified_countupserted_countrFrGrH insert_one) rIr r3rern existing_docZ alredy_datanew_dataupdate_operationrprLr*r*r+rEs8   4  rE)F)rNrOrPrQ)N)?Z save_datarZ comap_datarrrr{copyrrtypingrrrr rr r r rrrZopenpyxl.chartrrrrrSZopenpyxl.drawing.textrrZopenpyxl.workbook.protectionrr_rpathlibrrZ KEYS_INTERESZKEYS_INTERES_AUX#HISTORIAL_CONTROL_ARRAY_LEN_TO_SENDr,r2r8rMr^rcrqrrrkrDrrrrrrrrr r rEr*r*r*r+s\            ! M ,(6$   2>q!\