using Microsoft.Extensions.Configuration; using NLog; using System; using System.Collections.Generic; using System.IO; using Microsoft.EntityFrameworkCore; using System.Linq; using System.Text; using System.Threading.Tasks; using MP.FileData.DatabaseModels; namespace MP.FileData.Controllers { public class FileController : IDisposable { #region Private Fields private static IConfiguration _configuration; private static MoonPro_ProgContext dbCtx; private static NLog.Logger Log = LogManager.GetCurrentClassLogger(); #endregion Private Fields #region Public Constructors public FileController(IConfiguration configuration) { _configuration = configuration; dbCtx = new MoonPro_ProgContext(configuration); Log.Info("Avviata classe FileController"); } #endregion Public Constructors #region Public Methods /// /// Elenco tabella Articoli (FILTRATO!!!) /// /// /// /// public List ArtGetFilt(string searchVal, int maxNum = 100) { maxNum = maxNum <= 0 ? 100 : maxNum; List dbResult = new List(); using (MoonPro_ProgContext localDbCtx = new MoonPro_ProgContext(_configuration)) { int totRecord = localDbCtx .DbSetArticoli .Where(x => x.CodArticolo.Contains(searchVal) || x.DescArticolo.Contains(searchVal) || x.Disegno.Contains(searchVal)) .Count(); if (totRecord > maxNum) { dbResult = localDbCtx .DbSetArticoli .Where(x => x.CodArticolo.Contains(searchVal) || x.DescArticolo.Contains(searchVal) || x.Disegno.Contains(searchVal)) .OrderBy(x => x.DescArticolo) .Take(maxNum) .ToList(); dbResult.Add(new DatabaseModels.ArticoloModel() { CodArticolo = "#####", DescArticolo = $"... +{totRecord - maxNum} rec ..." }); } else { dbResult = localDbCtx .DbSetArticoli .Where(x => x.CodArticolo.Contains(searchVal) || x.DescArticolo.Contains(searchVal) || x.Disegno.Contains(searchVal)) .OrderBy(x => x.DescArticolo) .ToList(); } } return dbResult; } /// /// Effettua la comparazione tra i file in archivio ed i file attuali e segna info LastCheck e Changed (se cambiati) /// /// public bool CheckFileArchived(string idxMacchina, string path, string searchPattern) { bool answ = false; DirectoryInfo dirInfo = new DirectoryInfo(path); FileInfo[] fileList = dirInfo.GetFiles(searchPattern); List fileNew = new List(); List fileChecked = new List(); List fileMod = new List(); DateTime adesso = DateTime.Now; // recupera elenco file nel DB var archivedFile = FileGetByPath(path, true); using (System.Security.Cryptography.MD5 md5 = System.Security.Cryptography.MD5.Create()) { // verifica i file foreach (var file in fileList) { // cerca nel DB... FileModel currRecord = archivedFile .Where(x => x.Active && x.Path == file.FullName) .OrderByDescending(y => y.Rev) .FirstOrDefault(); // se NON trova lo crea if (currRecord == null) { fileNew.Add(file); } else { // verifico se data modifica sia cambiata... if (currRecord.LastMod != file.LastWriteTime) { // calcolo e verifico MD5 var fileContent = File.ReadAllBytes(file.FullName); var hash = md5.ComputeHash(fileContent); var newMD5 = BitConverter.ToString(hash).Replace("-", "").ToLowerInvariant(); if (newMD5 != currRecord.MD5) { fileMod.Add(currRecord); } else { fileChecked.Add(currRecord); } } else { fileChecked.Add(currRecord); } } } } // salvo i NUOVI file if (fileNew != null && fileNew.Count > 0) { FileInsert(idxMacchina, fileNew, 0); } // aggiorno i file modificati if (fileMod != null && fileMod.Count > 0) { FileSetUpdated(fileMod); } // segno data-ora ultimo controllo x file invariati if (fileChecked != null && fileChecked.Count > 0) { FileSetChecked(fileChecked); } return answ; } public void Dispose() { // Clear database context dbCtx.Dispose(); } /// /// ELiminazione file da tabella /// /// /// public bool FileDelete(FileModel currItem) { bool done = false; using (MoonPro_ProgContext localDbCtx = new MoonPro_ProgContext(_configuration)) { // eliminazione di uno specifico file + rev da tabella var file2del = localDbCtx .DbSetProgFile .Where(x => x.FileId == currItem.FileId) .FirstOrDefault(); localDbCtx .DbSetProgFile .Remove(file2del); // se ce ne fosse un altro precedente --> lo (ri)attiva var file2open = localDbCtx .DbSetProgFile .Where(x => x.Articolo == currItem.Articolo && x.IdxMacchina == currItem.IdxMacchina) .OrderByDescending(y => y.Rev) .FirstOrDefault(); if (file2open != null) { file2open.Active = true; } // salvo! localDbCtx.SaveChanges(); done = true; } return done; } public bool FileDiskStatusChange(List updFiles, FileState newStatus) { bool done = false; using (MoonPro_ProgContext localDbCtx = new MoonPro_ProgContext(_configuration)) { foreach (var item in updFiles) { item.DiskStatus = newStatus; localDbCtx.Entry(item).State = EntityState.Modified; } localDbCtx.SaveChanges(); done = true; } return done; } public FileModel FileGetByKey(int FileId) { FileModel thisFile = null; using (MoonPro_ProgContext localDbCtx = new MoonPro_ProgContext(_configuration)) { thisFile = localDbCtx .DbSetProgFile .Where(x => x.FileId == FileId) .FirstOrDefault(); } return thisFile; } public List FileGetByPath(string path, bool onlyActive) { List dbResult = new List(); using (MoonPro_ProgContext localDbCtx = new MoonPro_ProgContext(_configuration)) { dbResult = localDbCtx .DbSetProgFile .Where(x => x.Path.StartsWith(path) && ((onlyActive == x.Active) || !onlyActive)) .OrderBy(x => x.Name) .ToList(); } return dbResult; } public List FileGetFilt(string IdxMacchina, string CodArticolo, bool OnlyActive, bool OnlyMod, string SearchVal = "") { List dbResult = new List(); using (MoonPro_ProgContext localDbCtx = new MoonPro_ProgContext(_configuration)) { dbResult = localDbCtx .DbSetProgFile .Include(m => m.Macchina) .Include(a => a.Articolo) .Where(x => (x.IdxMacchina == IdxMacchina || IdxMacchina == "0") && (x.Active == OnlyActive || !OnlyActive) && (!OnlyMod || x.DiskStatus != FileState.Unchanged) && (x.Name.Contains(SearchVal) || string.IsNullOrEmpty(SearchVal))) .OrderByDescending(x => x.LastMod) .ToList(); } return dbResult; } /// /// Effettua inserimento di un elenco di record in archivio come NUOVO documento tracciato /// /// /// /// /// public bool FileInsert(string idxMacchina, List newFiles, int rev) { bool answ = false; DateTime adesso = DateTime.Now; // MD5 hash using (System.Security.Cryptography.MD5 md5 = System.Security.Cryptography.MD5.Create()) { using (MoonPro_ProgContext localDbCtx = new MoonPro_ProgContext(_configuration)) { // converto List newRec = newFiles.Select(o => new DatabaseModels.FileModel() { Active = true, CodArticolo = "ND", DiskStatus = FileState.Unchanged, IdxMacchina = idxMacchina, LastCheck = adesso, LastMod = o.LastWriteTime, MimeType = o.Extension, Name = o.Name, Path = o.FullName, Rev = rev, Size = o.Length, FileContent = File.ReadAllBytes(o.FullName) }).ToList(); // calcolo MD5 foreach (var item in newRec) { var hash = md5.ComputeHash(item.FileContent); item.MD5 = BitConverter.ToString(hash).Replace("-", "").ToLowerInvariant(); } // aggiungo in blocco localDbCtx .DbSetProgFile .AddRange(newRec); // salvo localDbCtx.SaveChanges(); answ = true; } } return answ; } public bool FileModApprove(FileModel currFile) { bool done = false; List listUpdate = new List(); using (MoonPro_ProgContext localDbCtx = new MoonPro_ProgContext(_configuration)) { // rileggo dati file... var newFileInfo = new FileInfo(currFile.Path); listUpdate.Add(newFileInfo); // inserisco come REVISIONE FileInsert(currFile.IdxMacchina, listUpdate, currFile.Rev + 1); // archivio vecchio file currFile.Active = false; currFile.DiskStatus = FileState.Unchanged; localDbCtx.Entry(currFile).State = EntityState.Modified; // salvo DB localDbCtx.SaveChanges(); done = true; } return done; } public bool FileModReject(FileModel currFile) { bool done = false; using (MoonPro_ProgContext localDbCtx = new MoonPro_ProgContext(_configuration)) { // sovrascrivo il file su disco File.WriteAllBytes(currFile.Path, currFile.FileContent); // rileggo file... var newFileInfo = new FileInfo(currFile.Path); // aggiorno stato del file a unchanged e data mod ad ora... currFile.DiskStatus = FileState.Unchanged; currFile.LastMod = newFileInfo.LastWriteTime; // salvo DB localDbCtx.SaveChanges(); done = true; } return done; } /// /// Effettua update di un record in archivio da lista (SOLO STATUS) /// /// /// public bool FileSetChecked(List updFiles) { bool answ = false; DateTime adesso = DateTime.Now; using (MoonPro_ProgContext localDbCtx = new MoonPro_ProgContext(_configuration)) { foreach (var item in updFiles) { item.LastCheck = adesso; localDbCtx.Entry(item).State = EntityState.Modified; } // salvo localDbCtx.SaveChanges(); answ = true; } return answ; } /// /// Effettua update di un record in archivio da lista (SOLO STATUS) /// /// /// public bool FileSetUpdated(List updFiles) { bool answ = false; DateTime adesso = DateTime.Now; using (MoonPro_ProgContext localDbCtx = new MoonPro_ProgContext(_configuration)) { foreach (var item in updFiles) { item.DiskStatus = FileState.Changed; item.LastCheck = adesso; localDbCtx.Entry(item).State = EntityState.Modified; } // salvo localDbCtx.SaveChanges(); answ = true; } return answ; } /// /// Aggiorna un Ordine /// /// /// public bool FileUpdate(FileModel updItem) { bool done = false; using (MoonPro_ProgContext localDbCtx = new MoonPro_ProgContext(_configuration)) { try { FileModel currData = null; currData = dbCtx .DbSetProgFile .Where(x => x.FileId == updItem.FileId) .FirstOrDefault(); if (currData != null) { updItem.DiskStatus = FileState.Changed; localDbCtx.Entry(updItem).State = EntityState.Modified; localDbCtx.SaveChanges(); } else { dbCtx .DbSetProgFile .Add(updItem); dbCtx.SaveChanges(); } done = true; } catch (Exception exc) { Log.Error(exc, "Eccezione durante FileUpdate"); } } return done; } #if false /// /// Elenco Azioni (decodifica) /// /// public List ActionsGetAll() { List dbResult = new List(); dbResult = dbCtx .DbSetAzioniUL .ToList(); return dbResult; } /// /// Elenco tabella Articoli da filtro /// /// /// /// public List ArticoliGetSearch(int numRecord, string searchVal = "") { List dbResult = new List(); dbResult = dbCtx .DbSetArticoli .Where(x => x.CodArticolo.Contains(searchVal) || x.DescArticolo.Contains(searchVal) || x.Disegno.Contains(searchVal) || string.IsNullOrEmpty(searchVal)) .OrderBy(x => x.CodArticolo) .Take(numRecord) .ToList(); return dbResult; } /// /// Elenco tabella Articoli da filtro /// /// /// /// public List CommesseGetSearch(int numRecord, string searchVal = "") { List dbResult = new List(); dbResult = dbCtx .DbSetODL .Where(x => x.KeyRichiesta.Contains(searchVal) || string.IsNullOrEmpty(searchVal)) .OrderBy(x => x.KeyRichiesta) .Take(numRecord) .ToList(); return dbResult; } #endif /// /// Elenco tabella Macchine /// /// public List MacchineGetAll() { List dbResult = new List(); using (MoonPro_ProgContext localDbCtx = new MoonPro_ProgContext(_configuration)) { dbResult = localDbCtx .DbSetMacchine .OrderBy(x => x.IdxMacchina) .ToList(); } return dbResult; } public void ResetController() { dbCtx = new MoonPro_ProgContext(_configuration); Log.Info("Effettuato reset FileController"); } /// /// Annulla modifiche su una specifica entity (cancel update) /// /// /// public bool RollBackEntity(object item) { bool answ = false; try { if (dbCtx.Entry(item).State == Microsoft.EntityFrameworkCore.EntityState.Deleted || dbCtx.Entry(item).State == Microsoft.EntityFrameworkCore.EntityState.Modified) { dbCtx.Entry(item).Reload(); } } catch (Exception exc) { Log.Error($"Eccezione in rollBackEntity{Environment.NewLine}{exc}"); } return answ; } #endregion Public Methods #if false /// /// Elenco tabella controlli da filtro /// /// /// /// public List StatControlliGetAll(DateTime DataStart, DateTime DataEnd, string IdxMacchina, int IdxODL, string KeyRichiesta, string CodArticolo) { List dbResult = new List(); var dataFrom = new SqlParameter("@dataFrom", DataStart); var dataTo = new SqlParameter("@dataTo", DataEnd); var idxMacchina = new SqlParameter("@idxMacchina", IdxMacchina); var idxODL = new SqlParameter("@IdxODL", IdxODL); var keyRichiesta = new SqlParameter("@KeyRichiesta", KeyRichiesta); var codArticolo = new SqlParameter("@CodArticolo", CodArticolo); dbResult = dbCtx .DbSetControlli .FromSqlRaw("EXEC stp_UI_RC_GetByFilter @dataFrom,@dataTo,@idxMacchina,@IdxODL,@KeyRichiesta,@CodArticolo", dataFrom, dataTo, idxMacchina, idxODL, keyRichiesta, codArticolo) .ToList(); return dbResult; } /// /// Elenco tabella DDB da filtro /// /// /// /// /// /// /// /// /// /// public List StatDdbGetAll(DateTime DataStart, DateTime DataEnd, string IdxMacchina, int IdxODL, string KeyRichiesta, string CodArticolo, int FirstRecord, int NumRecord) { List dbResult = new List(); var dataFrom = new SqlParameter("@dataFrom", DataStart); var dataTo = new SqlParameter("@dataTo", DataEnd); var idxMacchina = new SqlParameter("@idxMacchina", IdxMacchina); var idxODL = new SqlParameter("@IdxODL", IdxODL); var keyRichiesta = new SqlParameter("@KeyRichiesta", KeyRichiesta); var codArticolo = new SqlParameter("@CodArticolo", CodArticolo); var firstRecord = new SqlParameter("@FirstRecord", FirstRecord); var numRecord = new SqlParameter("@NumRecord", NumRecord); dbResult = dbCtx .DbSetDdbTurni .FromSqlRaw("EXEC stp_UI_DDBTurni_GetByFilter @dataFrom,@dataTo,@idxMacchina,@IdxODL,@KeyRichiesta,@CodArticolo,@FirstRecord,@NumRecord", dataFrom, dataTo, idxMacchina, idxODL, keyRichiesta, codArticolo, firstRecord, numRecord) .ToList(); return dbResult; } /// /// Elenco tabella DDB da filtro /// /// /// /// /// /// /// /// public int StatDdbGetCount(DateTime DataStart, DateTime DataEnd, string IdxMacchina, int IdxODL, string KeyRichiesta, string CodArticolo) { var dbResult = dbCtx .DbSetDdbTurni .Where(x => (x.IdxMacchina == IdxMacchina || IdxMacchina == "*") && (x.IdxOdl == IdxODL || IdxODL == -999) && (x.KeyRichiesta == KeyRichiesta || KeyRichiesta == "*") && (x.CodArticolo == CodArticolo || CodArticolo == "*") && (x.InizioPeriodo >= DataStart && x.InizioPeriodo <= DataEnd)) .Count(); return dbResult; } /// /// Elenco tabella ODL da filtro /// /// /// /// public List StatOdlGetAll(DateTime DataStart, DateTime DataEnd, string IdxMacchina, int IdxODL, string KeyRichiesta, string CodArticolo) { List dbResult = new List(); var dataFrom = new SqlParameter("@dataFrom", DataStart); var dataTo = new SqlParameter("@dataTo", DataEnd); var idxMacchina = new SqlParameter("@idxMacchina", IdxMacchina); var idxODL = new SqlParameter("@IdxODL", IdxODL); var keyRichiesta = new SqlParameter("@KeyRichiesta", KeyRichiesta); var codArticolo = new SqlParameter("@CodArticolo", CodArticolo); dbResult = dbCtx .DbSetODL .FromSqlRaw("EXEC stp_UI_Odl_GetByFilter @dataFrom,@dataTo,@idxMacchina,@IdxODL,@KeyRichiesta,@CodArticolo", dataFrom, dataTo, idxMacchina, idxODL, keyRichiesta, codArticolo) .ToList(); return dbResult; } /// /// Elenco tabella scarti da filtro /// /// /// /// /// /// public List StatScartiGetAll(DateTime DataStart, DateTime DataEnd, string IdxMacchina, int IdxODL, string KeyRichiesta, string CodArticolo) { List dbResult = new List(); var dataFrom = new SqlParameter("@dataFrom", DataStart); var dataTo = new SqlParameter("@dataTo", DataEnd); var idxMacchina = new SqlParameter("@idxMacchina", IdxMacchina); var idxODL = new SqlParameter("@IdxODL", IdxODL); var keyRichiesta = new SqlParameter("@KeyRichiesta", KeyRichiesta); var codArticolo = new SqlParameter("@CodArticolo", CodArticolo); dbResult = dbCtx .DbSetScarti .FromSqlRaw("EXEC stp_UI_RS_GetByFilter @dataFrom,@dataTo,@idxMacchina,@IdxODL,@KeyRichiesta,@CodArticolo", dataFrom, dataTo, idxMacchina, idxODL, keyRichiesta, codArticolo) .ToList(); return dbResult; } /// /// Elenco tabella TurniOee da filtro /// /// /// /// /// /// public List StatTurniOeeGetAll(DateTime DataStart, DateTime DataEnd, string IdxMacchina, int IdxODL, string KeyRichiesta, string CodArticolo) { List dbResult = new List(); var dataFrom = new SqlParameter("@dataFrom", DataStart); var dataTo = new SqlParameter("@dataTo", DataEnd); var idxMacchina = new SqlParameter("@idxMacchina", IdxMacchina); var idxODL = new SqlParameter("@IdxODL", IdxODL); var keyRichiesta = new SqlParameter("@KeyRichiesta", KeyRichiesta); var codArticolo = new SqlParameter("@CodArticolo", CodArticolo); dbResult = dbCtx .DbSetTurniOee .FromSqlRaw("EXEC stp_UI_TurniOee_GetByFilter @dataFrom,@dataTo,@idxMacchina,@IdxODL,@KeyRichiesta,@CodArticolo", dataFrom, dataTo, idxMacchina, idxODL, keyRichiesta, codArticolo) .ToList(); return dbResult; } /// /// Elenco tabella UserLog da filtro /// /// /// /// public List StatUserLogGetAll(DateTime DataStart, DateTime DataEnd, string IdxMacchina, int IdxODL, string KeyRichiesta, string CodArticolo) { List dbResult = new List(); //dbResult = dbCtx // .DbSetUserLog // .Where(x => x.Valore.Contains(searchVal) || x.Cognome.Contains(searchVal) || x.CodArticolo.Contains(searchVal) || string.IsNullOrEmpty(searchVal)) // .OrderByDescending(x => x.DataOraRif) // .Take(numRecord) // .ToList(); var dataFrom = new SqlParameter("@dataFrom", DataStart); var dataTo = new SqlParameter("@dataTo", DataEnd); var idxMacchina = new SqlParameter("@idxMacchina", IdxMacchina); var idxODL = new SqlParameter("@IdxODL", IdxODL); var keyRichiesta = new SqlParameter("@KeyRichiesta", KeyRichiesta); var codArticolo = new SqlParameter("@CodArticolo", CodArticolo); dbResult = dbCtx .DbSetUserLog .FromSqlRaw("EXEC stp_UI_UL_GetByFilter @dataFrom,@dataTo,@idxMacchina,@IdxODL,@KeyRichiesta,@CodArticolo", dataFrom, dataTo, idxMacchina, idxODL, keyRichiesta, codArticolo) .ToList(); return dbResult; } #endif } }