forked from ddrilling/AsbCloudServer
120 lines
4.2 KiB
C#
120 lines
4.2 KiB
C#
using AsbCloudApp.Data;
|
|
using AsbCloudApp.Services;
|
|
using AsbCloudDb.Model;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using AsbCloudInfrastructure.Services.Cache;
|
|
using Mapster;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace AsbCloudInfrastructure.Services
|
|
{
|
|
public class DataService : IDataService
|
|
{
|
|
private readonly IAsbCloudDbContext db;
|
|
private readonly ITelemetryService telemetryService;
|
|
private readonly IAnalyticsService analyticsService;
|
|
private readonly CacheTable<Telemetry> cacheTelemetry;
|
|
private readonly CacheTable<Well> cacheWells;
|
|
|
|
public DataService(IAsbCloudDbContext db, ITelemetryService telemetryService,
|
|
IAnalyticsService analyticsService, CacheDb cacheDb)
|
|
{
|
|
this.db = db;
|
|
this.telemetryService = telemetryService;
|
|
this.analyticsService = analyticsService;
|
|
cacheTelemetry = cacheDb.GetCachedTable<Telemetry>((AsbCloudDbContext)db);
|
|
cacheWells = cacheDb.GetCachedTable<Well>((AsbCloudDbContext)db);
|
|
}
|
|
|
|
public async Task<IEnumerable<DataSaubBaseDto>> GetAsync(int idWell,
|
|
DateTime dateBegin = default, double intervalSec = 600d,
|
|
int approxPointsCount = 1024, CancellationToken token = default)
|
|
{
|
|
var well = cacheWells.FirstOrDefault(w => w.Id == idWell);
|
|
if (well is null)
|
|
return default;
|
|
|
|
var telemetry = cacheTelemetry.FirstOrDefault(t => t.Id == well.IdTelemetry);
|
|
if (telemetry is null)
|
|
return default;
|
|
|
|
if (dateBegin == default)
|
|
dateBegin = DateTime.Now.AddSeconds(-intervalSec);
|
|
|
|
var datEnd = dateBegin.AddSeconds(intervalSec);
|
|
|
|
var query = from data in db.DataSaubBases
|
|
where data.IdTelemetry == telemetry.Id
|
|
&& data.Date >= dateBegin && data.Date < datEnd
|
|
select data;
|
|
|
|
var fullDataCount = await query.CountAsync(token);
|
|
|
|
if (fullDataCount == 0)
|
|
return default;
|
|
|
|
if (fullDataCount > 1.75 * approxPointsCount)
|
|
{
|
|
var m = (int)Math.Round(1d * fullDataCount / approxPointsCount);
|
|
if (m > 1)
|
|
query = query.Where(d => d.Id % m == 0);
|
|
}
|
|
|
|
var entities = await query.AsNoTracking().ToListAsync(token);
|
|
|
|
var dtos = entities.Adapt<DataSaubBaseDto>();
|
|
|
|
return dtos;
|
|
}
|
|
|
|
public async Task UpdateDataAsync(string uid, IEnumerable<DataSaubBaseDto> dtos,
|
|
CancellationToken token = default)
|
|
{
|
|
if (dtos == default || !dtos.Any())
|
|
return;
|
|
|
|
var telemetryId = telemetryService.GetOrCreateTemetryIdByUid(uid);
|
|
var dtoMinDate = dtos.Min(d => d.Date);
|
|
var dtoMaxDate = dtos.Max(d => d.Date);
|
|
|
|
var oldDataSaubBase = await (from d in db.DataSaubBases
|
|
where d.IdTelemetry == telemetryId
|
|
&& d.Date > dtoMinDate
|
|
&& d.Date < dtoMaxDate
|
|
select d).AsNoTracking().ToListAsync(token);
|
|
|
|
if (oldDataSaubBase.Any())
|
|
db.DataSaubBases.RemoveRange(oldDataSaubBase);
|
|
|
|
|
|
foreach (var dto in dtos)
|
|
{
|
|
var dataSaub = dto.Adapt<DataSaubBase>();
|
|
dataSaub.IdTelemetry = telemetryId;
|
|
db.DataSaubBases.Add(dataSaub);
|
|
|
|
dto.IdTelemetry = telemetryId;
|
|
analyticsService.SaveAnalytics(dto);
|
|
}
|
|
|
|
db.SaveChanges();
|
|
}
|
|
|
|
public async Task<DatesRangeDto> GetDataDatesRangeAsync(int idWell,
|
|
CancellationToken token = default)
|
|
{
|
|
var telemetryId = telemetryService.GetIdTelemetryByIdWell(idWell);
|
|
if (telemetryId is null)
|
|
return null;
|
|
|
|
var (From, To) = await db.GetDatesRangeAsync<DataSaubBase>((int)telemetryId, token);
|
|
|
|
return new DatesRangeDto { From = From, To = To };
|
|
}
|
|
}
|
|
}
|