ԟj d dl Z d dlZd dlmZ d dlmZ d dlZd dlmZ d dlm Z e j
d Z G d d Z dS ) N)datetime)Any)PostgresClient) get_settingszdscons.telegram_bridgec e Zd Zd Z ddedededefdZded ed
ed z fd Zd
ededefdZde ee
f fdZ d
edefdZ d S )TelegramBridgec t | _ | j j | _ d| j | _ t | _ | j j pd| _ d| _ d S )Nz https://api.telegram.org/botz-1000000000000z&http://127.0.0.1:3081/api/send-message)
r settingstelegram_bot_token bot_tokenapi_urlr db_clienttelegram_chat_id
main_group_idzalo_bridge_url)selfs 2C:\Projects\DSCons\app\services\telegram_bridge.py__init__zTelegramBridge.__init__ sX $
9FdnFF ')) !] ; O?O G F sender_name sender_idtext is_internalc K | j s t d dS |rdnd}| d| d| d| dt j d }d
| }d} | j | } | r| d }n# t $ r Y nw xY w| j
|d d
}
|r3t | rt | |
d< t j 4 d{V } | | j d|
d d{V } | }
|
d s<|
dd | | j d|
d d{V ddd d{V dS # 1 d{V swxY w Y dS # t $ r(}t d| Y d}~dS d}~ww xY w)z>Forward an inbound Zalo message to Telegram group immediately.z%Telegram Bot Token is not configured.Nu# 🚨 [VIP GIÁM ĐỐC ZALO]u 💬 [KHÁCH HÀNG ZALO]u
👤 Người gửi: z (ID: u! )
📝 Nội dung: u
⏱ Thời gian: z%H:%M:%S %d/%m/%Y
conv_company_telegram_topic_idHTML)chat_idr
parse_modemessage_thread_id /sendMessage $@jsontimeoutokz.Error forwarding inbound message to Telegram: )r loggerwarningr nowstrftimer "get_telegram_topic_by_conversationget Exceptionr strisdigitinthttpx AsyncClientpostr
r$ poperror)r r r r r iconmsg_textconv_idtopic_id topic_mappayloadclientrespdataes r forward_inbound_messagez&TelegramBridge.forward_inbound_message sM ~ NNB C C C F
3 1 12
V
V+6
V
VDM
V
V'+
V
V (0|~~'>'>?R'S'S
V
V .)-- II'RRI
>$==)<== D ) #
#
9H
--// 9+.x==G' (
O (**
f #[[|111 ) yy{{xx~~ KK 3T::: ++ <555GT &
O O O LLM!MM N N N N N N N N N OsO (1B
B'&B'+F6 B F#F6 #
F--F6 0F-1F6 6
G( G##G(conversation_id
topic_namereturnNc K | j sdS t j 4 d{V }| | j d| j |dd d{V }| }| d rt |d d }t t j
||t | j t j d }| j
| |cddd d{V S t d
| ddd d{V dS # 1 d{V swxY w Y dS ) zBCreate a forum topic on Telegram group for the given conversation.Nz/createForumTopic)r namer" r# r& resultr )idrA r telegram_group_id
created_atzFailed to create topic: )r r1 r2 r3 r
r r$ r, r. uuiduuid4r r) r upsert_telegram_topic_mapr' r5 )r rA rB r< r= r> r9 mapping_datas r create_topiczTelegramBridge.create_topicK s' ~ 4$&& & <222!%!3ZHH % D
99;;Dxx~~
tH~.A BCC djll++'6)1),T-?)@)@"*,.. 88 FFF # $
LL:D:: ; ; ;' s CE E
E
E
contact_idr9
draft_textc
K | j sdS ddd| dggi}t j 4 d{V }| | j d| j t
| rt | ndd| d|d d
d{V }| cddd d{V S # 1 d{V swxY w Y dS ) z@Phase 4: AI sends Draft Message to Telegram with Approve button.Ninline_keyboardu Duyệt & Gửi Zalo (Approve)approve_)r
callback_datar! u* 🤖 [AI SOẠN NHÁP TRẢ LỜI]
r )r r r r reply_markupr" r# )
r r1 r2 r3 r
r r. r/ r0 r$ )r rO r9 rP keyboardr< r= s r send_draft_for_approvalz&TelegramBridge.send_draft_for_approvald s ~ 4 !A)@J)@)@
$&& & <--- # 18}},,..* X V* V V"($, % D 99;; s A8B<<
C Cupdatec d K d|v r-|d }| dd }| d r| d d }| di dd dd d d }| || d
{V t j 4 d
{V }| | j d |d d
dd d
{V d
d
d
d
{V d
S # 1 d
{V swxY w Y d
S d
S d|v rn|d }t | di d d }|t | j
k r| di d st | dd } | d }
|
r| r | j | } | r]| d p)| dd dd }| ||
d
{V d
S d
S # t $ r(} t d| Y d
} ~ d
S d
} ~ ww xY wd
S d
S d
S d
S d
S )z'Process incoming webhook from Telegram.callback_queryr> rS messager u# 🤖 [AI SOẠN NHÁP TRẢ LỜI]
z
AI DRAFT:
Nz/answerCallbackQueryrG u" Đã duyệt và gửi tới Zalo!)callback_query_idr r" r# chatfromis_botr rO rA r z(Error mapping telegram message to Zalo: )r,
startswithsplitreplace send_to_zalor1 r2 r3 r
r. r r get_telegram_topic_by_idr- r' r5 )
r rX cbr> rO r7 r< msgr thread_idr mappingr? s
r process_webhookz TelegramBridge.process_webhook s v % %()B66&"%%Dz**
!ZZ
3 3A 6
FF9b))S__ W CRHH W]B// ''
H========= !,.. & ++ <===13D$H !%
&
. &
#C#''&"--11$;;<r{ s , , , , , , * * * * * * 3 4 4t t t t t t t t t tr