o [`h@sdZddlZddlZddlmZmZddlmZmZddlm Z m Z m Z ddl Z ddl Z zddlmZWn ey?dZYnwGdddZdS) u ProfitTaker Worker - Gestion des fermetures de positions Responsabilité : Fermer les positions selon différentes stratégies N)datetime timedelta)ThreadLock)DictListOptional)CooldownManagerc@s4eZdZdZd8ddZddZddZd d Zd9d ed e e fddZ d e e fddZ de e d e e e ffddZde e e fde e d e e e ffddZddZd:de de d e fddZd d!Zd"d#Zd$d%Zd&d'Zd(d)Zde d*e d+ed efd,d-Zd.d/Zd0d1Zd2d3Zd4d5Zd e fd6d7ZdS); ProfitTakeru2Worker spécialisé dans la fermeture de positionsNcCsZ||_d|_tr tddnd|_i|_t|_d|_d|_| | |j ddS)NF)default_cooldown_minutes zposition_peaks.jsonz#=== PROFIT TAKER WORKER STARTED ===) hyperliquid_clientrunningr cooldown_manageractive_positionsrlockcheck_interval peaks_file setup_logger load_peaksloggerinfo)selfrrM/var/www/html/HyperOracle/crypto_trader/simple_trading_system/profit_taker.py__init__szProfitTaker.__init__cCstd|_|jtjd}tj|st|t tj |d}|tjt }|tjt d}| || |ddl}|jtj |dddd |_|jjsg|j||j|dSdS) u Configure le système de loggingr logszprofit_taker.logz&%(asctime)s - [%(name)s] - %(message)srNazutf-8)encoding)logging getLoggerrsetLevelINFOospathexistsmakedirs FileHandlerjoin StreamHandler Formatter setFormattercodecsopenstreamhandlers addHandler)rlogs_dir file_handlerconsole_handler formatterr-rrrr0s$         zProfitTaker.setup_loggerc Csz;tj|jr2t|jd}t||_Wdn1swYtdt |jdWdSi|_tdWdSt yX}ztd|i|_WYd}~dSd}~ww)u/Charge les peaks sauvegardés depuis le fichierrNu✅ Peaks restaurés: u positions sauvegardéesu3ℹ️ Pas de peaks sauvegardés, démarrage freshu!⚠️ Erreur chargement peaks: ) r$r%r&rr.jsonload saved_peaksprintlen Exception)rferrrrOszProfitTaker.load_peaksc Cszi}t}|d}tj|jr6zt|jd }t|}Wdn1s)wYWni}Yg}|D]\}}| dd}||krO| |q<|D]}||=qR|j (|j D]\}} | dt d| d| d | d |d ||<qaWdn1swYt|jd }tj||d dWdWdS1swYWdSty} z|jd| WYd} ~ dSd} ~ ww)zDSauvegarde les peaks actuels dans le fichier (garde l'historique 6h)i`Tr6N timestamprpeak_pnl_percent-infsymbolside entry_price)r@rBrCrDr?w)indentzErreur sauvegarde peaks: )timer$r%r&rr.r7r8itemsgetappendrrfloatdumpr<rerror) r peaks_to_save current_time cutoff_timer=keys_to_removekeydatar?posr>rrr save_peaks]sJ     & zProfitTaker.save_peakslookback_hoursreturnc Cs|js |jdgSzPttt|dd}|jjdd}|s-|j dgWSg}|D]}t| dd}||krD| |q1|j dt |d t |d |d |WSt yx}z|jd |gWYd }~Sd }~ww)u'Récupère les fills depuis Hyperliquid!Client Hyperliquid non disponible)hours)limituAucun fill récupérérHru Récupérés /z fills depuis huErreur récupération fills: N)rrwarningintrnowrr? get_fill_inforrJrKr;r<rN)rrX start_time all_fillsfiltered_fillsfill fill_timer>rrrget_fills_from_hyperliquids,   (z&ProfitTaker.get_fills_from_hyperliquidc Cs|jsgSz|j}|r|jdt|d|WS|jdgWStyA}z|jd|gWYd}~Sd}~ww)u5Récupère les positions actuelles depuis HyperliquiduRécupérées z% positions actives depuis Hyperliquidz&Aucune position active sur Hyperliquidu!Erreur récupération positions: N)r get_positionsrrr;r<rN)r positionsr>rrr&get_current_positions_from_hyperliquids  z2ProfitTaker.get_current_positions_from_hyperliquidfillsc Csi}|D]}z|dddd}|ddks|ddkr!dnd}|dd}d |v}tt|d d }t|d d } t|d d } |d|} | |vr_||ggd d d d d|| <|ry|| d|| | d|| d|7<n|| d|| | d|| d|7<Wqty} z|jd| WYd} ~ qd} ~ ww| D]2\} } | d}|rt dd|D}t dd|D}|d kr||nd | d<| d| d| d<q|S)u*Reconstitue les trades à partir des fillscoin-PERPdirz Open Longz Close ShortLONGSHORTOpenszrpxrH_)rBrCopenscloses total_opened total_closedavg_open_price current_sizerx)sizepricerHrzryr{zErreur traitement fill: Ncss |] }|d|dVqdS)r~rNr.0orrr sz.css|]}|dVqdS)r~Nrrrrrrsr|r}) rJreplaceabsrLrarKr<rrNrIsum)rrmtradesrgrBrC direction is_openingr~rr? trade_keyr> trade_datarx total_value total_sizerrrreconstruct_trades_from_fillssb$     z)ProfitTaker.reconstruct_trades_from_fillsreconstructed_tradescurrent_positionscCsi}|D]}d|vr@|di}|dddd}t|dd}|dkr)dnd}t|} t|d d} t|d d} n,|d ddd}|d d}tt|d d} t|dd} t|dd} | dkrqq|d|} || gg| dd} d}z|jr|j|}|st|dd}Wn t|dd}Yd|vr|didi}n|di}t|tr|ddnd}d}| dkr|dkrd}n|dkrd}n |dkrd}nd}|dkr| d|d}n| d|d}||| | || t ||| dg| d gd!|vr|d!n|did"t |td#d$}|ddkr]|d%dkr]|jj |d|d%|d&|d |dd'}|d(|d)<|d*|d*<nd|d)<d|d*<|d)}|j| }|r{|d&ddkr|j| i}|d+td#}|dd}|dkrt||dd,kr|}|jd-| d.|d/d0ntd#}|jd1| d2n|d+td#}t|||d+<||| <q|S)3u NOUVELLE LOGIQUE: Partir directement des positions Hyperliquid pour éviter les décalages Les fills servent uniquement pour l'historique, pas pour déterminer les positions actives positionrnrorpszirrrrsentryPx unrealizedPnlrBrCr~rDunrealized_pnlgư>rw)rxryrzr{leveragevalueNr g?g333333?g?g?drxryliquidation_px liquidationPxrA)rBrCrDr} current_pricerr target_price opens_historycloses_historyliquidation_price last_updatedraw_hyperliquid_datar@rr})rDrr~rCrpnl_percent_leveraged pnl_percent pnl_dollarr@g{Gz? Position u% - Peak restauré depuis sauvegarde: .2f%u"Nouvelle position détectée pour u - Peak réinitialisé)rJrrLrupperrget_current_market_price isinstancedictrarrb isoformatcalculate_position_pnlrr9rrmax)rrrrrU position_inforBrrCr~rDrrSrcurrent_market_price leverage_datarrbase_tp_percent position_datapnl_data current_pnlexisting_positionsaved_peak_data saved_peak saved_entry previous_peakrrrsync_with_current_positionss      $      z'ProfitTaker.sync_with_current_positionscCs>z|jdd}|}||}|jdt|d|||}|j ||_Wdn1s4wY|jdt||r|jd|jd|jd| D]\}}|d }|d }|d } |d } |d } |d} |d} |d}| dkrd| d}d| d}n d| d}d| d}| dkrdnd}| dkrdnd}| t dkrd}n| dkrdnd}|| dd}|j|dd|d d!|d"d#|d"d$| d%d&|d'd(|| dd)|d|q\|jdWdS|jd*WdSt y}z|j d+|WYd}~dSd}~ww),u)Met à jour le repo des positions activesH)rXz Reconstruits z trades depuis les fillsNu!Positions actives mises à jour: zP================================================================================zPOSITIONS ACTIVES:rBrCrDrr}rr@rr\$z,.2fz.5fr+roUPDOWNrAz N/A z>6.2frz<6 z<5z | Entry: z<12z -> Current: z | Size: z<8.3fz | Leverage: z>2z x | PnL: z % | Peak: u!Aucune position active détectéeuErreur mise à jour positions: ) rirlrrrr;rrrrIrLr<rN)rrmrrrrSrUrBrCentrycurrentr~pnl_pctpeak_pnlr entry_str current_strpnl_sign pnl_color peak_display peak_signr>rrrupdate_active_positionssj          &  z#ProfitTaker.update_active_positions STOP_LOSSrBreasonc Csz|js dddWS|j}d}|D]}|dddd}||kr1t|dd d kr1|}nq|s>dd |d dWS|d d}|d k}tt|dd } |jd|d|d| d||jj ||| dd|d|d} | dr|jd |d||j r|j |||j $t |jD]} |j| d|kr| |jvr|j| =qWdn1swY|dd |ddWS|jd|d| dd| dddWSty } zd|d| } |j| d| dWYd} ~ Sd} ~ ww)z8Ferme une position par symbole via le client HyperliquidFrZ)successrNNrBrorpr~rru non trouvéerCrszFermeture position rz: Size=z , Reason=TCLOSE_rw)rBis_buyr~ reduce_only order_tagru fermée avec succès: u fermée)rmessageuÉchec fermeture : rNzErreur inconnuezErreur fermeture position )rrjrJrrLrrrrplace_market_orderrrecord_position_closerlistrkeysr9rVrNr<)rrBr hl_positionstarget_positionrU pos_symbol position_siderr~resultrSr> error_msgrrrclose_position_by_symbols\  $   z$ProfitTaker.close_position_by_symbolcCsdS)uKANCIENNE VERSION -12% - REMPLACÉE PAR VERSION ADAPTATIVE - NE PAS UTILISERNrrrrr&check_stop_loss_conditions_old_versionsz2ProfitTaker.check_stop_loss_conditions_old_versionc Cs(|j;g}|jD]+\}}|d}|d}|dd}|d}|d}|r6|jd|d|d d q Wd n1sAwY|D]I\}} z'||| } | d rc|jd |dn|jd|d| dWqHt y} z|jd|d| WYd } ~ qHd } ~ wwd S)u<Vérifie si les positions ont atteint leur target price (TP)rBrCrrrrzTARGET PRICE DISABLED: u+ géré uniquement par trailing stop (PnL: r%)NrzTARGET PRICE EXECUTED: u fermée avec succès sur TPzTARGET PRICE FAILED:  - rNzErreur target price r) rrrIrJrdebugrcriticalrNr<) rpositions_to_closerSrrBrCrrrrrr>rrrcheck_target_price_conditions s2     $z)ProfitTaker.check_target_price_conditionsc Csbd}|jNg}|jD]>\}}|d}|d}|dd}||}|dkrK||krK|jd|d|dd |d |d d |d d |||fq Wdn1sVwY|D]Q\}} z/||d| d} | dr|jd|d| ddn|j d|d| dWq]t y} z|j d|d| WYd} ~ q]d} ~ wwdS)u,Vérifie et ferme les positions trop petites$@rBr}rrzSMALL POSITION DETECTED: z Value=$rz < $z (Size=z.3fz @ $z.4f)NzSMALL_POSITION_$.1frzSMALL POSITION CLOSED: u fermée avec succès (Value=$zSMALL POSITION CLOSE FAILED: rrNz!Erreur fermeture petite position r) rrrIrJrr`rKrrrNr<) rMIN_POSITION_VALUE_USDrrSrrBr}rposition_value_usdrrr>rrrcheck_small_position_conditions's4 2  $z+ProfitTaker.check_small_position_conditionsc Cs|jwg}|jD]g\}}|d}|d}|d}|dd}d}|dkr*d} n|d kr1d } n |d kr8d } nd} |td krr||krr||| krr||} |jd|d|d|dd|dd| dd| dd |||fq Wdn1s}wY|D]Z\}}z8||d|d} | dr|j d|d|d|j r|j |dn|j d|d | d!Wqt y} z|j d"|d#| WYd} ~ qd} ~ wwdS)$uDVérifie les conditions de trailing stop adaptatif selon le leveragerr@rBrrg@g4@g@rg@g@g@rAu🔻 TRAILING STOP: z Lzx | PnL=rz % | Peak=z % | Recul=z% > z.0frNTRAILING_STOP_LEVxrzTRAILING STOP EXECUTED: u fermée avec succès (Leverage zx) TRAILING_STOPzTRAILING STOP FAILED: rrNzErreur trailing stop r)rrrIrJrLrr`rKrrrrrNr<) rrrSrrrrBrmin_profit_activationtrailing_distancedrawdownrr>rrrcheck_trailing_stop_conditionsGsN   : % $z*ProfitTaker.check_trailing_stop_conditionsc Cs|jIg}|jD]9\}}|d}|d}|d}|dd}||||}|rD|jd|d|d|d d |||||fq Wd n1sOwY|D]i\}}}}zEd |d |d|dd } ||| } | dr|j d|d|d|d d|j r|j |dn|j d|d| dWqVt y} z|j d|d| WYd } ~ qVd } ~ wwd S)uRDétecte les véritables inversions de tendance basées sur des signaux contrairesrBrCrrrzREAL TREND REVERSAL DETECTED: rz) | Strong opposite signal detected | PnL=rrNREAL_TREND_REVERSAL__Lx_rrzREAL TREND REVERSAL CLOSE:  fermée complètement (PnL=rTREND_REVERSALz"REAL TREND REVERSAL CLOSE FAILED: rrNz!Erreur fermeture vraie inversion r)rrrIrJ_detect_real_trend_reversalrr`rKrrrrrNr<) rrrSrrBrCpnlrreversal_detectedrrr>rrrcheck_trend_reversal_conditions{s< "  "$z+ProfitTaker.check_trend_reversal_conditions current_siderc CsFzddlm}|}|}d}|D] }|d|kr|}nq|s%WdS|dd} |dd} |d kr9| d kp@|d ko@| d k} | r| d kr^|jd |d |d| d| dd WdS| dkr|dkr|jd|d |d| d| dd|dd WdSWdSty} z|jd|d| WYd} ~ dSd} ~ ww)u Détecte un vrai retournement de tendance basé sur des signaux contraires Returns True si un signal contraire fort est détecté r)PragmaticSignalGeneratorNrBFrCro confidencerrrsgT@zStrong opposite signal: rz -> z signal at rz % confidenceTgN@gz$Moderate opposite signal with loss: z% confidence, PnL=rru"Erreur détection vraie inversion r)'simple_trading_system.pragmatic_signalsrgenerate_signalsrJrrr<rN) rrBrrr signal_gen all_signalssignalsig signal_sidesignal_confidenceis_opposite_signalr>rrrrs<   (0z'ProfitTaker._detect_real_trend_reversalc Cs|jag}|jD]Q\}}|d}|d}|d}|dd}|dkr(d}n|dkr/d }n |d kr6d }nd }||kr\|jd |d|d|dd|d|d |||||fq Wdn1sgwY|D]i\}}}}zEd|d|d|dd} ||| } | dr|jd|d|d|dd|j r|j |dn|j d|d| d Wqnt y} z|j d!|d"| WYd} ~ qnd} ~ wwdS)#uASystème de stop-loss séparé du trend reversal - moins agressifrBrCrrrgrg rg(g.zSTOP LOSS TRIGGERED: rz | PnL=rz % | Leverage=zx | Threshold=rN STOP_LOSS_rrrrzSTOP LOSS CLOSE: rrrzSTOP LOSS CLOSE FAILED: rrNzErreur fermeture stop-loss r) rrrIrJrr`rKrrrrrNr<) rrrSrrBrCrrstop_loss_thresholdrrr>rrrcheck_stop_loss_conditionssH .  "$z&ProfitTaker.check_stop_loss_conditionsc Cs|jd|jrmz>|||||||t |ds.d|_ t |j dkr@| t |_ t |jWn tyg}z|jd|t dWYd}~nd}~ww|js dSdS)z Boucle principale du ProfitTakeru&Démarrage de la boucle ProfitTaker..._last_peak_saverzErreur dans profit_taker_loop: rN)rrrrrrrrrhasattrrrHrVsleeprr<rN)rr>rrrprofit_taker_loops,   zProfitTaker.profit_taker_loopcCs@|jsd|_t|jd|_d|j_|j|jddSdS)uDémarre le ProfitTakerT)targetuProfitTaker démarréN)rrr worker_threaddaemonstartrrrrrrrs zProfitTaker.startcCs.d|_t|dr|jjdd|jddS)uArrête le ProfitTakerFrr)timeoutuProfitTaker arrêtéN)rrrr)rrrrrrstop's zProfitTaker.stopcCsJ|jt|jdd|jDdWdS1swYdS)u*Retourne un résumé des positions activescSs0i|]\}}||d|d|d|ddqS)rBrCrr})rBrCrr}r)rrSrUrrr 3s z5ProfitTaker.get_positions_summary..)total_positionsrkN)rr;rrIrrrrget_positions_summary.s$z!ProfitTaker.get_positions_summary)N)rW)r)__name__ __module__ __qualname____doc__rrrrVrarrrirlstrrrrrrrrrrrLboolrrrrrrrrrrr s0 )!*=D= 4!/*) r )r#r rHrr threadingrrtypingrrrr$r7rr ImportErrorr rrrrs