- Fix callback test
This commit is contained in:
ngfrolov 2024-08-05 16:07:41 +05:00
parent cbfce9eefc
commit 6ab3fdadbd
Signed by: ng.frolov
GPG Key ID: E99907A0357B29A7
3 changed files with 9 additions and 13 deletions

View File

@ -1,7 +1,4 @@
using AsbCloudApp.Data;
using AsbCloudApp.Requests;
using System; using System;
using System.Collections.Generic;
using System.Threading; using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
@ -13,16 +10,15 @@ namespace AsbCloudApp.Services
public interface IDataSaubStatService public interface IDataSaubStatService
{ {
/// <summary> /// <summary>
/// Создание записей таблицы DataSaubStat /// Расчет статистики DataSaubStat
/// </summary> /// </summary>
/// <param name="gap"> /// <param name="lastDaysFilter">
/// Количество дней, которые необходимо вычесть из текущей даты для формирования начальной даты /// Количество дней за которые должны были приходить данные, чтобы телеметрия попала в обработку.
/// сбора данных по телеметрии
/// </param> /// </param>
/// <param name="onProgressCallback"></param> /// <param name="onProgressCallback"></param>
/// <param name="token"></param> /// <param name="token"></param>
/// <returns></returns> /// <returns></returns>
Task CreateStatAsync(int gap, Action<string, double?> onProgressCallback, CancellationToken token); Task CreateStatAsync(int lastDaysFilter, Action<string, double?> onProgressCallback, CancellationToken token);
} }
} }

View File

@ -33,11 +33,11 @@ namespace AsbCloudInfrastructure.Services
this.detectedOperationRepository = detectedOperationRepository; this.detectedOperationRepository = detectedOperationRepository;
} }
public async Task CreateStatAsync(int gap, Action<string, double?> onProgressCallback, CancellationToken token) public async Task CreateStatAsync(int lastDaysFilter, Action<string, double?> onProgressCallback, CancellationToken token)
{ {
var cacheRequest = new TelemetryDataRequest() var cacheRequest = new TelemetryDataRequest()
{ {
GeDate = DateTime.UtcNow.AddDays(-gap) GeDate = DateTime.UtcNow.AddDays(-lastDaysFilter)
}; };
var idTelemetries = telemetryDataCache.GetIds(cacheRequest).ToArray(); var idTelemetries = telemetryDataCache.GetIds(cacheRequest).ToArray();
@ -52,7 +52,7 @@ namespace AsbCloudInfrastructure.Services
var lastDate = stats.FirstOrDefault(s => s.IdTelemetry == idTelemetry)?.DateEnd.ToUniversalTime() ?? DateTimeOffset.UnixEpoch; var lastDate = stats.FirstOrDefault(s => s.IdTelemetry == idTelemetry)?.DateEnd.ToUniversalTime() ?? DateTimeOffset.UnixEpoch;
var statsCount = await CreateStatForTelemetryFromDate(idTelemetry, lastDate, token); var statsCount = await CreateStatForTelemetryFromDate(idTelemetry, lastDate, token);
if(onProgressCallback != null) if(onProgressCallback != null)
onProgressCallback($"Calculate stat for telemetry: {idTelemetry}; from {lastDate}; results count: {statsCount};", i * 1d / idTelemetries.Length); onProgressCallback($"Calculate stat for telemetry: {idTelemetry}; from {lastDate}; results count: {statsCount};", 1d * i / idTelemetries.Length);
} }
} }

View File

@ -248,7 +248,7 @@ public class DataSaubStatServiceTest
{ {
//assert //assert
Assert.NotNull(percent); Assert.NotNull(percent);
Assert.InRange((double)percent, 0.0, 100.0); Assert.InRange(percent.Value, 0.0, 1.0);
}; };
//act //act
@ -309,7 +309,7 @@ public class DataSaubStatServiceTest
{ {
//assert //assert
Assert.NotNull(percent); Assert.NotNull(percent);
Assert.InRange((double)percent, 0.0, 100.0); Assert.InRange(percent.Value, 0.0, 1.0);
}; };
//act //act