o i%@s@ddlZddlmZmZmZddlZeeZGdddZ dS)N)AnyDictOptionalc@seZdZdZ  d6dededeedefdd Zd eeeffd d Z  d7d ededeeee fdeeee fd eee ff ddZ d eee ffddZ deee fd eee ffddZ ded eee ffddZdeee fd eee ffddZdedeee fd eee ffddZded eee ffd d!Z " # $d8d%ed&ed'ed(ed)ed eee ff d*d+Zed,e d efd-d.Zd/eee fd0ed efd1d2Zd3ed eee ffd4d5ZdS)9LeadSquaredServicezNPython port of LeadSquared integration service used in tatsat2dev/leadsquared.N access_key secret_keyapi_hosttimeoutcCs:|pd|_|p d|_|pdd|_t||_dS)Nz$https://api-in21.leadsquared.com/v2//)striprrrstripr intr )selfrrr r r0/var/www/html/pca-backend/leadsquared_service.py__init__ szLeadSquaredService.__init__returncCs|j|jdS)N) accessKey secretKey)rr)rrrr _auth_paramsszLeadSquaredService._auth_paramsmethodendpoint query_paramspayloadc Cs|jr|js ddddS|jd|d}|}|r"||zFtj|||||j d}|j rOz| }Wnt yGd|j i}Ynwdd|dWStd |||j|j dd |jd |j ddWSt y} ztjd | dd ddt| ddWYd} ~ Sd} ~ ww)NFz#LeadSquared credentials are missingsuccessmessagedatar )rurlparamsjsonr rawTzRequest successfulz7LeadSquared API request failed: %s %s status=%s body=%szLeadSquared API error (z): z!LeadSquared request exception: %s)exc_infoz Exception: )rrr lstriprupdaterequestsrequestupperr okr" Exceptiontextloggererror status_codestr) rrrrrr r!responseparsedexcrrr_requests\     zLeadSquaredService._requestcCsb|ddddi}|dr&dd|jr|jddd nd |jd d Sd d|ddS)NPagingrOffsetRowCountrTz!LeadSquared connection successful z...r )rr )rr credentialsFzLeadSquared connection failed: r)rr) search_leadsgetrr )rresultrrrtest_connection[s"  z"LeadSquaredService.test_connection search_paramscC|jdd|pidS)NPOSTLeadManagement.svc/Leads.Getrrrr4)rr@rrrr<r zLeadSquaredService.search_leadslead_idcCs|jdddt|idS)NGETz LeadManagement.svc/Leads.GetByIdid)rrrr4r0rrGrrrget_leadys  zLeadSquaredService.get_lead lead_datacCrA)NrBzLeadManagement.svc/Lead.CreaterDrE)rrMrrr create_leadrFzLeadSquaredService.create_leadcCs|jdddt|i|p idS)NrBzLeadManagement.svc/Lead.UpdateleadIdrrrrrJ)rrGrMrrr update_leads  zLeadSquaredService.update_leadcCs|jdddt|iidS)NrBzLeadManagement.svc/Lead.DeleterOrPrJrKrrr delete_leads  zLeadSquaredService.delete_leadr ModifiedOn from_date_str to_date_stroffset row_count date_fieldcCs:|d|d|d|dgdd||dd}|jdd |d S) aFetch leads whose `date_field` falls within [from_date_str, to_date_str]. Uses Leads.Get with AdvancedSearch so it works on all LSQ account tiers. Pagination is offset-based (Offset / RowCount) matching Leads.Get convention. `date_field` can be 'ModifiedOn' (default) or 'CreatedOn'. On a fresh / first-run call, pass a very old from_date to retrieve all historical leads. GreaterOrEqualToField ConditionValue LessOrEqualToAND) ConditionsOperatorr7AdvancedSearchr5rBrCrDrE)rrUrVrWrXrYrrrrget_leads_in_date_ranges( z*LeadSquaredService.get_leads_in_date_rangevaluecCsdddt|p dDS)z1Return only digit characters from a phone string.r css|] }|r|VqdS)N)isdigit).0chrrr sz3LeadSquaredService._phone_digits..)joinr0)rfrrr _phone_digitssz LeadSquaredService._phone_digitslead query_digitscCsvt|dkr |ddn|}dD](}||}|sq||}t|dkr+|ddn|}||ks5||kr8dSqdS)aSReturn True if any phone field on the lead contains `query_digits` as a suffix. LSQ stores phones with country-code prefixes (+91-XXXXXXXXXX). We normalise both sides to digits and check that either the query is a suffix of the stored number or vice-versa (handles 10-digit vs 12-digit variants). r:N)PhoneMobile PhoneNumberTF)lenr=rl)rrmrncorefield stored_rawstored stored_corerrr_lead_matches_phones  z&LeadSquaredService._lead_matches_phonephonec Cs|||}|s ddddSt|dkr|ddn|}tt||g}g}|D]"}|ddd|d gid d d d ddd|d gid d d d g7}q(|d|dd d d dd|dd d d dg7}|D]R}||}|dsrqe|d} g} t| tr| } nt| tr| dp| dp| dp| dpg} | D]} t| tr|| |rdd| gdSqqeddddS)NFzPhone is requiredrr:rorarpEqualr[rr7rcrq)SearchByr^) Parameterr5rrListDatalistTz Lead foundz#No LeadSquared lead found for phone) rlrsrdictfromkeysr<r= isinstancery) rrz normalizedrt search_valuespayloadsvalrr>rrowsrmrrrsearch_lead_by_phonesV        z'LeadSquaredService.search_lead_by_phone)Nr)NN)rrSrT)__name__ __module__ __qualname____doc__r0rrrrrrr4r?r<rLrNrQrRre staticmethodrlboolryrrrrrr sj     <""&   ,r) loggingtypingrrrr' getLoggerrr-rrrrrs