4ʜhBXddlZddlZddlmZmZmZmZmZmZm Z m Z ddl m Z ddl mZmZmZmZddlmZmZmZmZmZddlmZmZddlmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&ddl'm(Z(dd l)m*Z*dd l+m,Z,m-Z-ddl.Z.dd l.m/Z/dd l.m0Z0ddl1Z1dd l2m3Z3ddl4m5Z5ddl6m7Z7m8Z8m9Z9ddl:m;Z;ddlZ>ddl?m@Z@ddlAmBZBmCZCddlDmEZEddlFmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQddlRmSZSddlTmUZUmVZVmWZWmXZXddlYmZZZddl[m\Z\m]Z]ddl6m^Z^ddl_m`Z`ddlambZbddlcmdZdddleZeeZfe/jdZheiehe.jehGd d!eZkGd"d#eZlGd$d%eZmGd&d'eZnefjd(ee,j)dd*ee;fd+eqd,eqd-e fd.Zrefjd/e d0d12fd3esfd4Ztefjd5e dd62ee;eeSfd7eqd-e d8efd9Zuefjd:ee;eeSfd-e d8efd;Zvefjd<ee;eeSfd-e d8efd=Zwefjd>ee;eeSfd?e,jd-e d8ed@eeseffdAZzefjdBee;eeSfd-e d8ed@eeseffdCZ{efjdDe,j)ee;eeSfdEeqd-e d8efdFZ}efjd(ejGed0ee;eeSfdHed-e d8efdIZefjdDe,j)ee;eeSfdEeqdJe,jd-e d8efdKZefjdDee;eeSfdEeqd-e d8efdLZefjdMee,j)ee;eeSfdNeqd-e d8efdOZefj dPe,j)ee;eeSfdEeqdQeqd-e d8efdRZefjdSed0dTUee;eeSfdEeqdVed-e d8ed@ef dWZefjdXe de dee;eeSfdYedZed-e d8ed@eeseff d[Zefjd\e de dee;eeSfdYedZed-e d8ed@eeseff d]Zefjd^e de dee;eeSfdYedZed-e d8ed@eeseff d_Zefjd`e de de dda2ee;eeSfdYedZedEeeqd-e d8ed@eeseff dbZefjdcee;eeSfddekd-e d8ed@eeseffdeZefjdfed0ee;eeSfddekd-e d8ed@eeseffdgZefjdhe de de didj2ee;eeSfdYeedZeed,eqd-e d8ed@eeseff dkZdled@efdmZefjdned0ee;eeSfddeesefd-e d8ed@eeseffdoZefjdped0ee;eeSfddeesefd-e d8ed@eeseffdqZefjdree;eeSfd3esd-e d8ed@eeseffdsZefjdtee;eeSfd3esd-e d8efduZefjdveeesef)ee;eeSfd-e d8efdwZefjdxeesef)ee;eeSfdEeqd-e d8efdyZefjdzed0ee;eeSfddend-e d8efd{Zd|Zefjd}e,j2)ed0ee;eeSfd~emd-e d8ed@eeseffdZefjde)ee;eeSe dde didd*fd-e deqdeqfdZGddeZefjdeej<ed0ee;eeSfded-e d8efdZefjde)ee;fdeqd-e fdZefjded0ee;eeSfddeesefd-e d8efdZefjded0ee;eeSfddeesefd-e d8efdZefjdee;eeSfd-e d8efdZefjded0ee;eeSfddeesefd-e d8efdZefjded0ee;eeSfddeesefd-e d8efdZefjded0ee;eeSfddeesefd-e d8efdZefjded0ee;eeSfddeesefd-e d8efdZefjded0ee;eeSfddeesefd-e d8efdZefjde d0d2ee;eeSfdesd-e d8efdZefjded0ee;eeSfddeesefd-e d8efdZefjdee;eeSfdded-e d8efdZy)N) APIRouterDepends HTTPExceptionRequeststatusBodyQueryPath)Session)ListDictAnyOptional)datetime timedeltadatetimezonetime) BaseModelField) DatefunccasedescasccastStringand_literal_columnor_distinctselect)StreamingResponse)convert_to_local_time)schemasmodels) credentials) messaging)get_speech_to_text)OffTime)UserCustomerTransferResult)get_db)get_call_recording_public_urlget_twillio_client)convert_to_utc)NotFoundExceptionValidationError)Response) get_advisors get_advisorcreate_advisorprocess_booking_intentupdate_advisordelete_advisorget_advisors_by_departmentupdate_advisor_scoreupdate_advisor_availabilityis_advisor_availableget_all_available_advisors)validate_token)get_unique_repetitive_countsget_daily_call_countsget_hourly_call_volumeget_summary_statistics)ZoneInfo)stream_recording_from_urldownload_recording_by_call_id)Settings) get_setting) month_name) defaultdictzfirebase/serviceAccountKey.jsonc6eZdZUdZeeed<dZeeed<y)DashboardRequestN start_dateend_date)__name__ __module__ __qualname__rOrr__annotations__rPF/var/www/html/DP/alpha_backend/app/advisor_service/routers/advisors.pyrNrN;s %)J")#'Hhx 'rVrNc"eZdZUeed<eed<y)DateRangeRequestrOrPN)rQrRrSrrTrUrVrWrYrYIs NrVrYc"eZdZUeed<eed<y)DailyLogRequestlog_date advisor_idN)rQrRrSrrTintrUrVrWr[r[Ms NOrVr[c6eZdZUeed<eed<dZeeed<y)AdvisorTimeStatsRequestrOrPNr])rQrRrSrrTr]rr^rUrVrWr`r`RsN $J $rVr`z /advisors)response_modeldskiplimitdbc.Kt|||dd}|Sw)a Get all advisors, ordered by status (available first) and then by full name. Args: skip: Number of records to skip for pagination limit: Maximum number of records to return Returns: List of advisors ordered by availability and name T)rcrdorder_by_status order_by_name)r6)rcrdreadvisorss rW read_advisorsrjWs($  H Osz#/advisors/speech/get-speech-to-text.z%The call ID to get speech-to-text for) descriptioncall_idcKt|}|ttjdt |\}}}}||dSw)zs Get speech-to-text for a given call Args: call_id: The call ID to get speech-to-text for z No recording found for this call status_codedetail) transcriptbooking_intent)r/rrHTTP_404_NOT_FOUNDr))rlrecording_public_urlrqrrbooking_datetimetranscript_with_speaker_labelss rWget_speech_textrwrsW9A#115  TffzS{PJ 02P$ GGs>Az/advisors/notificationszNumber of records to skipstart current_userc Kd}|jtjtj|j dk(j }|j dk(sttjd|jtjjtjj|jk(j }|j}|jtjtj jjtj j"|k(j%}|jtjtj jjtj j"|k(tj j&dk(j%}|jtj jtj j"|k(j)tj j*j-j/|j1|j3} g} | D]X} d} d} | j4r{|jtj6jtj6j4| j4k(j }|r|j8} |j:} | j| j<| j>| j4| | | j@| jB| jDr | jDnd| j&| jFr| jFjInd| j*r| j*jIndd }| jK|[| ||||d Sw) z Get notifications for the authenticated advisor. Returns latest 5 notifications by default, with pagination for the rest. emailadvisorNo advisor ID found in tokenrnFNUnknown) idnotification_typetitlerlrq call_summarymessagecustomer_phone customer_nameis_readread_at created_at)datatotal total_unreadrxrd)&queryr+filterr|getfirsttyperrHTTP_403_FORBIDDENr&Advisoruser_idrrcount Notificationsr]scalarrorder_byrroffsetrdallrlCallsLogrqrrrrrrr isoformatappend)rxreryrduserr}r] total_countr notifications response_data notificationrqrcall_lognotification_datas rWget_notificationsrs E 88D> |/?/?/H!H I O O QD 99 !111  hhv~~&--fnn.D.D.OPVVXGJ(( 6''**+ f'':5 fh 88 6''**+ f'':5$$- fh HH f'':5h'',,. fUmEE%L M%     xx077''<+?+??eg %00 '44 //!-!?!?!''#++$(#++*99;G;U;U\77[d#++;G;O;O|++557UYAMAXAX,11;;=^b   ./5&:$  sPPz/advisors/notifications/latestc K|jtjtj|j dk(j }|j dk(sttjd|jtjjtjj|jk(j }|j}td||jtjjtjj |k(tjj"dk(tjj$dk(j'tjj(j+j }|sdd iS|j|j$|j,|j.|j0|j2r |j2nd |j"|j(r|j(j5nd d }d|iSw) zG Get single latest notification for the authenticated advisor. r|r}r~rnr]F missed_callrNr)rrrrrrrr)rr+rr|rrrrrrr&rrrprintrr]rrrrrrrrrr)reryrr}r]rrs rWget_latest_notificationrs 88D> |/?/?/H!H I O O QD 99 !111  hhv~~&--fnn.D.D.OPVVXGJ , #88 f'':5$$-..-?h'',,. eg ~oo);;##''&557C7Q7Q33W`''=I=T=Tl--779Z^  ! sI I z /advisors/notifications/read-allcK|jtjtj|j dk(j }|j dk(sttjd|jtjjtjj|jk(tjjdk(jtjjdtjj t#j$t&j(i}|j+dd|d iSw) zF Mark all notifications as read for the authenticated advisor r|r}r~rnFTrzMarked z notifications as read)rr+rr|rrrrrrr&rrrrupdaterrnowrutccommit)reryrresults rWread_all_notificationsr s 88D> |/?/?/H!H I O O QD 99 !111  XXf** + 2 2$$/$$- f$$d$$hll8<<&@ IIK WVH$:; sE(E*z/advisors/update-fcmreq_datareturncFK|jtjjtjj|j dk(j }|r2|j|_|j|j|ddiSw)Nr|rzFcm token updated successfully) rr&r+rr|rrtoken fcm_tokenrrefresh)rrerydb_users rWupdateFcmTokenr/s hhv{{#**6;;+<+< @P@PQX@Y+YZ``bG$NN  7 3 sBB!z/advisors/send-notificationcK|jtjjtjj|j dk(j }d}d}|rS|jG|j}tjddd|}tj|}td|d d iSw) Nr|zDealerPulse UpdatezUHi john, someone is missing you. Guess what, it's your client. Please call back asap.850z2:45)scorer)rrzSuccessfully sent message:rzNotification sent successfully) rr&r+rr|rrrr(Messagesendr)reryr message_title message_bodyregistration_tokenrresponses rWsendPushNotificationr@s hhv{{#**6;;+<+< @P@PQX@Y+YZ``bG(MjL    (!(!2!2  ''"") G!~~g.H . 93 CCz/advisors/{advisor_id}r]c$Kt||Sw)Nr])r7r]rerys rW read_advisorras rj 11)ro advisor_datac K|jdd}d|d< tjd i|}t|||}|j|j|j|j|j |j|j|jd}t!|d r|j"|d <|S#t$r,}t t j dt|d}~wwxYww) a: Create a new advisor with a user account Expects a JSON object with advisor details. The password field is optional - if not provided, a random secure password will be generated. Example request: { "full_name": "John Doe", "email": "john@example.com", "phone_number": "+1234567890", "status": "1", "department_id": 1, "type": "sales", "password": "securepassword123" // Optional } If password is not provided, the response will include a generated_password field. passwordN0rzInvalid advisor data: rn)rer}r)r full_namer| phone_numberr department_idrrgenerated_passwordrU)popr% AdvisorCreate ExceptionrrHTTP_400_BAD_REQUESTstrr8rrr|rrrrhasattrr)rreryrr}ecreated_advisorrs rWcreate_new_advisorris4 D1H L ''7,7%GhOO  $.. &&'44!(((66$$"** M 45.=.P.P *+ 3  33+CF84   s(C.B6BC.6 C+?'C&&C++C.r}cK|jtjjtjj|k(j }|st dd|d|jtjjtjjj|jtjj|k7j }|rt tjd|jr|jtjjtjj|jk(j }|r>|jr2|j|_ |j||jt!|||Sw)NzA staff member with id not foundrnzJA staff member with this name already exists. Please use a different name.)rer]r})rr&rrrrrrilikerrrr+nameaddrr:)r]r}rery db_advisorexisting_advisorrs rWupdate_existing_advisorrsU&..)001B1Bj1PQWWYJ ,ZL C  xx/66  &&w'8'89Z' eg 33_  xx $++FKKNNj>P>P,PQWWY   #-- t  RJ HHsG Gc$Kt||Sw)N)rer])r;rs rWdelete_existing_advisorrs RJ 77rz%/departments/{department_id}/advisorsrc(Kt||}|Sw)N)r)r<)rreryris rWread_advisors_by_departmentrs *"MJH Osz/advisors/{advisor_id}/scorerc&Kt|||Sw)N)rer]r)r=)r]rrerys rWupdate_advisor_score_endpointrs 2*E JJz/availability/{advisor_id}T)embed is_availablecKt|||}|stdd|d|j|j|jd|jd|jdk(rdnd d Sw) z Set an advisor's availability status. Args: advisor_id: ID of the advisor is_available: True to mark as available, False to mark as unavailable Returns: JSON response with updated advisor information rAdvisor with ID rrnzAdvisor z is now 1 available unavailable)rrrr)r>rrrr)r]rreryr}s rWset_advisor_availabilityrs"*"j,GG %j\<  jj&&..g//0Z]H]cp8qr  sA'A)z/dashboard/call-countsrOrPcbK |s!tjtdz }|stj}|jddd}t ||||}d||j |j dd S#t $r}td d t| d }~wwxYww)zM Get counts of unique and repetitive calls for the given date range. days;hourminutesecondrTrOrPsuccessr date_rangezError retrieving call counts: rnN) rrrreplacerBrrrr)rOrPrery call_countsrs rWget_call_countsrs !)*<BB- B* B%%B**B-z/dashboard/summaryzFilter by advisor IDcK |s!tjtdz }|stj}|jddd}t ||||}d||j |j ddS#t $r5}td t|td d t| d }~wwxYww) a. Get summary statistics for the given date range. Args: start_date: Optional start date for filtering (defaults to 30 days ago) end_date: Optional end date for filtering (defaults to current date) advisor_id: Optional advisor ID to filter statistics by advisor rrrrrTrrzError retrieving call summary: rrnN) rrrrrErrrrr)rOrPr]rerysummaryrs rWget_call_summaryrs  !)*<z!get_leaderboard..`s !$7"8rVkeyreverserrrz#Error retrieving leaderboard data: rnN)(rOrPr1rrrrrrrrrr&rrrrr-joinrtwilio_call_idtransferred_torrcall_date_time company_idrrrrroundsort isinstancerrrrrrr)rreryperformance_colorsrOrPrstart_datetime end_datetimerirr}r-r.r/r0r1rs rWget_leaderboardrDsl   '' ## ' 3J %h/H !33JH!))*hll6G6G6IJ''(,,2C2C2EF 88FNN+226>>3H3HC3OPTTV G((6#8#89>>!6!6!E!EIgIg!g&OO22g6J6JJ))88GJJFOO22nDOO22lBOO..,2B2BCT2UU  %'  "xx(=(=>CC!6!6!E!EIgIg!g &OO22g6J6JJ))88GJJF))00D8OO22nDOO22lBOO..,2B2BCT2UU %' 88F$9$9:??!6!6!E!EIgIg!g&OO22g6J6JJ))88GJJF))00E9OO22nDOO22lBOO..,2B2BCT2UU %' !" Q%1K%?3$F!1&9  2%#5g#> "R'#5e#< "R'#5d#; "R'#5f#= MM%jj ' 1 1*$4 ,%*+x4NH..0T\     i""$%8QA   s)X0W$W)(X0) X-26X((X--X0z/dashboard/recent-callsr*z Number of recent calls to returncbK |s!tjtdz }|stj}|jddd}|j t j jt j jt j jjdt j jjdt j jjdt j jt j jt j jt j j"t j$j&jd  j)t j t j j*t j j*k(j)t j$t j j,t j$jk(j/t j j|k\t j j|kt j j0|j3d k(j5t j jj7j9|j;}g}|D]}|j"rd nd }|j"d}|jrt=|jnd} |j?|j|j|j@|jBxsd|jD||jxsd|jxsd| |jFxsdd d|tI||jKtI||jKdtM|dS#tN$r} tQddt=| d } ~ wwxYww)aq Get a list of recent calls with details, sorted by date (newest first). Args: start_date: Optional start date for filtering end_date: Optional end date for filtering limit: Number of recent calls to return (default: 10) Returns: List of recent calls with details including transfer status and advisor name rrrrr call_daterrr,r& successfulfailedNnot transferredunknownrNot transferred) rlrrFrrtransfer_statusr recording_url call_durationr,Tr)rrrrrzError retrieving recent calls: rn))rrrrrr&rrrlr<label caller_name caller_numberrrNrOr-rrr outerjoinr:r;rr=rrrrdrrrrFrrr,r$rlenrr) rOrPrdrery calls_queryrcallrMcall_duration_strrs rWget_recent_callsrXrs&J !)*< Y%%..&2G2G2V2VVY%%448I8IIV..*<..(:**l.>.>?P.QQ Xfoo4499; < U5\ SU9 >D.2kklxO{{""3;?;M;MD$6$6 7S\  MM<<gg!^^!%!3!3!@y"&"5"5#2 $ 1 1 7R!%!3!3!9r!2 $ 1 1 F5F    (3BzBLLN1"X>HHJ[    4SVH=   s)P/PPP/ P,P''P,,P/ call_datetimec~tjd}|j|}|j}|dk\xs|dkS)zS Check if the given UTC datetime falls within off-hours (7 PM to 9 AM PST) r )pytzr astimezoner)rYpstpst_timers rW is_off_timerasC --- .C'',H ==D 2: !!rVz/dashboard/call-logc"K |jd}|jd}|jdd}|jd}|jd}|jd}|jd} |jd } |jd } |jd d } |jd d} | d z | z}t|tr tj|}t|tr tj|}|r t|}|r t|}tj}|s|tdz }|s|}t|tr$tj |dj}t|tr$tj |dj}tj|tjj}tj|tjj}| dk(rtj|tdd}tj|tdd}tj|tdd}tj|tdd}ndtj|tjj}tj|tjj}t!d|d|t!d|t!d|t!d|t!d | t!d!| | r| j#j%} |jd"}d#}d#}||j't(j*j-t(j*j.|k(t(j*j0d$k(j3}|r|j4}|j6}|j't(j8j;t(j<t(j8j>t(j<j>k(j-t(j8j@|k\t(j8j@|k}| r?|j-tCj$t(j8jD| k(}| r,|j-t(j8j>| k(}|rR|j-tCj$t(j8jFtCj$|k(}|r,|j-t(j<jH|k(}|s|rH|j-t(j8jH|k(t(j<jH|k(}|r<|j-t(j8jJjMd%|d%}|jO}tQjR|| z }|j-|t(j8jH|k(nd&t(j<jTd&k(jO}|j-|t(j8jH|k(nd&t(j<jTd'k(jO}|j'tCjVt(j8jXj[|j]j_}d} |r,t|tr|ja} n tc|} tetg| d(\}!}"te|"d)\}#}$tg|!d*d+tg|#d*d+tg|$d*}%| r| j%d,k(r8t!d-|j-t(j<jTd&k(}nJ| j%d.k(r7t!d/|j-t(j<jTd'k(}|j't(j8j4t(j8jht(j8j>t(j8j@jkd0t(j8jljkd1t(j8jJjkdt(j8jnt(j8jpt(j8jXt(j8jrt(j8jDt(j8jFjkdt(j<jTt(j*jtjkd2t(j*j4jkdj;t(j<t(j8j>t(j<j>k(j;t(j*t(j<jHt(j*j4k(}&| r<| j#} |&j-t(j8j>| k(}&| dk(r[|&j-|t(j8jH|k(nd&t(j8jrtvjxk(}&nh|&j-|t(j8jH|k(nd&t(j8j@|k\t(j8j@|k}&|rR|&j-tCj$t(j8jFtCj$|k(}&| r?|&j-tCj$t(j8jD| k(}&|r,|&j-t(j<jH|k(}&|r<|&j-t(j8jJjMd%|d%}&| r| j%d,k(r-|&j-t(j<jTd&k(}&n?| j%d.k(r,|&j-t(j<jTd'k(}&|&jO}'t!d3|'|&j{t(j8j@j}j|j| j}(g})|(D]}*|*jTrd,nd4}+|*jTd5}+|*jXrt|*jXnd6},t!|*d7|)j|*j4|*jh|*j>|*j|*jrtvjxk(|*jxsd8|*j|+|*jnxsd9|*jpxsd9|,|*jxsd:|*j|*jxsd;|*jDd<||||'|%tg| d=}-g}.|r|.jd>|d?|r|.jd@||r|.jdA|d?| r|.jdB| d?|)ss|.rqdCj|.}/d'dD|/dE|dF|g|-t|tr|jn|t|tr|jn|dG|||| dH||| | dIdJSd&|)|-t|tr|jn|t|tr|jn|dG|||| dH|'|| | dIdKS#t $rtj |d}YwxYw#t $r.tj |d}|jddd}YwxYw#t$rS}0dd#lL}1t!dLt|0t!|1jtdMdNt|0Od#}0~0wwxYww)Pz Get a filtered call log with details, sorted by date (newest first). Supports filtering by transfer status (successful/failed). rOrPrUTC sentimentr]rrM departmentr:pager+ page_sizer*%Y-%m-%drrrrrofftimer5rzFiltering with: start_date=z , end_date=zSentiment filter: zAdvisor ID filter: zCustomer phone filter: zTransfer status filter: zDepartment filter: rNr}%TFr'02:rGz'Filtering for successful transfers onlyrHz#Filtering for failed transfers onlyrFrr,zTotal matching records: missedrIrJz------rrKrLneutral)rrlr:rFrarrrMrrNrOr,r]rdre)r-total_successful_callstotal_missed_callsfiltered_count avg_call_timeavg_call_time_secondsz sentiment=''z advisor_id=zcustomer_phone='ztransfer_status='z, z#No records found matching filters: z for the date range z to r)rdr]rrM)r total_pagesrfrg)rrrrrfilters pagination)rrrrrzr{zError in call-log endpoint: rzError retrieving call log: rn)Orr@rr fromisoformat ValueErrorstrptimerr1rrrrrrrrstriplowerrr&rrrrrrrrrSr-r:r<rresentiment_scorer;rRlikermathceilravgrO select_fromsubqueryr total_secondsfloatdivmodr^rlrPrQrrN is_offtimerr*YESrrrrdrrrFrrr,r]rdr9rrrrr)2rreryrOrPrrdreq_advisor_idrrMrecallIdrfrgrrrBrC evening_start evening_end morning_start morning_endrr]rr} base_queryr-ryrsrtavg_duration_resultavg_duration_secondshours remainderminutessecondsrvrrrUrrVcall_transfer_statusrWr filter_info filter_strrrs2 rW get_call_logrs0n [[. ;;z*;;z51KK ,  \2 %56!++&78[[. -.{{61%KK R0 (i' j# & G%33J?  h $ K#11(; ' 3J %h/H !33JH j# &!**:zBGGIJ h $((:>CCEH!))*hll6G6G6IJ''(,,2C2C2EF i '%,,ZaDM"**:tAr{CK$,,ZaDM"**:tB|DK%--j(,,:K:K:MNN#++Hhll6G6G6IJL +N+;;|nUV "9+./ #N#345 ''789 ((9:; #J<01 #))+113J""4(   hhv~~.55fnn6L6LPW6WY_YgYgYlYlpyYyzAACG$ZZ ' 4 4  HHV__ % Y%%..&2G2G2V2VVV...@..,>  #** 6??556*DJ #**6??+I+IV+STJ #**4::foo6U6U+VZ^ZdZdenZo+opJ #**6+@+@+O+OSa+abJ #**..-?%%44 BJ #**6??+H+H+M+MPQR`QaabNc+deJ!&&( ii i 78    CPC\..-?bf%%,,4 eg    CPC\..-?bf%%,,5 eg  HHTXXfoo;;< = [,,. / VX  ! -y9':'H'H'J$(--@'A$"#&:";TBy!)R0u:b/3w<*;1S\"!!'' 5 "Y%%..&2G2G2V2VVY%%448I8II- 8 \\^FLL!?!?6!IJE i 'LLCPC\..-?bf**gkk9E LLCPC\..-?bf...@..,>E LLFOO,K,K!LPTPZPZ[dPe!efE LL 6??556*DE LL!6!6!E!E!WXE LL!>!>!C!CaGWWXDY!Z[E $$&,6 V%:%:%A%AT%IJ &&(H4 V%:%:%A%AU%JKkkm  ( 67  Xfoo4499; < VF^ U9  SU D37;;      YKq9 :    ZL9 :    !1.1AC D    !2?2C1E F+;/J @ L`ak`llpqypz{"x4NH..0T\ '("0#2 %*&   {  G%..z:F  G  K#,,XzB#++Br+J KZ   ,SVH56 "i""$%0Q9   sAECAC:AB0AC:AC|-AC:AAEAAAC:BAEBAB=B9AC:B<AB=B=AC:C3AC7C3AC:C6AC7C7AC:C: AEDAAEEAEEAEz/dashboard/advisor-statsc$K |jd}|jd}|jd}tj}|s|tdz }|s|}t |t r t j|}n2t j|t jj}t |t r+ t j|}|jddd }n2t j|t jj}|jt j"j%t j"j&|k(j)} | st+d d |d  |jt j,j%t j,j.|k(t j,j0dk(t j,j2|k\t j,j2|kj5} |jt j,j%t j,j.|k(t j,j0dk(t j,j2|k\t j,j2|kj5} | | z} | dkDr| | z dznd} |jt j6j&t j6j8t j6j:t j6j<t j6j>t j6j@t j6jBt j6jDt j6jFt j,j0 jIt j,t j6jFt j,jFk(j%t j,j.|k(t j6j8|k\t j6j8|kjKt j6j8jMjOdjQ}g}|D]}|jS|j&|j8r$tU||j8jWnd|j:xsd|j<|j>xsd|j@xsd|jBrt |jBnd|jDxsd|j0rdnd|jFd d| j&| jX| jZ| j\| j0d| | | t_| dd||jW|jWddS#t$rt j|d}YwxYw#t$r.t j|d}|jddd }YwxYw#t`$rS}ddl1}ted t |te|jft+d!d"t | d}~wwxYww)#a7 Get detailed statistics for a specific advisor within a date range. Args: request: Request body with advisor_id, start_date and end_date Returns: Dictionary with advisor statistics including calls missed, calls attended, and details of their last 10 calls r]rOrPrrrhrrrrrrrnFTrrbr*NrrKrJrrattendedrq) rrFrrrrNrOrdrr:)rrrrrr+) calls_missedcalls_attendedr-attendance_rater)rr}stats last_callsrz!Error in advisor-stats endpoint: rz%Error retrieving advisor statistics: )4rrrrr@rrr|r}r~rrrrrrr&rrrrrr-r;rrYrrr<rQrRrrNrOrr:r9rrrdrrr$rrrrr>rrrr)rreryr]rOrPrrBrCr}rrr-rlast_calls_queryrrVrrs rWget_advisor_statsrYs"E [[. [[. ;;z* !33JH j# & K!)!7!7 !C&--j(,,:K:K:MNN h $ S'55h? +33Br3R $++Hhll6G6G6IJL((6>>*11&..2C2Cz2QRXXZ)*Z@  xx 5 56==  ! ! 0 0J >  ! ! ( (E 1  ! ! / /> A  ! ! / /< ?  %' &"7"78??  ! ! 0 0J >  ! ! ( (D 0  ! ! / /> A  ! ! / /< ?  %' #^3 BMPQ/>K7#=WX HH""..++--,,----//..%%,, T%%..&2G2G2V2VVV%%44 B...@..,> Xfoo4499; < U2Y SU1 8 $D   ggZ^ZmZm22d6I6IJTTVsw!%!1!1!>Y"&"4"4 $ 1 1 7R!%!3!3!9r<@Y(, *"&"5"5  %jj))!(!6!6 ' 4 4!.. !-"0*#(!#<  %,668(224!  o K!)!2!2:z!J K S'00:F +33Br3R  SH   1#a&:; "i""$%:3q6(C   st\A,Z11YAZ1 )Y73UZ1\Y40Z13Y44Z173Z.*Z1-Z..Z11 \ :A\\  \z!/dashboard/call-details/{call_id}c K |jtjjtjj|k(j }|st dd|d|jtjjtjj|jk(j }d}|r|jr|jtjjtjj|jk(j }|r3|j|j|j|jrdndd}d |j|j|j|j xsd |j"|j$xsd |j&xsd |j(xsd |j*rt-|j*nd |j.xsd d |dS#t0$rS}ddl}t5dt-|t5|j6t ddt-|d}~wwxYww)a! Get detailed information about a specific call by its Twilio call ID. Args: call_log_id: The id of alpha_call_log table Returns: Dictionary with call details including customer information, recording URL, transcript, and call summary rzCall with Twilio ID rrnNrrq)rrrrTrrKrJrr) rlr:rFrrrrqrNrOrd)r call_details transfer_inforz Error in call-details endpoint: rzError retrieving call details: )rr&rrrrrr-r:r;rrrrrlr<rQrRrrqrNrOrrrrrr) rlreryrVr advisor_infor}rrs rWget_call_detailsrs 9 xx(// OO  ' ) %' -gYjA  !6!67>>  ! ! 0 0D4G4G G %'   ]99hhv~~.55!!]%A%AAeg !**#--$+$8$8,9,@,@jh   <<"&"5"5!00!%!1!1!>Y"&"4"4 $ 1 1 7R"oo3!%!3!3!9r<@Y *  "   0Q9: "i""$%4SVH=   s*I4HHI4 I1AI,,I11I4z'/dashboard/download-recording/{call_id}c&K ddlm}|j|j|j|k(j }|st dd|d|j}|st dd|t||d{\}}|rt d d ||s t d d |S7*#t$rS}ddl } td t|t| jt d d t|d}~wwxYww)z Download the MP3 recording for a specific call by its Twilio call ID. Args: twilio_call_id: The Twilio call ID to download the recording for Returns: Streaming response with the MP3 file r)rrzCall with call_id z# not found in alpha_calls_log tablernz.No Twilio call ID found for call with call_id NrzError streaming recording: z#Failed to create streaming responsez&Error in download-recording endpoint: zError downloading recording: )app.common.modelsrrrrlrrr:rHrrrrr) rlreryrrVr:streaming_responseerrorrrs rWdownload_recordingr<s>+ .xx!(()9)9W)DEKKM+G94WX  ,,GGWX  +HXZ*[$[!E 4UG<  "<  "!%\   6s1vh?@ "i""$%23q6(;   s<DBB2B0)B2/D0B22 D;AD  DDz/all-availablec$Kt|}|Sw)z8 Get a list of all currently available advisors )r@)reryavailable_advisorss rWget_available_advisorsrxs4B7 rz#/advisors/{advisor_id}/availabilityc&Kt||}|Sw)z4 Check if an advisor is currently available )r?)r]rery availabilitys rWcheck_advisor_availabilityrs(J7L rz/advisors/time-statsc K |j}|j}|j}tj|tj j }tj|tjj }t||z jdzDcgc]}|t|z} }g} ||jtjjtjj|k(j!} | st#dd|dt%|| | |} | j'| d | j| j(d | |j+|j+d d S|jtjj-} | s%d g|j+|j+d d S| D] } t%|| | } | j'| "d | |j+|j+d d Scc}w#t.$rS}ddl}t3dt5|t3|j6t#ddt5|d}~wwxYww)av Get aggregated statistics for an advisor's online time and calls within a date range. Args: request: JSON body with start_date, end_date, and optional advisor_id Returns: Dictionary with daily stats including online time, missed calls, and successful calls If advisor_id is not provided, returns stats for all advisors r+rNrrrrnrTrrr)rr}rrrrz&Error in advisor time stats endpoint: rz%Error retrieving advisor time stats: )rOrPr]rrrrrrangerrrr&rrrrrrextendrrrrrrrr)rreryrOrPr]rBrCidate_range_daysrr}rrirrs rWget_advisor_time_statsrse >f'' ##'' !))*hll6G6G6IJ''(,,2C2C2EF EJHWaLaKgKgjkKkElmElJ)::Elm  !hhv~~.55fnn6G6G:6UV\\^G#>NzlZd ""3 (9(9(;<&//*G*G!HIPP OO & &'** 4 OO $ $ + OO ) )T 1  &(  "-6y!)R0"5z"oQs7|B.?qWb@QRxx 5 56==  ! ! 0 0GJJ >  ! ! ( (E 1  ! ! / /9 <  ! ! / /7 :  %' 88F$9$9:AA  ! ! 0 0GJJ >  ! ! ( (D 0  ! ! / /9 <  ! ! / /7 :  %'   MMO!2*( 0!**#--  AT MrVz/advisors/daily-time-logs request_dataczK |jtjjtjjdk(j }|rt |jnd}|j}|j}|jtjjtjj|k(j }|stdd|d|jtjjtjj|k(tjj|k(tjjdk7jtjj j#}g} d} |D]} | j t%| z} | j&r| j&t%| znd} | jxsd}| |z } t)|d \}}t)|d \}}t |d d t |d d t |d }| j+| | ||dt)| d \}}t)|d \}}t |d d t |d d t |d }d|j|j,d|j/| ||dS#t0$rS}ddl}t5dt7|t5|j8tddt7|d}~wwxYww)zh Get detailed login/logout logs for an advisor on a specific day, adjusted for client timezone. TIMEZONE_OFFSETirrrrnNr)rrnr'rorp) login_time logout_timedurationduration_secondsTr)rr}r\ time_logs total_timetimezone_offsetz+Error in advisor daily time logs endpoint: rz*Error retrieving advisor daily time logs: )rr&rIrrrr^valuer\r]rrrrrrrrrrrrrrrrrrr)rrerytimezone_settingrr\r]r}logsrrlog local_login local_logoutrrrrr duration_strrrrs rWget_advisor_daily_time_logsrsCk88FOO4;; OO $5 5 %' :J#.445r((!,, ((6>>*11&..2C2Cz2QRXXZC:J:,V`8ab bxx(// OO & &* 4 OO $ $ 0 OO ) )T 1  (6??-- .ssu   C..9?+KKKQTQ`Q`3??Y_-MMfjL"005A  - -M &&6= E9%i4 GW!%j_Ac'l2->aG R?PQL   )+($4  *"-6y!)R0E 2aG R'8#g,r9JK jj))!**,"$.   k ;CF8DE "i""$%6`adefag`h4ijj ks*L;KKL; L8%AL33L88L;z /customersr+)ge)rlerfrgc j|dz |z}|jtj|j|j }|jtj }t j||z }g}|D]} | j} | j} |jtj tjjjtjj| k(j!} |jtj tj"jjt"j$| k(t"j&dk(j!} |jtj tj"jjt"j$| k(t"j&dk7j!}|jtj(tjj*jtjj| k(j!}|j-| j| | | | ||d!|||||ddS)Nr+F) customer_idrrr-r/received_callslast_call_time)rfrgrytotal_customersrr{)rr,rrdrrrrrrrr&rrrrRrr-customer_numberrrr<r)reryrfrgr customersrryrecordscustomerrrr-r/rrs rW get_customersr^s" Qh) #F"))&177 BFFHIhhx(..0O))Oi78KG .. ,, hhtzz&//*<*<=>EE OO ) )\ 9;;A68 xx 6+@+@+C+C DELL^MkMko{M{5C5J5Je5SUU[U[U] $**V-B-B-E-E"FGNN~OmOmq}O}7E7L7LPU7UWW]W]W_ $((6??+I+I"JKRR OO ) )\ 9;;A68  #;;*(&(,,  )D"&.   rVcPeZdZUedddZeed<edddd Zeed <y ) CustomerNameUpdate.rq)gtexamplerr+rbz Updated Name) min_length max_lengthrnew_nameN) rQrRrSrrr^rTrrrUrVrWrrs*SQ4K4#!^THcTrVrz/customers/update-name)raropayloadcK|jtjtj|jk(j }|st tjd|jj|_ |j|j||j|jdSw)z Update customer name by ID (ID in request body). Client should send JSON like: { "customer_id": 113, "new_name": "New Customer Name" } Customer not foundrn)rr)rr,rrrrrrrsrrrrr)rreryrs rWupdate_customer_name_by_idrs"xx!((8K8K)KLRRTH 11'  %--335HIIKJJx {{** rz/customers/detail/{customer_id}rc |jtjtj|k(j }|s t dd|jt jjt jj|jk(jt jjjjdj}|r|djnd}|jt jjt!j"t jjj%djt jj|jk(j't jjjt!j"t jjjj }|d}g}|D]>}|jt j(jt j(j|j*k(j-} |jt jjt jj|jk(j-}|j/|j0|j2|j4|j|j6|j8|j|j:| r | j<ndd A|j4|j|||d} d | iS) Nrrrnr*rr) rlr:r timestamprrqrrr,)rphonerecent_call_datetimeoverall_sentiment call_recordsr)rr,rrrrr&rrRrrr<rrdrrrrrPgroup_byrr;rrrlr:rrOrqrr) rrer last_10_callsr most_commonmost_common_sentimentcall_records_listrVr}records rWget_customer_by_idrsxx!(( )CDJJLH 4HII ! --1F1FF G &//00557 8 r  ?L=+::QU  OO + + JJv66 7 = =g F  --1F1FF G &//11 2 $**V__<<=BBD E (N((6>>*11&..2M2MtObOb2bcjjl88FOO,33FOO4P4PRVRdRd4delln  ||"11%33,,**//#33((18G--d " ""//&& 42) F F rVz/catch-phrases/graphc K|jdd}|jdd}|dz |z}|jd}|jd}|jd}|jd} |jd d } t|tr tj|}t|tr tj|}|r t|}|r t|}tj} |s| tdz }|s| }tj|tjj} tj|tjj} |jt j#t j$dk(j'}|s t)dd|j*j-d}|j/d}|jt0j2j#t0j2j4| k\t0j2j4| kt0j2j6|jdk(}|r|jt0j8j#t0j8j:|k(j'}|r6|j#t0j2j<|j>k(}| rg}| j/d}|D]m}|jAtCjDt0j2jFjId|j-jEdo|j#tK|}|jM}|jOt0j2j4jQjS|jU|jM}|jW}tYjZ||z }g}|D]`}g}|jFr|jFjEnd}|D]4}|j-jE|vs$|jA|6d}d}|j<{|jt0j8j#t0j8j>|j<k(j]}|r|j^}|j>}|jA|j:|j`|jb|jd|j4|jf|jh|jj|||dd c|Dcic]!}|j-jEd#} }|D]`}|jFs|jFjE}!|D]2}|j-jE}||!vs&| |xxdz cc<4b| jmD"cgc] \}}"||"d }#}}"|#jodd !||#||||d"d#S#t $rtj |d }YwxYw#t $r.tj |d }|jd d d }YwxYwcc}wcc}"}ww)$z Get catch phrases graph data for a given date range. Returns catch phrases graph data along with total count. rfr+rgr)rOrPr] catch_phrasesrrrhrrrrr CATCH_PHRASESrz#Catch phrases not found in settingsrn",r&rmrKN)rr) rrlr:rr<rrrqcatch_phrases_foundr}r)phraserc |dS)NrrUr3s rWr5zbdc_dashboard..s!G*rVTr6)rfrgryr-)calls graph_datar{)8rr@rrr|r}r~rr1rrrrrrrrIrrrrrrsplitr&rr<r=rrr;rrrrtwilio_recording_textrr rrrrdrrrrrrrlr:rrQrRrqitemsr?)$rreryrfrgrrOrPr]filter_catch_phrasesrrrBrCcatch_phrases_settingsrcatch_phrases_listcalls_log_data_queryr} conditionsphrasesrcalls_log_datacalls_log_data_paginatedr-ryretCallsrVrr r,r phrase_countstranscript_textrrs$ rW bdc_dashboardr"s ;;vq !D K,IQh) #F\*J{{:&H\*J";;7{{:'<=H*c" C!// ;J(C  G--h7H #J/ !(+ LLNE YB// %%j(,,2C2C2EFN##Hhll.?.?.ABLXXh/66 ( eg "4YZZ*0066s;M&,,S188FOO4;;&&.8&&,6""l&6&67H&II ((6>>*11&..2C2Cz2QRXXZ #7#>#>v?]?]ahauau?u#v  &,,S1F   djj)N)NOTTWXY_YeYeYgYmYmYoXppqUrs t3::3 ;KL)--/N3<>#**62)     *hhv~~.55fnn6Q6QSWSfSf6fgnnpG&00 ' 4 4 ''||"11(("11!--"00//#6$&  )@>PP=O6V\\^))+Q.=OMP  % %"88>>@O,--/_,!&)Q.)-+002  3MFE 3 OO,dO; "&&    e C!**:zBJ C  G((:>H''R2'FH GjQs{B[8Z +[8<Z3O[8(D[8<&[-"[86A[88$[8[2+"[8 Z0,[8/Z00[833[*&[8)[**[8z/executive-summary/datac K|jd}|jd}|jd}|jdd}tj}|s|tdz }|s|}|j t j jt j j|k(j}|j t jjt jj|k\t jj|k} | j} | jt jjtjt jjj!dj#t jjj%t'dj)d j+} |j t j jt j j,tjt/t j0j2d k(d fj!d tjt/t j0j2d k(d fj!dj5t j0t j0j6t j jk(jt j0j8j;||j#t j jt j j,j+} |j t j jt j j,tj<t jj>j!dtjt/t j j2dk(d fj!dtjt/t j j2dk(d fj!dj5t jt jj6t j j@k(jt jjj;||j#t j jt j j,j+} |j t j jt j j,tjBt/t jjDdk(dft jjDdk(dft jjDdk(dfdj!dtjt jjDj!djGt jt jj6t j j@k(jt jjj;||j#t j jt j j,j+}d}|r<|j@r/|j t jt j0j2j5t j0t jjHt j0jHk(jtKt jj|j@k(t jj6|j@k(j%t jjj'j+}| | Dcgc] }|d|d dc}| Dcgc]}|d|d |d |d!d"c}| Dcgc]}|d|d |d |d!|d#d$c}|Dcgc]%}|d|d |d rtM|d nd|d!d%'c}|xsgDcgc]a}|jj|jj>|jj|j2rd&n|j2d'nd(d)cc}d*Scc}wcc}wcc}wcc}wcc}ww)+zr Get executive summary for a given date range. Returns executive summary data along with total count. rOrPr]rrrr call_countr*Fr+r/Tanswered_callstotal_call_timer online_countr offline_countPositive?NeutralNegativeNelse_ avg_sentiment rated_callsr)numberrr5)r]r,r/r)r]r,total_call_time_seconds online_hours offline_hours)r]r,r%r&rGrqznot-transferred)rlrrr)incoming_calls top_callers advisor_statsadvisor_time_statssentiment_statscustomer_history)'rrrrrr&rrrrrr<r with_entitiesrRrrPrrrrdrrrr-rrSr;rYbetweenrrOrrrr9r:r r)rreryrOrPr]rrr}rUr-r.r/r0r1r2cstatrVs rWget_executive_summaryr7s\*J{{:&H\*J{{:'<=H JJLE YB// hhv~~&--fnn.?.?:.MNTTVG((6??+22&&*4&&(2K !&&(N   OO ) ) JJv)) * 0 0 >  &//// 0 $|$ % r   NN   NN $ $ JJtV2299UBAFG H N N~ ^ JJtV2299TA1EF G M MN^ _  6((&*?*?*N*NRXR`R`RcRc*c d %%33;;JQ R &..##V^^%=%= >   NN   NN $ $ HHV__22 3 9 9:K L JJtV^^22c91=> ? E En U JJtV^^22c91=> ? E Eo V   6??FOO$B$BfnnFaFa$a b ..66z8L M &..##V^^%=%= >   NN   NN $ $ HH__44 BCH__44 A3G__44 BDI  eO$ JJv66 7 = =m L  foov==A\A\\ ] ..66z8L M &..##V^^%=%= > #*7'' HH%%,, Y%%..&2G2G2V2VVVOO11W5I5IIOO22g6J6JJ Xfoo4499; < SU! ()ALMA1Q4!A$7M(  ($ #1g $Q $Q"&q'   (  - -$ #1g $Q+/7 $Q!%a   - *  *$ #1g $Q377tAw#Aw   *  ,1r1  2$  ==++ MM77"mm::*.++,t{{G^8du   2  9$ $M    sCb*g,f'>gf,g$f1 g*f6 2 gr/)rery current_yearrrrow month_idxs rWincoming_calls_reportr?S s<<>&&L HH Wfoo<<=CCGL 6??%%&,,]; v,,33usIIz/reports/top-calling-numbersc. K|jd}|jd}t|tr tj|}t|tr tj|}tj}|s|tdz }|s|}|r t|}|r t|}tj|tjj}tj|tjj}|jt j"j$t j"j&t)j*t j"j,j/d t)jt j"j0j/d t)jt j"j2j/d t)jt j"j4j/d t)jt j"j6j/d t)jt j"j8j/dt)jt j"j:j/dt)jt j"j<j/d j?t j@jBdk(t j"j0|k\t j"j0|kjEt j"j$t j"j&jGtId jKdjM}g} |D]} | jO| j&| jP| j2xsd| j$| jR| jTrt| jTnd| jVxsd| j4| j8| j6d d| iS#t $rtj |d}YwxYw#t $r.tj |d}|jddd}YwxYww)a Get top 10 calling numbers (numbers that called the most) with their details. Request body: { "start_date": "2023-01-01", // Optional, defaults to 30 days ago "end_date": "2023-01-31" // Optional, defaults to current date } rOrPrhrrrrrrrrQrlrr last_durationlast_transcriptr}r*rrrK) r:r<rrrrrqrlrrr),rr@rrr|r}r~rrrr1rrrrrr&rrRr:rrrrPr<rQrlrrrOrqrrrrrrrdrrrrrArB) rreryrOrPrrBrC top_callsrrVs rWtop_calling_numbersrDt s\*J{{:&H*c" C!// ;J(C  G--h7H LLNE YB// #J/ !(+%%j(,,2C2C2EFN##Hhll.?.?.ABL  OO ) ) OO * * JJv)) * 0 0 > HHV__33 4 : :;K L HHV__00 1 7 7 F HHV__,, - 3 3I > HHV__11 2 8 8 H HHV__44 5 ; ;G C!**:zBJ C  G((:>H''R2'FH GsM3TR5 TS1QT5STST3TTTTz/reports/worst-attendeesct K|jd}|jd}t|tr tj|}t|tr tj|}tj}|s|tdz }|s|}|r t|}|r t|}tj|tjj}tj|tjj}|jt j"j$t'j(t+t-t j.j0d k(t j.j2fj5d t'j(t+t-t j.j0d k(t j.j2fj5d t'j6t-t'j(t+t j.j2d k(dft'j8t-t j.j0d k(dfd dzdj5dt'j6t-t'j(t+t j.j2d k(d ft'j8t-t j.j0d k(dfd dzdj5dj;t j"j<dk(t j>j@|k\t j>j@|kjCt j.t j.jDt j"j2k(j;t j.jF|k\t j.jF|kjIt j"j$jKt'j(t+t j.j2d kDjMtOdjQdjS}g} |D]Q} | jU| j$| jV| jX| jZd| j\ddSd| iS#t $rtj |d}Y/wxYw#t $r.tj |d}|jddd}YCwxYww)z@ Get top 10 worst call attendees based on missed calls. rOrPrhrrrrrFr/Tattended_callsrrbr+r#r5missed_calls_percentageattended_calls_percentager}r*rm)r,rraverage_missedaverage_attendedr/rr@rrr|r}r~rrrr1rrrrrr&rrrrr!rr-rrrPr>rrrrr<r9r;rYrhavingrrrdrrr/rFrGrH rreryrOrPrrBrCr/rr6s rWworst_call_attendeesrN s^\*J{{:&H*c" C!// ;J(C  G--h7H LLNE YB// #J/ !(+%%j(,,2C2C2EFN##Hhll.?.?.ABL  NN $ $ JJxf&;&;&B&Be&KVMbMbMeMe%f gh i o op~  JJxf&;&;&B&Bd&JFLaLaLdLd%e fg h n no A JJZZ)>)>)A)A BCqH#N((4)>)>)E)E)NPQ(RZ[#\]`cc   e-. JJZZ)>)>)A)A BCqH!L((4)>)>)E)E)Mq(QYZ#[\_bb   e/0# &  NN  9 , OO * *n < OO * *l :   ! !  ! ! 0 0FNN4E4E E    ! ! / /> A  ! ! / /< ?  &..** +  8F$9$9$<$<=>B C $01 2 r MR D  NN --"11!%!=!= >a@#'#A#A"B! D    D>[ C!**:zBJ C  G((:>H''R2'FH GM3V8U V8U>1S'V8U;7V8:U;;V8>3V51V84V55V8z/reports/best-attendeesct K|jd}|jd}t|tr tj|}t|tr tj|}tj}|s|tdz }|s|}|r t|}|r t|}tj|tjj}tj|tjj}|jt j"j$t'j(t+t-t j.j0d k(t j.j2fj5d t'j(t+t-t j.j0d k(t j.j2fj5d t'j6t-t'j(t+t j.j2d k(dft'j8t-t j.j0d k(dfd dzdj5dt'j6t-t'j(t+t j.j2d k(d ft'j8t-t j.j0d k(dfd dzdj5dj;t j"j<dk(t j>j@|k\t j>j@|kjCt j.t j.jDt j"j2k(j;t j.jF|k\t j.jF|kjIt j"j$jKt'j(t+t j.j2d kDjMtOdjQdjS}g} |D]Q} | jU| j$| jV| jX| jZd| j\ddSd| iS#t $rtj |d}Y/wxYw#t $r.tj |d}|jddd}YCwxYww)zA Get top 10 best call attendees based on attended calls. rOrPrhrrrrrFr/TrFrrbr+r#r5rGrHr}r*rm)r,rrrI avg_attendedrrKrMs rWbest_call_attendeesrR- s^\*J{{:&H*c" C!// ;J(C  G--h7H LLNE YB// #J/ !(+%%j(,,2C2C2EFN##Hhll.?.?.ABL  NN $ $ JJxf&;&;&B&Be&KVMbMbMeMe%f gh i o op~  JJxf&;&;&B&Bd&JFLaLaLdLd%e fg h n no A JJZZ)>)>)A)A BCqH#N((4)>)>)E)E)NPQ(RZ[#\]`cc   e-. JJZZ)>)>)A)A BCqH!L((4)>)>)E)E)Mq(QYZ#[\_bb   e/0# &  NN  9 , OO * *n < OO * *l :   ! !  ! ! 0 0FNN4E4E E    ! ! / /> A  ! ! / /< ?  &..** +  8F$9$9$<$<=>B C $23 4 r MR D  NN --"11!%!=!= >a@#==>a@    D>[ C!**:zBJ C  G((:>H''R2'FH GrOz/reports/time-utilisationc K|jd}|jd}t|tr tj|}t|tr tj|}tj}|s|tdz }|s|}|r t|}|r t|}tj|tjj}tj|tjj}tj }tj"} |j%t'| j(t*j-d j/| j(|k\| j(|kj1t'| j(t*j3t5j6| j8d kDj;} |j%|j<j-d |j>j/|j@d k(j;} |j%| jBjD| jBj>| jBj(jG| jI| tKd j;} |j%| jBj(| jBj>t5jLt5j6| j8d j-djO| tQ| jD| jBjDk(t'| j(t*| jBj(k(j1| jBj(| jBj>jS| jBj(| jBj>jU} g}| D]}|jVxsd }tY|d\}}tY|d\}}t[|ddt[|ddt[|d}|j]|j(r|j(j_nd|j>|d|dddddS#t $rtj |d}YwxYw#t $r.tj |d}|jddd}YwxYww)z. Get advisor time utilisation report. rOrPrhrrrrrr\rr]r}truerrnr'rorpr)rr,total_time_onliner+r)ryrfrgr)0rr@rrr|r}r~rrrr1rrrrr&rrrrr\rrPrrrLrrrrrrrr5r]rr9rcoalescerSrrrrrr^rr)rreryrOrPrrBrCrractive_dates_subq advisors_subq advisor_dates time_statsrr6rrrrrtime_strs rWadvisor_time_utilisationr] s;\*J{{:&H*c" C!// ;J(C  G--h7H LLNE YB// #J/ !(+%%j(,,2C2C2EFN##Hhll.?.?.ABLnnGH  ""D ) / / ;  !!^3!!\1 3 $x(($/ 0 //014 5   JJ  \ *      ) *    OO & & OO % %    ( ( ] # !7 8   OO $ $ OO % % MM$((8#9#9:A > D DEX Y   ##}'A'AAX&&-1I1II   -//**MOO,E,E F -//**MOO,E,E F $ D..3! !-6y!)R0%j_Ac'l2%6aG R7HI 15DMM++-C NN!)    u C!**:zBJ C  G((:>H''R2'FH GsM3US2 UT1RU2TUTU3U UUUz/reports/customer-ratingsc K|jd}|jd}t|tr tj|}t|tr tj|}tj}|s|tdz }|s|}|r t|}|r t|}tj|tjj}tj|tjj}|jt j"j$t j"j&t j"j(t+j,t/t j0j2d k(d ft j0j2d k(d ft j0j2d k(dfdj5dt+j6t j0j2j5dj9t j"j:dk(t j0j<|k\t j0j<|kj?t j0t j0j@t j"j(k(jCt j"j$t j"j&jEt+j6t j0j2dkDjGtIdjK}g} |D]} | jLtO| jLnd} | dkDrd n| dkrd nd } | jQ| j$| j&| j(tS| d| | jTdd| iS#t $rtj |d}YwxYw#t $r.tj |d}|jddd}YwxYww)zF Get advisor-wise customer ratings based on sentiment scores. rOrPrhrrrrrrrrr r!r"Nr#r%r&r}rr5)r]r,raverage_sentimentsentiment_categorytotal_rated_callsr)+rr@rrr|r}r~rrrr1rrrrrr&rrrrrrrrrrPrrrr<r9r;rrLrrrr%rrr>r&) rreryrOrPrrBrCr1rr6r%r`s rWadvisor_customer_ratingsrb sn\*J{{:&H*c" C!// ;J(C  G--h7H LLNE YB// #J/ !(+%%j(,,2C2C2EFN##Hhll.?.?.ABL  NN   NN $ $ NN ' ' HH__44 BCH__44 A3G__44 BDI  eO$ JJv66 7 = =m L   NN  9 , OO * *n < OO * *l :  OO OO * *fnn.I.I I   NN   NN $ $   6??::;a? @ $' ( ?D D595G5G5Sd001YZ +81+U C!**:zBJ C  G((:>H''R2'FH GsM3Q5P Q5P;1N$Q5P84Q57P88Q5;3Q2.Q51Q22Q5z/customers/searchz'Search by customer name or phone numberqc |jtjjt tjj j d|dtjjj d|djdj}|Dcgc]&}|j|j |jd(c}Scc}w)z Search customers by name or phone number (case-insensitive, partial match). Returns: id, customer_name, customer_phone rmr*)rrr) rr&r,rr rrrrdrr)rcreryresultsrs rWsearch_customersrfZ s !  --33as!H=,,22Qqc8<  r  $    H ++%33&33    s0+Cz/customers/call-historyc |jd}|jdd}|jdd}|jd}|jd}|s tdd |d kDrd }t|tr t j |}t|tr t j |}t j}|s|tdz }|s|}|r t|}|r t|}t j|tjj} t j|tjj} |j!t"j$j't"j$j(|k(j+} | s tdd |dz |z} |j!t"j,j't"j,j.| j0k(t"j,j2| k\t"j,j2| kj5} t7j8| |z }|j!t"j,t"j:j<j?djAt"j:t"j,jBt"j:j0k(j't"j,j.| j0k(t"j,j2| k\t"j,j2| kjEt"j,j2jGjI| jK|jM}tOtP}|D]\}}|jRxsdjU}|dk(rd}n |dk(rd}nd}||j2jWjY|j(|jZ|jR|||j\|j^|j2|j`|jbd g}te|jgdD]}|jY|||d| jh| j0| ||||ddS#t $rt j|d }YwxYw#t $r.t j|d }|jd dd}YwxYw)Nrrfr+rgr)rOrPizCustomer ID is requiredrnrbrhrrrrrrrr,rKpositivenegativerr) rr:rdsentiment_iconr,rrrrqrlT)r8)rrrV)rrr-historyr{)5rrr@rrr|r}r~rrrr1rrrrrr&r,rrrrrRrr<rrrrrrPrSr;rrrrdrrLlistrrrrr:rrOrqrlsortedkeysr)rreryrrfrgrOrPrrBrCrrr-ryrgroupedrVr,rdrjrkrs rWget_customer_call_historyrpz sk ++m,K ;;vq !D K,I\*J{{:&H 4MNN3 *c" C!// ;J(C  G--h7H LLNE YB// #J/ !(+%%j(,,2C2C2EFN##Hhll.?.?.ABLxx(//0B0Bk0QRXXZH 4HIIQh) #F((6??+226??3P3PT\TiTi3i39??3Q3QUc3c39??3Q3QUa3a56;UW  ))K)34K  OO NN $ $ * *> :   NN OO * *fnn.I.I I  --1F1FF...@..,>  &//00557 8  y  # ($G#l))/R668  "'N * $'N&N##((*+22''"11--,(((++''//|| 4 $,Gw||~t4T]  5"//"//"&"  q C!**:zBJ C  G((:>H''R2'FH Gs$?T%T4T10T143U+*U+z /call/processc`K|jd{}|jd}|s td|jtj j tj j|k(j}|s td| t||d{tjd|jS77,#t$r0}tjdcYd}~|jSd}~wwxYw#|jwxYww)NrlzCall ID is requiredCallzCall processed successfully.)rz/Something went wrong while processing the call.)jsonrr3rr&rrrrr2r9r4postcloserr)rreryrrlrVrs rW process_callrv s  Dhhy!G  2 33 88FOO $ + +FOO,>,>',I J P P RD 00$T2...}}%CD    / Y~~&WXX  Y  sdD.CBD.C.C/CD.C D&D;D<DD.DDD++D.)rrfastapirrrrrrr r sqlalchemy.ormr typingr r rrrrrrrpydanticrr sqlalchemyrrrrrrrrrr r!r"fastapi.responsesr#)app.advisor_service.services.time_servicer$ app.commonr%r&firebase_adminr'r(loggingapp.common.ai_helpersr)app.common.constantsr*rr+r,r-app.common.databaser.app.common.twillio_helperr/r0app.common.utilsr1app.utils.exceptionsr2r3app.utils.responser4services.advisor_servicer6r7r8r9r:r;r<r=r>r?r@services.auth_utilsrAservices.dashboard_servicerBrCrDrEzoneinforF-app.twilio_service.services.recording_servicerGrHrI&auth_service.services.settings_servicerJcalendarrK collectionsrLr]router Certificatecredrinitialize_apprNrYr[r`rrr^rjrrwrrrrtUpdateTokenRequestrr AdvisorDetailrHTTP_201_CREATEDrput AdvisorUpdaterdeleterrpatchrboolrrr r rrrDrXrarrrrrrrAdvisorDailyTimeLogResponserdictrr HTTP_200_OKrrrr7r?rDrNrRr]rbrfrprvrUrVrWrs YYY",,>>%mmmm/K&&$4(<<&W+C'    1 r&># {@Ad d#(y(yi %i% KW__(=>&/   ?4 12).s@g)hH3H3H" %&q&AB&/ 0R RRR'Rh ,-&/ 0000.0d ./&/ 0   0 D #$&/ 0(( #s(^ %  )*&/ 0 #s(^+@ $W5J5JK&/ 02222L2&=&=>c&/ 09999?9v $W__E&/ 0 #I#I  " "#I #I #IF#IJ'(&/ 08888)8 3DDYZ&/ 0[,W__M&/ 0 KK K K KNK )*c.&/ 0     +B $% ;t&/ 0 $ $ $  $  $  #s(^ $ &$ L $% ;t&/ 0 , , ,  ,  ,  #s(^ , &, \ %& ;t&/ 0 $ $ $  $  $  #s(^ $ '$ L ! ;t %d8N O&/ 0 + + +  +   +  +  #s(^ + "+ Z &/ 0F F F F  #s(^ F F P %& $S &/ 0t t t t  #s(^ t 't l &'%*4[#(;r'IJ&/ 0 \ "\ x \  \   \  \  #s(^ \ (\ | "x "D " "#"3i&/ 0w #s(^w w w  #s(^ w $w r  '(#3i&/ 0 U #s(^U  U  U  #s(^ U )U n /0&/ 0H H H H  #s(^ H 1H T 56&/ 09 9 9 9 79 v T$sCx.-AB&/ 0C 1$sCx.Q&/ 0    R  #$'+Cy&/ 0Mf $MfMfMf%Mf`.` (9\9\]$(I&/ 0Kk!KkKkKk #s(^ Kk^KkZL.!(")."9$Q1~$)"s$;VwVV"V/VpUU  % ++ -'+3ifo$^4# -> -dC7>v?C?W?D?F #$"3i&/ 0Q #s(^QQQ%Qh %&"3i&/ 0Y #s(^YYY'Yv ,-&/ 0.@ +,"3i&/ 0W #s(^WWW-Wr '("3i&/ 0\ #s(^\\\)\| &'"3i&/ 0\ #s(^\\\(\| ()"3i&/ 0o #s(^ooo*ob ()"3i&/ 0X #s(^XXX*Xv  3$M N&/ 0 !> &'"3i&/ 0v #s(^vvv(vp_&/ 0 rV