Merge branch 'dev' into feature/fact_trajectory

AsbCloudApp/Data/WellMapInfoDto.cs

@@ -15,9 +15,85 @@ namespace AsbCloudApp.Data
         public int IdState { get; set; }
 
         /// <summary>
-        /// Дата/время кода приходили данные последний раз
+        /// Режим АПД:
+        /// 0 - "РУЧНОЙ"
+        /// 1 - "БУРЕНИЕ В РОТОРЕ"
+        /// 2 - "ПРОРАБОТКА"
+        /// 3 - "БУРЕНИЕ В СЛАЙДЕ"
+        /// 4 - "СПУСК СПО"
+        /// 5 - "ПОДЪЕМ СПО"
+        /// 6 - "ПОДЪЕМ С ПРОРАБОТКОЙ"
+        /// 10 - "БЛОКИРОВКА"
         /// </summary>
-        public DateTime LastTelemetryDate { get; set; }
+        public int IdMode { get; set; }
+
+        /// <summary>
+        /// Коэф-т использования автоподачи долота (суммарный ротор + слайд)
+        /// </summary>
+        public double SaubUsage { get; set; }
+
+        /// <summary>
+        /// Коэф-т использования осциллятора
+        /// </summary>
+        public double SpinUsage { get; set; }
+
+        /// <summary>
+        /// Коэф-т использования демпфера
+        /// </summary>
+        public double TorqueKUsage { get; set; }
+
+        /// <summary>
+        /// Состояние МСЕ
+        /// </summary>
+        public double IdStateMse { get; set; }
+
+        /// <summary>
+        /// Дата/время получения данных от системы АПД
+        /// </summary>
+        public DateTime LastTelemetrySaubDate { get; set; }
+
+        /// <summary>
+        /// Дата/время получения данных от системы осцилляции
+        /// </summary>
+        public DateTime LastTelemetrySpinDate { get; set; }
+
+        /// <summary>
+        /// Дата/время получения данных от ННБ
+        /// </summary>
+        public DateTime LastTelemetryDdsDate { get; set; }
+
+        /// <summary>
+        /// Дата/время получения данных от ГТИ
+        /// </summary>
+        public DateTime LastTelemetryGtrDate { get; set; }
+
+        /// <summary>
+        /// Дата/время получения данных от СКПБ
+        /// </summary>
+        public DateTime LastTelemetryDpcsDate { get; set; }
+
+        /// <summary>
+        /// <para>Дата начала первой фактической операции</para>
+        /// <para>Используется как дата начала бурения</para>
+        /// </summary>
+        public DateTime? FirstFactOperationDateStart { get; set; }
+
+        /// <summary>
+        /// <para>Дата окончания последней прогнозируемой операции</para>
+        /// <para>Если скважина завершена, то дата окончания последней фактической операции</para>
+        /// <para>Используется как прогноз окончания бурения</para>
+        /// </summary>
+        public DateTime? LastPredictOperationDateEnd { get; set; }
+
+        /// <summary>
+        /// Рейсовая скорость проходки, последнего рейса
+        /// </summary>
+        public PlanFactDto<double?> RaceSpeed { get; set; } = null!;
+
+        /// <summary>
+        /// Механическая скорость проходки, последней операции бурения
+        /// </summary>
+        public PlanFactDto<double?> ROP { get; set; } = null!;
 
         /// <summary>
         /// Плановая и текущая глубина
@@ -29,24 +105,5 @@ namespace AsbCloudApp.Data
         /// </summary>
         public double TvdLagPercent { get; set; }
 
-        /// <summary>
-        /// Механическая скорость проходки, последней операции бурения
-        /// </summary>
-        public PlanFactDto<double?> ROP { get; set; } = null!;
-
-        /// <summary>
-        /// Рейсовая скорость проходки, последнего рейса
-        /// </summary>
-        public PlanFactDto<double?> RaceSpeed { get; set; } = null!;
-
-        /// <summary>
-        /// Процент использования АКБ
-        /// </summary>
-        public double SaubUsage { get; set; }
-
-        /// <summary>
-        /// Процент использования Спин мастера
-        /// </summary>
-        public double SpinUsage { get; set; }
     }
 }

AsbCloudApp/Services/IWitsRepository.cs

@@ -37,7 +37,7 @@ namespace AsbCloudApp.Services
         /// <param name="idTelemetry">The id telemetry.</param>
         /// <param name="token">The token.</param>
         /// <returns>A Task.</returns>
-        Task<IEnumerable<TDto>> GetLastAsync(int idTelemetry, CancellationToken token);
+        TDto? GetLastOrDefault(int idTelemetry);
         
         /// <summary>
         /// получить статистику по всему архиву: дата самой ранней записи, самой поздней и общее количество

AsbCloudInfrastructure/Repository/WitsRecordRepository.cs

@@ -3,6 +3,7 @@ using AsbCloudDb.Model;
 using Mapster;
 using Microsoft.EntityFrameworkCore;
 using System;
