@jC dZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZddlmZmZddlmZddlmZmZddlmZmZdd lmZdd lmZed Zed z d z Zedz Z edz Z!edz Z"edz Z#edz Z$dZ%dZ&e'ejPjSddZ*dZ+ed z Z,e,dz Z-dZ.e.ejPjSddZ/ejPjSddZ0e1hdZ2edZ3d Z4dqd!Z5d"Z6d#Z7d$Z8d%Z9d&Z:d'Z;d(Zd+Z?d,Z@d-ZAd.ZBd/ZCd0ZDd1ZEd2ZFd3ZGdrd4ZHdsd5ZId6ZJd7ZKd8d8d9d:hd;ZLd<ZMe1hd=ZNd>ZOd?ZPdrd@ZQdAZRdBZSdCZTdDZUdEZVdFZWe'eXdGj!dHdIdJdddeXdGj"jKjdLzZ[dMZ\dNZ]dOZ^dPZ_dtdQZ`dRZahdSZbdTZcdUZddVZedWZfdXZgdYZhdZZid[Zjd\Zkd]Zld^Zmdud_Zndud`ZodvdaZpdvdbZqdcZrddZsdwdeZtdxdfZudydgZvdhZwdiZxdjZydkZzdlZ{GdmdneZ|doZ}e~dpk(re}yy)zu v2_stats_dashboard.py — Stats Dashboard 2° account (port 5511, Basic Auth) NO template engine: tutto render server-side in Python (niente {{}} / {% %} nel template). N) BytesParser)defaultdatetimetimezone)Path)BaseHTTPRequestHandler HTTPServer)urlparseparse_qs) defaultdict)ZoneInfoz /opt/charter-live/live_deploy_v2logszwebhook_queue.dbzv2_stats_trade_policy.json#v2_classification_review_queue.json!v2_classification_review_evidencez+v2_classification_certification_audit.jsonlv2_stats_policy_backupsiPi@ V2_STATS_PORT5511z0.0.0.0zv2_stats_dashboard.logcttdz }|jr |jjD]}|j }|j dsd|vr)|j dd\}}|j }|j j dj d}|dk(r3tjjds|tjd<|dk(stjjdr|tjd<yy#t$rYywxYw) Nz.v2_stats_creds#="' V2_STATS_USER V2_STATS_PASS) ROOTexists read_text splitlinesstrip startswithsplitosenvironget Exception) creds_filelinekvs [/opt/charter-live/backups/duration_by_strategy_asset_20260829T154513Z/v2_stats_dashboard.py_load_auth_from_envfiler-(s))J ",,.99; 4zz|??3'3d?zz#q)1GGIGGIOOC(..s3' 0O23BJJ//)"**..2Q23BJJ/ 4   sCD+4D+D++ D76D7rmattia_v2_statsr>classify exclude_test needs_reviewexclude_operationalz Europe/Romecl|yt|j}|sy|jrBt|dk\r4 t |}t j |dz tjS t j|jddS#t$rYywxYw#t$rYywxYw)zBybit V5 closed-pnl restituisce createdAt/updatedTime in MILLISECONDI come stringa (es. "1785856148609"). Accetta anche ISO 8601 ("2026-08-05T20:39:31Z") o None/"". Ritorna datetime (UTC) oppure None se non parsabile. N @@tzZ+00:00) strr!isdigitlenintr fromtimestamprutcr' fromisoformatreplace)tssmss r,_parse_bybit_tsrFGs  z B A yy{s1v| QB))"v+(,,G G%%aiiX&>??    s#2B3$B' B$#B$' B32B3c@t|}|y|j|S)zTRitorna una stringa formattata (UTC) per ts Bybit (ms o ISO). None se non parsabile.r/)rFstrftime)rCfmtdts r, _fmt_bybit_tsrK_s#  B z ;;s cft|}|y|jtjdS)Nz--z%d/%m/%Y %H:%M)rF astimezoneREVIEW_TIMEZONErH)rCrJs r,_fmt_review_tsrPgs/  B z == ) 2 23C DDrLcptjtjj j }d|d|}t |d tjddttdd5}|j|d zdddy#1swYyxYw#t$rYywxYw) N[z] T)flushparentsexist_okautf-8encoding ) rnowrr@rN isoformatprintLOG_DIRmkdiropenLOG_FILEwriter')msgrCr)fs r,logrfns hll # . . 0 : : HH $e,! X\\*334FG(-CE7%+PP,779:   % %  " " #1W%6%6q%9$:$? C$ tzz$U1EPWX e 3)* d # d #s z._strategy_history_for_symbol.. s$q'478KrLr)r r>r&_canonical_strategyVALID_CLOSED_TRADE_STRATEGIESrsortedr)rnsymbolcountsrowrs r,_strategy_history_for_symbolrs{  Fxx-r266vrB"&swwz':; 4 4 8  ! " v||~+KL MMrLc t}g}|jdgD]}t|jdxsdj}|r||vr7t |}t|jdxsdj }t ||}tt|}d} d} g} |rtt|} t|j} || } t|dk(r || k(rdnd} n | | d z kDrd} nd} | jd d jd |j!Dz|t"vrA| jd |j | s|} d} n|| k7rd} | jd| s| jd|j%d| | dj| t'|d|j||S)z2Genera suggerimenti, mai attribuzioni automatiche.unclassified_tradesrr/rLOWrHIGHMEDIUMruzstorico asset: , c3LK|]\}}|jd|yw)rNupper).0r}counts r, z,_certification_candidates..<s*9.9dE4::<.%)9s"$zconfig attuale: zconflitto storico/configz.nessuna prova storica o configurazione univocaPENDING_CERTIFICATIONz; ) anomaly_typeproposed_strategyproposal_confidenceproposal_evidenceproposal_alternatives)rr&r;r!rrrrget_strategy_for_symbolnextitersumrr=appendjoinrrupdaterm)rnrejected candidatesrrrrhistory configuredproposed confidencereasonstotal top_counts r,_certification_candidatesr #s"$HJxx-r2) swwz*0b17798x/ CyTXXh'-2.446.tV<()@)HI   DM*H()E)I7|q '1X'=V8 UQY&% " NN,tyy9=D]]_90  6 6 NN-j.>.>.@-AB C%% x'" 9: NNK L 3!)#-!%7!3%)']    $S) T rLct}g}|jdgD]W}t|jdxsdj}|s2||vs7t |}d|d<|j |Y|S)zESolo casi rifiutati: i nuovi trade restano nella coda certificazioni.rrr/PROPOSTA_RIFIUTATAr )rr&r;r!rr)rnrrrrrs r,_review_candidatesr#Ts~"$HJxx-r2$swwz*0b1779 H,9D#7D   d # $ rLct|xsdj}|jdgD]5}t|jdxsdj|k(s3|cStd)Nr/rrz1Trade non presente tra le classificazioni sospese)r;r!r&r)rnrrs r,_current_unclassifiedr%ask8>r"((*Hxx-r2 swwz"(b ) / / 1X =J H IIrLctjtjj }|D]6}|j ddk(s|j d|k(s-||d<||d<8|S)Nrrr resolved_at)rr\rr@r]r&)queuerrr\rs r,_resolve_queue_for_orderr)isg ,,x|| $ . . 0C& 88H  *txx /Cx/O#DN"%D & LrLc  t|jdxsdj t|jd}|tvr t dt | }t fdt|Dd}| t dt}|jdi}|jdi}t|j }|r||k7r t d || <d | <t|tt d } t| td t |jd d|jdd||jdd|jdddt#d d|y)Nrr/r#Strategia obbligatoria o non validac3LK|]}|jdk(s|ywrNr&rrrs r,r z!_certify_trade..y"[377:;NRZ;Z[$$z*Caso gia rifiutato o non piu certificabilestrategy_by_closed_order_id(classification_source_by_closed_order_idz.Order ID gia certificato con strategia diversa!operator_certified_from_dashboard certified CERTIFIEDrr r r)roperatorrrr chosen_strategyrevidenceztrade certified order= strategy=)r;r&r!rrrr%rr rrrr)rprr AUTH_USERrf) rrnrtradeproposalrmappingsourcesexistingr(rs @r,_certify_traderArs488J'-2.446H"488J#78H44>?? !$ 1E[1$7[ HEFF ) +F =rBG JBOG"7;;x#89HH(IJJ GH;GH ( $%7%98[ QEu))Hb)%\\*=rB#ll#8"=LL!4b9 !   *XJ?@rLc~t|jdxsdjt|}t vr t dt fdt|Ddxsi}t}|jdtjtjjddtj dtjtjj#d d dd |jd dd t%||jdd|jdd|jd ddd t'|t)dt*|jdd|jdd|jdddt-dy)Nrr/z!Trade gia presente nelle anomaliec3LK|]}|jdk(s|ywr-r.r/s r,r z(_reject_certification..r0r1zreject- %Y%m%d%H%M%S-rrrPROPOSTA_RIFIUTATA_DA_OPERATORErz'Da approfondire nella gestione anomalier r )rrr9) r created_atrrrreasonr9notesrtrade_snapshotproposal_snapshotREJECTED_TO_ANOMALYr)rr7rrr rz trade rejected to anomaly order=)r;r&r!r%rrrr rprrr\rr@rHr~rr]rrrr;rf)rrnr<r=r(rs @r,_reject_certificationrMs488J'-2.446H !$ 1E&((<==[1$7[      E LL hll!;!D!D^!T UUVW^WhWhijWkVlmll8<<0::<*3LL!4b9:u+ %8"=",,'.sZ   i' ) HHZ H , ) HHX & ( ) sA A z:Esiste gia una proposta pendente identica per questo tradezreview-rDrErrr rside closed_sizeqtyravg_entry_price entry_price entry_timerG updated_atpnl_netpnlclassification_sourceoperational_reason) r rrPrQrSrUrGrVrWrYrZ) rrGrrrrHr9rIrrJevidence_attachmentTrzzreview proposal saved id=rz order=z action=r:)r;r&r!rrr#rREVIEW_ACTIONSrrrpanyrr\rr@rHr~rr]rrrr'rrf)rrnrrrHr9rIrrr<validated_attachmentr(rr=attachment_pathrrrs @@r,_create_review_proposalr`s488J'-2.446H (#)r * 0 0 2 8 8 :F"488J#78H (#)r * 0 0 2F488J'-2.446H !'R ( . . 0E;Md;STC#cggj)*C/TJT NN8 $E }EFF ^#,-- 0M M>??  .//6zB ,4UVV  E     UVVHLL6??OPPQRYRcRcdeRfQghK"ll8<<0::<!IInb9ii"-IIfb) 99]EIIeQ4GH$yy):EIImUV. s C1B$KSWXrL/rrr/cVdjfdttDS)Nr/c 3xK|]1}d|d|k(rdndd|jd3yw)z