Update MTC e SHelly x track dati da pacchetti raw ricevuti

IOB-WIN-FORM/Iob/Generic.Protected.cs

@@ -3614,6 +3614,26 @@ namespace IOB_WIN_FORM.Iob
             }
         }
 
+
+        /// <summary>
+        /// Track dati ricevuti generici (serializzando)
+        /// </summary>
+        /// <param name="genObj"></param>
+        protected void trackExchDataRaw(object genObj, long val2rec = 256)
+        {
+            try
+            {
+                // salvo indicazione valore ricevuto
+                string rawVal = JsonConvert.SerializeObject(genObj);
+                // salvo dim caratteri ricevuti
+                trackExchData(rawVal.Length, val2rec);
+            }
+            catch (Exception exc)
+            {
+                lgError($"trackExchDataRaw | errore in fase di track obj ricevuto{Environment.NewLine}{exc}");
+            }
+        }
+
         /// <summary>
         /// Accumulatore counter byte x inviare meno record in REDIS
         /// </summary>

IOB-WIN-MTC/Iob/MTConn.cs

@@ -1,6 +1,7 @@
 using IOB_UT_NEXT;
 using IOB_UT_NEXT.Config;
 using MapoSDK;
+using MTConnect.Assets;
 using MTConnect.Clients;
 using MTConnect.Devices;
 using MTConnect.Observations;
@@ -16,6 +17,7 @@ using System.Threading;
 using System.Threading.Tasks;
 using System.Windows.Forms;
 using System.Xml.Linq;
+using static System.Windows.Forms.VisualStyles.VisualStyleElement;
 
 namespace IOB_WIN_MTC.Iob
 {
@@ -1028,6 +1030,7 @@ namespace IOB_WIN_MTC.Iob
                             {
                                 processObservation(observation, forceSend);
                             }
+
                         }
                     }
                 }
@@ -1559,11 +1562,17 @@ namespace IOB_WIN_MTC.Iob
             queueInEnabCurr = true;
             connectionOk = true;
             lastCurrent = DateTime.Now;
+            int docSize = 0;
+            string rawVal = "";
             foreach (var asset in doc.Assets)
             {
                 // Print AssetId to the Console
                 lgInfo($"Asset: {asset.AssetId}");
+                rawVal = JsonConvert.SerializeObject(asset);
+                docSize += rawVal.Length;
             }
+            // salvo dim caratteri ricevuti
+            trackExchData(docSize, 1024);
         }
 
         private void MTC_ref_ClientStarted(object sender, EventArgs e)
@@ -1685,6 +1694,8 @@ namespace IOB_WIN_MTC.Iob
                 {
                     lgInfo($"STEP 03 invio dati di {elencoDataItems.Count} records");
                     sendDataItemsList(elencoDataItems);
+                    // provoa a tracciare dataitems...
+                    trackExchDataRaw(elencoDataItems, 1024);
                 }
                 hasReadItems = true;
                 lgInfo($"STEP 04: memorizzati {dataItemMem.Count} oggetti in memoria");
@@ -1705,6 +1716,7 @@ namespace IOB_WIN_MTC.Iob
             lastCurrent = DateTime.Now;
             lgTrace("SAMPLE received");
             checkAndSend(document, false);
+            trackExchDataRaw(document, 1024);
         }
 
         /// <summary>
@@ -1865,6 +1877,7 @@ namespace IOB_WIN_MTC.Iob
                 }
             }
             lgTrace(sMsg);
+            trackExchDataRaw(observ, 1024);
         }
 
         /// <summary>
@@ -1892,6 +1905,7 @@ namespace IOB_WIN_MTC.Iob
                 }
             }
             lgTrace(sMsg);
+            trackExchDataRaw(observation, 1024);
         }
 
         #endregion Private Methods

IOB-WIN-SHELLY/Iob/ShellyClient.cs

@@ -124,6 +124,8 @@ namespace IOB_WIN_SHELLY.Iob
                         //outData.Add(item.Key, outValDbl.ToString("F3", CultureInfo.InvariantCulture));
                     }
                 }
+                // traccio dati ricevuti
+                trackExchDataRaw(lastShellyResp, 1024);
             }
             return outData;
         }