GitHub で見る
KWAN RDPトレンド戦略
この戦略はMetaTraderエキスパートExp_KWAN_RDPのStockSharp変換版です。このロジックは3つの標準インジケーターを組み合わせてその積を平滑化することでKWAN RDPオシレーターを計算します:
- DeMarker — 最近の高値と安値の関係を測定してモメンタムの枯渇を評価します。
- Money Flow Index — 価格とボリュームを評価して買われ過ぎや売られ過ぎの状態を検出します。
- Momentum — 選択した期間を使用して価格変化の速度を捉えます。
- 生の値
100 * DeMarker * MFI / Momentumは設定可能な移動平均(SMA、EMA、SMMA、WMA、またはJurik)で平滑化されます。
平滑化されたオシレーターの傾きがトレードシグナルを生成します:
- 強気の転換(上昇傾き): ショートポジションを閉じ、オプションでロングポジションを開きます。
- 弱気の転換(下降傾き): ロングポジションを閉じ、オプションでショートポジションを開きます。
- ニュートラルなバー(フラットな傾き)はアクションをトリガーしません。
パラメーター
CandleType — インジケーター計算のためのローソク足シリーズ(デフォルト:H1時間軸)。
DeMarkerPeriod — DeMarkerインジケーターの期間。
MfiPeriod — Money Flow Indexの期間。
MomentumPeriod — Momentumインジケーターの期間。
SmoothingLength — 平滑化移動平均の長さ。
Smoothing — 平滑化メソッド(Simple、Exponential、Smoothed、Weighted、Jurik)。
EnableLongEntries / EnableShortEntries — ロングまたはショートポジションの開設を許可。
CloseLongsOnReverse / CloseShortsOnReverse — 逆張りシグナルが現れたときに反対ポジションを閉じる。
TakeProfitPercent / StopLossPercent — StartProtectionを通じて適用されるオプションのパーセンテージベースの保護。
トレーディングルール
- 設定されたローソク足シリーズを購読し、完了した各ローソク足でDeMarker、MFI、MomentumおよびKWAN平滑化値を計算します。
- 最新のオシレーター値と前の値の傾き方向を検出します。
- 傾きが上向きに転換したとき、ショートを閉じ(有効な場合)、ロングトレーディングが許可されておりアクティブなロングポジションがない場合はロングを開きます。
- 傾きが下向きに転換したとき、ロングを閉じ(有効な場合)、ショートトレーディングが許可されておりアクティブなショートポジションがない場合はショートを開きます。
- オプションのストップロスとテイクプロフィットのパーセンテージを使用して、プラットフォームの保護でポジションを守ります。
ノート
- シグナルはインタバーノイズを避けるために完了したローソク足のみで処理されます。
- DeMarkerの計算はMetaTraderの実装に合わせるために内部平滑化を使用します。
- C#コードのすべてのコメントはプロジェクトガイドラインに従って英語で書かれています。
namespace StockSharp.Samples.Strategies;
using System;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.Messages;
/// <summary>
/// KWAN RDP trend strategy converted from MetaTrader version.
/// Combines DeMarker and Momentum indicators to detect trend reversals.
/// Opens long when DeMarker rises and momentum is positive, short when DeMarker falls and momentum is negative.
/// </summary>
public class KwanRdpStrategy : Strategy
{
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<int> _deMarkerPeriod;
private readonly StrategyParam<int> _momentumPeriod;
private decimal _prevDem;
private decimal _prevMom;
private bool _initialized;
public DataType CandleType
{
get => _candleType.Value;
set => _candleType.Value = value;
}
public int DeMarkerPeriod
{
get => _deMarkerPeriod.Value;
set => _deMarkerPeriod.Value = value;
}
public int MomentumPeriod
{
get => _momentumPeriod.Value;
set => _momentumPeriod.Value = value;
}
public KwanRdpStrategy()
{
_candleType = Param(nameof(CandleType), TimeSpan.FromHours(4).TimeFrame())
.SetDisplay("Candle Type", "Primary candle series", "General");
_deMarkerPeriod = Param(nameof(DeMarkerPeriod), 14)
.SetGreaterThanZero()
.SetDisplay("DeMarker Period", "DeMarker indicator length", "Indicators");
_momentumPeriod = Param(nameof(MomentumPeriod), 14)
.SetGreaterThanZero()
.SetDisplay("Momentum Period", "Momentum indicator length", "Indicators");
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_prevDem = 0m;
_prevMom = 0m;
_initialized = false;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_prevDem = 0;
_prevMom = 0;
_initialized = false;
var deMarker = new DeMarker { Length = DeMarkerPeriod };
var momentum = new Momentum { Length = MomentumPeriod };
var subscription = SubscribeCandles(CandleType);
subscription
.Bind(deMarker, momentum, (ICandleMessage candle, decimal demValue, decimal momValue) =>
{
if (candle.State != CandleStates.Finished)
return;
if (!IsFormedAndOnlineAndAllowTrading())
return;
if (!_initialized)
{
_prevDem = demValue;
_prevMom = momValue;
_initialized = true;
return;
}
var demUp = demValue > _prevDem;
var demDown = demValue < _prevDem;
var momUp = momValue > _prevMom;
var momDown = momValue < _prevMom;
// Long when DeMarker and Momentum both turn up
if (demUp && momUp && Position <= 0)
{
BuyMarket();
}
// Short when DeMarker and Momentum both turn down
else if (demDown && momDown && Position >= 0)
{
SellMarket();
}
_prevDem = demValue;
_prevMom = momValue;
})
.Start();
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, deMarker);
DrawOwnTrades(area);
}
}
}
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 DeMarker, Momentum
from StockSharp.Algo.Strategies import Strategy
class kwan_rdp_strategy(Strategy):
def __init__(self):
super(kwan_rdp_strategy, self).__init__()
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromHours(4))) \
.SetDisplay("Candle Type", "Primary candle series", "General")
self._demarker_period = self.Param("DeMarkerPeriod", 14) \
.SetDisplay("DeMarker Period", "DeMarker indicator length", "Indicators")
self._momentum_period = self.Param("MomentumPeriod", 14) \
.SetDisplay("Momentum Period", "Momentum indicator length", "Indicators")
self._prev_dem = 0.0
self._prev_mom = 0.0
self._initialized = False
@property
def CandleType(self):
return self._candle_type.Value
@property
def DeMarkerPeriod(self):
return self._demarker_period.Value
@property
def MomentumPeriod(self):
return self._momentum_period.Value
def OnReseted(self):
super(kwan_rdp_strategy, self).OnReseted()
self._prev_dem = 0.0
self._prev_mom = 0.0
self._initialized = False
def OnStarted2(self, time):
super(kwan_rdp_strategy, self).OnStarted2(time)
self._prev_dem = 0.0
self._prev_mom = 0.0
self._initialized = False
demarker = DeMarker()
demarker.Length = self.DeMarkerPeriod
momentum = Momentum()
momentum.Length = self.MomentumPeriod
subscription = self.SubscribeCandles(self.CandleType)
subscription \
.Bind(demarker, momentum, self._on_process) \
.Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawIndicator(area, demarker)
self.DrawOwnTrades(area)
def _on_process(self, candle, dem_value, mom_value):
if candle.State != CandleStates.Finished:
return
dv = float(dem_value)
mv = float(mom_value)
if not self._initialized:
self._prev_dem = dv
self._prev_mom = mv
self._initialized = True
return
dem_up = dv > self._prev_dem
dem_down = dv < self._prev_dem
mom_up = mv > self._prev_mom
mom_down = mv < self._prev_mom
if dem_up and mom_up and self.Position <= 0:
self.BuyMarket()
elif dem_down and mom_down and self.Position >= 0:
self.SellMarket()
self._prev_dem = dv
self._prev_mom = mv
def CreateClone(self):
return kwan_rdp_strategy()