ASP.NET Core 6 MVC多服务调用的事务回滚与创建验证问题

针对你提到的两个问题，核心解决方案是利用EF Core的数据库事务，确保Advertiser、Contact、Address的创建操作要么全部成功，要么全部回滚，从根源上解决依赖顺序和回滚问题。

核心思路 #

你当前的问题源于每个服务单独调用await _db.SaveChangesAsync()，导致操作分散、无原子性。正确的做法是将所有实体的变更操作纳入同一个事务，统一提交或回滚。

具体实现方案 #

方案一：隐式事务（推荐，代码简洁） #

EF Core会自动为同一DbContext实例下的多次实体变更开启事务，只需将所有实体添加到上下文后，只调用一次SaveChangesAsync()，就能保证操作的原子性。

示例代码：

[HttpPost]
public async Task<IActionResult> CreateAdvertiser(AdvertiserCreateViewModel model)
{
    if (!ModelState.IsValid)
        return View(model);

    // 1. 创建并添加Address到上下文
    var address = new Address
    {
        Street = model.Street,
        City = model.City
        // 填充其他属性
    };
    _db.Addresses.Add(address);

    // 2. 创建并添加Contact到上下文
    var contact = new Contact
    {
        Name = model.ContactName,
        Email = model.ContactEmail
        // 填充其他属性
    };
    _db.Contacts.Add(contact);

    // 3. 创建Advertiser并关联已添加的Address和Contact
    var advertiser = new Advertiser
    {
        Name = model.AdvertiserName,
        AddressId = address.Id, // EF Core会自动维护临时ID，提交时替换为真实数据库ID
        ContactId = contact.Id
        // 填充其他属性
    };
    _db.Advertisers.Add(advertiser);

    try
    {
        // 统一提交所有变更，EF自动开启事务
        await _db.SaveChangesAsync();
        return RedirectToAction(nameof(Index));
    }
    catch (Exception ex)
    {
        // 记录异常日志
        ModelState.AddModelError(string.Empty, "创建广告商失败，请重试");
        return View(model);
    }
}

说明：EF Core的变更跟踪会管理未提交实体的临时ID，提交时会按外键依赖顺序先插入Address、Contact，获取真实ID后再插入Advertiser，整个过程在同一事务中，任一环节失败则全部回滚。

方案二：显式事务（适合复杂业务场景） #

如果业务逻辑分散在多个服务中，可手动开启事务，控制提交和回滚时机。注意：所有服务必须共享同一DbContext实例，且服务内部不能单独调用SaveChangesAsync()。

示例代码：

[HttpPost]
public async Task<IActionResult> CreateAdvertiser(AdvertiserCreateViewModel model)
{
    if (!ModelState.IsValid)
        return View(model);

    // 手动开启事务
    using var transaction = await _db.Database.BeginTransactionAsync();

    try
    {
        // 调用服务创建Address（仅添加到上下文，不提交）
        var address = await _addressService.CreateAddressAsync(model);
        // 调用服务创建Contact（仅添加到上下文，不提交）
        var contact = await _contactService.CreateContactAsync(model);
        // 调用服务创建Advertiser（关联Address和Contact，仅添加到上下文）
        await _advertiserService.CreateAdvertiserAsync(model, address.Id, contact.Id);

        // 提交事务，统一保存所有变更
        await transaction.CommitAsync();
        return RedirectToAction(nameof(Index));
    }
    catch (Exception ex)
    {
        // 回滚事务，撤销所有未提交的变更
        await transaction.RollbackAsync();
        // 记录异常日志
        ModelState.AddModelError(string.Empty, "创建广告商失败，请重试");
        return View(model);
    }
}

服务层示例（以AddressService为例）：

public class AddressService : IAddressService
{
    private readonly AppDbContext _db;

    public AddressService(AppDbContext db)
    {
        _db = db;
    }

    public async Task<Address> CreateAddressAsync(AdvertiserCreateViewModel model)
    {
        var address = new Address
        {
            Street = model.Street,
            City = model.City
        };
        _db.Addresses.Add(address);
        // 不调用SaveChangesAsync，由控制器统一提交
        return address;
    }
}

关键注意事项 #

• 共享DbContext实例：确保DbContext的依赖注入生命周期为Scoped（ASP.NET Core默认配置），同一请求中所有服务使用同一个上下文实例。
• 禁止服务单独提交：服务方法仅负责实体的添加/修改，不要调用SaveChangesAsync()，否则会破坏事务原子性。
• 异常覆盖全面：所有可能抛出异常的操作需包裹在try-catch中，确保异常触发时能执行回滚。

内容的提问来源于stack exchange，提问作者Jesus