egtbeamwall/EgtBEAMWALL.DataLayer/Controllers/MaterialsController.cs

using EgtBEAMWALL.DataLayer.DatabaseModels;
using EgwProxy.MagMan.DTO;
using NLog;
using System;
using System.Collections.Generic;
using System.Linq;
using static EgtBEAMWALL.DataLayer.Controllers.MaterialsController.SearchResult;

namespace EgtBEAMWALL.DataLayer.Controllers
{
    /// <summary>
    /// Gestione Materiali su DB (= magazzino locale)
    /// </summary>
    public class MaterialsController : IDisposable
    {
        #region Public Constructors

        public MaterialsController()
        {
        }

        #endregion Public Constructors

        #region Public Methods

        /// <summary>
        /// Conversion of DB model class to base class
        /// </summary>
        /// <param name="coreMat"></param>
        /// <returns></returns>
        public static Core.MaterialM ConvToCore(MaterialModel dbRec)
        {
            Core.MaterialM answ = new Core.MaterialM(dbRec.MatId, (double)dbRec.WMm, (double)dbRec.HMm, (double)dbRec.LMm, dbRec.MatCode);
            return answ;
        }

        /// <summary>
        /// Helper conversione a DTO
        /// </summary>
        /// <param name="currRec"></param>
        /// <returns></returns>
        public static MaterialDTO ConvToDto(MaterialModel currRec)
        {
            MaterialDTO answ = new MaterialDTO()
            {
                MatCloudId = currRec.MatCloudId,
                MatLocalId = currRec.MatId,
                MatCode = currRec.MatCode,
                MatDesc = currRec.MatDesc,
                HMm = currRec.HMm,
                LMm = currRec.LMm,
                WMm = currRec.WMm
            };
            return answ;
        }

        /// <summary>
        /// Helper conversione da DTO
        /// </summary>
        /// <param name="currRec"></param>
        /// <returns></returns>
        public static MaterialModel ConvToModel(MaterialDTO currRec)
        {
            MaterialModel answ = new MaterialModel()
            {
                MatCloudId = currRec.MatCloudId,
                MatId = currRec.MatLocalId,
                MatCode = currRec.MatCode,
                MatDesc = currRec.MatDesc,
                HMm = currRec.HMm,
                LMm = currRec.LMm,
                WMm = currRec.WMm
            };
            return answ;
        }

        /// <summary>
        /// Conversion of base class to DB model class
        /// </summary>
        /// <param name="coreRec"></param>
        /// <returns></returns>
        public static MaterialModel ConvToModel(Core.MaterialM coreRec)
        {
            MaterialModel answ = new MaterialModel();
            if (coreRec != null)
            {
                answ = new MaterialModel()
                {
                    MatId = coreRec.nId,
                    MatCode = coreRec.sMaterial,
                    HMm = (decimal)coreRec.dH,
                    LMm = (decimal)coreRec.dL,
                    WMm = (decimal)coreRec.dW,
                };
            }
            return answ;
        }

        /// <summary>
        /// Delete by key
        /// </summary>
        /// <param name="MatId"></param>
        /// <returns></returns>
        public bool DeleteByKey(int MatId)
        {
            bool done = false;
            using (DatabaseContext localDbCtx = new DatabaseContext(DbConfig.CONNECTION_STRING))
            {
                var items2del = localDbCtx
                                    .MaterialsList
                                    .Where(x => x.MatId == MatId);
                try
                {
                    // Add to database
                    localDbCtx.MaterialsList.RemoveRange(items2del);
                    // Commit changes
                    localDbCtx.SaveChanges();
                    done = true;
                }
                catch (Exception exc)
                {
                    Log.Error($"EXCEPTION on Materials.DeleteByKey: {Environment.NewLine}{exc}");
                }
            }
            return done;
        }

        public void Dispose()
        {
        }

