A estratégia OneHrStocTrader replica o consultor especialista do MetaTrader 4 OneHrStocTrader.mq4 dentro da API de alto nível do StockSharp. Ela opera um único instrumento em velas horárias e combina o oscilador estocástico com um filtro de largura das Bandas de Bollinger. Uma operação é aberta apenas quando a volatilidade (medida pela distância entre as Bandas de Bollinger) está dentro do intervalo configurado e o oscilador estocástico abandona uma zona extrema exatamente na hora configurada.
Lógica de trading
Dados
Trabalha com velas horárias por padrão (configurável).
Usa os valores da vela concluída mais recente para corresponder ao comportamento do MetaTrader.
Filtro das Bandas de Bollinger
Calcula a diferença entre as bandas superior e inferior em pips.
Sinais de trading são ignorados quando a diferença cai fora do intervalo [BollingerSpreadLower, BollingerSpreadUpper].
Gatilho do oscilador estocástico
Referencia as duas velas concluídas mais recentes da linha %K estocástica.
Compra: %K atual abaixo de StochasticLower, %K anterior subindo (prev < current) e a nova barra começa em BuyHourStart.
Venda: %K atual acima de StochasticUpper, %K anterior descendo (prev > current) e a nova barra começa em SellHourStart.
Gestão de ordens
Fecha uma posição oposta antes de abrir uma nova.
Limita entradas consecutivas na mesma direção via MaxOrdersPerDirection.
Gestão de risco
Distâncias fixas de take-profit e stop-loss definidas em pips.
Trailing stop opcional que se move em incrementos de pip assim que o preço avança além da distância configurada.
Níveis de proteção internos são monitorados em cada vela concluída; quando atingidos, a estratégia fecha a posição a mercado.
Parâmetros
Nome
Descrição
Padrão
TradeVolume
Tamanho de ordem em lotes.
0.01
CandleType
Período usado para todos os cálculos.
1h
BollingerPeriod
Período de retrocesso das Bandas de Bollinger.
20
BollingerSigma
Multiplicador sigma das Bandas de Bollinger.
2.0
BollingerSpreadLower
Diferença mínima de banda em pips necessária para operar.
56
BollingerSpreadUpper
Diferença máxima de banda em pips permitida para operar.
158
BuyHourStart
Hora (0-23) quando entradas compradas são avaliadas.
4
SellHourStart
Hora (0-23) quando entradas vendidas são avaliadas.
0
StochasticKPeriod
Período %K estocástico.
5
StochasticDPeriod
Período %D estocástico.
3
StochasticSlowing
Fator de desaceleração estocástico.
5
StochasticLower
Limiar de sobrevenda.
36
StochasticUpper
Limiar de sobrecompra.
70
TakeProfitPips
Distância de take-profit em pips.
200
StopLossPips
Distância de stop-loss em pips.
95
TrailingStopPips
Distância de trailing stop em pips (0 = desabilitado).
40
MaxOrdersPerDirection
Máximo de entradas consecutivas por direção.
1
Gráficos
Quando uma superfície de gráfico está disponível, a estratégia desenha:
Velas de preço.
Bandas de Bollinger.
Oscilador estocástico em um painel separado.
Operações executadas para validação visual rápida.
Notas
O tamanho do pip é derivado do passo de preço do instrumento e da precisão decimal, refletindo a lógica do multiplicador do MetaTrader.
Níveis de proteção são recalculados usando Security.ShrinkPrice para garantir arredondamento de preço conforme ao exchange.
Ajustes do trailing stop imitam o EA original apertando o stop apenas quando o preço avança pelo menos um pip além do stop anterior.
A implementação não cria ordens pendentes; todas as entradas e saídas usam ordens a mercado exatamente como o consultor especialista fonte.
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 OneHrStocTraderStrategy : 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 OneHrStocTraderStrategy()
{
_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 one_hr_stoc_trader_strategy(Strategy):
def __init__(self):
super(one_hr_stoc_trader_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(one_hr_stoc_trader_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(one_hr_stoc_trader_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 one_hr_stoc_trader_strategy()