在 GitHub 上查看
TemplateEAbyMarket 策略
概览
TemplateEAbyMarket 是 MetaTrader 4 智能交易程序 TemplateEAbyMarket.mq4 在 StockSharp 平台上的直接移植版本。策略依靠 MACD 指标捕捉动量变化:当 MACD 主线与信号线发生交叉,并且两条线同时位于零轴同一侧时,就按照交叉方向提交市价单。离场完全交由保护模块处理,通过 StartProtection 一次性设置的止盈止损来控制风险。
该移植版本保持了原始 MQL 代码的行为:策略只负责开仓,并不会主动反向平仓。仓位建立后,由保护单或人工操作负责后续管理。
交易逻辑
- 订阅用户选择的蜡烛类型(默认 15 分钟)。
- 在每根收盘蜡烛上计算 MACD,默认参数为 12/26/9。
- 监控 MACD 主线与信号线的相对位置以判定交叉:
- 做多条件: 上一根蜡烛主线位于信号线之下,本根蜡烛收盘后主线位于信号线之上,且两条线均大于零。若当前持仓绝对值小于
MaxOrders * OrderVolume,则提交 OrderVolume 的买入市价单。
- 做空条件: 上一根蜡烛主线位于信号线之上,本根蜡烛收盘后主线位于信号线之下,且两条线均小于零。在同样的仓位限制下提交卖出市价单。
- 启动时激活一次止盈(
takeProfit)与止损(stopLoss)。策略不会自动反手,风控由保护模块或人工完成。
参数
| 名称 |
说明 |
MacdFastPeriod |
MACD 快速 EMA 的周期。 |
MacdSlowPeriod |
MACD 慢速 EMA 的周期。 |
MacdSignalPeriod |
MACD 信号线 EMA 的周期。 |
CandleType |
用于计算指标的蜡烛类型(时间框架)。 |
OrderVolume |
每次下单的数量(手数或合约数)。 |
MaxOrders |
允许的最大同时持仓量,以 OrderVolume 的倍数表示。下单前会检查 abs(Position) < MaxOrders * OrderVolume。 |
TakeProfitPoints |
止盈距离(价格点)。取值为 0 时禁用止盈。 |
StopLossPoints |
止损距离(价格点)。取值为 0 时禁用止损。 |
说明
- MQL 版本中的滑点与 magic number 设置未被移植,因为在 StockSharp 中由其他机制处理。
- 请确保连接器提供正确的最小变动价位信息,
StartProtection 会以该单位解释止盈止损距离。
- 策略保持模板化设计,不处理部分成交,也不会在
MaxOrders 限制之外进行加仓。
namespace StockSharp.Samples.Strategies;
using System;
using Ecng.Common;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.Messages;
/// <summary>
/// Template EA by Market strategy: MACD histogram crossover with signal line.
/// </summary>
public class TemplateEAbyMarketStrategy : Strategy
{
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<int> _fastPeriod;
private readonly StrategyParam<int> _slowPeriod;
private readonly StrategyParam<int> _signalPeriod;
private decimal _prevMacd;
private decimal _prevSignal;
private bool _hasPrev;
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 SignalPeriod { get => _signalPeriod.Value; set => _signalPeriod.Value = value; }
public TemplateEAbyMarketStrategy()
{
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(30).TimeFrame())
.SetDisplay("Candle Type", "Candle timeframe", "General");
_fastPeriod = Param(nameof(FastPeriod), 12)
.SetGreaterThanZero()
.SetDisplay("Fast Period", "MACD fast EMA", "Indicators");
_slowPeriod = Param(nameof(SlowPeriod), 26)
.SetGreaterThanZero()
.SetDisplay("Slow Period", "MACD slow EMA", "Indicators");
_signalPeriod = Param(nameof(SignalPeriod), 9)
.SetGreaterThanZero()
.SetDisplay("Signal Period", "MACD signal period", "Indicators");
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_prevMacd = 0m;
_prevSignal = 0m;
_hasPrev = false;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_hasPrev = false;
var macd = new MovingAverageConvergenceDivergenceSignal
{
Macd = { ShortMa = { Length = FastPeriod }, LongMa = { Length = SlowPeriod } },
SignalMa = { Length = SignalPeriod }
};
var subscription = SubscribeCandles(CandleType);
subscription.BindEx(macd, ProcessCandle).Start();
}
private void ProcessCandle(ICandleMessage candle, IIndicatorValue macdValue)
{
if (candle.State != CandleStates.Finished) return;
if (!macdValue.IsFinal) return;
var v = (MovingAverageConvergenceDivergenceSignalValue)macdValue;
if (v.Macd is not decimal macdLine || v.Signal is not decimal signal) return;
if (_hasPrev)
{
var prevHist = _prevMacd - _prevSignal;
var currHist = macdLine - signal;
if (prevHist <= 0 && currHist > 0 && Position <= 0)
BuyMarket();
else if (prevHist >= 0 && currHist < 0 && Position >= 0)
SellMarket();
}
_prevMacd = macdLine;
_prevSignal = signal;
_hasPrev = true;
}
}
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 MovingAverageConvergenceDivergenceSignal
from StockSharp.Algo.Strategies import Strategy
class template_e_aby_market_strategy(Strategy):
def __init__(self):
super(template_e_aby_market_strategy, self).__init__()
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromMinutes(30)))
self._fast_period = self.Param("FastPeriod", 12)
self._slow_period = self.Param("SlowPeriod", 26)
self._signal_period = self.Param("SignalPeriod", 9)
self._prev_macd = 0.0
self._prev_signal = 0.0
self._has_prev = False
@property
def CandleType(self):
return self._candle_type.Value
@CandleType.setter
def CandleType(self, value):
self._candle_type.Value = value
@property
def FastPeriod(self):
return self._fast_period.Value
@FastPeriod.setter
def FastPeriod(self, value):
self._fast_period.Value = value
@property
def SlowPeriod(self):
return self._slow_period.Value
@SlowPeriod.setter
def SlowPeriod(self, value):
self._slow_period.Value = value
@property
def SignalPeriod(self):
return self._signal_period.Value
@SignalPeriod.setter
def SignalPeriod(self, value):
self._signal_period.Value = value
def OnReseted(self):
super(template_e_aby_market_strategy, self).OnReseted()
self._prev_macd = 0.0
self._prev_signal = 0.0
self._has_prev = False
def OnStarted2(self, time):
super(template_e_aby_market_strategy, self).OnStarted2(time)
self._has_prev = False
macd = MovingAverageConvergenceDivergenceSignal()
macd.Macd.ShortMa.Length = self.FastPeriod
macd.Macd.LongMa.Length = self.SlowPeriod
macd.SignalMa.Length = self.SignalPeriod
subscription = self.SubscribeCandles(self.CandleType)
subscription.BindEx(macd, self._process_candle).Start()
def _process_candle(self, candle, macd_value):
if candle.State != CandleStates.Finished:
return
if not macd_value.IsFinal:
return
macd_line = macd_value.Macd
signal = macd_value.Signal
if macd_line is None or signal is None:
return
macd_line = float(macd_line)
signal = float(signal)
if self._has_prev:
prev_hist = self._prev_macd - self._prev_signal
curr_hist = macd_line - signal
if prev_hist <= 0 and curr_hist > 0 and self.Position <= 0:
self.BuyMarket()
elif prev_hist >= 0 and curr_hist < 0 and self.Position >= 0:
self.SellMarket()
self._prev_macd = macd_line
self._prev_signal = signal
self._has_prev = True
def CreateClone(self):
return template_e_aby_market_strategy()