o ȟ1i4@sddlZddlZddlZddlmZmZddlmZddlZddlm Z ddl m Z ddl m Z mZmZmZmZmZmZmZddlmZddlmZm Z mZdd lmZdd lmZddlZGd d d ZdS) N)datetimetimezone)Path)settings) GenericError)EventEventParticipant EventCart EventPaymentDiscountCouponParent Participant WalletHistory)EventResponseSchema)get_dbr BASE_PATH) joinedload)send_event_order_summary_emailc@seZdZdZddZddZddZdefd d Zd d Z d dZ ddZ ddZ ddZ ddZdefddZdefddZdefddZddZd d!Zd"d#Zd$d%Zd&d'Zd(d)Zd*efd+d,Zd-d.Zd/d0Zd1S)2 EventServiceZgbpcs|jr?t|jjj}t|}td|}|jIdH}t|d}| |Wd|S1s8wY|SdS)Nuploads/wb) imagerfilenamesuffixuuiduuid4rreadopenwrite)selfrequestfile_extension new_filename file_locationcontentfr&/app/services/event.py upload_images   zEventService.upload_imagec s||IdH}g}|jD]E}|rNt|jj}t|}td|}|IdH}t |d } | |Wdn1sCwY| |q| dqt j} zM| t|j|j|j|j|j|j|j|j|d } | | | | | t|j|D]\} }t| j| |d} | | q| | WWdSty}z| t ddt!|dd}~ww1swYdS)Nrr) nameevent_start_dateevent_end_dateevent_start_timeevent_end_timeprice descriptionlocationrevent_idr)rzError creating event:  status_codeexc)"r(participant_imagesrrrrrrrrrappendrbeginrr)r*r+r,r-r.r/r0addcommitrefreshzipparticipant_namesrid Exceptionrollbackrstr)rr Z event_imager7rr!r"r#r$r%dbeventr)db_participanter&r&r' create_events^         zEventService.create_eventcCstB}|ttjd}g}|D]%}t| }|t t j |j k}dd|D|d<| |q|WdS1sHwYdS)NcSg|] }|j|j|jdqSr)r image_urlrJ.0pr&r&r' \z0EventService.fetch_all_event.. participants)rqueryrwhere deleted_atis_allrmodel_validate model_dumprr2r?r8)rrCrecordseventsrecord event_datarQr&r&r'fetch_all_eventSs    $zEventService.fetch_all_eventr2cCstA}|ttj|ktjd}|stddd|t t j |k }t |}dd|D|d<|WdS1sGwYdS)NEvent not foundr4cSrHrIrJrLr&r&r'rOorPz4EventService.fetch_event_details..rQ)rrRrrSr?rTrUfirstrrr2rVrrWrX)rr2rCr[rQr\r&r&r'fetch_event_detailsbs&    $z EventService.fetch_event_detailsc s |jgdd}t|dr|jdur||IdH}||d<g}t|drt|jdurt|jD]E}|rnt|jj}t |}t d|}| IdH} t |d } | | Wdn1scwY||q.|dq.t} | ttj|ktjdj|dd} t|d r|jdurt|dr|jdurdgt|j}|j} |}t| t|krtd d d t| |D]#\}}| ttj|ktj|k}|st|||d }| |q| !| dkrtd dd WddS1swYdS)N)r?rr7r>)excluderr7rrfetchsynchronize_sessionr>z+Participant names and images count mismatchr4r1rzCould not update event)"rXhasattrrr(r7rrrrrrrrrr8rrRrrSr?rTrUupdater>lenrr=rfilterr2r)r`r:r;)rr2r payloadrr7r!r"r#r$r%rCresultnamesimagesr)Zexisting_participantrEr&r&r' update_eventtsb      "    "zEventService.update_eventcC|t1}|ttj|ktjd}|stdddt t j |_| ddiWdS1s7wYdS)Nr^r_r4messagezEvent deleted successfully)rrRrrSr?rTrUr`rrnowrutcr;)rr2rCrDr&r&r' delete_events$ $zEventService.delete_eventcCst7}|ttjd}|jr|tj|jk}|jr(|tj|jk}|}dd|DWdS1s=wYdS)NcSsg|] }t|qSr&)rrWrX)rMr[r&r&r'rOsz-EventService.event_filter..) rrRrrjrTrUr*r+rV)rr rCrRrYr&r&r' event_filters $zEventService.event_filterc std}zG||ttj|jk}|s tddd|j |j }t |j|d|d|j |d}| || |||WWdStyg}z|tddt|dd}~ww1skwYdS) Nr^r_r4r? user_type)r2user_idrvno_of_participants total_amountr3zError creating event cart: )rr9rRrrjr?r2r`rr.rxr r:r;r<r@rArB)rr userrCrDry event_cartrFr&r&r'create_event_carts4    zEventService.create_event_cartcCsR|j|j|j|j|j|j|j|j|j|j|j |j |j |j |j |j|j|jd d S)z>Generate response dictionary for event cart with event details) r?r)r*r+r,r-r.r/r0r) r?r2rwrvrxry created_at updated_atrD)r?r2rwrvrxryr}r~r)r*r+r,r-r.r/r0r)rcartrDr&r&r'_generate_event_cart_responses(z*EventService._generate_event_cart_responsec st=}|ttttjtjktj|dktj |dktj dtj dtj dk }fdd|DWdS1sCwYdS)Nr?rvFcsg|] \}}||qSr&)r)rMrrDrr&r'rO sz:EventService.get_event_cart_by_user_id..)rrRr rjoinr2r?rSrwrvrTrUis_cart_processedrV)rrzrCdatar&rr'get_event_cart_by_user_ids       $z&EventService.get_event_cart_by_user_id event_cart_idcCst:}|ttttjtjktj|ktj dtj d }|s,t ddd|\}}| ||WdS1s@wYdS)Nr^Event cart not foundr4) rrRr rrr2r?rSrTrUr`rr)rrrCrlrrDr&r&r'fetch_event_cart_detailss       $z%EventService.fetch_event_cart_detailscsxt.}|ttj|ktjd|jdd}| |dkr*t dddWddS1s5wYdS)NT) exclude_unsetrrfzCould not update event cartr4) rrRr rSr?rTrUrhrXr;r)rrr rCrlr&r&r'update_event_carts   "zEventService.update_event_cartcCrp)Nr^rr4rqzEvent cart deleted successfully)rrRr rSr?rTrUr`rrrrrrsr;)rrrCrr&r&r'delete_event_cart)s   $zEventService.delete_event_cartcCs,|rt,}|ttj|jktj|k}||jkr*t |dfWdSWdn1s4wYd}|j r\t ||j kr[|j dkrVt |t |j d}nt |j }n|j dkrmt |t |j d}nt |j }t|dr|jrt|t |j}t||}tdt ||}t ||fS)Nr percentaged max_discount)rrRr rjdiscount_coupon_idr?rwcountuses_per_customerfloat rule_typemin_cart_value discount_typediscount_valuergrminmax)rZcart_total_amountdiscount_coupon_instancerwrCZ usage_countZcalculated_discountr&r&r'apply_discount5s8           zEventService.apply_discountcCsd}|jrVtF}|ddkr|t|dj}n+|ddkr>|ttj|dktj d j}Wd|SWd|SWd|S1sQwY|S)Nrrvparentr? participant) use_walletrrRr get wallet_amountr rjr? parent_idrUr`)rr rzrrCr&r&r'fetch_wallet_amountWs*      z EventService.fetch_wallet_amountcs d}d}d}d}d}d}t} z|ddkr*| ttj|dk} n|ddkr?| ttj|dk} | sGtd d d | t t tj tj |dktj |dktjdtjdk} | dkrutd d d | } td d| D} ||d} d}d}|jrt}| ttj|jktjdktjtktjtktjdk}|r|| ||d\} }|j r| | dd} |j!r|ddkr| tj"tj|dk#pd}n|ddkr | tj"tj|dk#p d}t$|| }| |8} | dkr$|%| | | }|j&}n d}tt'j(}d}t)|d|d|| || dkr?dnd||| |||d }| *|| D] }| |_+d|_qP| ,|dkr|dkr|ddkr| ttj|dk-tj"tj"|in1|ddkr| ttj|dk-tj"tj"|i| *t.|j|j |j |d|j+dddd | ,|||| t/0dd| t/0dd| ||dWWdSt1y}z| 2tddt3|d d}~ww1swYdS) a Creates a payment session for event cart items. Args: request: Payment request containing discount_coupon_code and charity flag user: Dictionary containing user id and user_type Returns: Dictionary containing payment_url, status, transaction details Raises: GenericError: If cart is empty or payment creation fails NpendingFrrvrr?rr^zUser not foundr4zEvent cart is emptycSsg|]}|jqSr&)ryrMrr&r&r'rOsz=EventService.create_event_payment_session..Trsuccessstripewallet) rwrv stripe_urlrypayment_statuspayment_methodpaid_onis_payment_completedtransaction_batch_idcoupon_discounted_amountrused_wallet_amountpurchaseN/APurchased event(s) event_payment_idrv refund_for_idamount refund_typetransaction_idnote is_creditrq APP_UI_URL/dashboard/event-success//dashboard/event-failed/)Z payment_urlrrr success_url cancel_urlrrrfz(Could not create event payment session: )4rrRr rjr?r`r rr optionsrrDrwrvrTrUrrrVsum_generate_transaction_iddiscount_coupon_coderrrdater codestatus start_dateend_dateis_applicable_for_eventrcharityrrscalarr_generate_event_payment_linkurlrrsr r:rr;rhrosgetenvr@rArB)rr rzZ session_urlrrrrrrCZ user_exists event_cartsryrrZcalculated_coupon_discount current_datersessionpaymentrrFr&r&r'create_event_payment_sessionbs              &&         z)EventService.create_event_payment_sessioncCs0ttd}t|dd}|d|dS)z Generates a unique transaction ID for payment tracking. Args: user_id: ID of the user making the payment Returns: String containing timestamp, user_id and event identifier iiN-z-evnt)inttimerB)rrw timestampZbase_idr&r&r'rs z%EventService._generate_transaction_idc Csddd|D}d|jt|ddd|dd d g}tjt_tjjj d g|d d |it dd|t dd|d}|j rmtj d}tj}d} |D] } | j |kr`d} nqUt| | sm|t||S)ai Creates a Stripe checkout session for event payments. Args: event_carts: List of EventCart objects total_amount: Total payment amount in currency units transaction_batch_id: Unique transaction identifier Returns: Stripe Session object containing payment URL ,cSsg|]}|jjqSr&)rDr)rr&r&r'rOsz=EventService._generate_event_payment_link..rzWAC Event Purchasez Event(s): )r)r/)currencyZ unit_amountZ product_data)ZquantityZ price_dataZcardrrrrr)Zpayment_method_types line_itemsmodemetadatarrz/event/stripe/webhookFT)rrrrstripe_secret_keyrapi_keycheckoutSessioncreaterrrstripe_webhook_urlWebhookEndpointlistprintcreate_webhook) rrryrr/rr webhook_urlZexisting_webhooksZis_webhook_existswebhookr&r&r'rs@      z)EventService._generate_event_payment_linkcCs td|jj|gdd}|S)Nzcreating webhook)zpayment_intent.succeededcheckout.session.completedzpayment_intent.payment_failed)rZenabled_events)rrr)rrrrr&r&r'rDs zEventService.create_webhookrkcCsBt}t|d}|ddkr|dddd}t||dddd kr|ttj|ddddk }|sIt d d d |j r|j d kr|j dkro|t t j|jk }|rn|j|j 8_n|j dkr|ttj|jk }|r|j|j 8_|ttj|kjd|ddddtddd|ttj|kddi|ttj|ktjdk }|rt|j|j r|j d kr|t|j|j |j|j d|jdddd n|ttj|kjddddd|WddSWddS1swYdS)a Updates payment status and handles wallet deduction if payment was completed using wallet. Args: payload: Payment payload containing transaction details Returns: Updated payment record zutf-8typerrobjectrrrZpaidr^zPayment not foundr4rrrrZpayment_intentT)r payment_idrrrcrdrrrFrrZfailed)rrN)rjsonloadsdecoderrRr rjrr`rrrvr r?rwrr rhrrrr rrr:rr;)rrkrCrDrrrrr&r&r'update_paymentOs          $zEventService.update_paymentc CsLt}|t}g}|D]}|tttjtjk tj |j ktj dk}|D]d}i}|j dkrP|t  t j|jk}|rO|j|j|jd}n|j dkrn|t tj|jk} | rn| j| j| jd}||j|j d||j|jj|jj|j|j|j|j|j|jd q-q|WdS1swYdS)z Retrieves all event bookings for admin view Returns: List[AdminEventBookingResponse]: List of booking details Tr) first_name last_nameemailr)r?r) r2 event_name event_dateparticipants_countryr payment_daterdiscount_amountN)rrRr rVr rrr2r?rjrrrvr rwr`rrrr r8rDr)r*rxryrrrr) rrCpaymentsrlrcartsrZ user_detailsrrr&r&r'get_all_event_bookingssb      %$z#EventService.get_all_event_bookingscCste}|ttj|dktj|dk}g}|D]A}|tt tj t j ktj |j ktj dk}|D]"}||j |j |jj|jj|j|j|j|j|j|j|j|jd q;q|WdS1skwYdS)z Retrieves all event purchases for the current user. Returns: List[EventPurchaseDetailResponse]: List of purchase details r?rvT) rr2rrrryrrrrrrN)rrRr rjrwrvrVr rrr2r?rrr8rDr)r*rxryrrrrrr)rrzrCrrlrrrr&r&r'get_user_event_purchasessH       $z%EventService.get_user_event_purchasesN)__name__ __module__ __qualname__rr(rGr]rrarortrur|rrrrrrrrrrrrBrrrr&r&r&r'rs4 5?    " #2 O :r)rrrrrpathlibrr core.configrcore.security.exceptionsrmodelsrrr r r r r r schema.eventrrrsqlalchemy.ormrZ core.utilityrrrr&r&r&r's   (