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 2023-10-02 17:53:34 +05:00
parent 790f4eef0d
commit d4417a5552
6 changed files with 325 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
AsbCloudApp/Data/SlipsStatDto.cs Normal file
View File

@ -0,0 +1,44 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace AsbCloudApp.Data
{
/// <summary>
/// DTO, описывающая аналитику удержания в клиньях
/// </summary>
public class SlipsStatDto
{
/// <summary>
/// ФИО бурильщика
/// </summary>
public string DrillerName { get; set; } = null!;
/// <summary>
/// Количество скважин
/// </summary>
public int WellCount { get; set; }
/// <summary>
/// Название секции
/// </summary>
public string SectionCaption { get; set; } = null!;
/// <summary>
/// Количество удержаний в клиньях, шт.
/// </summary>
public int SlipsCount { get; set; }
/// <summary>
/// Время удержания в клиньях, мин.
/// </summary>
public double SlipsTimeInMinutes { get; set; }
/// <summary>
/// Проходка, м.
/// </summary>
public double SlipsDepth { get; set; }
}
}

23
AsbCloudApp/Repositories/ISlipsStatsRepository.cs Normal file
View File

@ -0,0 +1,23 @@
using AsbCloudApp.Data;
using AsbCloudApp.Requests;
using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
namespace AsbCloudApp.Repositories
{
/// <summary>
/// Сервис для получения аналитики удержания в клиньях
/// </summary>
public interface ISlipsStatsRepository
{
/// <summary>
/// Получение записей для построения аналитики удержания в клиньях
/// </summary>
/// <param name="request">параметры запроса</param>
/// <param name="token"></param>
/// <returns></returns>
Task<IEnumerable<SlipsStatDto>> GetAllAsync(OperationStatRequest request, CancellationToken token);
}
}

36
AsbCloudApp/Requests/OperationStatRequest.cs Normal file
View File

@ -0,0 +1,36 @@
using System;
using System.Collections.Generic;
using System.ComponentModel.DataAnnotations;
namespace AsbCloudApp.Requests
{
/// <summary>
/// Параметры фильтра операции
/// </summary>
public class OperationStatRequest : RequestBase
{
/// <summary>
/// Дата начала периода, за который строится отчет
/// </summary>
public DateTime? DateStart { get; set; }
/// <summary>
/// Дата окончания периода, за который строится отчет
/// </summary>
public DateTime? DateEnd { get; set; }
/// <summary>
/// Минимальная продолжительность операции, мину
/// </summary>
public int? DurationMinutesMin { get; set; }
/// <summary>
/// Максимальная продолжительность операции, мин
/// </summary>
public int? DurationMinutesMax { get; set; }
}
}

1
AsbCloudInfrastructure/DependencyInjection.cs
View File

@ -199,6 +199,7 @@ namespace AsbCloudInfrastructure
services.AddTransient<ITrajectoryPlanRepository, TrajectoryPlanRepository>();
services.AddTransient<ITrajectoryFactRepository, TrajectoryFactRepository>();
services.AddTransient<IFaqRepository, FaqRepository>();
services.AddTransient<ISlipsStatsRepository, SlipsStatRepository>();
services.AddTransient<IWellContactService, WellContactService>();
services.AddTransient<ICrudRepository<WellSectionTypeDto>, CrudCacheRepositoryBase<WellSectionTypeDto,
WellSectionType>>();

173
AsbCloudInfrastructure/Repository/SlipsStatRepository.cs Normal file
View File

