egtbeamwall/EgtBEAMWALL.DataLayer/Controllers/ProjController.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using EgtBEAMWALL.DataLayer.DatabaseModels;

namespace EgtBEAMWALL.DataLayer.Controllers
{
    public class ProjController : IDisposable
    {
        #region Private Fields

        private DatabaseContext dbCtx;

        #endregion Private Fields

        #region Public Constructors

        public ProjController()
        {
            // Initialize database context
            dbCtx = new DatabaseContext(Constants.CONNECTION_STRING);
        }

        #endregion Public Constructors

        #region Protected Methods

        /// <summary>
        /// Helper conversione modelli
        /// </summary>
        /// <param name="currProj"></param>
        /// <returns></returns>
        protected Core.ProjFileM coreConv(ProjModel currProj)
        {
            Core.ProjFileM answ = Core.ProjFileM.CreateProjFileM(currProj.ProjId, ProdIdByProdDbId(currProj.ProdDbId), currProj.DtCreated, currProj.DtExported, currProj.ListName, currProj.BTLFileName, currProj.Locked);
            return answ;
        }

        /// <summary>
        /// Get LAST paginated data from DB (DESC ordered)
        /// </summary>
        /// <param name="numRecord"></param>
        /// <returns></returns>
        protected List<ProjModel> GetLastDbModelDesc(int numRecord)
        {
            // se numRecord = 0 --> passo tutti
            if (numRecord == 0)
            {
                numRecord = dbCtx.ProjList.Count();
            }
            // retrieve
            return dbCtx
                .ProjList
                .OrderByDescending(x => x.ProjId)
                .Take(numRecord)
                .ToList();
        }

        /// <summary>
        /// Get ProdId by ProdDbId, 0 se non trovato
        /// </summary>
        /// <param name="ProdDbId"></param>
        /// <returns></returns>
        protected int ProdIdByProdDbId(int? ProdDbId)
        {
            int answ = 0;

            if (ProdDbId != null)
            {
                var prodRecord = dbCtx
                    .ProdList
                    .Where(x => x.ProdDbId == ProdDbId)
                    .SingleOrDefault();

                if (prodRecord != null)
                {
                    answ = prodRecord.ProdId;
                }
            }
            return answ;
        }

        #endregion Protected Methods

        #region Public Methods

        public bool DeleteProj(int ProjId)
        {
            bool done = false;

            var currProj = FindByProjId(ProjId);

            // sel delle BTLParts da proj
            var parts2del = dbCtx
                .BTLPartList
                .Where(x => x.ProjDbId == currProj.ProjDbId);

            try
            {
                // remove from database
                dbCtx.BTLPartList.RemoveRange(parts2del);
                dbCtx.ProjList.Remove(currProj);
                // Commit changes
                dbCtx.SaveChanges();
                done = true;
            }
            catch (Exception exc)
            {
                Console.WriteLine($"EXCEPTION on DeleteProj: {exc}");
            }
            return done;
        }

        public void Dispose()
        {
            // Clear database context
            dbCtx.Dispose();
        }

        /// <summary>
        /// Get record by ProjDbId
        /// </summary>
        /// <param name="ProjDbId"></param>
        /// <returns></returns>
        public ProjModel FindByProjDbId(int ProjDbId)
        {
            ProjModel answ = dbCtx
                .ProjList
                .Where(x => x.ProjDbId == ProjDbId)
                .SingleOrDefault();
            return answ;
        }

        /// <summary>
        /// Get record by ProjId
        /// </summary>
        /// <param name="ProjId"></param>
        /// <returns></returns>
        public ProjModel FindByProjId(int ProjId)
        {
            var answ = dbCtx
               .ProjList
                .Where(x => x.ProjId == ProjId)
                .SingleOrDefault();
            return answ;
        }

        /// <summary>
        /// Get record by ProjId converted
        /// </summary>
        /// <param name="ProjId"></param>
        /// <returns></returns>
        public Core.ProjFileM FindByProjIdConv(int ProjId)
        {
            return coreConv(FindByProjId(ProjId));
        }

