Español ES
Ver en GitHub

HFT Spreader para FORTS

Descripción General

Esta estrategia replica el comportamiento de un spreader de alta frecuencia en el mercado FORTS. Monitorea continuamente el libro de órdenes y coloca órdenes limitadas en ambos lados del mercado para capturar el diferencial bid-ask.

Lógica de la Estrategia

  • Suscribirse a actualizaciones del libro de órdenes en tiempo real.
  • Cuando no hay posición abierta y el diferencial es suficientemente amplio (determinado por SpreadMultiplier), la estrategia coloca:
    • Una orden limitada de compra un tick por encima del mejor bid.
    • Una orden limitada de venta un tick por debajo del mejor ask.
  • Si existe una posición y no hay órdenes activas, coloca una única orden limitada en el lado opuesto para cerrar y revertir la posición.
  • Las órdenes se cancelan y reemplazan cuando los mejores precios se mueven para mantenerlas en la cima del libro.

Parámetros

  • SpreadMultiplier – diferencial requerido en ticks para colocar ambas órdenes de compra y venta. El valor predeterminado es 4 ticks.
  • Volume – volumen de la orden. El valor predeterminado es 1 lote.

Notas de Uso

  • Diseñada para instrumentos con tamaños de tick pequeños, como futuros en la bolsa FORTS.
  • Utiliza únicamente órdenes limitadas; no se envían órdenes de mercado excepto por el mecanismo de protección si es necesario.
  • Asegurar suficiente liquidez y un entorno de baja latencia para una operación efectiva.
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 that captures the spread on FORTS by trading when spread is wide enough.
/// </summary>
public class HftSpreaderForFortsStrategy : Strategy
{
	private readonly StrategyParam<int> _spreadMultiplier;
	private readonly StrategyParam<DataType> _candleType;

	/// <summary>
	/// Required spread in ticks to place both buy and sell orders.
	/// </summary>
	public int SpreadMultiplier
	{
		get => _spreadMultiplier.Value;
		set => _spreadMultiplier.Value = value;
	}

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

	/// <summary>
	/// Initialize <see cref="HftSpreaderForFortsStrategy"/>.
	/// </summary>
	public HftSpreaderForFortsStrategy()
	{
		_spreadMultiplier = Param(nameof(SpreadMultiplier), 4)
			.SetGreaterThanZero()
			.SetDisplay("Spread Multiplier", "Spread ticks required to place orders", "General")
			.SetOptimize(1, 10, 1);

		_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(1).TimeFrame())
			.SetDisplay("Candle Type", "Candle type for price feed", "General");

		Volume = 1;
	}

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

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

		StartProtection(null, null);

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

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

		var step = Security.PriceStep ?? 1m;
		var spread = candle.HighPrice - candle.LowPrice;

		if (spread >= SpreadMultiplier * step)
		{
			if (Position == 0)
			{
				// Wide spread detected - buy at low, will exit when spread narrows
				BuyMarket();
			}
			else if (Position > 0)
			{
				// Close long position for spread capture
				SellMarket();
			}
			else if (Position < 0)
			{
				// Close short position for spread capture
				BuyMarket();
			}
		}
	}
}