@ -0,0 +1,173 @@
using AsbCloudApp.Data;
using AsbCloudApp.Repositories;
using AsbCloudApp.Requests;
using AsbCloudDb.Model;
using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
namespace AsbCloudInfrastructure.Repository
{
public class SlipsStatRepository : ISlipsStatsRepository
{
private readonly IAsbCloudDbContext db;
public SlipsStatRepository(IAsbCloudDbContext db)
{
this.db = db;
}
public async Task<IEnumerable<SlipsStatDto>> GetAllAsync(OperationStatRequest request, CancellationToken token)
{
if (request.DateStart.HasValue)
request.DateStart = DateTime.SpecifyKind(request.DateStart.Value, DateTimeKind.Utc);
if (request.DateEnd.HasValue)
request.DateEnd = DateTime.SpecifyKind(request.DateEnd.Value, DateTimeKind.Utc);
var schedulesQuery = db.Schedule
.Include(s => s.Well)
.Include(s => s.Driller)
.AsNoTracking();
if (request.DateStart.HasValue && request.DateEnd.HasValue)
schedulesQuery = schedulesQuery.
Where(s => s.DrillStart >= request.DateStart && s.DrillEnd <= request.DateEnd);
var schedules = await schedulesQuery.ToArrayAsync(token);
var wells = schedules
.Select(d => d.Well)
.Where(well => well.IdTelemetry != null)
.GroupBy(w => w.Id)
.ToDictionary(g => g.Key, g => g.First().IdTelemetry!.Value);
var idsWells = wells.Keys;
var idsTelemetries = wells.Values;
var telemetries = wells.ToDictionary(wt => wt.Value, wt => wt.Key);
var factWellOperationsQuery = db.WellOperations
.Where(o => idsWells.Contains(o.IdWell))
.Where(o => o.IdType == 1)
.Where(o => WellOperationCategory.MechanicalDrillingSubIds.Contains(o.IdCategory))
.Include(o => o.WellSectionType)
.AsNoTracking();
if (request.DateStart.HasValue && request.DateEnd.HasValue)
factWellOperationsQuery = factWellOperationsQuery
.Where(o => o.DateStart.AddHours(o.DurationHours) > request.DateStart && o.DateStart < request.DateEnd);
var factWellOperations = await factWellOperationsQuery.ToArrayAsync(token);
var sections = factWellOperations
.GroupBy(o => new { o.IdWell, o.IdWellSectionType })
.Select(g => new
{
g.Key.IdWell,
g.Key.IdWellSectionType,
DepthStart = g.Min(o => o.DepthStart),
DepthEnd = g.Max(o => o.DepthEnd),
g.FirstOrDefault()!.WellSectionType.Caption
});
var detectedOperationsQuery = db.DetectedOperations
.Where(o => idsTelemetries.Contains(o.IdTelemetry))
.Where(o => o.IdCategory == WellOperationCategory.IdSlipsTime)
.AsNoTracking();
if (request.DateStart.HasValue && request.DateEnd.HasValue)
detectedOperationsQuery = detectedOperationsQuery
.Where(o => o.DateStart < request.DateEnd)
.Where(o => o.DateEnd > request.DateStart);
TimeSpan? durationMinutesMin = request.DurationMinutesMin.HasValue
? new TimeSpan(0, request.DurationMinutesMin.Value, 0)
: null;
TimeSpan? durationMinutesMax = request.DurationMinutesMax.HasValue
? new TimeSpan(0, request.DurationMinutesMax.Value, 0)
: null;
if (durationMinutesMin.HasValue && durationMinutesMax.HasValue)
{
detectedOperationsQuery = detectedOperationsQuery
.Where(o => o.DateEnd - o.DateStart >= durationMinutesMin.Value
&& o.DateEnd - o.DateStart <= durationMinutesMax.Value);
}
else if (durationMinutesMin.HasValue && !durationMinutesMax.HasValue)
{
detectedOperationsQuery = detectedOperationsQuery
.Where(o => o.DateEnd - o.DateStart >= durationMinutesMin.Value);
}
else if (!durationMinutesMin.HasValue && durationMinutesMax.HasValue)
{
detectedOperationsQuery = detectedOperationsQuery
.Where(o => o.DateEnd - o.DateStart <= durationMinutesMax.Value);
}
var detectedOperations = await detectedOperationsQuery
.ToArrayAsync(token);
var detectedOperationsGroupedByDrillerAndSection = detectedOperations.Select(o => new
{
Operation = o,
IdWell = telemetries[o.IdTelemetry],
schedules.FirstOrDefault(s =>
s.IdWell == telemetries[o.IdTelemetry]
&& s.DrillStart <= o.DateStart
&& s.DrillEnd >= o.DateStart
&& new TimeDto(s.ShiftStart) <= new TimeDto(o.DateStart.DateTime)
&& new TimeDto(s.ShiftEnd) >= new TimeDto(o.DateStart.DateTime))
?.Driller,
Section = sections.FirstOrDefault(s =>
s.IdWell == telemetries[o.IdTelemetry]
&& s.DepthStart <= o.DepthStart
&& s.DepthEnd >= o.DepthStart)
})
.Where(o => o.Driller != null)
.Where(o => o.Section != null)
.Select(o => new
{
o.Operation,
o.IdWell,
Driller = o.Driller!,
Section = o.Section!
})
.GroupBy(o => new { o.Driller.Id, o.Section.IdWellSectionType });
var factWellOperationsGroupedByDrillerAndSection = factWellOperations
.Select(o => new
{
Operation = o,
schedules.FirstOrDefault(s =>
s.IdWell == o.IdWell
&& s.DrillStart <= o.DateStart
&& s.DrillEnd >= o.DateStart
&& new TimeDto(s.ShiftStart) <= new TimeDto(o.DateStart.DateTime)
&& new TimeDto(s.ShiftEnd) >= new TimeDto(o.DateStart.DateTime))
?.Driller,
})
.Where(o => o.Driller != null)
.GroupBy(o => new { o.Driller!.Id, o.Operation.IdWellSectionType });
var stats = detectedOperationsGroupedByDrillerAndSection.Select(group => new SlipsStatDto
{
DrillerName = $"{group.First().Driller!.Name} {group.First().Driller!.Patronymic} {group.First().Driller!.Surname}",
SlipsCount = group.Count(),
SlipsTimeInMinutes = group
.Sum(y => (y.Operation.DateEnd - y.Operation.DateStart).TotalMinutes),
SlipsDepth = factWellOperationsGroupedByDrillerAndSection
.Where(o => o.Key.Id == group.Key.Id)
.Where(o => o.Key.IdWellSectionType == group.Key.IdWellSectionType)
.Sum(o => o.Max(op => op.Operation.DepthEnd) - o.Min(op => op.Operation.DepthStart)),
SectionCaption = group.First().Section!.Caption,
WellCount = group.GroupBy(g => g.IdWell).Count(),
});
return stats;
}
}
}

