La Estrategia de Pure Price Action es un port de StockSharp del asesor experto de MetaTrader "Pure Price Action" (MQL id 24291).
Combina la confirmación de ruptura de los fractales de Bill Williams con un filtro de momentum calculado en un marco temporal superior y un filtro de tendencia MACD a largo plazo.
El algoritmo intenta capturar operaciones de continuación de tendencia inmediatamente después de que el mercado retoca el nivel fractal más reciente.
Lógica de trading
Velas de señal – Las decisiones de trading se toman en el marco temporal seleccionado por el usuario (15 minutos por defecto).
Confirmación de toque fractal – Una operación solo está permitida si la vela terminada más reciente cierra dentro de un paso de precio del nivel fractal confirmado más reciente (fractal superior para cortos, fractal inferior para largos).
Patrón de cuerpo direccional – El tamaño absoluto del cuerpo de la vela más reciente debe ser menor que el cuerpo de la vela anterior, mientras que el cuerpo anterior debe ser mayor que la vela anterior a él. Esto imita el filtro de retroceso de momentum del EA original.
Medias móviles – Dos medias móviles lineales ponderadas (LWMA 6 y LWMA 85 por defecto) proporcionan la tendencia base. Las operaciones largas requieren que el LWMA rápido esté por encima del LWMA lento; las cortas requieren lo opuesto.
Filtro de momentum – Un indicador de momentum de 14 períodos evaluado en un marco temporal superior (H1 por defecto) debe desviarse del nivel de equilibrio (100) al menos por el umbral configurado durante cualquiera de las últimas tres lecturas de momentum.
Filtro MACD – Un MACD(12, 26, 9) calculado en un marco temporal superior (mensual por defecto) debe mostrar la línea principal por encima de la línea de señal para largos y por debajo para cortos.
Dimensionamiento de posición – La estrategia usa la propiedad Volume de la clase base Strategy. Si Volume no está establecido, toma como predeterminado un contrato/lote. El parámetro MaxPosition limita el tamaño absoluto de la posición.
Gestión de posición
Protección inicial – Las distancias opcionales fijas de stop-loss y take-profit se especifican en pasos de precio y se aplican simétricamente a ambos lados.
Trailing stop – Cuando está habilitado, la estrategia rastrea el precio más alto/más bajo alcanzado después de la entrada a la distancia configurada.
Bloqueo de break-even – Después de que el precio recorre la distancia de activación, el nivel protector se mueve a la entrada ± offset para asegurar ganancias.
Salidas manuales – La lógica evalúa niveles de stop-loss, take-profit, trailing y break-even en cada vela terminada y cierra toda la posición cuando se cumple cualquier condición.
Parámetros
CandleType – Marco temporal de señal principal (predeterminado: marco temporal de 15 minutos).
MomentumCandleType – Marco temporal para el indicador de momentum (predeterminado: marco temporal de 1 hora).
MacdCandleType – Marco temporal para el filtro MACD (predeterminado: marco temporal de 30 días, emulando velas mensuales).
FastPeriod / SlowPeriod – Períodos del LWMA rápido y lento.
MomentumPeriod – Longitud del indicador de momentum.
MomentumThreshold – Desviación absoluta mínima del Momentum respecto a 100.
StopLossPoints, TakeProfitPoints – Distancias de protección de riesgo en pasos de precio.
TrailingStopPoints – Distancia de trailing en pasos de precio.
BreakEvenTriggerPoints, BreakEvenOffsetPoints – Distancias de activación y beneficio asegurado del break-even.
MaxPosition – Tamaño máximo absoluto de posición manejado por la estrategia.
EnableTrailing, EnableBreakEven, UseStopLoss, UseTakeProfit – Controles para los bloques de gestión de riesgo.
Notas
Todos los comentarios dentro del código están escritos en inglés, como requieren las directrices del proyecto.
La estrategia se basa únicamente en velas terminadas; las señales dentro de la barra no se procesan.
Las suscripciones multi-marco temporal se usan para emular el comportamiento del asesor experto original (velas de señal M15, momentum H1, MACD mensual por defecto).
No se proporcionan pruebas automáticas en esta carpeta. La suite de pruebas del repositorio global debe permanecer intacta, como se solicitó.
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 PurePriceActionFractalStrategy : 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 PurePriceActionFractalStrategy()
{
_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 pure_price_action_fractal_strategy(Strategy):
def __init__(self):
super(pure_price_action_fractal_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(pure_price_action_fractal_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(pure_price_action_fractal_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 pure_price_action_fractal_strategy()