A estratégia Eliot Waves replica o comportamento do expert advisor do MetaTrader "Eliot Waves" usando a API de alto nível do StockSharp. O algoritmo combina detecção de tendência por duas médias móveis ponderadas lineares com confirmação de momentum e saídas baseadas em volatilidade. Todos os cálculos são realizados em candles concluídos de um período configurável para espelhar a execução determinística do robô original.
Lógica de negociação
Filtro de tendência. A estratégia compara uma LWMA rápida (período padrão 6) com uma LWMA lenta (período padrão 85) calculadas sobre o preço típico do candle. Operações compradas são consideradas apenas quando a LWMA rápida fecha acima da LWMA lenta, enquanto operações vendidas exigem o alinhamento oposto.
Confirmação de momentum. Um indicador de momentum (período padrão 14) deve mostrar pelo menos uma das três últimas leituras se desviando do valor neutro 100 por mais que o limite configurado (padrão 0.3). Isso replica o EA original, que verificava a diferença absoluta de três valores recentes de momentum.
Filtro de estrutura do candle. Sinais comprados exigem que a mínima do candle de duas barras atrás esteja abaixo da máxima do candle anterior. Sinais vendidos exigem que a mínima do candle anterior permaneça abaixo da máxima de duas barras atrás. Isso captura o filtro estilo divergência presente no código-fonte.
Escalonamento de posição. Cada sinal tenta adicionar um passo de volume fixo (padrão 0.1) até o número máximo de passos (padrão 10). A estratégia fecha qualquer exposição oposta antes de abrir uma nova posição para permanecer alinhada com a implementação do MetaTrader.
Gestão de risco
Stop-loss e take-profit. Alvos de preço são definidos em pips relativos ao preço médio de entrada e recalculados sempre que a posição muda.
Trailing stop. Quando habilitado, o stop é puxado atrás do preço quando o lucro aberto excede a distância de trailing.
Break-even. Depois de atingir o gatilho configurado, o stop é movido para o preço de entrada mais um offset opcional, protegendo lucros acumulados.
Saída por Bollinger Band. Posições compradas saem quando o preço toca a banda inferior de um canal Bollinger de 20 períodos, enquanto posições vendidas saem no toque da banda superior. Isso espelha a lógica de fechamento baseada em volatilidade do script MQL.
Confirmação MACD. Posições também são fechadas em um cruzamento de sinal MACD (12, 26, 9) contra a direção da operação, reproduzindo a saída MACD mensal do expert original.
Chave de saída forçada. O parâmetro EnableExitStrategy permite que um operador liquide instantaneamente toda posição aberta.
Parâmetros
Nome
Descrição
Padrão
TradeVolume
Volume usado para cada passo de posição.
0.1
CandleType
Período do candle empregado para todos os indicadores.
Candles de 15 minutos
FastMaPeriod / SlowMaPeriod
Períodos das médias móveis ponderadas lineares rápida e lenta.
6 / 85
MomentumPeriod
Retrospectiva de momentum usada no bloco de confirmação.
14
MomentumThreshold
Desvio mínimo a partir de 100 exigido para habilitar a negociação.
0.3
StopLossPips / TakeProfitPips
Distâncias de stop-loss e take-profit expressas em pips.
20 / 50
EnableTrailing / TrailingStopPips
Chave e distância para o recurso de trailing stop.
Chave de ativação, gatilho e offset de break-even em pips.
true, 30, 30
MaxPositions
Número máximo de passos de volume permitidos.
10
EnableExitStrategy
Força a estratégia a zerar a posição quando habilitado.
false
Notas de conversão
A implementação StockSharp depende do pipeline de alto nível SubscribeCandles().BindEx(...) para processar todos os indicadores simultaneamente e operar estritamente em candles concluídos.
A conversão de pips usa o passo de preço do ativo sempre que possível e recorre ao valor do passo de preço quando a corretora não expõe precisão de pip, correspondendo ao comportamento adaptativo da versão MetaTrader.
A lógica de stop-loss, take-profit, trailing e break-even é gerenciada internamente em vez de usar ordens da corretora, mantendo o comportamento determinístico durante backtests.
Chamadas de alerta, e-mail e notificação do expert MQL foram removidas, pois o StockSharp fornece seus próprios recursos de registro.
Dicas de uso
Selecione o instrumento desejado e ajuste TradeVolume e MaxPositions ao tamanho da conta. Os padrões reproduzem o escalonamento conservador usado no EA.
Otimize MomentumThreshold, StopLossPips e TrailingStopPips em dados históricos se o mercado alvo apresentar características de volatilidade diferentes.
Ao testar múltiplos símbolos, garanta que o ativo exponha um passo de preço correto para que distâncias baseadas em pips sejam convertidas com precisão.
Monitore o log para o aviso "Unable to determine pip size from security settings". Se ele aparecer, considere configurar o instrumento com o passo de preço correto para evitar níveis de risco incompatíveis.
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 EliotWavesStrategy : 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 EliotWavesStrategy()
{
_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 eliot_waves_strategy(Strategy):
def __init__(self):
super(eliot_waves_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(eliot_waves_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(eliot_waves_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 eliot_waves_strategy()