+using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.Linq;
 using System.Threading;
@@ -10,16 +11,17 @@ using System.Threading.Tasks;
 
 namespace AsbCloudInfrastructure.Repository
 {
-
     public class WitsRecordRepository<TDto, TEntity> : IWitsRecordRepository<TDto>
         where TEntity : AsbCloudDb.Model.WITS.RecordBase, ITelemetryData
         where TDto : AsbCloudApp.Data.ITelemetryData
     {
-        private static Random random = new Random((int)(DateTime.Now.Ticks % 0xFFFFFFFF));
+        private static readonly Random random = new Random((int)(DateTime.Now.Ticks % 0xFFFFFFFF));
         private readonly DbSet<TEntity> dbset;
         private readonly IAsbCloudDbContext db;
         private readonly ITelemetryService telemetryService;
 
+        private static readonly ConcurrentDictionary<int, TDto> cache = new ();
+
         public WitsRecordRepository(IAsbCloudDbContext db, ITelemetryService telemetryService)
         {
             dbset = db.Set<TEntity>();
@@ -56,25 +58,16 @@ namespace AsbCloudInfrastructure.Repository
             return data.Select(d => Convert(d, timezoneHours));
         }
 
-        public async Task<IEnumerable<TDto>> GetLastAsync(int idTelemetry, CancellationToken token)
+        public TDto? GetLastOrDefault(int idTelemetry)
-        {
+            => cache.GetValueOrDefault(idTelemetry);
-            var timezoneHours = telemetryService.GetTimezone(idTelemetry).Hours;
-            var query = dbset
-                .Where(d => d.IdTelemetry == idTelemetry)
-                .OrderBy(d => d.DateTime)
-                .AsNoTracking();
-            var data = await query.LastOrDefaultAsync(token);
-            if(data is not null)
-                return new TDto[] { Convert(data, timezoneHours) };
-
-            return Enumerable.Empty<TDto>();
-        }
 
         public async Task SaveDataAsync(int idTelemetry, IEnumerable<TDto> dtos, CancellationToken token)
         {
-            if (dtos?.Any() != true)
+            if (!dtos.Any())
                 return;
 
+            cache.AddOrUpdate(idTelemetry, dtos.Last(), (_,_) => dtos.OrderBy(r => r.DateTime).Last());
+
             var timezoneHours = telemetryService.GetTimezone(idTelemetry).Hours;
             var entities = dtos
                 .DistinctBy(d => d.DateTime)
@@ -144,7 +137,5 @@ namespace AsbCloudInfrastructure.Repository
             data.DateTime = entity.DateTime.ToRemoteDateTime(timezoneHours);
             return data;
         }
-
     }
-
 }

AsbCloudWebApi/Controllers/WITS/WitsControllerAbstract.cs

@@ -67,16 +67,15 @@ namespace AsbCloudWebApi.Controllers.WITS
         /// <param name="token"></param>
         /// <returns></returns>
         [HttpGet("{idWell}/last")]
-        public async virtual Task<ActionResult<IEnumerable<TDto>>> GetLastDataAsync(
+        public virtual ActionResult<IEnumerable<TDto>> GetLastData(
             int idWell,
-            [FromServices] IWitsRecordRepository<TDto> witsRecordRepository,
+            [FromServices] IWitsRecordRepository<TDto> witsRecordRepository)
-            CancellationToken token)
         {
             var telemetry = telemetryService.GetOrDefaultTelemetryByIdWell(idWell);
             if (telemetry is null)
                 return NoContent();
-            var dtos = await witsRecordRepository.GetLastAsync(telemetry.Id, token);
+            var dto = witsRecordRepository.GetLastOrDefault(telemetry.Id);
-            return Ok(dtos);
+            return Ok(new[] { dto });
         }
 
         /// <summary>

AsbCloudWebApi/Middlewares/SimplifyExceptionsMiddleware.cs

@@ -1,7 +1,6 @@
 using AsbCloudApp.Exceptions;
 using Microsoft.AspNetCore.Http;
 using System;
-using System.IO;
 using System.Threading.Tasks;
 
 namespace AsbCloudWebApi.Middlewares
@@ -36,12 +35,15 @@ namespace AsbCloudWebApi.Middlewares
                 context.Response.Clear();
                 context.Response.StatusCode = 403;
             }
-            catch (TaskCanceledException ex)
+            catch (OperationCanceledException ex)
             {
                 Console.WriteLine(ex.Message);
             }
             catch (Exception ex) // TODO: find explicit exception. Use Trace. Add body size to message.
             {
+                context.Response.Clear();
+                context.Response.StatusCode = 500;
+                
                 if (ex.Message.Contains("Reading the request body timed out due to data arriving too slowly. See MinRequestBodyDataRate."))
                     Console.WriteLine("Reading the request body timed out due to data arriving too slowly.");
                 else