Стратегия повторяет логику советника MetaTrader 4 Signal-COunt-with array.mq4.
Она отслеживает экстремумы канала Дончиана для набора ценовых смещений и подсчитывает,
как часто индикатор меняет значение, возвращается к «пустому» значению или снова выдаёт
сигнал. Реализация сохраняет диагностический характер исходного скрипта: заявки не
выставляются, вместо этого стратегия выводит подробную статистику при появлении нового
максимума/минимума либо при включённом построчном логировании.
Концепция
Вместо вызова iCustom индикатора super_signals_v2_alert используется канал Дончиана,
который предоставляет максимум и минимум за ChannelPeriod свечей.
Анализируется сетка смещений (GapStart, GapStep, GapCount), имитирующая перебор
параметров в оригинальном советнике.
Для каждого смещения ведутся шесть счётчиков, соответствующих массивам исходного кода,
включая фиксацию переходов к пустым значениям (2147483647 для верхнего буфера и
-2147483646 для нижнего).
Результаты выводятся в виде таблицы, что позволяет быстро оценить, как часто буфер
генерирует сигнал, очищается или покидает нулевое состояние.
Параметры
Параметр
Значение по умолчанию
Описание
CandleType
Таймфрейм 5 минут
Свечной поток для вычисления канала Дончиана.
ChannelPeriod
24
Количество свечей, используемых для определения экстремумов.
GapStart
0
Начальное смещение (в шагах цены), применяемое к виртуальным значениям сигнала.
GapStep
1
Шаг (в шагах цены) между соседними смещениями.
GapCount
8
Число анализируемых смещений (аналог цикла 0..7 в MQL).
LogOnEachCandle
false
Включает вывод статистики после каждой завершённой свечи.
Счётчики
Каждое смещение содержит две строки: индекс 0 отвечает за верхний буфер Дончиана
(бычий сигнал), индекс 1 — за нижний буфер (медвежий сигнал). Собираются следующие
показатели:
Changed — значение индикатора отличается от предыдущего наблюдения.
NegEmpty — количество отрицательных sentinel -2147483646 (актуально для нижнего буфера).
Zero — переход от значения по умолчанию 0 к любому ненулевому значению.
NewFromEmpty — реальный сигнал заменил sentinel.
BackToEmpty — буфер вернулся к sentinel после периода с ненулевым значением.
Эти счётчики полностью соответствуют массивам GetInd_iCustom_changed, GetInd_iCustom_maxInt,
GetInd_iCustom_minInt и т.д. в исходном советнике.
Логирование
Диагностические сообщения формируются методом AddInfoLog в двух случаях:
Когда верхняя граница Дончиана повышается или нижняя граница снижается, что означает новый экстремум.
После каждой завершённой свечи, если параметр LogOnEachCandle установлен в true.
Каждая запись начинается с времени свечи, далее перечисляются счётчики для всех смещений, что
позволяет сравнивать поведение различных конфигураций индикатора.
Рекомендации
Стратегия использует только исторические свечи и не отправляет заявок — её можно подключать к любому инструменту.
Подбирайте ChannelPeriod под волатильность инструмента: увеличение периода делает сигналы более редкими, как в MT4.
При необходимости наблюдать больше смещений увеличьте GapCount. При запуске массивы автоматически пересоздаются.
Комбинируйте печать статистики с графическим отображением (свечи + канал Дончиана), чтобы визуально сопоставлять
логи с рыночной структурой.
using System;
using System.Collections.Generic;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.BusinessEntities;
using StockSharp.Messages;
namespace StockSharp.Samples.Strategies;
public class SignalCountWithArrayStrategy : Strategy
{
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<int> _cciPeriod;
private decimal? _prevCci;
public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }
public int CciPeriod { get => _cciPeriod.Value; set => _cciPeriod.Value = value; }
public SignalCountWithArrayStrategy()
{
_candleType = Param(nameof(CandleType), TimeSpan.FromHours(1).TimeFrame()).SetDisplay("Candle Type", "Timeframe", "General");
_cciPeriod = Param(nameof(CciPeriod), 14).SetGreaterThanZero().SetDisplay("CCI Period", "CCI lookback", "Indicators");
}
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities() => [(Security, CandleType)];
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_prevCci = null;
}
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_prevCci = null;
var cci = new CommodityChannelIndex { Length = CciPeriod };
var subscription = SubscribeCandles(CandleType);
subscription.Bind(cci, ProcessCandle).Start();
var area = CreateChartArea();
if (area != null) { DrawCandles(area, subscription); DrawOwnTrades(area); }
}
private void ProcessCandle(ICandleMessage candle, decimal cciVal)
{
if (candle.State != CandleStates.Finished) return;
if (!IsFormedAndOnlineAndAllowTrading()) { _prevCci = cciVal; return; }
if (_prevCci == null) { _prevCci = cciVal; return; }
if (_prevCci.Value < 0m && cciVal >= 0m && Position <= 0) { if (Position < 0) BuyMarket(); BuyMarket(); }
else if (_prevCci.Value > 0m && cciVal <= 0m && Position >= 0) { if (Position > 0) SellMarket(); SellMarket(); }
_prevCci = cciVal;
}
}
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 CommodityChannelIndex
from StockSharp.Algo.Strategies import Strategy
from datatype_extensions import *
from indicator_extensions import *
class signal_count_with_array_strategy(Strategy):
def __init__(self):
super(signal_count_with_array_strategy, self).__init__()
self._cci_period = self.Param("CciPeriod", 14).SetGreaterThanZero().SetDisplay("CCI Period", "CCI lookback", "Indicators")
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromHours(1))).SetDisplay("Candle Type", "Timeframe", "General")
@property
def CandleType(self): return self._candle_type.Value
@CandleType.setter
def CandleType(self, value): self._candle_type.Value = value
def OnReseted(self):
super(signal_count_with_array_strategy, self).OnReseted()
self._prev_cci = None
def OnStarted2(self, time):
super(signal_count_with_array_strategy, self).OnStarted2(time)
self._prev_cci = None
cci = CommodityChannelIndex()
cci.Length = self._cci_period.Value
sub = self.SubscribeCandles(self.CandleType)
sub.Bind(cci, self.OnProcess).Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, sub)
self.DrawOwnTrades(area)
def OnProcess(self, candle, cci_val):
if candle.State != CandleStates.Finished:
return
if not self.IsFormedAndOnlineAndAllowTrading():
self._prev_cci = cci_val
return
if self._prev_cci is None:
self._prev_cci = cci_val
return
if self._prev_cci < 0 and cci_val >= 0 and self.Position <= 0:
if self.Position < 0:
self.BuyMarket()
self.BuyMarket()
elif self._prev_cci > 0 and cci_val <= 0 and self.Position >= 0:
if self.Position > 0:
self.SellMarket()
self.SellMarket()
self._prev_cci = cci_val
def CreateClone(self):
return signal_count_with_array_strategy()