diff --git a/EgwCoreLib.Lux.Data/Services/Catalog/TemplateRowService.cs b/EgwCoreLib.Lux.Data/Services/Catalog/TemplateRowService.cs
index ae31ef57..50a6c525 100644
--- a/EgwCoreLib.Lux.Data/Services/Catalog/TemplateRowService.cs
+++ b/EgwCoreLib.Lux.Data/Services/Catalog/TemplateRowService.cs
@@ -14,6 +14,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
IConnectionMultiplexer redis,
ITemplateRowRepository repo) : base(config, redis)
{
+ _className = "TemplateRow";
_repo = repo;
}
@@ -28,7 +29,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
///
public async Task CloneAsync(TemplateRowModel rec2clone)
{
- return await TraceAsync("TemplateRow.Clone", async (activity) =>
+ return await TraceAsync($"{_className}.Clone", async (activity) =>
{
// eseguo clone
var result = await _repo.CloneAsync(rec2clone);
@@ -38,7 +39,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
{
// Invalido sia la lista classi che eventuali dettagli correlati
await ClearCacheAsync($"{_redisBaseKey}:Template:*");
- await ClearCacheAsync($"{_redisBaseKey}:TemplateRows:*");
+ await ClearCacheAsync($"{_redisBaseKey}:{_className}:*");
}
return result;
});
@@ -51,7 +52,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
///
public async Task DeleteAsync(TemplateRowModel rec2del)
{
- return await TraceAsync("TemplateRow.Delete", async (activity) =>
+ return await TraceAsync($"{_className}.Delete", async (activity) =>
{
var dbResult = await _repo.GetRowAsync(rec2del.TemplateRowID);
if (dbResult == null) return false;
@@ -61,7 +62,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
if (success)
{
await ClearCacheAsync($"{_redisBaseKey}:Template:*");
- await ClearCacheAsync($"{_redisBaseKey}:TemplateRows:*");
+ await ClearCacheAsync($"{_redisBaseKey}:{_className}:*");
}
return success;
@@ -75,7 +76,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
///
public async Task> FixRowUidAsync(int templateId)
{
- return await TraceAsync("TemplateRow.FixRowUidAsync", async (activity) =>
+ return await TraceAsync($"{_className}.FixRowUidAsync", async (activity) =>
{
// 1. Recupero righe
var rows = await _repo.GetRowsAsync(templateId);
@@ -105,7 +106,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
if (success)
{
await ClearCacheAsync($"{_redisBaseKey}:Template:*");
- await ClearCacheAsync($"{_redisBaseKey}:TemplateRows:*");
+ await ClearCacheAsync($"{_redisBaseKey}:{_className}:*");
}
return result;
@@ -118,10 +119,10 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
///
public async Task> GetAllAsync()
{
- return await TraceAsync("TemplateRow.GetAll", async (activity) =>
+ return await TraceAsync($"{_className}.GetAll", async (activity) =>
{
return await GetOrSetCacheAsync(
- $"{_redisBaseKey}:TemplateRow:ALL",
+ $"{_redisBaseKey}:{_className}:ALL",
async () => await _repo.GetAllWithNavAsync(),
UltraLongCache
);
@@ -135,11 +136,10 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
///
public async Task> GetByParentAsync(int templateId)
{
-
- return await TraceAsync("TemplateRow.GetByParent", async (activity) =>
+ return await TraceAsync($"{_className}.GetByParent", async (activity) =>
{
return await GetOrSetCacheAsync(
- $"{_redisBaseKey}:TemplateRow:{templateId}",
+ $"{_redisBaseKey}:{_className}:{templateId}",
async () => await _repo.GetRowsAsync(templateId),
LongCache
);
@@ -148,7 +148,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
public async Task UpdateAwaitStateAsync(int templateRowId, bool? awaitBom, bool? awaitPrice, bool flushCache = false)
{
- return await TraceAsync("TemplateRow.UpdateAwaitState", async (activity) =>
+ return await TraceAsync($"{_className}.UpdateAwaitState", async (activity) =>
{
var currRec = await _repo.GetRowAsync(templateRowId);
@@ -170,7 +170,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
if (success && flushCache)
{
await ClearCacheAsync($"{_redisBaseKey}:Template:*");
- await ClearCacheAsync($"{_redisBaseKey}:TemplateRows:*");
+ await ClearCacheAsync($"{_redisBaseKey}:{_className}:*");
}
return success;
@@ -184,7 +184,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
///
public async Task UpdateFileDataAsync(TemplateRowModel updRec)
{
- return await TraceAsync("TemplateRow.UpdateFileData", async (activity) =>
+ return await TraceAsync($"{_className}.UpdateFileData", async (activity) =>
{
var currRec = await _repo.GetRowAsync(updRec.TemplateRowID);
@@ -205,7 +205,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
if (success)
{
await ClearCacheAsync($"{_redisBaseKey}:Template:*");
- await ClearCacheAsync($"{_redisBaseKey}:TemplateRows:*");
+ await ClearCacheAsync($"{_redisBaseKey}:{_className}:*");
}
return success;
@@ -220,7 +220,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
///
public async Task UpdateSerStructAsync(int TemplateRowID, string serStruct)
{
- return await TraceAsync("TemplateRow.UpdateSerStruct", async (activity) =>
+ return await TraceAsync($"{_className}.UpdateSerStruct", async (activity) =>
{
var currRec = await _repo.GetRowAsync(TemplateRowID);
@@ -238,7 +238,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
if (success)
{
await ClearCacheAsync($"{_redisBaseKey}:Template:*");
- await ClearCacheAsync($"{_redisBaseKey}:TemplateRows:*");
+ await ClearCacheAsync($"{_redisBaseKey}:{_className}:*");
}
return success;
@@ -252,7 +252,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
///
public async Task UpsertAsync(TemplateRowModel upsRec)
{
- return await TraceAsync("TemplateRow.Upsert", async (activity) =>
+ return await TraceAsync($"{_className}.Upsert", async (activity) =>
{
var currRec = await _repo.GetRowAsync(upsRec.TemplateRowID);
@@ -274,7 +274,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
if (success)
{
await ClearCacheAsync($"{_redisBaseKey}:Template:*");
- await ClearCacheAsync($"{_redisBaseKey}:TemplateRows:*");
+ await ClearCacheAsync($"{_redisBaseKey}:{_className}:*");
}
return success;
@@ -285,6 +285,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
#region Private Fields
+ private readonly string _className;
private readonly ITemplateRowRepository _repo;
#endregion Private Fields
diff --git a/EgwCoreLib.Lux.Data/Services/Catalog/TemplateService.cs b/EgwCoreLib.Lux.Data/Services/Catalog/TemplateService.cs
index 4ce76091..2c2fc492 100644
--- a/EgwCoreLib.Lux.Data/Services/Catalog/TemplateService.cs
+++ b/EgwCoreLib.Lux.Data/Services/Catalog/TemplateService.cs
@@ -17,6 +17,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
IConnectionMultiplexer redis,
ITemplateRepository repo) : base(config, redis)
{
+ _className = "Template";
_repo = repo;
}
@@ -31,7 +32,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
///
public async Task CloneAsync(TemplateModel rec2clone)
{
- return await TraceAsync("Template.Clone", async (activity) =>
+ return await TraceAsync($"{_className}.Clone", async (activity) =>
{
// eseguo clone
var result = await _repo.CloneAsync(rec2clone);
@@ -40,7 +41,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
if (result)
{
// Invalido sia la lista classi che eventuali dettagli correlati
- await ClearCacheAsync($"{_redisBaseKey}:Template:*");
+ await ClearCacheAsync($"{_redisBaseKey}:{_className}:*");
await ClearCacheAsync($"{_redisBaseKey}:TemplateRows:*");
}
return result;
@@ -54,7 +55,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
///
public async Task DeleteAsync(TemplateModel rec2del)
{
- return await TraceAsync("Template.Delete", async (activity) =>
+ return await TraceAsync($"{_className}.Delete", async (activity) =>
{
var dbResult = await _repo.GetByIdAsync(rec2del.TemplateID);
if (dbResult == null) return false;
@@ -70,7 +71,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
bool success = await _repo.DeleteAsync(dbResult);
if (success)
{
- await ClearCacheAsync($"{_redisBaseKey}:Template:*");
+ await ClearCacheAsync($"{_redisBaseKey}:{_className}:*");
await ClearCacheAsync($"{_redisBaseKey}:TemplateRows:*");
}
@@ -85,10 +86,10 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
public async Task> GetAllAsync()
{
// Uso helper TraceAsync che gestisce automaticamente StartActivity, Log e Exception tracking
- return await TraceAsync("Template.GetAll", async (activity) =>
+ return await TraceAsync($"{_className}.GetAll", async (activity) =>
{
return await GetOrSetCacheAsync(
- $"{_redisBaseKey}:Template:ALL",
+ $"{_redisBaseKey}:{_className}:ALL",
async () => await _repo.GetAllWithNavAsync()
);
});
@@ -101,7 +102,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
///
public async Task UpdateCostAsync(int templateId)
{
- return await TraceAsync("Template.Upsert", async (activity) =>
+ return await TraceAsync($"{_className}.Upsert", async (activity) =>
{
// 1. Recupero dati
var rows = await _repo.GetRowsAsync(templateId);
@@ -150,7 +151,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
if (result)
{
// 4. Invalido cache
- await ClearCacheAsync($"{_redisBaseKey}:Template:*");
+ await ClearCacheAsync($"{_redisBaseKey}:{_className}:*");
await ClearCacheAsync($"{_redisBaseKey}:TemplateRows:*");
}
@@ -165,7 +166,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
///
public async Task UpsertAsync(TemplateModel upsRec)
{
- return await TraceAsync("Template.Upsert", async (activity) =>
+ return await TraceAsync($"{_className}.Upsert", async (activity) =>
{
var currRec = await _repo.GetByIdAsync(upsRec.TemplateID);
@@ -185,7 +186,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
if (success)
{
- await ClearCacheAsync($"{_redisBaseKey}:Template:*");
+ await ClearCacheAsync($"{_redisBaseKey}:{_className}:*");
await ClearCacheAsync($"{_redisBaseKey}:TemplateRows:*");
}
@@ -197,6 +198,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
#region Private Fields
+ private readonly string _className;
private readonly ITemplateRepository _repo;
#endregion Private Fields
diff --git a/EgwCoreLib.Lux.Data/Services/Config/ConfProfileService.cs b/EgwCoreLib.Lux.Data/Services/Config/ConfProfileService.cs
index dbf23e4d..844b0319 100644
--- a/EgwCoreLib.Lux.Data/Services/Config/ConfProfileService.cs
+++ b/EgwCoreLib.Lux.Data/Services/Config/ConfProfileService.cs
@@ -14,8 +14,8 @@ namespace EgwCoreLib.Lux.Data.Services.Config
IConnectionMultiplexer redis,
IConfProfileRepository repo) : base(config, redis)
{
- _repo = repo;
_className = "ConfProfile";
+ _repo = repo;
}
#endregion Public Constructors
diff --git a/EgwCoreLib.Lux.Data/Services/Config/ConfWoodService.cs b/EgwCoreLib.Lux.Data/Services/Config/ConfWoodService.cs
index 4ed2fab6..fc300382 100644
--- a/EgwCoreLib.Lux.Data/Services/Config/ConfWoodService.cs
+++ b/EgwCoreLib.Lux.Data/Services/Config/ConfWoodService.cs
@@ -14,8 +14,8 @@ namespace EgwCoreLib.Lux.Data.Services.Config
IConnectionMultiplexer redis,
IConfWoodRepository repo) : base(config, redis)
{
- _repo = repo;
_className = "ConfWood";
+ _repo = repo;
}
#endregion Public Constructors
diff --git a/EgwCoreLib.Lux.Data/Services/Config/EnvirParamService.cs b/EgwCoreLib.Lux.Data/Services/Config/EnvirParamService.cs
index fbe9905a..8d8a43e1 100644
--- a/EgwCoreLib.Lux.Data/Services/Config/EnvirParamService.cs
+++ b/EgwCoreLib.Lux.Data/Services/Config/EnvirParamService.cs
@@ -14,6 +14,7 @@ namespace EgwCoreLib.Lux.Data.Services.Config
IConnectionMultiplexer redis,
IEnvirParamRepository repo) : base(config, redis)
{
+ _className = "EnvirParam";
_repo = repo;
}
@@ -24,10 +25,10 @@ namespace EgwCoreLib.Lux.Data.Services.Config
public async Task> GetAllAsync()
{
// Uso helper TraceAsync che gestisce automaticamente StartActivity, Log e Exception tracking
- return await TraceAsync("EnvirParam.GetAll", async (activity) =>
+ return await TraceAsync($"{_className}.GetAll", async (activity) =>
{
return await GetOrSetCacheAsync(
- $"{_redisBaseKey}:ConfEnvir",
+ $"{_redisBaseKey}:{_className}",
async () => await _repo.GetAllAsync(),
UltraLongCache
);
@@ -38,6 +39,7 @@ namespace EgwCoreLib.Lux.Data.Services.Config
#region Private Fields
+ private readonly string _className;
private readonly IEnvirParamRepository _repo;
#endregion Private Fields
diff --git a/EgwCoreLib.Lux.Data/Services/Utils/GenClassService.cs b/EgwCoreLib.Lux.Data/Services/Utils/GenClassService.cs
index 2c2fb956..b545eb3e 100644
--- a/EgwCoreLib.Lux.Data/Services/Utils/GenClassService.cs
+++ b/EgwCoreLib.Lux.Data/Services/Utils/GenClassService.cs
@@ -14,6 +14,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
IConnectionMultiplexer redis,
IGenClassRepository repo) : base(config, redis)
{
+ _className = "GenClass";
_repo = repo;
}
@@ -23,7 +24,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
public async Task DeleteAsync(GenClassModel rec2del)
{
- return await TraceAsync("GenClass.Delete", async (activity) =>
+ return await TraceAsync($"{_className}.Delete", async (activity) =>
{
var dbResult = await _repo.GetByCodeAsync(rec2del.ClassCod);
if (dbResult == null) return false;
@@ -40,7 +41,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
if (success)
{
- await ClearCacheAsync($"{_redisBaseKey}:GenClass*");
+ await ClearCacheAsync($"{_redisBaseKey}:{_className}*");
}
return success;
@@ -49,10 +50,10 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
public async Task> GetAllAsync()
{
- return await TraceAsync("GenClass.GetAll", async (activity) =>
+ return await TraceAsync($"{_className}.GetAll", async (activity) =>
{
return await GetOrSetCacheAsync(
- $"{_redisBaseKey}:GenClass",
+ $"{_redisBaseKey}:{_className}",
async () => await _repo.GetAllAsync(),
UltraLongCache
);
@@ -61,7 +62,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
public async Task UpsertAsync(GenClassModel upsRec)
{
- return await TraceAsync("GenClass.Upsert", async (activity) =>
+ return await TraceAsync($"{_className}.Upsert", async (activity) =>
{
var currRec = await _repo.GetByCodeAsync(upsRec.ClassCod);
@@ -81,7 +82,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
if (success)
{
- await ClearCacheAsync($"{_redisBaseKey}:GenClass*");
+ await ClearCacheAsync($"{_redisBaseKey}:{_className}*");
}
return success;
@@ -92,6 +93,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
#region Private Fields
+ private readonly string _className;
private readonly IGenClassRepository _repo;
#endregion Private Fields
diff --git a/EgwCoreLib.Lux.Data/Services/Utils/GenValService.cs b/EgwCoreLib.Lux.Data/Services/Utils/GenValService.cs
index 7ef58d0f..addbfe3b 100644
--- a/EgwCoreLib.Lux.Data/Services/Utils/GenValService.cs
+++ b/EgwCoreLib.Lux.Data/Services/Utils/GenValService.cs
@@ -14,6 +14,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
IConnectionMultiplexer redis,
IGenValRepository repo) : base(config, redis)
{
+ _className = "GenVal";
_repo = repo;
}
@@ -23,14 +24,14 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
public async Task DeleteAsync(GenValueModel rec2del)
{
- return await TraceAsync("GenVal.Delete", async (activity) =>
+ return await TraceAsync($"{_className}.Delete", async (activity) =>
{
bool success = await _repo.DeleteAsync(rec2del);
if (success)
{
await ClearCacheAsync($"{_redisBaseKey}:GenClass*");
- await ClearCacheAsync($"{_redisBaseKey}:GenVal:*");
+ await ClearCacheAsync($"{_redisBaseKey}:{_className}:*");
}
return success;
@@ -39,10 +40,10 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
public async Task> GetFiltAsync(string codClass)
{
- return await TraceAsync("GenVal.GetFilt", async (activity) =>
+ return await TraceAsync($"{_className}.GetFilt", async (activity) =>
{
return await GetOrSetCacheAsync(
- $"{_redisBaseKey}:GenVal:{codClass}",
+ $"{_redisBaseKey}:{_className}:{codClass}",
async () => await _repo.GetFiltAsync(codClass),
UltraLongCache
);
@@ -51,14 +52,14 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
public async Task MoveAsync(GenValueModel selRec, bool moveUp)
{
- return await TraceAsync("GenVal.MoveAsync", async (activity) =>
+ return await TraceAsync($"{_className}.MoveAsync", async (activity) =>
{
bool success = await _repo.MoveAsync(selRec, moveUp);
if (success)
{
await ClearCacheAsync($"{_redisBaseKey}:GenClass*");
- await ClearCacheAsync($"{_redisBaseKey}:GenVal:*");
+ await ClearCacheAsync($"{_redisBaseKey}:{_className}:*");
}
return success;
@@ -67,7 +68,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
public async Task UpsertAsync(GenValueModel upsRec)
{
- return await TraceAsync("GenVal.Upsert", async (activity) =>
+ return await TraceAsync($"{_className}.Upsert", async (activity) =>
{
var currRec = await _repo.GetByIdAsync(upsRec.GenValID);
@@ -88,7 +89,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
if (success)
{
await ClearCacheAsync($"{_redisBaseKey}:GenClass*");
- await ClearCacheAsync($"{_redisBaseKey}:GenVal:*");
+ await ClearCacheAsync($"{_redisBaseKey}:{_className}:*");
}
return success;
@@ -99,6 +100,7 @@ namespace EgwCoreLib.Lux.Data.Services.Utils
#region Private Fields
+ private readonly string _className;
private readonly IGenValRepository _repo;
#endregion Private Fields