dao

Documentation

Index

• type Dao
  • func New(c *conf.Config) (dao *Dao)
  • func (d *Dao) AddOrderLog(c context.Context, tx *sql.Tx, o *model.CouponOrderLog) (a int64, err error)
  • func (d *Dao) BatchInsertBlanceLog(c context.Context, tx *sql.Tx, mid int64, ls []*model.CouponBalanceChangeLog) (a int64, err error)
  • func (d *Dao) BatchUpdateBlance(c context.Context, tx *sql.Tx, mid int64, blances []*model.CouponBalanceInfo) (a int64, err error)
  • func (d *Dao) BeginTran(c context.Context) (*sql.Tx, error)
  • func (d *Dao) BlanceList(c context.Context, mid int64, ct int8) (res []*model.CouponBalanceInfo, err error)
  • func (d *Dao) ByMidAndBatchToken(c context.Context, mid int64, batchToken string) (r *model.CouponBalanceInfo, err error)
  • func (d *Dao) ByOrderNo(c context.Context, orderNo string) (r *model.CouponOrder, err error)
  • func (d *Dao) Close()
  • func (d *Dao) ConsumeCouponLog(c context.Context, mid int64, orderNo string, ct int8) (rs []*model.CouponBalanceChangeLog, err error)
  • func (d *Dao) CouponInfo(c context.Context, mid int64, token string) (r *model.CouponInfo, err error)
  • func (d *Dao) CouponList(c context.Context, index int64, state int8, t time.Time) (res []*model.CouponInfo, err error)
  • func (d *Dao) DelCouponBalancesCache(c context.Context, mid int64, ct int8) (err error)
  • func (d *Dao) DelCouponsCache(c context.Context, mid int64, ct int8) (err error)
  • func (d *Dao) DelPrizeCardKey(c context.Context, mid, actID int64, cardType int8) (err error)
  • func (d *Dao) DelPrizeCardsKey(c context.Context, mid, actID int64) (err error)
  • func (d *Dao) InsertPointHistory(c context.Context, tx *sql.Tx, l *model.CouponChangeLog) (a int64, err error)
  • func (d *Dao) NotifyRet(c context.Context, notifyURL string, ticketNO string, orderNO string, ...) (data *model.CallBackRet, err error)
  • func (d *Dao) OrderInPay(c context.Context, state int8, t time.Time) (res []*model.CouponOrder, err error)
  • func (d *Dao) Ping(c context.Context) (err error)
  • func (d *Dao) UpdateBlance(c context.Context, tx *sql.Tx, id int64, mid int64, ver int64, balance int64) (a int64, err error)
  • func (d *Dao) UpdateCoupon(c context.Context, tx *sql.Tx, mid int64, state int8, useVer int64, ver int64, ...) (a int64, err error)
  • func (d *Dao) UpdateOrderState(c context.Context, tx *sql.Tx, mid int64, state int8, useVer int64, ver int64, ...) (a int64, err error)
  • func (d *Dao) UpdateUserCard(c context.Context, mid int64, state int8, couponToken, batchToken string) (a int64, err error)

Types

type Dao

type Dao struct {
	// contains filtered or unexported fields
}

Dao dao

func New

func New(c *conf.Config) (dao *Dao)

New init mysql db

func (*Dao) AddOrderLog

func (d *Dao) AddOrderLog(c context.Context, tx *sql.Tx, o *model.CouponOrderLog) (a int64, err error)

AddOrderLog add order log.

func (*Dao) BatchInsertBlanceLog

func (d *Dao) BatchInsertBlanceLog(c context.Context, tx *sql.Tx, mid int64, ls []*model.CouponBalanceChangeLog) (a int64, err error)

BatchInsertBlanceLog Batch Insert Balance log

func (*Dao) BatchUpdateBlance

func (d *Dao) BatchUpdateBlance(c context.Context, tx *sql.Tx, mid int64, blances []*model.CouponBalanceInfo) (a int64, err error)

