
    NĨh                     t    U d dl Z dZdZdZdZdZdae j                  dz  ed<   d Z	d	 Z
d
 ZdedededefdZy)    Ncatia_app_devz^)Q=voA4[0N/h[8WN2z)vmas-dev-mysql03.mysql.database.azure.comi  data_catastro_logspoolc            
         K   t         9t        j                  t        t        t
        t        t        ddd       d{   a t         S 7 
w)z Inicializa el pool de conexionesN   
   T)hostportuserpassworddbminsizemaxsize
autocommit)r   aiomysqlcreate_poolDB_HOSTDB_PORTDB_USERDB_PASSDB_NAME     U/var/www/dev.catia.catastroantioquia-mas.com/valormasv2/config/async_db_connection.pyinit_dbr      sF      |))	
 	
 K	
s   ;A
AA
c                  J   K   t         t                d{    t         S 7 
w)z#Obtiene el pool (para usar acquire)N)r   r   r   r   r   get_connectionr      s       |iK 	s   #!#c                    K   t                d{   } | j                         4 d{   }|j                         4 d{   }|j                  d       d{    |j	                          d{   }t        d|d          ddd      d{    ddd      d{    y7 7 7 i7 R7 <7 # 1 d{  7  sw Y   /xY w7 &# 1 d{  7  sw Y   yxY ww)u'   Ejecuta SELECT 1 para validar conexiónNzSELECT 1u   ✅ Conexión exitosa:r   )r   acquirecursorexecutefetchoneprint)r   conncurvals       r   test_connectionr'   $   s     !!D||~ 4 4;;= 	4 	4C++j)))&C*CF3	4 	44 4 4 "4	4)&	4 	4 	4 	44 4 4 4s   C B(C B*C CB,CB4B.B43B04B4CB2CC "C	#C *C ,C.B40B42C4C	:B=;C	C	C CCCC id_asistentepregunta	respuestausuarioc           	        K   t                d{   }d}|j                         4 d{   }|j                         4 d{   }|j                  || |||f       d{    |j	                          d{    |j
                  cddd      d{    cddd      d{    S 7 7 7 l7 P7 :7  7 # 1 d{  7  sw Y   nxY wddd      d{  7   y# 1 d{  7  sw Y   yxY ww)a  
    Inserta una fila en data_catastro_logs.conversaciones
    - id: AUTO_INCREMENT (MySQL lo genera solo)
    - modelo: 'gpt-4-turbo'
    - llegada: 'WEB'
    - fecha_hora: NOW() (timestamp actual en MySQL)
    - input, output, telefono, hilo_conversacion: NULL
    Na  
    INSERT INTO data_catastro_logs.conversaciones
    (id_asistente, modelo, llegada, fecha_hora, pregunta, respuesta, input, output, usuario, telefono, hilo_conversacion)
    VALUES
    (%s, 'gpt-4-turbo', 'WEB', NOW(), %s, %s, NULL, NULL, %s, NULL, NULL);
    )r   r   r    r!   commit	lastrowid)r(   r)   r*   r+   r   queryr$   r%   s           r   insertar_conversacionr0   .   s       !!DE ||~ ! !;;= 	! 	!C++elHi%QRRR++-==	! 	! 	!! ! ! "!	!R	!!	! 	! 	!! ! ! ! !s   C7B-C7B/C7C"B1C"B;"B3#B;:B5;B;
C"B7C"C7'B9(C7/C71C"3B;5B;7C"9C7;C	CC		C"C7CC7"C4(C+)C40C7)r   r   r   r   r   r   r   Pool__annotations__r   r   r'   strr0   r   r   r   <module>r4      si     

5

 "hmmd ! 4!c !S !S ![^ !r   