Nevalyashka 翻转策略
将 MetaTrader 专家顾问 “Nevalyashka” 直接移植到 StockSharp。策略始终在多空之间交替:先市价卖出,等待仓位被止损或止盈平仓,然后立即以相同的手数反向开仓。每次进场后都会根据设定的点数重新创建保护性订单,与原始 MQL 逻辑完全一致。
策略逻辑
- 初始化
- 读取品种的最小报价步长和小数位数,计算与 MQL 版本一致的点值(3/5 位小数的品种乘以 10)。
- 用参数
LotMultiplier乘以交易所的MinVolume得到下单手数,并根据VolumeStep进行向上取整。
- 行情处理
- 订阅盘口更新,实时获取最新买一/卖一价,相当于专家顾问中的
RefreshRates()调用。
- 订阅盘口更新,实时获取最新买一/卖一价,相当于专家顾问中的
- 下单流程
- 在获取到行情后先发出第一笔市价卖单。
- 仓位平掉后立即反向开仓(卖单后跟随买单,买单后跟随卖单),手数保持不变。
- 每次成交后根据点数参数提交新的止损与止盈订单。
风险管理
- 止损:当
StopLossPips大于 0 时,策略会在入场价 ± StopLossPips * 点值位置挂出保护性止损单(多单使用SellStop,空单使用BuyStop)。 - 止盈:当
TakeProfitPips大于 0 时,会在入场价 ± TakeProfitPips * 点值位置挂出保护性限价单(多单使用SellLimit,空单使用BuyLimit)。 - 每次仓位归零都会取消旧的保护性订单,防止未平掉的挂单影响下一次反向开仓。
参数
| 名称 | 说明 | 默认值 |
|---|---|---|
LotMultiplier |
乘以交易所最小交易量后的手数,最终会四舍五入到交易所的量化步长。 | 1 |
StopLossPips |
止损距离(点)。设置为 0 可关闭止损。 |
50 |
TakeProfitPips |
止盈距离(点)。设置为 0 可关闭止盈。 |
50 |
使用提示
- 策略始终保持在多空之间轮换,适合节奏平缓、倾向于均值回归的市场环境。
- 只要标的能够提供盘口最优报价即可运行,点值会根据报价精度自动调整。
- 订单以市价形式发送,滑点控制完全交由交易所,和原始专家顾问一致。
- 没有包含交易时段过滤、新闻过滤或移动止损,如有需要可在
TryOpenNextPosition或RegisterProtectionOrders中扩展。
using System;
using System.Linq;
using System.Collections.Generic;
using Ecng.Common;
using Ecng.Collections;
using Ecng.Serialization;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.BusinessEntities;
using StockSharp.Messages;
namespace StockSharp.Samples.Strategies;
/// <summary>
/// Alternating long-short strategy that mirrors the original Nevalyashka MQL logic.
/// Opens an initial sell position and flips direction each time the position is closed.
/// </summary>
public class NevalyashkaFlipStrategy : Strategy
{
private readonly StrategyParam<int> _stopLossPoints;
private readonly StrategyParam<int> _takeProfitPoints;
private readonly StrategyParam<DataType> _candleType;
private decimal _entryPrice;
private Sides? _currentSide;
private Sides? _lastCompletedSide;
/// <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>
/// Candle type for monitoring price.
/// </summary>
public DataType CandleType
{
get => _candleType.Value;
set => _candleType.Value = value;
}
/// <summary>
/// Initializes a new instance of the <see cref="NevalyashkaFlipStrategy"/> class.
/// </summary>
public NevalyashkaFlipStrategy()
{
_stopLossPoints = Param(nameof(StopLossPoints), 5)
.SetGreaterThanZero()
.SetDisplay("Stop Loss (pts)", "Stop loss distance in price steps", "Risk");
_takeProfitPoints = Param(nameof(TakeProfitPoints), 5)
.SetGreaterThanZero()
.SetDisplay("Take Profit (pts)", "Take profit distance in price steps", "Risk");
_candleType = Param(nameof(CandleType), TimeSpan.FromHours(4).TimeFrame())
.SetDisplay("Candle Type", "Candle timeframe", "General");
}
/// <inheritdoc />
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
{
return [(Security, CandleType)];
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_entryPrice = 0m;
_currentSide = null;
_lastCompletedSide = null;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
var subscription = SubscribeCandles(CandleType);
subscription.Bind(ProcessCandle).Start();
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawOwnTrades(area);
}
}
private void ProcessCandle(ICandleMessage candle)
{
if (candle.State != CandleStates.Finished)
return;
var step = Security?.PriceStep ?? 1m;
var stopDistance = StopLossPoints * step;
var takeDistance = TakeProfitPoints * step;
var price = candle.ClosePrice;
// Check SL/TP for current position
if (Position != 0 && _entryPrice > 0)
{
var hit = false;
if (_currentSide == Sides.Buy)
{
if (stopDistance > 0 && candle.LowPrice <= _entryPrice - stopDistance)
hit = true;
if (takeDistance > 0 && candle.HighPrice >= _entryPrice + takeDistance)
hit = true;
}
else if (_currentSide == Sides.Sell)
{
if (stopDistance > 0 && candle.HighPrice >= _entryPrice + stopDistance)
hit = true;
if (takeDistance > 0 && candle.LowPrice <= _entryPrice - takeDistance)
hit = true;
}
if (hit)
{
// Close position
if (Position > 0)
SellMarket();
else if (Position < 0)
BuyMarket();
_lastCompletedSide = _currentSide;
_currentSide = null;
_entryPrice = 0m;
}
}
// If flat, open next position
if (Position == 0 && _currentSide == null)
{
// Alternate direction: start with sell, then flip
var sideToOpen = _lastCompletedSide switch
{
Sides.Buy => Sides.Sell,
Sides.Sell => Sides.Buy,
_ => Sides.Sell,
};
if (sideToOpen == Sides.Buy)
BuyMarket();
else
SellMarket();
_currentSide = sideToOpen;
_entryPrice = price;
}
}
}
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.Strategies import Strategy
class nevalyashka_flip_strategy(Strategy):
"""Alternating long-short strategy that flips direction each time position is closed."""
def __init__(self):
super(nevalyashka_flip_strategy, self).__init__()
self._stop_loss_points = self.Param("StopLossPoints", 5) \
.SetGreaterThanZero() \
.SetDisplay("Stop Loss (pts)", "Stop loss distance in price steps", "Risk")
self._take_profit_points = self.Param("TakeProfitPoints", 5) \
.SetGreaterThanZero() \
.SetDisplay("Take Profit (pts)", "Take profit distance in price steps", "Risk")
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromHours(4))) \
.SetDisplay("Candle Type", "Candle timeframe", "General")
self._entry_price = 0.0
self._current_side = 0 # 0=none, 1=buy, -1=sell
self._last_completed_side = 0
@property
def StopLossPoints(self):
return int(self._stop_loss_points.Value)
@property
def TakeProfitPoints(self):
return int(self._take_profit_points.Value)
@property
def CandleType(self):
return self._candle_type.Value
def OnStarted2(self, time):
super(nevalyashka_flip_strategy, self).OnStarted2(time)
self._entry_price = 0.0
self._current_side = 0
self._last_completed_side = 0
subscription = self.SubscribeCandles(self.CandleType)
subscription.Bind(self.process_candle).Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawOwnTrades(area)
def process_candle(self, candle):
if candle.State != CandleStates.Finished:
return
sec = self.Security
step = float(sec.PriceStep) if sec is not None and sec.PriceStep is not None and float(sec.PriceStep) > 0 else 1.0
stop_dist = self.StopLossPoints * step
take_dist = self.TakeProfitPoints * step
price = float(candle.ClosePrice)
# Check SL/TP for current position
if self.Position != 0 and self._entry_price > 0:
hit = False
if self._current_side == 1:
if stop_dist > 0 and float(candle.LowPrice) <= self._entry_price - stop_dist:
hit = True
if take_dist > 0 and float(candle.HighPrice) >= self._entry_price + take_dist:
hit = True
elif self._current_side == -1:
if stop_dist > 0 and float(candle.HighPrice) >= self._entry_price + stop_dist:
hit = True
if take_dist > 0 and float(candle.LowPrice) <= self._entry_price - take_dist:
hit = True
if hit:
if self.Position > 0:
self.SellMarket()
elif self.Position < 0:
self.BuyMarket()
self._last_completed_side = self._current_side
self._current_side = 0
self._entry_price = 0.0
# If flat, open next position
if self.Position == 0 and self._current_side == 0:
# Alternate: start with sell, then flip
if self._last_completed_side == 1:
side_to_open = -1
elif self._last_completed_side == -1:
side_to_open = 1
else:
side_to_open = -1
if side_to_open == 1:
self.BuyMarket()
else:
self.SellMarket()
self._current_side = side_to_open
self._entry_price = price
def OnReseted(self):
super(nevalyashka_flip_strategy, self).OnReseted()
self._entry_price = 0.0
self._current_side = 0
self._last_completed_side = 0
def CreateClone(self):
return nevalyashka_flip_strategy()