Die Trend Line-Strategie repliziert die Kerntrade-Management-Logik des ursprünglichen MetaTrader-Experten durch Kombination eines schnellen und langsamen linear gewichteten gleitenden Durchschnitts, eines Momentum-Filters und einer MACD-Bestätigung. Die Konvertierung konzentriert sich auf High-Level-StockSharp-Komponenten und behält den gleichen systematischen Ansatz bei, der auf Momentum-Ausbrüche in Trendrichtung wartet, bevor er einsteigt. Schutzstops, Gewinnziele und ein optionaler Trailing Stop in Preisschritten bieten ein ähnliches Risikomanagement wie der Quell-Experte.
Handelslogik
Abonnement der konfigurierten Kerzenserie und Berechnung folgender Indikatoren:
Schneller linear gewichteter gleitender Durchschnitt (LWMA) mit dem konfigurierbaren FastMaPeriod.
Langsame LWMA mit dem konfigurierbaren SlowMaPeriod.
Momentum-Indikator mit Periode MomentumPeriod. Die jüngsten drei Momentum-Werte werden verfolgt, um die Multi-Bar-Momentum-Prüfung der MQL-Version zu emulieren.
MACD-Indikator (Moving Average Convergence Divergence) mit Standard-Schnell-/Langsam-/Signal-Längen. Die Strategie speichert die MACD- und Signalwerte für die spätere Verwendung.
Long einsteigen wenn:
Die schnelle LWMA über der langsamen LWMA liegt.
Mindestens einer der letzten drei Momentum-Werte größer oder gleich MomentumBuyThreshold ist.
Die MACD-Hauptlinie über der MACD-Signallinie liegt.
Keine offene Short-Position existiert (Short-Exposition wird geflacht, bevor eine Long-Position eröffnet wird).
Short einsteigen wenn:
Die schnelle LWMA unter der langsamen LWMA liegt.
Mindestens einer der letzten drei Momentum-Werte kleiner oder gleich MomentumSellThreshold ist (Schwellenwert sollte negativ sein, um Abwärtsbeschleunigung zu erkennen).
Die MACD-Hauptlinie unter der MACD-Signallinie liegt.
Keine offene Long-Position existiert (Long-Exposition wird geflacht, bevor eine Short-Position eröffnet wird).
Nach jedem Einstieg platziert die Strategie Schutz-Stop-Loss- und Take-Profit-Orders nach Distanz in Preisschritten. Beide Orders werden neu berechnet, wenn sich die Position ändert.
Ein Trailing Stop kann mit TrailingStopSteps und TrailingTriggerSteps aktiviert werden. Sobald die offene Position mindestens die Auslösedistanz gewinnt, wird der Stop-Loss auf TrailingStopSteps vom aktuellen Schlusskurs der verarbeiteten Kerze verschoben.
Parameter
CandleType – Datentyp für die Kerzenserie für jeden Indikator (Standard 1-Stunden-Zeitrahmen).
FastMaPeriod – Periode der schnellen LWMA (Standard 6).
SlowMaPeriod – Periode der langsamen LWMA (Standard 85).
MomentumPeriod – Kerzenanzahl für die Momentum-Berechnung (Standard 14).
MomentumBuyThreshold – Minimales positives Momentum für neue Long-Positionen (Standard 0.3).
MomentumSellThreshold – Maximales (negatives) Momentum vor dem Öffnen neuer Short-Positionen (Standard -0.3).
MacdFastLength – Schnelle EMA-Länge des MACD (Standard 12).
MacdSlowLength – Langsame EMA-Länge des MACD (Standard 26).
MacdSignalLength – Signal-EMA-Länge des MACD (Standard 9).
StopLossSteps – Schutz-Stop-Abstand in Instrumentenschritten (Standard 20).
TakeProfitSteps – Schutz-Gewinnziel-Abstand in Schritten (Standard 50).
TrailingStopSteps – Trailing-Stop-Abstand in Schritten (Standard 40, deaktiviert bei null).
TrailingTriggerSteps – Gewinn in Schritten vor Aktivierung des Trailing Stops (Standard 40).
Hinweise
Indikator-Bindungen basieren nur auf abgeschlossenen Kerzen; unfertige Daten werden ignoriert, um verfrühte Signale zu vermeiden.
SetStopLoss und SetTakeProfit arbeiten mit Abständen in Preisschritten, was das Verhalten auf Instrumenten mit unterschiedlichen Tick-Größen konsistent hält.
Wenn MomentumSellThreshold positiv gehalten wird, erwartet der Standardvergleich (<= threshold), dass dieser Wert negativ ist. Passen Sie das Vorzeichen bei der Optimierung der Strategie an.
Der Trailing Stop arbeitet im End-of-Bar-Modus, da er bei Verarbeitung jeder abgeschlossenen Kerze aktualisiert wird, was das Originalskript widerspiegelt.
Die Konvertierung lässt bewusst manuelles Trendlinien-Zeichnen und eigenkapitalbasierte Liquidierungsregeln aus, da diese auf interaktiven Terminal-Funktionen basierten, die in StockSharp nicht verfügbar sind. Alle anderen Kernein- und Risikoregeln bleiben erhalten.
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;
public class TrendLineStrategy : Strategy
{
private readonly StrategyParam<int> _fastPeriod;
private readonly StrategyParam<int> _slowPeriod;
private readonly StrategyParam<int> _stopLossPoints;
private readonly StrategyParam<int> _takeProfitPoints;
private ExponentialMovingAverage _fast;
private ExponentialMovingAverage _slow;
private decimal _prevFast;
private decimal _prevSlow;
private decimal _entryPrice;
private int _cooldown;
public int FastPeriod { get => _fastPeriod.Value; set => _fastPeriod.Value = value; }
public int SlowPeriod { get => _slowPeriod.Value; set => _slowPeriod.Value = value; }
public int StopLossPoints { get => _stopLossPoints.Value; set => _stopLossPoints.Value = value; }
public int TakeProfitPoints { get => _takeProfitPoints.Value; set => _takeProfitPoints.Value = value; }
public TrendLineStrategy()
{
_fastPeriod = Param(nameof(FastPeriod), 14).SetGreaterThanZero().SetDisplay("Fast Period", "Fast EMA period", "Indicator");
_slowPeriod = Param(nameof(SlowPeriod), 50).SetGreaterThanZero().SetDisplay("Slow Period", "Slow EMA period", "Indicator");
_stopLossPoints = Param(nameof(StopLossPoints), 200).SetNotNegative().SetDisplay("Stop Loss", "Stop-loss in price steps", "Risk");
_takeProfitPoints = Param(nameof(TakeProfitPoints), 400).SetNotNegative().SetDisplay("Take Profit", "Take-profit in price steps", "Risk");
}
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
{
yield return (Security, TimeSpan.FromMinutes(5).TimeFrame());
}
protected override void OnReseted()
{
base.OnReseted();
_fast = null; _slow = null;
_prevFast = 0; _prevSlow = 0; _entryPrice = 0; _cooldown = 0;
}
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_fast = new ExponentialMovingAverage { Length = FastPeriod };
_slow = new ExponentialMovingAverage { Length = SlowPeriod };
var subscription = SubscribeCandles(TimeSpan.FromMinutes(5).TimeFrame());
subscription.Bind(_fast, _slow, ProcessCandle);
subscription.Start();
}
private void ProcessCandle(ICandleMessage candle, decimal fastValue, decimal slowValue)
{
if (candle.State != CandleStates.Finished) return;
if (!_fast.IsFormed || !_slow.IsFormed) { _prevFast = fastValue; _prevSlow = slowValue; return; }
if (_cooldown > 0) { _cooldown--; _prevFast = fastValue; _prevSlow = slowValue; return; }
var close = candle.ClosePrice;
var step = Security?.PriceStep ?? 1m;
if (Position > 0 && _entryPrice > 0)
{
if (StopLossPoints > 0 && close <= _entryPrice - StopLossPoints * step) { SellMarket(); _entryPrice = 0; _cooldown = 100; _prevFast = fastValue; _prevSlow = slowValue; return; }
if (TakeProfitPoints > 0 && close >= _entryPrice + TakeProfitPoints * step) { SellMarket(); _entryPrice = 0; _cooldown = 100; _prevFast = fastValue; _prevSlow = slowValue; return; }
}
else if (Position < 0 && _entryPrice > 0)
{
if (StopLossPoints > 0 && close >= _entryPrice + StopLossPoints * step) { BuyMarket(); _entryPrice = 0; _cooldown = 100; _prevFast = fastValue; _prevSlow = slowValue; return; }
if (TakeProfitPoints > 0 && close <= _entryPrice - TakeProfitPoints * step) { BuyMarket(); _entryPrice = 0; _cooldown = 100; _prevFast = fastValue; _prevSlow = slowValue; return; }
}
if (_prevFast <= _prevSlow && fastValue > slowValue && Position <= 0)
{ if (Position < 0) BuyMarket(); BuyMarket(); _entryPrice = close; _cooldown = 100; }
else if (_prevFast >= _prevSlow && fastValue < slowValue && Position >= 0)
{ if (Position > 0) SellMarket(); SellMarket(); _entryPrice = close; _cooldown = 100; }
_prevFast = fastValue; _prevSlow = slowValue;
}
}
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 trend_line_strategy(Strategy):
def __init__(self):
super(trend_line_strategy, self).__init__()
self._fast_period = self.Param("FastPeriod", 14) \
.SetDisplay("Fast Period", "Fast MA period", "Indicator")
self._slow_period = self.Param("SlowPeriod", 50) \
.SetDisplay("Slow Period", "Slow MA period", "Indicator")
self._stop_loss_points = self.Param("StopLossPoints", 200) \
.SetDisplay("Stop Loss", "Stop-loss in price steps", "Risk")
self._take_profit_points = self.Param("TakeProfitPoints", 400) \
.SetDisplay("Take Profit", "Take-profit in price steps", "Risk")
self._fast = None
self._slow = None
self._prev_fast = 0.0
self._prev_slow = 0.0
self._entry_price = 0.0
self._cooldown = 0
@property
def fast_period(self):
return self._fast_period.Value
@property
def slow_period(self):
return self._slow_period.Value
@property
def stop_loss_points(self):
return self._stop_loss_points.Value
@property
def take_profit_points(self):
return self._take_profit_points.Value
def OnReseted(self):
super(trend_line_strategy, self).OnReseted()
self._fast = None
self._slow = None
self._prev_fast = 0.0
self._prev_slow = 0.0
self._entry_price = 0.0
self._cooldown = 0
def OnStarted2(self, time):
super(trend_line_strategy, self).OnStarted2(time)
self._fast = ExponentialMovingAverage()
self._fast.Length = self.fast_period
self._slow = ExponentialMovingAverage()
self._slow.Length = self.slow_period
subscription = self.SubscribeCandles(DataType.TimeFrame(TimeSpan.FromMinutes(5)))
subscription.Bind(self._fast, self._slow, self._process_candle)
subscription.Start()
def _process_candle(self, candle, fast_value, slow_value):
if candle.State != CandleStates.Finished:
return
fast_val = float(fast_value)
slow_val = float(slow_value)
if not self._fast.IsFormed or not self._slow.IsFormed:
self._prev_fast = fast_val
self._prev_slow = slow_val
return
if self._cooldown > 0:
self._cooldown -= 1
self._prev_fast = fast_val
self._prev_slow = slow_val
return
close = float(candle.ClosePrice)
step = float(self.Security.PriceStep) if self.Security is not None and self.Security.PriceStep is not None else 1.0
if self.Position > 0 and self._entry_price > 0:
if self.stop_loss_points > 0 and close <= self._entry_price - self.stop_loss_points * step:
self.SellMarket()
self._entry_price = 0.0
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
return
if self.take_profit_points > 0 and close >= self._entry_price + self.take_profit_points * step:
self.SellMarket()
self._entry_price = 0.0
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
return
elif self.Position < 0 and self._entry_price > 0:
if self.stop_loss_points > 0 and close >= self._entry_price + self.stop_loss_points * step:
self.BuyMarket()
self._entry_price = 0.0
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
return
if self.take_profit_points > 0 and close <= self._entry_price - self.take_profit_points * step:
self.BuyMarket()
self._entry_price = 0.0
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
return
if self._prev_fast <= self._prev_slow and fast_val > slow_val and self.Position <= 0:
if self.Position < 0:
self.BuyMarket()
self.BuyMarket()
self._entry_price = close
self._cooldown = 100
elif self._prev_fast >= self._prev_slow and fast_val < slow_val and self.Position >= 0:
if self.Position > 0:
self.SellMarket()
self.SellMarket()
self._entry_price = close
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
def CreateClone(self):
return trend_line_strategy()