La estrategia Trend Line replica la lógica central de gestión de trades del experto MetaTrader original combinando una media móvil ponderada linealmente rápida y lenta, un filtro de Momentum y una confirmación MACD. La conversión se centra en componentes StockSharp de alto nivel y mantiene el mismo enfoque sistemático que espera impulsos de Momentum en la dirección de la tendencia antes de entrar. Los stops de protección, los objetivos de beneficio y un stop de seguimiento opcional en pasos de precio proporcionan una gestión de riesgos similar al experto original.
Lógica de trading
Suscribirse a la serie de velas configurada y calcular los siguientes indicadores:
Media móvil ponderada linealmente (LWMA) rápida con el FastMaPeriod configurable.
LWMA lenta con el SlowMaPeriod configurable.
Indicador Momentum con período MomentumPeriod. Las tres lecturas de Momentum más recientes se rastrean para emular la verificación de Momentum de múltiples barras presente en la versión MQL.
Indicador de Convergencia/Divergencia de Medias Móviles (MACD) con longitudes estándar de rápida/lenta/señal. La estrategia almacena los valores de MACD y señal para uso posterior.
Entrar largo cuando:
La LWMA rápida está por encima de la LWMA lenta.
Al menos uno de los últimos tres valores de Momentum es mayor o igual a MomentumBuyThreshold.
La línea principal MACD está por encima de la línea de señal MACD.
No existe ninguna posición corta abierta (la exposición corta se aplana antes de abrir una posición larga).
Entrar corto cuando:
La LWMA rápida está por debajo de la LWMA lenta.
Al menos uno de los últimos tres valores de Momentum es menor o igual a MomentumSellThreshold (el umbral debe ser negativo para detectar aceleración descendente).
La línea principal MACD está por debajo de la línea de señal MACD.
No existe ninguna posición larga abierta (la exposición larga se aplana antes de abrir una posición corta).
Después de cada entrada, la estrategia coloca órdenes protectoras de stop-loss y take-profit por distancia en pasos de precio. Ambas órdenes se recalculan cada vez que cambia la posición.
Se puede activar un stop de seguimiento con TrailingStopSteps y TrailingTriggerSteps. Una vez que la posición abierta gana al menos la distancia de disparo, el stop-loss se mueve a TrailingStopSteps del precio de cierre actual de la vela procesada.
Parámetros
CandleType – tipo de datos para la serie de velas utilizada por cada indicador (temporalidad de 1 hora por defecto).
FastMaPeriod – período de la LWMA rápida (por defecto 6).
SlowMaPeriod – período de la LWMA lenta (por defecto 85).
MomentumPeriod – número de velas para el cálculo de Momentum (por defecto 14).
MomentumSellThreshold – Momentum máximo (negativo) permitido antes de abrir nuevas posiciones cortas (por defecto -0.3).
MacdFastLength – longitud EMA rápida del MACD (por defecto 12).
MacdSlowLength – longitud EMA lenta del MACD (por defecto 26).
MacdSignalLength – longitud EMA de señal del MACD (por defecto 9).
StopLossSteps – distancia de stop de protección expresada en pasos del instrumento (por defecto 20).
TakeProfitSteps – distancia del objetivo de beneficio de protección en pasos (por defecto 50).
TrailingStopSteps – distancia del stop de seguimiento en pasos (por defecto 40, desactivado cuando es cero).
TrailingTriggerSteps – beneficio en pasos requerido antes de que el stop de seguimiento se active (por defecto 40).
Notas
Los vínculos de indicadores se basan solo en velas terminadas; los datos no terminados se ignoran para evitar señales prematuras.
SetStopLoss y SetTakeProfit trabajan con distancias en pasos de precio, lo que mantiene el comportamiento consistente en instrumentos con diferentes tamaños de tick.
Cuando MomentumSellThreshold se mantiene positivo, la comparación predeterminada (<= threshold) espera que ese valor sea negativo. Ajuste el signo al optimizar la estrategia.
El stop de seguimiento funciona en modo de fin de barra porque se actualiza cuando se procesa cada vela terminada, reflejando el script original que recalculaba los stops en nuevas barras.
La conversión omite intencionalmente el dibujo manual de líneas de tendencia y las reglas de liquidación basadas en capital porque dependían de características interactivas de la terminal no disponibles en StockSharp. Se preservan todas las demás reglas centrales de entrada y riesgo.
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 TrendLineStrategy : 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 TrendLineStrategy()
{
_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 trend_line_strategy(Strategy):
def __init__(self):
super(trend_line_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(trend_line_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(trend_line_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 trend_line_strategy()