U iw@s<ddlZddlZddlmZddlmZmZmZmZedZ ddl m Z m Z ddl mZddZeeed d d Zeeed d d ZeeeedddZeeeedddZeeeedddZeeeeedddZeedddZeedddZd d!Zeed"d#d$Zeedd%d&Zeeed'd(d)Z dS)*N)datetime)DictListOptionalUnionZcotizaciones_especiales_sql) Productivo ENVIRONMENT)get_connectionc Cs0d}d|||ddf}d}d}zzht}|s4WWdS|}||||}||r~|d}td||WWnSWWfdStk r} z@t dt | |rz | Wn YnXWYWdSd} ~ XYnXW5|r z |Wn YnX|r*z |Wn YnXXdS)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) ZSYSTEMNru-✅ CRM Contact insertado: OpportunityNumber=u$❌ Error al insertar contacto CRM: ) closer cursorexecutefetchonecommitloggerinfo Exceptionerrorstrrollback) contactName contactNumber contactEmailqueryparamsconnr rowopportunity_numberernC:\Users\victor.barrera\Documents\proyectos\elepV3\Elep\src\Consultas_SQL\Ventas\Cotiz\CotizEspSolicitudSQL.pyinsert_CRM_CONTACTsR          r!)rreturnc Cstd|d}td|td|d}zzt}|sJtd||}|||fdd|jD}|}|rtt ||}t d|d d |kr|d r|d  |d <|W5QRWWSt d|d W5QRWWdSW5QRXWntjk rX}z*d |d t|}t |t|W5d}~XYntk r}z*d|d t|}t |t|W5d}~XYnJtk r}z*d|d t|}t |t|W5d}~XYnXW5|rz |Wn YnXXdS)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.0columnrrr sz*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 r ConnectionErrorr r descriptionrdictziprr isoformatwarningpyodbcErrorrrr) rrrr columnsrresultr error_msgrrr buscar_oportunidad_crmfsN"    r8c Cs&d}d}zz2t}|s"td||}|||fdd|jD}|}|rtt||}| dd }|dkrt d |d |d t d ||d krt d |d |dt d|t d |d|dd||W5QRWWSt d |dW5QRWWdSW5QRXWnt k rh}z|W5d}~XYntjk r}z*d|dt|} t | t| W5d}~XYnJtk r}z*d|dt|} t | t| W5d}~XYnXW5|r z |Wn YnXXdS)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$rr%rrr r(sz3verificar_oportunidad_existente..Status)ZVENDIDOZVENDIDAZATENDIDOr)z tiene status z - proceso terminadozOPPORTUNITY_CLOSED:) PENDIENTEz EN DESARROLLOz EN APROBACIONZ EN_DESARROLLOZ 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 r r-r r r.rr/r0getupperrr2 ValueErrorrr3r4rrr) rrrr r5rr6statusrr7rrr verificar_oportunidad_existentesN  "   rA)datos_oportunidaduser_idversionr"c Cst|}d}d}zƐzt}|s*td||}|||dd|||dd|dd|dd|d d|d d|d d|d d|d d|dd|dd|dd|dd|ddd||f||dd|}t d|dd|dW5QRWWSQRXWnt j k r}z4dt |} t | ddddddWYWfSd}~XYnTtk r}z4d t |} t | dd!d"dddWYWSd}~XYnXW5|rz |Wn YnXXdS)#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_ContactEmailr;-r)z creada exitosamenteT)successopportunity_idz-Error de base de datos al crear oportunidad: Fz,Error al guardar los datos de la oportunidadDATABASE_ERRORri)rTmessagecode alert_type status_codez'Error inesperado al crear oportunidad: z(Error interno al procesar la oportunidadINTERNAL_ERROR)obtener_nombre_usuarior r r-r r r=rrrr3r4rrr) rBrCrD user_namerrr rUrr7rrr crear_actualizar_oportunidad$sv              "  $  r^)rUquotation_type_idrCr"c Csft|}d}d}z,zt}|s(td|d|}|||||||f||d|}td|dd|dW5QRWWSQRXWnt j k r}z2d t |} t | d d d d dWYWdSd}~XYnRt k r:}z2dt |} t | d ddd dWYWSd}~XYnXW5|r`z |Wn YnXXdS)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#rSz FormHead z creado exitosamenteT)rTform_idz*Error de base de datos al crear FormHead: Fz%Error al crear registro de formulariorVrrTrWrXrYz$Error inesperado al crear FormHead: z!Error interno al crear formularior[)r\r r r-r r rrrr3r4rrr) rUr_rCr]rrr r`rr7rrr crear_formulario_headsV  "  $ rb)r` preguntasr"c Cstd|tdt|t|D] \}}td|dd|q(d}d}zz>t}|sltdd }||}t|dd D]\}}t|d } td |d td|td| td|dtd|dtd|dtd|d| | ||| |d|d|df|d7}td|dq| t d|d|d|dW5QRWWSQRXWnt jk r} z@dt| } t | td| d d!d"d#d$WYWrSd} ~ XYn`tk rV} z@d%t| } t | td&| d d'd(d#d$WYWSd} ~ XYnXW5|r|z |Wn YnXXdS))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: rSu✅ DEBUG - Registro z insertado exitosamentezCreados z detalles para FormID T)rTZrecords_createdz-Error de base de datos al crear FormDetails: u❌ DEBUG - Error SQL: Fz(Error al guardar detalles del formulariorVrraz'Error inesperado al crear FormDetails: u❌ DEBUG - Error general: z!Error interno al guardar detallesr[)r,len enumerater r r-r rzfillr rrrr3r4rr) r`rcirgrrZregistros_creadosr indexZ form_linerr7rrr crear_formulario_detailssv  "  $ rn)seller_user_idr`rUr]r"c Csjd}d}z8zt}|s td|p|}||||d||f|d|d}|td|d|d |d W5QRWWSQRXWnt j k r}z2d t |} t | d d dddWYWdSd}~XYnRt k r>}z2dt |} t | d ddddWYWSd}~XYnXW5|rdz |Wn YnXXdS)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)rTtask_idz'Error de base de datos al crear tarea: Fu#Error al crear tarea de cotizaciónrVrraz!Error inesperado al crear tarea: zError interno al crear tarear[)r r r-r r rrrrr3r4rrr) ror`rUr]rrr rprr7rrr crear_tarea_cotizacionAsV   "  $ rq)rCr"c Cs.d}d}zzt}|s(d|WWS|~|}|||f|}|rd|d}|rn|nd|W5QRWWSd|W5QRWWdSW5QRXWnPtk r}z0t d|dt |d|WYWSd}~XYnXW5|r(z |Wn YnXXdS)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 r+) r r r r rjoinsplitstriprrr2r)rCrrr r full_namerrrr r\s, (*( r\)r_r"c Csd}d}zPzt}|s4td|WW,dS||}|||f|}|rt|d}td|d||W5QRWWStd|dW5QRWWdSW5QRXWnt j k r}z(t d |d t |WYW\dSd}~XYnHt k rV}z(t d |d t |WYWdSd}~XYnXW5|r|z |Wn YnXXdS) 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 r rr2r r rboolrr3r4rrr)r_rrr r create_taskrrrr debe_crear_tareas8   "  ryc Csd}d}zzxt}|s WWdS|V|}|||f|}|rb|dW5QRWWnSW5QRWW\dSW5QRXWnFtk r}z(td|dt|WYWdSd}~XYnXW5|rz |Wn YnXXdS)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 r r rrrr2r)taskIDrrr rrrrr get_FormID_by_TaskIDs*  "  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)r=)r|Z mapeo_tiposrrr obtener_quotation_type_id-s rc Csd}d}zzt}|s |WWS|d|}|||f|}|rn|drnt|dW5QRWWrS|W5QRWW\SW5QRXWnHtk r}z*td|dt ||WYWSd}~XYnXW5|rz |Wn YnXXdS)a Obtiene el SellerUserID desde la tabla Profiles Para vendedores directos, retorna el mismo user_id Para distribuidores, retorna el SellerUserID asignado Args: user_id (int): ID del usuario actual Returns: int: ID del vendedor asignado z SELECT COALESCE(Profiles.SellerUserID, Profiles.UserID) AS SellerID FROM Profiles WHERE Profiles.UserID = ? Nrz+Error al obtener SellerUserID para usuario r+) r r r r rintrrr2r)rCrrr rrrrr obtener_seller_user_idHs*   $" r)r`docs_idr"c Csd}d}zXzt}|s td||}||||f|j}||dkrtd|d|ddiW5QRWWSt d |d d d d W5QRWWSW5QRXWnt j k r}z0dt |}t |d dddWYWbSd}~XYnPtk r^}z0dt |}t |d dddWYWSd}~XYnXW5|rz |Wn YnXXdS)u Actualiza el formulario con el DocsID generado Args: form_id (str): ID del formulario docs_id (int): ID del grupo de documentos Returns: dict: Resultado de la operación zp UPDATE Q_SpQ_FormsHead SET DocsID = ? WHERE FormID = ? AND Active = 1 Nr#rz Formulario z actualizado con DocsID rTTuNo se encontró formulario z para actualizarFz(Formulario no encontrado para actualizar)rTrWz1Error de base de datos al actualizar formulario: z-Error al actualizar formulario con documentosrV)rTrWrXz+Error inesperado al actualizar formulario: z&Error interno al actualizar formularior[)r r r-r r rowcountrrrr2r3r4rrr)r`rrrr Z rows_affectedrr7rrr actualizar_formulario_con_docswsJ &  $ r)!r3loggingrtypingrrrr getLoggerrconfigrrConsultas_SQL.conexionr r!floatr8rrArr^rbrnrqr\rwryr{rrr/rrrrr s&   SjTmMcP87-/