o
    DГi
                     @   sh   d dl mZmZ d dlZedZdededB dedB dedB dedB f
d	d
ZdededB fddZ	dS )    )get_db_configloggerN
Sales_A_DB
session_ideligibilityskills_and_experiencewelcome_personalitykey_informationc              
   C   s   z^t jjdi t}| }|pd|pd|pd|pd| f}d}||| |jdkrHd}	||	| |p3d|p6d|p9d|p<df td|   ntd|   |	  |
  |
  W dS  tys }
 z	td|
   d}
~
ww )	u   
    같은 session_id면 기존 행 업데이트, 없으면 INSERT.
    eligibility: 応募条件, skills_and_experience: 活かせる経験と能力,
    welcome_personality: 歓迎する人物像, key_information: 重要事項
    Nz
            UPDATE company_info
            SET eligibility = %s, skills_and_experience = %s, welcome_personality = %s, key_information = %s, updated_at = NOW()
            WHERE session_id = %s
        r   z
                INSERT INTO company_info
                (session_id, eligibility, skills_and_experience, welcome_personality, key_information)
                VALUES (%s, %s, %s, %s, %s)
            z#Company info inserted for session: z"Company info updated for session: zCompany info save error:  )mysql	connectorconnectA_DB_CONFIGcursorexecuterowcountr   infocommitclose	Exceptionerror)r   r   r   r   r	   connr   args
update_sql
insert_sqler
   r
   @/home/air/goalskill_sales/back/app/models/company_info_module.pysave_company_info   s@   

r   returnc              
   C   sz   z't jjdi t}|jdd}d}||| f | }|  |  |W S  ty< } z	t	
d|   d}~ww )uB   session_id로 저장된 회사 정보 1건 조회. 없으면 None.T)
dictionaryz
            SELECT eligibility, skills_and_experience, welcome_personality, key_information, created_at, updated_at
            FROM company_info
            WHERE session_id = %s
            ORDER BY updated_at DESC
            LIMIT 1
        zCompany info get error: Nr
   )r   r   r   r   r   r   fetchoner   r   r   r   )r   r   r   sqlrowr   r
   r
   r   get_company_info>   s   r#   )
app.core.configr   r   mysql.connectorr   r   strr   dictr#   r
   r
   r
   r   <module>   s    
7