        /// <summary>
        /// Get filtered data by ProdId (ASC ordered)
        /// </summary>
        /// <param name="ProdDbId"></param>
        /// <returns></returns>
        public List<ProjModel> GetByProdAsc(int ProdId)
        {
            List<ProjModel> answ = new List<ProjModel>();
            int ProdDbId = 0;
            try
            {
                var currProd = dbCtx
                    .ProdList
                    .Where(x => x.ProdId == ProdId)
                    .FirstOrDefault();
                if (currProd != null)
                {
                    ProdDbId = currProd.ProdDbId;
                }
            }
            catch (Exception exc)
            {
                Console.WriteLine($"EXCEPTION on GetByProdAsc: {exc}");
            }
            // retrieve
            answ = dbCtx
                .ProjList
                .Where(x => x.ProdDbId == ProdDbId)
                .OrderBy(x => x.ProdDbId)
                .ToList();
            return answ;
        }

        /// <summary>
        /// Get filtered data by ProdId (DESC ordered)
        /// </summary>
        /// <param name="ProdDbId"></param>
        /// <returns></returns>
        public List<Core.ProjFileM> GetByProdDesc(int ProdId)
        {
            List<Core.ProjFileM> answ = new List<Core.ProjFileM>();
            int ProdDbId = 0;
            try
            {
                var currProd = dbCtx
                    .ProdList
                    .Where(x => x.ProdId == ProdId)
                    .FirstOrDefault();
                if (currProd != null)
                {
                    ProdDbId = currProd.ProdDbId;
                }
            }
            catch (Exception exc)
            {
                Console.WriteLine($"EXCEPTION on GetByProdAsc: {exc}");
            }
            // retrieve
            var dbRes = dbCtx
                .ProjList
                .Where(x => x.ProdDbId == ProdDbId)
                .OrderByDescending(x => x.ProdDbId)
                .ToList();
            // conversione
            answ = dbRes.Select(x => coreConv(x)).ToList();
            return answ;
        }

        /// <summary>
        /// Elenco progetti
        /// </summary>
        /// <param name="numRecord"></param>
        /// <returns></returns>
        public List<Core.ProjFileM> GetLastDesc(int numRecord)
        {
            List<Core.ProjFileM> answ = new List<Core.ProjFileM>();

            // se numRecord = 0 --> passo tutti
            if (numRecord == 0)
            {
                numRecord = dbCtx.ProjList.Count();
            }
            // retrieve
            var dbRes = dbCtx
                .ProjList
                .OrderByDescending(x => x.ProjId)
                .Take(numRecord)
                .ToList();
            // conversione
            answ = dbRes.Select(x => coreConv(x)).ToList();
            return answ;
        }

        /// <summary>
        /// Fornisce nuovo indice VUOTO da usare (allocando sul DB)
        /// </summary>
        /// <returns></returns>
        public int GetNextIndex()
        {
            int nextId = 0;

            // cerco se ne ho ALMENO 1....
            var numRec = dbCtx.ProjList.Count();
            if (numRec == 0)
            {
                nextId = 1;
            }
            else
            {
                // retrieve ultimo...
                var maxRecord = dbCtx
                    .ProjList
                    .OrderByDescending(x => x.ProjId)
                    .Take(1)
                    .FirstOrDefault();
                // incremento
                nextId = maxRecord.ProjId + 1;
            }

            // creo nuovo...
            var newRec = dbCtx
                .ProjList
                .Add(new ProjModel() { ProjId = nextId, BTLFileName = "", IsNew = true, Locked = true, DtCreated = DateTime.Now });

            // Commit changes
            dbCtx.SaveChanges();

            return nextId;
        }

