如果 API 调用失败，我如何使事务回滚，反之亦然？

Question

我想要两件事：

a) 我希望只有在 API 调用成功时才能在数据库中保存记录

b) 我只想在 db 记录保存成功的情况下执行 API 调用

目标是使本地（数据库中）存储的数据与 Stripe 上的数据保持一致。

@payment = Payment.new(...)

begin
  Payment.transaction do
    @payment.save!

    stripe_customer = Stripe::Customer.retrieve(manager.customer_id)

    charge = Stripe::Charge.create(
      amount:   @plan.amount_in_cents,
      currency: 'usd',
      customer: stripe_customer.id
    )
  end
# https://stripe.com/docs/api#errors
rescue Stripe::CardError, Stripe::InvalidRequestError, Stripe::APIError => error
  @payment.errors.add :base, 'There was a problem processing your credit card. Please try again.'
  render :new
rescue => error
  render :new
else
  redirect_to dashboard_root_path, notice: 'Thank you. Your payment is being processed.'
end

上面的下面会起作用，因为如果记录（第 5 行）没有保存，其余的代码就不会执行。

但是如果我需要在 API 调用后保存 @payment 对象怎么办，因为我需要为 @payment 对象分配 API 结果中的值。举个例子：

@payment = Payment.new(...)

begin
  Payment.transaction do
    stripe_customer = Stripe::Customer.retrieve(manager.customer_id)

    charge = Stripe::Charge.create(
      amount:   @plan.amount_in_cents,
      currency: 'usd',
      customer: stripe_customer.id
    )

    @payment.payment_id = charge[:id]

    @payment.activated_at = Time.now.utc
    @payment.save!
  end
# https://stripe.com/docs/api#errors
rescue Stripe::CardError, Stripe::InvalidRequestError, Stripe::APIError => error
  @payment.errors.add :base, 'There was a problem processing your credit card. Please try again.'
  render :new
rescue => error
  render :new
else
  redirect_to dashboard_root_path, notice: 'Thank you. Your payment is being processed.'
end

您注意到@payment.save! 发生在 API 调用之后。这可能是一个问题，因为 API 调用在数据库尝试保存记录之前运行。这可能意味着 API 调用成功，但数据库提交失败。

对这个场景有什么想法/建议吗？

Answer 1

您不能同时执行 API => DB 和 DB => API（听起来像是无限的执行条件），至少我无法想象如何实现此工作流程。我了解您的数据一致性需求，因此我建议：

• 检查记录是否有效@payment.valid?（可能使用valid_without_payment?之类的自定义方法）
• 运行 api 调用
• 仅当 api 调用成功时才保存记录（使用payment_id）

或者：

• 不使用payment_id保存记录
• 运行 api 调用
• 如果调用成功，使用payment_id（api 响应）更新记录
• 定期（cron）运行任务（脚本）以检查不一致的实例（where(payment_id: nil)）并将其删除

我认为这两个选项都可以接受，并且您的数据将保持一致。