在 GitHub 上查看

3rd Generation XMA Reversal

采用双重指数平滑的第三代移动平均线来寻找局部高点和低点。当 XMA 从局部低点向上转折时开多单;当 XMA 在局部高点向下转折时开空单。出现反向信号时反向开仓,不设置固定止损或止盈。

细节

  • 入场条件:XMA 形成局部极值并反转。
  • 多空方向:双向。
  • 出场条件:反向信号。
  • 止损:无。
  • 默认数值
    • MaLength = 50
    • CandleType = TimeSpan.FromHours(4)
  • 过滤器
    • 类别:趋势
    • 方向:双向
    • 指标:EMA
    • 止损:无
    • 复杂度:基础
    • 时间框架:日内(4 小时)
    • 季节性:无
    • 神经网络:无
    • 背离:无
    • 风险等级:中等
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>
/// 3rd Generation XMA reversal strategy using double-smoothed EMA turning points.
/// </summary>
public class ThirdGenerationXmaReversalStrategy : Strategy
{
	private readonly StrategyParam<int> _maLength;
	private readonly StrategyParam<DataType> _candleType;

	private decimal _prev1;
	private decimal _prev2;
	private int _barCount;

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

	public ThirdGenerationXmaReversalStrategy()
	{
		_maLength = Param(nameof(MaLength), 50)
			.SetDisplay("MA Length", "Base length for the moving average", "General");
		_candleType = Param(nameof(CandleType), TimeSpan.FromHours(4).TimeFrame())
			.SetDisplay("Candle Type", "Type of candles to use", "General");
	}

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

	protected override void OnReseted()
	{
		base.OnReseted();
		_prev1 = 0;
		_prev2 = 0;
		_barCount = 0;
	}

	protected override void OnStarted2(DateTime time)
	{
		base.OnStarted2(time);

		var ema1 = new ExponentialMovingAverage { Length = MaLength };
		var ema2 = new ExponentialMovingAverage { Length = MaLength / 2 > 0 ? MaLength / 2 : 10 };

		SubscribeCandles(CandleType).Bind(ema1, ema2, ProcessCandle).Start();
	}

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

		// XMA = 2*ema1 - ema2 (third generation concept)
		var xma = 2m * ema1Value - ema2Value;
		_barCount++;

		if (_barCount >= 3)
		{
			// Local minimum => buy
			if (_prev1 < _prev2 && xma > _prev1 && Position <= 0)
			{
				if (Position < 0) BuyMarket();
				BuyMarket();
			}
			// Local maximum => sell
			else if (_prev1 > _prev2 && xma < _prev1 && Position >= 0)
			{
				if (Position > 0) SellMarket();
				SellMarket();
			}
		}

		_prev2 = _prev1;
		_prev1 = xma;
	}
}