Exp Blau HLM — порт советника MetaTrader 5 Exp_BlauHLM.mq5 на платформу StockSharp. Алгоритм использует осциллятор Blau High-Low Momentum (HLM), сравнивающий экстремумы последних баров, сглаживает разницу каскадом XMA и поддерживает три режима работы:
Breakdown — торговля пробоев нулевой линии гистограммы.
Twist — поиск «скруток» в наклоне гистограммы для фиксации смены импульса.
CloudTwist — анализ верхней и нижней оболочек индикатора с реакцией на их пересечения.
В порте сохранены все параметры и логика оригинала; управление размером позиции осуществляется через свойство Volume базовой стратегии.
Торговые правила
После закрытия свечи выбранного таймфрейма рассчитывается осциллятор Blau HLM:
Определяется разница между текущим максимумом и максимумом XLength - 1 баров назад, а также зеркальная разница по минимумам.
Отрицательные значения обнуляются, после чего формируется исходный HLM (в пунктах при наличии шага цены).
Значение проходит через четыре одинаковых по типу, но независимых по длине сглаживания.
В зависимости от выбранного режима:
Breakdown открывает покупки при положительном старом значении гистограммы и неположительном новом (возврат выше нуля) и закрывает шорты в той же ситуации. Симметрично для продаж.
Twist оценивает наклон гистограммы по трём точкам. Ускорение (рост средней точки после снижения) даёт сигнал на покупку, замедление — на продажу.
CloudTwist контролирует две сглаженные линии. Если старший верхний канал выше нижнего и на следующем баре происходит обратное пересечение, генерируются сигналы.
Разрешения BuyOpen, SellOpen, BuyClose, SellClose определяют открытие и закрытие позиций. Перед открытием противоположного направления активная позиция закрывается рыночной заявкой.
Параметры
Параметр
Тип
Значение по умолчанию
Описание
CandleType
DataType
Свечи H4
Таймфрейм, на котором строится осциллятор.
SmoothingMethod
SmoothMethod
Exponential
Тип сглаживания XMA (несовместимые варианты заменяются на EMA).
XLength
int
2
Число баров для расчёта необработанного импульса high/low.
FirstLength
int
20
Длина первого этапа сглаживания.
SecondLength
int
5
Длина второго этапа сглаживания.
ThirdLength
int
3
Длина третьего этапа сглаживания.
FourthLength
int
3
Длина финального сигнального сглаживания.
Phase
int
15
Параметр фазы для Jurik (ограничен диапазоном ±100).
SignalBar
int
1
Смещение по истории для сравнения значений индикатора.
EntryMode
Mode
Twist
Режим торговли (Breakdown, Twist, CloudTwist).
BuyOpen / SellOpen
bool
true
Разрешение на открытие длинных/коротких позиций.
BuyClose / SellClose
bool
true
Разрешение на закрытие длинных/коротких позиций по встречному сигналу.
Особенности порта
Библиотека SmoothAlgorithms.mqh содержит проприетарные фильтры (JJMA, JurX, ParMA, T3, VIDYA, AMA). В StockSharp используются ближайшие аналоги; неподдерживаемые методы заменены на экспоненциальное сглаживание.
Параметры управления капиталом (MM, MarginMode, StopLoss, TakeProfit, Deviation) в MT5 определяли объём и цены исполнения. В порте размер позиции задаётся через Volume, сделки открываются по рынку.
Логика SignalBar сохранена: стратегия ведёт буфер значений индикатора и сравнивает именно исторические точки, что обеспечивает сопоставимость оптимизаций.
Функция StartProtection() запускает базовую защиту. Для стоп-лоссов/тейк-профитов используйте глобальные настройки стратегии или коннектора.
Рекомендации по использованию
Перед запуском задайте Volume, чтобы определить объём сделки.
На инструментах без корректного PriceStep осциллятор работает в абсолютных ценах — при крупном тике подберите длины сглаживания вручную.
Экстремальные значения Phase при коротких периодах делают сигналы шумными; при необходимости увеличьте длины.
Дополните стратегию портфельными ограничениями или внешними правилами управления риском, чтобы повторить поведение оригинальных стопов.
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 ExpBlauHlmStrategy : Strategy
{
private readonly StrategyParam<int> _fastPeriod;
private readonly StrategyParam<int> _slowPeriod;
private readonly StrategyParam<int> _stopLossPoints;
private readonly StrategyParam<int> _takeProfitPoints;
private ExponentialMovingAverage _fast;
private ExponentialMovingAverage _slow;
private decimal _prevFast;
private decimal _prevSlow;
private decimal _entryPrice;
private int _cooldown;
public int FastPeriod { get => _fastPeriod.Value; set => _fastPeriod.Value = value; }
public int SlowPeriod { get => _slowPeriod.Value; set => _slowPeriod.Value = value; }
public int StopLossPoints { get => _stopLossPoints.Value; set => _stopLossPoints.Value = value; }
public int TakeProfitPoints { get => _takeProfitPoints.Value; set => _takeProfitPoints.Value = value; }
public ExpBlauHlmStrategy()
{
_fastPeriod = Param(nameof(FastPeriod), 14).SetGreaterThanZero().SetDisplay("Fast Period", "Fast EMA period", "Indicator");
_slowPeriod = Param(nameof(SlowPeriod), 50).SetGreaterThanZero().SetDisplay("Slow Period", "Slow EMA period", "Indicator");
_stopLossPoints = Param(nameof(StopLossPoints), 200).SetNotNegative().SetDisplay("Stop Loss", "Stop-loss in price steps", "Risk");
_takeProfitPoints = Param(nameof(TakeProfitPoints), 400).SetNotNegative().SetDisplay("Take Profit", "Take-profit in price steps", "Risk");
}
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
{
yield return (Security, TimeSpan.FromMinutes(5).TimeFrame());
}
protected override void OnReseted()
{
base.OnReseted();
_fast = null; _slow = null;
_prevFast = 0; _prevSlow = 0; _entryPrice = 0; _cooldown = 0;
}
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_fast = new ExponentialMovingAverage { Length = FastPeriod };
_slow = new ExponentialMovingAverage { Length = SlowPeriod };
var subscription = SubscribeCandles(TimeSpan.FromMinutes(5).TimeFrame());
subscription.Bind(_fast, _slow, ProcessCandle);
subscription.Start();
}
private void ProcessCandle(ICandleMessage candle, decimal fastValue, decimal slowValue)
{
if (candle.State != CandleStates.Finished) return;
if (!_fast.IsFormed || !_slow.IsFormed) { _prevFast = fastValue; _prevSlow = slowValue; return; }
if (_cooldown > 0) { _cooldown--; _prevFast = fastValue; _prevSlow = slowValue; return; }
var close = candle.ClosePrice;
var step = Security?.PriceStep ?? 1m;
if (Position > 0 && _entryPrice > 0)
{
if (StopLossPoints > 0 && close <= _entryPrice - StopLossPoints * step) { SellMarket(); _entryPrice = 0; _cooldown = 100; _prevFast = fastValue; _prevSlow = slowValue; return; }
if (TakeProfitPoints > 0 && close >= _entryPrice + TakeProfitPoints * step) { SellMarket(); _entryPrice = 0; _cooldown = 100; _prevFast = fastValue; _prevSlow = slowValue; return; }
}
else if (Position < 0 && _entryPrice > 0)
{
if (StopLossPoints > 0 && close >= _entryPrice + StopLossPoints * step) { BuyMarket(); _entryPrice = 0; _cooldown = 100; _prevFast = fastValue; _prevSlow = slowValue; return; }
if (TakeProfitPoints > 0 && close <= _entryPrice - TakeProfitPoints * step) { BuyMarket(); _entryPrice = 0; _cooldown = 100; _prevFast = fastValue; _prevSlow = slowValue; return; }
}
if (_prevFast <= _prevSlow && fastValue > slowValue && Position <= 0)
{ if (Position < 0) BuyMarket(); BuyMarket(); _entryPrice = close; _cooldown = 100; }
else if (_prevFast >= _prevSlow && fastValue < slowValue && Position >= 0)
{ if (Position > 0) SellMarket(); SellMarket(); _entryPrice = close; _cooldown = 100; }
_prevFast = fastValue; _prevSlow = slowValue;
}
}
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
from StockSharp.Algo.Strategies import Strategy
class exp_blau_hlm_strategy(Strategy):
def __init__(self):
super(exp_blau_hlm_strategy, self).__init__()
self._fast_period = self.Param("FastPeriod", 14) \
.SetDisplay("Fast Period", "Fast MA period", "Indicator")
self._slow_period = self.Param("SlowPeriod", 50) \
.SetDisplay("Slow Period", "Slow MA period", "Indicator")
self._stop_loss_points = self.Param("StopLossPoints", 200) \
.SetDisplay("Stop Loss", "Stop-loss in price steps", "Risk")
self._take_profit_points = self.Param("TakeProfitPoints", 400) \
.SetDisplay("Take Profit", "Take-profit in price steps", "Risk")
self._fast = None
self._slow = None
self._prev_fast = 0.0
self._prev_slow = 0.0
self._entry_price = 0.0
self._cooldown = 0
@property
def fast_period(self):
return self._fast_period.Value
@property
def slow_period(self):
return self._slow_period.Value
@property
def stop_loss_points(self):
return self._stop_loss_points.Value
@property
def take_profit_points(self):
return self._take_profit_points.Value
def OnReseted(self):
super(exp_blau_hlm_strategy, self).OnReseted()
self._fast = None
self._slow = None
self._prev_fast = 0.0
self._prev_slow = 0.0
self._entry_price = 0.0
self._cooldown = 0
def OnStarted2(self, time):
super(exp_blau_hlm_strategy, self).OnStarted2(time)
self._fast = ExponentialMovingAverage()
self._fast.Length = self.fast_period
self._slow = ExponentialMovingAverage()
self._slow.Length = self.slow_period
subscription = self.SubscribeCandles(DataType.TimeFrame(TimeSpan.FromMinutes(5)))
subscription.Bind(self._fast, self._slow, self._process_candle)
subscription.Start()
def _process_candle(self, candle, fast_value, slow_value):
if candle.State != CandleStates.Finished:
return
fast_val = float(fast_value)
slow_val = float(slow_value)
if not self._fast.IsFormed or not self._slow.IsFormed:
self._prev_fast = fast_val
self._prev_slow = slow_val
return
if self._cooldown > 0:
self._cooldown -= 1
self._prev_fast = fast_val
self._prev_slow = slow_val
return
close = float(candle.ClosePrice)
step = float(self.Security.PriceStep) if self.Security is not None and self.Security.PriceStep is not None else 1.0
if self.Position > 0 and self._entry_price > 0:
if self.stop_loss_points > 0 and close <= self._entry_price - self.stop_loss_points * step:
self.SellMarket()
self._entry_price = 0.0
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
return
if self.take_profit_points > 0 and close >= self._entry_price + self.take_profit_points * step:
self.SellMarket()
self._entry_price = 0.0
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
return
elif self.Position < 0 and self._entry_price > 0:
if self.stop_loss_points > 0 and close >= self._entry_price + self.stop_loss_points * step:
self.BuyMarket()
self._entry_price = 0.0
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
return
if self.take_profit_points > 0 and close <= self._entry_price - self.take_profit_points * step:
self.BuyMarket()
self._entry_price = 0.0
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
return
if self._prev_fast <= self._prev_slow and fast_val > slow_val and self.Position <= 0:
if self.Position < 0:
self.BuyMarket()
self.BuyMarket()
self._entry_price = close
self._cooldown = 100
elif self._prev_fast >= self._prev_slow and fast_val < slow_val and self.Position >= 0:
if self.Position > 0:
self.SellMarket()
self.SellMarket()
self._entry_price = close
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
def CreateClone(self):
return exp_blau_hlm_strategy()