From 19cb6b50bf1c618f75efc01e05a1f344b5b8a3d0 Mon Sep 17 00:00:00 2001 From: Mikhail Trubnikov Date: Thu, 11 Jun 2026 14:44:39 +1000 Subject: [PATCH] =?UTF-8?q?feat(api,core,domain):=20RobotSnapshot=20-=20?= =?UTF-8?q?=D0=BF=D0=BE=D1=87=D0=B0=D1=81=D0=BE=D0=B2=D0=BE=D0=B9=20=D0=BE?= =?UTF-8?q?=D1=82=D1=87=D0=B5=D1=82=20=D0=BE=20=D0=B7=D0=B0=D0=B3=D1=80?= =?UTF-8?q?=D1=83=D0=B7=D0=BA=D0=B5=20=D1=80=D0=BE=D0=B1=D0=BE=D1=82=D0=BE?= =?UTF-8?q?=D0=B2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- PARR.API/Contracts/V1/ApiRoutes.cs | 2 + PARR.API/Controllers/V1/TestController.cs | 23 ++- .../IRobotSnapshotService.cs | 17 +++ .../RobotSnapshotService.cs | 140 +++++++++++++++++- .../RobotSnapshotDTO/RobotAnalyticsQuery.cs | 16 ++ .../ServerHourlyAnalyticsDto.cs | 47 ++++++ 6 files changed, 243 insertions(+), 2 deletions(-) create mode 100644 PARR.Domain/DTOs/RobotSnapshotDTO/RobotAnalyticsQuery.cs create mode 100644 PARR.Domain/DTOs/RobotSnapshotDTO/ServerHourlyAnalyticsDto.cs diff --git a/PARR.API/Contracts/V1/ApiRoutes.cs b/PARR.API/Contracts/V1/ApiRoutes.cs index fa684666..0f2e903a 100644 --- a/PARR.API/Contracts/V1/ApiRoutes.cs +++ b/PARR.API/Contracts/V1/ApiRoutes.cs @@ -50,6 +50,8 @@ public const string GetNextRun = Base + "/tests/next-run"; public const string CreateCache = Base + "/tests/cache/"; + + public const string TestHandler = Base + "/tests/test/"; } public static class Template diff --git a/PARR.API/Controllers/V1/TestController.cs b/PARR.API/Controllers/V1/TestController.cs index e818bd37..e60bd570 100644 --- a/PARR.API/Controllers/V1/TestController.cs +++ b/PARR.API/Controllers/V1/TestController.cs @@ -10,9 +10,11 @@ using PARR.Core.Common.Interfaces; using PARR.Core.Repositories.Interfaces; using PARR.Core.Repositories.Interfaces.Unit; using PARR.Core.Services.NextRunServices; +using PARR.Core.Services.RobotSnapshotServices; using PARR.Core.Services.UnitService.Interfaces; using PARR.Core.Services.Workload.Implementations; using PARR.Domain.Cache; +using PARR.Domain.DTOs.RobotSnapshotDTO; namespace PARR.API.Controllers.V1 { @@ -27,6 +29,7 @@ namespace PARR.API.Controllers.V1 private readonly ILogger logger; private readonly IUnitService unitService; private readonly IUnitRepository unitRepository; + private readonly IRobotSnapshotService _robotSnapshotService; public TestController( IClientService clientService, @@ -37,7 +40,8 @@ namespace PARR.API.Controllers.V1 WorkloadCacheService workloadCacheService, ILogger logger, IUnitService unitService, - IUnitRepository unitRepository + IUnitRepository unitRepository, + IRobotSnapshotService robotSnapshotService ) { this.clientService = clientService; @@ -48,6 +52,7 @@ namespace PARR.API.Controllers.V1 this.logger = logger; this.unitService = unitService; this.unitRepository = unitRepository; + _robotSnapshotService = robotSnapshotService; } @@ -161,6 +166,22 @@ namespace PARR.API.Controllers.V1 } + /// + /// Тестовый метод + /// + /// + [HttpGet(ApiRoutes.Test.TestHandler)] + public async Task Test() + { + var data = await _robotSnapshotService.GetHourlyAnalyticsAsync(new RobotAnalyticsQuery + { + DateStart = DateTimeOffset.UtcNow.AddHours(-1), + DateEnd = DateTimeOffset.UtcNow, + Offset = TimeSpan.FromMinutes(600) + }); + + return Ok(data); + } diff --git a/PARR.Core/Services/RobotSnapshotServices/IRobotSnapshotService.cs b/PARR.Core/Services/RobotSnapshotServices/IRobotSnapshotService.cs index 6ac083f1..894e9dc2 100644 --- a/PARR.Core/Services/RobotSnapshotServices/IRobotSnapshotService.cs +++ b/PARR.Core/Services/RobotSnapshotServices/IRobotSnapshotService.cs @@ -4,8 +4,25 @@ namespace PARR.Core.Services.RobotSnapshotServices { public interface IRobotSnapshotService { + /// + /// Получить статистику + /// + /// + /// Task> GetAsync(RobotSnapshotQuery queryDto); + /// + /// Записать статистику + /// + /// + /// Task CreateAsync(CreateRobotSnapshot robotSnapshot); + + /// + /// Получить аналитику за период + /// + /// + /// + Task> GetHourlyAnalyticsAsync(RobotAnalyticsQuery queryDto); } } diff --git a/PARR.Core/Services/RobotSnapshotServices/RobotSnapshotService.cs b/PARR.Core/Services/RobotSnapshotServices/RobotSnapshotService.cs index 67738bc7..d208cf8d 100644 --- a/PARR.Core/Services/RobotSnapshotServices/RobotSnapshotService.cs +++ b/PARR.Core/Services/RobotSnapshotServices/RobotSnapshotService.cs @@ -64,7 +64,145 @@ namespace PARR.Core.Services.RobotSnapshotServices result.Add(new RobotSnapshotItemDto { Robot = userDto, Snapshots = snapshots }); } - return result.OrderBy(t => t.Robot.Ip).ThenBy(t => t.Robot.Name).ToList(); + return result.OrderBy(t => t.Robot.Name).ThenBy(t => t.Robot.Ip).ToList(); + } + + + public async Task> GetHourlyAnalyticsAsync(RobotAnalyticsQuery queryDto) + { + var snapshotsQuery = robotSnapshotRepository.Get() + .AsNoTracking() + .Where(t => queryDto.DateStart <= t.DateCreated && t.DateCreated <= queryDto.DateEnd); + + // Фильтруем по конкретному IP + if (!string.IsNullOrEmpty(queryDto.Ip)) + snapshotsQuery = snapshotsQuery.Where(t => t.Ip == queryDto.Ip); + + // Превращает TimeSpan в строку вида "+03:00" или "-05:00" + string formattedOffset = (queryDto.Offset >= TimeSpan.Zero ? "+" : "-") + + queryDto.Offset.ToString(@"hh\:mm"); + + // Группируем на стороне PostgreSQL с учетом часового пояса пользователя. + // Метод .Add(offset) сдвигает UTC-дату в Postgres на интервал времени пользователя, + // благодаря чему минуты объединяются в правильные локальные "часовые корзины". + var rawGroupedData = await snapshotsQuery + .GroupBy(t => new + { + t.Ip, + // Явно сдвигаем дату и достаем только нужные компоненты + Year = (t.DateCreated + queryDto.Offset).DateTime.Year, + Month = (t.DateCreated + queryDto.Offset).DateTime.Month, + Day = (t.DateCreated + queryDto.Offset).DateTime.Day, + Hour = (t.DateCreated + queryDto.Offset).DateTime.Hour + }) + .Select(g => new + { + g.Key.Ip, + // Вытаскиваем компоненты даты из уже смещенного локального времени + LocalYear = g.Key.Year, + LocalMonth = g.Key.Month, + LocalDay = g.Key.Day, + LocalHour = g.Key.Hour, + + MaxAllowed = g.Max(t => t.MaxRobots), + MaxTemplates = g.Max(t => t.TemplateRobotsCount), + MaxSchedules = g.Max(t => t.ScheduleRobotsCount), + SumTemplates = g.Sum(t => t.TemplateRobotsCount), + SumSchedules = g.Sum(t => t.ScheduleRobotsCount) + }) + .ToListAsync(); + + if (!rawGroupedData.Any()) + return new List(); + + // Получаем информацию о серверах + var serverIps = rawGroupedData.Select(g => g.Ip).ToHashSet(); + var serverDictionary = await userRepository.Get() + .AsNoTracking() + .Where(t => serverIps.Contains(t.Ip)) + .ToDictionaryAsync(t => t.Ip); + + // Группируем полученные агрегаты по серверам уже в памяти веб-сервера + var dataByServers = rawGroupedData.GroupBy(g => g.Ip); + var result = new List(); + + // Принудительно переводим UTC-границы запроса в локальное время пользователя для корректной генерации "дыр" + var localStart = queryDto.DateStart.ToOffset(queryDto.Offset).DateTime; + var localEnd = queryDto.DateEnd.ToOffset(queryDto.Offset).DateTime; + + // Округляем начальный час до ровного значения (00 минут, 00 секунд) + var startHour = new DateTime(localStart.Year, localStart.Month, localStart.Day, localStart.Hour, 0, 0); + + foreach (var serverGroup in dataByServers) + { + serverDictionary.TryGetValue(serverGroup.Key, out var robotInfo); + + var userDto = new UserBaseDto + { + Ip = serverGroup.Key, + Description = robotInfo?.Description ?? string.Empty, + Name = robotInfo?.Name ?? string.Empty + }; + + // Формируем точки, которые удалось вытащить из базы данных + var hourlyPoints = serverGroup.Select(g => new RobotHourlyPointDto + { + // Возвращаем дату со смещением пользователя, чтобы Angular сразу отображал правильный час + Hour = new DateTimeOffset(g.LocalYear, g.LocalMonth, g.LocalDay, g.LocalHour, 0, 0, TimeSpan.Zero), + MaxAllowedRobots = g.MaxAllowed, + MaxTemplateRobots = g.MaxTemplates, + MaxScheduleRobots = g.MaxSchedules, + // Считаем среднее количество роботов, деля поминутную сумму строго на 60 минут часа + AvgTemplateRobots = Math.Round(g.SumTemplates / 60.0, 1), + AvgScheduleRobots = Math.Round(g.SumSchedules / 60.0, 1) + }) + .ToList(); + + // Алгоритм заполнения пропусков во времени (если сервер был выключен) + var filledPoints = new List(); + var currentHour = startHour; + int lastKnownMax = hourlyPoints.FirstOrDefault()?.MaxAllowedRobots ?? 0; + + while (currentHour <= localEnd) + { + // Создаем временную точку со смещением для точного сопоставления + var targetOffsetDateTime = new DateTimeOffset(currentHour, TimeSpan.Zero); + var point = hourlyPoints.FirstOrDefault(p => p.Hour == targetOffsetDateTime); + + if (point != null) + { + filledPoints.Add(point); + lastKnownMax = point.MaxAllowedRobots; + } + else + { + // Если за этот час записей в БД нет — значит, сервер был полностью оффлайн. + // Выводим нули, чтобы график в Angular не прерывался, а плавно падал. + filledPoints.Add(new RobotHourlyPointDto + { + Hour = targetOffsetDateTime, + MaxAllowedRobots = lastKnownMax, + MaxTemplateRobots = 0, + AvgTemplateRobots = 0, + MaxScheduleRobots = 0, + AvgScheduleRobots = 0 + }); + } + // Шагаем строго на +1 час вперед по локальному времени клиента + currentHour = currentHour.AddHours(1); + } + + result.Add(new ServerHourlyAnalyticsDto + { + Robot = userDto, + Snapshots = filledPoints.OrderBy(p => p.Hour).ToList() + }); + } + + return result + .OrderBy(t => t.Robot.Name) + .ThenBy(t => t.Robot.Ip) + .ToList(); } diff --git a/PARR.Domain/DTOs/RobotSnapshotDTO/RobotAnalyticsQuery.cs b/PARR.Domain/DTOs/RobotSnapshotDTO/RobotAnalyticsQuery.cs new file mode 100644 index 00000000..f9f54a81 --- /dev/null +++ b/PARR.Domain/DTOs/RobotSnapshotDTO/RobotAnalyticsQuery.cs @@ -0,0 +1,16 @@ +namespace PARR.Domain.DTOs.RobotSnapshotDTO +{ + public record RobotAnalyticsQuery + { + public DateTimeOffset DateStart { get; init; } + + public DateTimeOffset DateEnd { get; init; } + + /// + /// Смещение часового пояса + /// + public TimeSpan Offset { get; init; } + + public string? Ip { get; init; } + } +} diff --git a/PARR.Domain/DTOs/RobotSnapshotDTO/ServerHourlyAnalyticsDto.cs b/PARR.Domain/DTOs/RobotSnapshotDTO/ServerHourlyAnalyticsDto.cs new file mode 100644 index 00000000..bca8ba7d --- /dev/null +++ b/PARR.Domain/DTOs/RobotSnapshotDTO/ServerHourlyAnalyticsDto.cs @@ -0,0 +1,47 @@ +using PARR.Domain.DTOs.User; + +namespace PARR.Domain.DTOs.RobotSnapshotDTO +{ + /// + /// Аналитика по снапшотам роботов + /// + public record ServerHourlyAnalyticsDto + { + public UserBaseDto Robot { get; init; } = null!; + + /// + /// Почасовая статистика для гарфиков + /// + public List Snapshots { get; set; } = new(); + } + + /// + /// Почасовая статистика по снапшотам роботов + /// + public record RobotHourlyPointDto + { + public DateTimeOffset Hour { get; set; } + + public int MaxAllowedRobots { get; set; } + + /// + /// Максимальное кол-во роботов работающих одновременно по шаблонам + /// + public int MaxTemplateRobots { get; set; } + + /// + /// Сколько роботов в среднем, работало в течении часа + /// + public double AvgTemplateRobots { get; set; } + + /// + /// Максимальное кол-во роботов работающих одновременно по расписаниям + /// + public int MaxScheduleRobots { get; set; } + + /// + /// Сколько роботов в среднем, работало в течении часа + /// + public double AvgScheduleRobots { get; set; } + } +}