Ha MaZi
Combines Heikin Ashi candles, an EMA filter, and ZigZag pivot confirmation. A long trade is opened when a bullish Heikin Ashi candle forms at a new ZigZag low above the EMA. Shorts appear on a bearish candle at a new ZigZag high below the EMA. Positions are closed by fixed stop loss or take profit.
Details
- Entry Criteria: ZigZag pivot with Heikin Ashi direction and EMA filter.
- Long/Short: Both directions.
- Exit Criteria: Stop loss or take profit.
- Stops: Fixed stop and target.
- Default Values:
MaPeriod= 40ZigzagLength= 13StopLoss= 70TakeProfit= 200CandleType= TimeSpan.FromMinutes(1)
- Filters:
- Category: Trend
- Direction: Both
- Indicators: Heikin Ashi, EMA, ZigZag
- Stops: Yes
- Complexity: Intermediate
- Timeframe: Intraday
- Seasonality: No
- Neural Networks: No
- Divergence: No
- Risk Level: Medium
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>
/// Heikin Ashi with moving average and ZigZag-style pivot confirmation.
/// </summary>
public class HaMaZiStrategy : Strategy
{
private readonly StrategyParam<int> _maPeriod;
private readonly StrategyParam<int> _zigzagLength;
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<decimal> _stopLossPct;
private readonly StrategyParam<decimal> _takeProfitPct;
private Highest _highest;
private Lowest _lowest;
private decimal _haOpenPrev;
private decimal _haClosePrev;
private decimal _lastZigzag;
private decimal _lastZigzagHigh;
private decimal _lastZigzagLow;
public int MaPeriod { get => _maPeriod.Value; set => _maPeriod.Value = value; }
public int ZigzagLength { get => _zigzagLength.Value; set => _zigzagLength.Value = value; }
public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }
public decimal StopLossPct { get => _stopLossPct.Value; set => _stopLossPct.Value = value; }
public decimal TakeProfitPct { get => _takeProfitPct.Value; set => _takeProfitPct.Value = value; }
public HaMaZiStrategy()
{
_maPeriod = Param(nameof(MaPeriod), 40)
.SetDisplay("MA Period", "EMA period", "General");
_zigzagLength = Param(nameof(ZigzagLength), 13)
.SetDisplay("ZigZag Length", "Lookback for pivot search", "ZigZag");
_candleType = Param(nameof(CandleType), TimeSpan.FromHours(4).TimeFrame())
.SetDisplay("Candle Type", "Type of candles to use", "General");
_stopLossPct = Param(nameof(StopLossPct), 2m)
.SetDisplay("Stop Loss %", "Stop loss percentage", "Risk");
_takeProfitPct = Param(nameof(TakeProfitPct), 3m)
.SetDisplay("Take Profit %", "Take profit percentage", "Risk");
}
/// <inheritdoc />
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
=> [(Security, CandleType)];
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_highest = default;
_lowest = default;
_haOpenPrev = 0; _haClosePrev = 0;
_lastZigzag = 0; _lastZigzagHigh = 0; _lastZigzagLow = 0;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
var ema = new ExponentialMovingAverage { Length = MaPeriod };
_highest = new Highest { Length = ZigzagLength };
_lowest = new Lowest { Length = ZigzagLength };
Indicators.Add(_highest);
Indicators.Add(_lowest);
var subscription = SubscribeCandles(CandleType);
subscription
.Bind(ema, (candle, emaVal) =>
{
if (candle.State != CandleStates.Finished)
return;
var highResult = _highest.Process(candle);
var lowResult = _lowest.Process(candle);
if (!highResult.IsFormed || !lowResult.IsFormed)
return;
var highest = highResult.ToDecimal();
var lowest = lowResult.ToDecimal();
var haClose = (candle.OpenPrice + candle.HighPrice + candle.LowPrice + candle.ClosePrice) / 4m;
var haOpen = (_haOpenPrev == 0 && _haClosePrev == 0)
? (candle.OpenPrice + candle.ClosePrice) / 2m
: (_haOpenPrev + _haClosePrev) / 2m;
var haBull = haClose > haOpen;
var haBear = haClose < haOpen;
if (candle.HighPrice >= highest && _lastZigzag != candle.HighPrice)
{
_lastZigzag = candle.HighPrice;
_lastZigzagHigh = candle.HighPrice;
_lastZigzagLow = 0;
}
else if (candle.LowPrice <= lowest && _lastZigzag != candle.LowPrice)
{
_lastZigzag = candle.LowPrice;
_lastZigzagLow = candle.LowPrice;
_lastZigzagHigh = 0;
}
if (_lastZigzag == _lastZigzagLow && _lastZigzagLow > 0 && haBull && candle.ClosePrice > emaVal && Position <= 0)
{
if (Position < 0) BuyMarket();
BuyMarket();
}
else if (_lastZigzag == _lastZigzagHigh && _lastZigzagHigh > 0 && haBear && candle.ClosePrice < emaVal && Position >= 0)
{
if (Position > 0) SellMarket();
SellMarket();
}
_haOpenPrev = haOpen;
_haClosePrev = haClose;
})
.Start();
StartProtection(
takeProfit: new Unit(TakeProfitPct, UnitTypes.Percent),
stopLoss: new Unit(StopLossPct, UnitTypes.Percent),
useMarketOrders: true);
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, ema);
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, Unit, UnitTypes
from StockSharp.Algo.Indicators import ExponentialMovingAverage, Highest, Lowest, CandleIndicatorValue
from StockSharp.Algo.Strategies import Strategy
class ha_ma_zi_strategy(Strategy):
def __init__(self):
super(ha_ma_zi_strategy, self).__init__()
self._ma_period = self.Param("MaPeriod", 40) \
.SetDisplay("MA Period", "EMA period", "General")
self._zigzag_length = self.Param("ZigzagLength", 13) \
.SetDisplay("ZigZag Length", "Lookback for pivot search", "ZigZag")
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromHours(4))) \
.SetDisplay("Candle Type", "Type of candles to use", "General")
self._stop_loss_pct = self.Param("StopLossPct", 2.0) \
.SetDisplay("Stop Loss %", "Stop loss percentage", "Risk")
self._take_profit_pct = self.Param("TakeProfitPct", 3.0) \
.SetDisplay("Take Profit %", "Take profit percentage", "Risk")
self._highest = None
self._lowest = None
self._ha_open_prev = 0.0
self._ha_close_prev = 0.0
self._last_zigzag = 0.0
self._last_zigzag_high = 0.0
self._last_zigzag_low = 0.0
@property
def ma_period(self):
return self._ma_period.Value
@property
def zigzag_length(self):
return self._zigzag_length.Value
@property
def candle_type(self):
return self._candle_type.Value
@property
def stop_loss_pct(self):
return self._stop_loss_pct.Value
@property
def take_profit_pct(self):
return self._take_profit_pct.Value
def OnReseted(self):
super(ha_ma_zi_strategy, self).OnReseted()
self._highest = None
self._lowest = None
self._ha_open_prev = 0.0
self._ha_close_prev = 0.0
self._last_zigzag = 0.0
self._last_zigzag_high = 0.0
self._last_zigzag_low = 0.0
def OnStarted2(self, time):
super(ha_ma_zi_strategy, self).OnStarted2(time)
ema = ExponentialMovingAverage()
ema.Length = self.ma_period
self._highest = Highest()
self._highest.Length = self.zigzag_length
self._lowest = Lowest()
self._lowest.Length = self.zigzag_length
self.Indicators.Add(self._highest)
self.Indicators.Add(self._lowest)
subscription = self.SubscribeCandles(self.candle_type)
subscription.Bind(ema, self.on_candle).Start()
self.StartProtection(
takeProfit=Unit(self.take_profit_pct, UnitTypes.Percent),
stopLoss=Unit(self.stop_loss_pct, UnitTypes.Percent),
useMarketOrders=True)
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawIndicator(area, ema)
self.DrawOwnTrades(area)
def on_candle(self, candle, ema_val):
if candle.State != CandleStates.Finished:
return
cv_h = CandleIndicatorValue(self._highest, candle)
high_result = self._highest.Process(cv_h)
cv_l = CandleIndicatorValue(self._lowest, candle)
low_result = self._lowest.Process(cv_l)
if not high_result.IsFormed or not low_result.IsFormed:
return
highest = float(high_result)
lowest = float(low_result)
ema_val = float(ema_val)
o = float(candle.OpenPrice)
h = float(candle.HighPrice)
l = float(candle.LowPrice)
c = float(candle.ClosePrice)
ha_close = (o + h + l + c) / 4.0
if self._ha_open_prev == 0 and self._ha_close_prev == 0:
ha_open = (o + c) / 2.0
else:
ha_open = (self._ha_open_prev + self._ha_close_prev) / 2.0
ha_bull = ha_close > ha_open
ha_bear = ha_close < ha_open
if h >= highest and self._last_zigzag != h:
self._last_zigzag = h
self._last_zigzag_high = h
self._last_zigzag_low = 0.0
elif l <= lowest and self._last_zigzag != l:
self._last_zigzag = l
self._last_zigzag_low = l
self._last_zigzag_high = 0.0
if (self._last_zigzag == self._last_zigzag_low and self._last_zigzag_low > 0 and
ha_bull and c > ema_val and self.Position <= 0):
if self.Position < 0:
self.BuyMarket()
self.BuyMarket()
elif (self._last_zigzag == self._last_zigzag_high and self._last_zigzag_high > 0 and
ha_bear and c < ema_val and self.Position >= 0):
if self.Position > 0:
self.SellMarket()
self.SellMarket()
self._ha_open_prev = ha_open
self._ha_close_prev = ha_close
def CreateClone(self):
return ha_ma_zi_strategy()