o լi @s>ddlZddlmZmZddZddZdedefd d ZdS) N) A_DB_CONFIGloggerc Csd}z8ztjjdit}|}d}|||||f|Wnty/}z|d}~wwW|r9|dSdS|rB|ww)NFINSERT INTO mbti_log (session_id, sender, message) VALUES (%s, %s, %s)) mysql connectorconnectrcursorexecutecommit Exceptionclose) session_idsendermessageconnr sqlerr4/home/air/goalskill_t/back/app/models/mbti_module.pyinsert_chat_logs"   rc Csd}zSz3tjjdit}||}d}|||d|fd}||||||f|t||Wnt yJ} z|rD| | d} ~ wwW|rT| dSdS|r]| ww)Nrsystema% INSERT INTO mbti_Output (session_id, result, scores, description) VALUES (%s, %s, %s, %s) ON DUPLICATE KEY UPDATE result = VALUES(result), scores = VALUES(scores), description = VALUES(description) r) rrrrstart_transactionr r r sync_to_user_profile_summaryr rollbackr ) r system_msg mbti_type scores_json descriptionrr sql_chat sql_resultrrrrsave_mbti_result_transactions.   r rrc Csd}zOz%tjjdit}|}d}||||f|td|Wnt yB}zt d|WYd}~nd}~wwW|rP| | dSdS|r]| | ww)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: zMBTI Summary Sync Error: r) rrrrr r r rinfor errorr )rrrr rrrrrr:s*   r) mysql.connectorrapp.core.configrrrr strrrrrrs $