a 0i @s^dZddlZddlmZddlZddlZddlmZddlm Z m Z m Z m Z ddl mZmZddlmZmZmZmZmZmZmZmZmZddlmZeed ed ed d d Zdedededddgedddddd ZgdgdgddZGdddZ Gd d!d!Z!Gd"d#d#Z"d$d%Z#d&d'Z$d(d)Z%d*d+Z&d,d-Z'dS).u Módulo completo de actualización del Score. Maneja el flujo completo desde la validación del Excel hasta la actualización de la tabla CM_Score en la base de datos. N) load_dotenvdatetime)requestjsonifyrender_templateredirect)get_connectionget_connectionERP) obtener_datos_score_erpobtener_estructura_validadorverificar_tabla_cm_scoreobtener_ultima_version_historyobtener_columnas_tablacrear_tabla_cm_scorecrear_tabla_scorehistorytruncate_tablainsertar_bulk_score) validar_score_para_actualizacionZFTP_HOSTZFTP_USERZFTP_PASSW/domains/sycelephant.com/public_html/file/SyC/IngenieroControl/RespaldoActualizarScore/)hostuserpassword remote_pathFZ TENANT_IDONEDRIVE_CLIENT_IDONEDRIVE_CLIENT_SECRETzhttp://localhost:5000/callbackzFiles.ReadWriteONEDRIVE_USERNAMEZ.EWDk3kJdEcdJivAlcKPi8woBTgMWG_qfQ1rYYo0Jcy5QbQz-https://login.microsoftonline.com/{tenant_id}z https://graph.microsoft.com/v1.0zonedrive_token_cache.json) enabled tenant_id client_id client_secret redirect_uriscopes user_emailfile_id authority graph_urltoken_cache_file)FOrderNum DepartamentoVendedorName TotalLines OrderLinePartNumLineDesc CapacidadVoltajeTipo RevisionNumDecriptionProdCaseta OrderDate NeedByDateZ FechaAnticipo LiberacionCXPZTerminos OrderNum&Line ProjectIDJobNum2 Revision_OVRevision_Project Revision_Job FechaDeCierreInsumosDemandadosInsumosEmitidosFechaDeTermino PartNum_M Description_M PartClass_M RefCategory_MQtyPer_M IssuedQty_M Demandado_M OnhandQty_MEn_PO_MNoPO_MEnRequisicion_MNoRequisicion_M PartNum_G Description_G PartClass_G RefCategory_GQtyPer_G IssuedQty_G Demandado_G OnhandQty_GEn_PO_GNoPO_GEnRequisicion_GNoRequisicion_G PartNum_T Description_T PartClass_T RefCategory_TQtyPer_T IssuedQty_T OnhandQty_T PartNum_R Description_R PartClass_R RefCategory_RQtyPer_R IssuedQty_R OnhandQty_RComentarioLINEZOvEEUUZ ClienteEEUU)$ProdCode ComentarioSyCChkFechaSyCConsideradaPreasignacionConsideradaMaterialesuFechaProducciónuComentarioProducciónuAvanceProducciónuFechaPlaneación EstadoFechauComentarioPlaneaciónuFechaInicialPlaneaciónZ MotivoInicialFechaMatAvisoDeTerminacionTerminadoConFaltanteuFechaActualizaciónMaterialFaltanteZ Auxiliar1Z Auxiliar2ComentarioCalidad Preasignado_M NoSerie_MReq_M Comment_M FechaReq_MPO_MCantidad_Pedida_M Preasignado_G NoSerie_GReq_G Comment_G FechaReq_GPO_GCantidad_Pedida_G) FechaVentasFechaSimulacionesFechaMGAvanceDeSurtimientoAvaceDeEmisiones Faltante_M Alternativa_MEn_PO_Altern_M NoPO_Alern_M Estatus_MFecha_Llegada_M Faltante_G Alternativa_GEn_PO_Altern_G NoPO_Alern_G Estatus_GFecha_Llegada_G) columnas_erpcolumnas_manualcolumnas_formuladoc@s8eZdZdZddZddZddZdd Zd d Zd S) FTPManageru Gestiona la conexión y operaciones con el servidor FTP para guardar respaldos del archivo Excel ✅ Versión actualizada con navegación paso a paso cCs2td|_td|_td|_td|_d|_dS)Nrrrr) FTP_CONFIGrrrrftpselfrJ/var/www/html/src/App/SupyCtrol_Module/IngenieroControl/ActualizarScore.py__init__s     zFTPManager.__init__c Csz6tdt|j|_|j|j|jtdWdSty~}z0tdt |tdt |WYd}~n d}~00dS)u Establece conexión con el servidor FTP Returns: bool: True si la conexión fue exitosa Raises: Exception: Si hay error de conexión zConectando a FTP...u ✓ Conectado a FTP exitosamenteTu✗ Error al conectar a FTP: uError de conexión FTP: N) printftplibFTPrrloginrr Exceptionstr)rerrrconectars zFTPManager.conectarc CsHztdz|jdtdWn Yn0z|jdtdWn6ty}ztd|WYd}~WdSd}~00z|jd td Wn6ty}ztd |WYd}~WdSd}~00z|jd td Wn8ty"}ztd|WYd}~WdSd}~00zv|jdtdg}|jd|jtdd|ddd|vs~d|vrtdntdtdWn8ty}ztd|WYd}~WdSd}~00z|jdtdWntjynz0|jd|j d|jdtdWn:tyh}z td|WYd}~YWdSd}~00Yn0z|jd td!Wntjy z0|jd|j d"|jd"td#Wn:ty}z td$|WYd}~YWdSd}~00Yn0z|jd%td&Wntjyz0|jd |j d'|jd'td(Wn:ty}z td)|WYd}~YWdSd}~00Yn0|j }td*td+|||j krtd,n&td-td.|j td/|Wd0StyB}z td1t |WYd}~dSd}~00dS)2u Crea la estructura de carpetas navegando paso a paso Se asegura de estar en el file correcto (el que tiene Formatos, Operaciones) Returns: bool: True si la estructura está lista z,Verificando estructura de carpetas en FTP.../u ✓ En la raíz FTPz/domainsu ✓ En /domainsu% ✗ No se pudo acceder a /domains: NFz/domains/sycelephant.comu! ✓ En /domains/sycelephant.comu, ✗ No se pudo acceder a sycelephant.com: z$/domains/sycelephant.com/public_htmlu- ✓ En /domains/sycelephant.com/public_htmlu( ✗ No se pudo acceder a public_html: z)/domains/sycelephant.com/public_html/fileu2 ✓ En /domains/sycelephant.com/public_html/fileNLSTu 📂 Contenido actual: z, ZFormatos OperacionesuJ ✓ Confirmado: Estamos en el file CORRECTO (tiene Formatos/Operaciones)u: ⚠ ADVERTENCIA: Este file no tiene Formatos/Operacionesu& ⚠ Puede que sea el file equivocadou! ✗ No se pudo acceder a file: z-/domains/sycelephant.com/public_html/file/SyCu ✓ Carpeta existe: SyCSyCu ✓ Carpeta creada: SyCu ✗ No se pudo crear SyC: z>/domains/sycelephant.com/public_html/file/SyC/IngenieroControlu& ✓ Carpeta existe: IngenieroControlIngenieroControlu& ✓ Carpeta creada: IngenieroControlu) ✗ No se pudo crear IngenieroControl: ru- ✓ Carpeta existe: RespaldoActualizarScoreZRespaldoActualizarScoreu- ✓ Carpeta creada: RespaldoActualizarScoreu0 ✗ No se pudo crear RespaldoActualizarScore: u ✓ Estructura de carpetas listau✓ Ubicación actual: u+✓ CONFIRMADO: Estamos en la ruta correctau>⚠ ADVERTENCIA: Ubicación actual no coincide con remote_pathz Esperado: z Actual: Tu+✗ Error al crear estructura de carpetas: ) rrcwdr retrlinesappendjoinr error_permmkdpwdrr)rritemsZubicacion_actualrrrcrear_estructura_carpetass                  "      "      "   z$FTPManager.crear_estructura_carpetasc Csz|jdur||tdtd|td|jt|d$}|jd||Wdn1sv0Ytd|td|d Wd Sty}z0td t|td t|WYd}~n d}~00dS) u\ Sube un archivo al servidor FTP Args: local_path (str): Ruta local del archivo remote_filename (str): Nombre del archivo en el servidor Returns: bool: True si se subió correctamente Raises: Exception: Si hay error al subir Nz Subiendo archivo a FTP...z Archivo: z Destino: rbzSTOR u!✓ Archivo subido exitosamente: uT✓ URL: https://sycelephantt.com/file/SyC/IngenieroControl/RespaldoActualizarScore/ Tu"✗ Error al subir archivo a FTP: zError al subir a FTP: ) rrrrropen storbinaryrr)rZ local_pathZremote_filenamefilerrrr subir_archivos  2zFTPManager.subir_archivoc CsXz |jdur|jtdWn2z|jdur>|jWn Yn0Yn0dS)uCierra la conexión FTPNu✓ Desconectado de FTP)rquitrcloserrrr desconectar@s    zFTPManager.desconectarN) __name__ __module__ __qualname____doc__rrrrrrrrrrzs ~%rc@s@eZdZdZddZddZddZdd Zd d Zd d Z dS)OneDriveManageru Gestiona actualización automática del Score en SharePoint usando Microsoft Authentication Library (MSAL) con Azure AD ✅ Maneja refresh tokens automáticamente ✅ Guarda tokens en archivo local ✅ No requiere regenerar tokens manualmente cCsrddl}ddl}t|_|jd|_|jdj|jdd}|j|jd|jd|d|_|jd |_| |_ dS) Nrr&r%rrrr rZclient_credentialr%r') msalosONEDRIVE_CONFIGconfigr&formatConfidentialClientApplicationmsal_appr'_load_token_cache token_cache)rrrr%rrrr\s   zOneDriveManager.__init__cCspddl}ddl}|j|jrlzty}z&tdt|tdWYd}~n d}~00td|||_t|j|jd<td|jddtd| td|jdd td| tdtdz2t |_ t|j |jd<td|jddWnty}znt|}d|vsd|vrd }n$d!|vrd"}nd#|vrd$}nd%}dd&d'||gd(d)d*WYd}~WSd}~00td+| t|j|jd,<|jd|jd,|jd-<td.|jd,dtd/|td0td1|td2td3td4rz|d |jd5<WnJty}z0td6t|tdd|jd5<WYd}~n d}~00ntd7td8|}tdtd9td|WStyh}z.td:t|d dt|d;WYd}~Sd}~00dS)z9ScoreProcessor.leer_excel_a_dataframe..)columnsu ✓ Excel leído: z filas, z columnasrrru 🔍 Columnas esperadas: u 🔍 Columnas en Excel: u( ❌ ERROR: Faltan columnas esperadas: z - z ... y u columnas mászDEl Excel no tiene todas las columnas esperadas. Columnas faltantes: u& ⚠️ Columnas extra detectadas (z):u) ℹ️ Estas columnas serán ignoradasu ✓ DataFrame filtrado a z columnas esperadas u2 🔍 Verificando valores en columnas formuladas:ru ⚠️ z: rz valores (z NULL)u ✓ z valoresz ... y u columnas formuladas másru& 📅 Ejemplo de valores en FechaMG:z Fila )rr0r sheetnamesrr enumerate iter_rowsrr# DataFramerr9CLASIFICACION_COLUMNASsetsortedisnasumnotnaheadrlimpiar_dataframe_para_sql)rr r0ZNOMBRE_HOJA_EXCELwbwsrridxrowr(Zcolumnas_esperadasZcolumnas_faltantescolZcolumnas_extraZcolumnas_formuladasZ valores_nullZvalores_no_nulltotalZvalores_ejemplovalrrrrs       $  z%ScoreProcessor.leer_excel_a_dataframec Cst}|dkrd}d}nBd|}t|}|jj}t||}|rN|}d}n |d}d}d|}|rzt} t|| nt|t |j|||j d<||j d<dS) zX Guarda respaldo del Excel en ScoreHistory_X con versionado inteligente rTZ ScoreHistory_FrrN) rrrr9tolistcomparar_estructura_columnasr rrrr) rZversion_actualZ version_usarZ crear_nuevaZ tabla_actualZcolumnas_historycolumnas_excelZ son_igualesZ tabla_destino estructurarrrrXs*       z"ScoreProcessor.guardar_respaldo_bdcCsRt|_tdt|jdtdt|jdtdt|jddS)uh Obtiene y asigna la clasificación de columnas (ahora usando clasificación estática) z - Columnas ERP: rz - Columnas Manual: rz - Columnas Formuladas: rN)r@rrrrrrrrsz*ScoreProcessor.obtener_estructura_columnasc Cs8g}|jd}|jd}|jd}tdt|jd|jD]\}}|d}i}|D]} | |jvrZ|| || <qZ|j|jd|k} t| dkr| jd} |D]} | | jvr| | || <q|D]} | | jvr| | || <qn$|D] } d|| <q|D] } d|| <q||qBt ||_ td t|j d dS) u$ Mezcla df_score_excel y df_score_erp según las reglas de negocio REGLA PRINCIPAL: - df_score_erp "manda" → solo filas que existen en ERP - Columnas ERP: siempre del ERP - Columnas Manual/Formuladas: del Excel si existe, NULL si no rrrz Procesando z filas del ERP...r9rNu ✓ Mezcla completada: z filas resultantes) rrrriterrowsr!rilocrr#r?r) rZ filas_scorerrrrJZfila_erpZ ordernum_lineZ fila_scorerL fila_excelrrrrs:              z!ScoreProcessor.mezclar_dataframescCs.t}|s"tdt}t|ntddS)zD Verifica si CM_Score existe y la crea si no existe u) Tabla CM_Score no existe, creándola...z Tabla CM_Score ya existeN)r rr r)rZexisterSrrrrs  z0ScoreProcessor.crear_tabla_cm_score_si_no_existecCstdt|jddS)zC Actualiza la tabla CM_Score con los datos finales rN)rrrrrrrrsz(ScoreProcessor.actualizar_tabla_cm_scorecCst|j}td}d|jdr(dndd|jdr}||jdkr4td|fdd}|||||<q4|jD](}||jd krz||d d ||<qztd |S) u Limpia DataFrame antes de insertar en SQL ✅ VERSIÓN CORREGIDA: Maneja correctamente fechas 1900-01-01 Args: df (pd.DataFrame): DataFrame a limpiar Returns: pd.DataFrame: DataFrame limpio rNrz Limpiando datos para SQL...zdatetime64[ns]z Limpiando columna de fecha: cs|dus|rdSt|jrP|}|jdkrL|jdkrL|jdkrLdS|St|tr~|dkrjdSd|vszd|vr~dS|S)u"Convierte fechas inválidas a NoneNilrOrz 1900-01-01z 1900/01/01) rC isinstance Timestamp to_pydatetimeyearmonthdayrr3)xZfechar#rr limpiar_fecha>s   z1limpiar_dataframe_para_sql..limpiar_fechaobjectcSs8|dust|tr"|dkr"dSt|tr4|S|S)Nr)r]rr3)rcrrrcr8z,limpiar_dataframe_para_sql..u ✓ Datos limpiados)pandasrrwhererEr9dtypeapply)r(rrLrerrdrrG%s      rGcCs tt|}tt|}||kS)z Compara dos listas de columnas Args: cols1 (list): Primera lista cols2 (list): Segunda lista Returns: bool: True si son iguales )rArB)Zcols1Zcols2Zset1Zset2rrrrQks  rQcCs@t}||}|}t|d}t|d}|d|dS)z Calcula tiempo transcurrido Args: tiempo_inicio (datetime): Tiempo de inicio Returns: str: Tiempo formateado (ej: "2m 34s") <zm s)rr total_secondsint)rZ tiempo_findeltaZsegundosZminutosZsegsrrrrZ}s   rZcCsX|jddgddd}|jddgddd }|d d d }|d dd}dS)u Registra las rutas de actualización del Score en Flask Args: app: Instancia de Flask mail: Instancia de Flask-Mail z%/SyC/IngenieroControl/ActualizarScoreGET)methodscSstdS)zx Renderiza la vista HTML principal Returns: render_template: Template HTML z/SupYCtrol/IngenieroControl/ActualizarScore.html)rrrrrvista_actualizar_scoresz.vista_actualizar_scorez./SyC/IngenieroControl/ActualizarScore/ejecutarPOSTc Ss|z6t}|}|dr&t|dfWSt|dfWSWn@tyv}z(tddt|ddfWYd}~Sd}~00dS) u Ejecuta el proceso completo de actualización del Score Returns: jsonify: Respuesta JSON con resultado rrFuError crítico: r r+N)rrrrr) processorr.rrrrejecutar_actualizacions z.ejecutar_actualizacionz/onedrive/logincSsRddl}tdjtdd}|jtdtd|d}|jtd td d }t|S) u Inicia el flujo de autorizaciónrNr%rrrr rr"r!)r"r!)rrrrZget_authorization_request_urlr)rr%app_msalZauth_urlrrronedrive_loginsz4ejecutar_actualizacion_score..onedrive_loginz /callbackcSsddl}ddl}tjd}|s$dStdjtdd}|jtdtd |d }|j|td td d }d|vrt tdd}| ||Wdn1s0YdSd|d|dfSdS)u/Callback que recibe el código de autorizaciónrNcode)u.Error: No se recibió código de autorizaciónrur%rrrr rr"r!)rzr"r!rr'ru

✅ Autorización Exitosa

OneDrive ha sido autorizado correctamente.

Los tokens se han guardado y se renovarán automáticamente.

Puedes cerrar esta ventana.

zError al obtener tokens: Zerror_descriptionr+) rrrargsrrrrZ#acquire_token_by_authorization_coderr)rrrzr%rxrrrrronedrive_callbacks. * z7ejecutar_actualizacion_score..onedrive_callbackN)route)appmailrsrwryr|rrrejecutar_actualizacion_scores    r)(rrdotenvrrhr#rrflaskrrrrConsultas_SQL.conexionr r Z7Consultas_SQL.SupYCtrol.IngDeControl.ActualizarScoreSQLr r r rrrrrr2App.SupyCtrol_Module.IngenieroControl.ValidarScorergetenvrrr@rrrr/rGrQrZrrrrrs\  ,  " 'Y A F