94 lines
3.4 KiB
Go
94 lines
3.4 KiB
Go
package payment
|
|
|
|
import (
|
|
"context"
|
|
|
|
"hfb_jysh/backend/internal/model"
|
|
|
|
"go.uber.org/zap"
|
|
)
|
|
|
|
// ConfirmChannelPaidBeforeClose 在取消或关闭订单前跟渠道核对未完成的下单支付单。
|
|
// 返回 true 表示渠道确认已收款且订单已被推进，调用方必须放弃本次取消。
|
|
//
|
|
// 待支付订单的 15 分钟超时和用户手动取消都可能正好撞上用户付款：
|
|
// 订单先没了，渠道结果几秒后才到，于是钱收了、订单却是已取消。
|
|
// 先核对一次能把绝大多数这种竞态挡在发生之前——而且是让支付正常入账，不必退款。
|
|
func (r *Repository) ConfirmChannelPaidBeforeClose(ctx context.Context, orderID uint64) (bool, error) {
|
|
if r == nil || r.db == nil || orderID == 0 {
|
|
return false, nil
|
|
}
|
|
payments, err := r.pendingOrderPayments(ctx, orderID)
|
|
if err != nil {
|
|
return false, err
|
|
}
|
|
advanced := false
|
|
for i := range payments {
|
|
if err := r.probeChannelPaid(ctx, &payments[i]); err != nil {
|
|
// 渠道不可用不能阻塞取消，否则渠道一挂订单就全卡住。
|
|
// 真漏掉的由支付回调兜底记账并告警。
|
|
r.log().Warn("取消前核对渠道支付状态失败", paymentLogFields(ctx, appendFields(
|
|
paymentOrderFields(&payments[i]),
|
|
[]zap.Field{zap.Error(err)},
|
|
)...,
|
|
)...)
|
|
continue
|
|
}
|
|
// 以订单是否真的被推进为准。钱到了但商品已被他人租走时，入账路径只会记账
|
|
// 并告警等人工退款，不推进订单，这种情况仍然该让取消照常进行。
|
|
if orderAdvancedPastPayment(r.orderStatus(ctx, orderID)) {
|
|
advanced = true
|
|
}
|
|
}
|
|
return advanced, nil
|
|
}
|
|
|
|
// orderAdvancedPastPayment 判断订单是否已经靠这笔支付走出待支付阶段。
|
|
func orderAdvancedPastPayment(status string) bool {
|
|
return status == "pending_handoff" || status == "renting"
|
|
}
|
|
|
|
// probeChannelPaid 向渠道查询一笔支付单的真实状态并落库。
|
|
func (r *Repository) probeChannelPaid(ctx context.Context, payment *model.PaymentOrder) error {
|
|
if payment.ProviderOrderID == "" {
|
|
// 没有渠道单号说明下单请求没被渠道受理，不可能收到钱。
|
|
return nil
|
|
}
|
|
runtimeConfig, err := r.runtimeConfigForPayment(ctx, payment)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if runtimeConfig.isMockMode() || runtimeConfig.Channel == nil {
|
|
return nil
|
|
}
|
|
resp, err := runtimeConfig.Channel.QueryPayment(ctx, channelQueryPaymentRequest{
|
|
ThirdOrderID: payment.ThirdOrderID,
|
|
TraceTime: paymentTraceTime(payment.RawRequest),
|
|
ProviderOrderID: payment.ProviderOrderID,
|
|
})
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if resp.Status != "paid" {
|
|
return nil
|
|
}
|
|
r.log().Warn("渠道核对到已收款但系统未入账", paymentLogFields(ctx, appendFields(
|
|
paymentOrderFields(payment),
|
|
runtimeConfigFields(runtimeConfig),
|
|
[]zap.Field{zap.String("order_status", r.orderStatus(ctx, payment.OrderID))},
|
|
)...,
|
|
)...)
|
|
// 走统一入账路径：订单还能支付就正常推进，已经结束就只记账并告警等人工退款。
|
|
return r.applyChannelStatus(ctx, payment, resp.Status, resp.PayTime, resp.Raw, channelSourceQuery)
|
|
}
|
|
|
|
func (r *Repository) pendingOrderPayments(ctx context.Context, orderID uint64) ([]model.PaymentOrder, error) {
|
|
var rows []model.PaymentOrder
|
|
err := r.db.WithContext(ctx).
|
|
Where("order_id = ? AND biz_type = ? AND status IN ? AND provider_order_id <> ''",
|
|
orderID, "order_pay", []string{"created", "paying"}).
|
|
Order("id DESC").
|
|
Find(&rows).Error
|
|
return rows, err
|
|
}
|