自定义时间周期

自定义时间周期 API 提供了一些类型，使您能够直接在 cTrader 图表中显示来自任何来源的自定义 OHLC 数据，包括第三方 API、合成计算或本地文件。 API 实体（如 CustomTimeFrame 和 TimeFrameManager）允许您从特定数据源流式传输K线，并在 cTrader 中将其显示为完整的周期。

重要类型包括：

TimeFrameManager.Custom.Add(name) 用于注册具有用户定义名称的新自定义周期。
CustomTimeFrame.BarsNeeded 用于定义如何以及何时为图表加载数据。
CustomBars.AppendBars()、CustomBars.UpdateLastBar()、CustomBars.PrependBars() 用于动态管理序列，其中每个 CustomBar 包含以下六个字段：time、open、high、low、close 和 volume。

添加后，自定义周期会无缝集成到 cTrader 周期 UI 中，并与内置周期一起出现在下拉菜单中。用户可以轻松地在标准周期和自定义周期之间切换。

提示

使用自定义周期来可视化外部市场、模拟实验性K线类型、创建高级相关性/套利图表或在定制数据上进行策略回测。

自定义时间周期 API 对象可用于执行以下操作：

功能或操作	示例
显示替代市场数据	从 REST API 加载K线（例如 AlphaVantage）可视化平台外价格
模拟合成K线类型	创建平均K线、砖形图或成交量K线从情绪或经济指数生成K线
离线数据测试	从 CSV 或 JSON 文件加载自定义K线在专有数据集上进行回测
跨资产策略叠加	在 EUR/USD 图表上绘制 GBP/USD 开发套利模型
增强 UI 控制	切换、收藏或修改自定义周期

基于现有数据创建自定义周期

此插件演示了如何在 cTrader 中创建和显示合成日内周期。

该插件通过获取活动交易品种的原生一分钟K线，将它们聚合成 25 分钟 OHLC 蜡烛图，然后将结果流式传输到 CustomBar 系列，从而构建 25 分钟时间周期。
新的时间周期在选择时间周期的下拉菜单中显示为 25Min。
当用户在图表上向后滚动时，插件会自动加载更多的分钟数据，在前面添加较早的 25 分钟K线，并保持视图更新。

using System;
using System.Linq;                 
using cAlgo.API;
using cAlgo.API.Internals;

namespace cAlgo.Plugins
{
    [Plugin(AccessRights = AccessRights.None)]
    public class TF25 : Plugin
    {
        private CustomTimeFrame _tf25Min;
        private bool _isLoadMoreEnabled = true;

        protected override void OnStart()
        {
            // Create the 25-minute TF
            _tf25Min = TimeFrameManager.Custom.Add("25Min");
            _tf25Min.Description = "25‑minute aggregated from 1‑minute bars";

            // Hook initial load and on‑scroll‑back
            _tf25Min.NewChart += OnNewChart;
            _tf25Min.BarsNeeded = OnBarsNeeded;
        }

        private void OnNewChart(CustomTimeFrameNewChartEventArgs args)
        {
            var cb    = args.CustomBars;
            var chart = args.Chart;

            // Show a loading indicator
            var loading = new TextBlock { Text = "Loading 25‑min bars…", FontSize = 12 };
            chart.AddControl(loading);

            // Fetch the 1‑min bars and aggregate
            MarketData.GetBarsAsync(TimeFrame.Minute, cb.Symbol.Name, minuteBars =>
            {
                var aggregated = minuteBars
                    .Select((bar, idx) => new { bar, idx })
                    .GroupBy(x => x.idx / 25)
                    .Select(g =>
                    {
                        var first = g.First().bar;
                        var last  = g.Last().bar;
                        return new CustomBar(
                            time:        first.OpenTime,
                            open:        first.Open,
                            high:        g.Max(x => x.bar.High),
                            low:         g.Min(x => x.bar.Low),
                            close:       last.Close,
                            volume:  g.Sum(x => (int)x.bar.TickVolume)
                        );
                    });

                chart.RemoveControl(loading);


            });
        }

