o *Eh-0@sddlmZmZmZmZddlmZmZmZm Z m Z m Z ddl m Z m Z ddlZddlmZmZddlmZddlZddlmZddlZddlZddlZedeZeZd d Zd d Zejd dgdddZejddgdddZ ejddgdddZ!ejddgdddZ"ddl#Z#ddl$m%Z%e&dZ'dZ(dd Z)d!d"Z*d#e+d$e+d%e,fd&d'Zd(d)Z-d*d+Z.d#e+d,e/fd-d.Z0d/d0Z1dS)1) Blueprintjsonifyrequest current_app)dbCustomerContent SentMessage SubscriberSchedule)datetime timedeltaN)MailMessage)BackgroundScheduler)generate_unique_link schedulercCsLt||gd}||_tt|WddS1swYdS)zFunction to send an email.)subject recipientsN)rbodyr app_contextmailsend)torrmsgrG/home/www/bk.finsightngr.online/FinSight/app/routes/scheduler_routes.py send_emails   "rcCs|Qt}tj}|D]2}|j|k|_tj tj |j ktj |j kB }|r1|j|_qt|j |j d|jd}tj|qtjtdWddS1sXwYdS)Nz New Customer) mobile_numberemailnamesubscription_statusu.✅ Subscription statuses checked and updated.)rr utcnowr queryallendtimesubscribeStatusrfilterrphonerfirstrsessionaddcommitlogginginfo)appnow subscribers subscribercustomer new_customerrrrcheck_subscriptionsDs0        "r5z /scheduleGET)methodscCsttddidfS)z(Route to trigger the scheduling process.messagezScheduled messages processed.)Zsend_daily_messagesrrrrrschedule_daily_messagesdsr:z/scheduled_contentsc Cstjjddtd}tjjddtd}tjjdd}g}|D]6}|jt dd}t |krUt j t jt k}|D]}||j|j|j|d d qBq|d|}||} ||| } t| t|||d S) zDGet the list of scheduled contents and their recipients (paginated).pagetypeper_page T)r!)hours%Y-%m-%d %H:%M:%S) recipientheadlinelinkscheduled_time)scheduled_contentstotalr;r?)rargsgetintrr# filter_byr$ created_atr r r0rr'dateappendrrDrEstrftimerlen) r;r?active_subscribersrGr2rFcontentscontentstartendZpaginated_contentsrrrget_scheduled_contentsms2 "   rWz/sent_contentsc Cstjjddtd}tjjddtd}tjj||dd}g}|jD]!}tj|j }t j|j }| |j |j|j|jdd q t||j||d S) Nr;r<r=r?r@F)r;r? error_outrB)rDrErCsent_at) sent_contentsrHr;r?)rrIrJrKr r#paginateitemsr content_idr recipient_idrOrDrErrYrPrrH)r;r?Zsent_messages_queryrZ sent_messagerTrCrrrget_sent_contentss&   r`z /push_contentPOSTc Cst}|d}|d}tdz?tj|}tj|}t |j |j d}t j |t j d|jd|jd|j}td|d td d id fWStyx}ztd t|tdt|idfWYd}~Sd}~ww)z0Endpoint to manually push content to a customer. customer_idr]z,Received request to push content to customer)r]r^zHello z, Today's News: z: zContent pushed to customer z successfullyr8z'Content pushed to customer successfullyr9z#Error pushing content to customer: erroriN)rget_jsonrJr-r.rr# get_or_404rr idrr*r+r,r rDrEr Exceptionrcstr) json_datarbr]r3rTr_r8errrpush_content_to_customers$        rk)SQLAlchemyErrorz Africa/Lagosz#https://bk.finsightngr.online:30976cCsttSN)r r0WATrNrrrr _wat_todaysrocCs ttjSrm)r r0rnhourrrrr_current_wat_hours rqr] subscriber_idreturncCsht|dr |nt|}|d|d|dt}t|}t d|d|d|S)N isoformat_z /content//) hasattrrtrhr r"hashlibmd5encode hexdigest BASE_HOST)r]scheduled_daterrsd unique_string unique_hashrrrrs"rcCsBt}tjj|dtj}|sdS|dj}|t |fS)z|Return a primary content_id for today (pick the earliest/lowest id if multiple). If none scheduled, return None. )rN)Nrr) ror r#rLorder_byrfascr$r]rQ)todayr\primaryrrr _get_todays_scheduled_content_ids   rcCsz.tjjddtjd}|}|jtjdiddtj t j d|d|WStyCt j dtj Yd Sw) z%Bulk clear news_link for active subs.Tr&NF)synchronize_sessionz#[DailyLinks] Cleared news_link for  active subscribers.z1[DailyLinks] Clearing links failed; rolling back.r)r r#rLr' news_linkisnotcountupdaterr*r,rloggerr.rl exceptionrollback)qrrrr#_clear_links_for_active_subscriberss    r only_missingc Csd}d}t}tjjdd}|r|tjd}zS|tj }d} |}|dur3|tj|k}| | } | s=q]| D]} t ||| j| _t j| | j}|d7}q?t jq%tjd|d|d |WStytjd t j|YSw) z_Populate links for active subscribers; if only_missing=True, fill only where news_link is NULL.irTrNr<z+[DailyLinks] Populated links (only_missing=z) for rz1[DailyLinks] Populate links failed; rolling back.)ror r#rLr'ris_rrfrlimitr$rrr*r+r,rrr.rlrr) r]rZBATCHrHrZ base_queryr#Zlast_idZpage_qbatchsubrrr_populate_links_for_subscribers s<      rcCst}t\}}|stjd|ddd|dSd}|dkr#d}n|d kr*d }n |d vr1d }nd }||||d}|dkrFt}||d<n0|d krUt|dd}||d<n!|d krdt|dd}||d<ntjd|dd|d<d|d<tjd||S)a! Runs at 4,5,6,7,8 WAT. - 4:00 => clear all links for active subscribers (phase CLEAR) - 5:00 => generate links for all active subscribers (phase POPULATE_ALL) - 6-8 => fill only missing links (phase TOP_UP) Only runs if there is scheduled content for *today*. z<[DailyLinks] No scheduled content for today; skipping (hour=z).TZno_scheduled_content)skippedreasonrpNZCLEARZ POPULATE_ALL)ZTOP_UPUNKNOWN)rpphasescheduled_countr]clearedF)r populatedZ topped_upz$[DailyLinks] Unknown phase for hour=z; doing nothing.rZ unknown_phaserz[DailyLinks] Result: )rqrrrr.rr)Zwat_hourZprimary_content_idrrresultrrZtoppedrrrrun_daily_link_maintenance0s8       r)2flaskrrrr app.modelsrrrr r r r r r- flask_mailrr!apscheduler.schedulers.backgroundrpytz app.utilsr threadingtime__name__ scheduler_bprrr5router:rWr`rkrxZsqlalchemy.excrltimezonernr|rorqrKrhrrboolrrrrrrsD    ,  (  #    %