CurrentUser在.Net核心微业务服务中的应用

Question

命名空间LED.OM.Core.Base

{公共抽象类BaseContext : DbContext {公共BaseContext(DbContextOptions选项)：基(选项){}

    public override int SaveChanges()
    {
        UpdateAuditEntities();
        return base.SaveChanges();
    }

    public override int SaveChanges(bool acceptAllChangesOnSuccess)
    {
        UpdateAuditEntities();
        return base.SaveChanges(acceptAllChangesOnSuccess);
    }

    public override Task<int> SaveChangesAsync(CancellationToken cancellationToken = default)
    {
        UpdateAuditEntities();
        return base.SaveChangesAsync(cancellationToken);
    }

    private void UpdateAuditEntities()
    { 
        var CurrentUser = Thread.CurrentPrincipal?.Identity?.Name ?? "";
        var modifiedEntries = ChangeTracker.Entries()
            .Where(x => x.Entity is Entity &&
                        (x.State == EntityState.Added || x.State == EntityState.Modified || x.State == EntityState.Deleted));



        foreach (var entry in modifiedEntries)
        {

            var entity = (Entity)entry.Entity;
            var now = DateTime.UtcNow;

            if (entry.State == EntityState.Added)
            {
                entity.CreatedDate = now;
                entity.CreatedBy = CurrentUser;
            }
            else if (entry.State == EntityState.Deleted && entry.Entity is not IHardDelete)
            { 
                // Varlığı değiştirilmedi olarak ayarlıyoruz.
                // (tüm varlığı Değiştirildi olarak işaretlersek, her alan güncelleme olarak Db'ye gönderilir)
                entry.State = EntityState.Unchanged;

                // Yalnızca IsDeleted alanını güncelleyin - yalnızca bu Db'ye gönderilir
                entity.IsDelete = true;  
            }
            else
            {
                base.Entry(entity).Property(x => x.CreatedBy).IsModified = false;
                base.Entry(entity).Property(x => x.CreatedDate).IsModified = false;
            }

            entity.UpdatedDate = now;
            entity.UpdatedBy = CurrentUser;
        }
    }


}

}

user.cs

entity.cs

我在做微型服务。实体是我整个表中的公共字段。我想填写那些想要登录的人创建和更新的字段。但是我找不到如何在BaseContext中填写这个用户信息。

Answer 1

问题不在于微服务或CQRS。问题在于实体框架核心。因此，您需要在UpdateAuditEntities()方法中检测修改过的实体，然后可以填充UpdatedDate和UpdatedBy属性。

此外，在创建CreatedDate操作时，此方法已经填充了(EntityState.Added)和CreatedBy属性。

当将entry.Entity转换为LED.OM.Core.Base.Entities.Entity时，可以获得异常。您应该使用此代码检索修改后的条目：var modifiedEntries = ChangeTracker.Entries<LED.OM.Core.Base.Entities.Entity>()...

您应该处理更新的实体(EntityState.Modified)，如下所示：

private void UpdateAuditEntities()
    { 
        var CurrentUser = Thread.CurrentPrincipal?.Identity?.Name ?? "";
        var modifiedEntries = ChangeTracker.Entries<LED.OM.Core.Base.Entities.Entity>()
            .Where(x => x.Entity is Entity &&
                        (x.State == EntityState.Added || x.State == EntityState.Modified || x.State == EntityState.Deleted));



        foreach (var entry in modifiedEntries)
        {

            var entity = (Entity)entry.Entity;
            var now = DateTime.UtcNow;

            if (entry.State == EntityState.Added)
            {
                entity.CreatedDate = now;
                entity.CreatedBy = CurrentUser;
            }
            else if (entry.State == EntityState.Modified)
            {
                entity.UpdatedDate = now;
                entity.UpdatedBy = CurrentUser;
            }
            else if (entry.State == EntityState.Deleted && entry.Entity is not IHardDelete)
            { 
                // Varlığı değiştirilmedi olarak ayarlıyoruz.
                // (tüm varlığı Değiştirildi olarak işaretlersek, her alan güncelleme olarak Db'ye gönderilir)
                entry.State = EntityState.Unchanged;

                // Yalnızca IsDeleted alanını güncelleyin - yalnızca bu Db'ye gönderilir
                entity.IsDelete = true;  
            }
            else
            {
                base.Entry(entity).Property(x => x.CreatedBy).IsModified = false;
                base.Entry(entity).Property(x => x.CreatedDate).IsModified = false;
            }

            entity.UpdatedDate = now;
            entity.UpdatedBy = CurrentUser;
        }
    }