在 GitHub 上查看

TCPivotLimit 策略

该策略基于经典的日内枢轴点。枢轴点由前一日的最高价、最低价和收盘价计算。策略在选定的支撑或阻力位挂出限价单,并按照预设的止损和止盈管理持仓。

参数

  • Volume – 下单量。
  • Target Variant – 选择进场、止损和目标所使用的支撑/阻力组合:
    1. 在 S1/R1 进场,止损 S2/R2,目标 R1/S1。
    2. 在 S1/R1 进场,止损 S2/R2,目标 R2/S2。
    3. 在 S2/R2 进场,止损 S3/R3,目标 R1/S1。
    4. 在 S2/R2 进场,止损 S3/R3,目标 R2/S2。
    5. 在 S2/R2 进场,止损 S3/R3,目标 R3/S3。
  • Intraday Close – 在 23:00 平掉所有持仓。
  • Modify Stop Loss – 达到第一目标后将止损移动到该目标。

交易逻辑

  1. 每个交易日开始时,根据前一日数据计算枢轴点以及三层支撑与阻力。
  2. 当价格触及选定的支撑或阻力位时,在相反方向挂出限价单。
  3. 持仓在触发止损或止盈时平仓;可选的止损移动在达到第一目标后收紧风险。
  4. 若启用 Intraday Close,策略在交易日结束时关闭所有持仓。
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>
/// Pivot point trading strategy based on previous period support/resistance levels.
/// Buys at support, sells at resistance, exits at opposite pivot level.
/// </summary>
public class TcpPivotLimitStrategy : Strategy
{
	private readonly StrategyParam<DataType> _candleType;

	private DateTime _currentDay;
	private decimal _dayHigh;
	private decimal _dayLow;
	private decimal _dayClose;

	private decimal _pivot;
	private decimal _r1, _s1;
	private decimal _entryPrice;

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

	public TcpPivotLimitStrategy()
	{
		_candleType = Param(nameof(CandleType), TimeSpan.FromHours(4).TimeFrame())
			.SetDisplay("Candle Type", "Candle type", "General");
	}

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

	protected override void OnReseted()
	{
		base.OnReseted();
		_currentDay = default;
		_dayHigh = 0;
		_dayLow = 0;
		_dayClose = 0;
		_pivot = _r1 = _s1 = 0;
		_entryPrice = 0;
	}

	protected override void OnStarted2(DateTime time)
	{
		base.OnStarted2(time);
		SubscribeCandles(CandleType).Bind(ProcessCandle).Start();
	}

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

		var day = candle.OpenTime.Date;

		if (_currentDay != day)
		{
			if (_currentDay != default)
			{
				_pivot = (_dayHigh + _dayLow + _dayClose) / 3m;
				_r1 = 2m * _pivot - _dayLow;
				_s1 = 2m * _pivot - _dayHigh;
			}

			_currentDay = day;
			_dayHigh = candle.HighPrice;
			_dayLow = candle.LowPrice;
			_dayClose = candle.ClosePrice;
			return;
		}

		_dayHigh = Math.Max(_dayHigh, candle.HighPrice);
		_dayLow = Math.Min(_dayLow, candle.LowPrice);
		_dayClose = candle.ClosePrice;

		if (_pivot == 0) return;

		var close = candle.ClosePrice;

		if (Position == 0)
		{
			// Buy at support
			if (close <= _s1)
			{
				BuyMarket();
				_entryPrice = close;
			}
			// Sell at resistance
			else if (close >= _r1)
			{
				SellMarket();
				_entryPrice = close;
			}
		}
		else if (Position > 0)
		{
			// Exit long at resistance or stop at entry - (r1 - s1)
			if (close >= _r1 || close <= _entryPrice - (_r1 - _s1))
			{
				SellMarket();
				_entryPrice = 0;
			}
		}
		else if (Position < 0)
		{
			// Exit short at support or stop
			if (close <= _s1 || close >= _entryPrice + (_r1 - _s1))
			{
				BuyMarket();
				_entryPrice = 0;
			}
		}
	}
}