o
    }i                     @   s   d dl Zd dlmZmZ d dlZd dlmZmZm	Z	 de
dede
fddZde
d	ed
e
fddZde
fddZde
dede
fddZde
de
fddZde
fddZde
de
fddZdS )    N)A_DB_CONFIGlogger)ListDictOptional
session_id
step_orderquestion_textc              
   C      d}zCz,t jjdi t}| }d}||| ||f |  |jW W |r/|  |  S S  t	yE } z
t
d|  |d}~ww |rQ|  |  w w )u!   질문 저장 (user_id 제거됨)Nz
            INSERT INTO findgoal_Q 
            (session_id, step_order, question_text)
            VALUES (%s, %s, %s)
        zFindGoal Q Save Error:  mysql	connectorconnectr   cursorexecutecommit	lastrowidclose	Exceptionr   error)r   r   r	   connr   sqler   r   </home/air/goalskill_sales/back/app/models/findgoal_module.pysave_question
   s*   

r   question_idanswer_textc              
   C   r
   )u+   Answer Save (user_id, step_order 제거됨)Nz
            INSERT INTO findgoal_A 
            (session_id, question_id, answer_text)
            VALUES (%s, %s, %s)
        zFindGoal A Save Error: r   r   )r   r   r   r   r   r   r   r   r   r   save_answer)   s*   

r   c              
   C   s   d}zTz+t jjdi t}|jdd}d}||| f | }|W W |r.|  |  S S  tyV } zt	
d|  W Y d}~W |rP|  |  dS dS d}~ww |rb|  |  w w )zGet the last questionNT
dictionaryz
            SELECT id, step_order, question_text
            FROM findgoal_Q
            WHERE session_id = %s
            ORDER BY step_order DESC
            LIMIT 1
        zFindGoal Q Load Error: r   )r   r   r   r   r   r   fetchoner   r   r   r   )r   r   r   r   resultr   r   r   r   get_last_questionA   s2   

r#   confidence_score	reasoningc              
   C   r
   )uS   Save the AI processing result (P) - user_id, step_order, answer_id 모두 제거됨Nz
            INSERT INTO findgoal_P
            (session_id, confidence_score, reasoning)
            VALUES (%s, %s, %s)
        zFindGoal P Save Error: r   r   )r   r$   r%   r   r   r   r   r   r   r   save_processing^   s0   

r&   
final_goalc              
   C   s   d}zCzt jjdi t}| }d}||| |f |  W n ty6 } z
t	d|  |d}~ww W |rD|
  |
  dS dS |rQ|
  |
  w w )uH   Save or update the final result (Output) - user_id, updated_at 제거됨Nz
            INSERT INTO findgoal_Output
            (session_id, final_goal)
            VALUES (%s, %s)
            ON DUPLICATE KEY UPDATE
                final_goal = VALUES(final_goal)
        zFindGoal Output Save Error: r   )r   r   r   r   r   r   r   r   r   r   r   r   r'   r   r   r   r   r   r   r   save_or_update_output{   s(   
r)   c              
   C   s   d}zTz+t jjdi t}|jdd}d}||| f | }|W W |r.|  |  S S  tyV } zt	
d|  g W  Y d}~W |rQ|  |  S S d}~ww |rb|  |  w w )z2Get the entire conversation history of the sessionNTr   a.  
            SELECT 
                Q.step_order,
                Q.question_text,
                A.answer_text
            FROM findgoal_Q Q
            LEFT JOIN findgoal_A A 
                ON Q.id = A.question_id
            WHERE Q.session_id = %s
            ORDER BY Q.step_order ASC
        zFindGoal History Load Error: r   )r   r   r   r   r   r   fetchallr   r   r   r   )r   r   r   r   resultsr   r   r   r   get_conversation_history   s2   


r,   c              
   C   s   d}zKz%t jjdi t}| }d}||| |f |  td|   W n t	y> } z
t
d|  |d}~ww W |rL|  |  dS dS |rY|  |  w w )uB   FindGoal 완료 시 user_profile_summary 테이블에도 동기화Nz
            INSERT INTO user_profile_summary
            (session_id, final_goal)
            VALUES (%s, %s)
            ON DUPLICATE KEY UPDATE
                final_goal = VALUES(final_goal),
                updated_at = NOW()
        z5FindGoal synced to user_profile_summary for session: zFindGoal Summary Sync Error: r   )r   r   r   r   r   r   r   r   infor   r   r   r(   r   r   r   sync_to_user_profile_summary   s*   
r.   )mysql.connectorr   app.core.configr   r   jsontypingr   r   r   strintr   r   r#   floatr&   r)   r,   r.   r   r   r   r   <module>   s    