wangjia
21 lines
1.2 KiB
Go
21 lines
1.2 KiB
Go
package model
|
|
|
|
import "time"
|
|
|
|
// WebhookDelivery 是 pay→业务方 webhook 的 outbox(v2)。unique(out_trade_no,event_type,refund_id)
|
|
// 保证同一订单同一事件(同一退款单)只入队一次(幂等);后台 Notifier 扫 Delivered=false 重试兜底。
|
|
type WebhookDelivery struct {
|
|
Base
|
|
OutTradeNo string `gorm:"size:64;not null;uniqueIndex:uq_delivery" json:"out_trade_no"`
|
|
EventType string `gorm:"size:32;not null;uniqueIndex:uq_delivery" json:"event_type"`
|
|
RefundID string `gorm:"size:64;not null;default:'';uniqueIndex:uq_delivery" json:"refund_id,omitempty"` // 退款事件的幂等维度;payment 事件为空
|
|
BizSystem string `gorm:"index;size:32" json:"biz_system"`
|
|
Payload string `gorm:"type:text" json:"payload"` // 已序列化的领域 JSON(含 event_type)
|
|
Delivered bool `gorm:"index;default:false" json:"delivered"`
|
|
Attempts int `json:"attempts"`
|
|
LastError string `gorm:"size:255" json:"last_error,omitempty"`
|
|
|
|
Dead bool `gorm:"index;default:false" json:"dead"` // 达最大次数放弃投递(死信),需人工/对账介入
|
|
NextAttemptAt *time.Time `gorm:"index" json:"next_attempt_at,omitempty"` // 指数退避的下次可投时刻;nil=立即可投
|
|
}
|