策略仅在 K 线收盘后处理信号,从而模拟原 EA “仅在新柱上工作” 的行为。BuyMarket 和 SellMarket 会自动加上反向头寸的绝对值,实现仓位翻转。
由于高层 API 不直接托管止损/止盈,代码内部会根据收盘价模拟执行。若收盘价触发保护价位,策略会立即通过市价单平仓。
马丁格尔逻辑使用在上一次开仓后保存的余额,与当前余额做对比判断是加仓还是减仓。
当合约缺少有效的价格步长或乘数时,策略会使用默认值 0.0001 和 1 避免计算异常。
与原始 EA 的差异
原版 EA 使用实时的买卖价,本移植版使用 K 线的收盘价作为近似值,因为在高层 API 中无法获取逐笔报价。
风险计算基于组合权益与合约乘数,替代了 MQL 中的 CMoneyFixedMargin 工具类。
可选的图形输出仅绘制价格 K 线;默认情况下不会额外绘制指标。
TrailingStepPips 的合法性在策略启动时校验,并通过抛出异常阻止配置错误继续运行。
namespace StockSharp.Samples.Strategies;
using System;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.Messages;
/// <summary>
/// Martingale MA Breakout strategy (simplified).
/// Enters long when price crosses above EMA, enters short when below.
/// Uses simple position flipping with market orders.
/// </summary>
public class MartingaleMaBreakoutStrategy : Strategy
{
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<int> _maPeriod;
private readonly StrategyParam<int> _atrPeriod;
public DataType CandleType
{
get => _candleType.Value;
set => _candleType.Value = value;
}
public int MaPeriod
{
get => _maPeriod.Value;
set => _maPeriod.Value = value;
}
public int AtrPeriod
{
get => _atrPeriod.Value;
set => _atrPeriod.Value = value;
}
public MartingaleMaBreakoutStrategy()
{
_candleType = Param(nameof(CandleType), TimeSpan.FromHours(4).TimeFrame())
.SetDisplay("Candle Type", "Source candles", "General");
_maPeriod = Param(nameof(MaPeriod), 12)
.SetGreaterThanZero()
.SetDisplay("MA Period", "Moving average period", "Indicators");
_atrPeriod = Param(nameof(AtrPeriod), 14)
.SetGreaterThanZero()
.SetDisplay("ATR Period", "ATR period for volatility filter", "Indicators");
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
var ema = new ExponentialMovingAverage { Length = MaPeriod };
var atr = new AverageTrueRange { Length = AtrPeriod };
var subscription = SubscribeCandles(CandleType);
subscription
.Bind(ema, atr, (ICandleMessage candle, decimal emaValue, decimal atrValue) =>
{
if (candle.State != CandleStates.Finished)
return;
if (!IsFormedAndOnlineAndAllowTrading())
return;
var distance = Math.Abs(candle.ClosePrice - emaValue);
// Buy when price breaks above MA by at least half ATR
if (candle.ClosePrice > emaValue && distance > atrValue && Position <= 0)
{
BuyMarket();
}
// Sell when price breaks below MA by at least half ATR
else if (candle.ClosePrice < emaValue && distance > atrValue && Position >= 0)
{
SellMarket();
}
})
.Start();
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, ema);
DrawIndicator(area, atr);
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, AverageTrueRange
from StockSharp.Algo.Strategies import Strategy
class martingale_ma_breakout_strategy(Strategy):
def __init__(self):
super(martingale_ma_breakout_strategy, self).__init__()
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromHours(4))) \
.SetDisplay("Candle Type", "Source candles", "General")
self._ma_period = self.Param("MaPeriod", 12) \
.SetDisplay("MA Period", "Moving average period", "Indicators")
self._atr_period = self.Param("AtrPeriod", 14) \
.SetDisplay("ATR Period", "ATR period for volatility filter", "Indicators")
@property
def CandleType(self):
return self._candle_type.Value
@property
def MaPeriod(self):
return self._ma_period.Value
@property
def AtrPeriod(self):
return self._atr_period.Value
def OnStarted2(self, time):
super(martingale_ma_breakout_strategy, self).OnStarted2(time)
ema = ExponentialMovingAverage()
ema.Length = self.MaPeriod
atr = AverageTrueRange()
atr.Length = self.AtrPeriod
subscription = self.SubscribeCandles(self.CandleType)
subscription \
.Bind(ema, atr, self._on_process) \
.Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawIndicator(area, ema)
self.DrawIndicator(area, atr)
self.DrawOwnTrades(area)
def _on_process(self, candle, ema_value, atr_value):
if candle.State != CandleStates.Finished:
return
close = float(candle.ClosePrice)
ev = float(ema_value)
av = float(atr_value)
distance = abs(close - ev)
if close > ev and distance > av and self.Position <= 0:
self.BuyMarket()
elif close < ev and distance > av and self.Position >= 0:
self.SellMarket()
def CreateClone(self):
return martingale_ma_breakout_strategy()