MOC Delta MOO Entry v2 Reverse Strategy
This strategy reverses the classic MOC Delta MOO Entry logic. It measures the buy-sell volume delta in the afternoon session (14:50–14:55) and stores the delta as a percentage of the day's volume. The next morning at 08:30 a position is opened in the opposite direction of the delta if it exceeds a threshold, filtered by two moving averages. Positions are closed with tick-based take profit and stop loss or at 14:50.
Details
- Entry Criteria:
- Long: At 08:30 when the saved delta percent is below
-DeltaThresholdand the open price is above SMA15 and SMA30 with SMA15 above SMA30. - Short: At 08:30 when the saved delta percent is above
DeltaThresholdand the open price is below SMA15 and SMA30 with SMA15 below SMA30.
- Long: At 08:30 when the saved delta percent is below
- Long/Short: Both sides.
- Exit Criteria:
- Take profit and stop loss in ticks.
- Close all open positions at 14:50.
- Stops:
TpTicks= 20 ticks take profit.SlTicks= 10 ticks stop loss.
- Default Values:
DeltaThreshold= 2TpTicks= 20SlTicks= 10CandleType= TimeSpan.FromMinutes(1).TimeFrame().
- Filters:
- Category: Volume
- Direction: Both
- Indicators: SMA
- Stops: Yes
- Complexity: Intermediate
- Timeframe: Intraday
- Seasonality: No
- Neural networks: No
- Divergence: No
- Risk level: Medium
using System;
using Ecng.Common;
using StockSharp.Algo.Strategies;
using StockSharp.BusinessEntities;
using StockSharp.Messages;
namespace StockSharp.Samples.Strategies;
/// <summary>
/// Reverse strategy based on aggregated volume delta windows.
/// </summary>
public class MocDeltaMooEntryV2ReverseStrategy : Strategy
{
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<int> _deltaWindow;
private readonly StrategyParam<decimal> _deltaThresholdPercent;
private readonly StrategyParam<int> _signalCooldownBars;
private decimal _windowBuyVolume;
private decimal _windowSellVolume;
private int _windowBarCount;
private int _barsFromSignal;
/// <summary>
/// Candle timeframe.
/// </summary>
public DataType CandleType
{
get => _candleType.Value;
set => _candleType.Value = value;
}
/// <summary>
/// Number of bars per delta window.
/// </summary>
public int DeltaWindow
{
get => _deltaWindow.Value;
set => _deltaWindow.Value = value;
}
/// <summary>
/// Absolute delta percent needed to trigger a reversal.
/// </summary>
public decimal DeltaThresholdPercent
{
get => _deltaThresholdPercent.Value;
set => _deltaThresholdPercent.Value = value;
}
/// <summary>
/// Minimum bars between entries.
/// </summary>
public int SignalCooldownBars
{
get => _signalCooldownBars.Value;
set => _signalCooldownBars.Value = value;
}
public MocDeltaMooEntryV2ReverseStrategy()
{
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(15).TimeFrame())
.SetDisplay("Candle Type", "Candles timeframe", "General");
_deltaWindow = Param(nameof(DeltaWindow), 24)
.SetGreaterThanZero()
.SetDisplay("Delta Window", "Bars per delta calculation window", "General");
_deltaThresholdPercent = Param(nameof(DeltaThresholdPercent), 12m)
.SetGreaterThanZero()
.SetDisplay("Delta Threshold %", "Minimum delta percent for reversal", "General");
_signalCooldownBars = Param(nameof(SignalCooldownBars), 16)
.SetGreaterThanZero()
.SetDisplay("Signal Cooldown Bars", "Minimum bars between entries", "General");
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_windowBuyVolume = 0m;
_windowSellVolume = 0m;
_windowBarCount = 0;
_barsFromSignal = 0;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
StartProtection(null, null);
_windowBuyVolume = 0m;
_windowSellVolume = 0m;
_windowBarCount = 0;
_barsFromSignal = SignalCooldownBars;
var subscription = SubscribeCandles(CandleType);
subscription.Bind(ProcessCandle).Start();
}
private void ProcessCandle(ICandleMessage candle)
{
if (candle.State != CandleStates.Finished)
return;
if (!IsFormedAndOnlineAndAllowTrading())
return;
if (candle.ClosePrice > candle.OpenPrice)
_windowBuyVolume += candle.TotalVolume;
else if (candle.ClosePrice < candle.OpenPrice)
_windowSellVolume += candle.TotalVolume;
else
{
_windowBuyVolume += candle.TotalVolume * 0.5m;
_windowSellVolume += candle.TotalVolume * 0.5m;
}
_windowBarCount++;
_barsFromSignal++;
if (_windowBarCount < DeltaWindow)
return;
var totalVolume = _windowBuyVolume + _windowSellVolume;
var deltaPercent = totalVolume > 0m
? (_windowBuyVolume - _windowSellVolume) / totalVolume * 100m
: 0m;
var reverseSignal = 0;
if (deltaPercent > DeltaThresholdPercent)
reverseSignal = -1;
else if (deltaPercent < -DeltaThresholdPercent)
reverseSignal = 1;
if (_barsFromSignal >= SignalCooldownBars && reverseSignal != 0)
{
if (reverseSignal > 0 && Position <= 0)
{
var volume = Volume + Math.Abs(Position);
BuyMarket(volume);
_barsFromSignal = 0;
}
else if (reverseSignal < 0 && Position >= 0)
{
var volume = Volume + Math.Abs(Position);
SellMarket(volume);
_barsFromSignal = 0;
}
}
_windowBuyVolume = 0m;
_windowSellVolume = 0m;
_windowBarCount = 0;
}
}
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.Strategies import Strategy
class moc_delta_moo_entry_v2_reverse_strategy(Strategy):
def __init__(self):
super(moc_delta_moo_entry_v2_reverse_strategy, self).__init__()
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromMinutes(15))) \
.SetDisplay("Candle Type", "Candles timeframe", "General")
self._delta_window = self.Param("DeltaWindow", 24) \
.SetGreaterThanZero() \
.SetDisplay("Delta Window", "Bars per delta calculation window", "General")
self._delta_threshold_percent = self.Param("DeltaThresholdPercent", 12.0) \
.SetGreaterThanZero() \
.SetDisplay("Delta Threshold %", "Minimum delta percent for reversal", "General")
self._signal_cooldown_bars = self.Param("SignalCooldownBars", 16) \
.SetGreaterThanZero() \
.SetDisplay("Signal Cooldown Bars", "Minimum bars between entries", "General")
self._window_buy_volume = 0.0
self._window_sell_volume = 0.0
self._window_bar_count = 0
self._bars_from_signal = 0
@property
def candle_type(self):
return self._candle_type.Value
@candle_type.setter
def candle_type(self, value):
self._candle_type.Value = value
def OnReseted(self):
super(moc_delta_moo_entry_v2_reverse_strategy, self).OnReseted()
self._window_buy_volume = 0.0
self._window_sell_volume = 0.0
self._window_bar_count = 0
self._bars_from_signal = 0
def OnStarted2(self, time):
super(moc_delta_moo_entry_v2_reverse_strategy, self).OnStarted2(time)
self._window_buy_volume = 0.0
self._window_sell_volume = 0.0
self._window_bar_count = 0
self._bars_from_signal = self._signal_cooldown_bars.Value
subscription = self.SubscribeCandles(self.candle_type)
subscription.Bind(self.OnProcess).Start()
def OnProcess(self, candle):
if candle.State != CandleStates.Finished:
return
vol = float(candle.TotalVolume)
close = float(candle.ClosePrice)
opn = float(candle.OpenPrice)
if close > opn:
self._window_buy_volume += vol
elif close < opn:
self._window_sell_volume += vol
else:
self._window_buy_volume += vol * 0.5
self._window_sell_volume += vol * 0.5
self._window_bar_count += 1
self._bars_from_signal += 1
if self._window_bar_count < self._delta_window.Value:
return
total_volume = self._window_buy_volume + self._window_sell_volume
delta_percent = (self._window_buy_volume - self._window_sell_volume) / total_volume * 100.0 if total_volume > 0.0 else 0.0
reverse_signal = 0
thr = float(self._delta_threshold_percent.Value)
if delta_percent > thr:
reverse_signal = -1
elif delta_percent < -thr:
reverse_signal = 1
if self._bars_from_signal >= self._signal_cooldown_bars.Value and reverse_signal != 0:
if reverse_signal > 0 and self.Position <= 0:
self.BuyMarket()
self._bars_from_signal = 0
elif reverse_signal < 0 and self.Position >= 0:
self.SellMarket()
self._bars_from_signal = 0
self._window_buy_volume = 0.0
self._window_sell_volume = 0.0
self._window_bar_count = 0
def CreateClone(self):
return moc_delta_moo_entry_v2_reverse_strategy()