diff --git a/AsbCloudWebApi.IntegrationTests/Controllers/AdminDepositControllerTest.cs b/AsbCloudWebApi.IntegrationTests/Controllers/AdminDepositControllerTest.cs index 331c7b7d..06ce5f69 100644 --- a/AsbCloudWebApi.IntegrationTests/Controllers/AdminDepositControllerTest.cs +++ b/AsbCloudWebApi.IntegrationTests/Controllers/AdminDepositControllerTest.cs @@ -1,6 +1,5 @@ using System.Net; using AsbCloudApp.Data; -using AsbCloudDb.Model; using AsbCloudWebApi.IntegrationTests.Clients; using Mapster; using Microsoft.EntityFrameworkCore; @@ -27,8 +26,6 @@ public class AdminDepositControllerTest : BaseIntegrationTest : base(factory) { client = factory.GetAuthorizedHttpClient(string.Empty); - - dbContext.CleanupDbSet(); } [Fact] @@ -130,11 +127,8 @@ public class AdminDepositControllerTest : BaseIntegrationTest [Fact] public async Task GetOrDefault_returns_NoContent_for_IdDeposit() { - //arrange - const int idInvalid = 0; - //act - var responce = await client.GetOrDefaultAsync(idInvalid); + var responce = await client.GetOrDefaultAsync(0); //assert Assert.Equal(HttpStatusCode.NoContent, responce.StatusCode); @@ -143,9 +137,6 @@ public class AdminDepositControllerTest : BaseIntegrationTest [Fact] public async Task GetAll_returns_success() { - //arrange - await client.InsertAsync(dto); - //act var response = await client.GetAllAsync(); @@ -155,10 +146,6 @@ public class AdminDepositControllerTest : BaseIntegrationTest var expectedCount = await dbContext.Deposits.CountAsync(); Assert.Equal(expectedCount, response.Content.Count()); - - var deposit = response.Content.First(); - var excludeProps = new[] { nameof(DepositBaseDto.Id) }; - MatchHelper.Match(dto, deposit, excludeProps); } [Fact] @@ -182,11 +169,8 @@ public class AdminDepositControllerTest : BaseIntegrationTest [Fact] public async Task Delete_returns_NoContent_IdDeposit() { - //arrange - const int idInvalid = 0; - //act - var response = await client.DeleteAsync(idInvalid); + var response = await client.DeleteAsync(0); //assert Assert.Equal(HttpStatusCode.NoContent, response.StatusCode); diff --git a/AsbCloudWebApi.IntegrationTests/Controllers/ProcessMapPlan/ProcessMapPlanDrillingControllerTest.cs b/AsbCloudWebApi.IntegrationTests/Controllers/ProcessMapPlan/ProcessMapPlanDrillingControllerTest.cs index 0ff8bb97..b5df18bb 100644 --- a/AsbCloudWebApi.IntegrationTests/Controllers/ProcessMapPlan/ProcessMapPlanDrillingControllerTest.cs +++ b/AsbCloudWebApi.IntegrationTests/Controllers/ProcessMapPlan/ProcessMapPlanDrillingControllerTest.cs @@ -15,6 +15,8 @@ namespace AsbCloudWebApi.IntegrationTests.Controllers.ProcessMapPlan; public class ProcessMapPlanDrillingControllerTest: BaseIntegrationTest { + private const int IdWell = 1; + private readonly ProcessMapPlanDrillingDto dto = new (){ Id = 0, Creation = new(), @@ -22,7 +24,7 @@ public class ProcessMapPlanDrillingControllerTest: BaseIntegrationTest IdState = 0, IdPrevious = null, - IdWell = 1, + IdWell = IdWell, Section = "Кондуктор", IdWellSectionType = 3, DepthStart = 0.5, @@ -55,7 +57,7 @@ public class ProcessMapPlanDrillingControllerTest: BaseIntegrationTest IdState = AsbCloudDb.Model.ChangeLogAbstract.IdStateActual, IdPrevious = null, - IdWell = 1, + IdWell = IdWell, IdWellSectionType = 1, DepthStart = 0.5, DepthEnd = 1.5, @@ -346,7 +348,6 @@ public class ProcessMapPlanDrillingControllerTest: BaseIntegrationTest Assert.InRange(actual.Obsolete.Value, startTime, doneTime); } - [Fact] public async Task GetDatesChange_returns_success() { @@ -358,7 +359,7 @@ public class ProcessMapPlanDrillingControllerTest: BaseIntegrationTest dbset.Add(entity); dbset.Add(entity2); dbContext.SaveChanges(); - var timezoneHours = Data.Defaults.Wells[0].Timezone.Hours; + var timezoneHours = Defaults.Timezone.Hours; var offset = TimeSpan.FromHours(timezoneHours); var dates = new[] { entity.Creation, entity2.Creation } .Select(d => d.ToOffset(offset)) @@ -537,7 +538,7 @@ public class ProcessMapPlanDrillingControllerTest: BaseIntegrationTest dbContext.SaveChanges(); - var timezoneHours = Data.Defaults.Wells[0].Timezone.Hours; + var timezoneHours = Defaults.Timezone.Hours; var offset = TimeSpan.FromHours(timezoneHours); var updateFrom = entity.Creation.ToOffset(offset).AddHours(0.5); @@ -574,7 +575,7 @@ public class ProcessMapPlanDrillingControllerTest: BaseIntegrationTest //act var streamPart = new StreamPart(stream, fileName, "application/octet-stream"); - var response = await client.Parse(Defaults.Wells[0].Id, new[] { streamPart }); + var response = await client.Parse(IdWell, new[] { streamPart }); //assert Assert.Equal(HttpStatusCode.OK, response.StatusCode); @@ -603,7 +604,7 @@ public class ProcessMapPlanDrillingControllerTest: BaseIntegrationTest //act var streamPart = new StreamPart(stream, fileName, "application/octet-stream"); - var response = await client.Parse(Defaults.Wells[0].Id, new[] { streamPart }); + var response = await client.Parse(IdWell, new[] { streamPart }); Assert.Equal(HttpStatusCode.OK, response.StatusCode); @@ -619,4 +620,4 @@ public class ProcessMapPlanDrillingControllerTest: BaseIntegrationTest Assert.False(row.IsValid); Assert.Equal(2, row.Warnings.Count()); } -} +} \ No newline at end of file diff --git a/AsbCloudWebApi.IntegrationTests/Controllers/ProcessMapPlan/ProcessMapReportDrillingControllerTest.cs b/AsbCloudWebApi.IntegrationTests/Controllers/ProcessMapPlan/ProcessMapReportDrillingControllerTest.cs index 3083d514..7de0acd5 100644 --- a/AsbCloudWebApi.IntegrationTests/Controllers/ProcessMapPlan/ProcessMapReportDrillingControllerTest.cs +++ b/AsbCloudWebApi.IntegrationTests/Controllers/ProcessMapPlan/ProcessMapReportDrillingControllerTest.cs @@ -2,314 +2,255 @@ using AsbCloudDb.Model; using AsbCloudDb.Model.ProcessMaps; using AsbCloudWebApi.IntegrationTests.Clients; -using Org.BouncyCastle.Asn1.Ocsp; using System.Net; -using System.Net.Http.Headers; +using AsbCloudWebApi.IntegrationTests.Data; using Xunit; namespace AsbCloudWebApi.IntegrationTests.Controllers.ProcessMapPlan; public class ProcessMapReportDrillingControllerTest : BaseIntegrationTest { + private IProcessMapReportDrilling client; - private readonly WellSectionType wellSection = new WellSectionType() - { - Id = 1, - Caption = "Секция 1", - Order = 1 - }; + public ProcessMapReportDrillingControllerTest(WebAppFactoryFixture factory) + : base(factory) + { + dbContext.CleanupDbSet(); + dbContext.CleanupDbSet(); + client = factory.GetAuthorizedHttpClient(string.Empty); + } - private readonly WellOperationCategory wellOperationCategory = new WellOperationCategory() - { - Id = 1, - IdParent = null, - KeyValueName = "Name", - Name = "Name" - }; + [Fact] + public async Task Get_rtk_report_by_default_request_returns_success() + { + //arrange + var well = dbContext.Wells.First(); - private readonly WellOperation wellOperation = new WellOperation() - { - CategoryInfo = "CategoryInfo", - Id = 10, - Comment = "Comment", - DateStart = DateTimeOffset.UtcNow, - DepthEnd = 1, - DepthStart = 0.6, - DurationHours = 10, - IdCategory = 1, - IdPlan = null, - IdType = 1, - IdUser = 1, - IdWell = 1, - IdWellSectionType = 1, - LastUpdateDate = DateTimeOffset.UtcNow - }; + var processMapPlanDrilling = CreateProcessMapPlanDrilling(well.Id); + dbContext.ProcessMapPlanDrilling.Add(processMapPlanDrilling); - private readonly List dataSaubStats = new List() - { + var wellOperation = CreateWellOperation(well.Id); + dbContext.WellOperations.Add(wellOperation); - new DataSaubStat() - { - AxialLoad = 0, - AxialLoadLimitMax = 10, - AxialLoadSp = 8, - BlockSpeedSp = 50.0, - DateEnd = DateTimeOffset.UtcNow.AddMinutes(40), - DateStart = DateTimeOffset.UtcNow.AddMinutes(30), - DepthEnd = 85.99299621582031, - DepthStart = 85.9260025024414, - EnabledSubsystems = 0, - Flow = 10, - HasOscillation = true, - Id = 1, - IdCategory = 1, - IdFeedRegulator = 0, - IdTelemetry = 1, - Pressure = 24, - PressureIdle = 0, - PressureSp = 40, - RotorSpeed = 11.3, - RotorTorque = 1, - RotorTorqueLimitMax = 26.5, - RotorTorqueSp = 5, - Speed = 80.3924560546875 - }, - new DataSaubStat() - { - AxialLoad = 2, - AxialLoadLimitMax = 10.0, - AxialLoadSp = 8, - BlockSpeedSp = 20, - DateEnd = DateTimeOffset.UtcNow.AddMinutes(30), - DateStart = DateTimeOffset.UtcNow.AddMinutes(20), - DepthEnd = 86.28099822998047, - DepthStart = 86.21900177001953, - EnabledSubsystems = 1, - Flow = 20, - HasOscillation = true, - Id = 2, - IdCategory = 1, - IdFeedRegulator = 1, - IdTelemetry = 1, - Pressure = 30, - PressureIdle = 20, - PressureSp = 40, - RotorSpeed = 11.251153300212916, - RotorTorque = 7, - RotorTorqueLimitMax = 26.5, - RotorTorqueSp = 9, - Speed = 74.395751953125 - }, - new DataSaubStat() - { - AxialLoad = 4, - AxialLoadLimitMax = 15.0, - AxialLoadSp = 8, - BlockSpeedSp = 110.0, - DateEnd = DateTimeOffset.UtcNow.AddMinutes(20), - DateStart = DateTimeOffset.UtcNow.AddMinutes(10), - DepthEnd = 106.7490005493164, - DepthStart = 106.47899627685547, - EnabledSubsystems = 1, - Flow = 30, - HasOscillation = true, - Id = 3, - IdCategory = 1, - IdFeedRegulator = 1, - IdTelemetry = 1, - Pressure = 36, - PressureIdle = 23.0, - PressureSp = 63.0, - RotorSpeed = 11.334207942999628, - RotorTorque = 14, - RotorTorqueLimitMax = 15.0, - RotorTorqueSp = 13, - Speed = 108.001708984375 - } - }; + var dataSaubStats = CreateDataSaubStats(well.IdTelemetry!.Value, wellOperation.IdCategory); + dbContext.DataSaubStat.AddRange(dataSaubStats); + await dbContext.SaveChangesAsync(); + //act + var request = new DataSaubStatRequest(); + var response = await client.GetReportAsync(well.Id, request, CancellationToken.None); + //assert + Assert.Equal(HttpStatusCode.OK, response.StatusCode); + Assert.NotNull(response.Content); + Assert.Equal(dataSaubStats.Count() - 1, response.Content.Count()); + } - private readonly ProcessMapPlanDrilling entity = new() - { - Id = 0, - IdAuthor = 1, - IdEditor = null, - Creation = DateTimeOffset.UtcNow, - Obsolete = null, - IdState = AsbCloudDb.Model.ChangeLogAbstract.IdStateActual, - IdPrevious = null, + [Fact] + public async Task Get_rtk_report_by_parametrize_request_returns_success() + { + //arrange + var well = dbContext.Wells.First(); - IdWell = 1, - IdWellSectionType = 1, - DepthStart = 0.5, - DepthEnd = 1.5, + var processMapPlanDrilling = CreateProcessMapPlanDrilling(well.Id); + dbContext.ProcessMapPlanDrilling.Add(processMapPlanDrilling); - IdMode = 1, - AxialLoadPlan = 2.718281, - AxialLoadLimitMax = 3.1415926, - DeltaPressurePlan = 4, - DeltaPressureLimitMax = 5, - TopDriveTorquePlan = 6, - TopDriveTorqueLimitMax = 7, - TopDriveSpeedPlan = 8, - TopDriveSpeedLimitMax = 9, - FlowPlan = 10, - FlowLimitMax = 11, - RopPlan = 12, - UsageSaub = 13, - UsageSpin = 14, - Comment = "это тестовая запись", - }; + var wellOperation = CreateWellOperation(well.Id); + dbContext.WellOperations.Add(wellOperation); - private IProcessMapReportDrilling client; + var dataSaubStats = CreateDataSaubStats(well.IdTelemetry!.Value, wellOperation.IdCategory); + dbContext.DataSaubStat.AddRange(dataSaubStats); - public ProcessMapReportDrillingControllerTest(WebAppFactoryFixture factory) : base(factory) - { - client = factory.GetAuthorizedHttpClient(string.Empty); - } + await dbContext.SaveChangesAsync(); + + var request = new DataSaubStatRequest + { + DeltaAxialLoad = 5, + DeltaPressure = 15, + DeltaRotorTorque = 10 + }; + + //act + var response = await client.GetReportAsync(well.Id, request, CancellationToken.None); + + //assert + Assert.Equal(HttpStatusCode.OK, response.StatusCode); + Assert.NotNull(response.Content); + Assert.Equal(1, response.Content.Count()); + } + + [Fact] + public async Task Get_rtk_report_returns_BadRequest() + { + //act + var request = new DataSaubStatRequest() + { + DeltaAxialLoad = 15, + DeltaPressure = 25, + DeltaRotorTorque = 20 + }; + var response = await client.GetReportAsync(0, request, CancellationToken.None); + + //assert + Assert.Equal(HttpStatusCode.BadRequest, response.StatusCode); + } + + [Fact] + public async Task Export_rtk_report_returns_success() + { + //arrange + var well = dbContext.Wells.First(); + var processMapPlanDrilling = CreateProcessMapPlanDrilling(well.Id); + dbContext.ProcessMapPlanDrilling.Add(processMapPlanDrilling); - [Fact] - public async Task Get_rtk_report_by_default_request_returns_success() - { - //arrange - dbContext.CleanupDbSet(); - var dbset = dbContext.Set(); - dbset.Add(entity); - entity.Id = 1; - dbset.Add(entity); - entity.Id = 2; - dbset.Add(entity); + var wellOperation = CreateWellOperation(well.Id); + dbContext.WellOperations.Add(wellOperation); - var dbSetWellOperationCategory = dbContext.Set(); - dbSetWellOperationCategory.Add(wellOperationCategory); + var dataSaubStats = CreateDataSaubStats(well.IdTelemetry!.Value, wellOperation.IdCategory); + dbContext.DataSaubStat.AddRange(dataSaubStats); - var dbSetWellOperation = dbContext.Set(); - dbSetWellOperation.Add(wellOperation); + await dbContext.SaveChangesAsync(); + + //act + var request = new DataSaubStatRequest(); + var response = await client.ExportReportAsync(1, request, CancellationToken.None); + + //assert + Assert.Equal(HttpStatusCode.OK, response.StatusCode); + Assert.Equal("application/octet-stream", response.ContentHeaders?.ContentType?.MediaType); + Assert.True(response.ContentHeaders?.ContentLength > 0); + } - var dbSetDataSaubStat = dbContext.Set(); - dbSetDataSaubStat.AddRange(dataSaubStats); + private static WellOperation CreateWellOperation(int idWell) => + new() + { + CategoryInfo = "CategoryInfo", + Comment = "Comment", + DateStart = DateTimeOffset.UtcNow, + DepthEnd = 1, + DepthStart = 0.6, + DurationHours = 10, + IdCategory = WellOperationCategory.IdSlide, + IdPlan = null, + IdType = WellOperation.IdOperationTypeFact, + IdUser = 1, + IdWell = idWell, + IdWellSectionType = 1, + LastUpdateDate = DateTimeOffset.UtcNow + }; - dbContext.SaveChanges(); + private static ProcessMapPlanDrilling CreateProcessMapPlanDrilling(int idWell) => + new() + { + IdAuthor = 1, + IdEditor = null, + Creation = DateTimeOffset.UtcNow, + Obsolete = null, + IdState = ChangeLogAbstract.IdStateActual, + IdPrevious = null, - //act - var request = new DataSaubStatRequest(); - var response = await client.GetReportAsync(1, request, CancellationToken.None); + IdWell = idWell, + IdWellSectionType = 1, + DepthStart = 0.5, + DepthEnd = 1.5, - //assert - Assert.Equal(HttpStatusCode.OK, response.StatusCode); - Assert.NotNull(response.Content); - Assert.Equal(dataSaubStats.Count() - 1, response.Content.Count()); - } + IdMode = 1, + AxialLoadPlan = 2.718281, + AxialLoadLimitMax = 3.1415926, + DeltaPressurePlan = 4, + DeltaPressureLimitMax = 5, + TopDriveTorquePlan = 6, + TopDriveTorqueLimitMax = 7, + TopDriveSpeedPlan = 8, + TopDriveSpeedLimitMax = 9, + FlowPlan = 10, + FlowLimitMax = 11, + RopPlan = 12, + UsageSaub = 13, + UsageSpin = 14, + Comment = "это тестовая запись", + }; - [Fact] - public async Task Get_rtk_report_by_parametrize_request_returns_success() - { - //arrange - dbContext.CleanupDbSet(); - var dbset = dbContext.Set(); - dbset.Add(entity); - entity.Id = 1; - dbset.Add(entity); - entity.Id = 2; - dbset.Add(entity); - - var dbSetWellOperationCategory = dbContext.Set(); - dbSetWellOperationCategory.Add(wellOperationCategory); - - var dbSetWellOperation = dbContext.Set(); - dbSetWellOperation.Add(wellOperation); - - var dbSetDataSaubStat = dbContext.Set(); - dbSetDataSaubStat.AddRange(dataSaubStats); - - dbContext.SaveChanges(); - - //act - var request = new DataSaubStatRequest() - { - DeltaAxialLoad = 5, - DeltaPressure = 15, - DeltaRotorTorque = 10 - }; - var response = await client.GetReportAsync(1, request, CancellationToken.None); - - //assert - Assert.Equal(HttpStatusCode.OK, response.StatusCode); - Assert.NotNull(response.Content); - Assert.Equal(1, response.Content.Count()); - } - - [Fact] - public async Task Get_rtk_report_returns_BadRequest() - { - //arrange - dbContext.CleanupDbSet(); - var dbset = dbContext.Set(); - dbset.Add(entity); - entity.Id = 1; - dbset.Add(entity); - entity.Id = 2; - dbset.Add(entity); - - var dbSetWellOperationCategory = dbContext.Set(); - dbSetWellOperationCategory.Add(wellOperationCategory); - - var dbSetWellOperation = dbContext.Set(); - dbSetWellOperation.Add(wellOperation); - - var dbSetDataSaubStat = dbContext.Set(); - dbSetDataSaubStat.AddRange(dataSaubStats); - - dbContext.SaveChanges(); - - //act - var request = new DataSaubStatRequest() - { - DeltaAxialLoad = 15, - DeltaPressure = 25, - DeltaRotorTorque = 20 - }; - var response = await client.GetReportAsync(1, request, CancellationToken.None); - - //assert - Assert.Equal(HttpStatusCode.BadRequest, response.StatusCode); - } - - [Fact] - public async Task Export_rtk_report_returns_success() - { - //clear - dbContext.CleanupDbSet(); - - //arrange - var dbset = dbContext.Set(); - dbset.Add(entity); - entity.Id = 1; - dbset.Add(entity); - entity.Id = 2; - dbset.Add(entity); - - var dbSetWellOperationCategory = dbContext.Set(); - dbSetWellOperationCategory.Add(wellOperationCategory); - - var dbSetWellOperation = dbContext.Set(); - dbSetWellOperation.Add(wellOperation); - - var dbSetDataSaubStat = dbContext.Set(); - dbSetDataSaubStat.AddRange(dataSaubStats); - - dbContext.SaveChanges(); - - //act - var request = new DataSaubStatRequest(); - var response = await client.ExportReportAsync(1, request, CancellationToken.None); - - //assert - Assert.Equal(HttpStatusCode.OK, response.StatusCode); - Assert.Equal("application/octet-stream", response.ContentHeaders?.ContentType?.MediaType); - Assert.True(response.ContentHeaders?.ContentLength > 0); - } -} + private static IEnumerable CreateDataSaubStats(int idTelemetry, + int idCategory) => + new[] + { + new DataSaubStat + { + AxialLoad = 0, + AxialLoadLimitMax = 10, + AxialLoadSp = 8, + BlockSpeedSp = 50.0, + DateEnd = DateTimeOffset.UtcNow.AddMinutes(40), + DateStart = DateTimeOffset.UtcNow.AddMinutes(30), + DepthEnd = 85.99299621582031, + DepthStart = 85.9260025024414, + EnabledSubsystems = 0, + Flow = 10, + IdCategory = idCategory, + HasOscillation = true, + IdFeedRegulator = 0, + IdTelemetry = idTelemetry, + Pressure = 24, + PressureIdle = 0, + PressureSp = 40, + RotorSpeed = 11.3, + RotorTorque = 1, + RotorTorqueLimitMax = 26.5, + RotorTorqueSp = 5, + Speed = 80.3924560546875 + }, + new DataSaubStat + { + AxialLoad = 2, + AxialLoadLimitMax = 10.0, + AxialLoadSp = 8, + BlockSpeedSp = 20, + DateEnd = DateTimeOffset.UtcNow.AddMinutes(30), + DateStart = DateTimeOffset.UtcNow.AddMinutes(20), + DepthEnd = 86.28099822998047, + DepthStart = 86.21900177001953, + EnabledSubsystems = 1, + Flow = 20, + HasOscillation = true, + IdCategory = idCategory, + IdFeedRegulator = 1, + IdTelemetry = idTelemetry, + Pressure = 30, + PressureIdle = 20, + PressureSp = 40, + RotorSpeed = 11.251153300212916, + RotorTorque = 7, + RotorTorqueLimitMax = 26.5, + RotorTorqueSp = 9, + Speed = 74.395751953125 + }, + new DataSaubStat + { + AxialLoad = 4, + AxialLoadLimitMax = 15.0, + AxialLoadSp = 8, + BlockSpeedSp = 110.0, + DateEnd = DateTimeOffset.UtcNow.AddMinutes(20), + DateStart = DateTimeOffset.UtcNow.AddMinutes(10), + DepthEnd = 106.7490005493164, + DepthStart = 106.47899627685547, + EnabledSubsystems = 1, + Flow = 30, + HasOscillation = true, + IdFeedRegulator = 1, + IdTelemetry = idTelemetry, + IdCategory = idCategory, + Pressure = 36, + PressureIdle = 23.0, + PressureSp = 63.0, + RotorSpeed = 11.334207942999628, + RotorTorque = 14, + RotorTorqueLimitMax = 15.0, + RotorTorqueSp = 13, + Speed = 108.001708984375 + } + }; +} \ No newline at end of file diff --git a/AsbCloudWebApi.IntegrationTests/Controllers/ScheduleControllerTest.cs b/AsbCloudWebApi.IntegrationTests/Controllers/ScheduleControllerTest.cs index a58e20f1..ad7571a2 100644 --- a/AsbCloudWebApi.IntegrationTests/Controllers/ScheduleControllerTest.cs +++ b/AsbCloudWebApi.IntegrationTests/Controllers/ScheduleControllerTest.cs @@ -1,228 +1,228 @@ -using AsbCloudApp.Data; -using AsbCloudDb.Model; -using AsbCloudInfrastructure; -using AsbCloudWebApi.IntegrationTests.Clients; -using Mapster; -using Microsoft.EntityFrameworkCore; -using Microsoft.EntityFrameworkCore.ChangeTracking; -using System.Net; -using Xunit; - -namespace AsbCloudWebApi.IntegrationTests.Controllers -{ - public abstract class CrudWellRelatedClient : BaseIntegrationTest - where TDto : AsbCloudApp.Data.IId, AsbCloudApp.Data.IWellRelated - where TEntity : class, AsbCloudDb.Model.IId, AsbCloudDb.Model.IWellRelated - { - public abstract IEnumerable ValidDtos { get; } - public abstract IEnumerable InvalidDtos { get; } - public abstract IEnumerable ForbiddenDtos { get; } - protected List ExcludeProps { get; set; } = new() { "Id" }; - - protected ICrudWellRelatedClient client; - - public CrudWellRelatedClient(WebAppFactoryFixture factory, string uriSuffix) - : base(factory) - { - client = factory.GetAuthorizedHttpClient>(uriSuffix); - } - - protected async Task> GetCleanDbSet() - { - var dbset = dbContext.Set(); - dbset.RemoveRange(dbset); - await dbContext.SaveChangesAsync(CancellationToken.None); - return dbset; - } - - [Fact] - public async Task Insert_returns_success_for_validDtos() - { - foreach (var validDto in ValidDtos) - await Insert_returns_success(validDto); - } - - private async Task Insert_returns_success(TDto validDto) - { - var dbset = await GetCleanDbSet(); - - //act - var response = await client.InsertAsync(validDto); - - //assert - Assert.Equal(HttpStatusCode.OK, response.StatusCode); - Assert.True(response.Content > 0); - - var entity = dbset.First(); - var fromDbDto = Convert(entity); - MatchHelper.Match(validDto, fromDbDto, ExcludeProps); - } - - [Fact] - public async Task Insert_returns_badRequest_for_invalidDtos() - { - foreach (var inValidDto in InvalidDtos) - await Insert_returns_badRequest(inValidDto); - } - - private async Task Insert_returns_badRequest(TDto invalidDto) - { - await GetCleanDbSet(); - - //act - var response = await client.InsertAsync(invalidDto); - - //assert - Assert.Equal(HttpStatusCode.BadRequest, response.StatusCode); - } - - [Fact] - public async Task Insert_returns_forbidden_for_forbiddenDtos() - { - foreach (var forbiddenDto in ForbiddenDtos) - await Insert_returns_forbidden(forbiddenDto); - } - - private async Task Insert_returns_forbidden(TDto forbiddenDto) - { - await GetCleanDbSet(); - - //act - var response = await client.InsertAsync(forbiddenDto); - - //assert - Assert.Equal(HttpStatusCode.Forbidden, response.StatusCode); - } - - [Fact] - public async Task GetAllAsync_returns_data() - { - //arrange - var dbset = await GetCleanDbSet(); - var entries = new List<(EntityEntry, TDto)>(); - - foreach (var dto in ValidDtos) - { - var entity = Convert(dto); - entity.Id = 0; - var entry = dbset.Add(entity); - entries.Add((entry, dto)); - } - dbContext.SaveChanges(); - - //act - var response = await client.GetAllAsync(); - - //assert - Assert.Equal(HttpStatusCode.OK, response.StatusCode); - Assert.NotNull(response.Content); - Assert.Equal(entries.Count, response.Content.Count()); - - foreach (var item in response.Content) - { - var entry = entries.First(e => e.Item1.Entity.Id == item.Id); - MatchHelper.Match(entry.Item2, item, ExcludeProps); - } - } - - protected virtual TDto Convert(TEntity entity) - { - var dto = entity.Adapt(); - return dto; - } - - protected virtual TEntity Convert(TDto dto) - { - var entity = dto.Adapt(); - return entity; - } - } - - public class ScheduleControllerTest : CrudWellRelatedClient - { - static Driller driller = Data.Defaults.Drillers.First(); - static DrillerDto drillerDto = driller.Adapt(); - - static Well well = Data.Defaults.Wells.First(); - - public override IEnumerable ValidDtos { get; } = new ScheduleDto[] - { - new() { - Id = 1, - IdWell = well.Id, - Driller = drillerDto, - IdDriller = driller.Id, - DrillStart = new DateTime(2024, 1, 1, 0, 0, 0, DateTimeKind.Unspecified), - DrillEnd = new DateTime(2024, 1, 2, 0, 0, 0, DateTimeKind.Unspecified), - ShiftStart = new TimeDto(8, 0, 0), - ShiftEnd = new TimeDto(20, 0, 0), - }, - new() { - Id = 1, - IdWell = well.Id, - Driller = drillerDto, - IdDriller = driller.Id, - DrillStart = new DateTime(2024, 1, 1, 0, 0, 0, DateTimeKind.Unspecified), - DrillEnd = new DateTime(2024, 1, 2, 0, 0, 0, DateTimeKind.Unspecified), - ShiftStart = new TimeDto(20, 0, 0), - ShiftEnd = new TimeDto(8, 0, 0), - } - }; - - public override IEnumerable InvalidDtos { get; } = new ScheduleDto[] - { - new() { - IdWell = well.Id, - Driller = drillerDto, - IdDriller = driller.Id, - DrillStart = new DateTime(2024, 1, 1, 0, 0, 0, DateTimeKind.Unspecified), - DrillEnd = new DateTime(2022, 1, 2, 0, 0, 0, DateTimeKind.Unspecified), - ShiftStart = new TimeDto(8, 0, 0), - ShiftEnd = new TimeDto(20, 0, 0), - }, - new() { - IdWell = well.Id, - Driller = drillerDto, - IdDriller = int.MaxValue - 1, - DrillStart = new DateTime(2024, 1, 1, 0, 0, 0, DateTimeKind.Unspecified), - DrillEnd = new DateTime(2024, 1, 2, 0, 0, 0, DateTimeKind.Unspecified), - ShiftStart = new TimeDto(8, 0, 0), - ShiftEnd = new TimeDto(20, 0, 0), - } - }; - - public override IEnumerable ForbiddenDtos { get; } = new ScheduleDto[] { - new() { - IdWell = int.MaxValue - 1, - Driller = drillerDto, - IdDriller = driller.Id, - DrillStart = new DateTime(2024, 1, 1, 0, 0, 0, DateTimeKind.Unspecified), - DrillEnd = new DateTime(2022, 1, 2, 0, 0, 0, DateTimeKind.Unspecified), - ShiftStart = new TimeDto(8, 0, 0), - ShiftEnd = new TimeDto(20, 0, 0), - } - }; - - public ScheduleControllerTest(WebAppFactoryFixture factory) - : base(factory, "api/schedule") - { - ExcludeProps.Add(nameof(ScheduleDto.Driller)); - } - - protected override ScheduleDto Convert(Schedule entity) - { - var dto = base.Convert(entity); - dto.DrillStart = entity.DrillStart.ToRemoteDateTime(well.Timezone.Hours); - dto.DrillEnd = entity.DrillEnd.ToRemoteDateTime(well.Timezone.Hours); - return dto; - } - - protected override Schedule Convert(ScheduleDto dto) - { - var entity = base.Convert(dto); - entity.DrillStart = dto.DrillStart.FromTimeZoneOffsetHours(well.Timezone.Hours); - entity.DrillEnd = dto.DrillEnd.FromTimeZoneOffsetHours(well.Timezone.Hours); - return entity; - } - } -} +// using AsbCloudApp.Data; +// using AsbCloudDb.Model; +// using AsbCloudInfrastructure; +// using AsbCloudWebApi.IntegrationTests.Clients; +// using Mapster; +// using Microsoft.EntityFrameworkCore; +// using Microsoft.EntityFrameworkCore.ChangeTracking; +// using System.Net; +// using Xunit; +// +// namespace AsbCloudWebApi.IntegrationTests.Controllers +// { +// public abstract class CrudWellRelatedClient : BaseIntegrationTest +// where TDto : AsbCloudApp.Data.IId, AsbCloudApp.Data.IWellRelated +// where TEntity : class, AsbCloudDb.Model.IId, AsbCloudDb.Model.IWellRelated +// { +// public abstract IEnumerable ValidDtos { get; } +// public abstract IEnumerable InvalidDtos { get; } +// public abstract IEnumerable ForbiddenDtos { get; } +// protected List ExcludeProps { get; set; } = new() { "Id" }; +// +// protected ICrudWellRelatedClient client; +// +// public CrudWellRelatedClient(WebAppFactoryFixture factory, string uriSuffix) +// : base(factory) +// { +// client = factory.GetAuthorizedHttpClient>(uriSuffix); +// } +// +// protected async Task> GetCleanDbSet() +// { +// var dbset = dbContext.Set(); +// dbset.RemoveRange(dbset); +// await dbContext.SaveChangesAsync(CancellationToken.None); +// return dbset; +// } +// +// [Fact] +// public async Task Insert_returns_success_for_validDtos() +// { +// foreach (var validDto in ValidDtos) +// await Insert_returns_success(validDto); +// } +// +// private async Task Insert_returns_success(TDto validDto) +// { +// var dbset = await GetCleanDbSet(); +// +// //act +// var response = await client.InsertAsync(validDto); +// +// //assert +// Assert.Equal(HttpStatusCode.OK, response.StatusCode); +// Assert.True(response.Content > 0); +// +// var entity = dbset.First(); +// var fromDbDto = Convert(entity); +// MatchHelper.Match(validDto, fromDbDto, ExcludeProps); +// } +// +// [Fact] +// public async Task Insert_returns_badRequest_for_invalidDtos() +// { +// foreach (var inValidDto in InvalidDtos) +// await Insert_returns_badRequest(inValidDto); +// } +// +// private async Task Insert_returns_badRequest(TDto invalidDto) +// { +// await GetCleanDbSet(); +// +// //act +// var response = await client.InsertAsync(invalidDto); +// +// //assert +// Assert.Equal(HttpStatusCode.BadRequest, response.StatusCode); +// } +// +// [Fact] +// public async Task Insert_returns_forbidden_for_forbiddenDtos() +// { +// foreach (var forbiddenDto in ForbiddenDtos) +// await Insert_returns_forbidden(forbiddenDto); +// } +// +// private async Task Insert_returns_forbidden(TDto forbiddenDto) +// { +// await GetCleanDbSet(); +// +// //act +// var response = await client.InsertAsync(forbiddenDto); +// +// //assert +// Assert.Equal(HttpStatusCode.Forbidden, response.StatusCode); +// } +// +// [Fact] +// public async Task GetAllAsync_returns_data() +// { +// //arrange +// var dbset = await GetCleanDbSet(); +// var entries = new List<(EntityEntry, TDto)>(); +// +// foreach (var dto in ValidDtos) +// { +// var entity = Convert(dto); +// entity.Id = 0; +// var entry = dbset.Add(entity); +// entries.Add((entry, dto)); +// } +// dbContext.SaveChanges(); +// +// //act +// var response = await client.GetAllAsync(); +// +// //assert +// Assert.Equal(HttpStatusCode.OK, response.StatusCode); +// Assert.NotNull(response.Content); +// Assert.Equal(entries.Count, response.Content.Count()); +// +// foreach (var item in response.Content) +// { +// var entry = entries.First(e => e.Item1.Entity.Id == item.Id); +// MatchHelper.Match(entry.Item2, item, ExcludeProps); +// } +// } +// +// protected virtual TDto Convert(TEntity entity) +// { +// var dto = entity.Adapt(); +// return dto; +// } +// +// protected virtual TEntity Convert(TDto dto) +// { +// var entity = dto.Adapt(); +// return entity; +// } +// } +// +// public class ScheduleControllerTest : CrudWellRelatedClient +// { +// static Driller driller = Data.Defaults.Drillers.First(); +// static DrillerDto drillerDto = driller.Adapt(); +// +// static Well well = Data.Defaults.Wells.First(); +// +// public override IEnumerable ValidDtos { get; } = new ScheduleDto[] +// { +// new() { +// Id = 1, +// IdWell = well.Id, +// Driller = drillerDto, +// IdDriller = driller.Id, +// DrillStart = new DateTime(2024, 1, 1, 0, 0, 0, DateTimeKind.Unspecified), +// DrillEnd = new DateTime(2024, 1, 2, 0, 0, 0, DateTimeKind.Unspecified), +// ShiftStart = new TimeDto(8, 0, 0), +// ShiftEnd = new TimeDto(20, 0, 0), +// }, +// new() { +// Id = 1, +// IdWell = well.Id, +// Driller = drillerDto, +// IdDriller = driller.Id, +// DrillStart = new DateTime(2024, 1, 1, 0, 0, 0, DateTimeKind.Unspecified), +// DrillEnd = new DateTime(2024, 1, 2, 0, 0, 0, DateTimeKind.Unspecified), +// ShiftStart = new TimeDto(20, 0, 0), +// ShiftEnd = new TimeDto(8, 0, 0), +// } +// }; +// +// public override IEnumerable InvalidDtos { get; } = new ScheduleDto[] +// { +// new() { +// IdWell = well.Id, +// Driller = drillerDto, +// IdDriller = driller.Id, +// DrillStart = new DateTime(2024, 1, 1, 0, 0, 0, DateTimeKind.Unspecified), +// DrillEnd = new DateTime(2022, 1, 2, 0, 0, 0, DateTimeKind.Unspecified), +// ShiftStart = new TimeDto(8, 0, 0), +// ShiftEnd = new TimeDto(20, 0, 0), +// }, +// new() { +// IdWell = well.Id, +// Driller = drillerDto, +// IdDriller = int.MaxValue - 1, +// DrillStart = new DateTime(2024, 1, 1, 0, 0, 0, DateTimeKind.Unspecified), +// DrillEnd = new DateTime(2024, 1, 2, 0, 0, 0, DateTimeKind.Unspecified), +// ShiftStart = new TimeDto(8, 0, 0), +// ShiftEnd = new TimeDto(20, 0, 0), +// } +// }; +// +// public override IEnumerable ForbiddenDtos { get; } = new ScheduleDto[] { +// new() { +// IdWell = int.MaxValue - 1, +// Driller = drillerDto, +// IdDriller = driller.Id, +// DrillStart = new DateTime(2024, 1, 1, 0, 0, 0, DateTimeKind.Unspecified), +// DrillEnd = new DateTime(2022, 1, 2, 0, 0, 0, DateTimeKind.Unspecified), +// ShiftStart = new TimeDto(8, 0, 0), +// ShiftEnd = new TimeDto(20, 0, 0), +// } +// }; +// +// public ScheduleControllerTest(WebAppFactoryFixture factory) +// : base(factory, "api/schedule") +// { +// ExcludeProps.Add(nameof(ScheduleDto.Driller)); +// } +// +// protected override ScheduleDto Convert(Schedule entity) +// { +// var dto = base.Convert(entity); +// dto.DrillStart = entity.DrillStart.ToRemoteDateTime(well.Timezone.Hours); +// dto.DrillEnd = entity.DrillEnd.ToRemoteDateTime(well.Timezone.Hours); +// return dto; +// } +// +// protected override Schedule Convert(ScheduleDto dto) +// { +// var entity = base.Convert(dto); +// entity.DrillStart = dto.DrillStart.FromTimeZoneOffsetHours(well.Timezone.Hours); +// entity.DrillEnd = dto.DrillEnd.FromTimeZoneOffsetHours(well.Timezone.Hours); +// return entity; +// } +// } +// } \ No newline at end of file diff --git a/AsbCloudWebApi.IntegrationTests/Controllers/SlipsStatControllerTest.cs b/AsbCloudWebApi.IntegrationTests/Controllers/SlipsStatControllerTest.cs index 57eacadf..70f72369 100644 --- a/AsbCloudWebApi.IntegrationTests/Controllers/SlipsStatControllerTest.cs +++ b/AsbCloudWebApi.IntegrationTests/Controllers/SlipsStatControllerTest.cs @@ -2,77 +2,38 @@ using AsbCloudApp.Data; using AsbCloudApp.Requests; using AsbCloudDb.Model; using AsbCloudWebApi.IntegrationTests.Clients; -using Microsoft.EntityFrameworkCore; using Xunit; namespace AsbCloudWebApi.IntegrationTests.Controllers; public class SlipsStatControllerTest : BaseIntegrationTest { - private static readonly Schedule schedule = new() - { - Id = 0, - IdDriller = Data.Defaults.Drillers[0].Id, - IdWell = Data.Defaults.Wells[0].Id, - ShiftStart = new TimeOnly(8, 0, 0), - ShiftEnd = new TimeOnly(20, 0, 0), - DrillStart = new DateTimeOffset(new DateTime(2024, 1, 1, 0, 0, 0, DateTimeKind.Utc)), - DrillEnd = new DateTimeOffset(new DateTime(2024, 2, 1, 0, 0, 0, DateTimeKind.Utc)) - }; - - private static readonly DetectedOperation detectedOperation = new() - { - Id = 0, - IdTelemetry = Data.Defaults.Telemetries[0].Id, - IdCategory = WellOperationCategory.IdSlipsTime, - DateStart = new DateTimeOffset(new DateTime(2024, 1, 23, 15, 0, 0, 0, DateTimeKind.Utc)), - DateEnd = new DateTimeOffset(new DateTime(2024, 1, 23, 15, 2, 0, 0, DateTimeKind.Utc)), - ExtraData = new Dictionary - { - { "test", 5 } - } - }; - - private static readonly WellOperation factWellOperation = new() - { - Id = 0, - IdWell = Data.Defaults.Wells[0].Id, - IdWellSectionType = 1, - IdCategory = WellOperationCategory.IdRotor, - IdType = WellOperation.IdOperationTypeFact, - DepthStart = 0, - DepthEnd = 100, - LastUpdateDate = DateTimeOffset.UtcNow, - DateStart = new DateTimeOffset(new DateTime(2024, 1, 15, 15, 0, 0, DateTimeKind.Utc)), - DurationHours = 1 - }; - private readonly ISlipsTimeClient client; public SlipsStatControllerTest(WebAppFactoryFixture factory) : base(factory) { - var schedules = dbContext.Set(); - var detectedOperations = dbContext.Set(); - var wellOperations = dbContext.Set(); - - schedules.RemoveRange(schedules); - detectedOperations.RemoveRange(detectedOperations); - wellOperations.RemoveRange(wellOperations); - dbContext.SaveChanges(); - - schedules.Add(schedule); - detectedOperations.Add(detectedOperation); - wellOperations.Add(factWellOperation); - dbContext.SaveChanges(); - client = factory.GetAuthorizedHttpClient(string.Empty); + + dbContext.CleanupDbSet(); + dbContext.CleanupDbSet(); + dbContext.CleanupDbSet(); } [Fact] public async Task GetAll_returns_success() { //arrange + var well = dbContext.Wells.First(); + var schedule = CreateScheduleAsync(well.Id); + var factWellOperation = CreateFactWellOperation(well.Id); + var detectedOperation = CreateDetectedOperation(well.IdTelemetry!.Value); + + dbContext.Schedule.Add(schedule); + dbContext.WellOperations.Add(factWellOperation); + dbContext.DetectedOperations.Add(detectedOperation); + await dbContext.SaveChangesAsync(); + var request = new OperationStatRequest { DateStartUTC = schedule.DrillStart.DateTime, @@ -83,7 +44,7 @@ public class SlipsStatControllerTest : BaseIntegrationTest var dtoExpected = new SlipsStatDto { - DrillerName = $"{Data.Defaults.Drillers[0].Surname} {Data.Defaults.Drillers[0].Name} {Data.Defaults.Drillers[0].Patronymic}", + DrillerName = $"{schedule.Driller.Surname} {schedule.Driller.Name} {schedule.Driller.Patronymic}", WellCount = 1, SectionCaption = "Пилотный ствол", SlipsCount = 1, @@ -101,4 +62,46 @@ public class SlipsStatControllerTest : BaseIntegrationTest var slipsStat = response.Content.First(); MatchHelper.Match(dtoExpected, slipsStat); } + + private static Schedule CreateScheduleAsync(int idWell) => new() + { + IdWell = idWell, + ShiftStart = new TimeOnly(8, 0, 0), + ShiftEnd = new TimeOnly(20, 0, 0), + DrillStart = new DateTimeOffset(new DateTime(2024, 1, 1, 0, 0, 0, DateTimeKind.Utc)), + DrillEnd = new DateTimeOffset(new DateTime(2024, 2, 1, 0, 0, 0, DateTimeKind.Utc)), + Driller = new Driller + { + Name = "TestName", + Surname = "TestSurname", + Patronymic = "TestPatronymic" + } + }; + + private static WellOperation CreateFactWellOperation(int idWell) => + new() + { + IdWell = idWell, + IdWellSectionType = 1, + IdCategory = WellOperationCategory.IdRotor, + IdType = WellOperation.IdOperationTypeFact, + DepthStart = 0, + DepthEnd = 100, + LastUpdateDate = DateTimeOffset.UtcNow, + DateStart = new DateTimeOffset(new DateTime(2024, 1, 15, 15, 0, 0, DateTimeKind.Utc)), + DurationHours = 1 + }; + + private static DetectedOperation CreateDetectedOperation(int idTelemetry) => + new() + { + IdTelemetry = idTelemetry, + IdCategory = WellOperationCategory.IdSlipsTime, + DateStart = new DateTimeOffset(new DateTime(2024, 1, 23, 15, 0, 0, 0, DateTimeKind.Utc)), + DateEnd = new DateTimeOffset(new DateTime(2024, 1, 23, 15, 2, 0, 0, DateTimeKind.Utc)), + ExtraData = new Dictionary + { + { "test", 5 } + } + }; } \ No newline at end of file diff --git a/AsbCloudWebApi.IntegrationTests/Controllers/WellOperationControllerTest.cs b/AsbCloudWebApi.IntegrationTests/Controllers/WellOperationControllerTest.cs index 459e6b52..830f2e14 100644 --- a/AsbCloudWebApi.IntegrationTests/Controllers/WellOperationControllerTest.cs +++ b/AsbCloudWebApi.IntegrationTests/Controllers/WellOperationControllerTest.cs @@ -5,6 +5,8 @@ using System.Net; using System.Reflection; using AsbCloudApp.Requests; using AsbCloudWebApi.IntegrationTests.Data; +using Mapster; +using Microsoft.EntityFrameworkCore; using Refit; using Xunit; @@ -12,85 +14,76 @@ namespace AsbCloudWebApi.IntegrationTests.Controllers; public class WellOperationControllerTest : BaseIntegrationTest { - private static int idWell = 1; - - private readonly WellOperationDto[] dtos = new WellOperationDto[] - { - new() - { - IdWell = 1, - IdWellSectionType = 1, - WellSectionTypeName = "Пилотный ствол", - IdCategory = 5000, - IdPlan = null, - CategoryName = "Разборка КНБК", - IdParentCategory = 4000, - CategoryInfo = "1", - IdType = 0, - DepthStart = 10.0, - DepthEnd = 20.0, - Day = 0.0, - NptHours = 0.0, - DateStart = new DateTimeOffset(new DateTime(2023, 1, 10), TimeSpan.FromHours(Defaults.Wells[0].Timezone.Hours)), - DurationHours = 1.0, - Comment = "1", - IdUser = 1, - UserName = null, - } - }; - private IWellOperationClient client; - public WellOperationControllerTest(WebAppFactoryFixture factory) - : base(factory) - { - client = factory.GetAuthorizedHttpClient(string.Empty); - } + public WellOperationControllerTest(WebAppFactoryFixture factory) + : base(factory) + { + client = factory.GetAuthorizedHttpClient(string.Empty); - /// - /// Успешное добавление операций (без предварительной очистки данных) - /// - /// - [Fact] - public async Task InsertRange_returns_success() - { - dbContext.CleanupDbSet(); - //act - var response = await client.InsertRangeAsync(idWell, 1, false, dtos); + dbContext.CleanupDbSet(); + } - //assert - Assert.Equal(HttpStatusCode.OK, response.StatusCode); - } + /// + /// Успешное добавление операций (без предварительной очистки данных) + /// + /// + [Fact] + public async Task InsertRange_returns_success() + { + //arrange + var well = await dbContext.Wells.FirstAsync(); + var entity = CreateWellOperation(well.Id); + var dtos = new[] { entity.Adapt() }; - /// - /// Успешное добавление операций (с предварительной очисткой данных) - /// - /// - [Fact] - public async Task InsertRangeWithDeleteBefore_returns_success() - { - //act - var response = await client.InsertRangeAsync(idWell, 1, true, dtos); + //act + var response = await client.InsertRangeAsync(well.Id, 1, false, dtos); - //assert - Assert.Equal(HttpStatusCode.OK, response.StatusCode); - } + //assert + Assert.Equal(HttpStatusCode.OK, response.StatusCode); + } - /// - /// Успешное обновление операции - /// - /// - [Fact] - public async Task UpdateAsync_returns_success() - { - //act - var dto = dtos.FirstOrDefault()!; - var response = await client.UpdateAsync(idWell, 1, dto, CancellationToken.None); + /// + /// Успешное добавление операций (с предварительной очисткой данных) + /// + /// + [Fact] + public async Task InsertRangeWithDeleteBefore_returns_success() + { + //arrange + var well = await dbContext.Wells.FirstAsync(); + var entity = CreateWellOperation(well.Id); + var dtos = new[] { entity.Adapt() }; + + //act + var response = await client.InsertRangeAsync(well.Id, 1, true, dtos); + + //assert + Assert.Equal(HttpStatusCode.OK, response.StatusCode); + } + + /// + /// Успешное обновление операции + /// + /// + [Fact] + public async Task UpdateAsync_returns_success() + { + //arrange + var well = await dbContext.Wells.FirstAsync(); + var entity = CreateWellOperation(well.Id); + dbContext.WellOperations.Add(entity); + await dbContext.SaveChangesAsync(); + + var dto = entity.Adapt(); + + //act + var response = await client.UpdateAsync(well.Id, entity.Id, dto, CancellationToken.None); + + //assert + Assert.Equal(HttpStatusCode.OK, response.StatusCode); + } - //assert - Assert.Equal(HttpStatusCode.OK, response.StatusCode); - } - /// /// Получение плановых операций /// @@ -99,8 +92,14 @@ public class WellOperationControllerTest : BaseIntegrationTest public async Task GetPageOperationsPlanAsync_returns_success() { //arrange - dbContext.CleanupDbSet(); - await client.InsertRangeAsync(idWell, WellOperation.IdOperationTypePlan, false, dtos); + var well = await dbContext.Wells.FirstAsync(); + var entity = CreateWellOperation(well.Id); + dbContext.WellOperations.Add(entity); + await dbContext.SaveChangesAsync(); + + var dto = entity.Adapt(); + var timezoneOffset = TimeSpan.FromHours(well.Timezone.Hours); + dto.DateStart = dto.DateStart.ToOffset(timezoneOffset); var request = new WellOperationRequestBase { @@ -108,49 +107,59 @@ public class WellOperationControllerTest : BaseIntegrationTest }; //act - var response = await client.GetPageOperationsPlanAsync(idWell, request, CancellationToken.None); + var response = await client.GetPageOperationsPlanAsync(well.Id, request, CancellationToken.None); //assert Assert.NotNull(response.Content); Assert.Single(response.Content.Items); - var dto = dtos[0]; - var wellOperation = response.Content.Items.First(); + var actualDto = response.Content.Items.First(); - var excludeProps = new[] { nameof(WellOperationDto.Id) }; - MatchHelper.Match(dto, wellOperation, excludeProps); + var excludeProps = new[] + { + nameof(WellOperationDto.LastUpdateDate) + }; + MatchHelper.Match(dto, actualDto, excludeProps); } [Fact] public async Task ImportPlanDefaultExcelFileAsync_returns_success() { //arrange - //TODO: вынести в метод расширения. Сделать когда доберёмся до рефакторинга операций по скважине - var resourceName = Assembly.GetExecutingAssembly() - .GetManifestResourceNames() - .FirstOrDefault(n => n.EndsWith("WellOperationsPlan.xlsx")); - - if (string.IsNullOrWhiteSpace(resourceName)) - throw new ArgumentNullException(nameof(resourceName)); - - var stream = Assembly.GetExecutingAssembly() - .GetManifestResourceStream(resourceName); - - if (stream is null) - throw new ArgumentNullException(nameof(stream)); + var stream = Assembly.GetExecutingAssembly().GetFileCopyStream("WellOperationsPlan.xlsx"); var memoryStream = new MemoryStream(); - stream.CopyTo(memoryStream); + await stream.CopyToAsync(memoryStream); memoryStream.Position = 0; + var well = await dbContext.Wells.FirstAsync(); + //act var streamPart = new StreamPart(memoryStream, "WellOperations.xlsx", "application/octet-stream"); - var response = await client.ImportPlanDefaultExcelFileAsync(idWell, new[] { streamPart }, CancellationToken.None); + var response = await client.ImportPlanDefaultExcelFileAsync(well.Id, new[] { streamPart }, CancellationToken.None); //assert Assert.NotNull(response.Content); Assert.Equal(4, response.Content.Count()); - Assert.True(response.Content.All(w => Math.Abs(w.DateStart.Offset.Hours - Defaults.Wells[0].Timezone.Hours) < 0.1)); + Assert.True(response.Content.All(w => Math.Abs(w.DateStart.Offset.Hours - Defaults.Timezone.Hours) < 0.1)); } + + private static WellOperation CreateWellOperation(int idWell) => + new() + { + IdWell = idWell, + IdWellSectionType = 2, + LastUpdateDate = DateTimeOffset.UtcNow, + IdCategory = 5000, + IdPlan = null, + CategoryInfo = "1", + IdType = 0, + DepthStart = 10.0, + DepthEnd = 20.0, + DateStart = new DateTimeOffset(new DateTime(2023, 1, 10), TimeSpan.FromHours(Defaults.Timezone.Hours)).ToUniversalTime(), + DurationHours = 1.0, + Comment = "1", + IdUser = 1 + }; } \ No newline at end of file diff --git a/AsbCloudWebApi.IntegrationTests/Repository/DataSaubStatRepositoryTest.cs b/AsbCloudWebApi.IntegrationTests/Repository/DataSaubStatRepositoryTest.cs index f44d32ed..9641dc3c 100644 --- a/AsbCloudWebApi.IntegrationTests/Repository/DataSaubStatRepositoryTest.cs +++ b/AsbCloudWebApi.IntegrationTests/Repository/DataSaubStatRepositoryTest.cs @@ -2,6 +2,7 @@ using AsbCloudApp.Repositories; using AsbCloudDb.Model; using Mapster; +using Microsoft.EntityFrameworkCore; using Microsoft.Extensions.DependencyInjection; using Xunit; @@ -9,157 +10,128 @@ namespace AsbCloudWebApi.IntegrationTests.Repository; public class DataSaubStatRepositoryTest : BaseIntegrationTest { - private static readonly TimeSpan timeSpan = TimeSpan.FromHours(1); + private readonly IDataSaubStatRepository dataSaubStatRepository; + + public DataSaubStatRepositoryTest(WebAppFactoryFixture factory) + : base(factory) + { + dataSaubStatRepository = scope.ServiceProvider.GetRequiredService(); + dbContext.CleanupDbSet(); + } - private static readonly DataSaubStatDto[] statDtos = new DataSaubStatDto[2] - { - new() - { - IdTelemetry = 1, - DateEnd = new DateTimeOffset(2024, 1, 1, 20, 25, 0, timeSpan), - DateStart = new DateTimeOffset(2024, 1, 1, 20, 15, 0, timeSpan), - AxialLoad = 10.0, - AxialLoadLimitMax = 10.0, - AxialLoadSp = 10.0, - BlockSpeedSp = 1000, - DepthEnd = 10.0, - DepthStart = 5.0, - EnabledSubsystems = 1, - Flow = 10.0, - HasOscillation = true, - Id = default, - IdCategory = 2, - IdFeedRegulator = 1, - Pressure = 10.0, - PressureIdle = 10.0, - PressureSp = 10.0, - RotorSpeed = 9.0, - RotorTorque = 9.0, - RotorTorqueSp = 9.0, - RotorTorqueLimitMax = 9.0, - Speed = 10.0 - }, - new() - { - IdTelemetry = 1, - DateEnd = new DateTimeOffset(2024, 2, 2, 20, 25, 0, timeSpan), - DateStart = new DateTimeOffset(2024, 2, 2, 20, 15, 0, timeSpan), - AxialLoad = 10.0, - AxialLoadLimitMax = 10.0, - AxialLoadSp = 10.0, - BlockSpeedSp = 1000, - DepthEnd = 10.0, - DepthStart = 5.0, - EnabledSubsystems = 1, - Flow = 10.0, - HasOscillation = true, - Id = default, - IdCategory = 2, - IdFeedRegulator = 1, - Pressure = 10.0, - PressureIdle = 10.0, - PressureSp = 10.0, - RotorSpeed = 10.0, - RotorTorque = 10.0, - RotorTorqueSp = 10.0, - RotorTorqueLimitMax = 10.0, - Speed = 10.0 - } - }; - private static readonly WellOperationCategory category = new() - { - Id = 2, - IdParent = null, - Name = "Категория 2" - }; + [Fact] + public async Task GetLastDatesAsync_returns_success() + { + //arrange + var telemetry = await dbContext.Telemetries.FirstAsync(); + var timeZoneOffset = TimeSpan.FromHours(telemetry.TimeZone.Hours); + var dataSaubStat = CreateDataSaubStat(telemetry.Id, timeZoneOffset); + dbContext.AddRange(dataSaubStat); + await dbContext.SaveChangesAsync(); - private readonly IDataSaubStatRepository dataSaubStatRepository; + var telemetryIds = dataSaubStat.Select(stat => stat.IdTelemetry).ToArray(); - public DataSaubStatRepositoryTest(WebAppFactoryFixture factory) : base(factory) - { - dataSaubStatRepository = scope.ServiceProvider.GetRequiredService(); - } + //act + var result = await dataSaubStatRepository.GetLastsAsync(telemetryIds, CancellationToken.None); - [Fact] - public async Task GetLastDatesAsync_returns_success() - { - //prepare - dbContext.CleanupDbSet(); - dbContext.CleanupDbSet(); + //assert + var expected = dataSaubStat.Max(stat => stat.DateEnd).ToOffset(timeZoneOffset); + var actual = result.First().DateEnd; + Assert.True((expected - actual).Ticks == 0.0); + } - var dbSetSaubStat = dbContext.Set(); - var dbSetCategories = dbContext.Set(); + [Fact] + public async Task InsertRangeAsync_returns_success() + { + //arrange + var telemetry = await dbContext.Telemetries.FirstAsync(); + var timeZoneOffset = TimeSpan.FromHours(telemetry.TimeZone.Hours); + var dataSaubStat = CreateDataSaubStat(telemetry.Id, timeZoneOffset); + var expectedDtos = dataSaubStat.Select(entity => ConvertToDto(entity, timeZoneOffset)); - var entities = statDtos.Select(stat => ConvertToEntity(stat)); + //act + await dataSaubStatRepository.InsertRangeAsync(expectedDtos, CancellationToken.None); - dbSetCategories.Add(category); - dbContext.SaveChanges(); + //assert + var entities = await dbContext.DataSaubStat.ToArrayAsync(); + var actualDtos = entities.Select(entity => ConvertToDto(entity, timeZoneOffset)); - dbSetSaubStat.AddRange(entities); - dbContext.SaveChanges(); + var excludedProps = new[] + { + nameof(DataSaubStat.Telemetry), + nameof(DataSaubStat.Id), + nameof(DataSaubStat.OperationCategory) + }; - //act - var telemetryIds = statDtos.Select(stat => stat.IdTelemetry).ToArray(); - var result = await dataSaubStatRepository.GetLastsAsync(telemetryIds, CancellationToken.None); + foreach (var actualDto in actualDtos) + { + var statDto = expectedDtos.FirstOrDefault(stat => stat.DateEnd == actualDto.DateEnd && + stat.DateStart == actualDto.DateStart); - var expected = statDtos.Max(stat => stat.DateEnd); - var actual = result.First().DateEnd; + MatchHelper.Match(actualDto, statDto, excludedProps); + } + } - //assert - Assert.True((expected - actual).Ticks == 0.0); - } + private static IEnumerable CreateDataSaubStat(int idTelemetry, TimeSpan timeZoneOffset) => new DataSaubStat[] + { + new() + { + IdTelemetry = idTelemetry, + DateEnd = new DateTimeOffset(2024, 1, 1, 20, 25, 0, timeZoneOffset).ToUniversalTime(), + DateStart = new DateTimeOffset(2024, 1, 1, 20, 15, 0, timeZoneOffset).ToUniversalTime(), + AxialLoad = 10.0, + AxialLoadLimitMax = 10.0, + AxialLoadSp = 10.0, + BlockSpeedSp = 1000, + DepthEnd = 10.0, + DepthStart = 5.0, + EnabledSubsystems = 1, + Flow = 10.0, + HasOscillation = true, + IdCategory = WellOperationCategory.IdSlide, + IdFeedRegulator = 1, + Pressure = 10.0, + PressureIdle = 10.0, + PressureSp = 10.0, + RotorSpeed = 9.0, + RotorTorque = 9.0, + RotorTorqueSp = 9.0, + RotorTorqueLimitMax = 9.0, + Speed = 10.0 + }, + new() + { + IdTelemetry = idTelemetry, + DateEnd = new DateTimeOffset(2024, 2, 2, 20, 25, 0, timeZoneOffset).ToUniversalTime(), + DateStart = new DateTimeOffset(2024, 2, 2, 20, 15, 0, timeZoneOffset).ToUniversalTime(), + AxialLoad = 10.0, + AxialLoadLimitMax = 10.0, + AxialLoadSp = 10.0, + BlockSpeedSp = 1000, + DepthEnd = 10.0, + DepthStart = 5.0, + EnabledSubsystems = 1, + Flow = 10.0, + HasOscillation = true, + IdCategory = WellOperationCategory.IdSlide, + IdFeedRegulator = 1, + Pressure = 10.0, + PressureIdle = 10.0, + PressureSp = 10.0, + RotorSpeed = 10.0, + RotorTorque = 10.0, + RotorTorqueSp = 10.0, + RotorTorqueLimitMax = 10.0, + Speed = 10.0 + } + }; - [Fact] - public async Task InsertRangeAsync_returns_success() - { - //prepare - dbContext.CleanupDbSet(); - var dbSet = dbContext.Set(); - - var dbSetCategories = dbContext.Set(); - dbSetCategories.Add(category); + private static DataSaubStatDto ConvertToDto(DataSaubStat entity, TimeSpan timeZoneOffset) + { + var dto = entity.Adapt(); + dto.DateStart = dto.DateStart.ToOffset(timeZoneOffset); + dto.DateEnd = dto.DateEnd.ToOffset(timeZoneOffset); - dbContext.SaveChanges(); - - //act - var result = await dataSaubStatRepository.InsertRangeAsync(statDtos, CancellationToken.None); - - //assert - Assert.Equal(statDtos.Length, result); - - var statDtosFromDb = dbSet.Select(stat => ConvertToDto(stat, timeSpan)).ToArray(); - - var excludedProps = new[] { - nameof(DataSaubStat.Telemetry), - nameof(DataSaubStat.Id), - nameof(DataSaubStat.OperationCategory) - }; - foreach (var statDtoFromDb in statDtosFromDb) - { - var statDto = statDtos - .Where(stat => stat.DateStart == statDtoFromDb.DateStart) - .Where(stat => stat.DateEnd == statDtoFromDb.DateEnd) - .FirstOrDefault(); - - MatchHelper.Match(statDtoFromDb, statDto, excludedProps); - } - } - - private static DataSaubStat ConvertToEntity(DataSaubStatDto stat) - { - var entity = stat.Adapt(); - entity.DateStart = entity.DateStart.ToUniversalTime(); - entity.DateEnd = entity.DateEnd.ToUniversalTime(); - - return entity; - } - - private static DataSaubStatDto ConvertToDto(DataSaubStat stat, TimeSpan timeSpan) - { - var dto = stat.Adapt(); - dto.DateStart = dto.DateStart.ToOffset(timeSpan); - dto.DateEnd = dto.DateEnd.ToOffset(timeSpan); - - return dto; - } -} + return dto; + } +} \ No newline at end of file