a 0i x@sDddlZddlZddlmZddlmZmZmZmZedZ ddl m Z m Z ddl mZddZeeed d d Zeeed d d ZeeeedddZeeeedddZddZeeeedddZeeeeedddZeedddZeedd d!Zd"d#Zeed$d%d&Zeedd'd(Zeee d)d*d+Z!dS),N)datetime)DictListOptionalUnioncotizaciones_especiales_sql) Productivo ENVIRONMENT)get_connectionc Csfd}d|||ddf}d}d}zzt}|srWW|rPz |Wn Yn0|rnz |Wn Yn0dS|}||||}||r|d}td||WW|rz |Wn Yn0|rz |WSYS0SWW|rz |Wn Yn0|r:z |Wn Yn0dSty} zt dt | |rz | Wn Yn0WYd} ~ W|rz |Wn Yn0|rz |Wn Yn0dSd} ~ 00W|rz |Wn Yn0|rbz |Wn Yn0nB|r@z |Wn Yn0|r`z |Wn Yn00dS)u Inserta un registro en Q_CRM usando solo: - contactName - contactNumber - contactEmail Y devuelve el nuevo CRM_OpportunityNumber (identity). Returns: Optional[int]: Nuevo OpportunityNumber si se insertó, None si hubo error. aQ INSERT INTO Q_CRM ( CRM_Version, CRM_ContactName, CRM_ContactNumber, CRM_ContactEmail, Status, CreatedAt, CreatedBy, Active ) OUTPUT INSERTED.CRM_OpportunityNumber VALUES (?, ?, ?, ?, ?, GETDATE(), ?, 1) SYSTEMNru-✅ CRM Contact insertado: OpportunityNumber=u$❌ Error al insertar contacto CRM: ) r closecursorexecutefetchonecommitloggerinfo Exceptionerrorstrrollback) contactName contactNumber contactEmailqueryparamsconnrrowopportunity_numberer!D/var/www/html/src/Consultas_SQL/Ventas/Cotiz/CotizEspSolicitudSQL.pyinsert_CRM_CONTACTs                  r#)rreturnc Cstd|d}td|td|d}z2z(t}|sLtd||}|||fdd|jD}|}|rtt||}t d|d d |vr|d r|d  |d <|WdWW|rz | WSYS0St d|d WdWW|r:z | Wn Yn0dSWdn1sT0YWntjy}z2d |d t|}t |t|WYd}~nd}~0ty}z2d|d t|}t |t|WYd}~nTd}~0tyB}z2d|d t|}t |t|WYd}~n d}~00W|rz | Wn Yn0n"|rz | 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 u%🔍 DEBUG - Buscar oportunidad CRM: 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 u🔍 DEBUG - Query: N4No se pudo establecer conexión con la base de datoscSsg|] }|dqSrr!.0columnr!r!r" z*buscar_oportunidad_crm.. Oportunidad z encontrada exitosamente CreatedAtz" no encontrada en la base de datosz-Error de base de datos al buscar oportunidad : u)Error de conexión al buscar oportunidad z'Error inesperado al buscar oportunidad )printr ConnectionErrorrr descriptionrdictziprr isoformatr warningpyodbcErrorrrr) rrrrcolumnsrresultr error_msgr!r!r"buscar_oportunidad_crmfsp  (      r;c 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 Nr%cSsg|] }|dqSr&r!r'r!r!r"r*r+z3verificar_oportunidad_existente..Status)VENDIDOVENDIDAATENDIDOr,z tiene status z - proceso terminadozOPPORTUNITY_CLOSED:) PENDIENTEz EN DESARROLLOz EN APROBACION EN_DESARROLLO EN_APROBACIONz - proceso activozOPPORTUNITY_IN_PROCESS:u encontrada con versión Versionz y status z no encontradaz0Error de base de datos al verificar oportunidad r.z*Error inesperado al verificar oportunidad )r r0rrr1rr2r3getupperrr5 ValueErrorrr r6r7rrr) rrrrr8rr9statusr r:r!r!r"verificar_oportunidad_existentesp    (     rI)datos_oportunidaduser_idversionr$c Cst|}d}d}zLzDt}|s*td||}|||dd|||dd|dd|dd|d d|d d|d d|d d|d d|dd|dd|dd|dd|ddd||f||dd|}td|dd|dWdWW|rDz | WSYS0S1sN0YWnt j y}zVdt |} t | ddddddWYd}~W|rz | WSYS0Sd}~0ty:}zVd t |} t | dd!d"dddWYd}~W|r0z | WSYS0Sd}~00W|rz | Wn Yn0n"|rz | Wn Yn00dS)#u Crea o actualiza un registro en Q_OpportunityCRM Args: datos_oportunidad (Dict): Datos de la oportunidad user_id (int): ID del usuario version (int): Versión de la oportunidad Returns: Dict: Resultado de la operación a INSERT INTO Q_OpportunityCRM ( CRM_OpportunityNumber, Version, UserID, CRM_ContactID, CRM_ContactName, CRM_ContactType, CRM_AssignedSalesperson, CRM_ContactAdress, CRM_ContactColonia, CRM_ContactCity, CRM_ContactNumber, CRM_ContactCountry, CRM_ContactLegalIdentifier, CRM_ContactZip, CRM_ContactState, CRM_ContactEmail, Status, CreatedBy, UpdatedBy ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) Nr%CRM_OpportunityNumberr= CRM_ContactIDCRM_ContactNameCRM_ContactTypeCRM_AssignedSalespersonCRM_ContactAdressCRM_ContactColoniaCRM_ContactCityCRM_ContactNumberCRM_ContactCountryCRM_ContactLegalIdentifierCRM_ContactZipCRM_ContactStateCRM_ContactEmailrA-r,z creada exitosamenteT)successopportunity_idz-Error de base de datos al crear oportunidad: Fz,Error al guardar los datos de la oportunidadDATABASE_ERRORri)r\messagecode alert_type status_codez'Error inesperado al crear oportunidad: z(Error interno al procesar la oportunidadINTERNAL_ERROR)obtener_nombre_usuarior r0rrrErrrr r6r7rrr) rJrKrL user_namerrrr]r r:r!r!r"crear_actualizar_oportunidad$s                        rf)r]quotation_type_idrKr$c Cst|}d}d}zzt}|s(td||}|||||||f||d|}td|dd|dWdWW|rz |WSYS0S1s0YWnt j y0}zTd t |} t | d d d d dWYd}~W|r&z |WSYS0Sd}~0t y}zTdt |} t | d ddd dWYd}~W|rz |WSYS0Sd}~00W|rz |Wn Yn0n"|rz |Wn Yn00dS)u  Crea un registro en Q_SpQ_FormsHead Args: opportunity_id (str): ID de la oportunidad quotation_type_id (str): ID del tipo de cotización user_id (int): ID del usuario Returns: Dict: Resultado de la operación z INSERT INTO Q_SpQ_FormsHead ( CRM_OpportunityID, QuotationTypeID, UserID, CreatedBy, UpdatedBy ) VALUES (?, ?, ?, ?, ?) Nr%r[z FormHead z creado exitosamenteT)r\form_idz*Error de base de datos al crear FormHead: Fz%Error al crear registro de formularior^rr\r_r`raz$Error inesperado al crear FormHead: z!Error interno al crear formulariorc)rdr r0rrrrrr r6r7rrr) r]rgrKrerrrrhr r:r!r!r"crear_formulario_heads          rjcCsdS)Nr!)Z opportunitur!r!r"getDocsUploadedFromOpportunitysrk)rh preguntasr$c Cstd|tdt|t|D] \}}td|dd|q(d}d}zzlt}|sltdd }|8|}t|dd D]\}}t|d } td |d td|td| td|dtd|dtd|dtd|d| |||| |d|d|df|d7}td|dq| t d|d|d|dWdWW|rz | WSYS0S1s0YWnt jyB} zbdt| } t | td| d d!d"d#d$WYd} ~ W|r8z | WSYS0Sd} ~ 0ty} zbd%t| } t | td&| d d'd(d#d$WYd} ~ W|rz | WSYS0Sd} ~ 00W|rz | Wn Yn0n"|rz | Wn Yn00dS))u Crea múltiples registros en Q_SpQ_FormsDetail Args: form_id (str): ID del formulario preguntas (List[Dict]): Lista de preguntas y respuestas Returns: Dict: Resultado de la operación u🔍 DEBUG - FormID: u🔍 DEBUG - Total preguntas: u🔍 DEBUG - Pregunta r r.z INSERT INTO Q_SpQ_FormsDetail ( FormID, FormLine, Question, TypeQuestion, Answer ) VALUES (?, ?, ?, ?, ?) Nr%r)startu!🔍 DEBUG - Insertando registro :z FormID: z FormLine: z Question: preguntaz TypeQuestion: Z tipoElementoz Answer: respuestaz Expected FormLineID: r[u✅ DEBUG - Registro z insertado exitosamentezCreados z detalles para FormID T)r\Zrecords_createdz-Error de base de datos al crear FormDetails: u❌ DEBUG - Error SQL: Fz(Error al guardar detalles del formularior^rriz'Error inesperado al crear FormDetails: u❌ DEBUG - Error general: z!Error interno al guardar detallesrc)r/len enumerater r0rrzfillrrrrr r6r7rr) rhrlirprrZregistros_creadosrindexZ form_liner r:r!r!r"crear_formulario_detailss          rw)seller_user_idrhr]rer$c Csd}d}zzt}|s td||}||||d||f|d|d}|td|d|d |d WdWW|rz |WSYS0S1s0YWnt j y4}zTd t |} t | d d dddWYd}~W|r*z |WSYS0Sd}~0t y}zTdt |} t | d ddddWYd}~W|rz |WSYS0Sd}~00W|rz |Wn Yn0n"|rz |Wn Yn00dS)uB Crea una tarea en Q_SpQ_QuotationTasks Args: seller_user_id (int): ID del vendedor form_id (str): ID del formulario opportunity_id (str): ID de la oportunidad user_name (str): Nombre del usuario que crea la tarea Returns: Dict: Resultado de la operación a4 INSERT INTO Q_SpQ_QuotationTasks ( SellerUserID, FormID, Status, StatusDate, CRM_OpportunityID, UpdatedBy ) VALUES (?, ?, ?, CAST(SYSDATETIMEOFFSET() AT TIME ZONE 'Central America Standard Time' AS DATETIME), ?, ?) Nr%z Por AsignarzSELECT @@IDENTITY AS TaskIDrzTarea z creada para FormID T)r\task_idz'Error de base de datos al crear tarea: Fu#Error al crear tarea de cotizaciónr^rriz!Error inesperado al crear tarea: zError interno al crear tarearc)r r0rrrrrrr r6r7rrr) rxrhr]rerrrryr r:r!r!r"crear_tarea_cotizacionFs           rz)rKr$c 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' ) NUsuario_ rz#Error al obtener nombre de usuario r.) r r rrrjoinsplitstriprrr5r)rKrrrr full_namer r!r!r"rdsf   &   &   rd)rgr$c CsJd}d}zz(t}|sPtd|WW|rLz |Wn Yn0dS||}|||f|}|rt|d}td|d||WdWW|rz |WSYS0Std|dWdWW|rz |Wn Yn0dSWdn1s*0YWnt j y}zJt d |d t |WYd}~W|rz |Wn Yn0dSd}~0t y}zJt d |d t |WYd}~W|rz |Wn Yn0dSd}~00W|rFz |Wn Yn0n"|rDz |Wn Yn00dS) u Consulta si un tipo de formulario debe crear tarea en Q_SpQ_QuotationTasks Args: quotation_type_id (str): ID del tipo de cotización Returns: bool: True si debe crear tarea, False si no z SELECT Q_QuotationType.CreateTask FROM Q_QuotationType WHERE Q_QuotationType.QuotationTypeID = ? AND Q_QuotationType.Active = 1 Nz1No se pudo conectar para verificar CreateTask de TrzQuotationType z - CreateTask: z no encontradoz)Error de BD al consultar CreateTask para r.z.Error inesperado al consultar CreateTask para )r rr5r rrrboolrr6r7rrr)rgrrrr create_taskr r!r!r"debe_crear_tareas~      (       rc Csd}d}znzt}|s>WW|r:z |Wn Yn0dS||}|||f|}|r|dWdWW|rz |WSYS0SWdWW|rz |Wn Yn0dSWdn1s0YWndtyT}zJtd|dt|WYd}~W|rHz |Wn Yn0dSd}~00W|rz |Wn Yn0n"|rz |Wn Yn00dS)z Obtiene el TaskID asociado a un FormID en Q_SpQ_QuotationTasks Args: form_id (str): ID del formulario Returns: Optional[int]: TaskID si existe, None si no z SELECT TOP 1 Q_SpQ_QuotationTasks.FormID FROM Q_SpQ_QuotationTasks WHERE Q_SpQ_QuotationTasks.taskID = ? Nrz$Error al obtener TaskID para FormID r.) r r rrrrrr5r)taskIDrrrrr r!r!r"get_FormID_by_TaskIDsd     &    r)tipo_formularior$c Cs(ddddddddd d d d }||dS) z Mapea el tipo de formulario al QuotationTypeID correspondiente Args: tipo_formulario (str): Tipo de formulario del frontend Returns: str: QuotationTypeID correspondiente FormGral FormSolicVisFormPTTransNac FormPTTransULFormAireFormSistCritUPSFormBess FormSolar FormEneCog FormImess FormProyecEsp) GeneralSolicVis PTTransNac PTTransULAire SistCritUPSBessSolarEnergyCogenerationImess ProyecEsp)rE)rZ mapeo_tiposr!r!r"obtener_quotation_type_id2s rc Csd}d}z~zt}|s>|WW|rs(   SjTmNcP87-/