GitHub で見る
輪ゴムグリッド戦略
概要
- MetaTrader 4 Expert Advisor RUBBERBANDS_2.mq4 の変換。
- ローソク足の代わりに最高買値/最高売値を使用して、現在の価格を中心に対称グリッドを実行します。
- 動作がヘッジされた MT4 実装と一致するように、長期エクスポージャーと短期エクスポージャーに対して個別の台帳を保持します。
- セッションレベルの損益管理と、元の入力と同じ手動の静止/停止モードを実装します。
取引ロジック
- この戦略は
SubscribeLevel1() をサブスクライブし、最良入札と最良売値のあらゆる変更に反応します。
- 2 つの変動極値 (
_upperExtreme / _lowerExtreme) は、最後のリセット以降に到達した最高売値と最低売値をキャプチャします。 UseInitialValues が true の場合はパラメータから初期化され、それ以外の場合は最初に受け取った売値が使用されます。
- オープンな取引がなく、サーバー時間が 1 分の最初のティック (秒がゼロに等しい) に達すると、ストラテジーは市場での買いと市場での売りの両方を要求します。これは、ブックが空のときに売買フラグが 1 分ごとに設定される MT4 の動作を反映しています。
- 売値が保存された高値を
GridStepPoints ポイント上回るたびに、新しい売り注文が発行されます。保存された安値を同じ距離だけ下回るたびに、新しい買い注文がトリガーされます。トリガーごとに極値が現在のアスクに更新されるため、ラダーは価格に応じて「伸縮」します。
- 同時にオープンする取引の総数 (ロングレッグとショートレッグの合計) は、
MaxTrades によって制限されます。
- 変動利益は現在のビッド/アスクから計算されます。ロング利益はビッドから平均ロング価格を引いたものを使用し、ショート利益は平均ショート価格からアスクを引いたものを使用します。ヘルパー
PriceToMoney は、利用可能な場合、PriceStep/StepPrice を使用して、価格差をアカウント通貨に変換します。
- 変動利益が
SessionTakeProfitPerLot * OrderVolume に達し、UseSessionTakeProfit が有効になると、すべてのエクスポージャが平坦化されます。同様に、UseSessionStopLoss が有効な場合、-SessionStopLossPerLot * OrderVolume を下回る変動損失は完全な決済をトリガーします。
- 手動フラグは、元の EA オプションを再現します。
CloseNow はフラット スタートを強制し、QuiesceMode はフラットの間戦略をアイドル状態に保ち、StopNow は既存のポジションを妨げずに新しいエントリーを停止します。
パラメーター
| パラメータ |
説明 |
OrderVolume |
すべての成行注文の出来高 (MT4 Lots)。 |
MaxTrades |
同時にオープンする取引の最大数 (MT4 maxcount)。 |
GridStepPoints |
グリッド レイヤー間の価格ポイントの距離 (MT4 pipstep)。 |
QuiesceMode |
有効にすると、戦略はフラットに 1 回待機します。これは quiescenow と同じです。 |
TriggerImmediateEntries |
戦略の準備が整い次第、最初の売買を開始します (donow)。 |
StopNow |
現在のポジションを維持したまま自動エントリーを一時停止します (stopnow)。 |
CloseNow |
開始時に即時フラット化をリクエストします (closenow)。 |
UseSessionTakeProfit & SessionTakeProfitPerLot |
ロットごとのセッションレベルの変動利益目標。 |
UseSessionStopLoss & SessionStopLossPerLot |
ロットごとのセッションレベルの変動損失しきい値。 |
UseInitialValues, InitialMax, InitialMin |
以前の極端な値 (useinvalues、inmax、inmin) を再利用するオプションの再起動サポート。 |
実装メモ
- プロジェクトのガイドラインに従って、すべての内部状態はタブでインデントされ、コレクションではなくフィールドに保存されます。
- 成行注文は
_activeBuyOrder と _activeSellOrder を追跡することによって抑制されるため、前のリクエストが保留されている間に重複したリクエストが送信されることはありません。
- ヘッジ会計は
OnOwnTradeReceived で実行され、ロングおよびショートの平均価格/出来高が個別に更新され、ストップ ロジックの変動利益に変換されます。
TryCloseAll() は、MT4 close1by1() ルーチンを反映しており、両方の元帳がフラットになるまで反対の成行注文を送信し、その後、極値を最新のアスクにリセットします。
- この戦略は、高レベルの API 呼び出し (
SubscribeLevel1()、BuyMarket、SellMarket) のみに依存し、リポジトリ ルールで要求されている直接のインジケーター アクセスを回避します。
using System;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.BusinessEntities;
using StockSharp.Messages;
namespace StockSharp.Samples.Strategies;
/// <summary>
/// Rubber Bands Grid: Mean reversion grid using SMA+ATR bands.
/// </summary>
public class RubberBandsGridStrategy : Strategy
{
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<int> _smaLength;
private readonly StrategyParam<int> _atrLength;
private decimal _entryPrice;
private int _gridCount;
public RubberBandsGridStrategy()
{
_candleType = Param(nameof(CandleType), TimeSpan.FromHours(4).TimeFrame())
.SetDisplay("Candle Type", "Timeframe.", "General");
_smaLength = Param(nameof(SmaLength), 20)
.SetDisplay("SMA Length", "SMA 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 SmaLength
{
get => _smaLength.Value;
set => _smaLength.Value = value;
}
public int AtrLength
{
get => _atrLength.Value;
set => _atrLength.Value = value;
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_entryPrice = 0;
_gridCount = 0;
}
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_entryPrice = 0;
_gridCount = 0;
var sma = new SimpleMovingAverage { Length = SmaLength };
var atr = new AverageTrueRange { Length = AtrLength };
var subscription = SubscribeCandles(CandleType);
subscription
.Bind(sma, atr, ProcessCandle)
.Start();
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, sma);
DrawOwnTrades(area);
}
}
private void ProcessCandle(ICandleMessage candle, decimal smaVal, decimal atrVal)
{
if (candle.State != CandleStates.Finished)
return;
if (atrVal <= 0)
return;
var close = candle.ClosePrice;
var lower = smaVal - atrVal * 2m;
var upper = smaVal + atrVal * 2m;
if (Position > 0)
{
if (close >= smaVal)
{
SellMarket();
_entryPrice = 0;
_gridCount = 0;
}
else if (close <= _entryPrice - atrVal * 4m)
{
SellMarket();
_entryPrice = 0;
_gridCount = 0;
}
else if (_gridCount < 3 && close <= _entryPrice - atrVal)
{
_entryPrice = (_entryPrice + close) / 2m;
_gridCount++;
BuyMarket();
}
}
else if (Position < 0)
{
if (close <= smaVal)
{
BuyMarket();
_entryPrice = 0;
_gridCount = 0;
}
else if (close >= _entryPrice + atrVal * 4m)
{
BuyMarket();
_entryPrice = 0;
_gridCount = 0;
}
else if (_gridCount < 3 && close >= _entryPrice + atrVal)
{
_entryPrice = (_entryPrice + close) / 2m;
_gridCount++;
SellMarket();
}
}
if (Position == 0)
{
if (close <= lower)
{
_entryPrice = close;
_gridCount = 0;
BuyMarket();
}
else if (close >= upper)
{
_entryPrice = close;
_gridCount = 0;
SellMarket();
}
}
}
}
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 SimpleMovingAverage, AverageTrueRange
from StockSharp.Algo.Strategies import Strategy
class rubber_bands_grid_strategy(Strategy):
def __init__(self):
super(rubber_bands_grid_strategy, self).__init__()
self._sma_length = self.Param("SmaLength", 20).SetDisplay("SMA Length", "SMA period", "Indicators")
self._atr_length = self.Param("AtrLength", 14).SetDisplay("ATR Length", "ATR period", "Indicators")
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromHours(4))).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(rubber_bands_grid_strategy, self).OnReseted()
self._entry_price = 0
self._grid_count = 0
def OnStarted2(self, time):
super(rubber_bands_grid_strategy, self).OnStarted2(time)
self._entry_price = 0
self._grid_count = 0
sma = SimpleMovingAverage()
sma.Length = self._sma_length.Value
atr = AverageTrueRange()
atr.Length = self._atr_length.Value
sub = self.SubscribeCandles(self.CandleType)
sub.Bind(sma, atr, self.OnProcess).Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, sub)
self.DrawIndicator(area, sma)
self.DrawOwnTrades(area)
def OnProcess(self, candle, sma_val, atr_val):
if candle.State != CandleStates.Finished:
return
if atr_val <= 0:
return
close = float(candle.ClosePrice)
lower = sma_val - atr_val * 2.0
upper = sma_val + atr_val * 2.0
if self.Position > 0:
if close >= sma_val:
self.SellMarket()
self._entry_price = 0
self._grid_count = 0
elif close <= self._entry_price - atr_val * 4.0:
self.SellMarket()
self._entry_price = 0
self._grid_count = 0
elif self._grid_count < 3 and close <= self._entry_price - atr_val:
self._entry_price = (self._entry_price + close) / 2.0
self._grid_count += 1
self.BuyMarket()
elif self.Position < 0:
if close <= sma_val:
self.BuyMarket()
self._entry_price = 0
self._grid_count = 0
elif close >= self._entry_price + atr_val * 4.0:
self.BuyMarket()
self._entry_price = 0
self._grid_count = 0
elif self._grid_count < 3 and close >= self._entry_price + atr_val:
self._entry_price = (self._entry_price + close) / 2.0
self._grid_count += 1
self.SellMarket()
if self.Position == 0:
if close <= lower:
self._entry_price = close
self._grid_count = 0
self.BuyMarket()
elif close >= upper:
self._entry_price = close
self._grid_count = 0
self.SellMarket()
def CreateClone(self):
return rubber_bands_grid_strategy()