Aggiunta salvataggio in mongoDB delle risposte nesting (TESTARE!!!)

AppData/ComLib.cs

@@ -1,4 +1,5 @@
-using Newtonsoft.Json;
+using MongoDB.Driver;
+using Newtonsoft.Json;
 using Newtonsoft.Json.Converters;
 using NKC_SDK;
 using SteamWare;
@@ -12,6 +13,75 @@ namespace AppData
   /// </summary>
   public class ComLib
   {
+    /// <summary>
+    /// Database corrente MongoDB
+    /// </summary>
+    IMongoDatabase database;
+    /// <summary>
+    /// Init classe ComLib
+    /// </summary>
+    public ComLib()
+    {
+      database = memLayer.ML.getMongoDatabase("NKC");
+    }
+    /// <summary>
+    /// Classe impiego sstatico ComLib...
+    /// </summary>
+    public static ComLib man = new ComLib();
+
+    /// <summary>
+    /// Salva una risposta ricevuta x STIMA
+    /// </summary>
+    /// <param name="nestAnsw">Stringa della risposta JSON ricevuta dal nesting</param>
+    /// <returns></returns>
+    public bool saveEstAnsw(nestReplyBatchInitial nestAnsw)
+    {
+      bool answ = false;
+      try
+      {
+        var collRawData = database.GetCollection<nestReplyBatchInitial>("EstimationArchive");
+        collRawData.InsertOne(nestAnsw);
+        answ = true;
+      }
+      catch
+      { }
+      return answ;
+    }
+    /// <summary>
+    /// Salva una risposta ricevuta x NESTING
+    /// </summary>
+    /// <param name="nestAnsw">Stringa della risposta JSON ricevuta dal nesting</param>
+    /// <returns></returns>
+    public bool saveNestAnsw(nestReplyBatchFinal nestAnsw)
+    {
+      bool answ = false;
+      try
+      {
+        var collRawData = database.GetCollection<nestReplyBatchFinal>("NestingArchive");
+        collRawData.InsertOne(nestAnsw);
+        answ = true;
+      }
+      catch
+      { }
+      return answ;
+    }
+
+    //public object getEstAnsw(int BatchId)
+    //{
+    //  List<nestReplyBatchFinal> answ = null;
+
+    //  var collNAA = database.GetCollection<nestReplyBatchFinal>("NestAnswArchive");
+    //  // oggetto filtraggio x nest answ
+    //  var builderNAA = Builders<nestReplyBatchFinal>.Filter;
+    //  var filtBatchId = builderNAA.Eq(u => u.BatchID, BatchId);
+
+    //  var datiCorrenti = collNAA.Find(filtBatchId);
+    //  foreach (var item in datiCorrenti)
+    //  {
+
+    //  }
+    //  return answ;
+    //}
 
     /// <summary>
     /// Wrapper traduzione termini

NKC_WF/Controllers/BatchProcController.cs

@@ -133,6 +133,10 @@ namespace NKC_WF.Controllers
               int bStatus = 0;
               // deserializzo come BatchreqIniziale (stima)
               nestReplyBatchInitial rispStima = JsonConvert.DeserializeObject<nestReplyBatchInitial>(content);
+
+              // 2020.01.16 salvo su mongoDb la risposta...
+              ComLib.man.saveEstAnsw(rispStima);
+
               // recupero info sul batch /KIT specifico x capire se sia di tipo "validation"
               bool isValidation = false;
               var tabOrd = DataLayer.man.taOL.getByBatch(rispStima.BatchID);
@@ -222,6 +226,10 @@ namespace NKC_WF.Controllers
             {
               // deserializzo come BatchreqFinale
               nestReplyBatchFinal rispNest = JsonConvert.DeserializeObject<nestReplyBatchFinal>(content);
+
+              // 2020.01.16 salvo su mongoDb la risposta...
+              ComLib.man.saveNestAnsw(rispNest);
+
               // calcolo status del batch...
               int bStatus = 2;
               switch (rispNest.ProcessStatus)

NKC_WF/Web.config

@@ -69,6 +69,8 @@
     <add key="RedisConn" value="nkcredis.steamware.net,abortConnect=false,ssl=false,password=nkc.password"/>
     <add key="RedisConnAdmin" value="nkcredis.steamware.net,abortConnect=false,ssl=false,password=nkc.password,allowAdmin=true"/>
     <add key="redisDb" value="0"/>
+    <!--MongoDB-->
+    <add key="mdbConnString" value="mongodb://W2019-MONGODB:27017"/>
     <!--Configurazioni DB per classi referenziate AppData e Steamware dll-->
     <add key="NKC_WFConnectionString" value="Data Source=SQL2016DEV;Initial Catalog=Sauder_NKC;Persist Security Info=True;User ID=sa;Password=keyhammer16;"/>
     <add key="DbConfConnectionString" value="Data Source=SQL2016DEV;Initial Catalog=Sauder_NKC;Persist Security Info=True;User ID=sa;Password=keyhammer16;"/>