eta_mini_ht_api/models/order/trade_order.go

package order

import (
	"eta/eta_mini_ht_api/models"
	"gorm.io/gorm"
	"time"
)

type PaymentStatus string
type PaymentType string

const (
	PaymentStatusPending    PaymentStatus = "pending"
	PaymentStatusProcessing PaymentStatus = "processing"
	PaymentStatusDone       PaymentStatus = "done"
	PaymentStatusFailed     PaymentStatus = "failed"

	PaymentTypePay    PaymentType = "pay"
	PaymentTypeRefund PaymentType = "refund"
)

type TradeOrder struct {
	ID             int           `gorm:"column:id;primaryKey"`
	TransactionID  string        `gorm:"column:transaction_id;type:varchar(255);comment:第三方平台ID"`
	ProductOrderID string        `gorm:"column:product_order_id;type:varchar(255);comment:商品订单号"`
	PaymentAccount string        `gorm:"column:payment_account;type:varchar(255);comment:支付账号"`
	PaymentWay     string        `gorm:"column:payment_way;type:enum('wechat');comment:支付渠道"`
	Amount         string        `gorm:"column:amount;type:varchar(20);comment:支付金额"`
	Currency       string        `gorm:"column:currency;type:varchar(255);comment:货币"`
	MerchantID     string        `gorm:"column:merchant_id;type:varchar(255);comment:商户id"`
	UserID         int           `gorm:"column:user_id;type:int(11);comment:用户id"`
	TemplateUserID int           `gorm:"column:template_user_id;type:int(11);comment:临时用户id"`
	PaymentType    PaymentType   `gorm:"column:payment_type;type:enum('pay','refund');comment:订单类型"`
	PaymentStatus  PaymentStatus `gorm:"column:payment_status;type:enum('pending','processing','done','failed');comment:支付状态"`
	DealTime       time.Time     `gorm:"column:deal_time;type:datetime;comment:完成时间"`
	CreatedTime    time.Time     `gorm:"column:created_time;type:datetime;comment:创建时间"`
	UpdatedTime    time.Time     `gorm:"column:updated_time;type:datetime;comment:更新时间"`
}

func (to *TradeOrder) TableName() string {
	return "trade_orders"
}

func (to *TradeOrder) BeforeCreate(_ *gorm.DB) (err error) {
	to.CreatedTime = time.Now()
	to.PaymentStatus = PaymentStatusPending
	return
}

func GetUnFailedTradeFlowByProductOrder(no string) (list []TradeOrder, err error) {
	db := models.Main()
	err = db.Where("product_order_id=? and payment_status!=? order by updated_time,created_time desc", no, PaymentStatusFailed).Find(&list).Error
	return
}