F2a AO 策略
该策略复现了 MetaTrader 顾问 "F2a_AO"。它使用短期 SMA 对 Awesome Oscillator 进行滤波,并且只在高一级时间框架的参考K线方向上开仓。
振荡器在独立的时间框架上计算。当参考K线收盘价高于开盘价且滤波后的 AO > 0 时,策略开多并平掉所有空头。当参考K线收盘价低于开盘价且滤波后的 AO < 0 时,策略开空并平掉所有多头。
细节
- 入场条件:
- 多头:参考K线为阳线且滤波 AO > 0。
- 空头:参考K线为阴线且滤波 AO < 0。
- 方向:双向。
- 出场条件:
- 滤波 AO < 0 平多。
- 滤波 AO > 0 平空。
- 止损:无显式止损或止盈,启用保护模块。
- 默认值:
IndicatorTimeFrame= 12 小时。TrendTimeFrame= 1 天。FastPeriod= 13。SlowPeriod= 144。FilterLength= 3。
- 筛选器:
- 分类:趋势跟随
- 方向:双向
- 指标:Awesome Oscillator、SMA
- 止损:无
- 复杂度:基础
- 时间框架:中期
- 季节性:无
- 神经网络:无
- 背离:无
- 风险级别:中
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;
/// <summary>
/// Uses Awesome Oscillator filtered by SMA to follow trend direction.
/// Buys when filtered AO crosses above zero, sells when it crosses below zero.
/// </summary>
public class F2aAoStrategy : Strategy
{
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<int> _fastPeriod;
private readonly StrategyParam<int> _slowPeriod;
private readonly StrategyParam<int> _filterLength;
private decimal _previousAo = decimal.MinValue;
private decimal _previousFilteredAo = decimal.MinValue;
private int _barsSinceTrade;
public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }
public int FastPeriod { get => _fastPeriod.Value; set => _fastPeriod.Value = value; }
public int SlowPeriod { get => _slowPeriod.Value; set => _slowPeriod.Value = value; }
public int FilterLength { get => _filterLength.Value; set => _filterLength.Value = value; }
public F2aAoStrategy()
{
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(5).TimeFrame())
.SetDisplay("Candle Type", "Candle timeframe", "General");
_fastPeriod = Param(nameof(FastPeriod), 5)
.SetDisplay("AO Fast", "Fast period for Awesome Oscillator", "Awesome Oscillator");
_slowPeriod = Param(nameof(SlowPeriod), 34)
.SetDisplay("AO Slow", "Slow period for Awesome Oscillator", "Awesome Oscillator");
_filterLength = Param(nameof(FilterLength), 3)
.SetDisplay("Filter", "SMA length for AO filter", "Awesome Oscillator");
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_previousAo = decimal.MinValue;
_previousFilteredAo = decimal.MinValue;
_barsSinceTrade = 20;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_previousAo = decimal.MinValue;
_previousFilteredAo = decimal.MinValue;
_barsSinceTrade = 20;
var ao = new AwesomeOscillator();
ao.ShortMa.Length = FastPeriod;
ao.LongMa.Length = SlowPeriod;
var filter = new SimpleMovingAverage { Length = FilterLength };
var subscription = SubscribeCandles(CandleType);
subscription
.Bind(ao, filter, ProcessCandle)
.Start();
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, ao);
DrawOwnTrades(area);
}
}
private void ProcessCandle(ICandleMessage candle, decimal aoValue, decimal filteredAo)
{
if (candle.State != CandleStates.Finished)
return;
_barsSinceTrade++;
if (_previousAo == decimal.MinValue)
{
_previousAo = aoValue;
_previousFilteredAo = filteredAo;
return;
}
var crossedUp = _previousAo <= 0m && aoValue > 0m;
var crossedDown = _previousAo >= 0m && aoValue < 0m;
if (_barsSinceTrade >= 10 && filteredAo > _previousFilteredAo && crossedUp && Position <= 0)
{
BuyMarket();
_barsSinceTrade = 0;
}
else if (_barsSinceTrade >= 10 && filteredAo < _previousFilteredAo && crossedDown && Position >= 0)
{
SellMarket();
_barsSinceTrade = 0;
}
_previousAo = aoValue;
_previousFilteredAo = filteredAo;
}
}
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 AwesomeOscillator, SimpleMovingAverage
from StockSharp.Algo.Strategies import Strategy
class f2a_ao_strategy(Strategy):
def __init__(self):
super(f2a_ao_strategy, self).__init__()
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromMinutes(5))) \
.SetDisplay("Candle Type", "Candle timeframe", "General")
self._fast_period = self.Param("FastPeriod", 5) \
.SetDisplay("AO Fast", "Fast period for Awesome Oscillator", "Awesome Oscillator")
self._slow_period = self.Param("SlowPeriod", 34) \
.SetDisplay("AO Slow", "Slow period for Awesome Oscillator", "Awesome Oscillator")
self._filter_length = self.Param("FilterLength", 3) \
.SetDisplay("Filter", "SMA length for AO filter", "Awesome Oscillator")
self._previous_ao = None
self._previous_filtered_ao = None
self._bars_since_trade = 20
@property
def candle_type(self):
return self._candle_type.Value
@property
def fast_period(self):
return self._fast_period.Value
@property
def slow_period(self):
return self._slow_period.Value
@property
def filter_length(self):
return self._filter_length.Value
def OnReseted(self):
super(f2a_ao_strategy, self).OnReseted()
self._previous_ao = None
self._previous_filtered_ao = None
self._bars_since_trade = 20
def OnStarted2(self, time):
super(f2a_ao_strategy, self).OnStarted2(time)
self._previous_ao = None
self._previous_filtered_ao = None
self._bars_since_trade = 20
ao = AwesomeOscillator()
ao.ShortMa.Length = int(self.fast_period)
ao.LongMa.Length = int(self.slow_period)
filt = SimpleMovingAverage()
filt.Length = int(self.filter_length)
subscription = self.SubscribeCandles(self.candle_type)
subscription.Bind(ao, filt, self.process_candle).Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawIndicator(area, ao)
self.DrawOwnTrades(area)
def process_candle(self, candle, ao_value, filtered_ao):
if candle.State != CandleStates.Finished:
return
ao_value = float(ao_value)
filtered_ao = float(filtered_ao)
self._bars_since_trade += 1
if self._previous_ao is None:
self._previous_ao = ao_value
self._previous_filtered_ao = filtered_ao
return
crossed_up = self._previous_ao <= 0 and ao_value > 0
crossed_down = self._previous_ao >= 0 and ao_value < 0
if self._bars_since_trade >= 10 and filtered_ao > self._previous_filtered_ao and crossed_up and self.Position <= 0:
self.BuyMarket()
self._bars_since_trade = 0
elif self._bars_since_trade >= 10 and filtered_ao < self._previous_filtered_ao and crossed_down and self.Position >= 0:
self.SellMarket()
self._bars_since_trade = 0
self._previous_ao = ao_value
self._previous_filtered_ao = filtered_ao
def CreateClone(self):
return f2a_ao_strategy()