From f78fb92d524fdf381cdbc991af46da6a1a742948 Mon Sep 17 00:00:00 2001
From: Samuele Locatelli <samuele@steamware.net>
Date: Wed, 19 Apr 2023 08:49:27 +0200
Subject: [PATCH] Ancora update x metodi accesso e gestione code

---
 .../Controllers/QueueController.cs            | 61 ++++++++++++++++++-
 .../Services/QueueDataService.cs              | 29 +++++++++
 2 files changed, 88 insertions(+), 2 deletions(-)

diff --git a/WebDoorCreator.API/Controllers/QueueController.cs b/WebDoorCreator.API/Controllers/QueueController.cs
index 66901a9..bf04d07 100644
--- a/WebDoorCreator.API/Controllers/QueueController.cs
+++ b/WebDoorCreator.API/Controllers/QueueController.cs
@@ -32,6 +32,7 @@ namespace WebDoorCreator.API.Controllers
             long numQueue = await QDService.NumRequestPending();
             return numQueue;
         }
+
         /// <summary>
         /// Lunghezza coda in fase di processing
         /// </summary>
@@ -43,6 +44,62 @@ namespace WebDoorCreator.API.Controllers
             return numQueue;
         }
 
+        /// <summary>
+        /// Invio elenco messaggi elaborazioni (se ho errori --&gt; messaggi oppure libero)
+        /// </summary>
+        /// <param name="ProcMessageList"></param>
+        /// <returns></returns>
+        [HttpPost("PostProcessingMessage")]
+        public async Task<bool> PostProcessingMessage(Dictionary<string, string> ProcMessageList)
+        {
+            bool answ = false;
+            await Task.Delay(1);
+            return answ;
+        }
+
+        /// <summary>
+        /// Invio elenco risultati elaborazioni (modalità boolean di esecuzione corretta)
+        /// </summary>
+        /// <param name="ProcResultList"></param>
+        /// <returns></returns>
+        [HttpPost("PostProcessingResult")]
+        public async Task<bool> PostProcessingResult(Dictionary<string, bool> ProcResultList)
+        {
+            bool answ = false;
+            //VC19Check answ = new VC19Check()
+            //{
+            //    Result = "KO"
+            //};
+            //var result = await _DataService.InsertCheck(DecodedData, "10.74.82.255");
+            //if (result)
+            //{
+            //    answ = new VC19Check
+            //    {
+            //        DTRecord = DateTime.Now,
+            //        CheckRecorded = true,
+            //        TimbrRecorder = true,
+            //        Result = $"OK, Check Recorded for {DecodedData.nam.fn} {DecodedData.nam.gn} {DecodedData.dob:yyyy.MM.dd}"
+            //    };
+            //}
+            //else
+            //{ }
+            await Task.Delay(1);
+            return answ;
+        }
+
+        /// <summary>
+        /// Invio elenco risultati elaborazioni come elenco di SVG
+        /// </summary>
+        /// <param name="ProcSvgList"></param>
+        /// <returns></returns>
+        [HttpPost("PostProcessingSvg")]
+        public async Task<bool> PostProcessingSvg(Dictionary<string, string> ProcSvgList)
+        {
+            bool answ = false;
+            await Task.Delay(1);
+            return answ;
+        }
+
         /// <summary>
         /// Elenco richieste in stato pending
         /// </summary>
@@ -51,7 +108,7 @@ namespace WebDoorCreator.API.Controllers
         public async Task<Dictionary<string, string>?> ShowPending()
         {
             var actQueue = await QDService.RequestPending();
-            return actQueue;// != null && actQueue.Count > 0 ? actQueue : null;
+            return actQueue;
         }
 
         /// <summary>
@@ -74,7 +131,7 @@ namespace WebDoorCreator.API.Controllers
         [HttpGet("TakeProcessingItems")]
         public async Task<Dictionary<string, string>> TakeProcessingItems(int numItems)
         {
-            var actQueue = await QDService.RequestPending();
+            var actQueue = await QDService.TakeProcessingItems(numItems);
             return actQueue;
         }
 
diff --git a/WebDoorCreator.Data/Services/QueueDataService.cs b/WebDoorCreator.Data/Services/QueueDataService.cs
index 530973d..fbec85f 100644
--- a/WebDoorCreator.Data/Services/QueueDataService.cs
+++ b/WebDoorCreator.Data/Services/QueueDataService.cs
@@ -174,6 +174,7 @@ namespace WebDoorCreator.API.Data
             Log.Debug($"RequestPending | {source} in: {ts.TotalMilliseconds} ms");
             return dictResult;
         }
+
         /// <summary>
         /// Get Queue request processing
         /// </summary>
@@ -202,6 +203,34 @@ namespace WebDoorCreator.API.Data
             return dictResult;
         }
 
+        /// <summary>
+        /// Get Queue request pending, removing from queue and putting on processing queue
+        /// </summary>
+        /// <returns>Dictionary of DoorId, saveVersNumb</returns>
+        public async Task<Dictionary<string, string>> TakeProcessingItems(int numItems)
+        {
+            string source = "REDIS";
+            long numReq = 0;
+            Dictionary<string, string> dictResult = new Dictionary<string, string>();
+            // cerco da cache
+            RedisKey currKey = new RedisKey(Constants.CALC_REQ_PEND);
+            Stopwatch stopWatch = new Stopwatch();
+            stopWatch.Start();
+            numReq = redisDb.HashLength(currKey);
+            if (numReq > 0)
+            {
+                var rawData = await redisDb.HashGetAllAsync(currKey);
+                foreach (var item in rawData)
+                {
+                    dictResult.Add($"{item.Name}", $"{item.Value}");
+                }
+            }
+            stopWatch.Stop();
+            TimeSpan ts = stopWatch.Elapsed;
+            Log.Debug($"TakeProcessingItems | {source} in: {ts.TotalMilliseconds} ms");
+            return dictResult;
+        }
+
         #endregion Public Methods
 
         #region Protected Fields