日本語 JA
GitHub で見る

ColorJMomentum 戦略

ColorJMomentum 戦略は、Jurik平滑化されたモメンタムインジケーターの方向転換に基づいて取引します。このアプローチは元のMQL5エキスパートアドバイザー Exp_ColorJMomentum から派生しており、StockSharpの高レベルAPIを使用して再現されています。

コンセプト

  1. 選択した価格シリーズの標準的な Momentum を計算します。
  2. モメンタム値を Jurik Moving Average (JMA) で平滑化します。
  3. 平滑化されたモメンタムの最後の2つの値を監視します:
    • インジケーターが下降していて上向きに転換した場合、ロングポジションが開かれます。
    • インジケーターが上昇していて下向きに転換した場合、ショートポジションが開かれます。
  4. ポジション保護はオプションのストップロスとテイクプロフィット（パーセント）で処理されます。

この戦略は過去のインジケーター値を直接読み取りません。代わりに、新しいローソク足の完成にのみ反応し、前の値を内部的に保持します。

パラメーター

  • Momentum Length – モメンタム計算の期間。
  • JMA Length – モメンタムに適用するJurik Moving Averageの平滑化期間。
  • Candle Type – ローソク足購読に使用する時間軸。
  • Stop Loss % – オプションのストップロスのパーセンテージ。
  • Enable Stop Loss – ストップロスを有効にするかどうか。
  • Take Profit % – テイクプロフィットのパーセンテージ。
  • Enable Long – ロングポジションの開設を許可。
  • Enable Short – ショートポジションの開設を許可。

すべてのパラメーターは StrategyParam で作成されているため、Designerで最適化できます。

使用方法

  1. 戦略を目的の銘柄にアタッチします。
  2. パラメーターを設定するか、デフォルト値（8時間のローソク足で8期間Momentumと8期間JMA）のままにします。
  3. 戦略を実行します。Momentumの方向が反転したときに BuyMarket と SellMarket を通じて注文が発行されます。

注意事項

  • 戦略は確定したローソク足のみを処理します。
  • インジケーターには明示的な色は設定されていません。Designerが自動的に選択します。
  • アルゴリズムはプロジェクトのガイドラインに従い、LINQやカスタムコレクションを回避しています。
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>
/// Strategy based on smoothed momentum direction changes.
/// Opens long when momentum turns up, short when momentum turns down.
/// </summary>
public class ColorJMomentumStrategy : Strategy
{
	private readonly StrategyParam<int> _momentumLength;
	private readonly StrategyParam<DataType> _candleType;
	private readonly StrategyParam<decimal> _stopLossPercent;
	private readonly StrategyParam<decimal> _takeProfitPercent;
	private readonly StrategyParam<bool> _enableLong;
	private readonly StrategyParam<bool> _enableShort;

	private decimal _prevMom;
	private decimal _prevPrevMom;
	private int _count;

	public int MomentumLength { get => _momentumLength.Value; set => _momentumLength.Value = value; }
	public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }
	public decimal StopLossPercent { get => _stopLossPercent.Value; set => _stopLossPercent.Value = value; }
	public decimal TakeProfitPercent { get => _takeProfitPercent.Value; set => _takeProfitPercent.Value = value; }
	public bool EnableLong { get => _enableLong.Value; set => _enableLong.Value = value; }
	public bool EnableShort { get => _enableShort.Value; set => _enableShort.Value = value; }

	public ColorJMomentumStrategy()
	{
		_momentumLength = Param(nameof(MomentumLength), 8)
			.SetGreaterThanZero()
			.SetDisplay("Momentum Length", "Period for momentum", "Parameters");

		_candleType = Param(nameof(CandleType), TimeSpan.FromHours(4).TimeFrame())
			.SetDisplay("Candle Type", "Timeframe for candles", "Parameters");

		_stopLossPercent = Param(nameof(StopLossPercent), 1m)
			.SetGreaterThanZero()
			.SetDisplay("Stop Loss %", "Stop loss percentage", "Risk management");

		_takeProfitPercent = Param(nameof(TakeProfitPercent), 2m)
			.SetGreaterThanZero()
			.SetDisplay("Take Profit %", "Take profit percentage", "Risk management");

		_enableLong = Param(nameof(EnableLong), true)
			.SetDisplay("Enable Long", "Allow long entries", "General");

		_enableShort = Param(nameof(EnableShort), true)
			.SetDisplay("Enable Short", "Allow short entries", "General");
	}

	/// <inheritdoc />
	public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
		=> [(Security, CandleType)];

	/// <inheritdoc />
	protected override void OnReseted()
	{
		base.OnReseted();
		_prevMom = 0;
		_prevPrevMom = 0;
		_count = 0;
	}

	/// <inheritdoc />
	protected override void OnStarted2(DateTime time)
	{
		base.OnStarted2(time);

		var momentum = new Momentum { Length = MomentumLength };

		SubscribeCandles(CandleType)
			.Bind(momentum, ProcessCandle)
			.Start();

		StartProtection(
			takeProfit: new Unit(TakeProfitPercent, UnitTypes.Percent),
			stopLoss: new Unit(StopLossPercent, UnitTypes.Percent)
		);
	}

	private void ProcessCandle(ICandleMessage candle, decimal momValue)
	{
		if (candle.State != CandleStates.Finished)
			return;

		_count++;
		if (_count < 3)
		{
			_prevPrevMom = _prevMom;
			_prevMom = momValue;
			return;
		}

		var wasDecreasing = _prevMom < _prevPrevMom;
		var nowIncreasing = momValue > _prevMom;
		var wasIncreasing = _prevMom > _prevPrevMom;
		var nowDecreasing = momValue < _prevMom;

		// Momentum turns up - go long
		if (wasDecreasing && nowIncreasing && EnableLong && Position <= 0)
		{
			if (Position < 0) BuyMarket();
			BuyMarket();
		}
		// Momentum turns down - go short
		else if (wasIncreasing && nowDecreasing && EnableShort && Position >= 0)
		{
			if (Position > 0) SellMarket();
			SellMarket();
		}

		_prevPrevMom = _prevMom;
		_prevMom = momValue;
	}
}