Egalware/gpw_next
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Continuo fix dati x cambio tipologia cache

Browse Source
This commit is contained in:
Samuele Locatelli
2023-01-11 07:58:41 +01:00
parent 882ca626de
commit e77c7b3c7f
5 changed files with 46 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files
GPW.CORE.WRKLOG/Data/GpwDataService.cs
+42 -25
View File
@@ -116,32 +116,39 @@ namespace GPW.CORE.WRKLOG.Data
/// <returns></returns>
public async Task<List<AnagClientiModel>> AnagClientiAll()
{
string source = "DB";
List<AnagClientiModel>? dbResult = new List<AnagClientiModel>();
string currKey = $"{rKeyCliAll}";
string rawData;
var redisDataList = await distributedCache.GetAsync(currKey);
if (redisDataList != null)
Stopwatch stopWatch = new Stopwatch();
stopWatch.Start();
string? rawData = await redisDb.StringGetAsync(currKey);
if (!string.IsNullOrEmpty(rawData))
{
rawData = Encoding.UTF8.GetString(redisDataList);
dbResult = JsonConvert.DeserializeObject<List<AnagClientiModel>>(rawData);
source = "REDIS";
var tempResult = JsonConvert.DeserializeObject<List<AnagClientiModel>>(rawData);
if (tempResult == null)
{
dbResult = new List<AnagClientiModel>();
}
else
{
dbResult = tempResult;
}
}
else
{
Stopwatch stopWatch = new Stopwatch();
stopWatch.Start();
dbResult = dbController.AnagClientiAll();
rawData = JsonConvert.SerializeObject(dbResult, JSSettings);
redisDataList = Encoding.UTF8.GetBytes(rawData);
await distributedCache.SetAsync(currKey, redisDataList, cacheOpt(true));
stopWatch.Stop();
TimeSpan ts = stopWatch.Elapsed;
Log.Trace($"Effettuata lettura da DB + caching per AnagClientiAll: {ts.TotalMilliseconds} ms");
await redisDb.StringSetAsync(currKey, rawData, FastCache);
}
if (dbResult == null)
{
dbResult = new List<AnagClientiModel>();
}
stopWatch.Stop();
TimeSpan ts = stopWatch.Elapsed;
Log.Debug($"AnagClientiAll | {source} in: {ts.TotalMilliseconds} ms");
return await Task.FromResult(dbResult);
}
@@ -151,32 +158,38 @@ namespace GPW.CORE.WRKLOG.Data
/// <returns></returns>
public async Task<List<AnagFasiModel>> AnagFasiAll()
{
string source = "DB";
List<AnagFasiModel>? dbResult = new List<AnagFasiModel>();
string currKey = $"{rKeyFasiAll}";
string rawData;
var redisDataList = await distributedCache.GetAsync(currKey);
if (redisDataList != null)
Stopwatch stopWatch = new Stopwatch();
stopWatch.Start();
string? rawData = await redisDb.StringGetAsync(currKey);
if (!string.IsNullOrEmpty(rawData))
{
rawData = Encoding.UTF8.GetString(redisDataList);
dbResult = JsonConvert.DeserializeObject<List<AnagFasiModel>>(rawData);
source = "REDIS";
var tempResult = JsonConvert.DeserializeObject<List<AnagFasiModel>>(rawData);
if (tempResult == null)
{
dbResult = new List<AnagFasiModel>();
}
else
{
dbResult = tempResult;
}
}
else
{
Stopwatch stopWatch = new Stopwatch();
stopWatch.Start();
dbResult = dbController.AnagFasiAll(false);
rawData = JsonConvert.SerializeObject(dbResult, JSSettings);
redisDataList = Encoding.UTF8.GetBytes(rawData);
await distributedCache.SetAsync(currKey, redisDataList, cacheOpt(true));
stopWatch.Stop();
TimeSpan ts = stopWatch.Elapsed;
Log.Trace($"Effettuata lettura da DB + caching per AnagFasiAll: {ts.TotalMilliseconds} ms");
await redisDb.StringSetAsync(currKey, rawData, FastCache);
}
if (dbResult == null)
{
dbResult = new List<AnagFasiModel>();
}
stopWatch.Stop();
TimeSpan ts = stopWatch.Elapsed;
Log.Debug($"AnagFasiAll | {source} in: {ts.TotalMilliseconds} ms");
return await Task.FromResult(dbResult);
}
@@ -659,6 +672,10 @@ namespace GPW.CORE.WRKLOG.Data
rawData = JsonConvert.SerializeObject(dbResult, JSSettings);
await redisDb.StringSetAsync(currKey, rawData, FastCache);
}
if (dbResult == null)
{
dbResult = new List<DailyDataDTO>();
}
stopWatch.Stop();
TimeSpan ts = stopWatch.Elapsed;
Log.Debug($"DailyDetails | {source} in: {ts.TotalMilliseconds} ms");
GPW.CORE.WRKLOG/GPW.CORE.WRKLOG.csproj
+1 -1
View File
@@ -2,7 +2,7 @@
<PropertyGroup>
<TargetFramework>net6.0</TargetFramework>
<Version>3.0.2301.1021</Version>
<Version>3.0.2301.1107</Version>
<Nullable>enable</Nullable>
<ImplicitUsings>enable</ImplicitUsings>
</PropertyGroup>
Resources/ChangeLog.html
+1 -1
View File
@@ -1,6 +1,6 @@
<body>
<i>GPW - Gestione Presenze Web</i>
<h4>Versione: 3.0.2301.1021</h4>
<h4>Versione: 3.0.2301.1107</h4>
<br /> Note di rilascio:
<ul>
<li>
Resources/VersNum.txt
+1 -1
View File
@@ -1 +1 @@
3.0.2301.1021
3.0.2301.1107
Resources/manifest.xml
+1 -1
View File
@@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<item>
<version>3.0.2301.1021</version>
<version>3.0.2301.1107</version>
<url>http://nexus.steamware.net/repository/SWS/GWMS/stable/0/GWMS.UI.zip</url>
<changelog>http://nexus.steamware.net/repository/SWS/GWMS/stable/0/ChangeLog.html</changelog>
<mandatory>false</mandatory>