日本語 JA
GitHub で見る

Linear Regression Channel

Trades pullbacks when price moves outside a linear regression channel and reverts toward the mean.

Details

  • Data: Price candles.
  • Entry: Buy when close drops below lower band in an uptrend; sell when close rises above upper band in a downtrend.
  • Exit: Close when price returns to the regression line.
  • Instruments: Any instruments.
  • Risk: Channel boundaries act as dynamic limits.
using System;
using System.Linq;
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 trading pullbacks using a linear regression channel.
/// </summary>
public class LinearRegressionChannelStrategy : Strategy
{
	private readonly StrategyParam<DataType> _candleType;
	private readonly StrategyParam<int> _length;
	private readonly StrategyParam<decimal> _deviation;
	private readonly StrategyParam<int> _cooldownBars;

	private Queue<decimal> _closes = new();
	private int _barsFromSignal;

	/// <summary>
	/// Candle type for calculations.
	/// </summary>
	public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }

	/// <summary>
	/// Number of bars used in regression.
	/// </summary>
	public int Length { get => _length.Value; set => _length.Value = value; }

	/// <summary>
	/// Channel width multiplier.
	/// </summary>
	public decimal Deviation { get => _deviation.Value; set => _deviation.Value = value; }

	/// <summary>
	/// Minimum bars between trade actions.
	/// </summary>
	public int CooldownBars { get => _cooldownBars.Value; set => _cooldownBars.Value = value; }

	/// <summary>
	/// Initializes a new instance of the <see cref="LinearRegressionChannelStrategy"/> class.
	/// </summary>
	public LinearRegressionChannelStrategy()
	{
		_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(5).TimeFrame())
			.SetDisplay("Candle Type", "Type of candles", "General");

		_length = Param(nameof(Length), 50)
			.SetGreaterThanZero()
			.SetDisplay("Length", "Bars for regression", "Parameters")

			.SetOptimize(80, 240, 40);

		_deviation = Param(nameof(Deviation), 1.5m)
			.SetGreaterThanZero()
			.SetDisplay("Deviation", "Channel width multiplier", "Parameters")

			.SetOptimize(2m, 4m, 0.5m);

		_cooldownBars = Param(nameof(CooldownBars), 20)
			.SetGreaterThanZero()
			.SetDisplay("Cooldown Bars", "Minimum bars between signals", "Parameters")
			
			.SetOptimize(10, 40, 2);
	}

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

	/// <inheritdoc />
	protected override void OnReseted()
	{
		base.OnReseted();
		_closes = new Queue<decimal>();
		_barsFromSignal = CooldownBars;
	}

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

		var dummyEma1 = new ExponentialMovingAverage { Length = 10 };
		var dummyEma2 = new ExponentialMovingAverage { Length = 20 };

		var subscription = SubscribeCandles(CandleType);
		subscription
			.Bind(dummyEma1, dummyEma2, ProcessCandle)
			.Start();

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

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

		_closes.Enqueue(candle.ClosePrice);
		if (_closes.Count > Length)
			_closes.Dequeue();

		if (_closes.Count < Length)
			return;

		var closesSnapshot = _closes.ToArray();

		var n = closesSnapshot.Length;
		decimal sumX = 0;
		decimal sumY = 0;
		decimal sumXY = 0;
		decimal sumX2 = 0;
		var i = 0;

		foreach (var y in closesSnapshot)
		{
			var x = (decimal)i;
			sumX += x;
			sumY += y;
			sumXY += x * y;
			sumX2 += x * x;
			i++;
		}

		var denom = n * sumX2 - sumX * sumX;
		if (denom == 0)
			return;

		var slope = (n * sumXY - sumX * sumY) / denom;
		var intercept = (sumY - slope * sumX) / n;

		var lastX = n - 1;
		var line = intercept + slope * lastX;

		decimal devSum = 0;
		i = 0;
		foreach (var y in closesSnapshot)
		{
			var x = (decimal)i;
			var fitted = intercept + slope * x;
			var diff = y - fitted;
			devSum += diff * diff;
			i++;
		}
		var deviation = (decimal)Math.Sqrt((double)(devSum / n));

		var upper = line + deviation * Deviation;
		var lower = line - deviation * Deviation;
		_barsFromSignal++;

		if (_barsFromSignal < CooldownBars)
			return;

		if (slope > 0 && candle.ClosePrice < lower && Position == 0)
		{
			BuyMarket();
			_barsFromSignal = 0;
		}
		else if (slope < 0 && candle.ClosePrice > upper && Position == 0)
		{
			SellMarket();
			_barsFromSignal = 0;
		}
		else if (Position > 0 && candle.ClosePrice >= line)
		{
			SellMarket();
			_barsFromSignal = 0;
		}
		else if (Position < 0 && candle.ClosePrice <= line)
		{
			BuyMarket();
			_barsFromSignal = 0;
		}
	}
}