Стратегия Ultimate Stochastics
Стратегия торгует по пересечению линий осциллятора Stochastic. Допускаются сделки в обе стороны. Возможны выходы по противоположному сигналу и управление позицией через тейк-профит и стоп-лосс в процентах.
Детали
- Лонг: %K пересекает %D снизу ниже уровня перепроданности.
- Шорт: %K пересекает %D сверху выше уровня перекупленности.
- Индикаторы: Stochastic.
- Стопы: опциональный процентный TP/SL.
using System;
using System.Linq;
using System.Collections.Generic;
using Ecng.Common;
using Ecng.Collections;
using Ecng.Serialization;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.BusinessEntities;
using StockSharp.Messages;
namespace StockSharp.Samples.Strategies;
/// <summary>
/// Ultimate Stochastics strategy using RSI momentum with EMA trend filter.
/// </summary>
public class UltimateStochasticsStrategy : Strategy
{
private readonly StrategyParam<int> _rsiLength;
private readonly StrategyParam<int> _smoothLength;
private readonly StrategyParam<decimal> _overbought;
private readonly StrategyParam<decimal> _oversold;
private readonly StrategyParam<decimal> _takeProfitPct;
private readonly StrategyParam<decimal> _stopLossPct;
private readonly StrategyParam<DataType> _candleType;
private decimal _prevRsi;
private decimal _prevFast;
private decimal _prevSlow;
private int _cooldown;
public int RsiLength { get => _rsiLength.Value; set => _rsiLength.Value = value; }
public int SmoothLength { get => _smoothLength.Value; set => _smoothLength.Value = value; }
public decimal Overbought { get => _overbought.Value; set => _overbought.Value = value; }
public decimal Oversold { get => _oversold.Value; set => _oversold.Value = value; }
public decimal TakeProfitPct { get => _takeProfitPct.Value; set => _takeProfitPct.Value = value; }
public decimal StopLossPct { get => _stopLossPct.Value; set => _stopLossPct.Value = value; }
public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }
public UltimateStochasticsStrategy()
{
_rsiLength = Param(nameof(RsiLength), 14)
.SetGreaterThanZero()
.SetDisplay("RSI Length", "RSI period", "Indicators");
_smoothLength = Param(nameof(SmoothLength), 3)
.SetGreaterThanZero()
.SetDisplay("Smooth Length", "Smoothing for D line", "Indicators");
_overbought = Param(nameof(Overbought), 70m)
.SetDisplay("Overbought", "Overbought level", "Levels");
_oversold = Param(nameof(Oversold), 30m)
.SetDisplay("Oversold", "Oversold level", "Levels");
_takeProfitPct = Param(nameof(TakeProfitPct), 2m)
.SetGreaterThanZero()
.SetDisplay("TP %", "Take profit percent", "Risk");
_stopLossPct = Param(nameof(StopLossPct), 1m)
.SetGreaterThanZero()
.SetDisplay("SL %", "Stop loss percent", "Risk");
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(5).TimeFrame())
.SetDisplay("Candle Type", "Type of candles", "General");
}
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
{
return [(Security, CandleType)];
}
protected override void OnReseted()
{
base.OnReseted();
_prevRsi = 0;
_prevFast = 0;
_prevSlow = 0;
_cooldown = 0;
}
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
var rsi = new RelativeStrengthIndex { Length = RsiLength };
var emaFast = new ExponentialMovingAverage { Length = 8 };
var emaSlow = new ExponentialMovingAverage { Length = 21 };
var subscription = SubscribeCandles(CandleType);
subscription.Bind(rsi, emaFast, emaSlow, ProcessCandle).Start();
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, emaFast);
DrawIndicator(area, emaSlow);
DrawOwnTrades(area);
}
}
private void ProcessCandle(ICandleMessage candle, decimal rsiVal, decimal emaFast, decimal emaSlow)
{
if (candle.State != CandleStates.Finished)
return;
if (_prevRsi == 0 || _prevFast == 0 || _prevSlow == 0)
{
_prevRsi = rsiVal;
_prevFast = emaFast;
_prevSlow = emaSlow;
return;
}
if (_cooldown > 0)
{
_cooldown--;
_prevRsi = rsiVal;
_prevFast = emaFast;
_prevSlow = emaSlow;
return;
}
var hist = emaFast - emaSlow;
var histUp = hist > 0m;
var histDown = hist < 0m;
var rsiCrossUp = _prevRsi <= 50m && rsiVal > 50m;
var rsiCrossDown = _prevRsi >= 50m && rsiVal < 50m;
// Exit
if (Position > 0 && rsiCrossDown)
{
SellMarket();
_cooldown = 80;
}
else if (Position < 0 && rsiCrossUp)
{
BuyMarket();
_cooldown = 80;
}
// Entry
if (Position == 0)
{
if (rsiCrossUp && histUp)
{
BuyMarket();
_cooldown = 80;
}
else if (rsiCrossDown && histDown)
{
SellMarket();
_cooldown = 80;
}
}
_prevRsi = rsiVal;
_prevFast = emaFast;
_prevSlow = emaSlow;
}
}
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, RelativeStrengthIndex
from StockSharp.Algo.Strategies import Strategy
class ultimate_stochastics_strategy(Strategy):
def __init__(self):
super(ultimate_stochastics_strategy, self).__init__()
self._rsi_length = self.Param("RsiLength", 14) \
.SetDisplay("RSI Length", "RSI period", "Indicators")
self._smooth_length = self.Param("SmoothLength", 3) \
.SetDisplay("Smooth Length", "Smoothing for D line", "Indicators")
self._overbought = self.Param("Overbought", 70) \
.SetDisplay("Overbought", "Overbought level", "Levels")
self._oversold = self.Param("Oversold", 30) \
.SetDisplay("Oversold", "Oversold level", "Levels")
self._take_profit_pct = self.Param("TakeProfitPct", 2) \
.SetDisplay("TP %", "Take profit percent", "Risk")
self._stop_loss_pct = self.Param("StopLossPct", TimeSpan.FromMinutes(5)) \
.SetDisplay("SL %", "Stop loss percent", "Risk")
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromMinutes(5))) \
.SetDisplay("Candle Type", "Type of candles", "General")
self._prev_rsi = 0.0
self._prev_fast = 0.0
self._prev_slow = 0.0
self._cooldown = 0
@property
def rsi_length(self):
return self._rsi_length.Value
@property
def smooth_length(self):
return self._smooth_length.Value
@property
def overbought(self):
return self._overbought.Value
@property
def oversold(self):
return self._oversold.Value
@property
def take_profit_pct(self):
return self._take_profit_pct.Value
@property
def stop_loss_pct(self):
return self._stop_loss_pct.Value
@property
def candle_type(self):
return self._candle_type.Value
def OnReseted(self):
super(ultimate_stochastics_strategy, self).OnReseted()
self._prev_rsi = 0.0
self._prev_fast = 0.0
self._prev_slow = 0.0
self._cooldown = 0
def OnStarted2(self, time):
super(ultimate_stochastics_strategy, self).OnStarted2(time)
rsi = RelativeStrengthIndex()
rsi.Length = self.rsi_length
ema_fast = ExponentialMovingAverage()
ema_fast.Length = 8
ema_slow = ExponentialMovingAverage()
ema_slow.Length = 21
subscription = self.SubscribeCandles(self.candle_type)
subscription.Bind(rsi, ema_fast, ema_slow, self.on_process).Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawIndicator(area, ema_fast)
self.DrawIndicator(area, ema_slow)
self.DrawOwnTrades(area)
def on_process(self, candle, rsi_val, ema_fast, ema_slow):
if candle.State != CandleStates.Finished:
return
rsi_val = float(rsi_val)
ema_fast = float(ema_fast)
ema_slow = float(ema_slow)
if self._prev_rsi == 0 or self._prev_fast == 0 or self._prev_slow == 0:
self._prev_rsi = rsi_val
self._prev_fast = ema_fast
self._prev_slow = ema_slow
return
if self._cooldown > 0:
self._cooldown -= 1
self._prev_rsi = rsi_val
self._prev_fast = ema_fast
self._prev_slow = ema_slow
return
hist = ema_fast - ema_slow
hist_up = hist > 0
hist_down = hist < 0
rsi_cross_up = self._prev_rsi <= 50 and rsi_val > 50
rsi_cross_down = self._prev_rsi >= 50 and rsi_val < 50
if self.Position > 0 and rsi_cross_down:
self.SellMarket()
self._cooldown = 80
elif self.Position < 0 and rsi_cross_up:
self.BuyMarket()
self._cooldown = 80
if self.Position == 0:
if rsi_cross_up and hist_up:
self.BuyMarket()
self._cooldown = 80
elif rsi_cross_down and hist_down:
self.SellMarket()
self._cooldown = 80
self._prev_rsi = rsi_val
self._prev_fast = ema_fast
self._prev_slow = ema_slow
def CreateClone(self):
return ultimate_stochastics_strategy()