中文 ZH
在 GitHub 上查看

MAVA Xonax 策略

该策略利用开盘价和收盘价的指数移动平均线来识别方向变化。止损和止盈距离基于最高价和最低价的EMA计算，从而在交易中预先设定风险和收益。

详情

  • 入场条件：
    • 多头：在最近两个完成的K线上，开盘价EMA上穿收盘价EMA。
    • 空头：在最近两个完成的K线上，开盘价EMA下穿收盘价EMA。
  • 多空方向：双向
  • 止损：基于EMA范围的固定止损和止盈。
  • 默认值：
    • EmaPeriod = 6
    • CandleType = TimeSpan.FromMinutes(240).TimeFrame()
  • 过滤条件：
    • 类别：反转
    • 方向：双向
    • 指标：EMA
    • 止损：是
    • 复杂度：基础
    • 时间框架：长周期
    • 季节性：否
    • 神经网络：否
    • 背离：否
    • 风险等级：中等
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>
/// Strategy based on EMA cross of open and close prices with stop and take levels.
/// </summary>
public class MavaXonaxStrategy : Strategy
{
	private readonly StrategyParam<int> _emaPeriod;
	private readonly StrategyParam<int> _signalCooldownBars;
	private readonly StrategyParam<DataType> _candleType;

	private EMA _emaClose;
	private EMA _emaOpen;
	private EMA _emaHigh;
	private EMA _emaLow;

	private decimal _prevOpen1;
	private decimal _prevOpen2;
	private decimal _prevClose1;
	private decimal _prevClose2;
	private decimal _prevHigh;
	private decimal _prevLow;
	private decimal _longStop;
	private decimal _longTake;
	private decimal _shortStop;
	private decimal _shortTake;
	private int _history;
	private int _cooldownRemaining;

	/// <summary>
	/// EMA period for all calculations.
	/// </summary>
	public int EmaPeriod
	{
		get => _emaPeriod.Value;
		set => _emaPeriod.Value = value;
	}

	/// <summary>
	/// Type of candles to process.
	/// </summary>
	public DataType CandleType
	{
		get => _candleType.Value;
		set => _candleType.Value = value;
	}

	public int SignalCooldownBars
	{
		get => _signalCooldownBars.Value;
		set => _signalCooldownBars.Value = value;
	}

	public MavaXonaxStrategy()
	{
		_emaPeriod = Param(nameof(EmaPeriod), 6)
			.SetGreaterThanZero()
			.SetDisplay("EMA Period", "EMA period", "General");

		_signalCooldownBars = Param(nameof(SignalCooldownBars), 1)
			.SetGreaterThanZero()
			.SetDisplay("Signal Cooldown", "Bars to wait after an entry or exit", "General");

		_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(240).TimeFrame())
			.SetDisplay("Candle Type", "Type of candles", "General");
	}

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

	/// <inheritdoc />
	protected override void OnReseted()
	{
		base.OnReseted();

		_prevOpen1 = _prevOpen2 = 0m;
		_prevClose1 = _prevClose2 = 0m;
		_prevHigh = _prevLow = 0m;
		_longStop = _longTake = 0m;
		_shortStop = _shortTake = 0m;
		_history = 0;
		_cooldownRemaining = 0;
		_emaClose = _emaOpen = _emaHigh = _emaLow = null;
	}

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

		_emaClose = new EMA { Length = EmaPeriod };
		_emaOpen = new EMA { Length = EmaPeriod };
		_emaHigh = new EMA { Length = EmaPeriod };
		_emaLow = new EMA { Length = EmaPeriod };
		_cooldownRemaining = 0;

		var subscription = SubscribeCandles(CandleType);
		subscription.Bind(_emaClose, ProcessCandle).Start();
	}

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

		if (_cooldownRemaining > 0)
			_cooldownRemaining--;

		var openValue = _emaOpen!.Process(candle.OpenPrice, candle.ServerTime, true);
		var highValue = _emaHigh!.Process(candle.HighPrice, candle.ServerTime, true);
		var lowValue = _emaLow!.Process(candle.LowPrice, candle.ServerTime, true);

		if (!openValue.IsFinal || !highValue.IsFinal || !lowValue.IsFinal)
			return;

		var openEma = openValue.ToDecimal();
		var highEma = highValue.ToDecimal();
		var lowEma = lowValue.ToDecimal();

		// Check for stop loss or take profit hits.
		if (Position > 0)
		{
			if (candle.ClosePrice <= _longStop || candle.ClosePrice >= _longTake)
			{
				SellMarket();
				_cooldownRemaining = SignalCooldownBars;
			}
		}
		else if (Position < 0)
		{
			if (candle.ClosePrice >= _shortStop || candle.ClosePrice <= _shortTake)
			{
				BuyMarket();
				_cooldownRemaining = SignalCooldownBars;
			}
		}

		if (_history >= 2 && _cooldownRemaining == 0 && IsFormedAndOnlineAndAllowTrading())
		{
			var step = Security.PriceStep ?? 1m;
			var buySignal = _prevOpen2 > _prevClose2 && _prevOpen1 < _prevClose1;
			var sellSignal = _prevOpen2 < _prevClose2 && _prevOpen1 > _prevClose1;

			if (buySignal && Position == 0)
			{
				var takePr = _prevHigh - _prevLow;
				if (takePr < 600m * step)
					takePr = 600m * step;

				var stopL = 2m * (_prevOpen1 - _prevLow);
				if (stopL > 400m * step)
					stopL = 400m * step;

				var entry = candle.ClosePrice;
				_longStop = entry - stopL;
				_longTake = entry + takePr;

				BuyMarket();
				_cooldownRemaining = SignalCooldownBars;
			}
			else if (sellSignal && Position == 0)
			{
				var takePr = _prevHigh - _prevLow;
				if (takePr < 600m * step)
					takePr = 600m * step;

				var stopL = 2m * (_prevHigh - _prevClose1);
				if (stopL > 400m * step)
					stopL = 400m * step;

				var entry = candle.ClosePrice;
				_shortStop = entry + stopL;
				_shortTake = entry - takePr;

				SellMarket();
				_cooldownRemaining = SignalCooldownBars;
			}
		}

		// Shift stored EMA values.
		_prevOpen2 = _prevOpen1;
		_prevOpen1 = openEma;
		_prevClose2 = _prevClose1;
		_prevClose1 = closeEma;
		_prevHigh = highEma;
		_prevLow = lowEma;

		if (_history < 2)
			_history++;
	}
}