Início
/
Exemplos de estratégias
Ver no GitHub
Estratégia Pivot Point Supertrend
Estratégia que combina Pivot Points com um Supertrend baseado em ATR para capturar reversões de tendência.
Os Pivot Points definem uma linha central dinâmica. Um multiplicador ATR constrói bandas superior e inferior que seguem o preço. Quando a tendência muda de direção, a estratégia entra de acordo.
Detalhes
Critérios de entrada : Sinais baseados em Pivot Points e ATR Supertrend.
Comprado/Vendido : Ambos.
Critérios de saída : Sinal oposto.
Stops : Não.
Valores padrão :
PivotPeriod = 2
AtrFactor = 3m
AtrPeriod = 10
CandleType = TimeSpan.FromMinutes(5)
Filtros :
Categoria: Tendência
Direção: Ambos
Indicadores: Pivot Points, ATR
Stops: Não
Complexidade: Básico
Período: Intradiário (5m)
Sazonalidade: Não
Redes neurais: Não
Divergência: Não
Nível de risco: Médio
Cálculo e execução
Usam-se apenas velas concluídas. Um pivô máximo/mínimo deve ficar estritamente acima/abaixo de todas as PivotPeriod velas de cada lado e só é confirmado após as velas à direita terminarem. Se ambos ocorrerem na mesma vela, o máximo tem prioridade. O primeiro pivô inicializa center; os demais usam (2 * center + pivot) / 3.
As bandas usam Wilder ATR: média dos primeiros AtrPeriod true ranges, depois suavização com peso 1 / AtrPeriod. Suporte/resistência básicos são center ± AtrFactor * ATR. O suporte conserva o máximo entre valor básico e anterior quando o fechamento anterior supera o suporte anterior; caso contrário reinicia. A resistência conserva o mínimo quando o fechamento anterior fica abaixo da resistência anterior; caso contrário reinicia. Fechamento estritamente acima da resistência anterior muda para alta; abaixo do suporte anterior muda para baixa; caso contrário mantém a direção. A direção inicial é de alta; inicialização não gera sinal.
Wilder ATR e um centro pivô confirmado devem estar prontos. Só a mudança de direção das bandas gera entrada: alta abre compra, baixa abre venda a descoberto. A direção inicial é de alta; a inicialização não gera ordem. Cada sinal oposto inverte toda a posição com uma ordem a mercado de Volume + abs(Position); entrada sem posição usa Volume. Sem SMA, SuperTrend de preço separado, filtro de datas, espera ou stop protetor.
Conceito pivô: Pivot Point Supertrend de LonesomeTheBlue . As regras acima definem o modelo bidirecional deste exemplo.
namespace StockSharp.Samples.Strategies;
using System;
using System.Collections.Generic;
using Ecng.Common;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.BusinessEntities;
using StockSharp.Messages;
/// <summary>
/// Trades direction changes of ATR bands around a center of confirmed swing pivots.
/// </summary>
public class PivotPointSupertrendStrategy : Strategy
{
private readonly StrategyParam<int> _pivotPeriod;
private readonly StrategyParam<decimal> _atrFactor;
private readonly StrategyParam<int> _atrPeriod;
private readonly StrategyParam<DataType> _candleType;
private readonly List<(decimal High, decimal Low)> _pivots = [];
private decimal? _center;
private decimal? _support;
private decimal? _resistance;
private decimal? _previousClose;
private bool? _pivotUp;
/// <summary>
/// Initializes the published pivot period, ATR settings and five-minute candles.
/// </summary>
public PivotPointSupertrendStrategy()
{
_pivotPeriod = Param(nameof(PivotPeriod), 2).SetGreaterThanZero()
.SetDisplay("Pivot Period", "Finished candles on each side of a confirmed pivot", "Indicators");
_atrFactor = Param(nameof(AtrFactor), 3m).SetGreaterThanZero()
.SetDisplay("ATR Factor", "ATR width of the pivot bands", "Indicators");
_atrPeriod = Param(nameof(AtrPeriod), 10).SetGreaterThanZero()
.SetDisplay("ATR Period", "Wilder ATR period of the pivot bands", "Indicators");
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(5).TimeFrame())
.SetDisplay("Candle Type", "Type of finished candles", "General");
}
/// <summary>
/// Number of finished candles required on each side of a pivot.
/// </summary>
public int PivotPeriod { get => _pivotPeriod.Value; set => _pivotPeriod.Value = value; }
/// <summary>
/// Wilder ATR multiplier for the pivot bands.
/// </summary>
public decimal AtrFactor { get => _atrFactor.Value; set => _atrFactor.Value = value; }
/// <summary>
/// Wilder ATR period.
/// </summary>
public int AtrPeriod { get => _atrPeriod.Value; set => _atrPeriod.Value = value; }
/// <summary>
/// Candle type; five minutes by default.
/// </summary>
public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }
/// <inheritdoc />
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
=> [(Security, CandleType)];
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
ResetSignals();
}
private void ResetSignals()
{
_pivots.Clear();
_center = _support = _resistance = _previousClose = null;
_pivotUp = null;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
ResetSignals();
var atr = new AverageTrueRange { Length = AtrPeriod };
var subscription = SubscribeCandles(CandleType);
subscription.BindEx(atr, ProcessCandle, allowEmpty: true).Start();
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawOwnTrades(area);
}
}
private void ProcessCandle(ICandleMessage candle, IIndicatorValue atrValue)
{
if (candle.State != CandleStates.Finished)
return;
var previousClose = _previousClose ?? candle.ClosePrice;
_previousClose = candle.ClosePrice;
_pivots.Add((candle.HighPrice, candle.LowPrice));
if (_pivots.Count > 2 * PivotPeriod + 1)
_pivots.RemoveAt(0);
if (_pivots.Count == 2 * PivotPeriod + 1)
{
var candidate = _pivots[PivotPeriod];
var isHigh = true;
var isLow = true;
for (var i = 0; i < _pivots.Count; i++)
{
if (i == PivotPeriod)
continue;
isHigh &= candidate.High > _pivots[i].High;
isLow &= candidate.Low < _pivots[i].Low;
}
if (isHigh || isLow)
{
var pivot = isHigh ? candidate.High : candidate.Low;
_center = _center is decimal center ? (2m * center + pivot) / 3m : pivot;
}
}
var previousPivotUp = _pivotUp;
if (_center is decimal pivotCenter && atrValue.IsFormed && !atrValue.IsEmpty)
{
var width = AtrFactor * atrValue.ToDecimal();
var oldSupport = _support;
var oldResistance = _resistance;
_support = oldSupport is decimal support && previousClose > support ? Math.Max(pivotCenter - width, support) : pivotCenter - width;
_resistance = oldResistance is decimal resistance && previousClose < resistance ? Math.Min(pivotCenter + width, resistance) : pivotCenter + width;
_pivotUp = oldResistance is decimal upper && candle.ClosePrice > upper ? true
: oldSupport is decimal lower && candle.ClosePrice < lower ? false : _pivotUp ?? true;
}
if (!IsFormedAndOnlineAndAllowTrading())
return;
if (previousPivotUp == false && _pivotUp == true && Position <= 0m)
BuyMarket(Volume + Math.Abs(Position));
else if (previousPivotUp == true && _pivotUp == false && Position >= 0m)
SellMarket(Volume + Math.Abs(Position));
}
}
import clr
clr.AddReference("StockSharp.Messages")
clr.AddReference("StockSharp.Algo")
clr.AddReference("StockSharp.Algo.Indicators")
clr.AddReference("StockSharp.Algo.Strategies")
from System import Decimal, TimeSpan
from StockSharp.Messages import DataType, CandleStates
from StockSharp.Algo.Indicators import AverageTrueRange
from StockSharp.Algo.Strategies import Strategy
class pivot_point_supertrend_strategy(Strategy):
def __init__(self):
super(pivot_point_supertrend_strategy, self).__init__()
self._pivot_period = self.Param("PivotPeriod", 2).SetGreaterThanZero() \
.SetDisplay("Pivot Period", "Finished candles on each side of a confirmed pivot", "Indicators")
self._atr_factor = self.Param("AtrFactor", Decimal.Parse("3")).SetGreaterThanZero() \
.SetDisplay("ATR Factor", "ATR width of the pivot bands", "Indicators")
self._atr_period = self.Param("AtrPeriod", 10).SetGreaterThanZero() \
.SetDisplay("ATR Period", "Wilder ATR period of the pivot bands", "Indicators")
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromMinutes(5))) \
.SetDisplay("Candle Type", "Type of finished candles", "General")
self._reset_signals()
@property
def candle_type(self):
return self._candle_type.Value
@candle_type.setter
def candle_type(self, value):
self._candle_type.Value = value
def _reset_signals(self):
self._pivots = []
self._center = None
self._support = None
self._resistance = None
self._previous_close = None
self._pivot_up = None
def OnReseted(self):
super(pivot_point_supertrend_strategy, self).OnReseted()
self._reset_signals()
def OnStarted2(self, time):
super(pivot_point_supertrend_strategy, self).OnStarted2(time)
self._reset_signals()
atr = AverageTrueRange()
atr.Length = self._atr_period.Value
subscription = self.SubscribeCandles(self.candle_type)
subscription.BindEx(atr, self.OnProcess, True).Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawOwnTrades(area)
def OnProcess(self, candle, atr_value):
if candle.State != CandleStates.Finished:
return
previous_close = candle.ClosePrice if self._previous_close is None else self._previous_close
self._previous_close = candle.ClosePrice
self._pivots.append((candle.HighPrice, candle.LowPrice))
period = self._pivot_period.Value
if len(self._pivots) > 2 * period + 1:
self._pivots.pop(0)
if len(self._pivots) == 2 * period + 1:
candidate = self._pivots[period]
neighbors = self._pivots[:period] + self._pivots[period + 1:]
is_high = all(candidate[0] > bar[0] for bar in neighbors)
is_low = all(candidate[1] < bar[1] for bar in neighbors)
if is_high or is_low:
pivot = candidate[0] if is_high else candidate[1]
self._center = pivot if self._center is None else (Decimal(2) * self._center + pivot) / Decimal(3)
previous_pivot_up = self._pivot_up
if self._center is not None and atr_value.IsFormed and not atr_value.IsEmpty:
width = self._atr_factor.Value * atr_value.GetValue[Decimal](None)
old_support = self._support
old_resistance = self._resistance
basic_support = self._center - width
basic_resistance = self._center + width
self._support = max(basic_support, old_support) if old_support is not None and previous_close > old_support else basic_support
self._resistance = min(basic_resistance, old_resistance) if old_resistance is not None and previous_close < old_resistance else basic_resistance
if old_resistance is not None and candle.ClosePrice > old_resistance:
self._pivot_up = True
elif old_support is not None and candle.ClosePrice < old_support:
self._pivot_up = False
elif self._pivot_up is None:
self._pivot_up = True
if not self.IsFormedAndOnlineAndAllowTrading():
return
if previous_pivot_up is False and self._pivot_up and self.Position <= 0:
self.BuyMarket(self.Volume + abs(self.Position))
elif previous_pivot_up is True and not self._pivot_up and self.Position >= 0:
self.SellMarket(self.Volume + abs(self.Position))
def CreateClone(self):
return pivot_point_supertrend_strategy()