Orb Vwap Braid Filter 策略
使用 VWAP 和 Braid 过滤器确认的开盘突破策略。
规则
- 交易时间为 09:35 到 11:00
- 每天仅一次交易
- 当价格收于开盘区间高点之上且位于 VWAP 上方并且 Braid 过滤器看涨时做多
- 当价格收于开盘区间低点之下且位于 VWAP 下方并且 Braid 过滤器看跌时做空
- 止损位于区间另一侧
- 止盈为风险的两倍,受昨日或盘前水平限制
指标
- 加权平均价格 (VWAP)
- 指数移动平均线 (3, 7, 14)
- 平均真实波幅 (14)
using System;
using Ecng.Common;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.Messages;
namespace StockSharp.Samples.Strategies;
public class OrbVwapBraidFilterStrategy : Strategy
{
private readonly StrategyParam<DataType> _candleType;
private decimal _orHigh;
private decimal _orLow;
private bool _tradeTakenToday;
private bool _wasInOr;
private DateTime _currentDay;
private bool _orEstablished;
public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }
public OrbVwapBraidFilterStrategy()
{
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(5).TimeFrame());
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_orHigh = 0;
_orLow = 0;
_tradeTakenToday = false;
_wasInOr = false;
_currentDay = default;
_orEstablished = false;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_orHigh = 0;
_orLow = 0;
_tradeTakenToday = false;
_wasInOr = false;
_currentDay = default;
_orEstablished = false;
var ema1 = new ExponentialMovingAverage { Length = 3 };
var ema2 = new ExponentialMovingAverage { Length = 7 };
var ema3 = new ExponentialMovingAverage { Length = 14 };
var subscription = SubscribeCandles(CandleType);
subscription
.Bind(ema1, ema2, ema3, (candle, e1, e2, e3) =>
{
if (candle.State != CandleStates.Finished)
return;
if (!ema1.IsFormed || !ema2.IsFormed || !ema3.IsFormed)
return;
var day = candle.OpenTime.Date;
if (_currentDay != day)
{
_currentDay = day;
_orHigh = 0;
_orLow = 0;
_tradeTakenToday = false;
_orEstablished = false;
}
var hour = candle.OpenTime.TimeOfDay.TotalHours;
var inOr = hour < 1;
if (inOr)
{
_orHigh = _orHigh > 0 ? Math.Max(_orHigh, candle.HighPrice) : candle.HighPrice;
_orLow = _orLow > 0 ? Math.Min(_orLow, candle.LowPrice) : candle.LowPrice;
}
if (_wasInOr && !inOr && _orHigh > 0 && _orLow > 0 && _orHigh - _orLow > 0)
_orEstablished = true;
var bullBraid = e1 > e2 && e2 > e3;
var bearBraid = e1 < e2 && e2 < e3;
if (!_tradeTakenToday && _orEstablished && !inOr)
{
if (candle.ClosePrice > _orHigh && bullBraid && Position <= 0)
{
BuyMarket();
_tradeTakenToday = true;
}
else if (candle.ClosePrice < _orLow && bearBraid && Position >= 0)
{
SellMarket();
_tradeTakenToday = true;
}
}
_wasInOr = inOr;
})
.Start();
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, ema1);
DrawOwnTrades(area);
}
}
}
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 orb_vwap_braid_filter_strategy(Strategy):
def __init__(self):
super(orb_vwap_braid_filter_strategy, self).__init__()
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromMinutes(5)))
self._or_high = 0.0
self._or_low = 0.0
self._trade_taken_today = False
self._was_in_or = False
self._current_day = None
self._or_established = False
@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(orb_vwap_braid_filter_strategy, self).OnReseted()
self._or_high = 0.0
self._or_low = 0.0
self._trade_taken_today = False
self._was_in_or = False
self._current_day = None
self._or_established = False
def OnStarted2(self, time):
super(orb_vwap_braid_filter_strategy, self).OnStarted2(time)
self._or_high = 0.0
self._or_low = 0.0
self._trade_taken_today = False
self._was_in_or = False
self._current_day = None
self._or_established = False
self._ema1 = ExponentialMovingAverage()
self._ema1.Length = 3
self._ema2 = ExponentialMovingAverage()
self._ema2.Length = 7
self._ema3 = ExponentialMovingAverage()
self._ema3.Length = 14
subscription = self.SubscribeCandles(self.candle_type)
subscription.Bind(self._ema1, self._ema2, self._ema3, self.OnProcess).Start()
def OnProcess(self, candle, e1, e2, e3):
if candle.State != CandleStates.Finished:
return
if not self._ema1.IsFormed or not self._ema2.IsFormed or not self._ema3.IsFormed:
return
e1v = float(e1)
e2v = float(e2)
e3v = float(e3)
close = float(candle.ClosePrice)
high = float(candle.HighPrice)
low = float(candle.LowPrice)
day = candle.OpenTime.Date
if self._current_day is None or self._current_day != day:
self._current_day = day
self._or_high = 0.0
self._or_low = 0.0
self._trade_taken_today = False
self._or_established = False
hour = candle.OpenTime.TimeOfDay.TotalHours
in_or = hour < 1
if in_or:
self._or_high = max(self._or_high, high) if self._or_high > 0 else high
self._or_low = min(self._or_low, low) if self._or_low > 0 else low
if self._was_in_or and not in_or and self._or_high > 0 and self._or_low > 0 and self._or_high - self._or_low > 0:
self._or_established = True
bull_braid = e1v > e2v and e2v > e3v
bear_braid = e1v < e2v and e2v < e3v
if not self._trade_taken_today and self._or_established and not in_or:
if close > self._or_high and bull_braid and self.Position <= 0:
self.BuyMarket()
self._trade_taken_today = True
elif close < self._or_low and bear_braid and self.Position >= 0:
self.SellMarket()
self._trade_taken_today = True
self._was_in_or = in_or
def CreateClone(self):
return orb_vwap_braid_filter_strategy()