a $9i@sdZddlmZddlZddlZddlmZmZmZmZddl m Z m Z m Z m Z edZddlmZmZddlmZdd lmZdd lmZdd lmZdd l m Z d dZddZddZd7edddZeeeefdddZ eeeeee!ffdddZ"ddZ#ddZ$d d!Z%d"d#Z&d$d%Z'd8ed'd(d)Z(e)ed*d+d,Z*eeedd-d.Z+e!eed/d0d1Z,e!eed2d3d4Z-eeed2d5d6Z.dS)9u Archivo: CotizCreatedIngSQL.py Ruta: src\Consultas_SQL\Operaciones\Ingenieria\Cotiz\CotizCreatedIngSQL.py Descripción: Módulo para crear cotizaciones del area de ingenierìa Autor: Equipo de Desarrollo IGSA Fecha: 2025 )datetimeN)DictListOptionalUnion) BlueprintrequestjsonifysessionZcotizaciones_especiales_sql) Productivo ENVIRONMENT)get_connection) upload_document_to_existing_docs)crear_docs_head)enviar_correo_universal)r c Cs&d}d}zt}|}|||f|}|sTtd|WdWdSdd|jD}tt||}|||f|}|r|dnd|d<t| d t r|d  d |d <|WdWS1s0YWn<t y } z"td |d | WYd} ~ dSd} ~ 00dS) u 🔹 Obtiene y une la información necesaria para el envío de correo basada en el TaskID (tabla Q_SpQ_QuotationTasks). 🔹 Devuelve un diccionario listo para usar como `template_data`. aH SELECT Q_OpportunityCRM.CRM_OpportunityNumber, Q_CostingHead.CostingNum, Q_QuotationType.FrontEN, Q_QuotationType.FrontES, Q_CostingHead.CostingDate FROM Q_SpQ_QuotationTasks INNER JOIN Q_SpQ_FormsHead ON Q_SpQ_QuotationTasks.FormID = Q_SpQ_FormsHead.FormID INNER JOIN Q_QuotationType ON Q_SpQ_FormsHead.QuotationTypeID = Q_QuotationType.QuotationTypeID INNER JOIN Q_CostingHead ON Q_CostingHead.CostingID = Q_SpQ_QuotationTasks.CostingID INNER JOIN Q_OpportunityCRM ON Q_SpQ_QuotationTasks.CRM_OpportunityID = Q_OpportunityCRM.CRM_OpportunityID WHERE Q_SpQ_QuotationTasks.TaskID = ?; a` SELECT Users.Email FROM Users INNER JOIN Q_CostingHead ON Q_CostingHead.SellerUserID = Users.UserID INNER JOIN Q_SpQ_QuotationTasks ON Q_SpQ_QuotationTasks.CostingID = Q_CostingHead.CostingID WHERE Q_SpQ_QuotationTasks.TaskID = ?; u0⚠️ No se encontró información para TaskID NcSsg|] }|dqSr.0colrrR/var/www/html/src/Consultas_SQL/Operaciones/Ingenieria/Cotiz/CotizCreatedIngSQL.py Wz"data_for_email..rEmailZ CostingDatez%d/%m/%Y %H:%Mu❌ Error en data_for_email(): ) r cursorexecutefetchoneprint descriptiondictzip isinstancegetrstrftime Exception) task_idZquery1Zquery2connrZrow1Zcolumns1Zresult1row2errrdata_for_emails*(r*c Csd}d}zzRt}|}d}||||f|}|WW|durL||dur\|Sty}z@td|gWYd}~W|dur||dur|Sd}~00W|dur||dur|n$|dur||dur|0dS)zv Consulta los documentos asociados a una oportunidad y form (task) y regresa las filas crudas del cursor. Na SELECT Q_SpQ_FormsHead.CRM_OpportunityID, Q_SpQ_FormsHead.FormID, Q_SpQ_DocsDetail.Title, Q_SpQ_DocsDetail.Ruta, Q_SpQ_DocsDetail.Type FROM Q_SpQ_FormsHead LEFT JOIN Q_SpQ_DocsHead ON Q_SpQ_FormsHead.DocsID = Q_SpQ_DocsHead.DocsID LEFT JOIN Q_SpQ_DocsDetail ON Q_SpQ_DocsHead.DocsID = Q_SpQ_DocsDetail.DocsID WHERE Q_SpQ_FormsHead.CRM_OpportunityID = ? AND Q_SpQ_FormsHead.FormID = ? AND Q_SpQ_FormsHead.DocsID IS NOT NULL zError al consultar documentos: )r rrfetchallcloser%r) oportunity_idr& connectionrqueryrowsr)rrr&consultar_docs_por_oportunidad_y_tareals<  r1c Cs,d|vrd|d<|dur"|d}|r(|r(d}d}zzxt}|Z|}||||f||dd|7<|WdWW|r|S1s0YWnTty}z:d|d<dt||d<|WYd}~W|r|Sd}~00W|r(|n|r&|0|S) Nmessagedocs_idY UPDATE Q_CostingHead SET DocsID = ? WHERE CostingID = ? z" | Costing actualizado con DocsID Fsuccessz Error DB: )r#r rrcommitr,r%str)DocsID CostingID resultador/r'rr)rrruploadFileAuxiliars<    r<r3)destinatarioTestc Cst|}td||s:td|dd|dSznd}|dkrN|}n|d}tdd |ggd d |d }|d rtd|dntd|d|WSty}z.td|d|dt|dWYd}~Sd}~00dS)uq 🔹 Usa los datos de data_for_email(task_id) 🔹 Envía el correo con el template correspondiente zDatos para correo: u1❌ No se pudieron obtener los datos para TaskID Fz$No se encontraron datos para TaskID )r6mensajer3rz0Emails/Ingenieria/Cotiz/CotizCreatedIngMail.htmlu/✅ Costeo creado correctamente - IGSA Elephant)zvictor.barrera.@igsa.com.mxzvictor.cervantes@igsa.com.mxzalexis.moreno@igsa.com.mx)TOCC) template_pathasuntodestinatarios_adicionales template_datar6u"✅ Correo enviado exitosamente a u⚠️ Error al enviar correo: r>u'❌ Error al enviar correo para TaskID : N)r*loggerinforrr#r%r8)r&r=data destinatarior;r)rrrenviarCorreoCostingCreados2 rJ)returnc Csd}g}ztr}|J}|||}|D]"}||d|d|ddq2Wdn1sj0YWdn1s0Y|WSty}ztd|gWYd}~Sd}~00dS)uo Consulta la tabla Q_Currency para obtener el código, el nombre y el símbolo de las monedas activas. zJSELECT CurrencyCode, FrontES, CurrSymbol FROM Q_Currency WHERE Active = 1;r) CurrencyCodeFrontESZ CurrSymbolNzError al obtener las monedas: )r rrr+appendr%r)r/ currenciesr'rr0rowr)rrrget_currenciess  BrSc Csd}g}zt}|X}|||f|}|D],}||d|dt|d|ddq6Wdn1sx0YWdn1s0Y|WSty}ztd|gWYd}~Sd}~00dS) ui Consulta la tabla Q_TaxRate para obtener el código y la descripción de los impuestos. zgSELECT TaxCode, FrontES, TaxAmount, CurrencyCode FROM Q_TaxRate WHERE Active >= 1 AND CurrencyCode = ?;rrLrM)TaxCoderOZ TaxAmountrNNz Error al obtener los impuestos: )r rrr+rPfloatr%r)rNr/Ztaxesr'rr0rRr)rrr get_taxess" FrWc Csd}d}zhzt}||}|||fdd|jD}|}|rtt||}td|d|WdWW|rz | WSYS0St d|dWdWW|rz | Wn Yn0dSWdn1s0YWnJt j yN}z.d|d |}t |t|WYd}~n d}~00W|rz | Wn Yn0n"|rz | Wn Yn00dS) Nzs SELECT TOP 1 CRM_OpportunityID, QuotationTypeID FROM Q_SpQ_FormsHead WHERE FormID = ? cSsg|] }|dqSrrrrrrrrz,obtener_datos_formulario..z Formulario z encontrado correctamente.uNo se encontró FormID .z&Error SQL en obtener_datos_formulario(rr rrrrr r!rFrGr,warningpyodbcErrorerrorr%) form_idr/r'rcolumnsrRresultr)msgrrrobtener_datos_formulariosR   &    rbc Csd}d}zhzt}||}|||fdd|jD}|}|rtt||}td|d|WdWW|rz | WSYS0St d|dWdWW|rz | Wn Yn0dSWdn1s0YWnJt j yN}z.d|d |}t |t|WYd}~n d}~00W|rz | Wn Yn0n"|rz | Wn Yn00dS) Na% SELECT TOP 1 UserRoles.RoleID, Roles.CompanyID, Roles.DivisionID, Roles.DepartamentID, Profiles.CompanyID AS ProfileCompanyID, Profiles.DivisionID AS ProfileDivisionID, Profiles.DepartamentID AS ProfileDepartamentID FROM Users INNER JOIN Profiles ON Users.UserID = Profiles.UserID INNER JOIN UserRoles ON Users.UserID = UserRoles.UserID INNER JOIN Roles ON UserRoles.RoleID = Roles.RoleID WHERE Users.UserID = ? cSsg|] }|dqSrrrrrrrPrz,obtener_contexto_usuario..zContexto de usuario z recuperado correctamente.%No se encontró contexto para UserID rXz&Error SQL en obtener_contexto_usuario(rrY) user_idr/r'rr_rRr`r)rarrrobtener_contexto_usuario9sR   &    rec CszzFt}|}d}|||}|r2|jndWW||Sty}z4tdt |WYd}~W||dSd}~00W||n||0dS)u8Genera el siguiente número de costing (IDENTITY 1000,1)zf SELECT ISNULL(MAX(CostingNum), 999) + 1 AS NextCostingNum FROM Q_CostingHead izError al generar CostingNum: N) r rrrZNextCostingNumr,r%rFr]r8)r'rr/rRr)rrrgenerar_costing_numis(   rfc'Cs|d}d}z z|d}|d}|d}td|d|rL|stddid fWW|r|z |Wn Yn0|rz|td WSYS0Std |d |t|}|s.tdd |idfWW|rz |Wn Yn0|r,z|td WSYS0St|}|stdd|idfWW|rtz |Wn Yn0|rz|td WSYS0St}|}|dd}| d| d} | d} | d|} td| d| dd} t d| | | ||d||d||d|d|d|d|d |d!|d"|d#|d$|d%|d&|d'|d(|d)|d*|d+|d,|d-|d.|d/|d0|d1|d2|d3|d4|d5d6|d7|d8f"td9| td:|dd;|dvrd|d!dd?d|d#dd?d|d%dd?d|d'dd?}td@|dA| rXdB}| D]f}| || |dC|dD|dE|dF|dG|dH||dH||dFf|d7}qtdI|dJn t dK|dL}dM}| ||dN}| ||d.f| }|d}|dkrdO}| ||d.ftdP|d.dQt dR| dS}| || f| }|r|dnd}tdT|dU| tdV|dW}| || ||f| tdX| td6dY| | ||d|d.||d1dZd[d\fWW|rz |Wn Yn0|rz|td WSYS0Stjy}z|r |td]|td^t|d_d`fWYd}~W|r^z |Wn Yn0|rz|td WSYS0Sd}~0tjy8}z|r|tda|tdbt|d_dcfWYd}~W|rz |Wn Yn0|r.z|td WSYS0Sd}~0ty}z|rV|tdd|tdet|d_dcfWYd}~W|rz |Wn Yn0|rz|td WSYS0Sd}~00W|rz |Wn Yn0|rxz|td Wn Yn0nL|rLz |Wn Yn0|rvz|td Wn Yn00dS)fu Endpoint que crea Q_CostingHead y Q_CostingDetail en una transacción. Obtiene el último CostingNum, incrementa +1 y lo usa para insertar. NZFormIDUserID SellerUserIDz costingId r:r]u4Faltan parámetros: FormID y UserID son obligatoriosu🔒 Conexión cerradau.📋 Iniciando creación de Costing - FormID: z , UserID: u)No se encontró información para FormID rcVersionrLz7SELECT ISNULL(MAX(CostingNum), 999) FROM Q_CostingHead;r-u!🧮 Generando nuevo CostingNum: u (último fue )a1 INSERT INTO Q_CostingHead ( CostingNum, Version, QuotationTypeID, UserID, RoleID, SellerUserID, CompanyID, DivisionID, DepartamentID, CaseCost, DirectCost, IndirectPercent, IndirectAmount, FinancePercent, FinanceAmount, UtilityPercent, UtilityAmount, OperationPercent, OperationAmount, SalePriceMin, DiscountMaxPercent, DiscountMaxAmount, SalePriceList, OvercostFactor, CRM_OpportunityID, ApprovalProcessID, PreviusDocsID, DocsID, TechnicalTermsAndConditions, RunTimeNumber, RunTimeType, Active, CurrencyCode, TaxCode ) VALUES ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ) z)Inserting into Q_CostingHead with values:QuotationTypeIDRoleID CompanyID DivisionID DepartamentIDZCaseCostZ DirectCostZIndirectPercentZIndirectAmountZFinancePercentZ FinanceAmountZUtilityPercentZ UtilityAmountZOperationPercentZOperationAmountZ SalePriceMinZDiscountMaxPercentZDiscountMaxAmountZ SalePriceListZOvercostFactorCRM_OpportunityIDZApprovalProcessIDZ PreviusDocsIDr9ZTechnicalTermsAndConditionsZ RunTimeNumberZ RunTimeTypeZActiveTrNrUu9✅ Q_CostingHead insertado correctamente con CostingNum=z----case cost: z----ZQ_CostingDetailA)BCdzOvercostFactor para detalles: z.6fz INSERT INTO Q_CostingDetail ( CostingID, CostingLine, PartNum, PartDescription, Qty, UOMCode, UnitPrice, Amount ) VALUES (?, ?, ?, ?, ?, ?, ?, ?) Z CostingLinePartNumPartDescriptionZQtyUOMCodeZ UnitPriceu✅ z$ items insertados en Q_CostingDetailu4⚠️ No hay items en Q_CostingDetail para insertarTaskIDz UPDATE Q_SpQ_QuotationTasks SET Status = 'COMPLETADO', StatusDate = CAST(SYSDATETIMEOFFSET() AT TIME ZONE 'Central America Standard Time' AS DATETIME) WHERE TaskID =?; z SELECT COUNT(TaskID) AS NumeroDeTareasPorAsignarNoCompletadas FROM Q_SpQ_QuotationTasks WHERE CRM_OpportunityID = ? AND Status <> 'COMPLETADO'; u UPDATE Q_OpportunityCRM SET Status = 'ATENDIDO', UpdatedAt = CAST(SYSDATETIMEOFFSET() AT TIME ZONE 'Central America Standard Time' AS DATETIME) -- Actualiza la fecha de modificación --UpdatedBy = 'NOMBRE_USUARIO_QUE_ACTUALIZA' -- Actualiza quién realizó la modificación WHERE CRM_OpportunityID = ?; u✅ Oportunidad CRM z actualizada a 'ATENDIDO'zcosting id generado:zh select CostingDate from Q_CostingHead where CostingID = ?; u✅ CostingDate obtenido: z para CostingID z*task id para actualizar en costing tasks: z UPDATE dbo.q_spq_quotationtasks SET CostingID = ?, CostingDate = ? WHERE TaskID = ? u)✅ Transacción confirmada - CostingID: zCosting creado exitosamente)r:Z CostingNumrkrnrsZItemsInsertadosr9)r6r2rHu❌ Error de integridad: zError de integridad de datosr]detailsiu❌ Error de base de datos: zError en base de datosu❌ Error inesperado: zError al crear costing)r#rFrGr r,rbrer rrrrrZr7r[IntegrityErrorrollbackr]r8r\r%)rHr'rr^rdseller_user_idZsub1Zsub2versionZlast_numZ costing_num costing_idZinsert_head_queryZ detail_itemsZitems_insertadosZcasoZfactorOverCostZinsert_detail_queryitemr{Zquery3Zquery4Z resultQuery4Znumero_de_tareasZquery5Zquery6Z resultQuery6Z costing_dateZquery7db_errorr)rrrgenerar_costing_headSQLs   } t p     &              ! "   "  "   rc Cstdd}d}z|ztd||d}|d}td|td||rf|stdd id fWW|rz |Wn Yn0|rz|td WSYS0Std |t}|}d }||||f|jdkrtt d|dtdd|idfWW|rHz |Wn Yn0|rrz|td WSYS0S| td|d|tdd|ddfWW|rz |Wn Yn0|rz|td WSYS0St j y}z|r| td|tdt|ddfWYd}~W|rjz |Wn Yn0|rz|td WSYS0Sd}~0tyB}z|r| td|tdt|ddfWYd}~W|rz |Wn Yn0|r8z|td WSYS0Sd}~00W|rfz |Wn Yn0|rz|td Wn Yn0nL|rz |Wn Yn0|rz|td Wn Yn00d}d}z\zt}|d}|d}|r|sttdd id fWW|rHz |Wn Yn0|rrz|td WSYS0Std |t}|}d }||||f|jdkr(t d|dtdd|idfWW|rz |Wn Yn0|r&z|td WSYS0S| td|d|tdd|ddfWW|rz |Wn Yn0|rz|td WSYS0St j yR}z|r| td|tdt|ddfWYd}~W|rz |Wn Yn0|rHz|td WSYS0Sd}~0ty}z|rp| td|tdt|ddfWYd}~W|rz |Wn Yn0|rz|td WSYS0Sd}~00W|rz |Wn Yn0|rz|td Wn Yn0nL|rfz |Wn Yn0|rz|td Wn Yn00dS)z> Endpoint para actualizar el DocsID en Q_CostingHead. u8🔄 Iniciando actualización de DocsID en Q_CostingHeadNu%Datos recibidos para actualización: r:r9zcostingId recibido: zdocsId recibido: r]u7Faltan parámetros: CostingID y DocsID son obligatoriosriu*🔒 Conexión a la base de datos cerrada.u8📋 Iniciando actualización de DocsID para CostingID: r5ru$⚠️ No se encontró el CostingID z para actualizar.u*No se encontró un registro con CostingID rju(✅ DocsID actualizado correctamente a 'z' para CostingID Tz.DocsID actualizado correctamente en CostingID )r6r2u1❌ Error de base de datos al actualizar DocsID: zError en la base de datosr}ru+❌ Error inesperado al actualizar DocsID: uOcurrió un error inesperado)rFrGr#r r,r rrrowcountrZr7r[r\rr]r8r%rget_json)rHr'rrr4 update_queryrr)rrrupdate_costing_head_docsidSQLs   ;  !  "   "      ;  !  "   "   rGeneral)r:c Cszt|dt|}|d}g}|D]>}t|||jd|d|d} | dr || ddq t|d k|t||d S) uA Patrón simplificado para casos con una sola categoría Z Q_CostingHeadr4z Archivo de zVentas/Costeo/)file_objr4titler ruta_completar6rH download_urlr)r6r4archivos_subidosurls)robtener_nombre_usuariorfilenamerPlen) archivosZ modulo_idrdr:Z categoriaZ docs_resultr4Zurls_generadasarchivor;rrrupload_archivos_simpleIs$ r)rdrKc Csd}d}zzt}|sFd|WW|rDz |WSYS0S||}|||f|}|rd|d}|r|nd|WdWW|rz |WSYS0Sd|WdWW|rz |WSYS0SWdn1s0YWnlty}zRt d|dt |d|WYd}~W|rz |WSYS0Sd}~00W|rz |Wn Yn0n"|rz |Wn Yn00dS)z Obtiene el nombre completo del usuario desde la tabla Profiles Args: user_id (int): ID del usuario Returns: str: Nombre completo del usuario a SELECT CONCAT( COALESCE(Profiles.FirstName, ''), ' ', COALESCE(Profiles.LastName, ''), ' ', COALESCE(Profiles.SecondLastName, '') ) AS FullName FROM Profiles WHERE Profiles.UserID = ? AND Profiles.UserID IN ( SELECT Users.UserID FROM Users WHERE Users.Status = 'ACTIVO' ) NZUsuario_ rz#Error al obtener nombre de usuario rE) r r,rrrjoinsplitstripr%rFrZr8)rdr/r'rrR full_namer)rrrrhsf   &   &   rc Csd}d}zvzlt}|s"td|>|}||dd|jD}|}|rg}|D]F}tt||}dD]$}||vrx||rx||||<qx| |qbt dt |d|WdWW|rz | WStyt d YS0St d WdWW|rTz | WntyRt d Yn0dSWdn1sn0YWntjy} z,d t| } t | t| WYd} ~ nd} ~ 0ty} z,d t| } t | t| WYd} ~ nNd} ~ 0tyJ} z,d t| } t | t| WYd} ~ n d} ~ 00W|rz | Wnty~t d Yn0n4|rz | Wntyt d Yn00dS)un Busca todos los datos de score en la tabla Score de la base de datos Returns: List[Dict]: Lista de diccionarios con los datos de los scores encontrados None: Si no se encuentra ningún registro Raises: ConnectionError: Si no se puede establecer conexión con la BD Exception: Para otros errores durante la consulta z) SELECT * FROM Score; N4No se pudo establecer conexión con la base de datoscSsg|] }|dqSrrrcolumnrrrrrz buscar_score..) CreatedAtZ UpdatedAtzSe encontraron z registros de scoreu$Error al cerrar la conexión a la BDz-No se encontraron registros en la tabla Scorez-Error de base de datos al buscar los scores: u)Error de conexión al buscar los scores: z'Error inesperado al buscar los scores: )r ConnectionErrorrrrr+r r! isoformatrPrFrGrr,r%rZr[r\r8r]) r/r'rr_r0resultsrRr`Z date_fieldr) error_msgrrr buscar_scoresr      (      r)r&rKc Csdd}d}z2z(t}|s"td||}|||fdd|jD}|}|rtt||}t d|dd|vr|dr|d |d<|WdWW|rz | WSYS0St d|d WdWW|rz | Wn Yn0dSWdn1s*0YWnt jy}z2d |d t|}t|t|WYd}~nd}~0ty}z2d |d t|}t|t|WYd}~nTd}~0ty}z2d |d t|}t|t|WYd}~n d}~00W|r`z | Wn Yn0n"|r^z | Wn Yn00dS)za Busca datos de la oportunidad en la tabla Q_CRM Args: Returns: Raises: a SELECT TOP 1 Q_CRM.CRM_OpportunityNumber, Q_CRM.CRM_Version, Q_CRM.CRM_ContactID, Q_CRM.CRM_ContactName, Q_CRM.CRM_ContactType, Q_CRM.CRM_AssignedSalesperson, Q_CRM.CRM_ContactAdress, Q_CRM.CRM_ContactColonia, Q_CRM.CRM_ContactCity, Q_CRM.CRM_ContactNumber, Q_CRM.CRM_ContactCountry, Q_CRM.CRM_ContactLegalIdentifier, Q_CRM.CRM_ContactZip, Q_CRM.CRM_ContactState, Q_CRM.CRM_ContactEmail, Q_CRM.Status, Q_CRM.CreatedAt, Q_CRM.CreatedBy, Q_CRM.Active FROM Q_SpQ_QuotationTasks JOIN Q_SpQ_FormsHead ON Q_SpQ_QuotationTasks.FormID = Q_SpQ_FormsHead.FormID JOIN Q_OpportunityCRM ON Q_SpQ_FormsHead.CRM_OpportunityID = Q_OpportunityCRM.CRM_OpportunityID JOIN Q_CRM ON Q_OpportunityCRM.CRM_OpportunityNumber = Q_CRM.CRM_OpportunityNumber WHERE Q_SpQ_QuotationTasks.taskID = ? AND Q_CRM.Active = 1 ORDER BY Q_CRM.CRM_Version DESC; NrcSsg|] }|dqSrrrrrrr/rz$buscar_tarea_crm.. Oportunidad  encontrada exitosamenter" no encontrada en la base de datosz0Error de base de datos al buscar la oportunidad rEu+Error de conexión al buscar la oprtunidad z*Error inesperado al buscar la oportunidad r rrrrrr r!rFrGrr,rZr[r\r8r]r%) r&r/r'rr_rRr`r)rrrrbuscar_tarea_crmsj #  (      r)opportunity_numberrKc Csdd}d}z2z(t}|s"td||}|||fdd|jD}|}|rtt||}t d|dd|vr|dr|d |d<|WdWW|rz | WSYS0St d|d WdWW|rz | Wn Yn0dSWdn1s*0YWnt jy}z2d |d t|}t|t|WYd}~nd}~0ty}z2d |d t|}t|t|WYd}~nTd}~0ty}z2d |d t|}t|t|WYd}~n d}~00W|r`z | Wn Yn0n"|r^z | Wn Yn00dS)u Busca una oportunidad en la tabla Q_OpportunityCRM Args: opportunity_number (float): Número de oportunidad del CRM Returns: Dict: Diccionario con los datos de la oportunidad si se encuentra, None si no existe Raises: ConnectionError: Si no se puede establecer conexión con la base de datos Exception: Para otros errores de base de datos a< SELECT TOP 1 Q_CRM.CRM_OpportunityNumber, Q_CRM.CRM_Version, Q_CRM.CRM_ContactID, Q_CRM.CRM_ContactName, Q_CRM.CRM_ContactType, Q_CRM.CRM_AssignedSalesperson, Q_CRM.CRM_ContactAdress, Q_CRM.CRM_ContactColonia, Q_CRM.CRM_ContactCity, Q_CRM.CRM_ContactNumber, Q_CRM.CRM_ContactCountry, Q_CRM.CRM_ContactLegalIdentifier, Q_CRM.CRM_ContactZip, Q_CRM.CRM_ContactState, Q_CRM.CRM_ContactEmail, Q_CRM.Status, Q_CRM.CreatedAt, Q_CRM.CreatedBy, Q_CRM.Active FROM Q_CRM WHERE Q_CRM.CRM_OpportunityNumber = ? AND Q_CRM.Active = 1 ORDER BY Q_CRM.CRM_Version DESC NrcSsg|] }|dqSrrrrrrrrz*buscar_oportunidad_crm..rrrrz-Error de base de datos al buscar oportunidad rEu)Error de conexión al buscar oportunidad z'Error inesperado al buscar oportunidad r) rr/r'rr_rRr`r)rrrrbuscar_oportunidad_crm`sj  (      rc Csd}d}zpzt}|s"td|Z|}|||fdd|jD}|}|r.tt||}|dd }|dvrt d |d |d t d ||d vrt d |d |dt d|t d |d|dd||WdWW|r,z |WSYS0St d |dWdWW|rpz |Wn Yn0dSWdn1s0YWnt y}z|WYd}~nd}~0tjy }z2d|dt|} t | t| WYd}~nTd}~0tyV}z2d|dt|} t | t| WYd}~n d}~00W|rz |Wn Yn0n"|rz |Wn Yn00dS)u Verifica si ya existe una oportunidad y retorna la versión más alta También valida que no esté cerrada/vendida o en proceso activo Args: opportunity_number (str): Número de oportunidad del CRM Returns: Dict: Datos de la oportunidad existente con versión más alta, None si no existe Raises: Exception: Si la oportunidad está cerrada/vendida o en proceso activo a SELECT TOP 1 Q_OpportunityCRM.CRM_OpportunityNumber, Q_OpportunityCRM.Version, Q_OpportunityCRM.CRM_OpportunityID, Q_OpportunityCRM.Status, Q_OpportunityCRM.Active FROM Q_OpportunityCRM WHERE Q_OpportunityCRM.CRM_OpportunityNumber = ? AND Q_OpportunityCRM.Active = 1 ORDER BY Q_OpportunityCRM.Version DESC NrcSsg|] }|dqSrrrrrrrrz3verificar_oportunidad_existente..Statusr3)ZVENDIDOZVENDIDAZATENDIDOrz tiene status z - proceso terminadozOPPORTUNITY_CLOSED:)Z PENDIENTEz EN DESARROLLOz EN APROBACIONZ EN_DESARROLLOZ EN_APROBACIONz - proceso activozOPPORTUNITY_IN_PROCESS:u encontrada con versión rkz y status z no encontradaz0Error de base de datos al verificar oportunidad rEz*Error inesperado al verificar oportunidad )r rrrrrr r!r#upperrFrZ ValueErrorrGr,r[r\r8r]r%) rr/r'rr_rRr`statusr)rrrrverificar_oportunidad_existentesp    (     r)r3)r)/__doc__rr[loggingtypingrrrrflaskrrr r getLoggerrFconfigr r Consultas_SQL.conexionr #App.Utilities_module.DocsManagementr)Consultas_SQL.Utilities.DocsManagementSQLr#App.Utilities_module.MailManagementrr*r1r<r8rJrSrVrWrbrerfrrrintrrrrrrrrrs@       O.$("(0/:Png