La estrategia Target EA Manager es una adaptación fiel a StockSharp del experto de MetaTrader TargetEA_v1.5. La estrategia no abre operaciones nuevas por sí misma. En su lugar, monitoriza constantemente la ganancia y pérdida flotante de las órdenes que ya pertenecen a la estrategia y, si es necesario, liquida posiciones y cancela órdenes pendientes cuando se alcanzan umbrales definidos por el usuario. El comportamiento reproduce la lógica de gestión de "cesta" del experto original: las órdenes de compra y venta pueden evaluarse de forma independiente o como una sola cesta combinada.
La estrategia se suscribe a datos Level1 (mejor bid y ask) y usa la API de alto nivel para cierres de posición y cancelación de órdenes. Las cotizaciones bid y ask en tiempo real se traducen en métricas de ganancia no realizada para la exposición abierta.
Funciones clave
Cestas independientes o combinadas - elija si las órdenes largas y cortas se tratan por separado o juntas mediante ManageBuySellOrders.
Múltiples tipos de objetivo - los umbrales pueden expresarse en pips, en divisa de la cuenta por lote o como porcentaje del balance de la cartera, coincidiendo con el flag TypeTargetUse de la versión MQL.
Disparadores de ambos lados - interruptores separados para reaccionar a ganancias flotantes (CloseInProfit) y pérdidas flotantes (CloseInLoss).
Limpieza de órdenes pendientes - cancelación opcional de órdenes pendientes de compra y/o venta cada vez que se cierra una cesta.
Operaciones de alto nivel - las salidas de mercado se ejecutan con BuyMarket / SellMarket, y las órdenes pendientes se cancelan mediante la colección de órdenes de la estrategia.
Parámetros
Parámetro
Descripción
ManageBuySellOrders
Separate emula dos cestas (larga y corta), Combined fusiona ambos lados.
Cancela órdenes pendientes activas después de que se cierre una cesta.
TypeTargetUse
Pips, CurrencyPerLot o PercentageOfBalance seleccionan la medición aplicada al PnL abierto.
CloseInProfit / CloseInLoss
Activa disparadores de ganancia o pérdida.
TargetProfitInPips, TargetLossInPips
Umbrales en pips. Cuando el instrumento proporciona PriceStep, el valor de pip se calcula como priceDifference / PriceStep * (volume / VolumeStep).
TargetProfitInCurrency, TargetLossInCurrency
Ganancia o pérdida flotante por lote, multiplicada por el volumen actual antes de la comparación.
TargetProfitInPercentage, TargetLossInPercentage
Porcentaje del balance de la cartera que debe alcanzarse antes del cierre. El experto original compara la ganancia flotante bruta con Balance ± Balance * Percentage / 100, y esta adaptación conserva intacta esa convención.
Comportamiento
Seguimiento de estado - las operaciones ejecutadas actualizan los totales internos de volumen largo y corto y sus precios medios ponderados. Por tanto, las posiciones cubiertas (largas y cortas) se manejan correctamente.
Cálculo de PnL - cada actualización Level1 refresca los valores bid/ask, a partir de los cuales se calculan ganancias en pips y divisa para ambos lados.
Evaluación de objetivos - según el modo de objetivo y el modo de cesta, se comprueban los umbrales correspondientes. Las comprobaciones de ganancia requieren valores mayores o iguales a los objetivos configurados, mientras que las comprobaciones de pérdida usan comparaciones menores o iguales, coincidiendo con la lógica MQL.
Liquidación de cesta - cuando una condición se satisface, la estrategia cancela opcionalmente órdenes pendientes de ese lado y envía la orden de mercado necesaria para aplanar la exposición abierta.
La implementación evita intencionalmente colecciones adicionales o almacenamiento de indicadores, y se apoya en la API de alto nivel de StockSharp, igual que el EA original.
using System;
using System.Collections.Generic;
using Ecng.Common;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.BusinessEntities;
using StockSharp.Messages;
namespace StockSharp.Samples.Strategies;
public class TargetEaManagerStrategy : Strategy
{
private readonly StrategyParam<int> _fastPeriod;
private readonly StrategyParam<int> _slowPeriod;
private readonly StrategyParam<int> _stopLossPoints;
private readonly StrategyParam<int> _takeProfitPoints;
private ExponentialMovingAverage _fast;
private ExponentialMovingAverage _slow;
private decimal _prevFast;
private decimal _prevSlow;
private decimal _entryPrice;
private int _cooldown;
public int FastPeriod { get => _fastPeriod.Value; set => _fastPeriod.Value = value; }
public int SlowPeriod { get => _slowPeriod.Value; set => _slowPeriod.Value = value; }
public int StopLossPoints { get => _stopLossPoints.Value; set => _stopLossPoints.Value = value; }
public int TakeProfitPoints { get => _takeProfitPoints.Value; set => _takeProfitPoints.Value = value; }
public TargetEaManagerStrategy()
{
_fastPeriod = Param(nameof(FastPeriod), 14).SetGreaterThanZero().SetDisplay("Fast Period", "Fast EMA period", "Indicator");
_slowPeriod = Param(nameof(SlowPeriod), 50).SetGreaterThanZero().SetDisplay("Slow Period", "Slow EMA period", "Indicator");
_stopLossPoints = Param(nameof(StopLossPoints), 200).SetNotNegative().SetDisplay("Stop Loss", "Stop-loss in price steps", "Risk");
_takeProfitPoints = Param(nameof(TakeProfitPoints), 400).SetNotNegative().SetDisplay("Take Profit", "Take-profit in price steps", "Risk");
}
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
{
yield return (Security, TimeSpan.FromMinutes(5).TimeFrame());
}
protected override void OnReseted()
{
base.OnReseted();
_fast = null; _slow = null;
_prevFast = 0; _prevSlow = 0; _entryPrice = 0; _cooldown = 0;
}
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_fast = new ExponentialMovingAverage { Length = FastPeriod };
_slow = new ExponentialMovingAverage { Length = SlowPeriod };
var subscription = SubscribeCandles(TimeSpan.FromMinutes(5).TimeFrame());
subscription.Bind(_fast, _slow, ProcessCandle);
subscription.Start();
}
private void ProcessCandle(ICandleMessage candle, decimal fastValue, decimal slowValue)
{
if (candle.State != CandleStates.Finished) return;
if (!_fast.IsFormed || !_slow.IsFormed) { _prevFast = fastValue; _prevSlow = slowValue; return; }
if (_cooldown > 0) { _cooldown--; _prevFast = fastValue; _prevSlow = slowValue; return; }
var close = candle.ClosePrice;
var step = Security?.PriceStep ?? 1m;
if (Position > 0 && _entryPrice > 0)
{
if (StopLossPoints > 0 && close <= _entryPrice - StopLossPoints * step) { SellMarket(); _entryPrice = 0; _cooldown = 100; _prevFast = fastValue; _prevSlow = slowValue; return; }
if (TakeProfitPoints > 0 && close >= _entryPrice + TakeProfitPoints * step) { SellMarket(); _entryPrice = 0; _cooldown = 100; _prevFast = fastValue; _prevSlow = slowValue; return; }
}
else if (Position < 0 && _entryPrice > 0)
{
if (StopLossPoints > 0 && close >= _entryPrice + StopLossPoints * step) { BuyMarket(); _entryPrice = 0; _cooldown = 100; _prevFast = fastValue; _prevSlow = slowValue; return; }
if (TakeProfitPoints > 0 && close <= _entryPrice - TakeProfitPoints * step) { BuyMarket(); _entryPrice = 0; _cooldown = 100; _prevFast = fastValue; _prevSlow = slowValue; return; }
}
if (_prevFast <= _prevSlow && fastValue > slowValue && Position <= 0)
{ if (Position < 0) BuyMarket(); BuyMarket(); _entryPrice = close; _cooldown = 100; }
else if (_prevFast >= _prevSlow && fastValue < slowValue && Position >= 0)
{ if (Position > 0) SellMarket(); SellMarket(); _entryPrice = close; _cooldown = 100; }
_prevFast = fastValue; _prevSlow = slowValue;
}
}
import clr
clr.AddReference("StockSharp.Messages")
clr.AddReference("StockSharp.Algo")
clr.AddReference("StockSharp.Algo.Indicators")
clr.AddReference("StockSharp.Algo.Strategies")
from System import TimeSpan
from StockSharp.Messages import DataType, CandleStates
from StockSharp.Algo.Indicators import ExponentialMovingAverage
from StockSharp.Algo.Strategies import Strategy
class target_ea_manager_strategy(Strategy):
def __init__(self):
super(target_ea_manager_strategy, self).__init__()
self._fast_period = self.Param("FastPeriod", 14) \
.SetDisplay("Fast Period", "Fast MA period", "Indicator")
self._slow_period = self.Param("SlowPeriod", 50) \
.SetDisplay("Slow Period", "Slow MA period", "Indicator")
self._stop_loss_points = self.Param("StopLossPoints", 200) \
.SetDisplay("Stop Loss", "Stop-loss in price steps", "Risk")
self._take_profit_points = self.Param("TakeProfitPoints", 400) \
.SetDisplay("Take Profit", "Take-profit in price steps", "Risk")
self._fast = None
self._slow = None
self._prev_fast = 0.0
self._prev_slow = 0.0
self._entry_price = 0.0
self._cooldown = 0
@property
def fast_period(self):
return self._fast_period.Value
@property
def slow_period(self):
return self._slow_period.Value
@property
def stop_loss_points(self):
return self._stop_loss_points.Value
@property
def take_profit_points(self):
return self._take_profit_points.Value
def OnReseted(self):
super(target_ea_manager_strategy, self).OnReseted()
self._fast = None
self._slow = None
self._prev_fast = 0.0
self._prev_slow = 0.0
self._entry_price = 0.0
self._cooldown = 0
def OnStarted2(self, time):
super(target_ea_manager_strategy, self).OnStarted2(time)
self._fast = ExponentialMovingAverage()
self._fast.Length = self.fast_period
self._slow = ExponentialMovingAverage()
self._slow.Length = self.slow_period
subscription = self.SubscribeCandles(DataType.TimeFrame(TimeSpan.FromMinutes(5)))
subscription.Bind(self._fast, self._slow, self._process_candle)
subscription.Start()
def _process_candle(self, candle, fast_value, slow_value):
if candle.State != CandleStates.Finished:
return
fast_val = float(fast_value)
slow_val = float(slow_value)
if not self._fast.IsFormed or not self._slow.IsFormed:
self._prev_fast = fast_val
self._prev_slow = slow_val
return
if self._cooldown > 0:
self._cooldown -= 1
self._prev_fast = fast_val
self._prev_slow = slow_val
return
close = float(candle.ClosePrice)
step = float(self.Security.PriceStep) if self.Security is not None and self.Security.PriceStep is not None else 1.0
if self.Position > 0 and self._entry_price > 0:
if self.stop_loss_points > 0 and close <= self._entry_price - self.stop_loss_points * step:
self.SellMarket()
self._entry_price = 0.0
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
return
if self.take_profit_points > 0 and close >= self._entry_price + self.take_profit_points * step:
self.SellMarket()
self._entry_price = 0.0
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
return
elif self.Position < 0 and self._entry_price > 0:
if self.stop_loss_points > 0 and close >= self._entry_price + self.stop_loss_points * step:
self.BuyMarket()
self._entry_price = 0.0
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
return
if self.take_profit_points > 0 and close <= self._entry_price - self.take_profit_points * step:
self.BuyMarket()
self._entry_price = 0.0
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
return
if self._prev_fast <= self._prev_slow and fast_val > slow_val and self.Position <= 0:
if self.Position < 0:
self.BuyMarket()
self.BuyMarket()
self._entry_price = close
self._cooldown = 100
elif self._prev_fast >= self._prev_slow and fast_val < slow_val and self.Position >= 0:
if self.Position > 0:
self.SellMarket()
self.SellMarket()
self._entry_price = close
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
def CreateClone(self):
return target_ea_manager_strategy()