BatchUpdateBlance batch update blance.

func (*Dao) BeginTran

func (d *Dao) BeginTran(c context.Context) (*sql.Tx, error)

BeginTran begin transaction.

func (*Dao) BlanceList

func (d *Dao) BlanceList(c context.Context, mid int64, ct int8) (res []*model.CouponBalanceInfo, err error)

BlanceList user balance by mid.

func (*Dao) ByMidAndBatchToken

func (d *Dao) ByMidAndBatchToken(c context.Context, mid int64, batchToken string) (r *model.CouponBalanceInfo, err error)

ByMidAndBatchToken query coupon by batch token and mid.

func (*Dao) ByOrderNo

func (d *Dao) ByOrderNo(c context.Context, orderNo string) (r *model.CouponOrder, err error)

ByOrderNo query order by order no.

func (*Dao) Close

func (d *Dao) Close()

Close close the resource.

func (*Dao) ConsumeCouponLog

func (d *Dao) ConsumeCouponLog(c context.Context, mid int64, orderNo string, ct int8) (rs []*model.CouponBalanceChangeLog, err error)

ConsumeCouponLog consume coupon log.

func (*Dao) CouponInfo

func (d *Dao) CouponInfo(c context.Context, mid int64, token string) (r *model.CouponInfo, err error)

CouponInfo coupon info.

func (*Dao) CouponList

func (d *Dao) CouponList(c context.Context, index int64, state int8, t time.Time) (res []*model.CouponInfo, err error)

CouponList query .

func (*Dao) DelCouponBalancesCache

func (d *Dao) DelCouponBalancesCache(c context.Context, mid int64, ct int8) (err error)

DelCouponBalancesCache delete user coupons blance cache.

func (*Dao) DelCouponsCache

func (d *Dao) DelCouponsCache(c context.Context, mid int64, ct int8) (err error)

DelCouponsCache delete user coupons cache.

func (*Dao) DelPrizeCardKey

func (d *Dao) DelPrizeCardKey(c context.Context, mid, actID int64, cardType int8) (err error)

DelPrizeCardKey .

func (*Dao) DelPrizeCardsKey

func (d *Dao) DelPrizeCardsKey(c context.Context, mid, actID int64) (err error)

DelPrizeCardsKey .

func (*Dao) InsertPointHistory

func (d *Dao) InsertPointHistory(c context.Context, tx *sql.Tx, l *model.CouponChangeLog) (a int64, err error)

InsertPointHistory .

func (*Dao) NotifyRet

func (d *Dao) NotifyRet(c context.Context, notifyURL string, ticketNO string, orderNO string, ip string) (data *model.CallBackRet, err error)

NotifyRet notify use coupon ret.

func (*Dao) OrderInPay

func (d *Dao) OrderInPay(c context.Context, state int8, t time.Time) (res []*model.CouponOrder, err error)

OrderInPay order in pay.

func (*Dao) Ping

func (d *Dao) Ping(c context.Context) (err error)

Ping dao ping

func (*Dao) UpdateBlance

func (d *Dao) UpdateBlance(c context.Context, tx *sql.Tx, id int64, mid int64, ver int64, balance int64) (a int64, err error)

UpdateBlance update blance.

func (*Dao) UpdateCoupon

func (d *Dao) UpdateCoupon(c context.Context, tx *sql.Tx, mid int64, state int8, useVer int64, ver int64, couponToken string) (a int64, err error)

UpdateCoupon update coupon in use.

func (*Dao) UpdateOrderState

func (d *Dao) UpdateOrderState(c context.Context, tx *sql.Tx, mid int64, state int8, useVer int64, ver int64, orderNo string) (a int64, err error)

UpdateOrderState update order state.

func (*Dao) UpdateUserCard

func (d *Dao) UpdateUserCard(c context.Context, mid int64, state int8, couponToken, batchToken string) (a int64, err error)

UpdateUserCard .