mapo-mono/MP.MONO.Data/MapoMonoContext.cs

using MP.MONO.Data.DbModels;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Configuration;
using NLog;
using System;
using System.Linq;

namespace MP.MONO.Data
{
    public partial class MapoMonoContext : DbContext
    {
        #region Private Fields

        private static NLog.Logger Log = LogManager.GetCurrentClassLogger();


        #endregion Private Fields

        #region Public Constructors

        public MapoMonoContext()
        {
            //connString = "server=10.74.82.230;port=3306;database=MAPO.MONO;uid=steamware;pwd=Seriate_24068!;sslmode=None;";
        }


        #endregion Public Constructors

        #region Public Properties


        /// <summary>
        /// DbSet elenco Allarmi riconosciuti
        /// </summary>
        public virtual DbSet<AlarmListModel> DbSetAlarmList { get; set; } = null!;

        /// <summary>
        /// DbSet log Allarmi
        /// </summary>
        public virtual DbSet<AlarmLogModel> DbSetAlarmLog { get; set; } = null!;

        /// <summary>
        /// DbSet elenco Allarmi registrati
        /// </summary>
        public virtual DbSet<AlarmRecModel> DbSetAlarmRec { get; set; } = null!;

        /// <summary>
        /// DbSet valori formato AKV
        /// </summary>
        public virtual DbSet<AnKeyValModel> DbSetKeyVal { get; set; } = null!;
        /// <summary>
        /// DbSet configurazioni su DB
        /// </summary>
        public virtual DbSet<ConfigModel> DbSetConfig { get; set; } = null!;
        /// <summary>
        /// DbSet Macchine
        /// </summary>
        public virtual DbSet<MachineModel> DbSetMachine { get; set; } = null!;
        /// <summary>
        /// DbSet valori dati registrati
        /// </summary>
        public virtual DbSet<DataLogModel> DbSetDataLog { get; set; } = null!;
        /// <summary>
        /// DbSet valori statistiche dati registrati
        /// </summary>
        public virtual DbSet<DataStAgModel> DbSetDataStAg { get; set; } = null!;
        /// <summary>
        /// DbSet tipi di eventi
        /// </summary>
        public virtual DbSet<EventModel> DbSetCodEvent { get; set; } = null!;

        /// <summary>
        /// DbSet elenco eventi registrati
        /// </summary>
        public virtual DbSet<EventLogModel> DbSetEventLog { get; set; } = null!;
        /// <summary>
        /// DbSet tipi di stati
        /// </summary>
        public virtual DbSet<StatusModel> DbSetCodStatus { get; set; } = null!;

        /// <summary>
        /// DbSet elenco stati registrati
        /// </summary>
        public virtual DbSet<StatusLogModel> DbSetStatusLog { get; set; } = null!;

        /// <summary>
        /// DbSet elenco stati formato statistiche aggregate
        /// </summary>
        public virtual DbSet<StatusStAgModel> DbSetStatusStAg { get; set; } = null!;

        /// <summary>
        /// DbSet log eventi produzione
        /// </summary>
        public virtual DbSet<ProdLogModel> DbSetProdLog { get; set; } = null!;

        /// <summary>
        /// DbSet contatori definiti x Prev Maint
        /// </summary>
        public virtual DbSet<CounterModel> DbSetCounter { get; set; } = null!;

        /// <summary>
        /// DbSet User Team definiti x Prev Maint
        /// </summary>
        public virtual DbSet<PMUTModel> DbSetUTeam { get; set; } = null!;

        /// <summary>
        /// DbSet Topics x Prev Maint
        /// </summary>
        public virtual DbSet<PMTaskTopicModel> DbSetPMTopic { get; set; } = null!;

        /// <summary>
        /// DbSet MachineGroup x Prev Maint
        /// </summary>
        public virtual DbSet<PMMGroupModel> DbSetPMMachGroup { get; set; } = null!;

        /// <summary>
        /// DbSet Task di Prev Maint definiti
        /// </summary>
        public virtual DbSet<PrevMaintTaskModel> DbSetPMTask { get; set; } = null!;

        /// <summary>
        /// DbSet Task schedualti
        /// </summary>
        public virtual DbSet<PendingMaintModel> DbSetSMTask { get; set; } = null!;

        /// <summary>
        /// DbSet Pareto Status giornaliero
        /// </summary>
        /// 
        public virtual DbSet<ParetoStatusModel> DbSetParetoStatus { get; set; } = null!;

        /// <summary>
        /// DbSet esecuzione task manutenzione DB
        /// </summary>
        public virtual DbSet<TaskExecModel> DbSetTaskExec { get; set; } = null!;

        #endregion Public Properties

        #region Private Methods

        partial void OnModelCreatingPartial(ModelBuilder modelBuilder);

        #endregion Private Methods

        #region Protected Methods

        protected string connString = "";
        protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
        {
            // tento setup da config
            try
            {
                // uso conn string calcolata
                connString = DbConfig.CONNECTION_STRING;
            }
            catch
            { }
            if (string.IsNullOrEmpty(connString))
            {
                // to fix in case of migrations
                connString = "server=10.74.82.230; port=3306; database=MAPO.MONO;uid=steamware; pwd=Seriate_24068!; sslmode=None;";
            }
            if (!optionsBuilder.IsConfigured)
            {
                var serverVersion = ServerVersion.AutoDetect(connString);
                optionsBuilder.UseMySql(connString, serverVersion, options => options.EnableRetryOnFailure(
                   maxRetryCount: 5,
                   maxRetryDelay: TimeSpan.FromSeconds(10),
                   errorNumbersToAdd: null)
                );
            }
        }

        protected override void OnModelCreating(ModelBuilder modelBuilder)
        {
            foreach (var relationship in modelBuilder.Model.GetEntityTypes().SelectMany(e => e.GetForeignKeys()))
            {
                relationship.DeleteBehavior = DeleteBehavior.Restrict;
            }

            modelBuilder.Entity<ParetoStatusModel>().ToView("v_ParetoStatus");

            //modelBuilder.Entity<ConfigModel>(entity =>
            //{
            //    entity.Property(e => e.ValStd)
            //        .HasComment("Valore di default/riferimento per la variabile");
            //});

            //modelBuilder.Entity<ListValModel>().HasKey(c => new { c.TabName, c.FieldName, c.Val });

            //modelBuilder.Entity<PlantStatusModel>().HasKey(c => new { c.PlantId, c.FluxType });

            //modelBuilder.Entity<ParamSendModel>().HasKey(c => new { c.PlantId, c.ParamUid });

            //modelBuilder.Entity<DataLogModel>()
            //    .HasIndex("DtRif");

            modelBuilder.Seed();

            OnModelCreatingPartial(modelBuilder);
        }

        #endregion Protected Methods

        #region Public Methods

        public void DbForceMigrate()
        {
            try
            {
                // se non ci fosse... crea o migra!
                Database.Migrate();
                Log.Info("DbForceMigrate: done!");
            }
            catch (Exception exc)
            {
                Log.Error(exc, "DbForceMigrate: Exception during context initialization 01");
            }
        }

        #endregion Public Methods
    }
}