o ¿Ôi<ã@s„ddlmZmZddlmZddlmZddlmZmZdd„Z dd„Z dd lmZd d„Zdd lmZdd „Zdd„Z dd„ZdS)é)ÚrequestÚjsonify)Úclosing)Úconnect_to_database)ÚdatetimeÚ timedeltac Cs tƒ}ddddddœ}z¿z’t|jddƒ€}| d |f¡| ¡}|s9td ddœƒdfWdƒWW| ¡S| d ¡rG|d d¡|d<| d¡rU|d d¡|d<| | d¡| d¡¡|d<| d|f¡| ¡|d<| d|f¡| ¡}||d<t|ddœƒdfWdƒWW| ¡S1s˜wYWn%t yÃ}ztdt|ƒ›ddœƒdfWYd}~W| ¡Sd}~wwW| ¡dS| ¡w)NÚPaidÚDraftúPending PaymentÚOverdueÚCanceled©ÚpaidÚdraftÚpendingZoverdueÚcanceledT©Ú dictionaryzû SELECT i.*, s.user_id, p.package_name FROM invoices i JOIN subscriptions s ON i.subscription_id = s.id JOIN packages p ON s.package_id = p.id WHERE i.id = %s zInvoice not found©ÚmessageÚerrori”Ú issue_dateú %b %d, %YÚissue_date_friendlyÚdue_dateÚdue_date_friendlyÚstatusÚstatus_friendlyz1SELECT * FROM invoice_items WHERE invoice_id = %sÚitemszæ SELECT id, amount, payment_method, transaction_id, payment_date, status, gateway_response FROM payments WHERE invoice_id = %s ORDER BY payment_date DESC ÚpaymentsF)ÚdataréÈzError fetching invoice: éô)rrÚcursorÚexecuteÚfetchonerÚcloseÚgetÚstrftimeÚfetchallÚ ExceptionÚstr)Ú invoice_idÚ connectionÚ status_mapr#ÚinvoicerÚe©r1úS/Users/harjaapdhillon/Desktop/newidea/medvista_backend/Services/Billing/Invoices.pyÚget_invoicesZûúô . á ûþýÚ .Ò+( €ýÕ.r3cCsdS)Nr1)r,r1r1r2Úgenerate_invoice_pdfEsr4)rc CsØtj d¡}tjjddtd}tjjddtd}tj d¡}tj d¡}tƒ}d d ddd dœ}z6zt|jddƒô}d} |g} |rL| d7} | |¡|rW| d7} | |¡|rb| d7} | |¡d| d}| || ¡| ¡d}| d7} | ||d|g¡| | | ¡| ¡} | s¨tgd||ddœƒdfWdƒWW| ¡Sdd„| Dƒ}d d!gt|ƒ¡}| d"|›d#t|ƒ¡| ¡}i}|D] }| |d$g¡ |¡qÍ| D]8}| |d%g¡|d&<| | d¡| d¡¡|d'<| d(¡r|d( d)¡|d*<| d+¡r|d+ d)¡|d,<qÝt| |||ddœƒdfWdƒWW| ¡S1s3wYWn&ty_}ztd-t|ƒ›dd.œƒd/fWYd}~W| ¡Sd}~wwW| ¡dS| ¡w)0zDGet all invoices for a specific user with filters and their paymentsrÚpageé©ÚdefaultÚtypeÚlimité Ú start_dateÚend_daterr r rrr Tra SELECT i.*, p.package_name, s.start_date as subscription_start FROM invoices i JOIN subscriptions s ON i.subscription_id = s.id JOIN packages p ON s.package_id = p.id WHERE s.user_id = %s ú AND i.status = %sú AND i.issue_date >= %sú AND i.issue_date <= %súSELECT COUNT(*) as total FROM (ú ) as tempÚtotalú. ORDER BY i.issue_date DESC LIMIT %s OFFSET %srF©r rCr5Úper_pagerr!NcSóg|]}|d‘qS©Úidr1©Ú.0r/r1r1r2Ú Šóz%get_user_invoices..ú,ú%sú¨ SELECT id, invoice_id, amount, payment_method, transaction_id, payment_date, status FROM payments WHERE invoice_id IN (ú9) ORDER BY payment_date DESC r,rIrrrrrrrúError fetching invoices: rr"©rÚargsr'Úintrrr#Úappendr$r%Úextendr)rr&ÚjoinÚlenÚtupleÚ setdefaultr(r*r+)Úuser_idrr5r:Ústart_date_strÚend_date_strr-r.r#ÚqueryÚparamsÚcount_queryrCÚinvoicesÚinvoice_idsÚformat_stringsrÚpayments_mapÚpayr/r0r1r1r2Úget_user_invoicesKs¤û ûúÜ QÛýû€ûúº Q¯N( €ý²Qrgc CsÖtj d¡}tjjddtd}tjjddtd}tj d¡}tj d¡}tƒ}d d ddd dœ}z5zt|jddƒó}d}g} |rK|d7}| |¡|rV|d7}| |¡|ra|d7}| |¡d|d} | | | ¡| ¡d}|d7}| ||d|g¡| || ¡| ¡}|s§tgd||ddœƒdfWdƒWW| ¡Sdd„|Dƒ} d d!gt| ƒ¡}| d"|›d#t| ƒ¡| ¡}i}|D] }| |d$g¡ |¡qÌ|D]8}| |d%g¡|d&<| | d¡| d¡¡|d'<| d(¡r|d( d)¡|d*<| d+¡r|d+ d)¡|d,<qÜt||||ddœƒdfWdƒWW| ¡S1s2wYWn&ty^}ztd-t|ƒ›dd.œƒd/fWYd}~W| ¡Sd}~wwW| ¡dS| ¡w)0zYGet all invoices with their payments, optionally filtered by status or invoice date rangerr5r6r7r:r;r<r=rr r rrr Tra SELECT i.*, p.package_name, s.user_id, s.start_date as subscription_start FROM invoices i JOIN subscriptions s ON i.subscription_id = s.id JOIN packages p ON s.package_id = p.id WHERE 1=1 r>r?r@rArBrCrDrFrEr!NcSrGrHr1rJr1r1r2rLôrMz$get_all_invoices..rNrOrPrQr,rIrrrrrrrrRrr"rS)rr5r:r]r^r-r.r#r_r`rarCrbrcrdrrerfr/r0r1r1r2Úget_all_invoices³s¤û ûúÚ QÝýû€ûúº Q¯N( €ý²QrhcCs^tƒ}t ¡}z¢z|t| ¡ƒ_}| d||tdd|f¡| ¡}|D]B}|\}}}} } }}|tdd|tdddœ |¡} d| d¡›d |›}| d ||||tdd| | |f¡| d| |f¡q$Wdƒn1sqwY| ¡dd dœWW| ¡Sty©}z| ¡dt|ƒ›ddœWYd}~W| ¡Sd}~ww| ¡w)Nag SELECT s.id AS subscription_id, s.billing_cycle, s.next_billing_date, s.package_id, p.price, p.currency_id, p.package_name FROM subscriptions s JOIN packages p ON s.package_id = p.id WHERE s.user_id = %s AND s.status = 'active' AND s.next_billing_date IS NOT NULL AND s.next_billing_date <= %s AND s.next_billing_date > %s é©Údayséém©ÚmonthlyÚannualúINV-ú%Y%m%dÚ-á* INSERT INTO invoices ( subscription_id, invoice_number, issue_date, due_date, amount, total_amount, currency_id, status, gateway_type ) VALUES (%s, %s, %s, %s, %s, %s, %s, 'draft', 'razorpay') z‹ UPDATE subscriptions SET next_billing_date = %s WHERE id = %s z+Invoice generated if within billing window.FrzFailed to generate invoice: T)rrÚnowrr#r$rr)r'r(Úcommitr&r*Úrollbackr+)r\r-Útodayr#Ú subscriptionsÚsubÚsubscription_idÚ billing_cycleÚnext_billing_dateÚ package_idÚpriceÚcurrency_idÚpackage_nameÚnew_billing_dateÚinvoice_numberr0r1r1r2Úgenerate_next_invoice_if_duesNýðþýþûüéè5 û €û r„cCs€tƒ}t ¡}z³z‰t| ¡ƒe}| d|tdd|f¡| ¡}d}|D]G}|\}}}} } }}} |tdd|tdddœ |¡}d| d ¡›d |›}| d||||tdd|||f¡| d||f¡|d 7}q%Wdƒn1swwY| ¡t|›dddœƒdfWW| ¡St yº}z| ¡tdt|ƒ›ddœƒdfWYd}~W| ¡Sd}~ww| ¡w)Na_ SELECT s.id AS subscription_id, s.billing_cycle, s.next_billing_date, s.package_id, s.user_id, p.price, p.currency_id, p.package_name FROM subscriptions s JOIN packages p ON s.package_id = p.id WHERE s.status = 'active' AND s.next_billing_date IS NOT NULL AND s.next_billing_date <= %s AND s.next_billing_date > %s rirjrrlrmrnrqrrrsrtzŒ UPDATE subscriptions SET next_billing_date = %s WHERE id = %s r6z invoice(s) generated.Frr!zFailed to generate invoices: Tr")rrrurr#r$rr)r'r(rvrr&r*rwr+)r-rxr#ryÚcountrzr{r|r}r~r\rr€rr‚rƒr0r1r1r2Ú$generate_next_invoices_for_all_users]sPþðþýþûü äç7 û( €û r†N)ÚflaskrrÚ contextlibrÚconfrrrr3r4rgrhr„r†r1r1r1r2Ús=ffD