A Estratégia WE TRUST Channel é um port de alto nível do StockSharp do expert advisor do MetaTrader 5 "WE TRUST". O sistema negocia pullbacks em direção a uma média móvel ponderada linear que é cercada por bandas de desvio padrão. Quando o preço fecha fora das bandas, a estratégia antecipa reversão à média e abre uma posição de mercado de volta ao centro do canal. Reversão de sinais, fechamento opcional de trades opostos e parâmetros de gestão monetária baseados em pips espelham o expert original.
Lógica de negociação
Assinar o tipo de vela configurado (velas horárias por padrão) e calcular dois indicadores na fonte de preço selecionada:
Uma média móvel ponderada linear (LWMA) com período e deslocamento configuráveis.
Um envelope de desvio padrão com seu próprio período e deslocamento.
Converter offsets baseados em pips em distâncias de preço absolutas usando o PriceStep do instrumento. Cotações de cinco e três dígitos multiplicam o passo por 10 para emular a definição de pip do MetaTrader.
Calcular os limites superior e inferior do canal: LWMA ± StdDev ± ChannelIndentPips (convertidos em unidades de preço).
Avaliar apenas velas concluídas. Quando o preço da vela escolhida fecha abaixo do canal inferior, a estratégia gera um sinal de compra. Quando fecha acima do canal superior, gera um sinal de venda.
Opcionalmente inverter os sinais quando ReverseSignals está habilitado. Opcionalmente zerar uma posição oposta antes de agir em um novo sinal quando CloseOpposite está habilitado.
Enviar ordens de mercado com o volume configurado quando a posição atual está flat ou alinhada com a direção do sinal.
Gestão de risco
StopLossPips e TakeProfitPips traduzem distâncias em pips para ordens protetoras absolutas via StartProtection. Definir como 0 para desabilitar o nível respectivo.
TrailingStopPips e TrailingStepPips controlam um trailing stop baseado em pips que segue trades lucrativos. Ambos os parâmetros são convertidos em distâncias de preço usando a mesma lógica de tamanho de pip.
Todas as saídas são realizadas com ordens de mercado para permanecer próximo à implementação MQL5.
Parâmetros
Parâmetro
Descrição
Padrão
OrderVolume
Volume de trade enviado com cada ordem de mercado.
0.1
StopLossPips
Distância de stop-loss expressa em pips (0 desabilita o stop).
40
TakeProfitPips
Distância de take-profit expressa em pips (0 desabilita o alvo).
60
TrailingStopPips
Distância de trailing stop em pips.
10
TrailingStepPips
Passo de trailing em pips entre ajustes de stop.
10
MaPeriod
Período da média móvel ponderada linear.
60
MaShift
Número de barras que a média móvel é deslocada para frente.
0
StdDevPeriod
Período do cálculo de desvio padrão.
50
StdDevShift
Número de barras que o valor de desvio é deslocado.
0
SignalBarOffset
Número de barras concluídas atrás ao avaliar sinais.
1
ChannelIndentPips
Buffer adicional adicionado fora das bandas de desvio.
1
ReverseSignals
Inverter a lógica de compra/venda do rompimento do canal.
false
CloseOpposite
Fechar uma posição oposta antes de entrar em um novo trade.
false
AppliedPrice
Componente de preço da vela alimentado em ambos os indicadores.
Weighted
CandleType
Tipo de dados de vela solicitado ao conector.
período de 1 hora
Notas
A estratégia depende de metadados válidos de PriceStep. Se a bolsa não os fornecer, o código recorre a Security.Step e finalmente a 1.
Apenas a implementação em C# está incluída neste diretório. O port Python é intencionalmente omitido conforme as instruções.
A lógica processa apenas velas concluídas e não tenta acumular dados de barra parciais.
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 WeTrustChannelStrategy : 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 WeTrustChannelStrategy()
{
_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 we_trust_channel_strategy(Strategy):
def __init__(self):
super(we_trust_channel_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(we_trust_channel_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(we_trust_channel_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 we_trust_channel_strategy()