Egalware/mapo-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Preprocess per cambio metodi Async

Browse Source
This commit is contained in:
Samuele Locatelli
2026-05-28 10:42:39 +02:00
parent e4d56be0af
commit 25c38f5bcb
5 changed files with 31 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files
MP.SPEC/Data/MpDataService.cs
+8 -8
View File
@@ -1105,9 +1105,9 @@ namespace MP.SPEC.Data
/// Elenco Gruppi
/// </summary>
/// <returns></returns>
public async Task<List<ParetoFluxLogDTO>> FluxLogPareto(string idxMacchina, DateTime dtFrom, DateTime dtTo)
public async Task<List<ParetoFluxLogDTO>> FluxLogParetoAsync(string idxMacchina, DateTime dtFrom, DateTime dtTo)
{
using var activity = ActivitySource.StartActivity("FluxLogPareto");
using var activity = ActivitySource.StartActivity("FluxLogParetoAsync");
string source = "DB";
List<ParetoFluxLogDTO>? result = new List<ParetoFluxLogDTO>();
// cerco in redis...
@@ -1120,7 +1120,7 @@ namespace MP.SPEC.Data
}
else
{
result = await Task.FromResult(dbController.FluxLogPareto(idxMacchina, dtFrom, dtTo));
result = await dbController.FluxLogParetoAsync(idxMacchina, dtFrom, dtTo);
// serializzo e salvo...
rawData = JsonConvert.SerializeObject(result);
await redisDb.StringSetAsync(redKey, rawData, getRandTOut(redisLongTimeCache));
@@ -1132,7 +1132,7 @@ namespace MP.SPEC.Data
activity?.SetTag("data.source", source);
activity?.SetTag("result.count", result.Count);
activity?.Stop();
LogTrace($"FluxLogPareto | Read from {source}: {activity?.Duration.TotalMilliseconds}ms");
LogTrace($"FluxLogParetoAsync | Read from {source}: {activity?.Duration.TotalMilliseconds}ms");
return result;
}
@@ -1545,9 +1545,9 @@ namespace MP.SPEC.Data
/// <param name="dtStart"></param>
/// <param name="dtEnd"></param>
/// <returns></returns>
public async Task<List<string>> MacchineWithFlux(DateTime dtStart, DateTime dtEnd)
public async Task<List<string>> MacchineWithFluxAsync(DateTime dtStart, DateTime dtEnd)
{
using var activity = ActivitySource.StartActivity("MacchineWithFlux");
using var activity = ActivitySource.StartActivity("MacchineWithFluxAsync");
List<string>? result = new List<string>();
string source = "DB";
string currKey = $"{Utils.redisMacByFlux}:{dtStart:yyyyMMddHHmm}:{dtEnd:yyyyMMddHHmm}";
@@ -1560,7 +1560,7 @@ namespace MP.SPEC.Data
}
else
{
result = await dbController.MacchineWithFlux(dtStart, dtEnd);
result = await dbController.MacchineWithFluxAsync(dtStart, dtEnd);
// serializzo e salvo...
rawData = JsonConvert.SerializeObject(result);
redisDb.StringSet(currKey, rawData, getRandTOut(redisLongTimeCache));
@@ -1572,7 +1572,7 @@ namespace MP.SPEC.Data
activity?.SetTag("data.source", source);
activity?.SetTag("result.count", result.Count);
activity?.Stop();
LogTrace($"MacchineWithFlux | Read from {source}: {activity?.Duration.TotalMilliseconds}ms");
LogTrace($"MacchineWithFluxAsync | Read from {source}: {activity?.Duration.TotalMilliseconds}ms");
return result;
}