Complex/Complex.Infrastructure/ComplexDBContext.cs

using Complex.Application;
using Complex.Domain.Commons;
using Complex.Domain.Entities;
using Complex.Infrastructure.Extensions;
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.ChangeTracking;
using Microsoft.EntityFrameworkCore.Metadata;
using Microsoft.EntityFrameworkCore.Metadata.Internal;
using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
using System;
using System.Collections.Generic;
using System.ComponentModel.DataAnnotations;
using System.Linq;
using System.Linq.Expressions;
using System.Reflection.Emit;
using System.Reflection.Metadata;
using System.Text;
using System.Threading.Tasks;

namespace Complex.Infrastructure
{
    public partial class ComplexDBContext : DbContext, IComplexDBContext
    {
        public ComplexDBContext()
        {

        }
        public object? Find(Type entityType, object keyId)
        {
            return base.Find(entityType, keyId);
        }
        public override EntityEntry Add(object entity)
        {
            return base.Add(entity);
        }
        public ComplexDBContext(DbContextOptions<ComplexDBContext> options)
            : base(options)
        {
        }
        protected override void OnModelCreating(ModelBuilder builder)
        {
            foreach (var entityType in builder.Model.GetEntityTypes())
            {
                if (entityType.ClrType.GetCustomAttributes(typeof(AuditableAttribute), true).Length > 0)
                {
                    builder.Entity(entityType.Name).Property<DateTime>("InsertTime").HasDefaultValue(DateTime.Now);
                    builder.Entity(entityType.Name).Property<DateTime?>("UpdateTime");
                    builder.Entity(entityType.Name).Property<DateTime?>("RemoveTime");
                    builder.Entity(entityType.Name).Property<bool>("IsRemoved").HasDefaultValue(false);
                }
            }
            builder.Entity<ComplexEntity>().HasQueryFilter(b => EF.Property<bool>(b, "IsRemoved") == false);
            builder.Entity<Unit>().HasQueryFilter(b => EF.Property<bool>(b, "IsRemoved") == false);
            builder.Entity<UnitCost>().HasQueryFilter(b => EF.Property<bool>(b, "IsRemoved") == false);
            builder.Entity<CostCycle>().HasQueryFilter(b => EF.Property<bool>(b, "IsRemoved") == false);
            //builder.ApplyGlobalFilters<bool>("IsRemoved", false);
            //    var allEntities = modelBuilder.Model.GetEntityTypes();
            //Expression<Func<IMutableEntityType, bool>> filterExpr = bm => (bm.GetProperty("IsRemoved").ToString() == "0");
            //foreach (var entity in builder.Model.GetEntityTypes())
            //{
            //    //if (!entity.ClrType.IsAssignableTo(typeof(BaseEntity)))
            //    //  continue;

            //    if (entity.ClrType.GetCustomAttributes(typeof(AuditableAttribute), true).Length > 0)
            //        entity
            //        //entity.SetQueryFilter(filterExpr);
            //}

        }


        public override int SaveChanges()
        {
            var modifiedEntries = ChangeTracker.Entries()
                .Where(p => p.State == EntityState.Modified ||
                p.State == EntityState.Added ||
                p.State == EntityState.Deleted
                );
            foreach (var item in modifiedEntries)
            {
                var entityType = item.Context.Model.FindEntityType(item.Entity.GetType());
                if (entityType != null)
                {
                    if (entityType.ClrType.GetCustomAttributes(typeof(AuditableAttribute), true).Length == 0)
                        continue;
                    var inserted = entityType.FindProperty("InsertTime");
                    var updated = entityType.FindProperty("UpdateTime");
                    var RemoveTime = entityType.FindProperty("RemoveTime");
                    var IsRemoved = entityType.FindProperty("IsRemoved");
                    if (item.State == EntityState.Added && inserted != null)
                    {
                        item.Property("InsertTime").CurrentValue = DateTime.Now;
                    }
                    if (item.State == EntityState.Modified && updated != null)
                    {
                        item.Property("UpdateTime").CurrentValue = DateTime.Now;
                    }

                    if (item.State == EntityState.Deleted && RemoveTime != null && IsRemoved != null)
                    {
                        item.Property("RemoveTime").CurrentValue = DateTime.Now;
                        item.Property("IsRemoved").CurrentValue = true;
                        item.State = EntityState.Modified;
                    }
                }

            }
            return base.SaveChanges();
        }

        //{
        //    var entries = ChangeTracker
        //        .Entries()
        //        .Where(e =>
        //                e.State == EntityState.Added
        //                || e.State == EntityState.Modified);

        //    foreach (var entityEntry in entries)
        //    {
        //        entityEntry.Property("UpdateTime").CurrentValue = DateTime.Now;

        //        if (entityEntry.State == EntityState.Added)
        //        {
        //            entityEntry.Property("InsertTime").CurrentValue = DateTime.Now;
        //        }
        //    }
        //    entries = ChangeTracker
        //        .Entries()
        //        .Where(e =>
        //                e.State == EntityState.Deleted);

        //    foreach (var entityEntry in entries)
        //    {
        //        entityEntry.State = EntityState.Modified;
        //        entityEntry.Property("RemoveTime").CurrentValue = DateTime.Now;
        //        entityEntry.Property("IsRemoved").CurrentValue = true;
        //    }

        //    return base.SaveChanges();
        //}
        public virtual DbSet<UnitState> UnitStates { get; set; }
        public virtual DbSet<Person> Persons { get; set; }
        public virtual DbSet<ComplexPerson> ComplexPersons { get; set; }
        public virtual DbSet<BasicTable> BasicTables { get; set; }
        public virtual DbSet<Chat> Chats { get; set; }
        public virtual DbSet<ComplexEntity> ComplexEntities { get; set; }
        public virtual DbSet<ComplexManager> ComplexManagers { get; set; }
        public virtual DbSet<ComplexUnitEvent> ComplexUnitEvents { get; set; }
        public virtual DbSet<Poster> Posters { get; set; }
        public virtual DbSet<Transaction> Transactions { get; set; }
        public virtual DbSet<IncomeCostTitle> IncomeCostTitles { get; set; }
        public virtual DbSet<TransactionType> TransactionTypes { get; set; }
        public virtual DbSet<Unit> Units { get; set; }
        public virtual DbSet<CostCycle> CostCycles { get; set; }
        public virtual DbSet<UnitCost> UnitCosts { get; set; }
        public virtual DbSet<UserToken> UserTokens { get; set; }
        public virtual DbSet<SmsCode> SmsCodes { get; set; }

        protected override void ConfigureConventions(ModelConfigurationBuilder builder)
        {

            builder.Properties<DateOnly>()
                .HaveConversion<DateOnlyConverter>()
                .HaveColumnType("date");

            base.ConfigureConventions(builder);

        }
    }
    public class DateOnlyConverter : ValueConverter<DateOnly, DateTime>
    {
        public DateOnlyConverter()
            : base(dateOnly =>
                    dateOnly.ToDateTime(TimeOnly.MinValue),
                dateTime => DateOnly.FromDateTime(dateTime))
        { }
    }
}