Bi1dZddlZddlZddlZddlZddlmZmZmZddlm Z ddl m Z ddl m Z ddlmZddlmZd Zdd lmZdd lmZmZmZmZmZdd lmZdd lmZddlm Z m!Z!m"Z"ej#e$Z%e dZ&dede'defdZ(e j)ddZ*e j)ddZ+dZ,e j)ddZ-dS)uF Celery 태스크 정의 정기구독 자동 갱신 및 결제 처리 N)datetime timedeltadate) monthrange)ZoneInfo)celery)db)Flaskcddlm}|S)uFlask 앱 인스턴스 반환rapp)src.mainr r s B/var/www/html/web/mlink/mlink_AI_Server/mlink-backend/src/tasks.pyget_apprs J)User) SubscriptionSubscriptionStatusProduct PaymentStatus PaymentMethod)PaymentHistory)send_payment_link_email) TOSS_CONFIG get_front_url get_back_urlz Asia/Seoul base_date start_dayreturnc|jdkr |jdzd}}n|j|jdz}}t||d}t||}t |||S)uObase_date 기준으로 +1개월, 시작일의 '일(day)' 유지. 말일 보정. )monthyearrminr)rrymlast_daykeep_days r_add_one_month_same_dayr*sh"~!11~y21!Q"H9h''H 1h  rz%src.tasks.check_subscription_renewals)namec Tt}|5 tjt}|}t jt j tj kt j dkt j dtjt j |k}t$dt)|d|D]k} t*|j##t0$r<}t$d|jdt5|Yd}~dd}~wwxYwdt)||dcdddS#t0$rR}t$dt5|d t5|d cYd}~cdddSd}~wwxYw#1swxYwYdS) u 정기구독 갱신 체크 태스크 next_billing_date가 오늘인 구독을 찾아 결제 링크 생성 및 이메일 발송 TNu정기구독 갱신 체크: u개 구독 발견u구독 u 갱신 처리 실패: )successchecked timestampu#정기구독 갱신 체크 실패: Fr-error)r app_contextrnowKSTrrqueryfilterstatusrACTIVE auto_renewnext_billing_dateisnotr funcallloggerinfolen"create_payment_link_and_send_emaildelayid Exceptionr1str isoformat)r now_ksttoday subscriptions subscriptiones rcheck_subscription_renewalsrL*s ))C   !! l3''GLLNNE).55#'9'@@'4/.44T:: \;<<E  cee  KK\s=7I7I\\\ ] ] ] - ] ] ]6<<\_MMMM ]]]LL![F>$EF> F 2FF>F  'F>> H;HHHHHH!$H!z,src.tasks.create_payment_link_and_send_emailct}|5 tj|}|s.t d|dddcdddS|jtj kr6t d|d|jdddcdddStjd }|s3t d |j dd dcdddStj|j}|s3t d |jdd dcdddS|jp|jpd}|dkr"t!|dr|jn |jdz}n|j}d|jdt)jjdddt/t1j}t7|||j||j |j}|r|ds.t d|dddcdddS|d} |dd} t;|j |j| ||t<jt@j!|j|j||t1j } tDj#$| tDj#%|j&r|j&'dnd} tQ|j)|j*|j| | |} | r&t +d|d |j)n%t d!|d |j)d"||| | d#cdddS#tX$rp}tDj#-t d$t]|dt]|dcYd}~cdddSd}~wwxYw#1swxYwYdS)%ue 결제 링크 생성 및 이메일 발송 Args: subscription_id: 구독 ID u#구독을 찾을 수 없습니다: Fu"구독을 찾을 수 없습니다.r0Nu)구독이 활성 상태가 아닙니다: u , 상태: u(구독이 활성 상태가 아닙니다.u&사용자를 찾을 수 없습니다: u%사용자를 찾을 수 없습니다.u#상품을 찾을 수 없습니다: u"상품을 찾을 수 없습니다.monthlyyearly price_yearr! mlink_renew__)order_idamount product_name billing_cycleuser_idsubscription_id payment_linku결제 링크 생성 실패: u결제 링크 생성 실패 pay_token) rYrZ payment_keyrUrVr7payment_method product_idrW product_pricerX created_atu%Y년 %m월 %d일u오늘) user_email user_namesubscription_namer[ billing_daterVu.결제 링크 이메일 발송 완료: 구독 u , 사용자 u.결제 링크 이메일 발송 실패: 구독 T)r-rZrUr[ email_sentu2결제 링크 생성 및 이메일 발송 실패: )/rr2rr5getr>r1r7rr8warningrrYrr`rXhasattrrQpricerCuuiduuid4hexintrr3r/create_toss_payment_linkr+rrPENDINGr TOSS_PAYMENTSr sessionaddcommitr:strftimeremailusernamer?rDrollbackrE)rZr rJuserproductrXrVrUpayment_resultr[r\payment_historyrfrgrKs rrArATs ))C   ccb '-11/BBL Y T?TTUUU#(3WXX cccccccc"&8&???{?{{frfy{{|||#(3]^^cccccccc:>>"%%D \ \lFZ\\]]]#(3Z[[!cccccccc&m'' (?@@G Y \>   O JNN? + + + J     \h[yH<9BBCVWWW@HL0:-"),)) J { v_vvjnjtvvwwwwyP_yymqmwyyzzz #2$ ,( kccccccccz    J   ! ! ! LLVcRSffVV W W W Q     Accccccccz {ccccccccccs^QAO 4>O ?AO A O ,C9O 2E O  QAP>,Q-Q>QQQ  Q c t|dz }||z }tjtdz}|d} ||d|||dt ddd d t d |d |t d |d || d } tjt dddi| d} | j dkr| } | d} | dd}| rL|r|}n"d| }t d|td|d||| dStd| dStd| j d | jdS#t"$r5}td!t%|Yd}~dSd}~wwxYw)"uZ 토스페이먼츠 결제 링크 생성 Args: order_id: 주문 ID amount: 결제 금액 product_name: 상품명 billing_cycle: 결제 주기 user_id: 사용자 ID subscription_id: 구독 ID Returns: dict: {'payment_link': str, 'pay_token': str} (실패 시 None) g?<)minutesz%Y-%m-%d %H:%M:%Sru 추가 구매api_keyTz*https://pay.toss.im/payfront/demo/callbackV2z/payment/success?orderId=z&subscriptionId=z/payment/fail?orderId=) orderNorV amountTaxFree amountTaxable amountVat productDescapiKey autoExecuteresultCallbackcallbackVersionretUrl retCancelUrl expiredTimebase_urlz Content-Typezapplication/json )headersjsontimeoutpayToken checkoutPager]z9https://pay.toss.im/transfer-web/linkgen-mobile?payToken=uC토스페이먼츠 응답에 checkoutPage가 없어 직접 생성: u0토스페이먼츠 결제 링크 생성 성공: z, payment_link: )r[r\u7토스페이먼츠 응답에 payToken이 없습니다: Nu&토스페이먼츠 API 호출 실패: z - u4토스페이먼츠 결제 링크 생성 중 오류: )rorr3rrvrrrequestspost status_coderrhr>rir?r1textrDrE)rUrVrWrXrYrZamount_taxable amount_vatexpiration_datetimeexpired_time_str payment_dataresponseresultr\ checkout_pager[rKs rrprps\>Vc\**n, 'lnny/D/D/DD.778KLL +#*:::!),J#&nn8nn]lnn,qqhqq`oqq+  $=  ##%78      3 & &]]__F :..I"JJ~r::M  u#0LL$k_h#j#jLNN#siq#s#sttt wxwwiuwwxxx$0!*  _W]__```t LLj(BVjj[c[hjj k k k4  TCPQFFTTUUUttttts$EF F 4*F G**GGz'src.tasks.cleanup_expired_subscriptionsc<t}|5 tj}tjtjtj ktj |k }d}|D]}tj |_d|_ |dz } tjt"d|dd||dcdddS#t($rp}tjt"d t/|dt/|d cYd}~cdddSd}~wwxYw#1swxYwYdS) uk 만료된 구독 정리 태스크 end_date가 지난 활성 구독을 만료 상태로 변경 rFr"u 만료된 구독 정리 완료: u개T)r-cleanedr/Nu 만료된 구독 정리 실패: r0)rr2rr3rr5r6r7rr8end_dater=EXPIREDr9r rsrur>r?rFrDryr1rE)r r3expired_subscriptionscountrJrKs rcleanup_expired_subscriptionsrs ))C      ,..C%1$6$=$=#'9'@@%+%%cee " E 5   &8&@ #*/ '  J      KKE5EEE F F F   ]]__)        4    J   ! ! ! LLDCFFDD E E E Q     ;        4 5          s<FC"D FAF 7F8F FFFF).__doc__osrlrloggingrrrcalendarrzoneinforsrc.celery_appr src.models.dbr flaskr rsrc.models.userrsrc.models.subscriptionrrrrrsrc.models.paymentrsrc.utils.email_servicersrc.routes.payments_v2rrr getLogger__name__r>r4ror*taskrLrArprrrrs- ..........!!!!!!! kkkkkkkkkkkkkk------;;;;;;KKKKKKKKKK  8 $ $h|  t          9:::'';:'R @AAAkkBAkZMMM^ ;<<<&&=<&&&r