Estratégia de Médio de Posição MA MACD v2
Visão Geral
A Estratégia de Médio de Posição MA MACD v2 é uma tradução direta do consultor especialista do MetaTrader de Vladimir
Karputov. Combina um filtro de média móvel ponderada, um bloco de confirmação MACD e um módulo de médio que aumenta a exposição
quando as operações existentes se movem contra a posição. A versão StockSharp mantém a hierarquia de sinais original, processa
indicadores em candles terminadas e gerencia a lógica de proteção (stop loss, take profit, trailing) em código para reproduzir
o comportamento do lado do broker em MQL.
Lógica de Trading
- Preparação de indicadores
- Uma média móvel configurável calcula no tipo de candle e componente de preço selecionados. O parâmetro
MaShift emula
o deslocamento para frente do MetaTrader lendo valores de candles mais antigas, enquanto BarOffset permite avaliar a
barra atual ou uma anterior.
- Um indicador de sinal MACD produz as linhas principal e de sinal usando períodos rápido, lento e de sinal personalizáveis
e um preço aplicado que corresponde ao consultor especialista original.
- Validação de sinais
- Setups comprados requerem que ambas as linhas MACD sejam negativas, que o preço esteja acima da média móvel deslocada
e que a distância do preço à média exceda
MaIndentPips (convertido para preço absoluto usando o tamanho de pip do
instrumento).
- Setups vendidos espelham as condições: ambas as linhas MACD devem ser positivas, o preço deve permanecer abaixo da
média móvel deslocada e a diferença à média deve ser pelo menos
MaIndentPips.
- O filtro de proporção
MacdRatio impõe MACD_main / MACD_signal >= MacdRatio (usando divisão decimal absoluta) antes
de permitir uma operação.
- Quando
ReverseSignals = true, a direção da ordem a mercado é invertida depois que todas as condições passam.
- Ciclo de vida da posição
- Se não existe posição, a estratégia abre uma ordem a mercado com o
OrderVolume configurado (arredondado pelo
passo de volume do instrumento) na direção calculada. Níveis de stop-loss e take-profit são aplicados imediatamente
de acordo com StopLossPips e TakeProfitPips.
- Se uma exposição já existe, a estratégia nunca abre o lado oposto. Em vez disso:
- Fecha tudo se comprados e vendidos forem detectados simultaneamente (rede de segurança espelhando a verificação MQL), ou
- Invoca o bloco de médio para o lado atual.
- Módulo de médio
- Para comprados, o algoritmo encontra o tramo aberto com o preço mais baixo cuja perda não realizada excede
StepLossPips.
Para vendidos seleciona o tramo perdedor com o preço mais alto.
- Uma vez que um candidato é encontrado, uma nova ordem a mercado é enviada com volume
CandidateVolume × LotCoefficient
(após ajuste ao passo/mín/máx de volume permitido). Isso reproduz a progressão geométrica do especialista original.
- Novos tramos herdam as mesmas distâncias de stop-loss e take-profit e se tornam elegíveis para atualizações de trailing.
- Controles de risco
- Um trailing stop ativa apenas quando tanto
TrailingStopPips quanto TrailingStepPips são maiores que zero. Para
comprados, o stop se move para Close - TrailingStopPips quando o lucro excede TrailingStopPips + TrailingStepPips;
vendidos se comportam simetricamente.
- Verificações manuais de stop-loss e take-profit são realizadas em cada candle terminada. Quando acionadas, uma ordem a
mercado fecha o tramo exato e o remove da lista de médio.
Parâmetros
| Parâmetro |
Descrição |
| OrderVolume |
Volume base para a primeira operação em um ciclo. |
| StopLossPips |
Distância do stop-loss em pips. Definir como zero para desativar o stop. |
| TakeProfitPips |
Distância do take-profit em pips. Definir como zero para desativar o alvo. |
| TrailingStopPips |
Distância entre o preço e o trailing stop. Funciona junto com TrailingStepPips. |
| TrailingStepPips |
Movimento favorável adicional necessário antes de atualizar o trailing stop. |
| StepLossPips |
Perda mínima (em pips) necessária antes de adicionar um tramo de médio. |
| LotCoefficient |
Multiplicador aplicado ao volume do tramo perdedor selecionado ao fazer médio. |
| BarOffset |
Número de barras para trás para ler valores de indicadores (0 = barra terminada atual). |
| ReverseSignals |
Inverte a execução comprado/vendido mantendo os mesmos filtros. |
| MaPeriod |
Período da média móvel. |
| MaShift |
Deslocamento para frente aplicado à média móvel (estilo MetaTrader). |
| MaMethod |
Método de suavização da média móvel (Simples, Exponencial, Suavizado, Ponderado). |
| MaPrice |
Componente de preço da candle usado para a média móvel. |
| MaIndentPips |
Distância mínima do preço à média móvel antes de entrar. |
| MacdFastPeriod |
Período de EMA rápido para MACD. |
| MacdSlowPeriod |
Período de EMA lento para MACD. |
| MacdSignalPeriod |
Período de EMA de sinal para MACD. |
| MacdPrice |
Preço aplicado usado no cálculo do MACD. |
| MacdRatio |
Proporção mínima entre as linhas principal e de sinal do MACD. |
| CandleType |
Série de candles usada para todos os cálculos. |
Notas de Implementação
- O tamanho do pip é calculado a partir do passo de preço do instrumento, reproduzindo o ajuste de 3/5 dígitos da versão MQL.
Isso mantém idênticas as distâncias baseadas em pips nos símbolos Forex.
- Todos os buffers de indicadores usam filas para emular a indexação
ma_shift e bar do MetaTrader sem chamar métodos de
busca histórica proibidos pelas regras do projeto.
- Os ajustes de volume respeitam
Security.VolumeStep, Security.MinVolume e Security.MaxVolume, evitando tamanhos de
ordem inválidos quando LotCoefficient multiplica a exposição.
- A lógica de proteção (stops, takes, trailing) é executada completamente na camada de estratégia, portanto não há dependência
de APIs de modificação de posição do broker.
- A classe reside no namespace
StockSharp.Samples.Strategies e segue o requisito do repositório de usar recuo de tabulação
e comentários exclusivamente em inglês.
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>
/// MA MACD Position Averaging v2 strategy using WMA crossover with EMA trend filter.
/// Buys when fast WMA crosses above slow WMA and price above EMA.
/// Sells on reverse conditions.
/// </summary>
public class MaMacdPositionAveragingV2Strategy : Strategy
{
private readonly StrategyParam<int> _fastPeriod;
private readonly StrategyParam<int> _slowPeriod;
private readonly StrategyParam<int> _emaPeriod;
private readonly StrategyParam<int> _stopLossPoints;
private readonly StrategyParam<int> _takeProfitPoints;
private WeightedMovingAverage _fast;
private WeightedMovingAverage _slow;
private ExponentialMovingAverage _ema;
private decimal _prevFast;
private decimal _prevSlow;
private decimal _entryPrice;
private int _cooldown;
/// <summary>
/// Fast WMA period.
/// </summary>
public int FastPeriod
{
get => _fastPeriod.Value;
set => _fastPeriod.Value = value;
}
/// <summary>
/// Slow WMA period.
/// </summary>
public int SlowPeriod
{
get => _slowPeriod.Value;
set => _slowPeriod.Value = value;
}
/// <summary>
/// EMA trend filter period.
/// </summary>
public int EmaPeriod
{
get => _emaPeriod.Value;
set => _emaPeriod.Value = value;
}
/// <summary>
/// Stop-loss distance in price steps.
/// </summary>
public int StopLossPoints
{
get => _stopLossPoints.Value;
set => _stopLossPoints.Value = value;
}
/// <summary>
/// Take-profit distance in price steps.
/// </summary>
public int TakeProfitPoints
{
get => _takeProfitPoints.Value;
set => _takeProfitPoints.Value = value;
}
/// <summary>
/// Initializes strategy parameters.
/// </summary>
public MaMacdPositionAveragingV2Strategy()
{
_fastPeriod = Param(nameof(FastPeriod), 15)
.SetGreaterThanZero()
.SetDisplay("Fast Period", "Fast WMA period", "Indicator");
_slowPeriod = Param(nameof(SlowPeriod), 100)
.SetGreaterThanZero()
.SetDisplay("Slow Period", "Slow WMA period", "Indicator");
_emaPeriod = Param(nameof(EmaPeriod), 200)
.SetGreaterThanZero()
.SetDisplay("EMA Period", "EMA trend filter 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");
}
/// <inheritdoc />
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
{
yield return (Security, TimeSpan.FromMinutes(5).TimeFrame());
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_fast = null;
_slow = null;
_ema = null;
_prevFast = 0;
_prevSlow = 0;
_entryPrice = 0;
_cooldown = 0;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_fast = new WeightedMovingAverage { Length = FastPeriod };
_slow = new WeightedMovingAverage { Length = SlowPeriod };
_ema = new ExponentialMovingAverage { Length = EmaPeriod };
var subscription = SubscribeCandles(TimeSpan.FromMinutes(5).TimeFrame());
subscription.Bind(_fast, _slow, _ema, ProcessCandle);
subscription.Start();
}
private void ProcessCandle(ICandleMessage candle, decimal fastValue, decimal slowValue, decimal emaValue)
{
if (candle.State != CandleStates.Finished)
return;
if (!_fast.IsFormed || !_slow.IsFormed || !_ema.IsFormed)
{
_prevFast = fastValue;
_prevSlow = slowValue;
return;
}
if (_cooldown > 0)
{
_cooldown--;
_prevFast = fastValue;
_prevSlow = slowValue;
return;
}
var close = candle.ClosePrice;
var step = Security?.PriceStep ?? 1m;
// Check SL/TP
if (Position > 0 && _entryPrice > 0)
{
if (StopLossPoints > 0 && close <= _entryPrice - StopLossPoints * step)
{
SellMarket();
_entryPrice = 0;
_cooldown = 80;
_prevFast = fastValue;
_prevSlow = slowValue;
return;
}
if (TakeProfitPoints > 0 && close >= _entryPrice + TakeProfitPoints * step)
{
SellMarket();
_entryPrice = 0;
_cooldown = 80;
_prevFast = fastValue;
_prevSlow = slowValue;
return;
}
}
else if (Position < 0 && _entryPrice > 0)
{
if (StopLossPoints > 0 && close >= _entryPrice + StopLossPoints * step)
{
BuyMarket();
_entryPrice = 0;
_cooldown = 80;
_prevFast = fastValue;
_prevSlow = slowValue;
return;
}
if (TakeProfitPoints > 0 && close <= _entryPrice - TakeProfitPoints * step)
{
BuyMarket();
_entryPrice = 0;
_cooldown = 80;
_prevFast = fastValue;
_prevSlow = slowValue;
return;
}
}
// WMA crossover with EMA trend filter
if (_prevFast <= _prevSlow && fastValue > slowValue && close > emaValue && Position <= 0)
{
if (Position < 0)
BuyMarket();
BuyMarket();
_entryPrice = close;
_cooldown = 80;
}
else if (_prevFast >= _prevSlow && fastValue < slowValue && close < emaValue && Position >= 0)
{
if (Position > 0)
SellMarket();
SellMarket();
_entryPrice = close;
_cooldown = 80;
}
_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 WeightedMovingAverage, ExponentialMovingAverage
from StockSharp.Algo.Strategies import Strategy
class ma_macd_position_averaging_v2_strategy(Strategy):
def __init__(self):
super(ma_macd_position_averaging_v2_strategy, self).__init__()
self._fast_period = self.Param("FastPeriod", 15) \
.SetDisplay("Fast Period", "Fast WMA period", "Indicator")
self._slow_period = self.Param("SlowPeriod", 100) \
.SetDisplay("Slow Period", "Slow WMA period", "Indicator")
self._ema_period = self.Param("EmaPeriod", 200) \
.SetDisplay("EMA Period", "EMA trend filter 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._ema = 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 ema_period(self):
return self._ema_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(ma_macd_position_averaging_v2_strategy, self).OnReseted()
self._fast = None
self._slow = None
self._ema = None
self._prev_fast = 0.0
self._prev_slow = 0.0
self._entry_price = 0.0
self._cooldown = 0
def OnStarted2(self, time):
super(ma_macd_position_averaging_v2_strategy, self).OnStarted2(time)
self._fast = WeightedMovingAverage()
self._fast.Length = self.fast_period
self._slow = WeightedMovingAverage()
self._slow.Length = self.slow_period
self._ema = ExponentialMovingAverage()
self._ema.Length = self.ema_period
subscription = self.SubscribeCandles(DataType.TimeFrame(TimeSpan.FromMinutes(5)))
subscription.Bind(self._fast, self._slow, self._ema, self._process_candle)
subscription.Start()
def _process_candle(self, candle, fast_value, slow_value, ema_value):
if candle.State != CandleStates.Finished:
return
fast_val = float(fast_value)
slow_val = float(slow_value)
ema_val = float(ema_value)
if not self._fast.IsFormed or not self._slow.IsFormed or not self._ema.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
# Check SL/TP
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 = 80
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 = 80
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 = 80
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 = 80
self._prev_fast = fast_val
self._prev_slow = slow_val
return
# WMA crossover with EMA trend filter
if self._prev_fast <= self._prev_slow and fast_val > slow_val and close > ema_val and self.Position <= 0:
if self.Position < 0:
self.BuyMarket()
self.BuyMarket()
self._entry_price = close
self._cooldown = 80
elif self._prev_fast >= self._prev_slow and fast_val < slow_val and close < ema_val and self.Position >= 0:
if self.Position > 0:
self.SellMarket()
self.SellMarket()
self._entry_price = close
self._cooldown = 80
self._prev_fast = fast_val
self._prev_slow = slow_val
def CreateClone(self):
return ma_macd_position_averaging_v2_strategy()