o «=)jÅ>ã@sèdZddlmZddlZddlZddlmZmZmZddl m Z ddl m Z e  e¡Zd;d d „Zddd„Zd?dd„Zd@dd„ZdAd!d"„ZdBd$d%„Z dCdDd*d+„ZdEd1d2„Z  dFdGd6d7„ZdHd9d:„ZeZeZeZdS)IzV LeadSquared activity push helpers shared by call_processor and orchestrate_pipeline. é)Ú annotationsN)ÚAnyÚDictÚOptional)ÚDatabaseHandler)ÚLeadSquaredServiceÚcallúDict[str, Any]ÚreturnÚstrcCs¨| d¡pd ¡}t| d¡p| d¡pdƒ ¡}|r|St| d¡p$dƒ ¡}t| d¡p/dƒ ¡}t| d¡p:dƒ ¡}|d krF|rF|S|dkrN|rN|S|pS|pS|S) NÚ directionÚinboundÚcustomer_phoneÚcustomer_callinfoÚÚcalltoÚcallfromÚclicktocalldidÚoutbound)ÚgetÚlowerr Ústrip)rr rrrr©rúD/home/aiteam/pcaa-dev/dashboard-backend/leadsquared_activity_push.pyÚpick_customer_phones    rÚrawc Cs^| d¡| d¡p d| d¡pd| d¡| d¡| d¡| d¡| d¡| d¡| d¡d œ S) z?Shape a raw_calls row (from get_raw_call_details) for LSQ push.Úcallidr r Ú agentnamerÚagent_callinforÚcall_starttime) rr rrrrrrrr)r)rrrrÚcall_dict_for_lsq_push s  ör ÚpayloadÚpathrcCsDt|tƒr|s dS|}| d¡D]}t|tƒsdS| |¡}q|S)NÚ.)Ú isinstanceÚdictÚsplitr)r!r"ÚcurrentÚpartrrrÚ_extract_nested_value0s  r)ÚanalysisÚ source_keyc sd‡fdd„ }d‡fdd„ }ˆd krtˆd ƒ}|dur|Stˆˆƒ}|dur(|Sˆ d ¡}t|tƒr@ˆd vr@||ƒ}|dur@|S|ƒ}ˆd krRt|d ƒ}|durR|Sˆd vrj| d ¡}t|tƒrj||ƒ}|durj|Sdddddœ} |  ˆd¡D]} tˆ| ƒ}|dur†|Sqwt|ˆƒS)Nr r cs\tˆtƒr ˆ d¡nd}t|tƒr%zt |¡}Wn tjy$d}Ynwt|tƒr,|SiS)NÚ raw_response)r$r%rr ÚjsonÚloadsÚJSONDecodeError)r,)r*rrÚ_raw_response_payload<s ÿz:_extract_lsq_activity_value.._raw_response_payloadÚprofilercs6| ˆ¡}t|tƒr| d¡p| d¡p| d¡S|S)NÚvalueÚsummaryÚevidence)rr$r%)r1Ú profile_value)r+rrÚ_profile_valueEs  z3_extract_lsq_activity_value.._profile_valueÚ sales_intentÚ sentimentÚcustomer_profile>ÚneedÚbudgetÚtimelineÚ authorityÚcustomer_profile_summary)r3Úoverall_summaryÚ rich_summary)r>)r8r7ÚintentÚ call_purpose)Ú quality_score)r3r>r7rCr)r r )r1r r r)r)rr$r%) r*rr+r0r6r2r9r,Ú raw_profileÚaliasesÚaliasr)r*r+rÚ_extract_lsq_activity_value;sH       ü ÿ rGÚvaluesú Optional[str]cGs0|D]}|dur qt|ƒ ¡}|r|SqdS©N)r r)rHr2ÚtextrrrÚ_first_present_strts ÿrLr2cCs t|ttfƒrtj|ddS|S)NF)Ú ensure_ascii)r$r%Úlistr-Údumps)r2rrrÚ_lsq_activity_field_value~srPÚtargetcCsXt|pdƒ ¡}| ¡}| d¡r$| ddd¡ ¡r$d| ddd¡›S|dvr*dS|S)NrÚ customfieldéÚ mx_Custom_>rAÚeventdescriptionÚ ActivityNote)r rrÚ startswithÚreplaceÚisdigit)rQÚcompactrrrrÚ_normalize_lsq_activity_target„sr[ÚrecordcCs<t|tƒsdSt| d¡| d¡| d¡| d¡| d¡ƒS)NÚ ProspectIDÚLeadIdÚIdÚ prospect_idÚlead_id)r$r%rLr)r\rrrÚ_lead_id_from_lsq_recordŽs ûrbÚ activity_cfgr`Úintegration_configúOptional[Dict[str, Any]]cCsB|r| d¡s dSt| d¡ƒ}|sdS|t|ƒ ¡rt|ƒn|dœ}t| d¡ƒ}|r0||d<| d¡p6i}t|tƒrPzt |¡}Wn tjyOi}Ynwg} hd£} t|t ƒr|  ¡D]/\} } t| ƒ} | sjq_t | ƒ} t ||| ƒ}|duryq_| | vr„t |ƒ|| <q_|  | t |ƒdœ¡q_| r•| |d <d d lm}||||ƒS) NÚenabledÚ activity_code)ÚRelatedProspectIdÚ ActivityEventÚ schema_nameÚ SchemaNameÚfield_mappings>rVÚActivityDateTimeÚIncludeLeadScoreÚProcessFilesAsyncÚActivityOwnerEmailÚValidateDropDownOptions)rkÚValueÚFieldsr)Úapply_lsq_agent_attribution)rrLr rYÚintr$r-r.r/r%Úitemsr[rGrPÚappendÚlsq_activity_helpersrt)rcr*rr`rdrgr!rjrlÚfieldsÚtop_level_targetsr+Ú target_keyrQr2rtrrrÚbuild_lsq_activity_payloadšsHþ ÿ    r|ÚdbrÚbidÚphonesú list[str]cCsp|D]3}t|ƒ}|s q| |d|¡}|sq| d¡pi}t| d¡| d¡| d¡| d¡ƒ}|r5|SqdS)NÚ leadsquaredÚ lead_payloadr]r^r_Úexternal_lead_id)rLÚget_cached_crm_lead_by_phoner)r}r~rÚ raw_phoneÚphoneÚcachedr!rarrrÚ_cached_lsq_prospect_idÕs$üÿrˆÚservicerúOptional[DatabaseHandler]cCs˜| d¡| d¡t|ƒ| d¡| d¡| d¡g}g}tƒ}|D]}t|ƒ} | r,| |vr-q | | ¡| | ¡q |durT|durTt|||ƒ} | rTt d|| d¡¡| St| d¡ƒpat| d¡ƒ} |D]4} |  | ¡} |  d ¡r˜|  d ¡} t | t ƒr‰| r‰t | d ƒ}|rˆ|Sqdt | t ƒr˜t | ƒ}|r˜|Sqd| rÊ| | ¡}| d ¡rÊ| d ¡} t | t ƒr½| r½t | d ƒ}|r»|SdSt | t ƒrÊt | ƒ}|rÊ|SdS) Nrrrrrz8[%s] Matched LeadSquared lead from cache by phone for %srÚcustomer_emailÚsuccessÚdatar)rrÚsetrLÚaddrwrˆÚloggerÚinfoÚsearch_lead_by_phoner$rNrbr%Úsearch_lead_by_email)r‰rr*r}r~Úphone_candidatesrÚseenr…r†Ú cached_idÚemailÚ phone_resultrraÚ email_resultrrrÚresolve_lsq_prospect_idésbú        ÿ €     ûršÚNonecCsŽ| |d¡pi}| d¡r| d¡sdS| d¡pi}| d¡s"dS| |d¡p)i}| d¡r4| d¡s6dSt|d|d| d¡d }| d ¡pJi}t|tƒsRdSt| d ¡| d ¡t|ƒ| d ¡| d¡ƒ} t|||||d} | s¥d} t   d|| d¡¡z|j |dd| d¡| | dWdSt y¤t   d|| d¡¡YdSw| ¡D]\} } zÏt| ||| |d}|sâz|j |dd| d¡| | | ddWnt yßt   d|| d¡¡YnwWq©| |¡}| d¡r:t   d|| d¡| | d¡p| d¡pd ¡pd¡z|j |dd| d¡| | | | d ¡d!|| d"¡d# WnVt y9t   d|| d¡¡YnCwt  d$|| d¡| | d%¡¡z|j |dd&| d¡| | | | d ¡| d%¡|| d"¡d# Wnt y{t   d|| d¡¡YnwWq©t yÄ}z:t   d'|| d¡| ¡z|j |dd&| d¡| | | t|ƒdWnt y¹t   d|| d¡¡YnwWYd}~q©d}~wwdS)(NrÚ is_activeÚhas_credentialsÚconfigrfÚ access_keyÚ secret_keyÚapi_host)rŸr r¡Ú activitiesrrrr)r}r~z*No LeadSquared lead matched the call phonezP[%s] Skipping LeadSquared push for %s because no LSQ lead matched the call phonerÚskipped)r~ÚproviderÚstatusrÚ lead_phoneÚmessagez0[%s] Failed to write LeadSquared push log for %s)rdz-Activity is disabled or missing activity code)r~r¤r¥rr¦Ú crm_lead_idÚ activity_keyr§rŒz<[%s] LeadSquared activity pushed for %s activity=%s agent=%srÚ agent_namerú?Úpushedriz(LeadSquared activity pushed successfullyr) r~r¤r¥rr¦r¨r©Úactivity_eventr§Úpayload_previewÚresponse_previewz<[%s] LeadSquared activity push failed for %s activity=%s: %sr§ÚfailedzD[%s] Exception while pushing LeadSquared activity for %s activity=%s)Úget_crm_integrationrÚget_crm_credentialsrr$r%rLrršrr‘Ú log_crm_pushÚ ExceptionÚ exceptionrvr|Úcreate_activityrÚwarningr )r~rr*r}Ú integrationržÚcredsr‰r¢r¦r`r§r©rcr!ÚresultÚexcrrrÚpush_leadsquared_activities%s ý ûýú þþ ÿ ø ÿ  $û õ ÿû õ ÿ€ü ø ÿ€î»r¼)rr r r )rr r r )r!r r"r r r)r*r rr r+r r r)rHrr rI)r2rr r)rQr r r )r\r r rIrJ) rcr r*r rr r`r rdrer re)r}rr~r rr€r rI)NN) r‰rrr r*r r}rŠr~rIr rI) r~r rr r*r r}rr r›)Ú__doc__Ú __future__rr-ÚloggingÚtypingrrrÚ db_handlerrÚleadsquared_servicerÚ getLoggerÚ__name__rrr r)rGrLrPr[rbr|rˆršr¼Ú_lsq_build_activity_payloadÚ_lsq_resolve_prospect_idÚ_push_leadsquared_activitiesrrrrÚs6        9   û ; û <