diff --git a/WebDoorCreator.API/Controllers/QueueController.cs b/WebDoorCreator.API/Controllers/QueueController.cs index 2234c51..9a7250f 100644 --- a/WebDoorCreator.API/Controllers/QueueController.cs +++ b/WebDoorCreator.API/Controllers/QueueController.cs @@ -99,8 +99,8 @@ namespace WebDoorCreator.API.Controllers * - server record x cancellazione logica delle porte OK * - il record (boolean, toDelete...) indica azione richiesta OK * - si prendono TUTTE le porte da DB con toDelete == true OK - * - si eliminano su REDIS dalle 4 code (req, processing, error, done) - * - check delle code processing, SE ci sono record rimasti li cerco sul DB + * - si eliminano su REDIS dalle 4 code (req, processing, error, done) OK + * - check delle code processing, SE ci sono record rimasti li cerco sul DB * - se NON ci sono sul db --> li elimino da processing * - effettivo delete sul db di toDelete * @@ -113,12 +113,16 @@ namespace WebDoorCreator.API.Controllers { foreach (var item in doors2Del) { - - //RedisValue pattern = new RedisValue($"{Core.Constants.rKeyDoor}:{item.DoorId}"); + //RedisValue pattern = new RedisValue($"{Core.Constants.}"); await WDService.FlushCustomPattern($"Cache:Door:{item.DoorId}"); await WDService.FlushCustomPattern($"CalcRequests:CacheDDF:{item.DoorId}"); await WDService.FlushCustomPattern($"CalcRequests:CacheSVG:{item.DoorId}"); await WDService.FlushCustomPattern($"CalcRequests:Errors:{item.DoorId}"); + await QDataServ.DoorRefreshRemove($"{item.DoorId}"); + await QDataServ.RequestDoneRemove($"{item.DoorId}"); + await QDataServ.RequestErrRemove($"{item.DoorId}"); + await QDataServ.RequestPendingRemove($"{item.DoorId}"); + await QDataServ.RequestProcessingRemove($"{item.DoorId}"); } }