}jV.UdZddlmZddlZddlmZddlmZddlmZm Z m Z ddl m Z ddl mZdd lmZdd lmZdd lmZdd lmZdd lmZeddgZeZded<eZGdde Zedd/dZedd0dZ e!d d1d!Z"e!d"d1d#Z#e!d$d1d%Z$Gd&d'e Z%ed(d2d*Z&e!d+d3d.Z'dS)4zFastAPI Presentation Router for Zalo CRM & Webhook Integration. Strict Hexagonal Architecture COMPLIANT (Outbound network operations delegated to Gateway Adapter). ) annotationsN)datetime)Any) APIRouterBackgroundTasksRequest) BaseModel)run_in_threadpool)PostgresClient)TelegramBridge)ZaloGatewayPort)ZaloHttpAdapter)PostgresZaloCrmRepositoryz/crmCRM)prefixtagsr zalo_gatewayc~eZdZUded<ded<ded<ded<dZded<dZded <d Zd ed <dZded <dZded<dS)WebhookPayloadstr event_name sender_id sender_namemessageNz str | Nonedisplay_message member_nameF bool | Noneis_group phone_numberz int | None timestamp) __name__ __module__ __qualname____annotations__rrrrr >C:\Projects\DSCons\app\modules\zalo_crm\presentation\router.pyrrsOOONNNLLL"&O&&&&"K""""!H!!!!#L#### I      r&rz/webhookpayloadbackground_tasksrreturndict[str, Any]c X Kttj jpjdvpdvpdvp jdvp j}|jj tjtjd d}|ddtjtjdd | || tjtjd  ttj }| d |j j rtjj d z ntjd d fd }t|d{Vd fd }||d fd }||d|dS)NSơn - Giám Đốc Giám ĐốcSơn)6455669426306340318729784557598851324idnamer is_internal created_at updated_atcompany_zalo_1zDSCons Zalo OA)r3r4rr6r7 conv_company_r3zalo_account_id contact_idr5r6r7contactg@@r3conversation_id sender_typercontentr r*NonecdS)N)upsert_contactupsert_zalo_accountupsert_conversationinsert_message)client contact_data conv_datamsg_data zalo_datasr'_save_dbz handle_webhook.._save_dbesYl+++""9---""9---h'''''r&cKt}s$|djd{V|jjjd{VdS)NzZalo - )rrtextr5)r create_topicrforward_inbound_messagerr)bridger?r5r(s r'dispatch_telegram_forwardz1handle_webhook..dispatch_telegram_forwardns!! X%%o7VAT7V7VWW W W W W W W W,,+'# -           r&cK ddlm}|}|jjd{VdS#t $r:}ddl}|dd|Yd}~dSd}~wwxYw)Nr)ZaloAiDispatcher)rrrrzdscons.crm_webhookzError in Zalo AI auto-reply: ) *app.modules.zalo_crm.application.use_casesrUprocess_and_replyrr Exceptionlogging getLoggererror)rU dispatcherexcrYrr(rs r'dispatch_ai_replyz)handle_webhook..dispatch_ai_reply|s  S S S S S S))++J..!+'! /              NNN   2 3 3 9 9555          s9A B /A??Bsuccess)status message_idr*rB)r boolrrrrrrnowruuiduuid4rr fromtimestampr add_task)r(r)r<r;msg_idrMrSr^rHrIrJr?rr5rKrrLs` @@@@@@@@@r'handle_webhookrj*sb  FG$%%H%<)> ! ! ! ! ! !F   F   ( (((((((( d r&z/qrcDKtd{VS)z?Proxy QR Code fetch to Node.js Zalo Bridge via Gateway Adapter.N)rget_qrr%r&r' get_zalo_qrrts,$$&& & & & & & &&r&z/statuscDKtd{VS)z>Proxy status check to Node.js Zalo Bridge via Gateway Adapter.N)r get_statusr%r&r'get_zalo_statusrws,((** * * * * * **r&z/friendscK td{V\}}dd}t|||d{V\}}t|t|z}|t |t |dS#t $r}gt|dcYd}~Sd}~wwxYw) zSFetch real friends and groups from Zalo via Gateway Adapter and sync to PostgreSQL.N friends_datalist[dict[str, Any]] groups_datact}|}i}|D]A}|ds*|d|d|d|dddd||d<B|D]}|dd}|dd}|s2|d kp |d kpd |vpd |v} |ddp| } | rd n|} | |d<| |d<d|d<|||<|| |d | tjtjd} || d|d|| tjtjd} || i}|D]}|ddkr|ddp/d|ddvpd|ddv}|r0|d|ddddd||d<|d|vr ||d=|D]}|dd}|r|dkr!|dd}d|d<d|d<|||<||d|||ddddtjtjd} || d|d|dtjtjd} || ||fS)Nrr3r4rr5F)r3r4 phoneNumberr5ravatarr1r/r.r-r~r2r9r8r: gridVerMapuNhómCtyT)r3r4r5rru Nhóm Zalo totalMemberru thành viên)r get_all_contactsgetrrdrDrFpop)ryr{ pg_client db_contactsmerged_friendsdb_cfraw_namer< is_directorr5 display_namerIrJ merged_groupsis_grpggroup_id group_names r'_sync_db_logicz(get_zalo_friends.._sync_db_logics&((I#4466K8:N#  xx ++"4j $V '+N';'+M':$)"$ 22N4:."% 9% 955,,UU4__ !"7726)2)2&1   eeM599H[ 8CQ44 (& #.- %* -.z*%($%EE-$8$8#."*,.."*,..    ((6667*66'7",#."*,.."*,..  --i888879M# 7 7:--HHZ//5$((62"6"665 4 44  7"4j $V '+$("$ 11M$t*-Dz^33*4:6  9 955r??8|#;#;UU6<88 $* #'- *+ h'""8T222#&'(uu]A'>'>$M$M$M#'"*,.."*,..    ((6665(44'7"*#'"*,.."*,..  --i8888!=0 0r&)friendstotal groups_count)rr[)ryrzr{rz)rget_friends_and_groupsr listvalueslenrXr)rgroupsrrrcombinedr]s r'get_zalo_friendsrsx2 , C C E EEEEEEEk 1k 1k 1k 1Z/@PWY_.`.`(`(`(`(`(`(`% --//004 8L8L8N8N3O3OO]] ..   222C111111112sB"B'' C 1CC C c2eZdZUded<ded<dZded<dS)SendMessageRequestruser_idrFrrN)r!r"r#r$rr%r&r'rr&s5LLLLLL!H!!!!!!r&rz /send_messagereqcK tjjt jd{V}dfd }t |d{V|S#t$r}t|ddcYd}~Sd}~wwxYw) z.Send real message to Zalo via Gateway Adapter.) target_idrrNr*rBct}dj}ttj|ddjt jd}||dS)Nr9userr8r>) r rrrerfrrrdrG)rconv_idrKrs r' _save_messagez(send_zalo_message.._save_message6sm&((I3ck33G$*,,''#*%-;%\^^ H  $ $X . . . . .r&F)r[r_rb) r send_messagerrrcrr rXr)rres_datarr]s` r'send_zalo_messager,s5%22kK#,''3         / / / / / / ......... 555Se444444445sAA!! B+B<BBz/messages/{contact_id}r<rct}d|}||}|s|d|}d|pgiS)z:Fetch all messages for a specific contact from PostgreSQL.r9conv_company_zalo_1_messages)r get_messages_by_conversation)r<rrrs r'get_contact_messagesrIsh  I*j**G55g>>H  99 /: / /   B ''r&)r(rr)rr*r+)rkrr*r+)r*r+)rrr*r+)r<rr*r+)(__doc__ __future__rrertypingrfastapirrrpydanticr starlette.concurrencyr app.core.postgresr 4app.modules.integrations.application.telegram_bridger 3app.modules.zalo_crm.domain.ports.zalo_gateway_portr >app.modules.zalo_crm.infrastructure.adapters.zalo_http_adapterrDapp.modules.zalo_crm.infrastructure.repositories.zalo_crm_repositoryrrouterrr$crm_repositoryrpostrjrqrrtrwrrrrr%r&r'rs#""""" 7777777777333333,,,,,,OOOOOOOOOOOOZZZZZZ &w / / /!0 1 1 1111**,, ! ! ! ! !Y ! ! !Ze7e7e7e7P !!"!E'''' I++++ Jz2z2z2z2z"""""""" _55558 $%% ( ( (&% ( ( (r&