From 9b5465a742975cb987b3682137878daf8ccf6c4d Mon Sep 17 00:00:00 2001 From: Roman Efremov Date: Mon, 27 Jan 2025 14:53:07 +0500 Subject: [PATCH] =?UTF-8?q?=D0=A4=D0=B8=D0=BA=D1=81=20=D0=BA=D0=BB=D0=B8?= =?UTF-8?q?=D0=B5=D0=BD=D1=82=D0=B0=20TimestampedValuesClient?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Clients/Interfaces/ITimestampedValuesClient.cs | 11 +++++++++++ .../Clients/TimestampedValuesClient.cs | 9 +++++++++ 2 files changed, 20 insertions(+) diff --git a/DD.Persistence.Client/Clients/Interfaces/ITimestampedValuesClient.cs b/DD.Persistence.Client/Clients/Interfaces/ITimestampedValuesClient.cs index e7d7be6..27449b2 100644 --- a/DD.Persistence.Client/Clients/Interfaces/ITimestampedValuesClient.cs +++ b/DD.Persistence.Client/Clients/Interfaces/ITimestampedValuesClient.cs @@ -35,6 +35,17 @@ public interface ITimestampedValuesClient : IDisposable int take, CancellationToken token); + /// + /// Получить данные с фильтрацией для нескольких систем. Значение фильтра null - отключен + /// + /// + /// + /// Фильтр свойств набора + /// + /// + /// + Task> Get(Guid discriminatorId, DateTimeOffset? geTimestamp, IEnumerable? columnNames, int skip, int take, CancellationToken token); + /// /// Получить данные, начиная с заданной отметки времени /// diff --git a/DD.Persistence.Client/Clients/TimestampedValuesClient.cs b/DD.Persistence.Client/Clients/TimestampedValuesClient.cs index 4c77b20..123ed71 100644 --- a/DD.Persistence.Client/Clients/TimestampedValuesClient.cs +++ b/DD.Persistence.Client/Clients/TimestampedValuesClient.cs @@ -39,6 +39,15 @@ public class TimestampedValuesClient : BaseClient, ITimestampedValuesClient return result!; } + /// + public async Task> Get(Guid discriminatorId, DateTimeOffset? geTimestamp, IEnumerable? columnNames, int skip, int take, CancellationToken token) + { + var data = await Get([discriminatorId], geTimestamp, columnNames, skip, take, token); + var mapper = GetMapper(discriminatorId); + + return data.Select(mapper.DeserializeTimeStampedData); + } + /// public async Task> GetGtDate(Guid discriminatorId, DateTimeOffset timestampBegin, CancellationToken token) {