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

hask key gestione tramite constants

Browse Source
This commit is contained in:
Samuele Locatelli
2022-03-10 07:29:58 +01:00
parent 41a9b29971
commit 27e654a872
5 changed files with 66 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files
MachineSim/Program.cs
+12 -13
View File
@@ -68,7 +68,7 @@ void setupConf()
{
List<MachineStatus>? statusList = JsonConvert.DeserializeObject<List<MachineStatus>>(rawData);
// salvo in redis!
redisDb.StringSetAsync(Utils.mHash("Conf:Status"), JsonConvert.SerializeObject(statusList));
redisDb.StringSetAsync(Constants.STATUS_CONF_KEY, JsonConvert.SerializeObject(statusList));
}
}
// leggo e salvo conf modi
@@ -80,7 +80,7 @@ void setupConf()
{
var localObj = JsonConvert.DeserializeObject<List<MachineMode>>(rawData);
// salvo in redis!
redisDb.StringSetAsync(Utils.mHash("Conf:Mode"), JsonConvert.SerializeObject(localObj));
redisDb.StringSetAsync(Constants.MODE_CONF_KEY, JsonConvert.SerializeObject(localObj));
}
}
}
@@ -89,8 +89,7 @@ void saveAndSendMessage(string memKey, string value, string notifyChannel, strin
{
// effettuo la scrittura nell'area di memoria indicata
redisDb.StringSetAsync(memKey, value);
//redis.GetDatabase().SetAdd(memKey, value);
//redis.GetDatabase().StringSetAsync(memKey, value);
//redisDb.SetAdd(memKey, value);
// invio notifica tramite il canale richiesto
sub.Publish(notifyChannel, message);
@@ -118,7 +117,7 @@ void simAlarms()
}
string rawData = JsonConvert.SerializeObject(activeAlarms);
// decodifico allarme e lo trasformo in List<String> di allarmi attivi...
saveAndSendMessage(Utils.mHash("Machine:Alarms:Current"), rawData, "allarms", rawData);
saveAndSendMessage(Constants.ALARM_CURR_KEY, rawData, "allarms", rawData);
// attesa random
Thread.Sleep(rand.Next(minPeriod, maxPeriod));
} while (true);
@@ -133,7 +132,7 @@ void simParameters()
{
var newParams = currSimGen.getParameters();
string rawData = JsonConvert.SerializeObject(newParams);
saveAndSendMessage(Utils.mHash("Machine:Parameters:Current"), rawData, "parameters", rawData);
saveAndSendMessage(Constants.PARAMS_CURR_KEY, rawData, "parameters", rawData);
// attesa random
Thread.Sleep(rand.Next(minPeriod, maxPeriod));
} while (true);
@@ -149,7 +148,7 @@ void simStatus()
// recupero uno stato simulato
var newStatus = currSimGen.getStatus();
string rawData = JsonConvert.SerializeObject(newStatus);
saveAndSendMessage(Utils.mHash("Machine:Status:Current"), rawData, "status", rawData);
saveAndSendMessage(Constants.STATUS_CURR_KEY, rawData, "status", rawData);
// attesa random
Thread.Sleep(rand.Next(minPeriod, maxPeriod));
@@ -166,7 +165,7 @@ void simProd()
// recupero uno stato simulato
var newStatus = currSimGen.getProd();
string rawData = JsonConvert.SerializeObject(newStatus);
saveAndSendMessage(Utils.mHash("Machine:Production:Current"), rawData, "production", rawData);
saveAndSendMessage(Constants.PROD_CURR_KEY, rawData, "production", rawData);
// attesa random
Thread.Sleep(rand.Next(minPeriod, maxPeriod));
@@ -183,7 +182,7 @@ void simMachStat()
// recupero uno stato simulato
var newVal = currSimGen.getProdStats();
string rawData = JsonConvert.SerializeObject(newVal);
saveAndSendMessage(Utils.mHash("Machine:MachStats:Current"), rawData, "machstats", rawData);
saveAndSendMessage(Constants.MACH_STATS_CURR_KEY, rawData, "machstats", rawData);
// attesa random
Thread.Sleep(rand.Next(minPeriod, maxPeriod));
@@ -200,7 +199,7 @@ void simMaint()
// recupero uno stato simulato
var newVal = currSimGen.getMaint();
string rawData = JsonConvert.SerializeObject(newVal);
saveAndSendMessage(Utils.mHash("Machine:Maintenance:Current"), rawData, "maintenance", rawData);
saveAndSendMessage(Constants.MAINT_STATS_CURR_KEY, rawData, "maintenance", rawData);
// attesa random
Thread.Sleep(rand.Next(minPeriod, maxPeriod));
@@ -217,7 +216,7 @@ void simTools()
// recupero uno stato simulato
var newVal = currSimGen.getTools();
string rawData = JsonConvert.SerializeObject(newVal);
saveAndSendMessage(Utils.mHash("Machine:Tools:Current"), rawData, "tools", rawData);
saveAndSendMessage(Constants.TOOLS_CURR_KEY, rawData, "tools", rawData);
// attesa random
Thread.Sleep(rand.Next(minPeriod, maxPeriod));
@@ -234,7 +233,7 @@ void simEvents()
// recupero uno stato simulato
var newVal = currSimGen.getEvents();
string rawData = JsonConvert.SerializeObject(newVal);
saveAndSendMessage(Utils.mHash("Machine:Events:Current"), rawData, "events", rawData);
saveAndSendMessage(Constants.EVENT_LOG_CURR_KEY, rawData, "events", rawData);
// attesa random
Thread.Sleep(rand.Next(minPeriod, maxPeriod));
@@ -251,7 +250,7 @@ void simActivityLog()
// recupero uno stato simulato
var newVal = currSimGen.getActLog();
string rawData = JsonConvert.SerializeObject(newVal);
saveAndSendMessage(Utils.mHash("Machine:ActivityLog:Current"), rawData, "activitylog", rawData);
saveAndSendMessage(Constants.ACT_LOG_CURR_KEY, rawData, "activitylog", rawData);
// attesa random
Thread.Sleep(rand.Next(minPeriod, maxPeriod));