48
AsbCloudWebApi/Controllers/SlipsStatController.cs Normal file
View File

@ -0,0 +1,48 @@
using AsbCloudApp.Data;
using AsbCloudApp.Repositories;
using AsbCloudApp.Requests;
using AsbCloudDb.Model;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
namespace AsbCloudWebApi.Controllers
{
/// <summary>
/// Аналитика по удержанию в клиньях
/// </summary>
[Route("api/slipsStat")]
[ApiController]
[Authorize]
public class SlipsStatController : ControllerBase
{
private readonly ISlipsStatsRepository slipsAnalyticsService;
public SlipsStatController(ISlipsStatsRepository slipsAnalyticsService)
{
this.slipsAnalyticsService = slipsAnalyticsService;
}
/// <summary>
/// Получить аналитику по удержанию в клиньях (по бурильщикам)
/// </summary>
/// <param name="request">Параметры запроса</param>
/// <param name="token"> Токен отмены задачи </param>
/// <returns>Список бурильщиков</returns>
[HttpGet]
[Permission]
[ProducesResponseType(typeof(IEnumerable<SlipsStatDto>), (int)System.Net.HttpStatusCode.OK)]
public async Task<IActionResult> GetAllAsync(
[FromQuery] OperationStatRequest request,
CancellationToken token)
{
var modal = await slipsAnalyticsService.GetAllAsync(request, token).ConfigureAwait(false);
return Ok(modal);
}
}
}