NKC/NKC_WF/OrderManager.aspx.cs

using AppData;
using SteamWare;
using System;
using System.Collections.Generic;
using System.Web.UI;

namespace NKC_WF
{
  public partial class OrderManager : BasePage
  {
    /// <summary>
    /// Folder REMOTA x copia verso SQL
    /// </summary>
    protected string _SqlCopyDir = memLayer.ML.CRS("_SqlCopyDir");
    /// <summary>
    /// Folder x SQL import
    /// </summary>
    protected string _SqlImportDir = memLayer.ML.CRS("_SqlImportDir");
    /// <summary>
    /// Path base x nesting
    /// </summary>
    protected string cadBaseBath = memLayer.ML.CRS("cadBaseBath");
    /// <summary>
    /// Path base x server
    /// </summary>
    protected string srvCadBaseBath = memLayer.ML.CRS("srvCadBaseBath");

    protected void Page_Load(object sender, EventArgs e)
    {
      if (!Page.IsPostBack)
      {
        doUpdate();
      }
      cmp_batchList.eh_doRefresh += Cmp_batchList_eh_doRefresh;
      cmp_fileUpload.eh_doRefresh += Cmp_fileUpload_eh_doRefresh;
      cmp_fileUpload.eh_FileUploaded += Cmp_fileUpload_eh_FileUploaded;
    }
    /// <summary>
    /// Ora continuo processing
    /// </summary>
    /// <param name="sender"></param>
    /// <param name="e"></param>
    private void Cmp_fileUpload_eh_FileUploaded(object sender, WebUserContols.FileUploadEventArgs e)
    {

      /*--------------------------------------------
       * Note validazione:
       * - leggo cSV
       * - carico su DB
       * - verifico (coem ora x DXF) TTTI i aprticolari
       * - cerco su tab ItemValidation
       *   --> NON TROVATO --> creo record IV + record Batch stato 8, con KitID = OrdID = 0, DA VALUTARE!!!
       *    - se valutazione tempo <= 1 sec --> NON VALIDO
       *    - se valutazione tempo > 1 sec --> VALIDO
       *    
       *   --> trovato
       *    - se valido --> check DXF, 
       *      --> dxf ok --> finito
       *      --> dxf non trovato --> NON VALIDO, segnalo errore su part
       *    - se NON valido --> segnalo errore su part
       * 
       *--------------------------------------------*/

      // valutare cambio 9/10 x OK/KO (in modo che 8-9 sono NON ok, 10 è OK... --> su DB e su classe enum...

      bool dataValidated = true;
      DateTime adesso = DateTime.Now;
      string dirFrom = e.LocalPath;
      string dirTo = $"{_SqlCopyDir}{adesso.ToString("yyyy-MM")}\\";
      string dirImport = $"{_SqlImportDir}{adesso.ToString("yyyy-MM")}\\";
      int batchID = 0;
      // recupero elenco parti validate...
      DS_App.ItemListDataTable ItemValitadion = DataLayer.man.taIL.GetData();
      // preporcessing file: leggo e correggo:
      // - sostituisco "," --> ";" come separatore
      // - tolgo "" e spazi da stringa
      string[] rawLines = System.IO.File.ReadAllLines($"{e.LocalPath}{e.FileName}");
      string[] fixLines = new string[rawLines.Length];
      int numRow = 0;
      foreach (var riga in rawLines)
      {
        string newLine = "";
        // splitto con "
        string[] rowPart = riga.Split('"');
        int i = 0;
        foreach (var parte in rowPart)
        {
          if (i % 2 == 0)
          {
            // pari --> sostituisco , --> ;
            newLine += parte.Replace(",", ";");
          }
          else
          {
            // dispari: trimmo
            newLine += parte.Trim();
          }
          i++;
        }
        // ricombino!
        fixLines[numRow] = newLine;
        numRow++;
        // cerco codice ITEM...
        string[] rawData = newLine.Split(';');
        if (rawData.Length > 8)
        {
          string currItemExtCode = rawData[7];
          try
          {
            //cerco nell'elenco
            var rigaIV = ItemValitadion.Select($"ItemExtCode = {currItemExtCode}");
            if (rigaIV == null)
            {
              // inserisco OfflineOrder

              // inserisco Item

              // inserisco OfflineOrder2Item




            }
          }
          catch
          { }
        }
      }
      // salvo NUOVO file...
      System.IO.File.WriteAllLines($"{e.LocalPath}{e.FileName}", fixLines);

      // copio su server SQL
      try
      {
        // copio su SQL...
        fileMover.obj.copiaFile(dirFrom, dirTo, e.FileName);
      }
      catch (Exception exc)
      {
        logger.lg.scriviLog($"Eccezione in Copia SQL file:{Environment.NewLine}{exc}");
        DataLayer.man.taEL.insertQuery(DateTime.Now, "Copy CSV", $"{e.BatchName}", $"{e.BatchName}.{e.FileName}", $"Exception: {exc}");
      }
      // chiamo stored caricamento
      DS_App.ImportLogDataTable tabDati = null;
      try
      {
        // chiamo procedura SQL x import... 
        tabDati = DataLayer.man.taImpLog.importCsvOrd($"{dirImport}", e.FileName, e.BatchName, ";", "\n", "2", 0, 0, 0);
      }
      catch (Exception exc)
      {
        logger.lg.scriviLog($"Eccezione in IMPORT file:{Environment.NewLine}{exc}");
        // salvo log errore...
        DataLayer.man.taEL.insertQuery(DateTime.Now, "Upload CSV", $"{e.BatchName}", $"{e.BatchName}.{e.FileName}", $"Exception: {exc}");
        dataValidated = false;
      }
      // recupero da batch la riga impostata...
      try
      {
        var tabBatch = DataLayer.man.taBL.getLastByTakt(e.BatchName);
        if (tabBatch != null)
        {
          if (tabBatch.Count > 0)
          {
            batchID = tabBatch[0].BatchID;
          }
        }
      }
      catch (Exception exc)
      {
        logger.lg.scriviLog($"Eccezione in verifica file:{Environment.NewLine}{exc}");
        dataValidated = false;
      }
      if (dataValidated && batchID > 0)
      {
        dataValidated = doValidations(batchID);
      }
      if (!dataValidated)
      {
        var newBatch = tabDati[0];
        int bStatus = 7;
        DataLayer.man.taBL.updateStatus(batchID, bStatus, e.BatchName, -1);
      }
      doUpdate();
    }
    /// <summary>
    /// Effettua validazione dati
    /// </summary>
    private bool doValidations(int batchID)
    {
      bool allOk = true;
      List<string> missingDxfList = new List<string>();
      // faccio un ciclo su OGNI record Part --> cerco se mancassero dei file dxf...
      try
      {
        var tabParts = DataLayer.man.taIL.getByBatch(batchID);
        if (tabParts.Count > 0)
        {
          bool fileOk = false;
          string localPath = "";
          foreach (var item in tabParts)
          {
            // verifico SE già processato...
            if (!missingDxfList.Contains(item.ItemExtCode))
            {
              // cerco file! sostituisco cadBaseBath --> srvCadBaseBath
              if (string.IsNullOrEmpty(item.CadFilePath))
              {
                localPath = $"{srvCadBaseBath}{item.ItemExtCode}.dxf";
              }
              else
              {
                localPath = item.CadFilePath.Replace(cadBaseBath, srvCadBaseBath);
              }
              // verifico
              fileOk = System.IO.File.Exists(localPath);
              if (!fileOk)
              {
                DataLayer.man.taEL.insertQuery(DateTime.Now, "I.1", $"B.{batchID}", $"{item.ItemExtCode}.dxf", $"DXF File not found for part {item.ItemExtCode} on {srvCadBaseBath} | {item.ItemDesc}");
                allOk = false;
                missingDxfList.Add(item.ItemExtCode);
              }
            }
          }
        }
      }
      catch
      { }
      // cerco errori preesistenti
      return allOk;
    }

    private void Cmp_fileUpload_eh_doRefresh(object sender, EventArgs e)
    {
      doUpdate();
    }

    private void Cmp_batchList_eh_doRefresh(object sender, EventArgs e)
    {
      doUpdate();
    }
    /// <summary>
    /// Update interfaccia
    /// </summary>
    public void doUpdate()
    {
      cmp_batchList.doUpdate();
    }

  }
}