多时间框架 MACD
多时间框架 MACD 将当前时间框架和更高时间框架的 MACD 信号结合。只有当两个时间框架在均线交叉或零线穿越上达成一致时才入场。
详情
- 数据:两个时间框架的价格蜡烛。
- 入场条件:
- 做多:基于
Entry参数,默认是两个时间框架同时出现看涨交叉。 - 做空:与做多相反。
- 做多:基于
- 出场条件:反向信号或移动止损。
- 止损:可选的移动止损。
- 默认值:
FastLength= 12SlowLength= 26SignalLength= 9CandleType= tf(5)HigherCandleType= tf(1d)ShowCurrentTimeframe= trueShowHigherTimeframe= trueEntry= CrossoverUseTrailingStop= falseTrailingStopPercent= 2
- 过滤器:
- 类别:趋势
- 方向:多头和空头
- 指标:MACD
- 止损:是
- 复杂度:中等
- 时间框架:多时间框架 (5m/1d)
- 季节性:否
- 神经网络:否
- 背离:否
- 风险等级:中等
using System;
using System.Linq;
using System.Collections.Generic;
using Ecng.Common;
using Ecng.Collections;
using Ecng.Serialization;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.BusinessEntities;
using StockSharp.Messages;
namespace StockSharp.Samples.Strategies;
/// <summary>
/// MACD crossover strategy with EMA trend filter.
/// </summary>
public class MultiTimeframeMacdStrategy : Strategy
{
private readonly StrategyParam<int> _fastLength;
private readonly StrategyParam<int> _slowLength;
private readonly StrategyParam<int> _trendLength;
private readonly StrategyParam<DataType> _candleType;
public int FastLength { get => _fastLength.Value; set => _fastLength.Value = value; }
public int SlowLength { get => _slowLength.Value; set => _slowLength.Value = value; }
public int TrendLength { get => _trendLength.Value; set => _trendLength.Value = value; }
public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }
public MultiTimeframeMacdStrategy()
{
_fastLength = Param(nameof(FastLength), 12)
.SetGreaterThanZero()
.SetDisplay("Fast", "Fast EMA", "MACD");
_slowLength = Param(nameof(SlowLength), 26)
.SetGreaterThanZero()
.SetDisplay("Slow", "Slow EMA", "MACD");
_trendLength = Param(nameof(TrendLength), 50)
.SetGreaterThanZero()
.SetDisplay("Trend", "Trend EMA period", "Trend");
_candleType = Param(nameof(CandleType), TimeSpan.FromHours(1).TimeFrame())
.SetDisplay("Candle Type", "Type of candles", "General");
}
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
var fastEma = new ExponentialMovingAverage { Length = FastLength };
var slowEma = new ExponentialMovingAverage { Length = SlowLength };
var trendEma = new ExponentialMovingAverage { Length = TrendLength };
var prevFast = 0m;
var prevSlow = 0m;
var initialized = false;
var subscription = SubscribeCandles(CandleType);
subscription
.Bind(fastEma, slowEma, trendEma, (candle, fastVal, slowVal, trendVal) =>
{
if (candle.State != CandleStates.Finished)
return;
if (!fastEma.IsFormed || !slowEma.IsFormed || !trendEma.IsFormed)
return;
if (!initialized)
{
prevFast = fastVal;
prevSlow = slowVal;
initialized = true;
return;
}
var macd = fastVal - slowVal;
var prevMacd = prevFast - prevSlow;
// MACD crosses zero up + price above trend => buy
if (prevMacd <= 0 && macd > 0 && candle.ClosePrice > trendVal && Position <= 0)
BuyMarket();
// MACD crosses zero down + price below trend => sell
else if (prevMacd >= 0 && macd < 0 && candle.ClosePrice < trendVal && Position > 0)
SellMarket();
prevFast = fastVal;
prevSlow = slowVal;
})
.Start();
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, trendEma);
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 multi_timeframe_macd_strategy(Strategy):
def __init__(self):
super(multi_timeframe_macd_strategy, self).__init__()
self._fast_length = self.Param("FastLength", 12) \
.SetGreaterThanZero() \
.SetDisplay("Fast", "Fast EMA", "MACD")
self._slow_length = self.Param("SlowLength", 26) \
.SetGreaterThanZero() \
.SetDisplay("Slow", "Slow EMA", "MACD")
self._trend_length = self.Param("TrendLength", 50) \
.SetGreaterThanZero() \
.SetDisplay("Trend", "Trend EMA period", "Trend")
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromHours(1))) \
.SetDisplay("Candle Type", "Type of candles", "General")
self._prev_fast = 0.0
self._prev_slow = 0.0
self._initialized = 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(multi_timeframe_macd_strategy, self).OnReseted()
self._prev_fast = 0.0
self._prev_slow = 0.0
self._initialized = False
def OnStarted2(self, time):
super(multi_timeframe_macd_strategy, self).OnStarted2(time)
self._prev_fast = 0.0
self._prev_slow = 0.0
self._initialized = False
self._fast_ema = ExponentialMovingAverage()
self._fast_ema.Length = self._fast_length.Value
self._slow_ema = ExponentialMovingAverage()
self._slow_ema.Length = self._slow_length.Value
self._trend_ema = ExponentialMovingAverage()
self._trend_ema.Length = self._trend_length.Value
subscription = self.SubscribeCandles(self.candle_type)
subscription.Bind(self._fast_ema, self._slow_ema, self._trend_ema, self.OnProcess).Start()
def OnProcess(self, candle, fast_val, slow_val, trend_val):
if candle.State != CandleStates.Finished:
return
if not self._fast_ema.IsFormed or not self._slow_ema.IsFormed or not self._trend_ema.IsFormed:
return
fv = float(fast_val)
sv = float(slow_val)
tv = float(trend_val)
close = float(candle.ClosePrice)
if not self._initialized:
self._prev_fast = fv
self._prev_slow = sv
self._initialized = True
return
macd = fv - sv
prev_macd = self._prev_fast - self._prev_slow
if prev_macd <= 0.0 and macd > 0.0 and close > tv and self.Position <= 0:
self.BuyMarket()
elif prev_macd >= 0.0 and macd < 0.0 and close < tv and self.Position > 0:
self.SellMarket()
self._prev_fast = fv
self._prev_slow = sv
def CreateClone(self):
return multi_timeframe_macd_strategy()