日本語 JA
GitHub で見る

XDPOヒストグラム戦略

概要

XDPOヒストグラム戦略は、オリジナルのMQL5エキスパート Exp_XDPO_Histogram を移植したものです。終値から二重平滑化されたデトレンド価格オシレーター（XDPO）を構築します。オシレーターは、移動平均を価格から差し引き、その差を第2の移動平均で平滑化することで算出されます。ヒストグラムの動きがポジションの開閉シグナルを提供します。

トレードロジック

  • オシレーターが上向きに転換すると、すべてのショートポジションが決済されます。現在のオシレーター値が前の値を上回る場合、新しいロングポジションが開設されます。
  • オシレーターが下向きに転換すると、すべてのロングポジションが決済されます。現在のオシレーター値が前の値を下回る場合、新しいショートポジションが開設されます。
  • 計算は完成したローソク足のみで実行されます。

パラメーター

  • FirstMaLength – 価格に適用する最初の移動平均の長さ。
  • SecondMaLength – 価格と最初のMAの差に適用する移動平均の長さ。
  • CandleType – すべての計算に使用するローソク足の種類。

備考

  • 移動平均は SimpleMovingAverage インジケーターで実装されます。
  • 戦略は成行注文（BuyMarket および SellMarket）を使用し、新規ポジションを開設する前に反対側のポジションを決済します。
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>
/// XDPO Histogram strategy built on double smoothed detrended price oscillator.
/// </summary>
public class XdpoHistogramStrategy : Strategy
{
	private readonly StrategyParam<int> _firstMaLength;
	private readonly StrategyParam<int> _secondMaLength;
	private readonly StrategyParam<DataType> _candleType;

	private decimal _prev1;
	private decimal _prev2;
	private bool _initialized;

	public XdpoHistogramStrategy()
	{
		_firstMaLength = Param(nameof(FirstMaLength), 12)
			.SetDisplay("First MA Length", "Length of the initial moving average.", "Indicators");

		_secondMaLength = Param(nameof(SecondMaLength), 5)
			.SetDisplay("Second MA Length", "Length of the moving average applied to the difference.", "Indicators");

		_candleType = Param(nameof(CandleType), TimeSpan.FromHours(4).TimeFrame())
			.SetDisplay("Candle Type", "Type of candles for strategy calculations.", "General");
	}

	public int FirstMaLength
	{
		get => _firstMaLength.Value;
		set => _firstMaLength.Value = value;
	}

	public int SecondMaLength
	{
		get => _secondMaLength.Value;
		set => _secondMaLength.Value = value;
	}

	public DataType CandleType
	{
		get => _candleType.Value;
		set => _candleType.Value = value;
	}

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

	/// <inheritdoc />
	protected override void OnReseted()
	{
		base.OnReseted();
		_prev1 = 0m;
		_prev2 = 0m;
		_initialized = false;
	}

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

		var ma1 = new ExponentialMovingAverage { Length = FirstMaLength };
		var ma2 = new ExponentialMovingAverage { Length = SecondMaLength };

		var subscription = SubscribeCandles(CandleType);
		subscription
			.Bind(ma1, ma2, ProcessCandle)
			.Start();

		var area = CreateChartArea();
		if (area != null)
		{
			DrawCandles(area, subscription);
			DrawOwnTrades(area);
		}
	}

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

		if (!IsFormedAndOnlineAndAllowTrading())
			return;

		// DPO = close - MA1, then smooth with MA2
		// Since we bind both MAs on close price, approximate: xdpo ~ close - ma1
		// But we need the smoothed version. Use difference between the two MAs as oscillator.
		var xdpo = ma1Value - ma2Value;

		if (!_initialized)
		{
			_prev1 = xdpo;
			_prev2 = xdpo;
			_initialized = true;
			return;
		}

		if (_prev1 < _prev2 && xdpo > _prev1 && Position <= 0)
		{
			BuyMarket();
		}
		else if (_prev1 > _prev2 && xdpo < _prev1 && Position >= 0)
		{
			SellMarket();
		}

		_prev2 = _prev1;
		_prev1 = xdpo;
	}
}