x=j d Z ddlmZmZ ddlmZ ddlZddlmZ ddlm Z e e
Z e Z G d d Z
e
Zy) z3Notification service for email and Telegram alerts. )datetimetimezone)OptionalN) get_settings)
get_loggerc 4 e Zd ZdZ d#dedededededz dedz d edz d
edz d edz d dfd
Z d$deded
ededz dedz d edz d dfdZded dfdZd%dZ ded dfdZ
d
ed dfdZ deded dfdZ deded ed e
d df
d Zd ed efd Zd ed!ed efd"Zy)&NotificationServicez9Sends alerts for trading events, errors, and risk limits.Nsymbolsidepricesize stop_loss take_profit
confidencereasonmodereturnc
K d| d| d| dd| dg}
|r|
j d| d |r|
j d| d ||
j d| d | r|
j d
| d |r|
j d | | j d
d| d| dj |
||||d d { y 7 w)Nu 🟢 Trade Opened — z
Price: zStop Loss: zTake Profit: zConfidence: z/100 Mode: Reason: trade_openedzTrade Opened:
)r
r r r
)append _notify_alljoin) selfr
r r r
r r r r r liness KC:\xampp\htdocs\tradingbinance\backend\app\services\notification_service.pysend_trade_openedz%NotificationService.send_trade_opened s 5TF!F8 DE7' *4& (
LL,YKw? @ LL.{m7C D ! LL?:,h? @ LL9TF$/ 0 LL8F8, - TF!F8 , IIe teT J
s B7C9B?:Cpnl entry_price
exit_pricec x K t | }|dk\ rdnd}| d| d| dd| g} |r| j d | d
|r| j d | d
|r| j d | d
| j dd| dj | |||d d { y # t t f$ r d}Y w xY w7 w)Ng r u 📈u 📉u Trade Closed — zPnL: zr z
Entry: r z Exit: r r trade_closedzTrade Closed: r )r
r# r )float TypeError
ValueErrorr r r )
r r
r# r r$ r% r pnl_valueemojir s
r! send_trade_closedz%NotificationService.send_trade_closed4 s c
I !*Q Lg1& :se4 vh
LL=
W= > LL<
|7; < LL9TF$/ 0 VH % IIe cV <
:& I
s4 B: B! B B:B8 B:!B52B:4B55B:loss_pctc T K | j ddd| dd|i d { y 7 w)N
daily_losszDaily Loss Limit WarningzDaily loss reached z%. Trading may be locked.r. r )r r. s r! send_daily_loss_alertz)NotificationService.send_daily_loss_alertT s9 &!(+D E
"
s (&(c H K | j dddi d { y 7 w)Nconnection_lostzBinance Connection LostzAConnection to Binance API has been lost. Attempting reconnection.r1 )r s r! send_connection_lostz(NotificationService.send_connection_lost\ s* % O
s " "errorc R K | j ddd| d|i d { y 7 w)Ncritical_errorzCritical ErrorzA critical error occurred: r6 r1 )r r6 s r! send_critical_errorz'NotificationService.send_critical_errord s6 )% 1
e
'%'c R K | j ddd| d|i d { y 7 w)N bot_stoppedzTrading Bot Stoppedz*The trading bot has been stopped. Reason: r r1 )r r s r! send_bot_stoppedz$NotificationService.send_bot_stoppedl s6 !8 A
v
r: detailsc ` K | j dd| d| d| ||d d { y 7 w)NanomalyzAnomaly Detected: zUnusual market behavior on z: )r
r> r1 )r r
r> s r! send_anomalyz NotificationService.send_anomalyt sC ))&G9 = ' 2
s $.,.
event_typetitlemessagepayloadc . K t j d|| t j r)t j r| j | d { t j r,t j r| j || d { y y y 7 A7 w)N notification)rB rC ) loggerinfosettingstelegram_bot_tokentelegram_chat_id_send_telegram smtp_host smtp_from _send_email)r rB rC rD rE s r! r z NotificationService._notify_all| su Nz G & &8+D+D%%g. . . ("4"4""5'2 2 2 #5
/ 2s$ A
BB9B B
BBc K dt j d} t j 4 d { }|j |t j
|dd 4 d { }|j dk( cd d d d { cd d d d { S 7 c7 77 7 # 1 d { 7 sw Y nxY wd d d d { 7 y # 1 d { 7 sw Y y xY w# t $ r*}t j dt | Y d }~y d }~ww xY ww)
Nz https://api.telegram.org/botz /sendMessageHTML)chat_idtext
parse_mode)json telegram_send_failedr6 F) rJ rK aiohttp
ClientSessionpostrL status ExceptionrH r6 str)r rD urlsessionrespes r! rM z"NotificationService._send_telegram s ,X-H-H,I V ,,..'"<<%-%>%>_ef ( ;;#- /.. / /.... LL/s1vL > s DC BC *C B C"B 1 C=B>C C BC DC CCC B. "B%#B. *C1 C <B?=C DC C
CC DC D ! DDD Dsubjectbodyc K dd l }ddlm} || }||d< t j |d< t j
|d< |j
|t j t j t j
t j d d { y7 # t $ r*}t j dt | Y d }~y
d }~ww xY ww) Nr )MIMETextSubjectFromToT)hostnameportusernamepassword start_tlsemail_send_failedrY F)
aiosmtplibemail.mime.textrg rJ rO smtp_usersendrN smtp_port
smtp_passwordr^ rH r6 r_ )r rd re rq rg msgrc s r! rP z NotificationService._send_email s 04.C $C N",,CK **CI //!++ ''!++!//
"
LL,CFL ; sA CBB BB CB C$ C C CC)NNNNN)NNN)r N)__name__
__module__ __qualname____doc__r_ intr" r- r2 r5 r9 r= rA dictr boolrM rP r! r r s C !%"&!% !
:
4Z
$J
d
Dj
N #'!%
4Z
$J
Dj
@
C
D
s
t
S
T
s
t
3C 3 3c 3TX 3]a 3 C D C D r r )r{ r r typingr rZ app.core.configr app.core.loggingr rx rH rJ r notification_servicer r r! r s@ 9 ' ( ' H >V Vr +, r