La Estrategia de Cronex RSI recrea el asesor experto Exp_CronexRSI.mq5 en la API de alto nivel de StockSharp. La pila de indicadores combina un Índice de Fuerza Relativa (RSI) clásico con dos medias móviles secuenciales para reducir el ruido. Las decisiones de trading se basan en cruces entre las curvas RSI suavizadas rápida y lenta, con permisos de entrada/salida configurables que coinciden con los parámetros MQL5 originales.
Lógica de trading
Construir el RSI desde el precio aplicado y el período de retroceso seleccionados.
Suavizar el valor RSI con una media móvil rápida, luego suavizar el resultado con una media móvil lenta.
Evaluar cruces con un desplazamiento de confirmación configurable:
Cuando la curva rápida estaba por encima de la curva lenta una barra antes y cae por debajo en la barra confirmada, la estrategia cierra posiciones cortas y, si está habilitado, abre una posición larga.
Cuando la curva rápida estaba por debajo de la curva lenta y cruza por encima en la barra confirmada, la estrategia cierra posiciones largas y puede entrar en operaciones cortas.
Los volúmenes son simétricos en ambas direcciones. Cuando una nueva señal revierte la posición, la estrategia primero cubre la exposición existente y luego abre el nuevo lado usando el volumen base configurado.
Por defecto la estrategia espera una vela completamente cerrada antes de actuar sobre una señal, reproduciendo el comportamiento SignalBar = 1 de Exp_CronexRSI. Establecer el desplazamiento en cero procesa el cruce inmediatamente en la barra de cierre.
Parámetros
Nombre
Descripción
RsiPeriod
Período de retroceso RSI.
FastPeriod
Longitud de la media móvil de suavizado rápido.
SlowPeriod
Longitud de la segunda media móvil de suavizado.
SignalShift
Número de barras completadas utilizadas para confirmación (0 reacciona instantáneamente).
SmoothingMethod
Tipo de media móvil aplicado durante ambas etapas de suavizado (simple, exponencial, suavizada, ponderada linealmente, ponderada por volumen).
AppliedPrice
Componente de precio pasado al RSI (cierre, apertura, máximo, mínimo, mediana, típico, ponderado).
CandleType
Serie de velas procesada por la estrategia.
TradeVolume
Tamaño de orden base utilizado para nuevas entradas.
EnableLongEntry / EnableShortEntry
Permitir abrir posiciones largas/cortas.
EnableLongExit / EnableShortExit
Permitir cerrar posiciones en respuesta a señales opuestas.
Notas de implementación
El método de suavizado utiliza clases de media móvil de StockSharp. La opción VolumeWeighted también cubre los estilos VIDYA/AMA de MQL5 aplicando un sustituto pragmático ponderado por volumen.
La selección de precio aplicado coincide con las entradas del indicador Cronex y refleja el asistente utilizado dentro del asesor experto original.
Todos los valores de indicadores se procesan a través de instancias DecimalIndicatorValue para permanecer compatibles con la tubería de indicadores de StockSharp mientras se evita el sondeo directo de valores.
La estrategia redimensiona automáticamente su historial interno cuando cambia el desplazamiento de confirmación, asegurando que la lógica de cruce mantenga la estructura exacta de retroceso de la versión MQL5.
Uso
Adjuntar la estrategia a una cartera y valor en el diseñador de StockSharp o mediante código.
Configurar el marco temporal de velas, el estilo de suavizado y los permisos de trading para que coincidan con la configuración preferida de Cronex RSI.
Lanzar la estrategia. Se suscribirá a la serie de velas seleccionada, actualizará la combinación RSI/MA y enviará órdenes a mercado en cruces confirmados.
Usar los asistentes de gráficos integrados para visualizar las curvas de indicadores y las operaciones ejecutadas para mayor validación.
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 CronexRsiStrategy : 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 CronexRsiStrategy()
{
_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 cronex_rsi_strategy(Strategy):
def __init__(self):
super(cronex_rsi_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(cronex_rsi_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(cronex_rsi_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 cronex_rsi_strategy()