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

Update pagina composizione kit PODL

Browse Source
This commit is contained in:
Samuele Locatelli
2026-05-29 12:01:01 +02:00
parent af264a8922
commit 7de0f88b9e
41 changed files with 111 additions and 142 deletions
Download Patch File Download Diff File Expand all files Collapse all files
MP.SPEC/Data/MpDataService.cs
+28 -17
View File
@@ -2251,18 +2251,21 @@ namespace MP.SPEC.Data
/// Elimina record + svuotamento cache
/// </summary>
/// <param name="currRecord"></param>
public bool WipKitDelete(WipSetupKitModel currRecord)
public async Task<bool> WipKitDeleteAsync(WipSetupKitModel currRecord)
{
using var activity = ActivitySource.StartActivity("WipKitDelete");
using var activity = ActivitySource.StartActivity("WipKitDeleteAsync");
string source = "DB";
bool fatto = false;
// salvo
fatto = dbController.WipKitDelete(currRecord);
fatto = await dbController.WipKitDeleteAsync(currRecord);
// svuoto cache
EmptyWipCache();
await FlushCacheByTagAsync(Utils.redisKitWip);
#if false
EmptyWipCache();
#endif
activity?.SetTag("data.source", source);
activity?.Stop();
LogTrace($"WipKitDelete Read from {source}: {activity?.Duration.TotalMilliseconds}ms");
LogTrace($"WipKitDeleteAsync Read from {source}: {activity?.Duration.TotalMilliseconds}ms");
return fatto;
}
@@ -2270,18 +2273,21 @@ namespace MP.SPEC.Data
/// Elimina i record più vecchi della data-ora indicata
/// </summary>
/// <param name="DateLimit"></param>
public bool WipKitDeleteOlder(DateTime DateLimit)
public async Task<bool> WipKitDeleteOlderAsync(DateTime DateLimit)
{
using var activity = ActivitySource.StartActivity("WipKitDeleteOlder");
using var activity = ActivitySource.StartActivity("WipKitDeleteOlderAsync");
string source = "DB";
bool fatto = false;
// salvo
fatto = dbController.WipKitDeleteOlder(DateLimit);
// svuoto cache
EmptyWipCache();
fatto = await dbController.WipKitDeleteOlderAsync(DateLimit);
// svuoto cache KitWip
await FlushCacheByTagAsync(Utils.redisKitWip);
#if false
EmptyWipCache();
#endif
activity?.SetTag("data.source", source);
activity?.Stop();
LogTrace($"WipKitDeleteOlder Read from {source}: {activity?.Duration.TotalMilliseconds}ms");
LogTrace($"WipKitDeleteOlderAsync Read from {source}: {activity?.Duration.TotalMilliseconds}ms");
return fatto;
}
@@ -2306,18 +2312,21 @@ namespace MP.SPEC.Data
/// Esegue salvataggio record + svuotamento cache
/// </summary>
/// <param name="currRecord"></param>
public bool WipKitUpsert(WipSetupKitModel currRecord)
public async Task<bool> WipKitUpsertAsync(WipSetupKitModel currRecord)
{
using var activity = ActivitySource.StartActivity("WipKitUpsert");
using var activity = ActivitySource.StartActivity("WipKitUpsertAsync");
string source = "DB";
bool fatto = false;
// salvo
fatto = dbController.WipKitUpsert(currRecord);
fatto = await dbController.WipKitUpsertAsync(currRecord);
// svuoto cache KitWip
EmptyWipCache();
await FlushCacheByTagAsync(Utils.redisKitWip);
#if false
EmptyWipCache();
#endif
activity?.SetTag("data.source", source);
activity?.Stop();
LogTrace($"WipKitUpsert | {source} | {activity?.Duration.TotalMilliseconds}ms");
LogTrace($"WipKitUpsertAsync | {source} | {activity?.Duration.TotalMilliseconds}ms");
return fatto;
}
@@ -2472,6 +2481,7 @@ namespace MP.SPEC.Data
#region Private Methods
#if false
/// <summary>
/// Svuota cache creazione KIT
/// </summary>
@@ -2482,7 +2492,8 @@ namespace MP.SPEC.Data
{
ExecFlushRedisPattern(pattern);
}
}
}
#endif
/// <summary>
/// Verifica caricamento dizionario ConfigData