2DLimits é uma portagem direta do expert advisor MetaTrader 4 2DLimits_EA_v2. A estratégia avalia as duas últimas velas diárias completadas e participa apenas quando formam um padrão em escada (máximas/mínimas mais altas ou máximas/mínimas mais baixas). Quando o padrão é válido, a estratégia submete ordens de stop na extremidade do dia anterior e protege a posição com um stop-loss no ponto médio e um alvo igual ao intervalo diário anterior.
A implementação depende das assinaturas de velas de alto nível do StockSharp junto com cotações de nível 1. As velas diárias fornecem os níveis de rompimento enquanto os snapshots do melhor bid/ask garantem que configurações compradas só sejam armadas quando o preço opera abaixo do ponto médio e configurações vendidas só quando o preço opera acima.
Lógica da estratégia
Filtro de estrutura diária
A estratégia mantém uma janela deslizante de dois dias de velas diárias completadas (configurável pelo parâmetro de tipo de vela).
Uma configuração de alta exige que o dia mais recente registre tanto uma máxima mais alta quanto uma mínima mais alta em comparação com o dia anterior.
Uma configuração de baixa exige que o dia mais recente apresente tanto uma máxima mais baixa quanto uma mínima mais baixa que o dia anterior.
O ponto médio do dia mais recente é calculado como (high + low) / 2, e o intervalo da vela é armazenado para o alvo de lucro.
Regras de entrada
Apenas um lote de ordens pendentes está ativo de cada vez; todas as ordens são canceladas e recalculadas quando uma nova vela diária fecha.
Entradas compradas são preparadas quando:
O filtro de estrutura de alta está satisfeito.
O último preço ask está abaixo do ponto médio do dia anterior (espelha a verificação Ask < middleY do EA original).
Uma ordem de compra-stop é colocada exatamente na máxima do dia anterior.
Entradas vendidas são preparadas quando:
O filtro de estrutura de baixa está satisfeito.
O último preço bid está acima do ponto médio do dia anterior (espelha Bid > middleY).
Uma ordem de venda-stop é colocada na mínima do dia anterior.
Se ambas as verificações de estrutura falharem, nenhuma ordem fica ativa para a próxima sessão.
Regras de saída
Quando uma ordem de stop é acionada, a ordem de entrada oposta é cancelada imediatamente para que a estratégia nunca mantenha exposições compradas e vendidas simultaneamente.
Após um rompimento comprado, duas ordens protetoras são registradas:
Uma ordem de stop no ponto médio do dia de referência atua como stop-loss.
Uma ordem de take-profit em máxima anterior + intervalo anterior corresponde à distância de take-profit do MetaTrader.
Após um rompimento vendido, proteção simétrica é aplicada:
Uma ordem de stop no ponto médio (buy-stop) cobre o stop-loss.
Uma ordem de take-profit em mínima anterior - intervalo anterior espelha o alvo original.
Ordens protetoras são reativadas sempre que o tamanho da posição executada muda e são removidas quando a posição retorna ao zero.
Ciclo de vida da ordem e verificações de segurança
Ordens pendentes são atualizadas apenas após a próxima vela diária completar, impondo uma única configuração por dia de negociação.
A estratégia pula a geração de sinais sempre que já possui uma posição, evitando sobreposições entre configurações.
O último snapshot de bid/ask é retido de SubscribeLevel1(); se não disponível, o último preço de transação é usado como fallback para evitar enviar ordens cegas.
O arredondamento é realizado com o passo de preço do instrumento para que todas as ordens se alinhem com o tamanho de tick da bolsa.
Parâmetros
Nome
Descrição
Volume
Volume da ordem para as entradas de stop. Deve ser maior que zero.
CandleType
Tipo de vela que fornece o intervalo de referência (padrão velas diárias).
Notas adicionais
A estratégia gerencia cada ordem diretamente através da API de alto nível; não há dependência de coleções personalizadas ou buffers de indicadores.
Apenas a implementação C# é fornecida neste pacote. Nenhuma versão Python é criada para esta conversão.
Os testes permanecem inalterados conforme solicitado.
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 TwoDLimitsStrategy : 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 TwoDLimitsStrategy()
{
_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 two_d_limits_strategy(Strategy):
def __init__(self):
super(two_d_limits_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(two_d_limits_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(two_d_limits_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 two_d_limits_strategy()