@@ -0,0 +30,4 @@
+
+	public void Dispose()
+	{
+		dataSourceSystemClient.Dispose();

@@ -44,3 +44,3 @@
 	/// Получить статистику по системам
 	/// </summary>
-	/// <param name="autoDrillingSystem"></param>
+	/// <param name="systemIds"></param>

@@ -36,2 +35,3 @@
+	public async Task<IEnumerable<DataSourceSystemDto>> GetSystems(CancellationToken token)
 	{
-		var result = await ExecuteGetResponse<IEnumerable<string>>(
+		var result = await ExecuteGetResponse<IEnumerable<DataSourceSystemDto>>(

@@ -63,3 +62,4 @@
+			async () => await refitTechMessagesClient.GetStatistics(systemIds, categoryIds, token), token);
 
 		return result;
 	}

@@ -100,3 +100,3 @@
 			{
 				//act
-				var response = await techMessagesClient.AddRange(dtos, new CancellationToken());
+				var response = await techMessagesClient.AddRange(systemId, dtos, new CancellationToken());

@@ -136,0 +128,4 @@
+		public async Task GetSystems_AfterSave_returns_success()
+		{
+			//arrange
+			var dtos = await InsertRange(Guid.NewGuid());

@@ -153,3 +149,2 @@
 
-            var importantId = 1;
-            var autoDrillingSystem = nameof(TechMessageDto.System);
+			var imortantIds = new [] { 1 };

@@ -173,0 +162,4 @@
+		public async Task GetStatistics_AfterSave_returns_success()
+		{
+			//arrange
+			var categoryIds = new[] { 1 };

@@ -0,0 +7,4 @@
+{
+    private static readonly string SystemCacheKey = $"{typeof(Database.Entity.DataSourceSystem).FullName}CacheKey";
+    private readonly IMemoryCache memoryCache;
+    private const int CacheExpirationInMinutes = 60;

@@ -0,0 +22,4 @@
+
+    public override async Task<IEnumerable<DataSourceSystemDto>> Get(CancellationToken token)
+    {
+        var systems = await memoryCache.GetOrCreateAsync(SystemCacheKey, async f =>

@@ -0,0 +25,4 @@
+	{
+		var entity = dataSourceSystemDto.Adapt<DataSourceSystem>();
+
+		await db.Set<DataSourceSystem>().AddAsync(entity);

@@ -0,0 +32,4 @@
+	public virtual async Task<IEnumerable<DataSourceSystemDto>> Get(CancellationToken token)
+	{
+	    var query = GetQueryReadOnly();
+	    var entities = await query.ToListAsync(token);

@@ -66,0 +53,4 @@
+		{
+			var query = GetQueryReadOnly();
+			var result = await query
+				.Where(e => systems.Count() == 0 || systems.Contains(e.System.SystemId))

@@ -102,3 +90,1 @@
-
-                entity.SystemId = systemId;
-                entity.UserId = userId;
+				await CreateSystemIfNotExist(systemId, token);

@@ -143,0 +116,4 @@
+		{
+            var systems = await sourceSystemRepository.Get(token);
+
+            return systems ?? [];

@@ -143,0 +128,4 @@
+					Min = group.Min(e => e.Timestamp),
+					Max = group.Max(e => e.Timestamp),
+				});
+			var values = await query.FirstOrDefaultAsync(token);

@@ -178,0 +148,4 @@
+				system = new DataSourceSystemDto()
+				{
+					SystemId = systemId,
+					Name = string.Empty