100 lines
2.9 KiB
C#
100 lines
2.9 KiB
C#
using DD.Persistence.Database.Entity;
|
|
using DD.Persistence.Models.Common;
|
|
using DD.Persistence.ModelsAbstractions;
|
|
using DD.Persistence.Repositories;
|
|
using Mapster;
|
|
using Microsoft.EntityFrameworkCore;
|
|
|
|
namespace DD.Persistence.Repository.Repositories;
|
|
public class TimestampedValuesRepository<TDto> : ITimestampedValuesRepository<TDto>
|
|
where TDto : class, ITimestampAbstractDto, new()
|
|
{
|
|
private readonly DbContext db;
|
|
|
|
public TimestampedValuesRepository(DbContext db)
|
|
{
|
|
this.db = db;
|
|
}
|
|
|
|
protected virtual IQueryable<TimestampedValues> GetQueryReadOnly() => this.db.Set<TimestampedValues>();
|
|
|
|
public virtual async Task<DatesRangeDto?> GetDatesRange(CancellationToken token)
|
|
{
|
|
var query = GetQueryReadOnly();
|
|
var minDate = await query.MinAsync(o => o.Timestamp, token);
|
|
var maxDate = await query.MaxAsync(o => o.Timestamp, token);
|
|
|
|
return new DatesRangeDto
|
|
{
|
|
From = minDate,
|
|
To = maxDate
|
|
};
|
|
}
|
|
|
|
public virtual async Task<IEnumerable<TDto>> GetGtDate(DateTimeOffset date, CancellationToken token)
|
|
{
|
|
var query = GetQueryReadOnly().Where(e => e.Timestamp > date);
|
|
var entities = await query.ToArrayAsync(token);
|
|
|
|
var dtos = entities.Select(e => e.Adapt<TDto>());
|
|
|
|
return dtos;
|
|
}
|
|
|
|
public virtual async Task<int> AddRange(IEnumerable<TDto> dtos, CancellationToken token)
|
|
{
|
|
var entities = dtos.Select(d => d.Adapt<TimestampedValues>());
|
|
|
|
await db.Set<TimestampedValues>().AddRangeAsync(entities, token);
|
|
var result = await db.SaveChangesAsync(token);
|
|
|
|
return result;
|
|
}
|
|
|
|
protected async Task<IEnumerable<TDto>> GetLastAsync(int takeCount, CancellationToken token)
|
|
{
|
|
var query = GetQueryReadOnly()
|
|
.OrderByDescending(e => e.Timestamp)
|
|
.Take(takeCount);
|
|
|
|
var entities = await query.ToArrayAsync(token);
|
|
var dtos = entities.Select(e => e.Adapt<TDto>());
|
|
|
|
return dtos;
|
|
}
|
|
|
|
protected async Task<TDto?> GetFirstAsync(CancellationToken token)
|
|
{
|
|
var query = GetQueryReadOnly()
|
|
.OrderBy(e => e.Timestamp);
|
|
|
|
var entity = await query.FirstOrDefaultAsync(token);
|
|
|
|
if (entity == null)
|
|
return null;
|
|
|
|
var dto = entity.Adapt<TDto>();
|
|
return dto;
|
|
}
|
|
|
|
public async virtual Task<IEnumerable<TDto>> GetResampledData(
|
|
DateTimeOffset dateBegin,
|
|
double intervalSec = 600d,
|
|
int approxPointsCount = 1024,
|
|
CancellationToken token = default)
|
|
{
|
|
var dtos = await GetGtDate(dateBegin, token);
|
|
|
|
var dateEnd = dateBegin.AddSeconds(intervalSec);
|
|
dtos = dtos
|
|
.Where(i => i.Timestamp <= dateEnd);
|
|
|
|
var ratio = dtos.Count() / approxPointsCount;
|
|
if (ratio > 1)
|
|
dtos = dtos
|
|
.Where((_, index) => index % ratio == 0);
|
|
|
|
return dtos;
|
|
}
|
|
}
|