中文 ZH
在 GitHub 上查看

订单关闭状态邮件与警报策略

该策略监控账户并在关键事件发生时发送通知：

  • 在指定的分钟发送每日状态报告。
  • 在每个订单关闭时发送通知。

该策略基于 MQL 专家 StatusMailandAlertOnOrderClose.mq4，演示如何在 StockSharp 中处理通知。

参数

名称 说明
SendReportEmail 是否在每日指定时间发送状态报告。
StatusEmailMinute 发送状态信息的分钟。
SendClosedEmail 是否在订单关闭时发送通知。
StartBalance 用于计算收益的初始账户余额。
CandleType 用于检查时间的K线周期，通常为1分钟。

逻辑

  1. 订阅所选时间框架的K线。
  2. 当K线收盘时检查是否到达指定分钟并发送报告。
  3. 在每个新成交产生时，如果订单已关闭则发送通知。

通知通过 AddInfo 记录，可替换为任何需要的通知机制。

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>
/// EMA crossover with status tracking.
/// </summary>
public class StatusMailAndAlertOnOrderCloseStrategy : Strategy
{
	private readonly StrategyParam<int> _fastLength;
	private readonly StrategyParam<int> _slowLength;
	private readonly StrategyParam<DataType> _candleType;

	private decimal _prevFast;
	private decimal _prevSlow;
	private bool _hasPrev;

	public int FastLength { get => _fastLength.Value; set => _fastLength.Value = value; }
	public int SlowLength { get => _slowLength.Value; set => _slowLength.Value = value; }
	public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }

	public StatusMailAndAlertOnOrderCloseStrategy()
	{
		_fastLength = Param(nameof(FastLength), 9)
			.SetGreaterThanZero()
			.SetDisplay("Fast EMA", "Fast EMA period", "Indicators");
		_slowLength = Param(nameof(SlowLength), 26)
			.SetGreaterThanZero()
			.SetDisplay("Slow EMA", "Slow EMA period", "Indicators");
		_candleType = Param(nameof(CandleType), TimeSpan.FromHours(4).TimeFrame())
			.SetDisplay("Candle Type", "Type of candles", "General");
	}

	public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
		=> [(Security, CandleType)];

	protected override void OnReseted()
	{
		base.OnReseted();
		_prevFast = 0; _prevSlow = 0; _hasPrev = false;
	}

	protected override void OnStarted2(DateTime time)
	{
		base.OnStarted2(time);
		var fast = new ExponentialMovingAverage { Length = FastLength };
		var slow = new ExponentialMovingAverage { Length = SlowLength };
		SubscribeCandles(CandleType).Bind(fast, slow, ProcessCandle).Start();
	}

	private void ProcessCandle(ICandleMessage candle, decimal fast, decimal slow)
	{
		if (candle.State != CandleStates.Finished) return;
		if (!_hasPrev) { _prevFast = fast; _prevSlow = slow; _hasPrev = true; return; }

		if (_prevFast <= _prevSlow && fast > slow)
		{ if (Position < 0) BuyMarket(); if (Position <= 0) BuyMarket(); }
		else if (_prevFast >= _prevSlow && fast < slow)
		{ if (Position > 0) SellMarket(); if (Position >= 0) SellMarket(); }

		_prevFast = fast; _prevSlow = slow;
	}
}