UiddlZddlmZmZddlZddlmZmZm Z de de de fdZ de de d e fd Z de fd Zde d ed e fdZde de fdZde fdZde de fdZde fdZde fdZdS)N) A_DB_CONFIGlogger)ListDictOptional session_id step_order question_textcd} tjjdit}|}d}|||||f||j|r)||SS#t$r}tj d||d}~wwxYw#|r)||wwxYw)u!질문 저장 (user_id 제거됨)Nz INSERT INTO findgoal_Q (session_id, step_order, question_text) VALUES (%s, %s, %s) zFindGoal Q Save Error: mysql connectorconnectrcursorexecutecommit lastrowidclose Exceptionrerror)rr r connrsqles "/app/app/models/findgoal_module.py save_questionr s D&5555  sZ]CDDD    LLNNN JJLLLL   2q22333   LLNNN JJLLLL $A$B B<B77B<<B??-C, question_id answer_textcd} tjjdit}|}d}|||||f||j|r)||SS#t$r}tj d||d}~wwxYw#|r)||wwxYw)u+Answer Save (user_id, step_order 제거됨)Nz INSERT INTO findgoal_A (session_id, question_id, answer_text) VALUES (%s, %s, %s) zFindGoal A Save Error: r r )rrrrrrrs r save_answerr!)s D&5555  sZkBCCC    LLNNN JJLLLL   2q22333   LLNNN JJLLLL rc4d} tjjdit}|d}d}|||f|}||r)||SS#t$rN}tj d|Yd}~|r*||dSdSd}~wwxYw#|r)||wwxYw)zGet the last questionNT dictionaryz SELECT id, step_order, question_text FROM findgoal_Q WHERE session_id = %s ORDER BY step_order DESC LIMIT 1 zFindGoal Q Load Error: r rrrrrrfetchonerrrrrrrrresultrs rget_last_questionr)As5 D&5555--  sZM***""   LLNNN JJLLLL   2q22333ttt   LLNNN JJLLLLL      LLNNN JJLLLL s*AB C'C"0C*"C''C**-Dconfidence_score reasoningcd} tjjdit}|}d}|||||f||j|r)||SS#t$r}tj d||d}~wwxYw#|r)||wwxYw)uSSave 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) zFindGoal P Save Error: r r )rr*r+rrrrs rsave_processingr-^s  D&5555  s  i        LLNNN JJLLLL   2q22333   LLNNN JJLLLL r final_goalcd} tjjdit}|}d}||||f|n+#t$r}tj d||d}~wwxYw |r*| | dSdS#|r)| | wwxYw)uHSave 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) zFindGoal Output Save Error: r rrrrrrrrrrrrr.rrrrs rsave_or_update_outputr2{s D&5555  sZ4555  7A77888    LLNNN JJLLLLL  4  LLNNN JJLLLL s*AA"!B<" B ,BB  B<<-C)c4d} tjjdit}|d}d}|||f|}||r)||SS#t$rN}tj d|gcYd}~|r)||SSd}~wwxYw#|r)||wwxYw)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 zFindGoal History Load Error: r ) rrrrrrfetchallrrrr)rrrrresultsrs rget_conversation_historyr6s2 D&5555--   sZM***//##   LLNNN JJLLLL   8Q88999   LLNNN JJLLLL     LLNNN JJLLLL s0AB C'C"1C'2C*"C''C**-Dcd} tjjdit}|}d}||||f|tjd|n+#t$r}tj d||d}~wwxYw |r*| | dSdS#|r)| | wwxYw)uBFindGoal 완료 시 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: zFindGoal Summary Sync Error: r ) rrrrrrrrinforrrr1s rsync_to_user_profile_summaryr9s D&5555  sZ4555  XJXXYYYY  8Q88999 Z   LLNNN JJLLLLL  4  LLNNN JJLLLL s*A4A98C9 B!BB!!C-DcJd} tjjdit}|d}d}|||f|}|r|dnd |r)||SS#t$rN}tj d|Yd}~|r*||dSdSd}~wwxYw#|r)||wwxYw)u0findgoal_Output에서 최종 목표를 가져옴NTr#z