c# - 如何在不同的方法中执行两个 SQL 命令并在第二个引发异常时回滚

Question

我很难解释这个问题。但也许我可以在这里做得更好。

在我的 4 层架构应用程序中，一个带有仓库管理系统（一个简单的系统）但有很多业务规则的在线商店。

示例 1：

1. Presentation Layer调用Business Layer保存_Product
2. BL.SaveProduct方法调用然后DL.SaveProduct调用DL.DecreaseBalance方法

如果 中发生异常DL.DecreaseBalance，产品将被保存，违反业务规则，如果我不能通过让 DL 处理两个事务来违反 SoC

是否有设计模式或技巧来帮助解决这个问题？

我的 BL 方法

    public static bool CreateProduct(Product Product, out string Message)
    {
        using (TransactionScope transactionScope = new TransactionScope())
        {
            try
            {
                //validate
                if (Product.ValidateNew(out Message))
                {
                    //Check if sufficient balance exists
                    if (ProductBulksBL.BulkHasEnoughBalance(Product.BulkID, 1))
                    {
                        //save
                        ProductsDAL.CreateProduct(Product, out Message);

                            //log
                            ProductCreationLogDTO pLog = new ProductCreationLogDTO();
                            pLog.BulkID = Product.BulkID;
                            pLog.CreatedBy = UsersDAL.GetCurrentUserID();
                            pLog.TimeCreated = DateTime.Now;

                            ProductsDAL.LogCreatedProduct(pLog, out Message);

                                //update bulk balance 
                                ProductBulksDAL.UpdateBulkBalance(Product.BulkID, 1);
                                return true;
                    }
                    else
                    {
                        Message = "This product bulks doesn't have enough balance";
                        return false;
                    }
                }
                else
                {
                    return false;
                }
            }
            catch (TransactionException ex)
            {
                Message = ex.Message;
                transactionScope.Dispose();
                return false;
            }
            finally
            {
                transactionScope.Complete();
                transactionScope.Dispose();
            }
        }
    }

使用相同方法构建的示例 DL 方法

    public static void CreateProduct(Product Product, out string Message)
    {
        using (SqlConnection conn = new SqlConnection(CONNECTION_STRING))
        {
            using (SqlCommand cmd = new SqlCommand("INSERT INTO Products (BulkID, CountryID, CityID, AreaID, Price, [Description], IPBan) VALUES (@BulkID, @CountryID, @CityID, @AreaID, @Price, @Description, @IPBan) ", conn))
            {
                cmd.Parameters.AddWithValue("@BulkID", Product.BulkID);
                cmd.Parameters.AddWithValue("@Price", Product.Price);
                cmd.Parameters.AddWithValue("@Description", Product.Description);
                cmd.Parameters.AddWithValue("@IPBan", Product.IPBan);

                if (Product.Country != null)
                    cmd.Parameters.AddWithValue("@CountryID", Product.Country.ID);
                else
                    cmd.Parameters.AddWithValue("@CountryID", DBNull.Value);

                if (Product.City != null)
                    cmd.Parameters.AddWithValue("@CityID", Product.City.ID);
                else
                    cmd.Parameters.AddWithValue("@CityID", DBNull.Value);

                if (Product.Area != null)
                    cmd.Parameters.AddWithValue("@AreaID", Product.Area.ID);
                else
                    cmd.Parameters.AddWithValue("@AreaID", DBNull.Value);

                    conn.Open();
                    cmd.ExecuteNonQuery();

                    Message = "";
            }
        }
    }

TransactionScope 不工作