在 SaveChanges() 中返回字典

Posted 2023-03-31

【中文标题】在 SaveChanges() 中返回字典

【英文标题】：Return Dictionary in SaveChanges()

【发布时间】：2015-07-14 06:30:18

【问题描述】：

我重写了SaveChanges() 方法，以便我可以使用ChangeTracker 来获取实体的修改属性。我需要返回修改后属性的Dictionary<string, string>，以便在我的控制器中调用Audit Service。到目前为止，我的 SaveChanges() 方法如下所示：

public override int SaveChanges()

    var changeInfo = ChangeTracker.Entries()
        .Where(t => t.State == EntityState.Modified)
        .Select(t => new 
            Original = t.OriginalValues.PropertyNames.ToDictionary(pn => pn, pn => t.OriginalValues[pn]),
            Current = t.CurrentValues.PropertyNames.ToDictionary(pn => pn, pn => t.CurrentValues[pn])
        );

    Dictionary<string, string> modifiedProperties = new Dictionary<string, string>();
    foreach (var item in changeInfo)
    
        foreach (var origValue in item.Original)
        
            var currValue = item.Current[origValue.Key];
            if ((origValue.Value != null && currValue != null) && !origValue.Value.Equals(currValue))
            
                modifiedProperties.Add(origValue.Key, string.Format("Old Value: 0, New Value: 1", origValue.Value, currValue));
            
        
    
    return base.SaveChanges();

有没有办法访问我的控制器中的 modifiedProperties 字典，以便我可以将它传递给我的服务？

控制器：

if (validator.IsValid())

    _workRequestRepo.Save(workRequest);
    _auditService.Log(UserId, modelId, "Work Order", "Edit", modifiedProperties);

【问题讨论】：

这里的依赖关系似乎不匹配。听起来它应该去控制器 -> 业务层（审计服务） -> 数据层。你所拥有的是只有控制器知道的东西，任何新的控制器也必须实现相同的逻辑，这不是很干。

我在想它会去控制器 -> 数据层来保存实体，然后如果没有任何问题，它会去控制器 -> 审计服务（域层） -> 数据层来保存审计表。

这会在不应该知道任何内容的层上创建依赖关系。控制者不应该知道它是否应该审计，这是商业决策而不是演示决策。

架构不谈，您能否为您的 DataModel 编写一个扩展方法，该方法返回字典并仍调用 base.SaveChanges()？

您认为我应该从 SaveChanges() 还是在我的存储库中的 Save() 方法中调用审计服务？

【参考方案1】：

您不必返回修改后的属性，您可以在 SaveChanges 方法中处理您的审计程序。这是一个例子：

    public MyContainer(IUserProvider userProvider) 
        _userProvider = userProvider;
    

    public override int SaveChanges() 
        var entities = ChangeTracker.Entries().Where(x => x.Entity is BaseEntity && (x.State == EntityState.Added || x.State == EntityState.Modified));
        if (entities.Any()) 
            User currentUser = _userProvider.GetCurrent();
            if (currentUser == null)
                throw new Exception("Current user is undefined.");
            DateTime time = DateTime.Now;
            foreach (var entity in entities) 
                BaseEntity baseEntity = (BaseEntity)entity.Entity;
                if (entity.State == EntityState.Added) 
                    baseEntity.Created = time;
                    baseEntity.CreatedBy = currentUser;
                
                baseEntity.Modified = time;
                baseEntity.ModifiedBy = currentUser;

                // get and store the changed properties of the entity here
                // ....
                var changeInfo = entities.Select(t => new  Original = t.OriginalValues.PropertyNames.ToDictionary(pn => pn, pn => originalValues[pn]), Current = t.CurrentValues.PropertyNames.ToDictionary(pn => pn, pn => t.CurrentValues[pn]);

            
        

        return base.SaveChanges();
    

【参考方案2】：

使用 IOC，我想你有类似的东西：

（这是假设审核而不是修订）

演示文稿：

public PersonController

  private IPersonBL _personBL;

  public PersonController(IPersonBL personBL)
  
    _personBL = personBL
  

  public ActionResult SavePerson(PersonVM model)
  
     // if ModelState etc etc
     var person = Mapper.Map<Person>(model);
     _personBL.Save(person)
  

业务层

public PersonBL : IPersonBL

  private IAuditService _auditService;
  private IPersonRepo _personRepo;

  public PersonBL(IAuditService auditService,
    IPersonRepo personRepo)
  
    _auditService = auditService;
    _personRepo = personRepo;
  

  public void Save(Person person)
  
    PersonDTO personDTO = Mapper.Map<PersonDTO>(person);
    var result = _personRepo.Save(personDTO);
    if (result.Count > 0)
    
      _auditService.Audit(result);
    
  

数据层

public PersonDL : IPersonDL

  private DbContext _context;

  public PersonDL(DbContext dbContext)
  
    _context = dbContext;
  

  public IDictionary<string, string> Save(PersonDTO person)
  
    var result = new Dictionary<string, string>()

    _context.Persons.Add(person);
    var saveCount = _context.SaveChanges();

    if (saveCount > 0)
    
      // Do Object Tracking
      // Populate result;
    

    return result;
  

【讨论】：

我要试一试。我没有那个业务层，所以我将不得不在我的控制器中添加那个审计调用。我想我必须在SaveChanges 中有ChangeTracker 才能获得修改后的属性。