o cBj<4@srdZddlZddlZddlmZmZmZmZddlmZddl m Z m Z m Z m Z mZmZeeZeedddZdad d Zd efd d Zde d e fddZdee ee fd e ee ffddZde ee fd e ee ffddZdeed eeeeeeeffddZdede ge fde ee fd e fddZdd d!d"ed#eed$eed%eed&ed'ed e ee ffd(d)Zd*ee e ee fd e ee ffd+d,Z d"ed-ed e ee ffd.d/Z!  d6d"edee ee fdeed e ee ffd0d1Z"  d6d"edee ee fdeed e ee ffd2d3Z#  d6d"edee ee fdeed e ee ffd4d5Z$dS)7ucLive PCA panel data for MCube AI — mirrors dashboard stats, analytics, agents, calls, objections.N)datedatetime timedeltatimezone)Decimal)AnyCallableDictListOptionalTuple)hoursminutescsBtdurddlmddlm}fddtD}||atS)NrConfig)DatabaseHandlercs i|] }|r|t|qS)isuppergetattr).0keyrr=/home/aiteam/pcaa-dev/dashboard-backend/mcube_ai_analytics.py s z_get_db..) _db_handlerconfigr db_handlerrdir)rcfgrrr_get_dbs   r returncCsttSN)rnow_ISTrrrrr _ist_todaysr%valuecCsdt|ttfr |St|trt|St|tr"dd|DSt|tt fr0dd|DS|S)NcSsi|] \}}|t|qSr _serializerkvrrrr$z_serialize..cSsg|]}t|qSrr')rr+rrr &z_serialize..) isinstancerr isoformatrfloatdictitemslisttuple)r&rrrr(s  r(statscCs|siStt|dp dt|dpdt|dpdt|dp$dt|dp,dt|dp4dt|dpr?rArBrC)r(intgetroundr1)r6rrr_compact_stats*s&rGmetadatacCs|pi}|d}|d}|d}|d}t|trC|dp#i}|s+|d}|p6|dp6|d}|pB|dpB|d}||||d|d d S) N groupname date_fromdate_tosnapshotfiltersdateFromdateTo active_tab route_path)rIrJrKrPrQ)rEr/r2)rHmetarIrJrKrLrMrrr_extract_filtersAs"      rSmessagecCst|pd}|sdSt}td|r |}||dfStd|r4|tdd}||dfStd |rH|td d|d fStd |r]|jdd }||dfSdS)z(Map user wording to a date range in IST.)NNNz \btoday\btodayz \byesterday\bdays yesterdayz<\bthis week\b|\blast 7 days\b|\bpast week\b|\bthis week'?s\b last_7_daysz \bthis month\b|\bcurrent month\b)day this_month) strlowerstripr%researchr0rreplace)rTtextrVdstartrrr_detect_period_from_messageVs        rhlabelfnfactsc CsRz|WSty(}ztd||t||di|<WYd}~dSd}~ww)Nzpanel_data %s failed: %serrors) Exceptionloggerwarningr_ setdefault)rirjrkexcrrr _safe_runksrrT )include_agents agent_limitbidrIrJrKrtruc CsXt|||||}|||d}|r*|j|||||d} | pg|d<| r*| d|d<|S)N)rJrKr6limitagent_call_countsrtop_agent_by_call_volume)rGget_location_statsget_agent_call_counts) dbrvrIrJrKrtrur6bundleagentsrrr_period_bundlets    rrowscCsRi}|s|S|D]}t|dpd}||dt|dp!d||<q|S)N sentimentunknownrcount)r_rEr`rD)rtotalsrowrrrr_summarize_sentiments$rcall_idc Cst}t|}t|}d|ddtdd}t|||p i}t|||p*i}t|||p4i}t|||p>i}t| dpGd}t |dkr]|ddd |d<d |d <||d <||d <||d<||d<|S)N call_detaildatabase_live_query Asia/Kolkata)r today_ist)scopersource reference transcriptrUipz...(truncated)Ttranscript_truncatedcall analyticsbant) r r_r%r0r(get_call_by_idget_call_analyticsget_bant_analysisget_call_transcriptrElen) rvrr}rkrrrtranscript_objtranscript_textrrrbuild_call_detail_panel_datas.  rc sNt|pi}tt|d|d}|d}t}||tdd}|tdd}ddd tt  d d d d | Ddd} i} t | d<t ||dd| d<t || d<t dd| d<|s~|rt ||| d<| | d<t |\} } } | rd| it | | dd| d<||tdfdd| }|rt|| d<td fd!d| }|r|| d <td"fd#d| }|r|| d"<|d$| d%<td&fd'd| }|r |dd| d&<|d$| d(<td)fd*d| }|r!|| d)<td+fd,d| }|r=|p6gdd| d+<td-fd.d| }|rY|pRgdd| d-<td/fd0d| }|rzt|dd1| d/<t|| d2<td3fd4d| }|r|pgdd| d3<td5fd6d| }|r|pgdd| d5<td7fd8d| }|r|pgdd9| d7<td:fd;d| }|rt|tr|n|d<pg}|dd| d:<|r|d$| d=<td>fd?d| }|r%t|tr|n|d<pg}|dd9| d><| S)@zOFull dashboard panel context with explicit today / all-time / filtered periods.rIrJrKrWrXr[ dashboardrrz%Y-%m-%d %H:%M:%S)rrnow_istcSsi|] \}}|r||qSrrr)rrrrr,z.build_dashboard_panel_data..uUse periods.today for 'today' questions, periods.all_time for lifetime totals, and question_focus when the user asks about a specific time range. Never invent call counts — use stats and agent_call_counts from this data.)rrrrMnoterVF)rtrZr\Nall_timedashboard_filterperiodsri)ruquestion_focusdashboard_statscSr")r{rrvr}rI primary_from primary_torrz,build_dashboard_panel_data..analytics_overviewctSr")r(get_analytics_overviewrrrrrr.rycsjddS)Nrw)r|rrrrrr.rrzagent_quality_leaderboardcrr")get_agent_leaderboardrrrrr rtop_agent_by_quality_scorequality_by_agentcrr")r(get_quality_by_agentrrrrrr. call_purposescrr")r(get_call_purpose_frequencyrrrrrr.objections_and_concernscrr")r(get_concerns_frequencyrrrrr%r.sentiment_by_locationcrr")get_sentiment_by_locationrrrrr-rrsentiment_totalsquality_by_locationcrr")r(get_quality_by_locationrrrrr6r.busy_locationscrr")r(get_busy_locationsrrrrr>r.groupscs Sr")get_all_groupnamesr)rvr}rrrDs  recent_callsc stjdddddS)NrrrxoffsetrJrKr(get_filtered_raw_callsrrrrrJcalls latest_call today_callsc stjdddddS)Nrrrrr)rvr}rI today_strrrr`r)rSr r_rEr%r0rrr#r$strftimer3rrhrrr(rr/r4)rvrHrTrMdashboard_from dashboard_torV yesterday_str week_fromrkrq_fromq_toq_labelr6overview agent_counts leaderboardrrconcernssentiment_rowsrrrrecentrrr)rvr}rIrrrrbuild_dashboard_panel_datas                 rcCs@|pi}|ddkr|drt|t|dSt|||dS)NrrrrT)rErr_r)rvrHrTrRrrrbuild_panel_datausrc Csft|pi}zt|||d}||d<||d<W|Sty2}ztd||WYd}~|Sd}~ww)Nr panel_datalive_analyticsz'attach_live_analytics failed bid=%s: %s)r2rrmrnro)rvrHrTrRpanelrqrrrattach_live_analyticss  r)NN)%__doc__loggingrbrrrrdecimalrtypingrrr r r r getLogger__name__rnr$rr r%r(r_rGrSrhrrboolrDrrrrrrrrrrs    & ",* * !  A