o i!@sddlZddlmZmZmZddlmZmZedZ d!de de de dee fd d Z de d e d e d e de de de fddZde d e de de fddZde de fddZde de deefddZde deefddZde deefddZde fdd ZdS)"N)ListDictOptional) get_db_configlogger Sales_A_DB session_id question_idselected_option is_correctc Csd}zDz-tjjdit}|}d}||||||f||jWW|r0||SSt yF}z t d||d}~ww|rR||ww)u SPI 답변 저장 (spi_log 테이블) Args: session_id: 세션 ID question_id: 문제 ID selected_option: 선택한 답변 is_correct: 정답 여부 (능력검사만, 성격검사는 None) Nz INSERT INTO spi_log (session_id, question_id, selected_option, is_correct) VALUES (%s, %s, %s, %s) zSPI Answer Save Error: ) mysql connectorconnect A_DB_CONFIGcursorexecutecommit lastrowidclose Exceptionrerror)rr r r connrsqler r 7/home/air/goalskill_sales/back/app/models/spi_module.py save_answer s*   rlanguage_scorelanguage_gradenonverbal_scorenonverbal_gradepersonality_scorepersonality_typec Csd}zWz1tjjdit}|}d} || |||||||f|td|t ||||Wnt yJ} z t d| | d} ~ wwW|rX| | dSdS|re| | ww)u personality_score: 性格特性の個別スコアJSON文字列 personality_type: AI コメント（日本語テキスト） Nar INSERT INTO spi_Output (session_id, language_score, language_grade, nonverbal_score, nonverbal_grade, personality_score, personality_type) VALUES (%s, %s, %s, %s, %s, %s, %s) ON DUPLICATE KEY UPDATE language_score = VALUES(language_score), language_grade = VALUES(language_grade), nonverbal_score = VALUES(nonverbal_score), nonverbal_grade = VALUES(nonverbal_grade), personality_score = VALUES(personality_score), personality_type = VALUES(personality_type) zSPI Output saved for session: zSPI Output Save Error: r ) r rrrrrrrinfosync_to_user_profile_summaryrrr) rrrrr r!r"rrrrr r rsave_or_update_output1s<    r%c Csd}zQz'tjjdit}|}d}||||||f|td|Wnt yD}zt d|WYd}~nd}~wwW|rR| | dSdS|r_| | ww)u=SPI 완료 시 user_profile_summary 테이블에도 동기화Na INSERT INTO user_profile_summary (session_id, spi_language, spi_nonverbal, spi_personality) VALUES (%s, %s, %s, %s) ON DUPLICATE KEY UPDATE spi_language = VALUES(spi_language), spi_nonverbal = VALUES(spi_nonverbal), spi_personality = VALUES(spi_personality), updated_at = NOW() z0SPI synced to user_profile_summary for session: zSPI Summary Sync Error: r r rrrrrrrr#rrr)rrr r"rrrrr r rr$es*    r$returnc Csd}zXz/tjjdit}|}d}|||f|}|r$|dndWW|r2||SStyZ}zt d|WYd}~W|rT||dSdSd}~ww|rf||ww)u"현재 답변한 문제 수 조회Nz2SELECT COUNT(*) FROM spi_log WHERE session_id = %srzSPI Answer Count Error: r r rrrrrfetchonerrrrrrrrresultrr r rget_answer_counts2    r, question_typec Csd}zzWtjjd it}|jdd}|dkrd\}}n!|dkr%d\}}n|dkr.d \}}ngWW|r<||SSd }|||||f|}|WW|rZ||SSty}zt d |gWYd}~W|r}||SSd}~ww|r||ww) u 타입별 답변 조회 Args: session_id: 세션 ID question_type: 'language' (1-5), 'nonverbal' (6-10), 'personality' (11-20) Returns: 답변 리스트 NT dictionarylanguage) nonverbal) personality) z SELECT question_id, selected_option, is_correct FROM spi_log WHERE session_id = %s AND question_id BETWEEN %s AND %s ORDER BY question_id zSPI Answers by Type Error: r ) r rrrrrrfetchallrrr) rr-rrmin_idmax_idrresultsrr r rget_answers_by_typesH         r=c Csd}zTz+tjjdit}|jdd}d}|||f|}|WW|r.||SStyV}zt d|gWYd}~W|rQ||SSd}~ww|rb||ww)u전체 답변 조회NTr.z SELECT question_id, selected_option, is_correct FROM spi_log WHERE session_id = %s ORDER BY question_id zSPI All Answers Error: r ) r rrrrrr9rrrr)rrrrr<rr r rget_all_answerss2    r>c Csd}zTz+tjjdit}|jdd}d}|||f|}|WW|r.||SStyV}zt d|WYd}~W|rP||dSdSd}~ww|rb||ww)uSPI 최종 결과 조회NTr.z.SELECT * FROM spi_Output WHERE session_id = %szSPI Output Get Error: r r(r*r r r get_outputs2     r?c Csd}zNz$tjjdit}|}d}|||f|td|Wnt yA}zt d|WYd}~nd}~wwW|rO| | dSdS|r\| | ww)uE 테스트 시작 시 이전 기록 초기화 (재시작용) Nz)DELETE FROM spi_log WHERE session_id = %szSPI Session Cleared: zSPI Session Clear Error: r r&)rrrrrr r rclear_session_logss(  r@)N)mysql.connectorr typingrrrapp.core.configrrrstrintboolrr%r$r,r=r>r?r@r r r rs0 & 4 $/