o
    Rii                     @   s(   d dl Zd dlmZ dd Zdd ZdS )    N)MBTI_DB_CONFIGc              
   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 )uB   
    단순 대화 로그를 chat_MBTI_jp 테이블에 저장
    NJINSERT INTO chat_MBTI_jp (session_id, sender, message) VALUES (%s, %s, %s) )	mysql	connectorconnectr   cursorexecutecommit	Exceptionclose)
session_idsendermessageconnr   sqler   r   4/home/air/goalskill_t/back/app/models/mbti_module.pyinsert_chat_log   s"   
r   c           	   
   C   s   d}zMz-t jjdi t}|  | }d}||| d|f d}||| ||f |  W n tyD } z|r>|	  |d}~ww W |rN|
  dS dS |rW|
  w w )u   
    진단 완료 시 트랜잭션 처리:
    1. chat_MBTI_jp에 완료 메시지 저장
    2. mbti_results에 분석 결과 저장
    Nr   systemzLINSERT INTO mbti_results (session_id, mbti_type, scores) VALUES (%s, %s, %s)r   )r   r   r   r   start_transactionr   r	   r
   r   rollbackr   )	r   
system_msg	mbti_typescores_jsonr   r   sql_chat
sql_resultr   r   r   r   save_mbti_result_transaction   s,   
r   )mysql.connectorr   app.core.configr   r   r   r   r   r   r   <module>   s   