i)xdZddlZddlmZmZmZmZddlZejdZ GddZ da de fdZ y)u~ Volume Profile Analyzer - Analyse avancée des volumes Détecte accumulation, distribution, breakouts et zones de liquidité N)DictListOptionalTupleVolumeProfileAnalyzerceZdZdZdZdedeedeedefdZ de jde jdefdZ de jde jdefd Z de jde jdeefd Zde jdefd Zde jde jde jfd Zd edeeeffdZy)ru%Analyseur avancé de profil de volumec<i|_tjdy)Nu'✅ Volume Profile Analyzer initialisé)volume_historyloggerinfo)selfs ./volume_profile_analyzer.py__init__zVolumeProfileAnalyzer.__init__s  =>symbolpricesvolumesreturncR|rt|dkrdddS tj|dd}tj|dd}tj|dd}tj|}|d}||tjd d |j |<d ||||d kDr||z nd d gd} ||dzkDrB| dj d| dxxdz cc<tjd|d||z ddn)||dzkDr!| dj d| dxxdz cc<|j||} | d kDrB| | d<| dj d| dxx| z cc<tjd|d| d|j||} | d kDrB| | d<| dj d | dxx| zcc<tjd!|d"| d|j||} | | d#<|j|} | | d$<| d%k(r| dxxd&z cc<n| d'k(r | dxxd&zcc<|j||}|| d(<|d|d)kDrd*nd+| d,<| d,d*k(r | dxxd-z cc<| S#t$r3}tjd.|d/|dt!|dcYd}~Sd}~wwxYw)0u Analyse complète du profil de volume Returns: Dict avec détection accumulation/distribution, breakouts, anomalies Finsufficient_data)successreasoniNnow)avg_20avg_50 timestampTr)rcurrent_volume avg_volume_20 avg_volume_50 volume_ratio score_bonussignalsr&BREAKOUT_VOLUMEr%u🔥 u: BREAKOUT VOLUME détecté (×.1f) HIGH_VOLUMEaccumulation_score ACCUMULATIONu💎 u!: ACCUMULATION détectée (score=distribution_score DISTRIBUTIONu⚠️ u!: DISTRIBUTION détectée (score=volume_clusters volume_trend INCREASING DECREASINGobvBULLISHBEARISH obv_trend zErreur analyse volume profile z: )lennparraymean datetime64r appendr debug_detect_accumulation_detect_distribution_find_volume_clusters_analyze_volume_trend_calculate_obv Exceptionerrorstr)r rrr volumes_array prices_arrayr"r#r!resultr/r1r3r4r8es ranalyze_volume_profilez,VolumeProfileAnalyzer.analyze_volume_profiles-#g,+$0CD DL 8HHWST]3M88F34L1LGGM#$$78MGGM2M*2.N(']]51+D   ' "0!.!.BORSBS >YZ F  11y!(():;}%+% uVH,KN[hLhilKmmnop-!"33y!((7}%+%"&!:!:<!W !A%/A+,y!((8}%);;% uVH,MN`Maabcd"&!:!:<!W !A%/A+,y!((8}%);;% wvh.OPbOccdef#88}UO(7F$ % 55mDL%1F> "|+}%*%-}%*%%%lMBCF5M/22wS/A)yF; k"i/}%+%M 8 LL9&A3G H$A7 7 8sII** J&3(J!J&!J&cbt|dkst|dkrytj|dd}tj|dd}tj|ddtj|ddz }|dkDr||z nd}|dkDr |dkrt dt |dz d zSy) u Détecte une phase d'accumulation (volume élevé + prix stable) Returns: Score 0-20 selon intensité de l'accumulation rrr9Nrr ?gQ?)r>r?rAstdminint)r rr recent_volume older_volumeprice_volatilityvolume_increases rrEz*VolumeProfileAnalyzer._detect_accumulationls v; s7|b0 . wwws3/0 66&,/"''&,2GG;G:J-,6PQ S %5%=r3! 3r9:; ;rct|dkst|dkrytj|dd}tj|dd}|d|dz |dz }||dzkDr&|dkr!td t t |d zSy) u Détecte une phase de distribution (volume élevé + prix en baisse) Returns: Score 0-20 selon intensité de la distribution r=rr9NrrrSg{Gzri)r>r?rArVrWabs)r rrrX avg_volume price_changes rrFz*VolumeProfileAnalyzer._detect_distributions v; s7|b0 . WWWST]+ r VC[0F3K?  :+ + u0Dr3s<03678 8rc t|dkrgStj|}tj|}d}tj|||}g}t t|dz D]b}|||k\|||dzkz} tj || } | dkDs5|j||||dzzdz | ||||dzdd|jdd |d d S) u Identifie les zones de prix avec volume important (support/résistance) Returns: Liste de clusters {price_level, volume_total, type} rr=r rr,) price_level volume_total price_min price_maxc |dS)Nrb)xs rz=VolumeProfileAnalyzer._find_volume_clusters..s An$5rT)keyreverseNr6) r>r?rVmaxlinspacerangesumrCsort) r rrrcrdn_binsbinsclustersimask volume_in_bins rrGz+VolumeProfileAnalyzer._find_volume_clusterss v; IFF6N FF6N {{9i8s4y1}% Ad1g%&4!9*<=DFF74=1Mq $(Gd1Q3i$71#<$1!%a!%ac !   5t D|rct|dkrytj|dd}tj|dd}|dkDr||z |z nd}|dkDry|d kry y) z Analyse la tendance du volume (hausse, baisse, stable) Returns: 'INCREASING', 'DECREASING', 'STABLE' rSTABLEr9Nrrg333333?r5g333333ÿr7)r>r?rA)r r recent_avg older_avgchanges rrHz+VolumeProfileAnalyzer._analyze_volume_trendsj w<" WWWST]+ GGGC,- 9BQ*y(I5A D= e^rctjt|}|d|d<tdt|D]M}||||dz kDr||dz ||z||<#||||dz kr||dz ||z ||<C||dz ||<O|S)z Calcule l'On-Balance Volume (OBV) Indicateur cumulatif : +volume si prix monte, -volume si prix baisse rr )r?zerosr>rm)r rrr8rss rrIz$VolumeProfileAnalyzer._calculate_obvs hhs6{#Aq#f+& "Aay6!A#;&QqSGAJ.AVAaC[(QqSGAJ.AQqSA  " r volume_resultc|jdsyd}g}|jdd}|dkDr|dz }|jd|d d n |d kDr|d z }d |jdgvr|dz }|jdd|jdgvr|dz}|jd|jddk(r|d z }|jdtdtd|}|rdj |nd}||fS)u Évalue la qualité du signal basé sur le volume Returns: (score 0-100, explication) r)2uDonnées volume insuffisantesrr$r r,ruVolume élevé (×r*r+g?r=r0r&r.zPhase d'accumulationr2uPhase de distribution (⚠️)r<r:z OBV haussierrdz | z Volume normal)getrCrkrVjoin)r r}scorereasonsr$ explanations rget_volume_quality_scorez.VolumeProfileAnalyzer.get_volume_quality_scores!  +6%((; !  RKE NN/ S/AC D C  RKE ]..y"= = RKE NN1 2 ]..y"= = RKE NN; <   [ )Y 6 RKE NN> *As3'-4ejj)/ k!!rN)__name__ __module__ __qualname____doc__rrLrfloatrrQr?ndarrayrErFrGrHrIrrrfrrrr s/?V8SV8$u+V8PTUZP[V8`dV8p2:: u22:: u,!BJJ!!PTUYPZ!FRZZC,RZZ"**$'"d'"uUCZ?P'"rrc.t tatS)z4Retourne l'instance globale de l'analyseur de volume)_volume_analyzerrrfrrget_volume_analyzerrs02 r)rnumpyr?typingrrrrlogging getLoggerr rrrrfrrrsM ..   2 3@"@"H2r