Completato metodo MP-IO x invio messaggio update!

This commit is contained in:
Samuele Locatelli
2022-12-09 19:39:13 +01:00
parent 3162608d82
commit ed7ffa7d22
3 changed files with 28 additions and 8 deletions
+15 -4
View File
@@ -110,14 +110,25 @@ namespace MP_IO.Controllers
public bool askCloseODL(string id, int idxOdl)
{
bool answ = false;
// init obj DataLayer
DataLayer DataLayerObj = new DataLayer();
try
{
// !!! FixME TODO inviare su channel redis richiesta chiusura immediata ODL all'utente
//DataLayerObj.taODL.forceClose(idxOdl, id);
answ = true;
// preparo una richiesta di chiusura...
DisplayAction CurrAction = new DisplayAction()
{
Topic = "Chiusura ODL",
Message = "Rilevato possibile fine operazioni, Vuoi chiudere la commessa?",
ShowCancel = true,
ShowClose = true,
ShowConfirm = true,
CancelAction = "DisableAction",
ConfirmAction = "CloseODL",
DtReq = DateTime.Now,
IsActive = true,
Parameter = $"{idxOdl}"
};
answ = DataLayerObj.ActionSetReq(CurrAction);
}
catch
{ }
+2
View File
@@ -17,6 +17,8 @@
<add key="RedisConn" value="localhost,abortConnect=false,ssl=false" />
<add key="RedisConnAdmin" value="localhost,abortConnect=false,ssl=false" />
<add key="redisDb" value="1" />
<add key="RedisConnSPEC" value="localhost:6379,DefaultDatabase=1,connectTimeout=5000,syncTimeout=5000,asyncTimeout=5000,abortConnect=false,ssl=false" />
<add key="RedisConnSPECAdmin" value="localhost:6379,DefaultDatabase=1,connectTimeout=5000,syncTimeout=5000,asyncTimeout=5000,abortConnect=false,ssl=false,allowAdmin=true" />
<!--altri parametri-->
<add key="CodModulo" value="MoonPro" />
<add key="cacheOnRedis" value="true" />
+11 -4
View File
@@ -176,12 +176,15 @@ namespace MapoDb
/// </summary>
private Lazy<ConnectionMultiplexer> lazyConnection = new Lazy<ConnectionMultiplexer>(() =>
{
string RedisConn = memLayer.ML.confReadString("RedisConn");
string RedisConn = memLayer.ML.confReadString("RedisConnSPEC");
if (string.IsNullOrEmpty(RedisConn))
{
RedisConn = memLayer.ML.confReadString("RedisConn");
}
if (string.IsNullOrEmpty(RedisConn))
{
RedisConn = "localhost,abortConnect=false,ssl=false";
}
return ConnectionMultiplexer.Connect(RedisConn);
});
@@ -190,12 +193,15 @@ namespace MapoDb
/// </summary>
private Lazy<ConnectionMultiplexer> lazyConnectionAdmin = new Lazy<ConnectionMultiplexer>(() =>
{
string RedisConnAdmin = memLayer.ML.confReadString("RedisConnAdmin");
string RedisConnAdmin = memLayer.ML.confReadString("RedisConnSPECAdmin");
if (string.IsNullOrEmpty(RedisConnAdmin))
{
RedisConnAdmin = memLayer.ML.confReadString("RedisConnAdmin");
}
if (string.IsNullOrEmpty(RedisConnAdmin))
{
RedisConnAdmin = "localhost,abortConnect=false,ssl=false,allowAdmin=true";
}
return ConnectionMultiplexer.Connect(RedisConnAdmin);
});
@@ -224,6 +230,7 @@ namespace MapoDb
string rawData = JsonConvert.SerializeObject(act2save);
// invio broadcast + salvo in redis
BroadastMsgPipe.saveAndSendMessage(Constants.redisActionReq, rawData);
fatto = true;
//await redisDb.StringSetAsync(redisActionReq, rawData);
stopWatch.Stop();
TimeSpan ts = stopWatch.Elapsed;