        private void OnBarsNeeded(CustomTimeFrameBarsNeededArgs args)
        {
            var cb = args.CustomBars;

            // Same logic for explicit BarsNeeded triggers
            MarketData.GetBarsAsync(TimeFrame.Minute, cb.Symbol.Name, minuteBars =>
            {
                var aggregated = minuteBars
                    .Select((bar, idx) => new { bar, idx })
                    .GroupBy(x => x.idx / 25)
                    .Select(g => new CustomBar(
                        time:        g.First().bar.OpenTime,
                        open:        g.First().bar.Open,
                        high:        g.Max(x => x.bar.High),
                        low:         g.Min(x => x.bar.Low),
                        close:       g.Last().bar.Close,
                        volume:  g.Sum(x => (int)x.bar.TickVolume)
                    ));
                cb.AppendBars(aggregated);
                 args.CustomBars.NeedsMore += _ =>
                {
                    if (!_isLoadMoreEnabled)
                    {
                        Print("Load‑more disabled; skipping additional bars.");
                        return;
                    }

                    Print("NeedsMore fired; loading more history…");
                    minuteBars.LoadMoreHistoryAsync(loadArgs =>
                    {
                        Print($"Loaded {loadArgs.Count} more 1‑min bars");
                        if (loadArgs.Count == 0)
                            return;

                        Sleep(TimeSpan.FromSeconds(1));
                        args.CustomBars.PrependBars(minuteBars.Take(loadArgs.Count).Select(bar => new CustomBar(bar.OpenTime, bar.Open, bar.High, bar.Low, bar.Close, (int)bar.TickVolume)));
                    });
                };
            });
        }

        protected override void OnStop()
        {
        }
    }
}

使用外部数据创建自定义周期

此插件演示了如何使用自定义时间周期 API 对象在 cTrader 图表中获取和显示外部金融数据。

该插件通过从 AlphaVantage API 检索 IBM 的历史每日 OHLC 数据，在 cTrader 中创建自定义周期。
它解析 CSV 响应并将数据加载到 CustomBar 系列中，然后在图表 UI 中显示为可选择的名为 AlphaVantage 的自定义周期。

using System;
using System.Collections.Generic;
using cAlgo.API;
using cAlgo.API.Collections;
using cAlgo.API.Indicators;
using cAlgo.API.Internals;

namespace cAlgo.Plugins
{
    [Plugin(AccessRights = AccessRights.None)]
    public class CustomTimeFrameAlphaVantage : Plugin
    {
        private const string ApiKey = "YOUR_ALPHA_VANTAGE_KEY";
        private const string Symbol = "IBM";
        private const string Endpoint = $"https://www.alphavantage.co/query?function=TIME_SERIES_DAILY&symbol={Symbol}&apikey={ApiKey}&datatype=csv&outputsize=full";

        private CustomTimeFrame _customTimeFrame;

        protected override void OnStart()
        {
            _customTimeFrame = TimeFrameManager.Custom.Add("AlphaVantage");

            _customTimeFrame.Description = "Loads data from AlphaVantage";

            _customTimeFrame.BarsNeeded = args => 
            {
                var response = Http.Get(new Uri(Endpoint));

                if (!response.IsSuccessful)
                {
                    Print($"Error loading data from AlphaVantage, status code: {response.StatusCode}, body: {response.Body}");
                    return;
                }

                Print($"Response Received: {response.StatusCode}");

                var ohlcData = response.Body.Split(Environment.NewLine)[1..];

                Array.Reverse(ohlcData);

                Print($"ohlcData Count: {ohlcData.Length}");

                var bars = new List<CustomBar>();

                foreach (var ohlc in ohlcData)
                {
                    var ohlcSplit = ohlc.Split(',');

                    if (ohlcSplit.Length < 6) continue;

                    var time = DateTime.Parse(ohlcSplit[0]);
                    var open = double.Parse(ohlcSplit[1]);
                    var high = double.Parse(ohlcSplit[2]);
                    var low = double.Parse(ohlcSplit[3]);
                    var close = double.Parse(ohlcSplit[4]);
                    var volume = long.Parse(ohlcSplit[5]);

                    bars.Add(new CustomBar(time, open, high, low, close, volume));
                }

                Print($"AppendBars Count: {bars.Count}");

                args.CustomBars.AppendBars(bars);
            };
        }

        protected override void OnStop()
        {
            // Handle Plugin stop here
        }
    }
}