-zjq> d Z ddlmZ ddlZddlmZ ddlZ ej d ZdZ dZ
ddZ d dd Z d dd
Z
d d d Z d d d Z d d d
Zd!dZ d d"dZ d#dZ d$dZ d%dZd&dZ d d'dZ d(dZy))u
GoHighLevel (Linkia) API client — Climb / TORQ.
Wrappers:
- send_whatsapp_message: envia msg WhatsApp de volta ao lead
- get_conversation_messages: busca historico da conversa
- get_contact: recupera contato + custom fields
- update_contact_custom_fields: atualiza campos custom sdr__
- move_opportunity_stage: move opportunity entre stages do pipeline
- list_custom_fields: lista custom fields da location
- create_custom_field: cria custom field (usado no setup)
) annotationsN)Any
ghl_clientz$https://services.leadconnectorhq.comz
2021-07-28c d| ddt dS )NzBearer application/json)
Authorization Content-TypeAcceptVersion)GHL_API_VERSION)tokens G/opt/mia/workspace/clientes/torq-brasil/sdr_bruno_webhook/ghl_client.py_headersr s "5'**$" c ddl }|j dd| xs d }|sy|j d d}|dd }||d
d } t j |||d
} | j
dv }
|
rr | j
} t | t rP| j d du r=t j d|| j dd d| j
| j fS n/t j d|| j
| j dd |
| j
| j fS # t $ r Y $w xY w# t j $ r.} t j d| ddt! | fcY d} ~ S d} ~ ww xY w)u Envia msg direto na Dinastia API — chega no WhatsApp do lead em tempo real.
Complementa o send_whatsapp_message (que registra no CRM Linkia).
Usar os dois em paralelo: Linkia pra histórico, Dinastia pra entrega.
r Nz\D )Fr z sem telefone/z/chat/send/textr )r
r T)PhoneBody NumberCheck )headersjsontimeout) successFz,Dinastia send success=false phone=%s body=%sr z/Dinastia send failed phone=%s status=%s body=%szDinastia send exception: %s)resubrstriprequestspost status_coder
isinstancedictgetlogwarningtext ExceptionRequestException exceptionstr)
phonemessagedinastia_token
dinastia_base_refoneurlr bodyrokdataes
r send_via_dinastiar: ( s` 775"ekr *D '
!
!#
& '
7C&8JKG74 @D MM#wT2 F
]]j
(
vvx dD)dhhy.AU.JKK N $affTcl4 !--77
KKI ammQVVDS\
;1==!&&((
$ $
3Q7aQ sC )D1 )A/D" AD1 " D.+D1 -D..D1 1E2#E-'E2-E2c t d}d| |d}|r||d< t j ||t | d }|j }|s/t
j
d| |j |j dd ||j |j fS # t j $ r.}t
j d
| d d t | fcY d}~S d}~ww xY w)
z2Envia mensagem WhatsApp via GHL Conversations API.z/conversations/messagesWhatsApp)type contactIdr/ conversationId r r r z,GHL send failed contact=%s status=%s body=%sN zGHL send exception: %sFr GHL_API_BASEr! r" r r7 r' r( r# r) r+ r, r- )
contact_idr/ r
conversation_idr4 payloadr6 r7 r9 s r send_whatsapp_messagerH O s N1
2C G
$3 ! MM#GXe_b Q
TT KKF"AMM166$3<
A1==!&&(( $ $
.2aQ s A7B C##C C Cc | sg S t d| d}d|i}|r||d< t j |t | |d }|j s0t
j
d|j |j dd g S |j xs i }|j d
}t |t r|j d
g }|xs g S # t j $ r"} t
j d | g cY d} ~ S d} ~ ww xY w) zBusca historico de mensagens de uma conversa (mais recentes primeiro).
`types` opcional: filtro tipo GHL (ex: 'TYPE_SMS,TYPE_WHATSAPP').
z/conversations/z /messageslimitr= r r paramsr z6GHL get_conversation_messages failed status=%s body=%sNrB messagesz+GHL get_conversation_messages exception: %s)rD r! r& r r7 r' r( r# r) r r$ r% r+ r, )
rF r
rJ typesr4 rL r6 r8 msgsr9 s
r get_conversation_messagesrP j s
N//):)
DC %u -F v LLhuo &
4tt KKP
qvvds|
5Ivvx~2 xx
# dD !88J+Dzr $ $
CQG s% A C ;A C C=C82C=8C=c | r|sg S t d}|| |d} t j |t | |d }|j s0t
j
d|j |j dd g S |j xs i }|j d xs |j d xs g }|xs g S # t j $ r"} t
j d
| g cY d} ~ S d} ~ ww xY w) zProcura conversas de um contato (mais recente primeiro).
Endpoint: GET /conversations/search?locationId=X&contactId=Y&limit=N
Retorna lista de {id, contactId, lastMessageBody, ...}.
z/conversations/search)
locationIdr> rJ rK z1GHL search_conversations failed status=%s body=%sNrB
conversationsr8 z&GHL search_conversations exception: %s rD r! r& r r7 r' r( r# r) r r+ r, )
rE location_idr
rJ r4 rL r6 r8 convsr9 s
r search_conversationsrX s [
N/
0C! F
LLhuo &
4tt KKK
qvvds|
5Ivvx~2 )CTXXf-=C{ $ $
>B s% A B7 5AB7 7C,
C'!C,'C,c ddl }d}t d|dz D ]T }t | ||d }|sI||k r+t j d| ||| |j | Et j d| | y|d } | j
d xs | j
d }|st j d
| yt ||d d
}
|
D ]V } | j
d xs dj dk7 r*| j
d xs dj } | sP| |fc c S ||k r-t j d| |||| |j | =t j d| || W d|fS )u Busca a ultima mensagem INBOUND do contato via GHL, com retry.
Retorna (body, conversation_id) — ambos podem ser None se nao houver.
Fluxo: search_conversations -> pega conv mais recente -> lista mensagens
filtrando WhatsApp/SMS -> pega a primeira inbound (mais recente).
Race condition tratada: o GHL leva 3-15s pra indexar conversa recém-criada
pelo endpoint /conversations/search. Se nao achar, faz retry com backoff.
r N )rJ zR[fetch_last_inbound] contact=%s tentativa %d/%d sem conversa GHL, aguardando %.1fszC[fetch_last_inbound] contact=%s sem conversa GHL apos %d tentativas)NNid_idz+[fetch_last_inbound] contact=%s conv sem id
zTYPE_SMS,TYPE_WHATSAPP)rJ rN directionr inboundr5 z`[fetch_last_inbound] contact=%s conv=%s sem msg inbound util, aguardando %.1fs (tentativa %d/%d)zO[fetch_last_inbound] contact=%s conv=%s sem msg inbound util apos %d tentativas)
timerangerX r' infosleepr& rP lowerstrip)
rE rV r
max_attempts backoff_sr` conv_idattemptrW convrO mr5 s
r fetch_last_inbound_messagerl s GL1 ,- !4$Ze1M %m#WlIG
9% HHZ
/ Qx((4.3DHHUO HHBJ O ( U",D
%Ak"(b//1Y>EE&M'R..0DW}$ % \ ! HHw )Wl
L JJy ! bWl 4A!4D =r c t d| } t j |t | d }|j s/t
j
d|j |j d d y |j xs i }|j d xs |S # t j $ r }t
j d| Y d }~y d }~ww xY w)N
/contacts/rS r r z(GHL get_contact failed status=%s body=%srB contactz GHL get_contact exception: %srU )rE r
r4 r6 r8 r9 s r get_contactrq s
N*ZL
1C
LLhuor Btt KKB
qvvds|
5vvx~2xx "*d* $ $
5q9s AB )(B C%C Cc J |sy|st j d yg }|j D ]C \ }}|j | }|st j d| 0|j ||d E |syt
d| }d|i} t
j || t | d }
|
j s.t j d
|
j |
j d d |
j S # t j $ r } t j d
| Y d } ~ yd } ~ ww xY w)z
Atualiza custom fields de um contato.
`fields` = {"sdr__nome_lead": "Marcos", "sdr__cidade": "BH", ...}
`field_id_map` = {"sdr__nome_lead": "aBc123XyZ", ...} (obrigatorio na v2 da API)
Tu< update_contact_custom_fields sem field_id_map — nada feitoFu% campo %s sem ID mapeado — ignorando)r[ field_valuern customFieldsr rA z+GHL update_contact failed status=%s body=%sNrB z GHL update_contact exception: %s)r' r( itemsr& appendrD r! putr r7 r# r) r+ r, ) rE fieldsr
field_id_mappayload_fieldskeyvalfidr4 rG r6 r9 s r update_contact_custom_fieldsr~ s RSNLLN ?S s# KK? E S => ?
N*ZL
1C ~.G LL7HUOR Ptt KKE
qvvds|
5tt $ $
8!<s A'C/ /D"D D"c t d}|| |dd} t j |t | |d }|j s/t
j
d|j |j dd y|j xs i }|j d g }|r|d
S dS # t j $ r } t
j d | Y d} ~ yd} ~ ww xY w) z1Procura opportunity ativa do contato no pipeline.z/opportunities/searchr )rV rE pipeline_idrJ rS rK z/GHL search opportunity failed status=%s body=%sNrB
opportunitiesr z$GHL search opportunity exception: %srU )
rE r r
rV r4 rL r6 r8 oppsr9 s
r find_opportunity_for_contactr & s N/
0C" " F LLhuofb Qtt KKI
qvvds|
5vvx~2xx, tAw(D( $ $
r rA z/GHL create opportunity failed status=%s body=%srB opportunityz$GHL create opportunity exception: %s)
rD r! r" r r7 r' r( r# r) r r& r+ r, )
rE r stage_idr r
rV r4 rG r6 r9 s
r create_opportunityr B s N/
*C!!#
G MM#GXe_b Qtt KKI
qvvds|
5B##M22 $ $
s A'A: :B-
B((B-c t d| d} t j |t | d }|j s0t
j
d|j |j dd g S |j xs i j dg S # t j $ r"}t
j d | g cY d}~S d}~ww xY w)
z)Lista todos os custom fields da location. /locations/
/customFieldsrS ro z/GHL list_custom_fields failed status=%s body=%sNrB rt z$GHL list_custom_fields exception: %srU )rV r
r4 r6 r9 s r list_custom_fieldsr y s
N+k]-
@C LLhuor Btt KKI
qvvds|
5IB##NB77 $ $
r s # g %5 " > $ $
$ $ $
$ V #'
<
N
L 444 4 4
4 #
4v & +/ && & & ( &
&Z
8
:
4 * *.
##
# # #
# '
# #L
r