on.nemtina/DD.WellWorkover.Cloud
1
0
Fork 0
forked from ddrilling/AsbCloudServer
Code Pull Requests Activity

Получение операций для построения композитной скважины

Browse Source
This commit is contained in:
Olga Nemt 2024-03-07 13:38:40 +05:00
parent adf19cf7f7
commit f88381353e
4 changed files with 222 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
AsbCloudApp/Services/IWellCompositeOperationService.cs Normal file
View File

@ -0,0 +1,21 @@
using AsbCloudApp.Data;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
namespace AsbCloudApp.Services
{
/// <summary>
/// Интерфейс для вычисления композитной скважины
/// </summary>
public interface IWellCompositeOperationService
{
/// <summary>
/// Получение данных для построения композитной скважины
/// </summary>
/// <param name="idsWells"></param>
/// <param name="token"></param>
/// <returns></returns>
Task<List<Dictionary<int, WellOperationDataDto>>> GetAsync(IEnumerable<int> idsWells, CancellationToken token);
}
}

1
AsbCloudInfrastructure/DependencyInjection.cs
View File

@ -198,6 +198,7 @@ namespace AsbCloudInfrastructure
services.AddTransient<ICrudRepository<NotificationCategoryDto>, CrudCacheRepositoryBase<NotificationCategoryDto,
NotificationCategory>>();
services.AddTransient<IDrillTestRepository, DrillTestRepository>();
services.AddTransient<IWellCompositeOperationService, WellCompositeOperationService>();
// admin crud services:
services.AddTransient<ICrudRepository<TelemetryDto>, CrudCacheRepositoryBase<TelemetryDto, Telemetry>>(s =>

165
AsbCloudInfrastructure/Services/WellCompositeOperationService.cs Normal file
View File

@ -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;
/// <summary>
/// Тип секции "Транспортный стол"
/// </summary>
private const int wellSectionTransportTable = 5;
/// <summary>
/// Тип секции "Эксплуатационная колонна"
/// </summary>
private const int wellSectionProductionString = 4;
/// <summary>
/// набор настроек для замены одной категории секции на другую
/// </summary>
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<int, List<int>> WellSectionTypesWithCategories = new Dictionary<int, List<int>>()
{
{ 2, new List<int>{ 5001, 5003, 5013, 5000, 5022, 5017, 5023, 4007, 5090 } },
{ 3, new List<int>{ 5001, 5015, 5037, 5057, 5003, 5036, 5084, 5013, 5000, 5022, 5017, 4007, 5090, 5045, 5042, 5046 } },
{ 31, new List<int>{ 5001, 5015, 5037, 5057, 5003, 5036, 5013, 5022, 5017, 5023, 4007, 5045, 5042, 5046 } },
{ 4, new List<int>{ 5001, 5015, 5046, 5037, 5097, 5057, 5003, 5036, 5008, 5003, 5036, 5013, 5000, 5029, 5022, 5017, 5019, 5042, 5046 } },
{ 6, new List<int>{ 5001, 5015, 5034, 5037, 5097, 5057, 5003 } },
};
public WellCompositeOperationService(IAsbCloudDbContext db)
{
this.db = db;
}
public async Task<List<Dictionary<int, WellOperationDataDto>>> GetAsync(IEnumerable<int> idsWells, CancellationToken token)
{
var sections = await db.WellSectionTypes
.Select(t => t.Adapt<WellSectionTypeDto>())
.ToArrayAsync(token);
var sectionsDict = sections.ToDictionary(s => s.Id, s => s.Caption);
var categories = await db.WellOperationCategories
.Select(c => c.Adapt<WellOperationCategoryDto>())
.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<Dictionary<int, WellOperationDataDto>>();
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<int, string> sectionsDict, Dictionary<int, string> 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;
}
}
}

35
AsbCloudWebApi/Controllers/WellCompositeOperationController.cs Normal file
View File

@ -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<Dictionary<int, WellOperationDataDto>>), (int)System.Net.HttpStatusCode.OK)]
public async Task<IActionResult> GetAsync([FromQuery] IEnumerable<int> idsWells, CancellationToken token)
{
var result = await wellCompositeOperationService.GetAsync(idsWells, token)
.ConfigureAwait(false);
return Ok(result);
}
}
}