Estrategia de Ruptura de Pendiente Williams %R
La estrategia de Ruptura de Pendiente Williams %R monitorea la tasa de cambio del Williams %R. Una pendiente inusualmente pronunciada sugiere que se está formando una nueva tendencia.
Las pruebas indican un rendimiento anual promedio de aproximadamente 139%. Funciona mejor en el mercado de acciones.
Las entradas ocurren cuando la pendiente supera su nivel típico en un múltiplo de la desviación estándar, tomando operaciones en la dirección de la aceleración con un stop protector.
Atrae a los traders activos que buscan una exposición temprana a la tendencia. Las posiciones se cierran cuando la pendiente regresa a lecturas normales. WilliamsRPeriod predeterminado = 14.
Detalles
- Criterios de entrada: El indicador supera la media por el multiplicador de desviación.
- Largo/Corto: Ambas direcciones.
- Criterios de salida: El indicador revierte a la media.
- Stops: Sí.
- Valores predeterminados:
WilliamsRPeriod= 14SlopePeriod= 20BreakoutMultiplier= 2.0mStopLossPercent= 2.0mCandleType= TimeSpan.FromMinutes(5)
- Filtros:
- Categoría: Ruptura
- Dirección: Ambos
- Indicadores: Williams %R
- Stops: Sí
- Complejidad: Intermedio
- Marco temporal: Corto plazo
- Estacionalidad: No
- Redes neuronales: No
- Divergencia: No
- Nivel de riesgo: Medio
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;
/// <summary>
/// Strategy based on Williams %R slope breakout.
/// Opens positions when Williams %R slope deviates from its recent average by a multiple of standard deviation.
/// </summary>
public class WilliamsRSlopeBreakoutStrategy : Strategy
{
private readonly StrategyParam<int> _williamsRPeriod;
private readonly StrategyParam<int> _slopePeriod;
private readonly StrategyParam<decimal> _breakoutMultiplier;
private readonly StrategyParam<decimal> _stopLossPercent;
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<int> _cooldownBars;
private readonly StrategyParam<decimal> _centerLevel;
private WilliamsR _williamsR;
private decimal _prevWilliamsRValue;
private decimal _currentSlope;
private decimal _avgSlope;
private decimal _stdDevSlope;
private decimal[] _slopes;
private int _currentIndex;
private int _filledCount;
private int _cooldown;
private bool _isInitialized;
/// <summary>
/// Williams %R period.
/// </summary>
public int WilliamsRPeriod
{
get => _williamsRPeriod.Value;
set => _williamsRPeriod.Value = value;
}
/// <summary>
/// Lookback period for slope statistics calculation.
/// </summary>
public int SlopePeriod
{
get => _slopePeriod.Value;
set => _slopePeriod.Value = value;
}
/// <summary>
/// Standard deviation multiplier for breakout detection.
/// </summary>
public decimal BreakoutMultiplier
{
get => _breakoutMultiplier.Value;
set => _breakoutMultiplier.Value = value;
}
/// <summary>
/// Stop loss percentage.
/// </summary>
public decimal StopLossPercent
{
get => _stopLossPercent.Value;
set => _stopLossPercent.Value = value;
}
/// <summary>
/// Candle type.
/// </summary>
public DataType CandleType
{
get => _candleType.Value;
set => _candleType.Value = value;
}
/// <summary>
/// Cooldown bars between orders.
/// </summary>
public int CooldownBars
{
get => _cooldownBars.Value;
set => _cooldownBars.Value = value;
}
/// <summary>
/// Center level separating bullish and bearish zones.
/// </summary>
public decimal CenterLevel
{
get => _centerLevel.Value;
set => _centerLevel.Value = value;
}
/// <summary>
/// Initializes a new instance of <see cref="WilliamsRSlopeBreakoutStrategy"/>.
/// </summary>
public WilliamsRSlopeBreakoutStrategy()
{
_williamsRPeriod = Param(nameof(WilliamsRPeriod), 14)
.SetGreaterThanZero()
.SetDisplay("Williams %R Period", "Period for Williams %R calculation", "Indicator Parameters")
.SetOptimize(10, 20, 2);
_slopePeriod = Param(nameof(SlopePeriod), 20)
.SetGreaterThanZero()
.SetDisplay("Slope Period", "Period for slope statistics calculation", "Strategy Parameters")
.SetOptimize(10, 50, 5);
_breakoutMultiplier = Param(nameof(BreakoutMultiplier), 2.5m)
.SetGreaterThanZero()
.SetDisplay("Breakout Multiplier", "Standard deviation multiplier for breakout detection", "Strategy Parameters")
.SetOptimize(1.5m, 4m, 0.5m);
_stopLossPercent = Param(nameof(StopLossPercent), 2m)
.SetGreaterThanZero()
.SetDisplay("Stop Loss %", "Stop loss percentage", "Risk Management");
_cooldownBars = Param(nameof(CooldownBars), 1200)
.SetRange(1, 5000)
.SetDisplay("Cooldown Bars", "Bars to wait between orders", "Risk Management");
_centerLevel = Param(nameof(CenterLevel), -50m)
.SetRange(-100m, 0m)
.SetDisplay("Center Level", "Zone separator for bullish and bearish entries", "Signal Filters");
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(5).TimeFrame())
.SetDisplay("Candle Type", "Type of candles to use", "General");
}
/// <inheritdoc />
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
{
return [(Security, CandleType)];
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_williamsR = null;
_prevWilliamsRValue = default;
_currentSlope = default;
_avgSlope = default;
_stdDevSlope = default;
_currentIndex = default;
_filledCount = default;
_cooldown = default;
_isInitialized = default;
_slopes = new decimal[SlopePeriod];
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_williamsR = new WilliamsR { Length = WilliamsRPeriod };
_slopes = new decimal[SlopePeriod];
_cooldown = 0;
var subscription = SubscribeCandles(CandleType);
subscription
.Bind(_williamsR, ProcessCandle)
.Start();
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, _williamsR);
DrawOwnTrades(area);
}
StartProtection(new(), new Unit(StopLossPercent, UnitTypes.Percent));
}
private void ProcessCandle(ICandleMessage candle, decimal williamsRValue)
{
if (candle.State != CandleStates.Finished)
return;
if (!_williamsR.IsFormed)
return;
if (!_isInitialized)
{
_prevWilliamsRValue = williamsRValue;
_isInitialized = true;
return;
}
_currentSlope = williamsRValue - _prevWilliamsRValue;
_prevWilliamsRValue = williamsRValue;
_slopes[_currentIndex] = _currentSlope;
_currentIndex = (_currentIndex + 1) % SlopePeriod;
if (_filledCount < SlopePeriod)
_filledCount++;
if (_filledCount < SlopePeriod)
return;
CalculateStatistics();
if (!IsFormedAndOnlineAndAllowTrading())
return;
if (_stdDevSlope <= 0)
return;
if (_cooldown > 0)
{
_cooldown--;
return;
}
var upperThreshold = _avgSlope + BreakoutMultiplier * _stdDevSlope;
var lowerThreshold = _avgSlope - BreakoutMultiplier * _stdDevSlope;
if (Position == 0)
{
if (_currentSlope > upperThreshold && williamsRValue > CenterLevel)
{
BuyMarket();
_cooldown = CooldownBars;
}
else if (_currentSlope < lowerThreshold && williamsRValue < CenterLevel)
{
SellMarket();
_cooldown = CooldownBars;
}
}
else if (Position > 0)
{
if (_currentSlope <= _avgSlope)
{
SellMarket(Math.Abs(Position));
_cooldown = CooldownBars;
}
}
else if (Position < 0)
{
if (_currentSlope >= _avgSlope)
{
BuyMarket(Math.Abs(Position));
_cooldown = CooldownBars;
}
}
}
private void CalculateStatistics()
{
_avgSlope = 0;
var sumSquaredDiffs = 0m;
for (var i = 0; i < SlopePeriod; i++)
_avgSlope += _slopes[i];
_avgSlope /= SlopePeriod;
for (var i = 0; i < SlopePeriod; i++)
{
var diff = _slopes[i] - _avgSlope;
sumSquaredDiffs += diff * diff;
}
_stdDevSlope = (decimal)Math.Sqrt((double)(sumSquaredDiffs / SlopePeriod));
}
}
import clr
clr.AddReference("StockSharp.Messages")
clr.AddReference("StockSharp.Algo")
clr.AddReference("StockSharp.Algo.Indicators")
clr.AddReference("StockSharp.Algo.Strategies")
import math
from System import TimeSpan, Math
from StockSharp.Messages import DataType, Unit, UnitTypes, CandleStates
from StockSharp.Algo.Indicators import WilliamsR
from StockSharp.Algo.Strategies import Strategy
class williams_r_slope_breakout_strategy(Strategy):
"""
Strategy based on Williams %R slope breakout.
Opens positions when Williams %R slope deviates from its recent average by a multiple of standard deviation.
"""
def __init__(self):
super(williams_r_slope_breakout_strategy, self).__init__()
self._williams_r_period = self.Param("WilliamsRPeriod", 14) \
.SetGreaterThanZero() \
.SetDisplay("Williams %R Period", "Period for Williams %R calculation", "Indicator Parameters") \
.SetOptimize(10, 20, 2)
self._slope_period = self.Param("SlopePeriod", 20) \
.SetGreaterThanZero() \
.SetDisplay("Slope Period", "Period for slope statistics calculation", "Strategy Parameters") \
.SetOptimize(10, 50, 5)
self._breakout_multiplier = self.Param("BreakoutMultiplier", 2.5) \
.SetGreaterThanZero() \
.SetDisplay("Breakout Multiplier", "Standard deviation multiplier for breakout detection", "Strategy Parameters") \
.SetOptimize(1.5, 4.0, 0.5)
self._stop_loss_percent = self.Param("StopLossPercent", 2.0) \
.SetGreaterThanZero() \
.SetDisplay("Stop Loss %", "Stop loss percentage", "Risk Management")
self._cooldown_bars = self.Param("CooldownBars", 1200) \
.SetDisplay("Cooldown Bars", "Bars to wait between orders", "Risk Management")
self._center_level = self.Param("CenterLevel", -50.0) \
.SetDisplay("Center Level", "Zone separator for bullish and bearish entries", "Signal Filters")
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromMinutes(5))) \
.SetDisplay("Candle Type", "Type of candles to use", "General")
self._williams_r = None
self._prev_wr = 0.0
self._current_slope = 0.0
self._avg_slope = 0.0
self._std_dev_slope = 0.0
self._slopes = None
self._current_index = 0
self._filled_count = 0
self._cooldown = 0
self._is_initialized = False
@property
def candle_type(self):
return self._candle_type.Value
def OnReseted(self):
super(williams_r_slope_breakout_strategy, self).OnReseted()
self._williams_r = None
self._prev_wr = 0.0
self._current_slope = 0.0
self._avg_slope = 0.0
self._std_dev_slope = 0.0
sp = int(self._slope_period.Value)
self._slopes = [0.0] * sp
self._current_index = 0
self._filled_count = 0
self._cooldown = 0
self._is_initialized = False
def OnStarted2(self, time):
super(williams_r_slope_breakout_strategy, self).OnStarted2(time)
sp = int(self._slope_period.Value)
self._slopes = [0.0] * sp
self._cooldown = 0
self._filled_count = 0
self._current_index = 0
self._williams_r = WilliamsR()
self._williams_r.Length = int(self._williams_r_period.Value)
subscription = self.SubscribeCandles(self.candle_type)
subscription.Bind(self._williams_r, self._process_candle).Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawIndicator(area, self._williams_r)
self.DrawOwnTrades(area)
self.StartProtection(Unit(), Unit(self._stop_loss_percent.Value, UnitTypes.Percent))
def _process_candle(self, candle, wr_value):
if candle.State != CandleStates.Finished:
return
if not self._williams_r.IsFormed:
return
wr_val = float(wr_value)
if not self._is_initialized:
self._prev_wr = wr_val
self._is_initialized = True
return
self._current_slope = wr_val - self._prev_wr
self._prev_wr = wr_val
sp = int(self._slope_period.Value)
self._slopes[self._current_index] = self._current_slope
self._current_index = (self._current_index + 1) % sp
if self._filled_count < sp:
self._filled_count += 1
if self._filled_count < sp:
return
self._calculate_statistics()
if not self.IsFormedAndOnlineAndAllowTrading():
return
if self._std_dev_slope <= 0:
return
if self._cooldown > 0:
self._cooldown -= 1
return
bm = float(self._breakout_multiplier.Value)
upper_threshold = self._avg_slope + bm * self._std_dev_slope
lower_threshold = self._avg_slope - bm * self._std_dev_slope
center = float(self._center_level.Value)
if self.Position == 0:
if self._current_slope > upper_threshold and wr_val > center:
self.BuyMarket()
self._cooldown = int(self._cooldown_bars.Value)
elif self._current_slope < lower_threshold and wr_val < center:
self.SellMarket()
self._cooldown = int(self._cooldown_bars.Value)
elif self.Position > 0:
if self._current_slope <= self._avg_slope:
self.SellMarket(Math.Abs(self.Position))
self._cooldown = int(self._cooldown_bars.Value)
elif self.Position < 0:
if self._current_slope >= self._avg_slope:
self.BuyMarket(Math.Abs(self.Position))
self._cooldown = int(self._cooldown_bars.Value)
def _calculate_statistics(self):
sp = int(self._slope_period.Value)
self._avg_slope = 0.0
sum_sq = 0.0
for i in range(sp):
self._avg_slope += self._slopes[i]
self._avg_slope /= float(sp)
for i in range(sp):
diff = self._slopes[i] - self._avg_slope
sum_sq += diff * diff
self._std_dev_slope = math.sqrt(sum_sq / float(sp))
def CreateClone(self):
return williams_r_slope_breakout_strategy()