        /// <summary>
        /// Manage Lock by ProjId (proj & prod)
        /// </summary>
        /// <param name="ProjId">ProjID</param>
        /// <param name="Locked">Stato Lock da impostare</param>
        /// <returns></returns>
        public Core.ProjFileM LockByProjId(int ProjId, bool Locked)
        {
            var currProj = dbCtx
                .ProjList
                .Where(x => x.ProjId == ProjId)
                .SingleOrDefault();
            // aggiorno stato del proj
            currProj.Locked = Locked;

            // seleziono il prod e lo blocco...
            var currProd = dbCtx
                .ProdList
                .Where(x => x.ProdDbId == currProj.ProdDbId)
                .SingleOrDefault();

            if (currProj != null)
            {
                // blocco prod corrente
                currProd.Locked = Locked;

                // ora blocco altri proj del prod...
                var currProjs = dbCtx
                   .ProjList
                   .Where(x => x.ProdDbId == currProd.ProdDbId && x.ProjId != ProjId)
                   .ToList();
                currProjs.ForEach(x => x.Locked = Locked);
            }
            // salvataggio
            dbCtx.SaveChanges();

            return coreConv(currProj);
        }

        /// <summary>
        /// Reimposta come NEW
        /// </summary>
        /// <param name="ProjId">ProjID</param>
        /// <param name="Locked">Stato Lock da impostare</param>
        /// <returns></returns>
        public Core.ProjFileM ResetNew(int ProjId)
        {
            var currProj = dbCtx
                .ProjList
                .Where(x => x.ProjId == ProjId)
                .SingleOrDefault();

            // aggiorno stato
            currProj.IsNew = true;
            dbCtx.SaveChanges();

            return coreConv(currProj);
        }

        /// <summary>
        /// Update single PROJ
        /// </summary>
        /// <param name="updItem"></param>
        /// <returns></returns>
        public bool Update(ProjModel updItem)
        {
            bool done = false;
            var item2update = dbCtx
                .ProjList
                .Where(x => x.ProjDbId == updItem.ProjDbId)
                .SingleOrDefault();
            try
            {
                // update, vers 1...
                dbCtx.Entry(item2update).CurrentValues.SetValues(updItem);

                //// update, vers 2
                //dbCtx.PartList.Remove(item2del);
                //dbCtx.PartList.Add(updItem);

                // Commit changes
                dbCtx.SaveChanges();
                done = true;
            }
            catch
            { }
            return done;
        }

        /// <summary>
        /// Update record su DB x elenco BTLParts
        /// </summary>
        /// <param name="ProjId"></param>
        /// <param name="newBTLFileName"></param>
        /// <returns></returns>
        public ProjModel UpdateBtlParts(int ProjId, List<Core.BTLPartM> BtlPartList)
        {
            var currData = FindByProjId(ProjId);

            // sel delle BTLParts da proj
            var items2del = dbCtx
                .BTLPartList
                .Where(x => x.ProjDbId == currData.ProjDbId);

            // converto le BtlParts
            var items2add = BtlPartList.Select(x => BTLPartController.ConvertFromCore(x, currData.ProjDbId)).ToList();

            try
            {
                // elimino dal DB
                dbCtx.BTLPartList.RemoveRange(items2del);
                // aggiungo le nuove
                dbCtx.BTLPartList.AddRange(items2add);
            }
            catch
            { }

            // aggiorno valore isNew a false
            currData.IsNew = false;

            // Commit changes
            dbCtx.SaveChanges();

            return currData;
        }

        /// <summary>
        ///  Update record su DB x nomeBTL, ListName, ExportDate
        /// </summary>
        /// <param name="ProjId"></param>
        /// <param name="BTLFileName"></param>
        /// <param name="ListName"></param>
        /// <param name="DtExported"></param>
        /// <returns></returns>
        public Core.ProjFileM UpdateInfo(int ProjId, string BTLFileName, string ListName, DateTime DtExported)
        {
            var currData = FindByProjId(ProjId);
            // aggiorno valore BTL
            currData.BTLFileName = BTLFileName;
            currData.DtExported = DtExported;
            currData.ListName = ListName;

            // Commit changes
            dbCtx.SaveChanges();

            return coreConv(currData);
        }

        #endregion Public Methods
    }
}