Стратегия Colibri Grid Manager
Обзор
Colibri Grid Manager — это перенос советника MetaTrader 4 Colibri.mq4 (каталог MQL/9713) в экосистему StockSharp. Стратегия рассчитана на полуавтоматическую работу с сеткой заявок: формирует уровни по требованию, рассчитывает объём исходя из заданного риска, выставляет защитные стопы/тейк-профиты и блокирует дальнейшую торговлю при превышении дневного лимита убытков.
Логика работы
- При запуске стратегия подписывается на выбранные свечи и стакан, сбрасывает предыдущие заявки и фиксирует стартовые показатели прибыли/убытка на текущий день.
- Если
EnableGrid включён и отсутствуют позиции либо активные сеточные заявки, формируется новая сетка по разрешённым направлениям (AllowBuy, AllowSell). Уровни можно расставить симметрично относительно центра (CenterPrice) либо отталкиваться от отдельных точек входа для покупок/продаж.
- Параметр
OrderType определяет тип входа (лимитный, стоповый или рыночный). Расстояние между уровнями задаётся в пунктах (LevelSpacingPoints) и переводится в абсолютное значение через PriceStep инструмента.
- Объём каждой заявки можно зафиксировать (
FixedOrderVolume) либо рассчитать по доле риска (RiskPercent). В риск-режиме доля капитала делится на количество уровней по данному направлению и нормируется на денежный риск, связанный с защитным стопом.
- После исполнения входящей заявки стратегия автоматически выставляет пару защитных ордеров. Стоп-цена берётся из
StopLossPrice либо рассчитывается по StopDistancePoints, тейк-профит — из TakeProfitDistancePoints или по умолчанию равен одному шагу сетки. Заявки могут иметь срок действия ExpirationHours.
- Реализован постоянный контроль суммарного (реализованного + плавающего) PnL. Если дневной убыток превышает
DailyLossLimitPercent, все заявки отменяются, позиции закрываются, а построение новой сетки блокируется до начала следующего дня.
- Ручные флаги (
CloseAllPositions, CloseLongPositions, CloseShortPositions, CancelOrders) позволяют мгновенно закрыть позиции или очистить книгу заявок без правок кода.
Параметры
- EnableGrid — главный переключатель автоматического сопровождения сетки.
- OrderType — тип заявок для уровней (
Limit, Stop, Market).
- AllowBuy / AllowSell — разрешённые направления торговли.
- UseCenterLine / CenterPrice — распределение уровней симметрично вокруг центральной цены; при нуле используется средняя цена.
- LevelSpacingPoints — интервал между уровнями в пунктах, пересчитывается в абсолютные цены.
- LevelsCount — количество уровней на направление (для рыночного входа фактически используется одно срабатывание).
- BuyEntryPrice / SellEntryPrice — опорные цены входа для длинной/короткой сетки при отключённом центрировании (ноль — текущие bid/ask).
- StopLossPrice — абсолютный уровень стоп-лосса, применяемый ко всем ордерам. Ноль означает использование
StopDistancePoints.
- StopDistancePoints — расстояние до стопа в пунктах, если абсолютная цена не задана.
- TakeProfitDistancePoints — расстояние до тейк-профита в пунктах; при нуле равняется одному шагу сетки.
- UseRiskSizing / RiskPercent — включение расчёта объёма по проценту капитала и величина этого процента. Значение распределяется поровну между уровнями одного направления.
- FixedOrderVolume — объём по умолчанию, если риск-расчёт отключён или невозможен.
- ExpirationHours — срок жизни отложенных заявок (в часах).
- DailyLossLimitPercent — дневной лимит убытков в долях от капитала.
- CloseAllPositions / CloseLongPositions / CloseShortPositions / CancelOrders — ручные команды для оперативного управления позицией и заявками.
- CandleType — таймфрейм свечей, используемых для служебных проверок и дневного сброса.
Особенности реализации
- Используются только высокоуровневые методы StockSharp (
SubscribeCandles, SubscribeOrderBook, BuyLimit, SellStop и т. д.), что упрощает интеграцию.
- При расчёте объёма учитываются
PriceStep и StepPrice, благодаря чему точная конвертация пунктов в денежный риск соответствует оригинальной логике MT4.
- Защитные ордера регистрируются отдельно от входящих заявок, что согласуется с моделью связанных ордеров в StockSharp.
- Лимит дневных потерь сбрасывается при смене календарного дня; при необходимости можно вручную возобновить работу, переключив
EnableGrid.
- MT4-глобальные переменные, сложные сценарии аварийного закрытия и очистки графических объектов заменены типизированными параметрами и понятными ручными флагами.
Рекомендации по использованию
- До запуска определите тип сетки: симметричную относительно центра или от конкретных точек входа, и заполните соответствующие параметры.
- Подбирайте значения
LevelSpacingPoints, StopDistancePoints и TakeProfitDistancePoints исходя из волатильности инструмента (все значения задаются в пунктах).
- При использовании риск-менеджмента убедитесь, что для инструмента корректно настроены
PriceStep и StepPrice.
- Для оперативных изменений конфигурации сначала воспользуйтесь ручными командами отмены/закрытия, затем меняйте параметры.
- Сочетайте внутренний дневной лимит с внешними системами управления риском, если один счёт используется несколькими стратегиями.
Отличия от оригинального советника
- Вместо MT4-глобальных переменных и «магических» комментариев используются понятные параметры и ручные переключатели.
- Сложная логика аварийного закрытия, автонастройки количества уровней и удаления графических объектов упрощена и сведена к управляемым настройкам.
- Функции трейлинг-стопа из MQL не перенесены; при необходимости можно комбинировать стратегию с готовыми trailing-модулями StockSharp.
- Схема зависимостей «мать-дочь» между ордерами не реализована: каждый уровень работает автономно со своими защитными заявками.
Таким образом, реализованная стратегия сохраняет ключевые идеи Colibri — поэтапный вход и строгий контроль риска — но в более прозрачной и типовой для StockSharp форме.
using System;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.BusinessEntities;
using StockSharp.Messages;
namespace StockSharp.Samples.Strategies;
/// <summary>
/// Colibri Grid Manager: EMA crossover with RSI filter and ATR stops.
/// </summary>
public class ColibriGridManagerStrategy : Strategy
{
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<int> _fastEmaLength;
private readonly StrategyParam<int> _slowEmaLength;
private readonly StrategyParam<int> _rsiLength;
private readonly StrategyParam<int> _atrLength;
private decimal _prevFast;
private decimal _prevSlow;
private decimal _entryPrice;
public ColibriGridManagerStrategy()
{
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(5).TimeFrame())
.SetDisplay("Candle Type", "Timeframe.", "General");
_fastEmaLength = Param(nameof(FastEmaLength), 10)
.SetDisplay("Fast EMA Length", "Fast EMA period.", "Indicators");
_slowEmaLength = Param(nameof(SlowEmaLength), 30)
.SetDisplay("Slow EMA Length", "Slow EMA period.", "Indicators");
_rsiLength = Param(nameof(RsiLength), 14)
.SetDisplay("RSI Length", "RSI period.", "Indicators");
_atrLength = Param(nameof(AtrLength), 14)
.SetDisplay("ATR Length", "ATR period.", "Indicators");
}
public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }
public int FastEmaLength { get => _fastEmaLength.Value; set => _fastEmaLength.Value = value; }
public int SlowEmaLength { get => _slowEmaLength.Value; set => _slowEmaLength.Value = value; }
public int RsiLength { get => _rsiLength.Value; set => _rsiLength.Value = value; }
public int AtrLength { get => _atrLength.Value; set => _atrLength.Value = value; }
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_prevFast = 0; _prevSlow = 0; _entryPrice = 0;
}
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_prevFast = 0; _prevSlow = 0; _entryPrice = 0;
var fastEma = new ExponentialMovingAverage { Length = FastEmaLength };
var slowEma = new ExponentialMovingAverage { Length = SlowEmaLength };
var rsi = new RelativeStrengthIndex { Length = RsiLength };
var atr = new AverageTrueRange { Length = AtrLength };
var subscription = SubscribeCandles(CandleType);
subscription.Bind(fastEma, slowEma, rsi, atr, ProcessCandle).Start();
var area = CreateChartArea();
if (area != null) { DrawCandles(area, subscription); DrawIndicator(area, fastEma); DrawIndicator(area, slowEma); DrawOwnTrades(area); }
}
private void ProcessCandle(ICandleMessage candle, decimal fastVal, decimal slowVal, decimal rsiVal, decimal atrVal)
{
if (candle.State != CandleStates.Finished) return;
if (_prevFast == 0 || _prevSlow == 0 || atrVal <= 0) { _prevFast = fastVal; _prevSlow = slowVal; return; }
var close = candle.ClosePrice;
if (Position > 0)
{
if ((fastVal < slowVal && _prevFast >= _prevSlow) || close <= _entryPrice - atrVal * 2m) { SellMarket(); _entryPrice = 0; }
}
else if (Position < 0)
{
if ((fastVal > slowVal && _prevFast <= _prevSlow) || close >= _entryPrice + atrVal * 2m) { BuyMarket(); _entryPrice = 0; }
}
if (Position == 0)
{
if (fastVal > slowVal && _prevFast <= _prevSlow && rsiVal > 50) { _entryPrice = close; BuyMarket(); }
else if (fastVal < slowVal && _prevFast >= _prevSlow && rsiVal < 50) { _entryPrice = close; SellMarket(); }
}
_prevFast = fastVal; _prevSlow = slowVal;
}
}
import clr
clr.AddReference("StockSharp.Messages")
clr.AddReference("StockSharp.Algo")
clr.AddReference("StockSharp.Algo.Indicators")
clr.AddReference("StockSharp.Algo.Strategies")
from System import TimeSpan
from StockSharp.Messages import DataType, CandleStates
from StockSharp.Algo.Indicators import ExponentialMovingAverage, RelativeStrengthIndex, AverageTrueRange
from StockSharp.Algo.Strategies import Strategy
class colibri_grid_manager_strategy(Strategy):
"""
Colibri Grid Manager: EMA crossover with RSI filter and ATR stops.
"""
def __init__(self):
super(colibri_grid_manager_strategy, self).__init__()
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromMinutes(5))) \
.SetDisplay("Candle Type", "Timeframe.", "General")
self._fast_ema_length = self.Param("FastEmaLength", 10) \
.SetDisplay("Fast EMA Length", "Fast EMA period.", "Indicators")
self._slow_ema_length = self.Param("SlowEmaLength", 30) \
.SetDisplay("Slow EMA Length", "Slow EMA period.", "Indicators")
self._rsi_length = self.Param("RsiLength", 14) \
.SetDisplay("RSI Length", "RSI period.", "Indicators")
self._atr_length = self.Param("AtrLength", 14) \
.SetDisplay("ATR Length", "ATR period.", "Indicators")
self._prev_fast = 0.0
self._prev_slow = 0.0
self._entry_price = 0.0
@property
def candle_type(self):
return self._candle_type.Value
def OnReseted(self):
super(colibri_grid_manager_strategy, self).OnReseted()
self._prev_fast = 0.0
self._prev_slow = 0.0
self._entry_price = 0.0
def OnStarted2(self, time):
super(colibri_grid_manager_strategy, self).OnStarted2(time)
self._prev_fast = 0.0
self._prev_slow = 0.0
self._entry_price = 0.0
fast_ema = ExponentialMovingAverage()
fast_ema.Length = self._fast_ema_length.Value
slow_ema = ExponentialMovingAverage()
slow_ema.Length = self._slow_ema_length.Value
rsi = RelativeStrengthIndex()
rsi.Length = self._rsi_length.Value
atr = AverageTrueRange()
atr.Length = self._atr_length.Value
subscription = self.SubscribeCandles(self.candle_type)
subscription.Bind(fast_ema, slow_ema, rsi, atr, self.on_process).Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawIndicator(area, fast_ema)
self.DrawIndicator(area, slow_ema)
self.DrawOwnTrades(area)
def on_process(self, candle, fast_val, slow_val, rsi_val, atr_val):
if candle.State != CandleStates.Finished:
return
if self._prev_fast == 0.0 or self._prev_slow == 0.0 or atr_val <= 0:
self._prev_fast = fast_val
self._prev_slow = slow_val
return
close = float(candle.ClosePrice)
if self.Position > 0:
if (fast_val < slow_val and self._prev_fast >= self._prev_slow) or close <= self._entry_price - atr_val * 2:
self.SellMarket()
self._entry_price = 0.0
elif self.Position < 0:
if (fast_val > slow_val and self._prev_fast <= self._prev_slow) or close >= self._entry_price + atr_val * 2:
self.BuyMarket()
self._entry_price = 0.0
if self.Position == 0:
if fast_val > slow_val and self._prev_fast <= self._prev_slow and rsi_val > 50:
self._entry_price = close
self.BuyMarket()
elif fast_val < slow_val and self._prev_fast >= self._prev_slow and rsi_val < 50:
self._entry_price = close
self.SellMarket()
self._prev_fast = fast_val
self._prev_slow = slow_val
def CreateClone(self):
return colibri_grid_manager_strategy()