o niI @sdZddlmZmZmZmZddlZddlm Z ddl m Z e dZ deee efdefd d Z dd e d ee deee effd dZdS)uy sales_sheet_data 테이블 접근. 1s(개인 시트) / 2s(팀 시트) 업로드 후 파싱된 레코드 저장·조회. )ListDictAnyOptionalN)logger) get_db_config Sales_A_DBrecordsreturnc CsP|sdSztjjd it}|}|dd}d}|D]f}|d}|d}|d}|d} |d} |d } |d usQ|d usQ|d usQ| d usQ| d urRq| d urszt| tt fsbt | n| } Wn t t fyrd } Ynw|||||| | | f|d 7}q| | | |WSty} z td | d } ~ ww)u sales_sheet_data 에 레코드 일괄 INSERT. uk_record (session_id, sheet_type, period_type, record_type, category) 기준 중복 시 value 갱신. rSET time_zone = '+09:00'z INSERT INTO sales_sheet_data (session_id, sheet_type, period_type, record_type, category, value) VALUES (%s, %s, %s, %s, %s, %s) ON DUPLICATE KEY UPDATE value = VALUES(value), created_at = CURRENT_TIMESTAMP session_id sheet_type period_type record_typecategoryvalueNzSales sheet insert error: )mysql connectorconnect A_DB_CONFIGcursorexecuteget isinstanceintfloat TypeError ValueErrorcommitclose Exceptionrerror) r connrsqlcountrr r rrrrerr?/home/air/goalskill_sales/back/app/models/sales_sheet_module.pyinsert_sales_sheet_records sD       ( r*r r c Csz9tjjdit}|jdd}|d|r"d}||||fn d}|||f|}|||WStyU}zt d|gWYd}~Sd}~ww) uo session_id 기준으로 sales_sheet_data 조회. sheet_type 이 있으면 '1s' / '2s' 로 필터. T) dictionaryr a SELECT id, session_id, sheet_type, period_type, record_type, category, value, created_at FROM sales_sheet_data WHERE session_id = %s AND sheet_type = %s ORDER BY sheet_type, period_type, category, record_type a  SELECT id, session_id, sheet_type, period_type, record_type, category, value, created_at FROM sales_sheet_data WHERE session_id = %s ORDER BY sheet_type, period_type, category, record_type zSales sheet get error: Nr) rrrrrrfetchallr!r"rr#)r r r$rr%rowsr(rrr)get_sales_sheet_by_session7s$  r.)N)__doc__typingrrrrmysql.connectorrapp.corerapp.core.configrrstrrr*r.rrrr)s  ,