        /// <summary>
        /// Get record by Key
        /// </summary>
        /// <param name="MatId"></param>
        /// <returns></returns>
        public Core.MaterialM FindByDbId(int MatId)
        {
            Core.MaterialM result = new Core.MaterialM(0, 0, 0, "NONE");
            var rawData = FindByDbIdModel(MatId);
            if (rawData != null)
            {
                result = ConvToCore(rawData);
            }
            return result;
        }

        /// <summary>
        /// Get record by Key in formato Model
        /// </summary>
        /// <param name="MatId"></param>
        /// <returns></returns>
        public MaterialModel FindByDbIdModel(int MatId)
        {
            MaterialModel result = new MaterialModel();
            using (DatabaseContext localDbCtx = new DatabaseContext(DbConfig.CONNECTION_STRING))
            {
                result = localDbCtx
                                .MaterialsList
                                .Where(x => x.MatId == MatId)
                                .SingleOrDefault();
            }
            return result;
        }

        /// <summary>
        /// Get Material (filtro x MatId) in formato Core
        /// </summary>
        /// <param name="MatCode">se "" restituisce tutti</param>
        /// <returns></returns>
        public List<Core.MaterialM> GetFilt(string MatCode)
        {
            // recupero e converto
            List<Core.MaterialM> result = new List<Core.MaterialM>();
            var rawData = GetFiltModel(MatCode);
            if (rawData != null)
            {
                result = rawData.Select(x => ConvToCore(x)).ToList();
            }
            return result;
        }

        /// <summary>
        /// Get Material (filtro x MatId) in formato Model
        /// </summary>
        /// <param name="MatCode">se "" restituisce tutti</param>
        /// <returns></returns>
        public List<MaterialModel> GetFiltModel(string MatCode)
        {
            List<MaterialModel> result = new List<MaterialModel>();
            // retrieve
            using (DatabaseContext localDbCtx = new DatabaseContext(DbConfig.CONNECTION_STRING))
            {
                result = localDbCtx
                                .MaterialsList
                                .Where(x => string.IsNullOrEmpty(MatCode) || x.MatCode == MatCode)
                                .OrderBy(x => x.MatDesc)
                                .ToList();
            }
            return result;
        }

        /// <summary>
        /// Insert Material record from CoreM if missing or return existing (for Id)
        /// </summary>
        /// <param name="coreItem"></param>
        /// <returns>MatId (existing or new)</returns>
        public int Insert(Core.MaterialM coreItem)
        {
            int newIdx = 0;
            // converto
            MaterialModel updItem = ConvToModel(coreItem);
            newIdx = Insert(updItem);
            return newIdx;
        }

        /// <summary>
        /// Insert Material record
        /// </summary>
        /// <param name="updItem"></param>
        /// <returns>MatId (existing or new)</returns>
        public int Insert(MaterialModel updItem)
        {
            int newIdx = 0;
            using (DatabaseContext localDbCtx = new DatabaseContext(DbConfig.CONNECTION_STRING))
            {
                try
                {
                    var item2update = localDbCtx
                                        .MaterialsList
                                        .Where(x => (updItem.MatId > 0 && x.MatId == updItem.MatId)
                                                 || (updItem.MatCloudId > 0 && x.MatCloudId == updItem.MatCloudId)
                                                 || (x.MatCode == updItem.MatCode && x.WMm == updItem.WMm && x.HMm == updItem.HMm && x.LMm == updItem.LMm))
                                        .SingleOrDefault();

                    if (item2update != null)
                    {
                        newIdx = item2update.MatId;
                    }
                    else
                    {
                        localDbCtx.MaterialsList.Add(updItem);
                        // Commit changes
                        localDbCtx.SaveChanges();
                        newIdx = updItem.MatId;
                    }
                }
                catch (Exception exc)
                {
                    Log.Error($"EXCEPTION on Materials.Insert: {Environment.NewLine}{exc}");
                }
            }
            return newIdx;
        }

