Color Stochastic NR 策略
该策略使用随机指标并提供多种信号模式。每种模式以不同方式解释 %K 和 %D 线以生成买卖信号。
模式:
- Breakdown – 当 %K 向上突破 50 时做多,跌破 50 时做空。
- OscTwist – 对 %K 方向的改变做出反应。
- SignalTwist – 对 %D 方向的改变做出反应。
- OscDisposition – 当 %K 上穿 %D 时做多,下穿时做空。
- SignalBreakdown – 当 %D 穿越 50 水平时交易。
相反信号会平掉当前仓位并在反方向开仓。风险由固定百分比的止损和止盈控制。
详细信息
- 入场条件:
- 多头:取决于所选模式。
- 空头:取决于所选模式。
- Long/Short:双向。
- 离场条件:相反信号或保护性止损止盈。
- 止损:是,
StopLossPercent和TakeProfitPercent。 - 默认参数:
KPeriod= 5DPeriod= 3Mode=OscDispositionStopLossPercent= 2TakeProfitPercent= 2CandleType= 4 小时
- 过滤器:
- 分类: 振荡器
- 方向: 双向
- 指标: Stochastic
- 止损: 是
- 复杂度: 中等
- 时间框架: 4H
- 季节性: 否
- 神经网络: 否
- 背离: 否
- 风险等级: 中等
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>
/// Stochastic oscillator with five selectable entry modes and percentage protection.
/// </summary>
public class ColorStochNrStrategy : Strategy
{
public enum AlgModes
{
Breakdown,
OscTwist,
SignalTwist,
OscDisposition,
SignalBreakdown,
}
private readonly StrategyParam<AlgModes> _mode;
private readonly StrategyParam<int> _kPeriod;
private readonly StrategyParam<int> _dPeriod;
private readonly StrategyParam<decimal> _stopLossPercent;
private readonly StrategyParam<decimal> _takeProfitPercent;
private readonly StrategyParam<DataType> _candleType;
private decimal? _prevK;
private decimal? _prevD;
private decimal? _prevKDelta;
private decimal? _prevDDelta;
public AlgModes Mode { get => _mode.Value; set => _mode.Value = value; }
public int KPeriod { get => _kPeriod.Value; set => _kPeriod.Value = value; }
public int DPeriod { get => _dPeriod.Value; set => _dPeriod.Value = value; }
public decimal StopLossPercent { get => _stopLossPercent.Value; set => _stopLossPercent.Value = value; }
public decimal TakeProfitPercent { get => _takeProfitPercent.Value; set => _takeProfitPercent.Value = value; }
public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }
public ColorStochNrStrategy()
{
_mode = Param(nameof(Mode), AlgModes.OscDisposition)
.SetDisplay("Algorithm Mode", "Trading algorithm to use", "Parameters");
_kPeriod = Param(nameof(KPeriod), 5)
.SetGreaterThanZero()
.SetDisplay("K Period", "Length for %K line", "Stochastic")
.SetOptimize(5, 20, 1);
_dPeriod = Param(nameof(DPeriod), 3)
.SetGreaterThanZero()
.SetDisplay("D Period", "Length for %D line", "Stochastic")
.SetOptimize(3, 10, 1);
_stopLossPercent = Param(nameof(StopLossPercent), 2m)
.SetGreaterThanZero()
.SetDisplay("Stop Loss %", "Stop loss percentage", "Risk Management")
.SetOptimize(1m, 5m, 1m);
_takeProfitPercent = Param(nameof(TakeProfitPercent), 2m)
.SetGreaterThanZero()
.SetDisplay("Take Profit %", "Take profit percentage", "Risk Management")
.SetOptimize(1m, 5m, 1m);
_candleType = Param(nameof(CandleType), TimeSpan.FromHours(4).TimeFrame())
.SetDisplay("Candle Type", "Type of candles to use", "General");
}
/// <inheritdoc />
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
=> [(Security, CandleType)];
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_prevK = _prevD = _prevKDelta = _prevDDelta = null;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
var stochastic = new StochasticOscillator
{
K = { Length = KPeriod },
D = { Length = DPeriod },
};
var subscription = SubscribeCandles(CandleType);
subscription.BindEx(stochastic, ProcessCandle).Start();
StartProtection(
stopLoss: new Unit(StopLossPercent, UnitTypes.Percent),
takeProfit: new Unit(TakeProfitPercent, UnitTypes.Percent));
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, stochastic);
DrawOwnTrades(area);
}
}
private void ProcessCandle(ICandleMessage candle, IIndicatorValue stochValue)
{
if (candle.State != CandleStates.Finished)
return;
var stoch = (IStochasticOscillatorValue)stochValue;
if (stoch.K is not decimal k || stoch.D is not decimal d)
return;
if (_prevK is not decimal prevK || _prevD is not decimal prevD)
{
_prevK = k;
_prevD = d;
return;
}
var deltaK = k - prevK;
var deltaD = d - prevD;
var buy = false;
var sell = false;
switch (Mode)
{
case AlgModes.Breakdown:
buy = prevK <= 50m && k > 50m;
sell = prevK >= 50m && k < 50m;
break;
case AlgModes.OscTwist:
buy = _prevKDelta is decimal prevKDelta && prevKDelta <= 0m && deltaK > 0m;
sell = _prevKDelta is decimal prevKDelta2 && prevKDelta2 >= 0m && deltaK < 0m;
break;
case AlgModes.SignalTwist:
buy = _prevDDelta is decimal prevDDelta && prevDDelta <= 0m && deltaD > 0m;
sell = _prevDDelta is decimal prevDDelta2 && prevDDelta2 >= 0m && deltaD < 0m;
break;
case AlgModes.OscDisposition:
buy = prevK <= prevD && k > d;
sell = prevK >= prevD && k < d;
break;
case AlgModes.SignalBreakdown:
buy = prevD <= 50m && d > 50m;
sell = prevD >= 50m && d < 50m;
break;
default:
throw new InvalidOperationException($"Unsupported stochastic signal mode: {Mode}.");
}
var position = Position;
if (buy && position <= 0m)
{
if (position < 0m)
BuyMarket(-position);
BuyMarket(Volume);
}
else if (sell && position >= 0m)
{
if (position > 0m)
SellMarket(position);
SellMarket(Volume);
}
_prevKDelta = deltaK;
_prevDDelta = deltaD;
_prevK = k;
_prevD = d;
}
}
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, Unit, UnitTypes
from StockSharp.Algo.Indicators import StochasticOscillator
from StockSharp.Algo.Strategies import Strategy
class color_stoch_nr_strategy(Strategy):
"""Stochastic oscillator with five entry modes and percentage protection."""
# Numeric modes match ColorStochNrStrategy.AlgModes enum ordering in C#.
BREAKDOWN = 0
OSC_TWIST = 1
SIGNAL_TWIST = 2
OSC_DISPOSITION = 3
SIGNAL_BREAKDOWN = 4
def __init__(self):
super(color_stoch_nr_strategy, self).__init__()
self._mode = self.Param("Mode", self.OSC_DISPOSITION) \
.SetDisplay("Algorithm Mode", "0=Breakdown, 1=OscTwist, 2=SignalTwist, 3=OscDisposition, 4=SignalBreakdown", "Parameters")
self._k_period = self.Param("KPeriod", 5) \
.SetDisplay("K Period", "Length for %K line", "Stochastic")
self._d_period = self.Param("DPeriod", 3) \
.SetDisplay("D Period", "Length for %D line", "Stochastic")
self._stop_loss_percent = self.Param("StopLossPercent", 2.0) \
.SetDisplay("Stop Loss %", "Stop loss percentage", "Risk Management")
self._take_profit_percent = self.Param("TakeProfitPercent", 2.0) \
.SetDisplay("Take Profit %", "Take profit percentage", "Risk Management")
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromHours(4))) \
.SetDisplay("Candle Type", "Type of candles to use", "General")
self._prev_k = None
self._prev_d = None
self._prev_k_delta = None
self._prev_d_delta = None
@property
def Mode(self):
return self._mode.Value
@Mode.setter
def Mode(self, value):
self._mode.Value = value
@property
def CandleType(self):
return self._candle_type.Value
@CandleType.setter
def CandleType(self, value):
self._candle_type.Value = value
def OnReseted(self):
super(color_stoch_nr_strategy, self).OnReseted()
self._prev_k = None
self._prev_d = None
self._prev_k_delta = None
self._prev_d_delta = None
def OnStarted2(self, time):
super(color_stoch_nr_strategy, self).OnStarted2(time)
stochastic = StochasticOscillator()
stochastic.K.Length = self._k_period.Value
stochastic.D.Length = self._d_period.Value
subscription = self.SubscribeCandles(self.CandleType)
subscription.BindEx(stochastic, self.on_process).Start()
self.StartProtection(
stopLoss=Unit(self._stop_loss_percent.Value, UnitTypes.Percent),
takeProfit=Unit(self._take_profit_percent.Value, UnitTypes.Percent)
)
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawIndicator(area, stochastic)
self.DrawOwnTrades(area)
def on_process(self, candle, stoch_value):
if candle.State != CandleStates.Finished:
return
if stoch_value.K is None or stoch_value.D is None:
return
k = float(stoch_value.K)
d = float(stoch_value.D)
if self._prev_k is None or self._prev_d is None:
self._prev_k = k
self._prev_d = d
return
delta_k = k - self._prev_k
delta_d = d - self._prev_d
mode = int(self.Mode)
buy = sell = False
if mode == self.BREAKDOWN:
buy = self._prev_k <= 50 < k
sell = self._prev_k >= 50 > k
elif mode == self.OSC_TWIST:
if self._prev_k_delta is not None:
buy = self._prev_k_delta <= 0 < delta_k
sell = self._prev_k_delta >= 0 > delta_k
elif mode == self.SIGNAL_TWIST:
if self._prev_d_delta is not None:
buy = self._prev_d_delta <= 0 < delta_d
sell = self._prev_d_delta >= 0 > delta_d
elif mode == self.OSC_DISPOSITION:
buy = self._prev_k <= self._prev_d and k > d
sell = self._prev_k >= self._prev_d and k < d
elif mode == self.SIGNAL_BREAKDOWN:
buy = self._prev_d <= 50 < d
sell = self._prev_d >= 50 > d
else:
raise ValueError("Unsupported stochastic signal mode: %s" % mode)
position = self.Position
if buy and position <= 0:
if position < 0:
self.BuyMarket(-position)
self.BuyMarket(self.Volume)
elif sell and position >= 0:
if position > 0:
self.SellMarket(position)
self.SellMarket(self.Volume)
self._prev_k_delta = delta_k
self._prev_d_delta = delta_d
self._prev_k = k
self._prev_d = d
def CreateClone(self):
return color_stoch_nr_strategy()