From f88381353e8b2880dd6011e0cfee9f66265e67b4 Mon Sep 17 00:00:00 2001 From: Olga Nemt Date: Thu, 7 Mar 2024 13:38:40 +0500 Subject: [PATCH 01/15] =?UTF-8?q?=D0=9F=D0=BE=D0=BB=D1=83=D1=87=D0=B5?= =?UTF-8?q?=D0=BD=D0=B8=D0=B5=20=D0=BE=D0=BF=D0=B5=D1=80=D0=B0=D1=86=D0=B8?= =?UTF-8?q?=D0=B9=20=D0=B4=D0=BB=D1=8F=20=D0=BF=D0=BE=D1=81=D1=82=D1=80?= =?UTF-8?q?=D0=BE=D0=B5=D0=BD=D0=B8=D1=8F=20=D0=BA=D0=BE=D0=BC=D0=BF=D0=BE?= =?UTF-8?q?=D0=B7=D0=B8=D1=82=D0=BD=D0=BE=D0=B9=20=D1=81=D0=BA=D0=B2=D0=B0?= =?UTF-8?q?=D0=B6=D0=B8=D0=BD=D1=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../IWellCompositeOperationService.cs | 21 +++ AsbCloudInfrastructure/DependencyInjection.cs | 1 + .../Services/WellCompositeOperationService.cs | 165 ++++++++++++++++++ .../WellCompositeOperationController.cs | 35 ++++ 4 files changed, 222 insertions(+) create mode 100644 AsbCloudApp/Services/IWellCompositeOperationService.cs create mode 100644 AsbCloudInfrastructure/Services/WellCompositeOperationService.cs create mode 100644 AsbCloudWebApi/Controllers/WellCompositeOperationController.cs diff --git a/AsbCloudApp/Services/IWellCompositeOperationService.cs b/AsbCloudApp/Services/IWellCompositeOperationService.cs new file mode 100644 index 00000000..94ba1f93 --- /dev/null +++ b/AsbCloudApp/Services/IWellCompositeOperationService.cs @@ -0,0 +1,21 @@ +using AsbCloudApp.Data; +using System.Collections.Generic; +using System.Threading; +using System.Threading.Tasks; + +namespace AsbCloudApp.Services +{ + /// + /// Интерфейс для вычисления композитной скважины + /// + public interface IWellCompositeOperationService + { + /// + /// Получение данных для построения композитной скважины + /// + /// + /// + /// + Task>> GetAsync(IEnumerable idsWells, CancellationToken token); + } +} diff --git a/AsbCloudInfrastructure/DependencyInjection.cs b/AsbCloudInfrastructure/DependencyInjection.cs index 2111356b..6250112f 100644 --- a/AsbCloudInfrastructure/DependencyInjection.cs +++ b/AsbCloudInfrastructure/DependencyInjection.cs @@ -198,6 +198,7 @@ namespace AsbCloudInfrastructure services.AddTransient, CrudCacheRepositoryBase>(); services.AddTransient(); + services.AddTransient(); // admin crud services: services.AddTransient, CrudCacheRepositoryBase>(s => diff --git a/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs b/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs new file mode 100644 index 00000000..562b82c6 --- /dev/null +++ b/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs @@ -0,0 +1,165 @@ +using AsbCloudApp.Data; +using AsbCloudApp.Services; +using AsbCloudDb.Model; +using Mapster; +using Microsoft.EntityFrameworkCore; +using System.Collections.Generic; +using System.Linq; +using System.Threading; +using System.Threading.Tasks; + +namespace AsbCloudInfrastructure.Services +{ + public class WellCompositeOperationService : IWellCompositeOperationService + { + private IAsbCloudDbContext db; + + /// + /// Тип секции "Транспортный стол" + /// + private const int wellSectionTransportTable = 5; + + /// + /// Тип секции "Эксплуатационная колонна" + /// + private const int wellSectionProductionString = 4; + + + /// + /// набор настроек для замены одной категории секции на другую + /// + private static Dictionary<(int, int), int> SettingsForSectionCategoryChange = new Dictionary<(int, int), int>() { + { (2, 5096), 5013 }, + { (2, 5008), 5013 }, + { (3, 5096), 5084 }, + { (3, 5008), 5084 }, + { (3, 5085), 5015 }, + { (3, 5014), 5015 }, + { (31, 5014), 5015 }, + { (31, 5012), 5013 }, + { (31, 5083), 5013 }, + { (4, 5085), 5015 }, + { (4, 5087), 5015 }, + { (4, 5014), 5015 }, + { (4, 5053), 5037 }, + { (4, 5084), 5096 }, + { (4, 5086), 5013 }, + { (6, 5085), 5015 }, + { (6, 5036), 5034 }, + { (6, 5035), 5097 } + }; + + private Dictionary> WellSectionTypesWithCategories = new Dictionary>() + { + { 2, new List{ 5001, 5003, 5013, 5000, 5022, 5017, 5023, 4007, 5090 } }, + { 3, new List{ 5001, 5015, 5037, 5057, 5003, 5036, 5084, 5013, 5000, 5022, 5017, 4007, 5090, 5045, 5042, 5046 } }, + { 31, new List{ 5001, 5015, 5037, 5057, 5003, 5036, 5013, 5022, 5017, 5023, 4007, 5045, 5042, 5046 } }, + { 4, new List{ 5001, 5015, 5046, 5037, 5097, 5057, 5003, 5036, 5008, 5003, 5036, 5013, 5000, 5029, 5022, 5017, 5019, 5042, 5046 } }, + { 6, new List{ 5001, 5015, 5034, 5037, 5097, 5057, 5003 } }, + }; + + + + public WellCompositeOperationService(IAsbCloudDbContext db) + { + this.db = db; + } + + public async Task>> GetAsync(IEnumerable idsWells, CancellationToken token) + { + var sections = await db.WellSectionTypes + .Select(t => t.Adapt()) + .ToArrayAsync(token); + var sectionsDict = sections.ToDictionary(s => s.Id, s => s.Caption); + + var categories = await db.WellOperationCategories + .Select(c => c.Adapt()) + .ToArrayAsync(token); + var categoriesDict = categories.ToDictionary(s => s.Id, s => s.Name); + + var idsWellSectionTypes = WellSectionTypesWithCategories.Select(t => t.Key); + + var groupedWellOperations = db.WellOperations + .Where(o => idsWells.Contains(o.IdWell)) + .Where(o => o.IdType == WellOperation.IdOperationTypeFact) + .Where(o => idsWellSectionTypes.Contains(o.IdWellSectionType)) + .AsEnumerable() + .GroupBy(o => o.IdWellSectionType, (key, group) => group.Where(x => WellSectionTypesWithCategories[key].Contains(x.IdCategory))) + .SelectMany(o => o) + .Select(x => Convert(x, sectionsDict, categoriesDict)) + .GroupBy(o => (o.IdWellSectionType, o.IdCategory, o.IdWell), (gr, o) => o.Count() == 1 ? o.FirstOrDefault()! : new WellOperationDataDto() + { + IdWellSectionType = o.FirstOrDefault()!.IdWellSectionType, + IdCategory = o.FirstOrDefault()!.IdCategory, + DepthStart = o.Max(x => x.DepthStart), + DurationHours = o.Sum(x => x.DurationHours), + IdWell = o.FirstOrDefault()!.IdWell, + WellSectionTypeCaption = o.FirstOrDefault()!.WellSectionTypeCaption, + OperationCategoryName = o.FirstOrDefault()!.OperationCategoryName + }); + + var wellOperationsWithComposite = new List>(); + var operationsGroupBySectionAndCategory = groupedWellOperations.GroupBy(o => (o.IdWellSectionType, o.IdCategory), (key, group) => group.ToList()); + foreach (var operationGroupBySectionAndCategory in operationsGroupBySectionAndCategory) + { + var dictElem = operationGroupBySectionAndCategory.ToDictionary(o => o.IdWell); + + var currentOperation = operationGroupBySectionAndCategory.FirstOrDefault()!; + var composite = new WellOperationDataDto() + { + IdWell = 0, + IdCategory = currentOperation.IdCategory, + IdWellSectionType = currentOperation.IdWellSectionType, + DurationHours = currentOperation.DurationHours, + DepthStart = currentOperation.DepthStart, + OperationCategoryName = currentOperation.OperationCategoryName, + WellSectionTypeCaption = currentOperation.WellSectionTypeCaption, + }; + dictElem.Add(0, composite); + + if (operationGroupBySectionAndCategory.Count() == 1) + { + wellOperationsWithComposite.Add(dictElem); + continue; + } + + var maxDurationHours = operationGroupBySectionAndCategory.Max(o => o.DurationHours); + var minDurationHours = operationGroupBySectionAndCategory.Min(o => o.DurationHours); + if (maxDurationHours == minDurationHours) + { + composite.DepthStart = operationGroupBySectionAndCategory.Max(o => o.DepthStart); + } + else + { + composite.DepthStart = operationGroupBySectionAndCategory.Min(o => o.DepthStart); + } + composite.DurationHours = minDurationHours; + dictElem[0] = composite; + wellOperationsWithComposite.Add(dictElem); + } + return wellOperationsWithComposite; + } + + private static WellOperationDataDto Convert(WellOperation entity, Dictionary sectionsDict, Dictionary categoriesDict) + { + var dto = new WellOperationDataDto(); + dto.IdWellSectionType = entity.IdWellSectionType == wellSectionTransportTable + ? wellSectionProductionString + : entity.IdWellSectionType; + dto.IdCategory = (SettingsForSectionCategoryChange.TryGetValue(((entity.IdWellSectionType == wellSectionTransportTable ? wellSectionProductionString : entity.IdWellSectionType), entity.IdCategory), out int newIdCategory)) + ? newIdCategory + : entity.IdCategory; + dto.DepthStart = entity.DepthStart; + dto.DurationHours = entity.DurationHours; + dto.IdWell = entity.IdWell; + dto.OperationCategoryName = categoriesDict.TryGetValue(dto.IdCategory, out string? CategoryName) + ? CategoryName + : string.Empty; + dto.WellSectionTypeCaption = sectionsDict.TryGetValue(dto.IdWellSectionType, out string? WellSectionName) + ? WellSectionName + : string.Empty; + + return dto; + } + } +} diff --git a/AsbCloudWebApi/Controllers/WellCompositeOperationController.cs b/AsbCloudWebApi/Controllers/WellCompositeOperationController.cs new file mode 100644 index 00000000..e2e4ee4b --- /dev/null +++ b/AsbCloudWebApi/Controllers/WellCompositeOperationController.cs @@ -0,0 +1,35 @@ +using AsbCloudApp.Data; +using AsbCloudApp.Services; +using Microsoft.AspNetCore.Authorization; +using Microsoft.AspNetCore.Mvc; +using System.Collections.Generic; +using System.Threading; +using System.Threading.Tasks; + +namespace AsbCloudWebApi.Controllers +{ + + [ApiController] + [Authorize] + [Route("api/[controller]")] + public class WellCompositeOperationController : ControllerBase + { + private readonly IWellCompositeOperationService wellCompositeOperationService; + + public WellCompositeOperationController(IWellCompositeOperationService wellCompositeOperationService, IWellService wellService) + { + this.wellCompositeOperationService = wellCompositeOperationService; + } + + [HttpGet] + [ProducesResponseType(typeof(List>), (int)System.Net.HttpStatusCode.OK)] + public async Task GetAsync([FromQuery] IEnumerable idsWells, CancellationToken token) + { + var result = await wellCompositeOperationService.GetAsync(idsWells, token) + .ConfigureAwait(false); + + return Ok(result); + } + } + +} From dc4d9b1708d67047f82810c0bc60598ea2068277 Mon Sep 17 00:00:00 2001 From: Olga Nemt Date: Thu, 7 Mar 2024 13:48:11 +0500 Subject: [PATCH 02/15] WellOperationDataDto --- AsbCloudApp/Data/WellOperationDataDto.cs | 39 ++++++++++++++++++++++++ 1 file changed, 39 insertions(+) create mode 100644 AsbCloudApp/Data/WellOperationDataDto.cs diff --git a/AsbCloudApp/Data/WellOperationDataDto.cs b/AsbCloudApp/Data/WellOperationDataDto.cs new file mode 100644 index 00000000..874bd65c --- /dev/null +++ b/AsbCloudApp/Data/WellOperationDataDto.cs @@ -0,0 +1,39 @@ +namespace AsbCloudApp.Data +{ + /// Операция на скважине + public class WellOperationDataDto : IWellRelated + { + /// + public int IdWell { get; set; } + + /// + /// id секции скважины + /// + public int IdWellSectionType { get; set; } + + /// + /// id категории операции + /// + public int IdCategory { get; set; } + + /// + /// Глубина на начало операции, м + /// + public double DepthStart { get; set; } + + /// + /// Продолжительность, часы + /// + public double DurationHours { get; set; } + + /// + /// Наименование секции + /// + public string WellSectionTypeCaption { get; set; } = string.Empty; + + /// + /// Наименование категории + /// + public string OperationCategoryName { get; set; } = string.Empty; + } +} From 3828c781299d5ac3b8bbf13b4b0d279c4043dc8c Mon Sep 17 00:00:00 2001 From: Olga Nemt Date: Mon, 11 Mar 2024 14:11:13 +0500 Subject: [PATCH 03/15] =?UTF-8?q?=D0=9F=D1=80=D0=B0=D0=B2=D0=BA=D0=B8=20?= =?UTF-8?q?=D0=BF=D0=BE=20=D1=80=D0=B5=D0=B7=D1=83=D0=BB=D1=8C=D1=82=D0=B0?= =?UTF-8?q?=D1=82=D0=B0=D0=BC=20=D1=80=D0=B5=D0=B2=D1=8C=D1=8E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Repositories/IWellOperationRepository.cs | 8 + AsbCloudApp/Requests/WellOperationRequest.cs | 18 +- .../Repository/WellOperationRepository.cs | 25 ++ .../Services/WellCompositeOperationService.cs | 224 +++++++++++------- .../WellCompositeOperationController.cs | 18 +- 5 files changed, 207 insertions(+), 86 deletions(-) diff --git a/AsbCloudApp/Repositories/IWellOperationRepository.cs b/AsbCloudApp/Repositories/IWellOperationRepository.cs index cf277304..dd39ce52 100644 --- a/AsbCloudApp/Repositories/IWellOperationRepository.cs +++ b/AsbCloudApp/Repositories/IWellOperationRepository.cs @@ -42,6 +42,14 @@ namespace AsbCloudApp.Repositories /// Task> GetAsync(WellOperationRequest request, CancellationToken token); + /// + /// Получить список операций по запросу + /// + /// + /// + /// + Task> GetAsync(WellsOperationRequest request, CancellationToken token); + /// /// Получить страницу списка операций /// diff --git a/AsbCloudApp/Requests/WellOperationRequest.cs b/AsbCloudApp/Requests/WellOperationRequest.cs index ab5b901e..89cd6858 100644 --- a/AsbCloudApp/Requests/WellOperationRequest.cs +++ b/AsbCloudApp/Requests/WellOperationRequest.cs @@ -72,7 +72,7 @@ namespace AsbCloudApp.Requests this.LeDepth = request.LeDepth; this.GeDate = request.GeDate; this.LtDate = request.LtDate; - + this.OperationCategoryIds = request.OperationCategoryIds; this.OperationType = request.OperationType; this.SectionTypeIds = request.SectionTypeIds; @@ -82,4 +82,20 @@ namespace AsbCloudApp.Requests this.SortFields = request.SortFields; } } + + /// + /// Параметры для запроса списка операций (с массивом id скважин) + /// + public class WellsOperationRequest : WellOperationRequestBase + { + /// + /// ids скважин + /// + public IEnumerable IdsWell { get; set; } = null!; + + /// + /// Тип 0 = План или 1 = Факт + /// + public int IdType { get; set; } + } } diff --git a/AsbCloudInfrastructure/Repository/WellOperationRepository.cs b/AsbCloudInfrastructure/Repository/WellOperationRepository.cs index 57bf3768..be039c86 100644 --- a/AsbCloudInfrastructure/Repository/WellOperationRepository.cs +++ b/AsbCloudInfrastructure/Repository/WellOperationRepository.cs @@ -205,6 +205,31 @@ public class WellOperationRepository : IWellOperationRepository return dtos.Select(Convert); } + public async Task> GetAsync( + WellsOperationRequest request, + CancellationToken token) + { + var query = db.WellOperations + .Where(o => request.IdsWell.Contains(o.IdWell)) + .Where(o => request.IdType == o.IdType) + .Where(o => request.SectionTypeIds != null ? request.SectionTypeIds.Contains(o.IdWellSectionType) : true) + .Where(o => request.OperationCategoryIds != null ? request.OperationCategoryIds.Contains(o.IdCategory) : true) + .Select(o => new WellOperationDataDto(){ + DepthStart = o.DepthStart, + DurationHours = o.DurationHours, + IdCategory = o.IdCategory, + IdWell = o.IdWell, + IdWellSectionType = o.IdWellSectionType, + OperationCategoryName = o.OperationCategory.Name, + WellSectionTypeCaption = o.WellSectionType.Caption, + }) + .AsNoTracking(); + + var dtos = await query.ToArrayAsync(token); + + return dtos; + } + /// public async Task> GetPageAsync( WellOperationRequest request, diff --git a/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs b/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs index 562b82c6..0056b267 100644 --- a/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs +++ b/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs @@ -1,7 +1,8 @@ using AsbCloudApp.Data; +using AsbCloudApp.Repositories; +using AsbCloudApp.Requests; using AsbCloudApp.Services; using AsbCloudDb.Model; -using Mapster; using Microsoft.EntityFrameworkCore; using System.Collections.Generic; using System.Linq; @@ -12,7 +13,9 @@ namespace AsbCloudInfrastructure.Services { public class WellCompositeOperationService : IWellCompositeOperationService { - private IAsbCloudDbContext db; + private ICrudRepository wellSectionTypeRepository; + private IWellOperationCategoryRepository wellOperationCategoryRepository; + private IWellOperationRepository wellOperationRepository; /// /// Тип секции "Транспортный стол" @@ -49,115 +52,168 @@ namespace AsbCloudInfrastructure.Services { (6, 5035), 5097 } }; - private Dictionary> WellSectionTypesWithCategories = new Dictionary>() + private HashSet<(int IdSectionType, int IdCategory)> WellSectionTypesWithCategories = new HashSet<(int IdSectionType, int IdCategory)>() { - { 2, new List{ 5001, 5003, 5013, 5000, 5022, 5017, 5023, 4007, 5090 } }, - { 3, new List{ 5001, 5015, 5037, 5057, 5003, 5036, 5084, 5013, 5000, 5022, 5017, 4007, 5090, 5045, 5042, 5046 } }, - { 31, new List{ 5001, 5015, 5037, 5057, 5003, 5036, 5013, 5022, 5017, 5023, 4007, 5045, 5042, 5046 } }, - { 4, new List{ 5001, 5015, 5046, 5037, 5097, 5057, 5003, 5036, 5008, 5003, 5036, 5013, 5000, 5029, 5022, 5017, 5019, 5042, 5046 } }, - { 6, new List{ 5001, 5015, 5034, 5037, 5097, 5057, 5003 } }, + { (2, 5001) }, + { (2, 5003) }, + { (2, 5013) }, + { (2, 5000) }, + { (2, 5022) }, + { (2, 5017) }, + { (2, 5023) }, + { (2, 4007) }, + { (2, 5090) }, + { (3, 5001) }, + { (3, 5015) }, + { (3, 5037) }, + { (3, 5057) }, + { (3, 5003) }, + { (3, 5036) }, + { (3, 5084) }, + { (3, 5013) }, + { (3, 5000) }, + { (3, 5022) }, + { (3, 5017) }, + { (3, 4007) }, + { (3, 5090) }, + { (3, 5045) }, + { (3, 5042) }, + { (3, 5046) }, + { (31, 5001) }, + { (31, 5015) }, + { (31, 5037) }, + { (31, 5057) }, + { (31, 5003) }, + { (31, 5036) }, + { (31, 5013) }, + { (31, 5022) }, + { (31, 5017) }, + { (31, 5023) }, + { (31, 4007) }, + { (31, 5045) }, + { (31, 5042) }, + { (31, 5046) }, + { (4, 5001) }, + { (4, 5015) }, + { (4, 5046) }, + { (4, 5037) }, + { (4, 5097) }, + { (4, 5057) }, + { (4, 5003) }, + { (4, 5036) }, + { (4, 5008) }, + { (4, 5003) }, + { (4, 5036) }, + { (4, 5013) }, + { (4, 5000) }, + { (4, 5029) }, + { (4, 5022) }, + { (4, 5017) }, + { (4, 5019) }, + { (4, 5042) }, + { (4, 5046) }, + { (6, 5001) }, + { (6, 5015) }, + { (6, 5034) }, + { (6, 5037) }, + { (6, 5097) }, + { (6, 5057) }, + { (6, 5003) } }; - public WellCompositeOperationService(IAsbCloudDbContext db) + public WellCompositeOperationService( + ICrudRepository wellSectionTypeRepository, + IWellOperationCategoryRepository wellOperationCategoryRepository, + IWellOperationRepository wellOperationRepository) { - this.db = db; + this.wellSectionTypeRepository = wellSectionTypeRepository; + this.wellOperationCategoryRepository = wellOperationCategoryRepository; + this.wellOperationRepository = wellOperationRepository; } public async Task>> GetAsync(IEnumerable idsWells, CancellationToken token) { - var sections = await db.WellSectionTypes - .Select(t => t.Adapt()) - .ToArrayAsync(token); + var sections = await wellSectionTypeRepository.GetAllAsync(token); var sectionsDict = sections.ToDictionary(s => s.Id, s => s.Caption); - var categories = await db.WellOperationCategories - .Select(c => c.Adapt()) - .ToArrayAsync(token); + var categories = wellOperationCategoryRepository.Get(true); var categoriesDict = categories.ToDictionary(s => s.Id, s => s.Name); - var idsWellSectionTypes = WellSectionTypesWithCategories.Select(t => t.Key); + var idsWellSectionTypes = WellSectionTypesWithCategories.Select(t => t.IdSectionType); + var usedCategories = WellSectionTypesWithCategories.Select(c => c.IdCategory).Distinct(); - var groupedWellOperations = db.WellOperations - .Where(o => idsWells.Contains(o.IdWell)) - .Where(o => o.IdType == WellOperation.IdOperationTypeFact) - .Where(o => idsWellSectionTypes.Contains(o.IdWellSectionType)) - .AsEnumerable() - .GroupBy(o => o.IdWellSectionType, (key, group) => group.Where(x => WellSectionTypesWithCategories[key].Contains(x.IdCategory))) - .SelectMany(o => o) - .Select(x => Convert(x, sectionsDict, categoriesDict)) - .GroupBy(o => (o.IdWellSectionType, o.IdCategory, o.IdWell), (gr, o) => o.Count() == 1 ? o.FirstOrDefault()! : new WellOperationDataDto() - { - IdWellSectionType = o.FirstOrDefault()!.IdWellSectionType, - IdCategory = o.FirstOrDefault()!.IdCategory, - DepthStart = o.Max(x => x.DepthStart), - DurationHours = o.Sum(x => x.DurationHours), - IdWell = o.FirstOrDefault()!.IdWell, - WellSectionTypeCaption = o.FirstOrDefault()!.WellSectionTypeCaption, - OperationCategoryName = o.FirstOrDefault()!.OperationCategoryName - }); + var wellOperationRequest = new WellsOperationRequest() + { + IdsWell = idsWells, + OperationCategoryIds = usedCategories, + SectionTypeIds = idsWellSectionTypes, + IdType = WellOperation.IdOperationTypeFact + }; + var operations = await wellOperationRepository.GetAsync(wellOperationRequest, token); + + var renamedOperations = operations.Select(o => UpdateIdWellSectionAndIdCategory(o, sectionsDict, categoriesDict)); var wellOperationsWithComposite = new List>(); - var operationsGroupBySectionAndCategory = groupedWellOperations.GroupBy(o => (o.IdWellSectionType, o.IdCategory), (key, group) => group.ToList()); - foreach (var operationGroupBySectionAndCategory in operationsGroupBySectionAndCategory) + var compositeDepth = 0d; + foreach ((int IdSection, int IdCategory) in WellSectionTypesWithCategories) { - var dictElem = operationGroupBySectionAndCategory.ToDictionary(o => o.IdWell); + var filteredByTemplate = renamedOperations + .Where(o => o.IdWellSectionType == IdSection) + .Where(o => o.IdCategory == IdCategory); - var currentOperation = operationGroupBySectionAndCategory.FirstOrDefault()!; - var composite = new WellOperationDataDto() - { - IdWell = 0, - IdCategory = currentOperation.IdCategory, - IdWellSectionType = currentOperation.IdWellSectionType, - DurationHours = currentOperation.DurationHours, - DepthStart = currentOperation.DepthStart, - OperationCategoryName = currentOperation.OperationCategoryName, - WellSectionTypeCaption = currentOperation.WellSectionTypeCaption, - }; - dictElem.Add(0, composite); - - if (operationGroupBySectionAndCategory.Count() == 1) - { - wellOperationsWithComposite.Add(dictElem); + if (!filteredByTemplate.Any()) continue; - } - var maxDurationHours = operationGroupBySectionAndCategory.Max(o => o.DurationHours); - var minDurationHours = operationGroupBySectionAndCategory.Min(o => o.DurationHours); - if (maxDurationHours == minDurationHours) + var groupedByWell = filteredByTemplate.GroupBy(o => o.IdWell); + + var aggreagtedByWell = groupedByWell.Select(g => new WellOperationDataDto { - composite.DepthStart = operationGroupBySectionAndCategory.Max(o => o.DepthStart); - } - else - { - composite.DepthStart = operationGroupBySectionAndCategory.Min(o => o.DepthStart); - } - composite.DurationHours = minDurationHours; - dictElem[0] = composite; - wellOperationsWithComposite.Add(dictElem); + IdCategory = IdCategory, + IdWell = g.Key, + IdWellSectionType = IdSection, + DepthStart = g.Min(o => o.DepthStart), + DurationHours = g.Sum(o => o.DurationHours), + OperationCategoryName = g.First().OperationCategoryName, + WellSectionTypeCaption = g.First().WellSectionTypeCaption, + }); + + var composite = aggreagtedByWell + .OrderBy(o => o.DurationHours) + .ThenByDescending(o => o.DepthStart) + .First(); + composite.IdWell = 0; + if (compositeDepth > composite.DepthStart) + composite.DepthStart = compositeDepth; + + compositeDepth = composite.DepthStart; + + + var resultItem = aggreagtedByWell.ToDictionary(o => o.IdWell); + resultItem.Add(0, composite); + + wellOperationsWithComposite.Add(resultItem); } return wellOperationsWithComposite; } - private static WellOperationDataDto Convert(WellOperation entity, Dictionary sectionsDict, Dictionary categoriesDict) + private WellOperationDataDto UpdateIdWellSectionAndIdCategory( + WellOperationDataDto dto, + Dictionary sectionTypes, + Dictionary operationCategories) { - var dto = new WellOperationDataDto(); - dto.IdWellSectionType = entity.IdWellSectionType == wellSectionTransportTable - ? wellSectionProductionString - : entity.IdWellSectionType; - dto.IdCategory = (SettingsForSectionCategoryChange.TryGetValue(((entity.IdWellSectionType == wellSectionTransportTable ? wellSectionProductionString : entity.IdWellSectionType), entity.IdCategory), out int newIdCategory)) - ? newIdCategory - : entity.IdCategory; - dto.DepthStart = entity.DepthStart; - dto.DurationHours = entity.DurationHours; - dto.IdWell = entity.IdWell; - dto.OperationCategoryName = categoriesDict.TryGetValue(dto.IdCategory, out string? CategoryName) - ? CategoryName - : string.Empty; - dto.WellSectionTypeCaption = sectionsDict.TryGetValue(dto.IdWellSectionType, out string? WellSectionName) - ? WellSectionName - : string.Empty; + if (dto.IdWellSectionType == wellSectionTransportTable) + { + dto.IdWellSectionType = wellSectionProductionString; + dto.WellSectionTypeCaption = sectionTypes[dto.IdWellSectionType] ?? string.Empty; + } + + if ((SettingsForSectionCategoryChange.TryGetValue((dto.IdWellSectionType, dto.IdCategory), out int newIdCategory))) + { + dto.IdCategory = newIdCategory; + dto.OperationCategoryName = operationCategories[dto.IdCategory] ?? string.Empty; + } return dto; } diff --git a/AsbCloudWebApi/Controllers/WellCompositeOperationController.cs b/AsbCloudWebApi/Controllers/WellCompositeOperationController.cs index e2e4ee4b..d662e4e8 100644 --- a/AsbCloudWebApi/Controllers/WellCompositeOperationController.cs +++ b/AsbCloudWebApi/Controllers/WellCompositeOperationController.cs @@ -15,21 +15,37 @@ namespace AsbCloudWebApi.Controllers public class WellCompositeOperationController : ControllerBase { private readonly IWellCompositeOperationService wellCompositeOperationService; + private readonly IWellService wellService; public WellCompositeOperationController(IWellCompositeOperationService wellCompositeOperationService, IWellService wellService) { this.wellCompositeOperationService = wellCompositeOperationService; + this.wellService = wellService; } [HttpGet] - [ProducesResponseType(typeof(List>), (int)System.Net.HttpStatusCode.OK)] + [ProducesResponseType(typeof(IList>), (int)System.Net.HttpStatusCode.OK)] public async Task GetAsync([FromQuery] IEnumerable idsWells, CancellationToken token) { + foreach (var idWell in idsWells) + if (!await UserHasAccessToWellAsync(idWell, token)) + return Forbid(); + var result = await wellCompositeOperationService.GetAsync(idsWells, token) .ConfigureAwait(false); return Ok(result); } + + protected async Task UserHasAccessToWellAsync(int idWell, CancellationToken token) + { + var idCompany = User.GetCompanyId(); + if (idCompany is not null && + await wellService.IsCompanyInvolvedInWellAsync((int)idCompany, idWell, token) + .ConfigureAwait(false)) + return true; + return false; + } } } From 18c6cb316fede5bda0bace4f69b1a180dc73057d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=A1=D1=82=D0=B5=D0=BF=D0=B0=D0=BD=D0=BE=D0=B2=20=D0=94?= =?UTF-8?q?=D0=BC=D0=B8=D1=82=D1=80=D0=B8=D0=B9?= Date: Mon, 11 Mar 2024 13:16:07 +0300 Subject: [PATCH 04/15] =?UTF-8?q?=D0=A0=D0=B5=D1=84=D0=B0=D0=BA=D1=82?= =?UTF-8?q?=D0=BE=D1=80=D0=B8=D0=BD=D0=B3=20=D0=B8=D0=BD=D1=84=D1=80=D0=B0?= =?UTF-8?q?=D1=81=D1=82=D1=80=D1=83=D0=BA=D1=82=D1=83=D1=80=D1=8B=20=D0=B4?= =?UTF-8?q?=D0=BB=D1=8F=20=D1=82=D0=B5=D1=81=D1=82=D0=BE=D0=B2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../BaseIntegrationTest.cs | 16 +- .../Data/Defaults.cs | 157 ++++++------------ .../DbConnection.cs | 15 ++ .../WebAppFactoryFixture.cs | 98 +++++------ AsbCloudWebApi/appsettings.Tests.json | 8 + 5 files changed, 131 insertions(+), 163 deletions(-) create mode 100644 AsbCloudWebApi.IntegrationTests/DbConnection.cs create mode 100644 AsbCloudWebApi/appsettings.Tests.json diff --git a/AsbCloudWebApi.IntegrationTests/BaseIntegrationTest.cs b/AsbCloudWebApi.IntegrationTests/BaseIntegrationTest.cs index add2e07b..aeaab07f 100644 --- a/AsbCloudWebApi.IntegrationTests/BaseIntegrationTest.cs +++ b/AsbCloudWebApi.IntegrationTests/BaseIntegrationTest.cs @@ -4,15 +4,23 @@ using Xunit; namespace AsbCloudWebApi.IntegrationTests; -public abstract class BaseIntegrationTest : IClassFixture +public abstract class BaseIntegrationTest : IClassFixture, + IDisposable { protected readonly IServiceScope scope; - - protected readonly IAsbCloudDbContext dbContext; + + protected readonly AsbCloudDbContext dbContext; protected BaseIntegrationTest(WebAppFactoryFixture factory) { scope = factory.Services.CreateScope(); - dbContext = scope.ServiceProvider.GetRequiredService(); + + dbContext = scope.ServiceProvider.GetRequiredService(); + } + + public void Dispose() + { + scope.Dispose(); + dbContext.Dispose(); } } \ No newline at end of file diff --git a/AsbCloudWebApi.IntegrationTests/Data/Defaults.cs b/AsbCloudWebApi.IntegrationTests/Data/Defaults.cs index 4142705c..a3667662 100644 --- a/AsbCloudWebApi.IntegrationTests/Data/Defaults.cs +++ b/AsbCloudWebApi.IntegrationTests/Data/Defaults.cs @@ -2,110 +2,55 @@ namespace AsbCloudWebApi.IntegrationTests.Data { - [System.Diagnostics.CodeAnalysis.SuppressMessage("Usage", "CA2211:Поля, не являющиеся константами, не должны быть видимыми", Justification = "<Ожидание>")] - public static class Defaults - { - public static Driller[] Drillers = new Driller[] - { - new() - { - Id = 1, - Name = "test1", - Surname = "test1", - Patronymic = "test1" - }, - new() - { - Id = 2, - Name = "test2", - Surname = "test2", - Patronymic = "test2" - } - }; + [System.Diagnostics.CodeAnalysis.SuppressMessage("Usage", "CA2211:Поля, не являющиеся константами, не должны быть видимыми", + Justification = "<Ожидание>")] + public static class Defaults + { + public static SimpleTimezone Timezone => new() + { + Hours = 1 + }; - public static WellOperation[] WellOperations = new WellOperation[] - { - new() - { - Id = 1, - IdWell = 1, - IdType = 1, - DateStart = DateTimeOffset.UtcNow.AddDays(-1), - CategoryInfo = "1", - Comment = "1", - DepthEnd = 20, - DepthStart = 10, - DurationHours = 1, - IdCategory = 5000, - IdPlan = null, - IdUser = 1, - IdWellSectionType = 1, - LastUpdateDate = DateTimeOffset.UtcNow - } - }; - - public static Deposit[] Deposits = new Deposit[] { - new() - { - Id = 1, - Caption = "Deposit1", - Latitude = 10, - Longitude = 20, - Timezone = GetTimezone() - } - }; - - public static Cluster[] Clusters = new Cluster[] { - new() - { - Id = 1, - IdDeposit = Deposits[0].Id, - Caption = "Cluster1", - Latitude = 10, - Longitude = 20, - Timezone = GetTimezone() - } - }; - - public static Telemetry[] Telemetries = new Telemetry[] - { - new() - { - Id = 1, - RemoteUid = "555-555-555", - TimeZone = GetTimezone() - } - }; - - public static Well[] Wells = new Well[] { - new() - { - Id = 1, - IdCluster = Clusters[0].Id, - IdWellType = 1, - IdState = 1, - Caption = "Well1", - Latitude = 10, - Longitude = 20, - IdTelemetry = Telemetries[0].Id, - Timezone = GetTimezone() - } - }; - - public static RelationCompanyWell[] RelationsCompanyWell = new RelationCompanyWell[] - { - new() { IdCompany = 1, IdWell = Wells[0].Id }, - }; - - public static RelationUserUserRole[] RelationsUserUserRole = new RelationUserUserRole[] - { - new(){ IdUserRole= 1, IdUser = 1} - }; - - private static SimpleTimezone GetTimezone() => - new () - { - Hours = 1 - }; - } -} + public static Deposit[] Deposits => new Deposit[] + { + new() + { + Caption = "Deposit1", + Latitude = 10, + Longitude = 20, + Timezone = Timezone, + Clusters = new[] + { + new Cluster + { + Caption = "Cluster1", + Latitude = 10, + Longitude = 20, + Timezone = Timezone, + Wells = new[] + { + new Well + { + IdWellType = 1, + IdState = 1, + Caption = "Well1", + Latitude = 10, + Longitude = 20, + Timezone = Timezone, + Telemetry = new Telemetry + { + RemoteUid = "555-555-555", + TimeZone = Timezone + }, + RelationCompaniesWells = new RelationCompanyWell[] + { + new() { IdCompany = 1 }, + }, + } + } + } + } + } + }; + } +} \ No newline at end of file diff --git a/AsbCloudWebApi.IntegrationTests/DbConnection.cs b/AsbCloudWebApi.IntegrationTests/DbConnection.cs new file mode 100644 index 00000000..fad06ed8 --- /dev/null +++ b/AsbCloudWebApi.IntegrationTests/DbConnection.cs @@ -0,0 +1,15 @@ +namespace AsbCloudWebApi.IntegrationTests; + +public class DbConnection +{ + public string Host { get; set; } = null!; + + public int Port { get; set; } + + public string Username { get; set; } = null!; + + public string Password { get; set; } = null!; + + public string GetConnectionString() => + $"Host={Host};Database={Guid.NewGuid()};Port={Port};Username={Username};Password={Password};Persist Security Info=True;Include Error Detail=True"; +} \ No newline at end of file diff --git a/AsbCloudWebApi.IntegrationTests/WebAppFactoryFixture.cs b/AsbCloudWebApi.IntegrationTests/WebAppFactoryFixture.cs index 44bd4b67..b990295b 100644 --- a/AsbCloudWebApi.IntegrationTests/WebAppFactoryFixture.cs +++ b/AsbCloudWebApi.IntegrationTests/WebAppFactoryFixture.cs @@ -1,4 +1,3 @@ -using AsbCloudDb; using AsbCloudDb.Model; using Microsoft.AspNetCore.Hosting; using Microsoft.AspNetCore.Mvc.Testing; @@ -8,87 +7,80 @@ using Microsoft.Extensions.DependencyInjection; using Refit; using System.Net.Http.Headers; using System.Text.Json; +using AsbCloudDb; using AsbCloudWebApi.IntegrationTests.Converters; -using Xunit; namespace AsbCloudWebApi.IntegrationTests; public class WebAppFactoryFixture : WebApplicationFactory, - IAsyncLifetime + IDisposable { - private static readonly JsonSerializerOptions jsonSerializerOptions = new() - { - PropertyNamingPolicy = JsonNamingPolicy.CamelCase, - PropertyNameCaseInsensitive = true, + private static readonly JsonSerializerOptions JsonSerializerOptions = new() + { + PropertyNamingPolicy = JsonNamingPolicy.CamelCase, + PropertyNameCaseInsensitive = true, Converters = { new ValidationResultConverter() } - }; + }; - private static readonly RefitSettings refitSettings = new RefitSettings(new SystemTextJsonContentSerializer(jsonSerializerOptions)); + private static readonly RefitSettings RefitSettings = new(new SystemTextJsonContentSerializer(JsonSerializerOptions)); - protected override void ConfigureWebHost(IWebHostBuilder builder) + protected override void ConfigureWebHost(IWebHostBuilder builder) { var configuration = new ConfigurationBuilder() - .AddJsonFile("appsettings.json") + .AddJsonFile("appsettings.Tests.json") .Build(); - var connectionString = configuration.GetConnectionString("TestConnection")!; - builder.ConfigureServices(services => + var dbConnection = configuration.GetSection("DbConnection").Get(); + var connectionString = dbConnection?.GetConnectionString(); + + builder.ConfigureServices(services => { - var descriptor = services.FirstOrDefault(d => d.ServiceType == typeof(DbContextOptions)); + var descriptor = services.SingleOrDefault(d => d.ServiceType == typeof(DbContextOptions)); - if (descriptor is not null) + if (descriptor != null) services.Remove(descriptor); services.AddDbContext(options => options.UseNpgsql(connectionString)); + + var serviceProvider = services.BuildServiceProvider(); + + using var scope = serviceProvider.CreateScope(); + var scopedServices = scope.ServiceProvider; + var dbContext = scopedServices.GetRequiredService(); + + dbContext.Database.EnsureCreatedAndMigrated(); + dbContext.Deposits.AddRange(Data.Defaults.Deposits); + dbContext.SaveChanges(); }); } - public async Task InitializeAsync() + public new void Dispose() { using var scope = Services.CreateScope(); var scopedServices = scope.ServiceProvider; var dbContext = scopedServices.GetRequiredService(); - dbContext.Database.EnsureDeleted(); - dbContext.Database.EnsureCreatedAndMigrated(); - await FillBaseDatasets(dbContext); + + dbContext.Database.EnsureDeleted(); } - private static async Task FillBaseDatasets(AsbCloudDbContext dbContext) - { - dbContext.AddRange(Data.Defaults.Deposits); - dbContext.AddRange(Data.Defaults.Clusters); - dbContext.AddRange(Data.Defaults.Wells); - dbContext.AddRange(Data.Defaults.RelationsCompanyWell); - dbContext.AddRange(Data.Defaults.Telemetries); - dbContext.AddRange(Data.Defaults.Drillers); - dbContext.AddRange(Data.Defaults.WellOperations); - await dbContext.SaveChangesAsync(); - } - - public new async Task DisposeAsync() + public T GetAuthorizedHttpClient(string uriSuffix) { - using var scope = Services.CreateScope(); - var scopedServices = scope.ServiceProvider; - var dbContext = scopedServices.GetRequiredService(); - - await dbContext.Database.EnsureDeletedAsync(); - } + var httpClient = GetAuthorizedHttpClient(); + if (string.IsNullOrEmpty(uriSuffix)) + return RestService.For(httpClient, RefitSettings); - public HttpClient GetAuthorizedHttpClient() - { - var httpClient = CreateClient(); - var jwtToken = ApiTokenHelper.GetAdminUserToken(); - httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", jwtToken); - return httpClient; - } + if (httpClient.BaseAddress is not null) + httpClient.BaseAddress = new Uri(httpClient.BaseAddress, uriSuffix); - public T GetAuthorizedHttpClient(string uriSuffix) - { - var httpClient = GetAuthorizedHttpClient(); - if (!string.IsNullOrEmpty(uriSuffix)) - if(httpClient.BaseAddress is not null) - httpClient.BaseAddress = new Uri(httpClient.BaseAddress, uriSuffix); - return RestService.For(httpClient, refitSettings); - } + return RestService.For(httpClient, RefitSettings); + } + + private HttpClient GetAuthorizedHttpClient() + { + var httpClient = CreateClient(); + var jwtToken = ApiTokenHelper.GetAdminUserToken(); + httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", jwtToken); + return httpClient; + } } \ No newline at end of file diff --git a/AsbCloudWebApi/appsettings.Tests.json b/AsbCloudWebApi/appsettings.Tests.json new file mode 100644 index 00000000..d04cf2b1 --- /dev/null +++ b/AsbCloudWebApi/appsettings.Tests.json @@ -0,0 +1,8 @@ +{ + "DbConnection": { + "Host": "localhost", + "Port": 5433, + "Username": "postgres", + "Password": "root" + } +} \ No newline at end of file From 3d828a21590324547ee91a50d6cf26d1b7a13f23 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=A1=D1=82=D0=B5=D0=BF=D0=B0=D0=BD=D0=BE=D0=B2=20=D0=94?= =?UTF-8?q?=D0=BC=D0=B8=D1=82=D1=80=D0=B8=D0=B9?= Date: Mon, 11 Mar 2024 13:19:50 +0300 Subject: [PATCH 05/15] =?UTF-8?q?=D0=A0=D0=B5=D1=84=D0=B0=D0=BA=D1=82?= =?UTF-8?q?=D0=BE=D1=80=D0=B8=D0=BD=D0=B3=20=D1=82=D0=B5=D1=81=D1=82=D0=BE?= =?UTF-8?q?=D0=B2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Controllers/AdminDepositControllerTest.cs | 20 +- .../ProcessMapPlanDrillingControllerTest.cs | 17 +- .../ProcessMapReportDrillingControllerTest.cs | 505 ++++++++---------- .../Controllers/ScheduleControllerTest.cs | 456 ++++++++-------- .../Controllers/SlipsStatControllerTest.cs | 111 ++-- .../WellOperationControllerTest.cs | 197 +++---- .../Repository/DataSaubStatRepositoryTest.cs | 254 ++++----- 7 files changed, 735 insertions(+), 825 deletions(-) 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 From caf2392f45941822c5318eaeee36efe41b1845b9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=A1=D1=82=D0=B5=D0=BF=D0=B0=D0=BD=D0=BE=D0=B2=20=D0=94?= =?UTF-8?q?=D0=BC=D0=B8=D1=82=D1=80=D0=B8=D0=B9?= Date: Tue, 12 Mar 2024 07:24:24 +0300 Subject: [PATCH 06/15] fix protobuf registered --- AsbCloudWebApi/ProtobufModel.cs | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) diff --git a/AsbCloudWebApi/ProtobufModel.cs b/AsbCloudWebApi/ProtobufModel.cs index fb3479e2..fc8b9995 100644 --- a/AsbCloudWebApi/ProtobufModel.cs +++ b/AsbCloudWebApi/ProtobufModel.cs @@ -5,13 +5,18 @@ namespace AsbCloudWebApi { public static class ProtobufModel { + private static readonly object SyncRoot = new(); + public static void EnshureRegistered() { - EnshureRegisteredDataSpin(); - EnshureRegisteredDataSaub(); - EnshureRegisteredWITS(); - EnshureRegisteredWirelineRunOutBaseDto(); - EnshureRegisteredWirelineRunOutDto(); + lock (SyncRoot) + { + EnshureRegisteredDataSpin(); + EnshureRegisteredDataSaub(); + EnshureRegisteredWITS(); + EnshureRegisteredWirelineRunOutBaseDto(); + EnshureRegisteredWirelineRunOutDto(); + } } private static void EnshureRegisteredWirelineRunOutBaseDto() From 45f0f50a347b63cab4572a98a706c9aeacc97d79 Mon Sep 17 00:00:00 2001 From: Olga Nemt Date: Tue, 12 Mar 2024 15:00:14 +0500 Subject: [PATCH 07/15] =?UTF-8?q?Bug=20fix=20+=20=D0=B0=D0=B2=D1=82=D0=BE?= =?UTF-8?q?=D1=82=D0=B5=D1=81=D1=82=D1=8B=20(=D1=8E=D0=BD=D0=B8=D1=82-?= =?UTF-8?q?=D1=82=D0=B5=D1=81=D1=82=D0=B8=D1=80=D0=BE=D0=B2=D0=B0=D0=BD?= =?UTF-8?q?=D0=B8=D0=B5)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Services/WellCompositeOperationService.cs | 10 +- .../WellCompositeOperationServiceTest.cs | 299 ++++++++++++++++++ 2 files changed, 304 insertions(+), 5 deletions(-) create mode 100644 AsbCloudWebApi.Tests/Services/WellCompositeOperation/WellCompositeOperationServiceTest.cs diff --git a/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs b/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs index 0056b267..3a02b6b2 100644 --- a/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs +++ b/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs @@ -141,7 +141,7 @@ namespace AsbCloudInfrastructure.Services var categories = wellOperationCategoryRepository.Get(true); var categoriesDict = categories.ToDictionary(s => s.Id, s => s.Name); - var idsWellSectionTypes = WellSectionTypesWithCategories.Select(t => t.IdSectionType); + var idsWellSectionTypes = WellSectionTypesWithCategories.Select(t => t.IdSectionType).Distinct(); var usedCategories = WellSectionTypesWithCategories.Select(c => c.IdCategory).Distinct(); var wellOperationRequest = new WellsOperationRequest() @@ -179,10 +179,10 @@ namespace AsbCloudInfrastructure.Services WellSectionTypeCaption = g.First().WellSectionTypeCaption, }); - var composite = aggreagtedByWell - .OrderBy(o => o.DurationHours) - .ThenByDescending(o => o.DepthStart) - .First(); + var composite = aggreagtedByWell.GroupBy(g => g.DurationHours).Count() == 1 + ? aggreagtedByWell.OrderByDescending(o => o.DepthStart).First() + : aggreagtedByWell.OrderBy(o => o.DepthStart).First(); + composite.IdWell = 0; if (compositeDepth > composite.DepthStart) composite.DepthStart = compositeDepth; diff --git a/AsbCloudWebApi.Tests/Services/WellCompositeOperation/WellCompositeOperationServiceTest.cs b/AsbCloudWebApi.Tests/Services/WellCompositeOperation/WellCompositeOperationServiceTest.cs new file mode 100644 index 00000000..eece10e8 --- /dev/null +++ b/AsbCloudWebApi.Tests/Services/WellCompositeOperation/WellCompositeOperationServiceTest.cs @@ -0,0 +1,299 @@ +using AsbCloudApp.Requests; +using AsbCloudDb.Model; +using AsbCloudInfrastructure.Repository; +using AsbCloudInfrastructure.Services.ProcessMaps.Report; +using AsbCloudInfrastructure.Services; +using NSubstitute; +using ProtoBuf.Meta; +using SignalRSwaggerGen.Enums; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading; +using System.Threading.Tasks; +using Xunit; +using AsbCloudApp.Repositories; +using AsbCloudApp.Data; +using AsbCloudApp.Services; + +namespace AsbCloudWebApi.Tests.Services.WellCompositeOperation +{ + public class WellCompositeOperationServiceTest + { + private WellCompositeOperationService service; + + private ICrudRepository wellSectionTypeRepository + = Substitute.For>(); + private IWellOperationCategoryRepository wellOperationCategoryRepository + = Substitute.For(); + private IWellOperationRepository wellOperationRepository + = Substitute.For(); + + + + private readonly static IEnumerable operationCategories = new List() + { + new(){Id = 5096, Name = "Шаблонирование перед спуском"}, + new(){Id = 5008, Name = "Шаблонировка во время бурения"}, + new(){Id = 5013, Name = "Подъем КНБК"}, + new(){Id = 5003, Name = "Бурение ротором"}, + new(){Id = 5036, Name = "Промывка"}, + new(){Id = 5012, Name = "Подъем инструмента"}, + new(){Id = 5083, Name = "Проработка принудительная"}, + }; + + private readonly static IEnumerable sectionTypes = new List() + { + new() {Id = 2, Caption = "Направление", Order = 0}, + new() {Id = 3, Caption = "Кондуктор", Order = 1}, + new() {Id = 31, Caption = "Техническая колонна", Order = 2} + }; + + private readonly static IEnumerable wellOperations1 = new List() + { + new WellOperationDataDto() + { + DepthStart = 50, + DurationHours = 1, + IdCategory = 5096, + IdWell = 55, + IdWellSectionType = 2, + OperationCategoryName = "Шаблонирование перед спуском", + WellSectionTypeCaption = "Направление" + }, + new WellOperationDataDto() + { + DepthStart = 84, + DurationHours = 1, + IdCategory = 5008, + IdWell = 64, + IdWellSectionType = 2, + OperationCategoryName = "Шаблонировка во время бурения", + WellSectionTypeCaption = "Направление" + } + }; + + private readonly static IEnumerable wellOperations2 = new List() + { + new WellOperationDataDto() + { + DepthStart = 10, + DurationHours = 1.5, + IdCategory = 5003, + IdWell = 55, + IdWellSectionType = 2, + OperationCategoryName = "Бурение ротором", + WellSectionTypeCaption = "Направление" + }, + new WellOperationDataDto() + { + DepthStart = 20, + DurationHours = 3.5, + IdCategory = 5003, + IdWell = 64, + IdWellSectionType = 2, + OperationCategoryName = "Бурение ротором", + WellSectionTypeCaption = "Направление" + } + }; + + private readonly static IEnumerable wellOperations3 = new List() + { + new WellOperationDataDto() + { + DepthStart = 1372, + DurationHours = 3, + IdCategory = 5036, + IdWell = 55, + IdWellSectionType = 3, + OperationCategoryName = "Промывка", + WellSectionTypeCaption = "Кондуктор" + }, + new WellOperationDataDto() + { + DepthStart = 1435, + DurationHours = 4, + IdCategory = 5036, + IdWell = 64, + IdWellSectionType = 3, + OperationCategoryName = "Промывка", + WellSectionTypeCaption = "Кондуктор" + } + }; + + private readonly static IEnumerable wellOperations4 = new List() + { + new WellOperationDataDto() + { + DepthStart = 1000, + DurationHours = 10, + IdCategory = 5012, + IdWell = 55, + IdWellSectionType = 31, + OperationCategoryName = "Подъем инструмента", + WellSectionTypeCaption = "Техническая колонна" + }, + new WellOperationDataDto() + { + DepthStart = 500, + DurationHours = 5, + IdCategory = 5083, + IdWell = 55, + IdWellSectionType = 31, + OperationCategoryName = "Проработка принудительная", + WellSectionTypeCaption = "Техническая колонна" + }, + new WellOperationDataDto() + { + DepthStart = 600, + DurationHours = 5, + IdCategory = 5083, + IdWell = 64, + IdWellSectionType = 31, + OperationCategoryName = "Проработка принудительная", + WellSectionTypeCaption = "Техническая колонна" + } + }; + + public WellCompositeOperationServiceTest() + { + + wellSectionTypeRepository.GetAllAsync(Arg.Any()) + .Returns(sectionTypes); + + wellOperationCategoryRepository.Get(Arg.Any()) + .Returns(operationCategories); + + service = new WellCompositeOperationService( + wellSectionTypeRepository, + wellOperationCategoryRepository, + wellOperationRepository); + } + + [Fact] + public async Task GetAsync_return_data() + { + // arrange + wellOperationRepository.GetAsync(Arg.Any(), Arg.Any()) + .Returns(wellOperations1); + + var idsWell = new List() { 55, 64 }; + + // act + var result = await service.GetAsync(idsWell, CancellationToken.None); + + // assert + var compositeWellOperation = result.SelectMany(o => o.Values.Where(o => o.IdWell == 0)).FirstOrDefault(); + Assert.NotNull(compositeWellOperation); + Assert.Equal(5013, compositeWellOperation.IdCategory); + Assert.Equal(1, compositeWellOperation.DurationHours); + Assert.Equal(84, compositeWellOperation.DepthStart); + + var currentWellOperations = result.SelectMany(o => o.Values.Where(o => o.IdWell != 0)); + var categories = currentWellOperations.Select(o => o.IdCategory).Distinct(); + Assert.NotNull(categories); + Assert.Single(categories); + Assert.Equal(5013, categories.First()); + + var categoryName = currentWellOperations.Select(o => o.OperationCategoryName).First(); + Assert.Equal("Подъем КНБК", categoryName); + } + + + [Fact] + public async Task GetAsync_return_data2() + { + // arrange + wellOperationRepository.GetAsync(Arg.Any(), Arg.Any()) + .Returns(wellOperations2); + + var idsWell = new List() { 55, 64 }; + + // act + var result = await service.GetAsync(idsWell, CancellationToken.None); + + // assert + var compositeWellOperation = result.SelectMany(o => o.Values.Where(o => o.IdWell == 0)).FirstOrDefault(); + Assert.NotNull(compositeWellOperation); + Assert.Equal(5003, compositeWellOperation.IdCategory); + Assert.Equal(1.5, compositeWellOperation.DurationHours); + Assert.Equal(10, compositeWellOperation.DepthStart); + } + + [Fact] + public async Task GetAsync_return_data3() + { + // arrange + wellOperationRepository.GetAsync(Arg.Any(), Arg.Any()) + .Returns(wellOperations3); + + var idsWell = new List() { 55, 64 }; + + // act + var result = await service.GetAsync(idsWell, CancellationToken.None); + + // assert + var compositeWellOperation = result.SelectMany(o => o.Values.Where(o => o.IdWell == 0)).FirstOrDefault(); + Assert.NotNull(compositeWellOperation); + Assert.Equal(5036, compositeWellOperation.IdCategory); + Assert.Equal(3, compositeWellOperation.DurationHours); + Assert.Equal(1372, compositeWellOperation.DepthStart); + } + + [Fact] + public async Task GetAsync_return_data4() + { + // arrange + wellOperationRepository.GetAsync(Arg.Any(), Arg.Any()) + .Returns(wellOperations4); + + var idsWell = new List() { 55, 64 }; + + // act + var result = await service.GetAsync(idsWell, CancellationToken.None); + + // assert + var currentWellOperations = result.SelectMany(o => o.Values.Where(o => o.IdWell != 0)); + var categories = currentWellOperations.Select(o => o.IdCategory).Distinct(); + Assert.NotNull(categories); + Assert.Single(categories); + Assert.Equal(5013, categories.First()); + + var categoryName = currentWellOperations.Select(o => o.OperationCategoryName).First(); + Assert.Equal("Подъем КНБК", categoryName); + + var compositeWellOperation = result.SelectMany(o => o.Values.Where(o => o.IdWell == 0)).FirstOrDefault(); + Assert.NotNull(compositeWellOperation); + Assert.Equal(5013, compositeWellOperation.IdCategory); + Assert.Equal(15, compositeWellOperation.DurationHours); + Assert.Equal(500, compositeWellOperation.DepthStart); + } + + [Fact] + public async Task GetAsync_return_data5() + { + // arrange + var wellOperations = new List(); + wellOperations.AddRange(wellOperations1); + wellOperations.AddRange(wellOperations2); + wellOperations.AddRange(wellOperations3); + wellOperations.AddRange(wellOperations4); + + wellOperationRepository.GetAsync(Arg.Any(), Arg.Any()) + .Returns(wellOperations); + + var idsWell = new List() { 55, 64 }; + + // act + var result = await service.GetAsync(idsWell, CancellationToken.None); + + // assert + Assert.Equal(4, result.Count()); + + var lastOperation = result.Last(); + var lastOperationComposite = lastOperation[0]; + Assert.Equal(1372, lastOperationComposite.DepthStart); + } + } +} From a03e9bb7f2a5b223a12d580a6e760cc6f8610323 Mon Sep 17 00:00:00 2001 From: ngfrolov Date: Tue, 12 Mar 2024 17:21:05 +0500 Subject: [PATCH 08/15] WellOperationRequest move copeCtor to WellOperationRequestBase --- AsbCloudApp/Requests/WellOperationRequest.cs | 50 +++++++++++++------- 1 file changed, 33 insertions(+), 17 deletions(-) diff --git a/AsbCloudApp/Requests/WellOperationRequest.cs b/AsbCloudApp/Requests/WellOperationRequest.cs index 89cd6858..3296c4ad 100644 --- a/AsbCloudApp/Requests/WellOperationRequest.cs +++ b/AsbCloudApp/Requests/WellOperationRequest.cs @@ -6,7 +6,7 @@ namespace AsbCloudApp.Requests /// /// параметры для запроса списка операций /// - public class WellOperationRequestBase: RequestBase + public class WellOperationRequestBase : RequestBase { /// /// фильтр по дате начала операции @@ -42,12 +42,40 @@ namespace AsbCloudApp.Requests /// фильтр по списку id конструкций секции /// public IEnumerable? SectionTypeIds { get; set; } + + /// + /// Параметры для запроса списка операций. + /// Базовый конструктор + /// + public WellOperationRequestBase() + { } + + /// + /// Параметры для запроса списка операций. + /// Копирующий конструктор + /// + /// + public WellOperationRequestBase(WellOperationRequestBase request) + { + GeDepth = request.GeDepth; + LeDepth = request.LeDepth; + GeDate = request.GeDate; + LtDate = request.LtDate; + + OperationCategoryIds = request.OperationCategoryIds; + OperationType = request.OperationType; + SectionTypeIds = request.SectionTypeIds; + + Skip = request.Skip; + Take = request.Take; + SortFields = request.SortFields; + } } /// /// Параметры для запроса списка операций (с id скважины) /// - public class WellOperationRequest: WellOperationRequestBase + public class WellOperationRequest : WellOperationRequestBase { /// /// id скважины @@ -57,7 +85,7 @@ namespace AsbCloudApp.Requests /// /// ctor /// - public WellOperationRequest(){} + public WellOperationRequest() { } /// /// копирующий конструктор @@ -65,21 +93,9 @@ namespace AsbCloudApp.Requests /// /// public WellOperationRequest(WellOperationRequestBase request, int idWell) + :base(request) { - this.IdWell = idWell; - - this.GeDepth = request.GeDepth; - this.LeDepth = request.LeDepth; - this.GeDate = request.GeDate; - this.LtDate = request.LtDate; - - this.OperationCategoryIds = request.OperationCategoryIds; - this.OperationType = request.OperationType; - this.SectionTypeIds = request.SectionTypeIds; - - this.Skip= request.Skip; - this.Take= request.Take; - this.SortFields = request.SortFields; + IdWell = idWell; } } From fc2589b5a25205f8537a2072c06964e17f043aa7 Mon Sep 17 00:00:00 2001 From: Olga Nemt Date: Wed, 13 Mar 2024 09:52:21 +0500 Subject: [PATCH 09/15] =?UTF-8?q?fix=20=D0=BE=D0=BF=D1=80=D0=B5=D0=B4?= =?UTF-8?q?=D0=B5=D0=BB=D0=B5=D0=BD=D0=B8=D1=8F=20=D0=BE=D0=BF=D0=B5=D1=80?= =?UTF-8?q?=D0=B0=D1=86=D0=B8=D0=B8,=20=D0=BA=D0=BE=D1=82=D0=BE=D1=80?= =?UTF-8?q?=D0=B0=D1=8F=20=D0=B4=D0=BE=D0=BB=D0=B6=D0=BD=D0=B0=20=D0=B2?= =?UTF-8?q?=D0=BE=D0=B9=D1=82=D0=B8=20=D0=B2=20=D0=BA=D0=BE=D0=BC=D0=BF?= =?UTF-8?q?=D0=BE=D0=B7=D0=B8=D1=82=D0=BD=D1=83=D1=8E=20=D0=BE=D0=BF=D0=B5?= =?UTF-8?q?=D1=80=D0=B0=D1=86=D0=B8=D1=8E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Services/WellCompositeOperationService.cs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs b/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs index 3a02b6b2..4730352d 100644 --- a/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs +++ b/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs @@ -179,9 +179,9 @@ namespace AsbCloudInfrastructure.Services WellSectionTypeCaption = g.First().WellSectionTypeCaption, }); - var composite = aggreagtedByWell.GroupBy(g => g.DurationHours).Count() == 1 - ? aggreagtedByWell.OrderByDescending(o => o.DepthStart).First() - : aggreagtedByWell.OrderBy(o => o.DepthStart).First(); + var composite = aggreagtedByWell.OrderBy(o => o.DurationHours). + ThenByDescending(o => o.DepthStart) + .First(); composite.IdWell = 0; if (compositeDepth > composite.DepthStart) From cc69ff832cff229d7a7846591258f5447c86bd42 Mon Sep 17 00:00:00 2001 From: ngfrolov Date: Wed, 13 Mar 2024 14:21:40 +0500 Subject: [PATCH 10/15] fix appsettings.Tests.json --- AsbCloudWebApi/appsettings.Tests.json | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/AsbCloudWebApi/appsettings.Tests.json b/AsbCloudWebApi/appsettings.Tests.json index d04cf2b1..e8132302 100644 --- a/AsbCloudWebApi/appsettings.Tests.json +++ b/AsbCloudWebApi/appsettings.Tests.json @@ -1,8 +1,8 @@ { "DbConnection": { "Host": "localhost", - "Port": 5433, + "Port": 5432, "Username": "postgres", - "Password": "root" + "Password": "q" } } \ No newline at end of file From fa9095b2f0e9a4e21e83be9a4560dc7923789109 Mon Sep 17 00:00:00 2001 From: Olga Nemt Date: Wed, 13 Mar 2024 14:30:54 +0500 Subject: [PATCH 11/15] =?UTF-8?q?=D0=9A=D0=BE=D0=BC=D0=BC=D0=B5=D0=BD?= =?UTF-8?q?=D1=82=D0=B0=D1=80=D0=B8=D0=B8=20=D0=BA=20=D0=B0=D0=B2=D1=82?= =?UTF-8?q?=D0=BE=D1=82=D0=B5=D1=81=D1=82=D0=B0=D0=BC=20+=20=D0=BF=D0=B5?= =?UTF-8?q?=D1=80=D0=B5=D0=B3=D1=80=D1=83=D0=B7=D0=BA=D0=B0=20=D0=BC=D0=B5?= =?UTF-8?q?=D1=82=D0=BE=D0=B4=D0=B0=20BuildQuery?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Repository/WellOperationRepository.cs | 61 ++++++++++++++----- .../WellCompositeOperationServiceTest.cs | 48 +++++++++++++-- 2 files changed, 88 insertions(+), 21 deletions(-) diff --git a/AsbCloudInfrastructure/Repository/WellOperationRepository.cs b/AsbCloudInfrastructure/Repository/WellOperationRepository.cs index be039c86..aa0d28ce 100644 --- a/AsbCloudInfrastructure/Repository/WellOperationRepository.cs +++ b/AsbCloudInfrastructure/Repository/WellOperationRepository.cs @@ -209,24 +209,10 @@ public class WellOperationRepository : IWellOperationRepository WellsOperationRequest request, CancellationToken token) { - var query = db.WellOperations - .Where(o => request.IdsWell.Contains(o.IdWell)) - .Where(o => request.IdType == o.IdType) - .Where(o => request.SectionTypeIds != null ? request.SectionTypeIds.Contains(o.IdWellSectionType) : true) - .Where(o => request.OperationCategoryIds != null ? request.OperationCategoryIds.Contains(o.IdCategory) : true) - .Select(o => new WellOperationDataDto(){ - DepthStart = o.DepthStart, - DurationHours = o.DurationHours, - IdCategory = o.IdCategory, - IdWell = o.IdWell, - IdWellSectionType = o.IdWellSectionType, - OperationCategoryName = o.OperationCategory.Name, - WellSectionTypeCaption = o.WellSectionType.Caption, - }) - .AsNoTracking(); + var query = BuildQuery(request) + .AsNoTracking(); var dtos = await query.ToArrayAsync(token); - return dtos; } @@ -497,6 +483,49 @@ public class WellOperationRepository : IWellOperationRepository return dtos.AsNoTracking(); } + /// + /// Получение данных по запросу + /// + /// + /// + /// + private IQueryable BuildQuery(WellsOperationRequest request) + { + var query = db.WellOperations + .Where(o => request.IdsWell.Contains(o.IdWell)) + .Where(o => request.IdType == o.IdType); + + if (request.SectionTypeIds?.Any() == true) + query = query.Where(o => request.SectionTypeIds.Contains(o.IdWellSectionType)); + + if (request.OperationCategoryIds?.Any() == true) + query = query.Where(o => request.OperationCategoryIds.Contains(o.IdCategory)); + + var dtos = query.Select(o => new WellOperationDataDto + { + DepthStart = o.DepthStart, + DurationHours = o.DurationHours, + IdCategory = o.IdCategory, + IdWell = o.IdWell, + IdWellSectionType = o.IdWellSectionType, + OperationCategoryName = o.OperationCategory.Name, + WellSectionTypeCaption = o.WellSectionType.Caption, + }); + + if (request.SortFields?.Any() == true) + { + dtos = dtos.SortBy(request.SortFields); + } + + if (request.Skip.HasValue) + dtos = dtos.Skip(request.Skip.Value); + + if (request.Take.HasValue) + dtos = dtos.Take(request.Take.Value); + + return dtos.AsNoTracking(); + } + private WellOperationDto Convert(WellOperationDto dto) { var timezone = wellService.GetTimezone(dto.IdWell); diff --git a/AsbCloudWebApi.Tests/Services/WellCompositeOperation/WellCompositeOperationServiceTest.cs b/AsbCloudWebApi.Tests/Services/WellCompositeOperation/WellCompositeOperationServiceTest.cs index eece10e8..d4659d8a 100644 --- a/AsbCloudWebApi.Tests/Services/WellCompositeOperation/WellCompositeOperationServiceTest.cs +++ b/AsbCloudWebApi.Tests/Services/WellCompositeOperation/WellCompositeOperationServiceTest.cs @@ -171,8 +171,14 @@ namespace AsbCloudWebApi.Tests.Services.WellCompositeOperation wellOperationRepository); } + /// + /// На вход подаются 2 операции с одинаковыми секциями (id = 2), но разными категориями (ids = 5096, 5008) и ключами скважин (ids = 55, 64) + /// Метод возвращает список из одной операции в разрезе 3-х скважин: 2 текущие скважины и одна композитная + /// Операция должна иметь категорию 5013 для всех трех скважин + /// + /// [Fact] - public async Task GetAsync_return_data() + public async Task GetAsync_return_composite_and_others_with_category_5013() { // arrange wellOperationRepository.GetAsync(Arg.Any(), Arg.Any()) @@ -200,9 +206,14 @@ namespace AsbCloudWebApi.Tests.Services.WellCompositeOperation Assert.Equal("Подъем КНБК", categoryName); } - + /// + /// На вход подаются 2 операции с одинаковыми секциями (id = 2) и категориями (id = 5003), но разными ключами скважин (ids = 55, 64) + /// Метод возвращает список из одной операции в разрезе 3-х скважин: 2 текущие скважины и одна композитная + /// Операция композитной скважины должна содержать данные той операции, которая содержит минимальный duration_hours + /// + /// [Fact] - public async Task GetAsync_return_data2() + public async Task GetAsync_return_composite_with_minimum_depth_start() { // arrange wellOperationRepository.GetAsync(Arg.Any(), Arg.Any()) @@ -221,6 +232,12 @@ namespace AsbCloudWebApi.Tests.Services.WellCompositeOperation Assert.Equal(10, compositeWellOperation.DepthStart); } + /// + /// На вход подаются 2 операции с одинаковыми секциями (id = 3) и категориями (id = 5036), но разными ключами скважин (ids = 55, 64) + /// Метод возвращает список из одной операции в разрезе 3-х скважин: 2 текущие скважины и одна композитная + /// Операция композитной скважины должна содержать данные той операции, которая содержит минимальный duration_hours + /// + /// [Fact] public async Task GetAsync_return_data3() { @@ -241,6 +258,16 @@ namespace AsbCloudWebApi.Tests.Services.WellCompositeOperation Assert.Equal(1372, compositeWellOperation.DepthStart); } + /// + /// На вход подаются 3 операции с одинаковыми секциями (id = 31), но разными категориями (ids = 5012, 5083) и ключами скважин (ids = 55, 64) + /// Метод возвращает список из одной операции в разрезе 3-х скважин: 2 текущие скважины и одна композитная + /// Операция композитной скважины должна содержать: + /// данные той операции, которая содержит минимальный duration_hours + /// категорию с ключом 5013 + /// Операции по скважине с ключом 55 должны объединиться в одну, + /// при этом их длительность складывается, а depth_start берется минимальный из двух + /// + /// [Fact] public async Task GetAsync_return_data4() { @@ -260,16 +287,27 @@ namespace AsbCloudWebApi.Tests.Services.WellCompositeOperation Assert.Single(categories); Assert.Equal(5013, categories.First()); + var currentOperationByWell55 = currentWellOperations.Where(o => o.IdWell == 55).FirstOrDefault(); + Assert.NotNull(currentOperationByWell55); + Assert.Equal(15, currentOperationByWell55.DurationHours); + Assert.Equal(500, currentOperationByWell55.DepthStart); + var categoryName = currentWellOperations.Select(o => o.OperationCategoryName).First(); Assert.Equal("Подъем КНБК", categoryName); var compositeWellOperation = result.SelectMany(o => o.Values.Where(o => o.IdWell == 0)).FirstOrDefault(); Assert.NotNull(compositeWellOperation); Assert.Equal(5013, compositeWellOperation.IdCategory); - Assert.Equal(15, compositeWellOperation.DurationHours); - Assert.Equal(500, compositeWellOperation.DepthStart); + Assert.Equal(5, compositeWellOperation.DurationHours); + Assert.Equal(600, compositeWellOperation.DepthStart); } + /// + /// На вход подаются список разных операций с разными ключами скважин (ids = 55, 64) + /// Метод возвращает список из 4-х операций в разрезе 3-х скважин: 2 текущие скважины и одна композитная + /// Операция композитной скважины должна содержать глубину забоя = 1372 + /// + /// [Fact] public async Task GetAsync_return_data5() { From a91fc4f213f904e75ef36efc342db0289af17e7a Mon Sep 17 00:00:00 2001 From: ngfrolov Date: Wed, 13 Mar 2024 16:04:49 +0500 Subject: [PATCH 12/15] =?UTF-8?q?WellsOperationRequest.IdType=20=D0=B7?= =?UTF-8?q?=D0=B0=D0=BC=D0=B5=D0=BD=D0=B5=D0=BD=20=D0=BD=D0=B0=20WellOpera?= =?UTF-8?q?tionRequestBase.OperationType.=20=D0=94=D0=BE=D0=B1=D0=B0=D0=B2?= =?UTF-8?q?=D0=BB=D0=B5=D0=BD=D1=8B=20=D1=82=D1=83=D0=B4=D1=83=D1=88=D0=BA?= =?UTF-8?q?=D0=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- AsbCloudApp/Requests/WellOperationRequest.cs | 5 ----- AsbCloudInfrastructure/Repository/WellOperationRepository.cs | 5 +++-- .../Services/WellCompositeOperationService.cs | 5 ++--- 3 files changed, 5 insertions(+), 10 deletions(-) diff --git a/AsbCloudApp/Requests/WellOperationRequest.cs b/AsbCloudApp/Requests/WellOperationRequest.cs index 3296c4ad..1d190018 100644 --- a/AsbCloudApp/Requests/WellOperationRequest.cs +++ b/AsbCloudApp/Requests/WellOperationRequest.cs @@ -108,10 +108,5 @@ namespace AsbCloudApp.Requests /// ids скважин /// public IEnumerable IdsWell { get; set; } = null!; - - /// - /// Тип 0 = План или 1 = Факт - /// - public int IdType { get; set; } } } diff --git a/AsbCloudInfrastructure/Repository/WellOperationRepository.cs b/AsbCloudInfrastructure/Repository/WellOperationRepository.cs index aa0d28ce..329d2502 100644 --- a/AsbCloudInfrastructure/Repository/WellOperationRepository.cs +++ b/AsbCloudInfrastructure/Repository/WellOperationRepository.cs @@ -396,7 +396,6 @@ public class WellOperationRepository : IWellOperationRepository .Include(s => s.OperationCategory) .Where(o => o.IdWell == request.IdWell); - if (request.OperationType.HasValue) query = query.Where(e => e.IdType == request.OperationType.Value); @@ -431,6 +430,7 @@ public class WellOperationRepository : IWellOperationRepository .Where(subOp => subOp.IdType == 1) .Where(subOp => WellOperationCategory.NonProductiveTimeSubIds.Contains(subOp.IdCategory)); + // TODO: Вынести query.Select из метода BuildQuery var dtos = query.Select(o => new WellOperationDto { Id = o.Id, @@ -493,7 +493,7 @@ public class WellOperationRepository : IWellOperationRepository { var query = db.WellOperations .Where(o => request.IdsWell.Contains(o.IdWell)) - .Where(o => request.IdType == o.IdType); + .Where(o => request.OperationType == o.IdType); if (request.SectionTypeIds?.Any() == true) query = query.Where(o => request.SectionTypeIds.Contains(o.IdWellSectionType)); @@ -501,6 +501,7 @@ public class WellOperationRepository : IWellOperationRepository if (request.OperationCategoryIds?.Any() == true) query = query.Where(o => request.OperationCategoryIds.Contains(o.IdCategory)); + // TODO: Вынести query.Select из метода BuildQuery var dtos = query.Select(o => new WellOperationDataDto { DepthStart = o.DepthStart, diff --git a/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs b/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs index 4730352d..6ba97ea0 100644 --- a/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs +++ b/AsbCloudInfrastructure/Services/WellCompositeOperationService.cs @@ -149,7 +149,7 @@ namespace AsbCloudInfrastructure.Services IdsWell = idsWells, OperationCategoryIds = usedCategories, SectionTypeIds = idsWellSectionTypes, - IdType = WellOperation.IdOperationTypeFact + OperationType = WellOperation.IdOperationTypeFact }; var operations = await wellOperationRepository.GetAsync(wellOperationRequest, token); @@ -189,7 +189,6 @@ namespace AsbCloudInfrastructure.Services compositeDepth = composite.DepthStart; - var resultItem = aggreagtedByWell.ToDictionary(o => o.IdWell); resultItem.Add(0, composite); @@ -198,7 +197,7 @@ namespace AsbCloudInfrastructure.Services return wellOperationsWithComposite; } - private WellOperationDataDto UpdateIdWellSectionAndIdCategory( + private static WellOperationDataDto UpdateIdWellSectionAndIdCategory( WellOperationDataDto dto, Dictionary sectionTypes, Dictionary operationCategories) From 5b3664d3e02089fdeb8c7ad11dc8b79084b521cb Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=A1=D1=82=D0=B5=D0=BF=D0=B0=D0=BD=D0=BE=D0=B2=20=D0=94?= =?UTF-8?q?=D0=BC=D0=B8=D1=82=D1=80=D0=B8=D0=B9?= Date: Wed, 13 Mar 2024 14:34:51 +0300 Subject: [PATCH 13/15] =?UTF-8?q?=D0=A4=D0=B8=D0=BA=D1=81=20=D1=83=D0=B4?= =?UTF-8?q?=D0=B0=D0=BB=D0=B5=D0=BD=D0=B8=D1=8F=20=D0=91=D0=94?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../WebAppFactoryFixture.cs | 29 +++++++++++-------- 1 file changed, 17 insertions(+), 12 deletions(-) diff --git a/AsbCloudWebApi.IntegrationTests/WebAppFactoryFixture.cs b/AsbCloudWebApi.IntegrationTests/WebAppFactoryFixture.cs index b990295b..b3edf988 100644 --- a/AsbCloudWebApi.IntegrationTests/WebAppFactoryFixture.cs +++ b/AsbCloudWebApi.IntegrationTests/WebAppFactoryFixture.cs @@ -12,8 +12,7 @@ using AsbCloudWebApi.IntegrationTests.Converters; namespace AsbCloudWebApi.IntegrationTests; -public class WebAppFactoryFixture : WebApplicationFactory, - IDisposable +public class WebAppFactoryFixture : WebApplicationFactory { private static readonly JsonSerializerOptions JsonSerializerOptions = new() { @@ -24,15 +23,20 @@ public class WebAppFactoryFixture : WebApplicationFactory, private static readonly RefitSettings RefitSettings = new(new SystemTextJsonContentSerializer(JsonSerializerOptions)); - protected override void ConfigureWebHost(IWebHostBuilder builder) + private readonly string connectionString; + + public WebAppFactoryFixture() { var configuration = new ConfigurationBuilder() .AddJsonFile("appsettings.Tests.json") .Build(); - - var dbConnection = configuration.GetSection("DbConnection").Get(); - var connectionString = dbConnection?.GetConnectionString(); - + + var dbConnection = configuration.GetSection("DbConnection").Get()!; + connectionString = dbConnection.GetConnectionString(); + } + + protected override void ConfigureWebHost(IWebHostBuilder builder) + { builder.ConfigureServices(services => { var descriptor = services.SingleOrDefault(d => d.ServiceType == typeof(DbContextOptions)); @@ -55,13 +59,14 @@ public class WebAppFactoryFixture : WebApplicationFactory, }); } - public new void Dispose() + public override async ValueTask DisposeAsync() { - using var scope = Services.CreateScope(); - var scopedServices = scope.ServiceProvider; - var dbContext = scopedServices.GetRequiredService(); + var dbContext = new AsbCloudDbContext( + new DbContextOptionsBuilder() + .UseNpgsql(connectionString) + .Options); - dbContext.Database.EnsureDeleted(); + await dbContext.Database.EnsureDeletedAsync(); } public T GetAuthorizedHttpClient(string uriSuffix) From 8f29a9178b91727e3585fc021c5fb0fb15df6008 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=A1=D1=82=D0=B5=D0=BF=D0=B0=D0=BD=D0=BE=D0=B2=20=D0=94?= =?UTF-8?q?=D0=BC=D0=B8=D1=82=D1=80=D0=B8=D0=B9?= Date: Wed, 13 Mar 2024 14:40:56 +0300 Subject: [PATCH 14/15] fix after merge --- .../ProcessMapPlanDrillingControllerTest.cs | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/AsbCloudWebApi.IntegrationTests/Controllers/ProcessMapPlan/ProcessMapPlanDrillingControllerTest.cs b/AsbCloudWebApi.IntegrationTests/Controllers/ProcessMapPlan/ProcessMapPlanDrillingControllerTest.cs index b5df18bb..c5335ae0 100644 --- a/AsbCloudWebApi.IntegrationTests/Controllers/ProcessMapPlan/ProcessMapPlanDrillingControllerTest.cs +++ b/AsbCloudWebApi.IntegrationTests/Controllers/ProcessMapPlan/ProcessMapPlanDrillingControllerTest.cs @@ -573,9 +573,10 @@ public class ProcessMapPlanDrillingControllerTest: BaseIntegrationTest const string fileName = "ProcessMapPlanDrillingValid.xlsx"; var stream = Assembly.GetExecutingAssembly().GetFileCopyStream(fileName); - //act var streamPart = new StreamPart(stream, fileName, "application/octet-stream"); - var response = await client.Parse(IdWell, new[] { streamPart }); + + //act + var response = await client.Parse(IdWell, streamPart); //assert Assert.Equal(HttpStatusCode.OK, response.StatusCode); @@ -602,9 +603,10 @@ public class ProcessMapPlanDrillingControllerTest: BaseIntegrationTest const string fileName = "ProcessMapPlanDrillingInvalid.xlsx"; var stream = Assembly.GetExecutingAssembly().GetFileCopyStream(fileName); - //act var streamPart = new StreamPart(stream, fileName, "application/octet-stream"); - var response = await client.Parse(IdWell, new[] { streamPart }); + + //act + var response = await client.Parse(IdWell, streamPart); Assert.Equal(HttpStatusCode.OK, response.StatusCode); From 0b9fd490395ccd772d732a60e839c4936e741d9c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=A1=D1=82=D0=B5=D0=BF=D0=B0=D0=BD=D0=BE=D0=B2=20=D0=94?= =?UTF-8?q?=D0=BC=D0=B8=D1=82=D1=80=D0=B8=D0=B9?= Date: Wed, 13 Mar 2024 14:49:28 +0300 Subject: [PATCH 15/15] =?UTF-8?q?=D0=A4=D0=B8=D0=BA=D1=81=D1=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 1. Удалён лишний тест. В данном тесте никогда не возникнет BadRequest. Если идентификатор скважины не валиден у нас возникнет Forbidden. 2. Сделал коллекцию прав потокобезопасной, чтобы не возникало состояние RaiseCondition --- .../ProcessMapPlanDrillingControllerTest.cs | 16 +--------------- AsbCloudWebApi/PermissionAttribute.cs | 5 ++--- 2 files changed, 3 insertions(+), 18 deletions(-) diff --git a/AsbCloudWebApi.IntegrationTests/Controllers/ProcessMapPlan/ProcessMapPlanDrillingControllerTest.cs b/AsbCloudWebApi.IntegrationTests/Controllers/ProcessMapPlan/ProcessMapPlanDrillingControllerTest.cs index c5335ae0..6f21bd0b 100644 --- a/AsbCloudWebApi.IntegrationTests/Controllers/ProcessMapPlan/ProcessMapPlanDrillingControllerTest.cs +++ b/AsbCloudWebApi.IntegrationTests/Controllers/ProcessMapPlan/ProcessMapPlanDrillingControllerTest.cs @@ -150,21 +150,7 @@ public class ProcessMapPlanDrillingControllerTest: BaseIntegrationTest //assert Assert.Equal(HttpStatusCode.BadRequest, response.StatusCode); } - - [Fact] - public async Task InsertRange_returns_BadRequest_for_IdWell() - { - //arrange - var badDto = dto.Adapt(); - badDto.IdWell = int.MaxValue; - - //act - var response = await client.InsertRange(dto.IdWell, new[] { badDto }); - - //assert - Assert.Equal(HttpStatusCode.BadRequest, response.StatusCode); - } - + [Fact] public async Task ClearAndInsertRange_returns_success() { diff --git a/AsbCloudWebApi/PermissionAttribute.cs b/AsbCloudWebApi/PermissionAttribute.cs index 1249b531..775617a1 100644 --- a/AsbCloudWebApi/PermissionAttribute.cs +++ b/AsbCloudWebApi/PermissionAttribute.cs @@ -1,13 +1,12 @@ using System; -using System.Collections.Generic; -using System.Runtime.CompilerServices; +using System.Collections.Concurrent; namespace AsbCloudWebApi { [AttributeUsage(AttributeTargets.Class | AttributeTargets.Method, AllowMultiple = false, Inherited = true)] public class PermissionAttribute : Attribute { - public static SortedSet Registered { get; } = new SortedSet(); + public static ConcurrentBag Registered { get; } = new(); public string Name { get; set; } = null!;