Bi@UdZddlmZddlZddlZddlmZmZddlm Z m Z ddl m Z erddl mZmZejeZdaded <dd Zdd ZddZddZ dd dZdS)!uk원장 DB(DATABASE_URL) 커밋 후 credit_balances / credit_transactions 를 DATABASE_LOCAL_URL 로 복제.) annotationsN) TYPE_CHECKINGOptional) create_enginetext)Engine) CreditBalanceCreditTransactionOptional[Engine]_enginereturnboolctjddsdStjdddvS)NDATABASE_LOCAL_URLFCREDIT_MIRROR_ENABLED0)1trueyes)osgetenvstriplowerP/var/www/html/web/mlink/mlink_AI_Server/mlink-backend/src/utils/credit_mirror.py_mirror_enabledrsY 9)2 . . 4 4 6 6u 9,c 2 2 8 8 : : @ @ B BFZ ZZrctsdSt9tjdd}t |ddatS)NrrTi) pool_pre_ping pool_recycle)rr rrrr)urls r _get_enginer#sQ   ti,b1177994dKKK Nrbalance'CreditBalance'Nonecxt}|r|dS |5}|td|jt |jpdt |jpdt |jpdt |j pdt |j pdt |j pd|j |j d ddddS#1swxYwYdS#t$r6}tdt#|dd|Yd}~dSd}~wwxYw)u3credit_balances 단일 행 upsert (user_id 기준).Nad INSERT INTO credit_balances ( user_id, total_credit, free_credit, event_credit, daily_renewal_credit, subscription_credit, add_on_credit, last_daily_renewal, updated_at ) VALUES ( :user_id, :total_credit, :free_credit, :event_credit, :daily_renewal_credit, :subscription_credit, :add_on_credit, :last_daily_renewal, :updated_at ) ON DUPLICATE KEY UPDATE total_credit = VALUES(total_credit), free_credit = VALUES(free_credit), event_credit = VALUES(event_credit), daily_renewal_credit = VALUES(daily_renewal_credit), subscription_credit = VALUES(subscription_credit), add_on_credit = VALUES(add_on_credit), last_daily_renewal = VALUES(last_daily_renewal), updated_at = VALUES(updated_at) r) user_id total_credit free_credit event_creditdaily_renewal_creditsubscription_credit add_on_creditlast_daily_renewal updated_atu+credit_mirror balance 실패 user_id=%s: %sr()r#beginexecuterr(intr)r*r+r,r-r.r/r0 Exceptionloggerwarninggetattr)r$engconnes rmirror_credit_balance_rowr;$s --C '/&l YY[[# D LL. '$'(<(A$B$B#&w':'?a#@#@$'(<(A$B$B,/0L0QPQ,R,R+.w/J/Oa+P+P%()>)C!%D%D*1*D")"4  /" " " # # # # # # # # # # # # # # # # # # H lllDggW`bfFgFgijkkkkkkkkkls;C9B5C, C9,C00C93C04C99 D9+D44D9txn'CreditTransaction'c*t}|r ||jdS |jr |jjnd}|5}|t d|j|j|t|j t|j |j |j |j |j|j|jd ddddS#1swxYwYdS#t"$r,}t$d|j|Yd}~dSd}~wwxYw)uScredit_transactions 단일 행 upsert (id 기준으로 원장과 동일 PK 유지).Na INSERT INTO credit_transactions ( id, user_id, credit_type, amount, balance_after, description, reference_id, reference_type, meta_data, created_at, event_expiry_date ) VALUES ( :id, :user_id, :credit_type, :amount, :balance_after, :description, :reference_id, :reference_type, :meta_data, :created_at, :event_expiry_date ) ON DUPLICATE KEY UPDATE user_id = VALUES(user_id), credit_type = VALUES(credit_type), amount = VALUES(amount), balance_after = VALUES(balance_after), description = VALUES(description), reference_id = VALUES(reference_id), reference_type = VALUES(reference_type), meta_data = VALUES(meta_data), created_at = VALUES(created_at), event_expiry_date = VALUES(event_expiry_date) ) idr( credit_typeamount balance_after description reference_idreference_type meta_data created_atevent_expiry_dateu*credit_mirror transaction id=%s 실패: %s)r#r?r@valuer1r2rr(r3rArBrCrDrErFrGrHr4r5r6)r<r8ctr9r:s rmirror_credit_transaction_rowrKRsy --C #++P&)o ?S_ " "4 YY[[' D LL2&"{#%!#*oo%():%;%;#&?$'$4&)&8!$"%.),)>  3& & & ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' P PPPCSVQOOOOOOOOOPs<)CArasAqqq"""""" ****************$$$$$$CBBBBBBBB  8 $ $  [[[[ +l+l+l+l\0P0P0P0Pj*.#'1111111r