o
    S€iâ
  ã                   @   s>   d dl Zd dlmZmZ dd„ Zdd„ Zdedefd	d
„ZdS )é    N)ÚA_DB_CONFIGÚloggerc              
   C   s†   d }z8zt jjdi t¤Ž}| ¡ }d}| || ||f¡ | ¡  W n ty/ } z|‚d }~ww W |r9| ¡  d S d S |rB| ¡  w w )NúFINSERT INTO mbti_log (session_id, sender, message) VALUES (%s, %s, %s)© )	ÚmysqlÚ	connectorÚconnectr   ÚcursorÚexecuteÚcommitÚ	ExceptionÚclose)Ú
session_idÚsenderÚmessageÚconnr	   ÚsqlÚer   r   ú8/home/air/goalskill_sales/back/app/models/mbti_module.pyÚinsert_chat_log   s"   €ÿÿÿ
ÿr   c           	   
   C   sº   d }zRz2t jjdi t¤Ž}| ¡  | ¡ }d}| || d|f¡ d}| || ||f¡ | ¡  t| |ƒ W n t	yI } z|rC| 
¡  |‚d }~ww W |rS| ¡  d S d S |r\| ¡  w w )Nr   Úsystemzá
            INSERT INTO mbti_Output (session_id, result, scores) 
            VALUES (%s, %s, %s)
            ON DUPLICATE KEY UPDATE 
                result = VALUES(result),
                scores = VALUES(scores)
        r   )r   r   r   r   Ústart_transactionr	   r
   r   Úsync_to_user_profile_summaryr   Úrollbackr   )	r   Ú
system_msgÚ	mbti_typeÚscores_jsonr   r	   Úsql_chatÚ
sql_resultr   r   r   r   Úsave_mbti_result_transaction   s.   €ýþÿ
ÿr   r   r   c              
   C   s¼   d}zOz%t jjdi t¤Ž}| ¡ }d}| || |f¡ | ¡  t d| › ¡ W n t	yB } zt 
d|› ¡ W Y d}~nd}~ww W |rP| ¡  | ¡  dS dS |r]| ¡  | ¡  w w )u>   MBTI ì™„ë£Œ ì‹œ user_profile_summary í…Œì´ë¸”ì—ë„ ë™ê¸°í™”NzÝ
            INSERT INTO user_profile_summary
            (session_id, mbti)
            VALUES (%s, %s)
            ON DUPLICATE KEY UPDATE
                mbti = VALUES(mbti),
                updated_at = NOW()
        z1MBTI synced to user_profile_summary for session: zMBTI Summary Sync Error: r   )r   r   r   r   r	   r
   r   r   Úinfor   Úerrorr   )r   r   r   r	   r   r   r   r   r   r   9   s*   €ý€þ
þr   )	Úmysql.connectorr   Úapp.core.configr   r   r   r   Ústrr   r   r   r   r   Ú<module>   s
   #