y=j d Z ddlZddlZddlmZmZ ddlmZmZmZm Z m
Z
ddl m Z m
Z
ddlmZ ddlmZmZ ddlmZ dd lmZ dd
lmZmZmZmZm Z dd l m Z dd l m Z dd
l!m"Z" ddl#m$Z$ ddl%m&Z& eddg Z' e Z(e'jS d defd Z*e'jW d defd Z,e'jS d defd Z-e'jW d ee fde ded efd Z.e'jW d ee fde ded efd Z/e'jS d ee fde ded efd! Z0e'jS d" ee d#fded ed$e1fd% Z2e'jS d& ee fde ded efd' Z3y)(zFOperations API: circuit breaker, go/no-go, reconciliation, tax export. N)datetimetimezone) APIRouterDepends
HTTPExceptionRequestResponse)descselect) AsyncSession)RequireAdmin2FARequireAnalyst) get_settings)get_db)AuditLog BotConfigOrder OrderStatusSymbol)record_audit_event)circuit_breaker)go_no_go_evaluator)notification_service)reconciliation_servicez /operations
Operations)prefixtagsz/notifications/statususerc K t t j xr t j t t j xr t j
dS w)N)telegram_configuredemail_configured)boolsettingstelegram_bot_tokentelegram_chat_id smtp_host smtp_from)r s CC:\xampp\htdocs\tradingbinance\backend\app\api\routes\operations.pynotifications_statusr) sD $H$?$?$]HD]D] ^ !3!3!J8J8J K s AAz/notifications/testc K t j rt j s
t dd t j
d d { }|s
t dd ddiS 7 w) Ni zOTelegram is not configured. Set TELEGRAM_BOT_TOKEN and TELEGRAM_CHAT_ID in .env status_codedetailuE ✅ Test notification
TradingBinance is connected to Telegram.i z5Telegram message failed to send. Check token/chat id.sentT)r# r$ r% r r _send_telegram)r oks r( test_notificationr1 ! sf ' 'H,E,Ed
$22S
B 4kll D>
s AA"A A"z/circuit-breakerc V K t j d { \ }}||dS 7 w)N)activedetails)r is_active)r r3 datas r( get_circuit_breaker_statusr7 0 s+ (2244LFD .. 5s )'
)z/circuit-breaker/resetrequestdbc K t j t |j d { t ||j ddddi| d { dddS 7 .7 w)NCIRCUIT_BREAKER_RESETCircuitBreakertrading_enabledTuser_idaction entity_type new_valuer8 zCircuit breaker reset)messager= )r resetstridr )r8 r r9 s r( reset_circuit_breakerrG 6 si
DGG
---
&$$d+
/4 HH .s! ,A!A $A!A
A! A!z
/reconcilec K t j d { }t ||j dd|| d { |j d s
t d| |S 7 G7 &w)NMANUAL_RECONCILIATION_RUNReconciliationr> passedi r+ )r
reconcile_allr rF getr )r8 r r9 reports r( run_reconciliationrO H sl *779
9F
*$
::h F;; M :s A&A""A&A$%A&$A&z /go-no-goc K |j t t j d d { }|j }|r |j
sdddS |j t t j t t j j d d { }|j j }t j |D cg c] }ddi c}dg|j
}|j |j |j |j" d
} t% ||j& d d | |
d { | S 7 (7 c c}w 7 w)N Fz:Paper trading not started. Set paper_start_date in config.)rK rC pnlr i' )trades equity_curve paper_start)rK checksmetricsfailuresGO_NO_GO_EVALUATEDGoNoGor> )executer r limitscalar_one_or_nonepaper_start_dater order_byr
created_atscalarsallr evaluaterK rW rX rY r rF )
r8 r r9 config
bot_config
orders_resultordersoresultresponses
r( evaluate_go_no_gorl \ sB ::fY / 5 5a 89
9F**,J Z 8 8S
**VE]%;%;DAQAQ>OO H
#
O= : ` ,sA 1E'EA=E'1E 25E'' E 2A"E'E%E' E' E'z/auditd r] c K t t |d d }|j t t j t
t j j | d { }|j j }|D cg c] }t |j |j rt |j nd |j |j |j rt |j nd |j" |j$ |j& |j( |j j+ d
c}S 7 c c}w w)NrQ i )
rF r? r@ rA entity_id old_valuerB
ip_address
user_agentra )minmaxr\ r r r` r
ra r] rb rc rE rF r? r@ rA ro rp rB rq rr isoformat)r r9 r]
safe_limitrj logslogs r( list_audit_logsry s S]C(J::x!!$x':':";<BB:N F >> !D C cff++.;;s3;;'Djj ??/2}}S]]+$ .. .. ..224
s% A-E /E0&E B=EE E z/reports/tax-exportc
, K |j t t t j j t t j t j k( j t j t j k( j t j d{ }|j }t j }t# j$ | }|j' g d |D ] \ }}|j' |j r|j j) nd||j* j, t/ |j0 t/ |j2 xs d t/ |j4 |j6 j, t/ |j g t9 ||j dddt; | i| d{ t= |j? dd d
i S 7 ^7 %w) zAExport trades for tax declaration (Colombia DIAN compatible CSV).N) fecha_utcsimbololadocantidadprecio_ejecucioncomisionmodoorder_id TAX_EXPORT_GENERATEDr rowsr> ztext/csvzContent-Dispositionz*attachment; filename=trades_tax_export.csv)content
media_typeheaders) r\ r r r symboljoin symbol_idrF wherestatusr FILLEDr` filled_atrc ioStringIOcsvwriterwriterowru sidevaluerE quantity filled_price
commission trading_moder lenr getvalue) r8 r r9 rj r outputr ordersyms r( tax_export_csvr s ::ufmm$
feoo2 3 u||{ 1 11 2 %// " F ::r s
L
' H H # / 8 ( $ F F 9 8 4 B F -|n = > #$^ %
"# . $ /> / /
%& vI
I
I I 'I" \ v
& K v#
#
# # #L H v
6 !" v-
-
- - #-r