pay.go 3.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  1. package shanghu
  2. import (
  3. orm "duoduo/database"
  4. "github.com/shopspring/decimal"
  5. "time"
  6. )
  7. type ClientPayTrans struct {
  8. ID int64 `gorm:"column:id;type:bigint(20);primary_key" json:"id"` // 主键
  9. RequestID string `gorm:"column:request_id;type:varchar(255)" json:"request_id"` // 请求id,幂等性
  10. OutTradeNo string `gorm:"column:out_trade_no;type:varchar(255)" json:"out_trade_no"` // 交易id
  11. MerchantCardID int64 `gorm:"column:merchant_card_id;type:bigint(20)" json:"merchant_card_id"` // 商户卡id
  12. ClientOpenID string `gorm:"column:client_open_id;type:varchar(255)" json:"client_open_id"` // 客户端openid
  13. Status int `gorm:"column:status;type:int(11)" json:"status"` // 1-未支付 2-支付成功 3-取消支付 4-退款
  14. Amount decimal.Decimal `gorm:"column:amount;type:decimal(10,2)" json:"amount"` // 交易金额
  15. ThirdTradeNo string `gorm:"column:third_trade_no;type:varchar(255)" json:"third_trade_no"` // 微信交易id
  16. PayTime time.Time `gorm:"column:pay_time;type:datetime(3);default:null" json:"pay_time"` // 支付时间
  17. CreateBy int64 `gorm:"column:create_by;type:bigint(20)" json:"create_by"` // 创建者
  18. UpdateBy int64 `gorm:"column:update_by;type:bigint(20)" json:"update_by"` // 更新者
  19. CreatedAt time.Time `gorm:"column:created_at;type:datetime(3)" json:"created_at"` // 创建时间
  20. UpdatedAt time.Time `gorm:"column:updated_at;type:datetime(3)" json:"updated_at"` // 最后更新时间
  21. DeletedAt time.Time `gorm:"column:deleted_at;type:datetime(3);default:null" json:"deleted_at"` // 删除时间
  22. }
  23. func (m *ClientPayTrans) TableName() string {
  24. return "client_pay_trans"
  25. }
  26. func (m *ClientPayTrans) GetRequestNum() int {
  27. var count int
  28. tableCount := orm.ShMysql.Table(m.TableName()).Where("request_id = ? ", m.RequestID)
  29. tableCount.Count(&count)
  30. return count
  31. }
  32. func (m *ClientPayTrans) GetPayTransByTradeNo() (ClientPayTrans, error) {
  33. var doc ClientPayTrans
  34. table := orm.ShMysql.Table(m.TableName())
  35. table = table.Where("out_trade_no = ? ", m.OutTradeNo)
  36. if err := table.Select("*").First(&doc).Error; err != nil {
  37. return doc, err
  38. }
  39. return doc, nil
  40. }
  41. func (u *ClientPayTrans) Create() (ClientPayTrans, error) {
  42. var doc ClientPayTrans
  43. var err error
  44. doc = *u
  45. err = orm.ShMysql.Table(u.TableName()).Create(&doc).Error
  46. if err != nil {
  47. return doc, err
  48. }
  49. return doc, nil
  50. }
  51. //var data biz.EbankAccountVa
  52. //err := c.data.mysql.WithContext(ctx).Table(req.TableName()).Where("open_id = ? and pay_agency = ? and account_no = ?", req.OpenID, req.PayAgency, req.AccountNo).Select("id").First(&data).Error
  53. //
  54. //if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
  55. //return err
  56. //}
  57. //req.ID = data.ID
  58. //err = c.data.mysql.Clauses(clause.OnConflict{
  59. //UpdateAll: true,
  60. //}).Table(req.TableName()).Create(&req).Error
  61. //if err != nil {
  62. //return err
  63. //}
  64. //return nil
  65. func (m *ClientPayTrans) UpdatePayTransByTradeNo() error {
  66. if err := orm.ShMysql.Table(m.TableName()).Model(&m).Where("out_trade_no = ? ", m.OutTradeNo).Updates(
  67. map[string]interface{}{
  68. "third_trade_no": m.ThirdTradeNo,
  69. "pay_time": m.PayTime,
  70. "updated_at": time.Now()}).Error; err != nil {
  71. return err
  72. }
  73. return nil
  74. }