Esta estrategia de StockSharp porta el experto de MetaTrader Exp_SpearmanRankCorrelation_Histogram. Se suscribe a una serie de velas configurable, calcula el histograma de correlación de rango de Spearman para cada barra completada y reacciona cuando cambia el estado codificado por color. Dependiendo del modo de operación, el algoritmo puede cerrar posiciones opuestas, revertir a una nueva operación, o esperar valores extremos antes de actuar.
Pipeline del indicador
Un indicador RankCorrelationIndex (correlación de rango de Spearman escalada a ±100) se alimenta con los precios de cierre de las velas. La ventana de lookback está limitada por MaxRange y por defecto es de 14 barras.
La correlación bruta se normaliza al intervalo [-1, 1]. Cuando InvertCorrelation está habilitado, el signo se invierte para emular el flag direction de MQL.
El valor normalizado se compara con HighLevel y LowLevel para asignar un estado de color:
4 – zona fuertemente alcista (value > HighLevel).
3 – zona moderadamente alcista (0 < value ≤ HighLevel).
2 – neutral (value == 0).
1 – zona moderadamente bajista (LowLevel ≤ value < 0).
0 – zona fuertemente bajista (value < LowLevel).
Los últimos colores se almacenan en un buffer estilo serie para que el índice 0 represente la vela cerrada más reciente, el índice 1 la anterior, y así sucesivamente.
Flujo de trabajo de trading
Las señales se evalúan únicamente en velas terminadas (CandleStates.Finished).
El parámetro SignalBar define qué barra completada se inspecciona (por defecto una barra atrás). La estrategia también observa la barra inmediatamente anterior, replicando la búsqueda de doble buffer del asesor experto.
Los interruptores de órdenes (AllowBuyEntries, AllowSellEntries, AllowBuyExits, AllowSellExits) deciden si las posiciones largas/cortas pueden abrirse o cerrarse.
Los modos de operación reproducen el interruptor de MetaTrader:
Modo 1 – cerrar la posición opuesta siempre que el color anterior sea alcista/bajista (> 2 o < 2). Si se permite, abrir en la nueva dirección cuando el color reciente sale de la zona alcista (< 3) o bajista (> 1).
Modo 2 – reaccionar solo a colores extremos. El extremo alcista (4) permite a la estrategia cerrar cortos y opcionalmente abrir largos cuando la barra más nueva cae por debajo de 4. El extremo bajista (0) cierra largos y puede abrir cortos cuando la barra más nueva sube por encima de 0.
Modo 3 – una versión más estricta del Modo 2: los cortos se cierran inmediatamente en 4, los largos en 0, y las nuevas operaciones se permiten bajo las mismas condiciones que el Modo 2.
CancelActiveOrders() se ejecuta antes de enviar nuevas órdenes de mercado para evitar solicitudes obsoletas.
Las reversiones de posición usan el Volume configurado más la posición actual absoluta para que la operación cambie completamente al lado opuesto.
Los opcionales StopLossPoints y TakeProfitPoints (unidades de precio) habilitan la gestión de riesgo basada en StartProtection; cuando se dejan en 0, no se generan órdenes de protección.
Parámetros
Parámetro
Descripción
CandleType
Marco temporal usado para el indicador y las decisiones de trading.
RangeLength
Período de lookback nominal de Spearman (limitado por MaxRange).
MaxRange
Límite superior para la longitud de lookback efectiva; cae a 10 si se establece en 0.
HighLevel, LowLevel
Umbrales que separan las zonas alcistas y bajistas del histograma.
SignalBar
Número de barras cerradas a omitir antes de analizar el histograma.
InvertCorrelation
Invierte el signo del histograma para coincidir con el comportamiento direction=false de MQL.
AllowBuyEntries, AllowSellEntries
Habilitar apertura de posiciones largas/cortas.
AllowBuyExits, AllowSellExits
Habilitar cierre automático de posiciones largas/cortas existentes.
TradeMode
Selecciona la lógica del Modo 1, Modo 2 o Modo 3 del experto original.
StopLossPoints, TakeProfitPoints
Distancias de protección opcionales en unidades de precio absolutas para StartProtection.
Volume (integrado)
Tamaño base de orden usado al abrir o revertir posiciones.
Diferencias con el experto de MetaTrader
Las entradas de gestión de capital (MM, MMMode) y deslizamiento (Deviation_) no se replican; el dimensionamiento de posición depende de la propiedad estándar Volume y la configuración del bróker.
Las funciones auxiliares MQL de TradeAlgorithms.mqh se reemplazan con llamadas directas a BuyMarket/SellMarket después de cancelar órdenes pendientes.
La sugerencia de rendimiento CalculatedBars es innecesaria en StockSharp y se ha omitido.
El flag direction está representado por InvertCorrelation, que simplemente refleja el signo del histograma.
Las distancias de stop-loss y take-profit (StopLoss_, TakeProfit_) se interpretan como offsets de precio absolutos al habilitar StartProtection; no se realiza conversión automática de punto a precio.
Los tiempos de señal se manejan al cierre de la vela; no hay programación diferida a la apertura de la siguiente barra.
Estos ajustes siguen las pautas de estrategia de alto nivel de StockSharp mientras preservan la lógica de señal original.
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 ExpSpearmanRankCorrelationHistogramStrategy : 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 ExpSpearmanRankCorrelationHistogramStrategy()
{
_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 exp_spearman_rank_correlation_histogram_strategy(Strategy):
def __init__(self):
super(exp_spearman_rank_correlation_histogram_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(exp_spearman_rank_correlation_histogram_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(exp_spearman_rank_correlation_histogram_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 exp_spearman_rank_correlation_histogram_strategy()