颜色 Schaff JCCX 趋势循环策略
该策略是 MQL5 专家 Exp_ColorSchaffJCCXTrendCycle 的 C# 版本,
使用基于 JCCX 算法的 Schaff 趋势循环 (STC) 振荡器。
交易逻辑
- 在每根完成的蜡烛上计算 Schaff 趋势循环。
- 当振荡器在高于
High Level后跌破该水平时,开多单并平空单。 - 当振荡器在低于
Low Level后突破该水平时,开空单并平多单。
参数
| 名称 | 说明 |
|---|---|
| Fast JCCX | 指标中使用的快速 JCCX 周期。 |
| Slow JCCX | 指标中使用的慢速 JCCX 周期。 |
| Smoothing | JCCX 的 JJMA 平滑因子。 |
| Phase | JJMA 相位值。 |
| Cycle | Schaff 趋势计算的周期长度。 |
| High Level | 振荡器的上触发水平。 |
| Low Level | 振荡器的下触发水平。 |
| Open Long | 允许开多。 |
| Open Short | 允许开空。 |
| Close Long | 允许平多。 |
| Close Short | 允许平空。 |
说明
策略使用 StockSharp 的高级 API,并订阅蜡烛数据。只对已完成的蜡烛作出反应。资金管理和风险控制仅用于演示目的。
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>
/// Strategy based on the Schaff Trend Cycle indicator level crossovers.
/// </summary>
public class ColorSchaffJccxTrendCycleStrategy : Strategy
{
private readonly StrategyParam<decimal> _highLevel;
private readonly StrategyParam<decimal> _lowLevel;
private readonly StrategyParam<DataType> _candleType;
private decimal? _prev;
public decimal HighLevel { get => _highLevel.Value; set => _highLevel.Value = value; }
public decimal LowLevel { get => _lowLevel.Value; set => _lowLevel.Value = value; }
public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }
public ColorSchaffJccxTrendCycleStrategy()
{
_highLevel = Param(nameof(HighLevel), 75m)
.SetDisplay("High Level", "Upper trigger level", "Signal");
_lowLevel = Param(nameof(LowLevel), 25m)
.SetDisplay("Low Level", "Lower trigger level", "Signal");
_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();
_prev = null;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
var stc = new SchaffTrendCycle();
var subscription = SubscribeCandles(CandleType);
subscription
.Bind(stc, ProcessCandle)
.Start();
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, stc);
DrawOwnTrades(area);
}
}
private void ProcessCandle(ICandleMessage candle, decimal stc)
{
if (candle.State != CandleStates.Finished)
return;
if (_prev is null)
{
_prev = stc;
return;
}
if (_prev > HighLevel && stc <= HighLevel && Position <= 0)
{
if (Position < 0) BuyMarket();
BuyMarket();
}
else if (_prev < LowLevel && stc >= LowLevel && Position >= 0)
{
if (Position > 0) SellMarket();
SellMarket();
}
_prev = stc;
}
}
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 SchaffTrendCycle
from StockSharp.Algo.Strategies import Strategy
class color_schaff_jccx_trend_cycle_strategy(Strategy):
def __init__(self):
super(color_schaff_jccx_trend_cycle_strategy, self).__init__()
self._high_level = self.Param("HighLevel", 75.0) \
.SetDisplay("High Level", "Upper trigger level", "Signal")
self._low_level = self.Param("LowLevel", 25.0) \
.SetDisplay("Low Level", "Lower trigger level", "Signal")
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromHours(4))) \
.SetDisplay("Candle Type", "Candle timeframe", "General")
self._prev = None
@property
def high_level(self):
return self._high_level.Value
@property
def low_level(self):
return self._low_level.Value
@property
def candle_type(self):
return self._candle_type.Value
def OnReseted(self):
super(color_schaff_jccx_trend_cycle_strategy, self).OnReseted()
self._prev = None
def OnStarted2(self, time):
super(color_schaff_jccx_trend_cycle_strategy, self).OnStarted2(time)
stc = SchaffTrendCycle()
subscription = self.SubscribeCandles(self.candle_type)
subscription.Bind(stc, self.process_candle).Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawIndicator(area, stc)
self.DrawOwnTrades(area)
def process_candle(self, candle, stc_val):
if candle.State != CandleStates.Finished:
return
stc_val = float(stc_val)
if self._prev is None:
self._prev = stc_val
return
if self._prev > float(self.high_level) and stc_val <= float(self.high_level) and self.Position <= 0:
if self.Position < 0:
self.BuyMarket()
self.BuyMarket()
elif self._prev < float(self.low_level) and stc_val >= float(self.low_level) and self.Position >= 0:
if self.Position > 0:
self.SellMarket()
self.SellMarket()
self._prev = stc_val
def CreateClone(self):
return color_schaff_jccx_trend_cycle_strategy()