Merge pull request '#32567544 Фикс получения установок для панели' (#261) from fix/setpoints into dev

Reviewed-on: http://test.digitaldrilling.ru:8080/DDrilling/AsbCloudServer/pulls/261

AsbCloudInfrastructure/DependencyInjection.cs

@@ -52,6 +52,11 @@ namespace AsbCloudInfrastructure
     {
         public static void MapsterSetup()
         {
+            TypeAdapterConfig.GlobalSettings.Default.Config
+               .ForType<SetpointsRequestDto, SetpointsRequest>()
+               .Ignore(source => source.Author)
+               .Ignore(source => source.Well);
+               
             TypeAdapterConfig.GlobalSettings.Default.Config
                .ForType<DetectedOperationDto, DetectedOperation>()
                .Ignore(source => source.OperationCategory);

AsbCloudInfrastructure/Repository/CacheBase.cs

@@ -53,7 +53,7 @@ namespace AsbCloudInfrastructure.Repository
                 cacheEntry.AbsoluteExpirationRelativeToNow = CacheObsolescence;
                 cacheEntry.SlidingExpiration = CacheObsolescence;
 
-                var entities = await this.GetQuery().ToArrayAsync(token);
+                var entities = await GetQuery().AsNoTracking().ToArrayAsync(token);
                 cacheEntry.Value = entities;
                 return entities.AsEnumerable();
             });

AsbCloudInfrastructure/Repository/SetpointsRequestRepository.cs

@@ -8,6 +8,7 @@ using System.Collections.Generic;
 using System.Threading.Tasks;
 using System.Threading;
 using System.Linq;
+using AsbCloudApp.Exceptions;
 
 namespace AsbCloudInfrastructure.Repository
 {
@@ -23,26 +24,40 @@ namespace AsbCloudInfrastructure.Repository
             this.wellService = wellService;
         }
 
+        //TODO: заметка для рефакторинга. Использовать метод из базового репозитория
         public virtual async Task<int> UpdateRangeAsync(IEnumerable<SetpointsRequestDto> dtos, CancellationToken token)
         {
-            var ids = dtos.Select(d => d.Id);
+            if (!dtos.Any())
-            var existingEntities = await dbSet
+                return 0;
-                .AsNoTracking()
-                .Where(d => ids.Contains(d.Id))
-                .Select(d => d.Id)
-                .ToListAsync(token)
-                .ConfigureAwait(false);
             
-            if (ids.Count() > existingEntities.Count)
+            var ids = dtos
-                return ICrudRepository<SetpointsRequestDto>.ErrorIdNotFound;
+                .Select(o => o.Id)
+                .Distinct()
+                .ToArray();
             
-            foreach (var dto in dtos)
+            if (ids.Any(id => id == default))
-            {
+                throw new ArgumentInvalidException(nameof(dtos), "Все записи должны иметь Id");
-                var entity = Convert(dto);
+            
-                var entry = dbSet.Update(entity);
+            if (ids.Length != dtos.Count())
-            }
+                throw new ArgumentInvalidException(nameof(dtos), "Все записи должны иметь уникальные Id");
+            
+            var existingEntitiesCount = await dbContext.Set<SetpointsRequest>()
+                .Where(o => ids.Contains(o.Id))
+                .CountAsync(token);
+            
+            if (ids.Length != existingEntitiesCount)
+                throw new ArgumentInvalidException(nameof(dtos), "Все записи должны существовать в БД");
+
+            var entities = dtos.Select(Convert);
+            var entries = entities.Select(entity => dbContext.Set<SetpointsRequest>().Update(entity)).ToList();
 
             var affected = await dbContext.SaveChangesAsync(token);
+            
+            entries.ForEach(entry => entry.State = EntityState.Detached);
+
+            if(affected > 0) 
+                DropCache();
+            
             return affected;
         }
 

AsbCloudInfrastructure/Services/SAUB/SetpointsService.cs

@@ -2,7 +2,6 @@
 using AsbCloudApp.Services;
 using AsbCloudDb.Model;
 using AsbCloudInfrastructure.Repository;
-using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Caching.Memory;
 using System;
 using System.Collections.Generic;
@@ -63,16 +62,14 @@ namespace AsbCloudInfrastructure.Services.SAUB
             var filtered = all.Where(s =>
                 s.IdWell == idWell &&
                 s.IdState == 1 && 
-                s.UploadDate.AddSeconds(s.ObsolescenceSec) > DateTime.UtcNow)
+                s.UploadDate.AddSeconds(s.ObsolescenceSec).UtcDateTime > DateTime.UtcNow)
-                .ToList();
+                .ToArray();
 
             if (!filtered.Any())
                 return Enumerable.Empty<SetpointsRequestDto>();
 
             foreach (var item in filtered)
-            {
                 item.IdState = 2;
-            }
 
             await setpointsRepository.UpdateRangeAsync(filtered, token);
 

AsbCloudWebApi.IntegrationTests/Clients/ISetpointsClient.cs

@@ -0,0 +1,12 @@
+using AsbCloudApp.Data.SAUB;
+using Refit;
+
+namespace AsbCloudWebApi.IntegrationTests.Clients;
+
+public interface ISetpointsClient
+{
+	private const string BaseRoute = "/api/telemetry/{uid}/Setpoints";
+
+	[Get(BaseRoute)]
+	Task<IApiResponse<IEnumerable<SetpointsRequestDto>>> GetByTelemetryUidAsync(string uid);
+}

AsbCloudWebApi.IntegrationTests/Controllers/SetpointsControllerTest.cs

@@ -0,0 +1,53 @@
+using System.Net;
+using AsbCloudDb.Model;
+using AsbCloudWebApi.IntegrationTests.Clients;
+using Microsoft.EntityFrameworkCore;
+using Xunit;
+
+namespace AsbCloudWebApi.IntegrationTests.Controllers;
+
+public class SetpointsControllerTest : BaseIntegrationTest
+{
+	private readonly ISetpointsClient client;
+
+	public SetpointsControllerTest(WebAppFactoryFixture factory)
+		: base(factory)
+	{
+		client = factory.GetAuthorizedHttpClient<ISetpointsClient>(string.Empty);
+	}
+
+	[Fact]
+	public async Task GetByTelemetryUidAsync_returns_success()
+	{
+		//arrange
+		var well = await dbContext.Wells
+			.Include(w => w.Telemetry)
+			.FirstAsync();
+		
+		var entity = new SetpointsRequest
+		{
+			IdWell = well.Id,
+			UploadDate = DateTimeOffset.UtcNow, 
+			ObsolescenceSec = 15,
+			IdState = 1,
+			IdAuthor = 1
+		};
+		
+		var entry = dbContext.SetpointsRequests.Add(entity);
+		await dbContext.SaveChangesAsync();
+		entry.State = EntityState.Detached;
+
+		//act
+		var response = await client.GetByTelemetryUidAsync(well.Telemetry!.RemoteUid);
+		
+		//assert
+		Assert.Equal(HttpStatusCode.OK, response.StatusCode);
+		Assert.NotNull(response.Content);
+		Assert.Single(response.Content);
+
+		var setpoints = await dbContext.SetpointsRequests.ToArrayAsync();
+
+		foreach (var setpoint in setpoints)
+			Assert.Equal(2, setpoint.IdState);
+	}
+}