中文 ZH
在 GitHub 上查看

Market Slayer 策略

该策略使用加权移动平均线交叉，并通过高时间框架的SSL趋势确认。短期WMA上穿长期WMA且趋势为多头时开多；相反条件下开空。可以选择启用以点数表示的止盈和止损。

细节

  • 入场条件：
    • 多头：短期WMA上穿长期WMA且高周期SSL为多头。
    • 空头：短期WMA下破长期WMA且高周期SSL为空头。
  • 多空方向：双向。
  • 出场条件：
    • 趋势过滤器转向相反方向。
    • 可选的止损或止盈。
  • 止损：可选。
  • 默认值：
    • ShortLength = 10。
    • LongLength = 20。
    • ConfirmationTrendValue = 2。
    • CandleType = TimeSpan.FromMinutes(5).TimeFrame()。
    • TrendCandleType = TimeSpan.FromMinutes(240).TimeFrame()。
    • TakeProfitEnabled = false。
    • TakeProfitValue = 20。
    • StopLossEnabled = false。
    • StopLossValue = 50。
  • 筛选：
    • 类型: 趋势跟随
    • 方向: 双向
    • 指标: WMA, SSL
    • 止损: 可选
    • 复杂度: 基础
    • 时间框架: 日内
    • 季节性: 无
    • 神经网络: 无
    • 背离: 无
    • 风险等级: 中
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;

public class MarketSlayerStrategy : Strategy
{
	private readonly StrategyParam<int> _shortLength;
	private readonly StrategyParam<int> _longLength;
	private readonly StrategyParam<int> _confirmationTrendValue;
	private readonly StrategyParam<DataType> _candleType;

	private WeightedMovingAverage _trendWmaHigh;
	private WeightedMovingAverage _trendWmaLow;
	private WeightedMovingAverage _shortWma;
	private WeightedMovingAverage _longWma;
	private int _trendHlv;
	private bool _isTrendBullish;
	private decimal? _prevShort;
	private decimal? _prevLong;

	public int ShortLength { get => _shortLength.Value; set => _shortLength.Value = value; }
	public int LongLength { get => _longLength.Value; set => _longLength.Value = value; }
	public int ConfirmationTrendValue { get => _confirmationTrendValue.Value; set => _confirmationTrendValue.Value = value; }
	public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }

	public MarketSlayerStrategy()
	{
		_shortLength = Param(nameof(ShortLength), 10);
		_longLength = Param(nameof(LongLength), 20);
		_confirmationTrendValue = Param(nameof(ConfirmationTrendValue), 2);
		_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(5).TimeFrame());
	}

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

		_trendWmaHigh = null;
		_trendWmaLow = null;
		_shortWma = null;
		_longWma = null;
		_trendHlv = 0;
		_isTrendBullish = false;
		_prevShort = null;
		_prevLong = null;
	}

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

		_shortWma = new WeightedMovingAverage { Length = ShortLength };
		_longWma = new WeightedMovingAverage { Length = LongLength };
		_trendWmaHigh = new WeightedMovingAverage { Length = ConfirmationTrendValue };
		_trendWmaLow = new WeightedMovingAverage { Length = ConfirmationTrendValue };

		_prevShort = _prevLong = null;
		_trendHlv = 0;
		_isTrendBullish = false;

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

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

		// Update trend using candle high/low
		var t = candle.ServerTime;
		var highVal = _trendWmaHigh.Process(new DecimalIndicatorValue(_trendWmaHigh, candle.HighPrice, t));
		var lowVal = _trendWmaLow.Process(new DecimalIndicatorValue(_trendWmaLow, candle.LowPrice, t));

		if (_trendWmaHigh.IsFormed && _trendWmaLow.IsFormed)
		{
			var high = highVal.ToDecimal();
			var low = lowVal.ToDecimal();

			if (candle.ClosePrice > high)
				_trendHlv = 1;
			else if (candle.ClosePrice < low)
				_trendHlv = -1;

			var sslDown = _trendHlv < 0 ? high : low;
			var sslUp = _trendHlv < 0 ? low : high;
			_isTrendBullish = sslUp > sslDown;
		}

		if (!_shortWma.IsFormed || !_longWma.IsFormed)
		{
			_prevShort = shortWma;
			_prevLong = longWma;
			return;
		}

		if (_prevShort.HasValue && _prevLong.HasValue)
		{
			var crossUp = _prevShort <= _prevLong && shortWma > longWma;
			var crossDown = _prevShort >= _prevLong && shortWma < longWma;

			if (crossUp && _isTrendBullish && Position <= 0)
				BuyMarket();

			if (crossDown && !_isTrendBullish && Position >= 0)
				SellMarket();

			if (Position > 0 && !_isTrendBullish)
				SellMarket();

			if (Position < 0 && _isTrendBullish)
				BuyMarket();
		}

		_prevShort = shortWma;
		_prevLong = longWma;
	}
}