        /// <summary>
        /// Get Last RawItem used for Material
        /// </summary>
        /// <param name="updItem"></param>
        /// <returns>Returns 0 if not found</returns>
        public int LastRawItemGet(int MatId)
        {
            int RawItemIdLast = 0;
            using (DatabaseContext localDbCtx = new DatabaseContext(DbConfig.CONNECTION_STRING))
            {
                try
                {
                    var item2update = localDbCtx
                                        .MaterialsList
                                        .Where(x => (MatId > 0 && x.MatId == MatId))
                                        .SingleOrDefault();

                    if (item2update != null)
                    {
                        RawItemIdLast = item2update.RawItemIdLast;
                    }
                }
                catch (Exception exc)
                {
                    Log.Error($"EXCEPTION on Materials.LastRawItemGet: {Environment.NewLine}{exc}");
                }
            }
            return RawItemIdLast;
        }

        /// <summary>
        /// Update Last RawItem used for Material record
        /// </summary>
        /// <param name="MatId">Id locale materiale</param>
        /// <param name="RawItemIdLast">Id del RawItem</param>
        /// <returns>Returns true if updated</returns>
        public bool LastRawItemSet(int MatId, int RawItemIdLast)
        {
            bool done = false;
            using (DatabaseContext localDbCtx = new DatabaseContext(DbConfig.CONNECTION_STRING))
            {
                try
                {
                    var item2update = localDbCtx
                                        .MaterialsList
                                        .Where(x => (MatId > 0 && x.MatId == MatId))
                                        .SingleOrDefault();

                    if (item2update != null)
                    {
                        item2update.RawItemIdLast = RawItemIdLast;
                        localDbCtx.Entry(item2update).State = System.Data.Entity.EntityState.Modified;
                        // Commit changes
                        localDbCtx.SaveChanges();
                        done = true;
                    }
                }
                catch (Exception exc)
                {
                    Log.Error($"EXCEPTION on Materials.LastRawItemSet: {Environment.NewLine}{exc}");
                }
            }
            return done;
        }

        /// <summary>
        /// Restituisce il primo materiale (se esiste) per MatCode (diretto o tramite Alias)
        /// </summary>
        /// <param name="MatCode">Non accetta ""</param>
        /// <returns></returns>
        public SearchResult SearchFilt(string MatCode)
        {
            // init valori esito ricerca + risultato
            TypeFound esito = string.IsNullOrEmpty(MatCode) ? TypeFound.MISSING_CODE : TypeFound.NOT_FOUND;
            List<Core.MaterialM> result = new List<Core.MaterialM>();
            // solo se ho una VERA ricerca x MatCode
            if (!string.IsNullOrEmpty(MatCode))
            {
                // cerco nei materiali
                var rawData = GetFiltModel(MatCode);
                if (rawData != null && rawData.Count > 0)
                {
                    // ...e converto
                    result = rawData.Select(x => ConvToCore(x)).ToList();
                    esito = TypeFound.MATERIAL;
                }
                else
                {
                    // cerco negli alias...
                    using (AliasController aliasDbContr = new AliasController())
                    {
                        var aliasRec = aliasDbContr.FindByDbId(MatCode);
                        if (aliasRec != null)
                        {
                            rawData = GetFiltModel(aliasRec.ValueAlias);
                            if (rawData != null && rawData.Count > 0)
                            {
                                // ...e converto
                                result = rawData.Select(x => ConvToCore(x)).ToList();
                                esito = TypeFound.ALIAS;
                            }
                        }
                    }
                }
            }
            // compongo risposta!
            SearchResult answ = new SearchResult()
            {
                Tipo = esito,
                Result = result
            };
            return answ;
        }

        /// <summary>
        /// Update Material record from CoreM
        /// </summary>
        /// <param name="coreItem"></param>
        /// <returns>Returns 0 if not found</returns>
        public int Update(Core.MaterialM coreItem)
        {
            int newIdx = 0;
            // converto
            MaterialModel updItem = ConvToModel(coreItem);
            newIdx = Update(updItem);
            return newIdx;
        }

