UiHdZddlZddlmZmZedZeZdD]/Z dD]*Z dD]%Z dD] Z e e e d e e !&+0d ed efd Zd-d ed eded efdZd ed edededed ef dZd edededededededededed efdZd ed ed efdZd ed ed efdZd ed efd Zd.d ed!eded efd"Zd ed efd#Zd ed$ed efd%Zd ed$ed&ed efd'Zd ed edzfd(Zd.d ed$ed)ed*ed ef d+Z d ed efd,Z!dS)/u% ============================================================================== 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_namereturnc|tvS)uD테이블명이 48개 중 하나인지 검증 (SQL Injection 방지)) VALID_TABLES)rs #/app/app/models/goalskill_module.py_validate_table_namers  %% session_id output_textc rt|std|d} tjjd it }|}d|d}|||||f||j }tj d|d|d|d|||r)| | SS#t$r!}tjd |d ||d}~wwxYw#|r)| | wwxYw) 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 (): r ValueErrormysql connectorconnectGOALSKILL_DB_CONFIGcursorexecutecommit lastrowidrinfoclose Exceptionerror) rrrstatusconnr*sqlrow_ides rsave_to_goalskill_tabler7 sr + +>< <<=== D&==)<==ojooosZf=>>> ! ozooZooV\oogmooppp   LLNNN JJLLLL   E:EE!EEFFF   LLNNN JJLLLL s$B C D%DDD -D6text source_typer2ct|std|d} tjjd it }|}d|d}||||||f||j }tj d|d|d|d|d |d | ||r)| | SS#t$r!} tjd |d | | d} ~ wwxYw#|r)| | wwxYw)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=r!r z![Goalskill DB] Save Score Error (r"r#r$) rrr8r9r2r3r*r4r5r6s rsave_to_goalskill_table_scorer;Gs + +>< <<=== D&==)<== .J . . . sZ{FCDDD !  eZ e e! e e*. e e9D e eOU e e\b e e      LLNNN JJLLLL   KKKKKLLL   LLNNN JJLLLL s$BC"" D ,DD  D-D=senderpart input_text h_scoring s_scoring t_scoring p_scoring r_scoring result_tablec d} tjjdit} | } d} | | |||||||||| f | | j} tj d| d| | | r)| | SS#t$rN}tj d|Yd}~| r*| | dSdSd}~wwxYw#| r)| | wwxYw)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=r z%[Goalskill DB] Admin Log Save Error: rr#) r&r'r(r)r*r+r,r-rr.r/r0r1)rr<r=r>r?r@rArBrCrDr3r*r4r5r6s rsave_admin_logrFxs@ D&==)<== E s j y y)      ! X\XXPVXXYYY   LLNNN JJLLLL   @Q@@AAAqqq   LLNNN JJLLLLL      LLNNN JJLLLL s*BB77 DD D DD-D?ct|std|d} tjjd it }|d}d|d}|||f|}||r)| | SS#t$rQ}tj d|d|gcYd}~|r)| | SSd}~wwxYw#|r)| | wwxYw) 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 (r"r#) rr%r&r'r(r)r*r+fetchallr/r0rr1)rrr3r*r4resultsr6s rget_from_goalskill_tablerNsk + +>< <<=== D&==)<==--[ [[[sZM***//##   LLNNN JJLLLL   D*DDDDEEE   LLNNN JJLLLL     LLNNN JJLLLL s0A#B44 D>D DD DD-D?ct|std|d} tjjd it }|d}d|d}|||f|}|pi |r)| | SS#t$rQ}tj d|d|icYd}~|r)| | SSd}~wwxYw#|r)| | wwxYw) u8 특정 세션의 최신 데이터 1건 조회. rNTrHrJz8` WHERE session_id = %s ORDER BY created_at DESC LIMIT 1z![Goalskill DB] Get Latest Error (r"r#) rr%r&r'r(r)r*r+fetchoner/r0rr1)rrr3r*r4resultr6s rget_latest_from_goalskill_tablerRsr + +>< <<=== D&==)<==--d dddsZM***""|   LLNNN JJLLLL   KKKKKLLL   LLNNN JJLLLL     LLNNN JJLLLL s0A%B77 DD DD DD-Ec|i}d} tjjdit}|d}t t D]:}d|d}|||f|}|r|||<;||r)| | SS#t$rN}tj d|icYd}~|r)| | SSd}~wwxYw#|r)| | wwxYw)u 유저의 모든 Goalskill_DB 데이터를 48개 테이블에서 수집. Returns: { "HA_PI": [{"id": 1, "output": "..."}], "HA_TI": [{"id": 2, "output": 1}], ... } NTrHrJrKz[Goalskill DB] Get All Error: r#) r&r'r(r)r*sortedrr+rLr/r0rr1)rrQr3r*rr4rowsr6s rget_all_goalskill_datarVskF D&==)<==-- .. * *J_J___C NN3 . . .??$$D *%)z"   LLNNN JJLLLL   9a99:::   LLNNN JJLLLL     LLNNN JJLLLL s0BB33 D =DD DD  D-D; goal_scopecd}d} tjjd it}|}|r|gnddg}|r|gngd}ddg}|D]S} |D]N} |D]I} | | d| } d | d } || |f|}|r ||dz }JOT||r)||SS#t$rN}tj d |Yd}~|r*||dSdSd}~wwxYw#|r)||wwxYw) u 특정 세션의 대화 횟수 합계를 조회. Args: session_id: 세션 ID goal_scope: "H" 또는 "S" (None이면 모두) part: "A"~"D" (None이면 모두) Returns: 대화 횟수 합계 Nrrrrrr_TzSELECT COUNT(*) FROM `z` WHERE session_id = %sz![Goalskill DB] Talk Count Error: r# r&r'r(r)r*r+rPr/r0rr1)rrWr=r3totalr*scopespartssendersspr<rr4rowr6s rget_talk_countrb"s D E&==)<==",;*#s8$8$8$8* ( (A ( (%((F$%!4q!4!4F!4!4JV:VVVCNN3 666 //++C(Q ( (   LLNNN JJLLLL   <<<===qqq   LLNNN JJLLLLL      LLNNN JJLLLL s*BC D&D!/D)!D&&D))-EcVd} tjjdit}|}d}|||f|}|r|d|dnd |r)||SS#t$rN}tj d|Yd}~|r*||dSdSd}~wwxYw#|r)||wwxYw)um result テーブルから現在の最大daily番号を取得。 行がなければ0を返す。 Nz5SELECT MAX(daily) FROM `result` WHERE session_id = %srz%[Result DB] Get Current Daily Error: r#rZ)rr3r*r4rar6s rget_current_dailyrdSsG D &==)<==EsZM***oo:Q!3s1vv:   LLNNN JJLLLL   @Q@@AAAqqq   LLNNN JJLLLLL      LLNNN JJLLLL s*A/B C8*C3C;3C88C;;-D(dailyc (d} tjjd it}|}d}||||f|}|rVtjd|d|d|d|d|r)| | SSd}|||d|f| |j }tjd |d|d|||r)| | SS#t$r}tj d ||d}~wwxYw#|r)| | wwxYw) u result テーブルに新しい行を作成（カリキュラム日次の開始）。 既に同じdailyの行がある場合は作成しない。 Returns: 作成された行のid。既に存在する場合は既存行のid。 Nz