Esta estratégia reproduz o comportamento do expert MetaTrader original stochSell. Ela ouve um único fluxo de velas e aguarda uma confirmação estocástica tripla combinada com um filtro de volatilidade antes de enviar uma ordem de venda a mercado inicial. Imediatamente após a entrada vendida, implanta uma escada de sell stops pendentes para escalar no movimento se o preço continuar caindo.
Lógica de negociação
Filtro de volatilidade – um Average True Range (ATR) com comprimento configurável deve permanecer abaixo do limiar especificado.
Confirmação estocástica lenta – o oscilador estocástico de período mais longo deve permanecer abaixo do nível de sobrevendido de longo prazo antes de qualquer negociação ser permitida.
Confirmação de cruzamento – tanto o oscilador estocástico médio quanto o rápido devem cruzar para baixo através do gatilho de sobrevendido durante a mesma vela finalizada.
Verificação de posição – novas entradas são colocadas apenas quando a estratégia não tem ordens ativas e a posição está zerada.
Uma vez que todas as condições são atendidas, a estratégia envia uma ordem de venda a mercado usando o volume configurado e imediatamente programa um conjunto de ordens de sell stop de acordo com as configurações de grade. Ordens pendentes são opcionais e podem ser desativadas definindo a contagem de ordens de grade como zero.
Regras de saída
Alvo de lucro – quando a cesta vendida acumula o lucro desejado em pips (calculado a partir do preço de entrada ponderado por volume), a estratégia recompra toda a posição e remove cada ordem pendente restante.
Stop manual – ordens de grade respeitam um tempo de vida configurável. Quando uma ordem de stop expira sem ser executada, é cancelada automaticamente.
Fechamento completo – qualquer operação de compra que retorne a posição a zero limpa as estatísticas de entrada internas e cancela a grade pendente.
Gestão de grade
Ordens pendentes são colocadas abaixo do preço de referência usando o offset inicial e o passo expressos em pips.
Cada ordem pendente usa o multiplicador de volume da grade, permitindo que o tamanho da cesta difira da entrada a mercado inicial.
O vencimento (em minutos) é aplicado a cada ordem pendente; zero desativa o tempo limite.
Parâmetros
Nome
Descrição
CandleType
Período principal para cada indicador e decisão de negociação.
AtrPeriod / AtrThreshold
Filtro de volatilidade que controla quando a estratégia pode negociar.
FastKPeriod, FastDPeriod, FastSlowing
Configuração do oscilador estocástico rápido.
MediumKPeriod, MediumDPeriod, MediumSlowing
Configuração do oscilador estocástico médio.
SlowKPeriod, SlowDPeriod, SlowSlowing
Configuração do oscilador estocástico lento.
OversoldLevel
Nível que os valores estocásticos rápido e médio devem cruzar para baixo.
LongTermOversoldLevel
Limite superior para o estocástico lento durante a entrada.
ProfitTargetPips
Lucro líquido em pips necessário para fechar a cesta vendida.
GridOrdersCount
Número de sell stops pendentes criados após a entrada.
GridStartOffsetPips
Offset em pips entre o preço de entrada e a primeira ordem pendente.
GridStepPips
Distância em pips entre ordens pendentes consecutivas.
GridVolume
Volume aplicado a cada ordem pendente.
GridExpirationMinutes
Tempo de vida das ordens pendentes em minutos.
MarketVolume
Volume usado para a venda a mercado inicial.
Notas
Os valores dos indicadores são processados através da API BindEx de alto nível e apenas velas finalizadas acionam decisões de negociação.
A lógica de rastreamento de posição mantém um preço de entrada ponderado por volume para traduzir o alvo de lucro bruto em pips.
Para desativar o escalonamento, basta definir a contagem de ordens de grade como zero; a estratégia ainda dependerá da confirmação estocástica e do filtro ATR para operações de disparo único.
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 StochSellStrategy : 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 StochSellStrategy()
{
_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 stoch_sell_strategy(Strategy):
def __init__(self):
super(stoch_sell_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(stoch_sell_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(stoch_sell_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 stoch_sell_strategy()