        /// <summary>
        /// Update Material record
        /// </summary>
        /// <param name="updItem"></param>
        /// <returns>Returns 0 if not found</returns>
        public int Update(MaterialModel updItem)
        {
            int newIdx = 0;
            using (DatabaseContext localDbCtx = new DatabaseContext(DbConfig.CONNECTION_STRING))
            {
                try
                {
                    var item2update = localDbCtx
                                        .MaterialsList
                                        .Where(x => (updItem.MatId > 0 && x.MatId == updItem.MatId)
                                                 || (updItem.MatCloudId > 0 && x.MatCloudId == updItem.MatCloudId)
                                                 || (x.MatCode == updItem.MatCode && x.WMm == updItem.WMm && x.HMm == updItem.HMm && x.LMm == updItem.LMm))
                                        .SingleOrDefault();

                    if (item2update != null)
                    {
                        //// update, vers 1...
                        //localDbCtx.Entry(item2update).CurrentValues.SetValues(updItem);
                        item2update.MatCloudId = updItem.MatCloudId;
                        item2update.MatDesc = updItem.MatDesc;
                        localDbCtx.Entry(item2update).State = System.Data.Entity.EntityState.Modified;
                        // Commit changes
                        localDbCtx.SaveChanges();
                        newIdx = item2update.MatId;
                    }
                }
                catch (Exception exc)
                {
                    Log.Error($"EXCEPTION on Materials.Update: {Environment.NewLine}{exc}");
                }
            }
            return newIdx;
        }

        /// <summary>
        /// Upsert Material record
        /// </summary>
        /// <param name="updItem"></param>
        /// <returns>MatId (existing or new)</returns>
        public int Upsert(MaterialModel updItem)
        {
            int newIdx = 0;
            using (DatabaseContext localDbCtx = new DatabaseContext(DbConfig.CONNECTION_STRING))
            {
                try
                {
                    var item2update = localDbCtx
                                        .MaterialsList
                                        .Where(x => (updItem.MatId > 0 && x.MatId == updItem.MatId)
                                                 || (updItem.MatCloudId > 0 && x.MatCloudId == updItem.MatCloudId)
                                                 || (x.MatCode == updItem.MatCode && x.WMm == updItem.WMm && x.HMm == updItem.HMm && x.LMm == updItem.LMm))
                                        .SingleOrDefault();

                    if (item2update != null)
                    {
                        //// update, vers 1...
                        //localDbCtx.Entry(item2update).CurrentValues.SetValues(updItem);
                        item2update.MatCloudId = updItem.MatCloudId;
                        item2update.MatDesc = updItem.MatDesc;
                        localDbCtx.Entry(item2update).State = System.Data.Entity.EntityState.Modified;
                        // Commit changes
                        localDbCtx.SaveChanges();
                        newIdx = item2update.MatId;
                    }
                    else
                    {
                        localDbCtx.MaterialsList.Add(updItem);
                        // Commit changes
                        localDbCtx.SaveChanges();
                        newIdx = updItem.MatId;
                    }
                }
                catch (Exception exc)
                {
                    Log.Error($"EXCEPTION on Materials.Insert: {Environment.NewLine}{exc}");
                }
            }
            return newIdx;
        }

        #endregion Public Methods

        #region Public Classes

        /// <summary>
        /// Risultato ricerca materiali
        /// </summary>
        public class SearchResult
        {
            #region Public Enums

            /// <summary>
            /// Enum del risultato della ricerca materiali
            /// </summary>
            public enum TypeFound
            {
                MISSING_CODE = 0,
                NOT_FOUND,
                ALIAS,
                MATERIAL
            }

            #endregion Public Enums

            #region Public Properties

            /// <summary>
            /// Materiali trovati
            /// </summary>
            public List<Core.MaterialM> Result { get; set; } = new List<Core.MaterialM>();

            /// <summary>
            /// Tipologia oggetto trovato
            /// </summary>
            public TypeFound Tipo { get; set; } = TypeFound.MISSING_CODE;

            #endregion Public Properties
        }

        #endregion Public Classes

        #region Private Fields

        /// <summary>
        /// Istanza logger
        /// </summary>
        private NLog.Logger Log = LogManager.GetCurrentClassLogger();

        #endregion Private Fields
    }
}