o լi:@sdZddlZddlmZmZedZeZdD]Z dD]Z dD]Z dD]Z e e e d e e q#qqqd ed efd d Zd5d ededed efddZd ededededed ef ddZdedededededededededed efd d!Zd eded efd"d#Zd eded efd$d%Zded efd&d'Zd6ded(eded efd)d*Zded efd+d,Zded-ed efd.d/Zded-ed0ed efd1d2Zded edBfd3d4ZdS)7u% ============================================================================== Goalskill DB 모듈 - Goalskill_DB CRUD 레이어 ============================================================================== 48개 테이블({H|S}{A|B|C|D}_{T|P|R}{I|M})에 대한 동적 INSERT/SELECT 함수. N) get_db_configlogger Goalskill_DB)HSABCD)TPR)IM_ table_namereturncCs|tvS)uD테이블명이 48개 중 하나인지 검증 (SQL Injection 방지)) VALID_TABLES)rr9/home/air/goalskill_t/back/app/models/goalskill_module.py_validate_table_namesr session_id output_textc Cst|s td|d}z]zCtjjd it}|}d|d}|||||f||j }t d|d|d|d||WW|rQ| | SSt yj}z t d |d ||d}~ww|rv| | ww) u| Goalskill_DB 테이블에 text 데이터 저장. T/P/R 모든 타입에서 공통으로 사용. (A/C/D 파트) Args: table_name: 테이블명 (예: "HA_PI", "SA_TM") session_id: 유저 세션 ID output_text: 저장할 텍스트 status: 컨디션 점수 (1~10). None이면 NULL로 저장. Returns: 저장된 row의 id Invalid table name: N INSERT INTO `zE` (session_id, output, status, created_at) VALUES (%s, %s, %s, NOW())z[Goalskill DB] Saved to : session=, id= , status=zoalskill DB] Save Error (): rr ValueErrormysql connectorconnectGOALSKILL_DB_CONFIGcursorexecutecommit lastrowidrinfoclose Exceptionerror) rrrstatusconnr&sqlrow_iderrrsave_to_goalskill_table s2 "  r3text source_typer.c Cst|s td|d}zdzJtjjd it}|}d|d}||||||f||j }t d|d|d|d|d |d | |WW|rX| | SSt yq} z t d |d | | d} ~ ww|r}| | ww)uw B파트 전용: Goalskill_DB 테이블에 수치 데이터 저장. source_type(learning/mindset)과 Gemini status(1~10)를 저장. Args: table_name: 테이블명 (예: "HB_TM", "SB_PM") session_id: 유저 세션 ID source_type: "learning" 또는 "mindset" status: 1~10 Gemini 점수 Returns: 저장된 row의 id rNrzV` (session_id, output, source_type, status, created_at) VALUES (%s, %s, %s, %s, NOW())z[Goalskill DB] Saved score to rz, text=z , source=rrz![Goalskill DB] Save Score Error (rrr ) rrr4r5r.r/r&r0r1r2rrrsave_to_goalskill_table_scoreGsL   r6senderpart input_text h_scoring s_scoring t_scoring p_scoring r_scoring result_tablec  Csd} ziz@tjjdit} | } d} | | |||||||||| f | | j} t d| d| | WW| rC| | SSt yk}zt d|WYd}~W| re| | dSdSd}~ww| rw| | ww)u admin 테이블에 분류 점수 로그 저장. 어떤 기준으로 해당 테이블에 분류되었는지 확인할 수 있도록 각 카테고리별 키워드 점수를 기록합니다. Args: session_id: 유저 세션 ID sender: "I" (AI) 또는 "M" (User) part: "A" / "B" / "C" / "D" input_text: 원문 텍스트 h_scoring: H(큰 목표) 키워드 점수 s_scoring: S(작은 목표) 키워드 점수 t_scoring: T(대화) 최종 점수 p_scoring: P(조언) 최종 점수 r_scoring: R(방향성) 최종 점수 result_table: 최종 분류된 테이블명 Returns: 저장된 row의 id NzINSERT INTO `admin` (session_id, sender, part, input_text, H_scoring, S_scoring, T_scoring, P_scoring, R_scoring, result_table, created_at) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, NOW())z&[Goalskill DB] Admin log saved: table=rz%[Goalskill DB] Admin Log Save Error: rr) r"r#r$r%r&r'r(r)rr*r+r,r-)rr7r8r9r:r;r<r=r>r?r/r&r0r1r2rrrsave_admin_logxsB     r@c Cst|s td|d}z[z/tjjd it}|jdd}d|d}|||f|}|WW|r=| | SSt yh}zt d|d|gWYd}~W|rc| | SSd}~ww|rt| | ww) u 특정 세션의 모든 데이터를 조회. Args: table_name: 테이블명 (예: "HA_PI") session_id: 유저 세션 ID Returns: [{"id": 1, "session_id": "...", "output": "...", "created_at": "..."}] rNT dictionarySELECT * FROM `/` WHERE session_id = %s ORDER BY created_at ASCz[Goalskill DB] Get Error (rr) rr!r"r#r$r%r&r'fetchallr+r,rr-)rrr/r&r0resultsr2rrrget_from_goalskill_tables6      rGc Cst|s td|d}z]z1tjjd it}|jdd}d|d}|||f|}|p2iWW|r?| | SSt yj}zt d|d|iWYd}~W|re| | SSd}~ww|rv| | ww) u8 특정 세션의 최신 데이터 1건 조회. rNTrArCz8` WHERE session_id = %s ORDER BY created_at DESC LIMIT 1z![Goalskill DB] Get Latest Error (rr) rr!r"r#r$r%r&r'fetchoner+r,rr-)rrr/r&r0resultr2rrrget_latest_from_goalskill_tables6      rJc Csi}d}zezsv ' 1   E"$1'!