unicom

Documentation

Index

• type Dao
  • func New(c *conf.Config) (d *Dao)
  • func (d *Dao) AddUserBindCache(c context.Context, mid int64, ub *unicom.UserBind) (err error)
  • func (d *Dao) AddUserFlowCache(c context.Context, keyStr string) (err error)
  • func (d *Dao) AddUserFlowListCache(c context.Context, list map[string]*unicom.UnicomUserFlow) (err error)
  • func (d *Dao) AddUserPackReceiveCache(c context.Context, mid int64, count int, now time.Time) (err error)
  • func (d *Dao) BeginTran(ctx context.Context) (tx *xsql.Tx, err error)
  • func (d *Dao) BindAll(ctx context.Context, start, end int) (res []*unicom.UserBind, err error)
  • func (d *Dao) DeleteUserBindCache(c context.Context, mid int64) (err error)
  • func (d *Dao) DeleteUserFlowCache(c context.Context, keyStr string) (err error)
  • func (d *Dao) DeleteUserPackReceiveCache(c context.Context, mid int64) (err error)
  • func (d *Dao) FlowQry(c context.Context, phone int, requestNo int64, outorderid, orderid string, ...) (orderstatus, msg string, err error)
  • func (d *Dao) IPSync(ctx context.Context) (res []*unicom.UnicomIP, err error)
  • func (d *Dao) InUnicomIPSync(tx *xsql.Tx, u *unicom.UnicomIP, now time.Time) (row int64, err error)
  • func (d *Dao) InUserIntegralLog(ctx context.Context, u *unicom.UserIntegralLog) (row int64, err error)
  • func (d *Dao) InUserPackLog(ctx context.Context, u *unicom.UserPackLog) (row int64, err error)
  • func (d *Dao) OrdersUserFlow(ctx context.Context, usermob string) (res []*unicom.Unicom, err error)
  • func (d *Dao) UnicomCache(c context.Context, usermob string) (u []*unicom.Unicom, err error)
  • func (d *Dao) UnicomIP(c context.Context, now time.Time) (unicomIPs []*unicom.UnicomIP, err error)
  • func (d *Dao) UpUnicomIP(tx *xsql.Tx, ipstart, ipend, state int, now time.Time) (row int64, err error)
  • func (d *Dao) UpUserIntegral(ctx context.Context, ub *unicom.UserBind) (row int64, err error)
  • func (d *Dao) UserBind(ctx context.Context, mid int64) (res *unicom.UserBind, err error)
  • func (d *Dao) UserBindCache(c context.Context, mid int64) (ub *unicom.UserBind, err error)
  • func (d *Dao) UserFlowCache(c context.Context, keyStr string) (err error)
  • func (d *Dao) UserFlowListCache(c context.Context) (res map[string]*unicom.UnicomUserFlow, err error)
  • func (d *Dao) UserPackReceiveCache(c context.Context, mid int64) (count int, err error)

Types

type Dao

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

func New

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

func (*Dao) AddUserBindCache

func (d *Dao) AddUserBindCache(c context.Context, mid int64, ub *unicom.UserBind) (err error)

AddUserBindCache add user user bind cache

func (*Dao) AddUserFlowCache

func (d *Dao) AddUserFlowCache(c context.Context, keyStr string) (err error)

AddUserFlowCache add user pack cache

func (*Dao) AddUserFlowListCache

func (d *Dao) AddUserFlowListCache(c context.Context, list map[string]*unicom.UnicomUserFlow) (err error)

AddUserFlowListCache add user pack cache

func (*Dao) AddUserPackReceiveCache

func (d *Dao) AddUserPackReceiveCache(c context.Context, mid int64, count int, now time.Time) (err error)

AddUserPackReceiveCache add user pack cache

func (*Dao) BeginTran

func (d *Dao) BeginTran(ctx context.Context) (tx *xsql.Tx, err error)

BeginTran begin a transacition

func (*Dao) BindAll

func (d *Dao) BindAll(ctx context.Context, start, end int) (res []*unicom.UserBind, err error)

BindAll select bind all mid state 1

func (*Dao) DeleteUserBindCache

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

DeleteUserBindCache delete user bind cache

func (*Dao) DeleteUserFlowCache

func (d *Dao) DeleteUserFlowCache(c context.Context, keyStr string) (err error)

DeleteUserPackCache delete user pack cache

func (*Dao) DeleteUserPackReceiveCache

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

DeleteUserPackReceiveCache delete user pack cache

func (*Dao) FlowQry

func (d *Dao) FlowQry(c context.Context, phone int, requestNo int64, outorderid, orderid string, ts time.Time) (orderstatus, msg string, err error)

FlowQry unicom phone qryflowchange

func (*Dao) IPSync

func (d *Dao) IPSync(ctx context.Context) (res []*unicom.UnicomIP, err error)

IPSync select all ipSync

func (*Dao) InUnicomIPSync

func (d *Dao) InUnicomIPSync(tx *xsql.Tx, u *unicom.UnicomIP, now time.Time) (row int64, err error)

InUnicomIPSync insert or update unicom_ip

func (*Dao) InUserIntegralLog

func (d *Dao) InUserIntegralLog(ctx context.Context, u *unicom.UserIntegralLog) (row int64, err error)

InUserIntegralLog insert unicom user add integral and flow log

func (*Dao) InUserPackLog

func (d *Dao) InUserPackLog(ctx context.Context, u *unicom.UserPackLog) (row int64, err error)

InUserPackLog insert unicom user pack log

func (*Dao) OrdersUserFlow

func (d *Dao) OrdersUserFlow(ctx context.Context, usermob string) (res []*unicom.Unicom, err error)

OrdersUserFlow select user OrdersSync

func (*Dao) UnicomCache

func (d *Dao) UnicomCache(c context.Context, usermob string) (u []*unicom.Unicom, err error)

UnicomCache

func (*Dao) UnicomIP

func (d *Dao) UnicomIP(c context.Context, now time.Time) (unicomIPs []*unicom.UnicomIP, err error)

UnicomIP unicom ip orders

func (*Dao) UpUnicomIP

func (d *Dao) UpUnicomIP(tx *xsql.Tx, ipstart, ipend, state int, now time.Time) (row int64, err error)

UpUnicomIP update unicom_ip state

func (*Dao) UpUserIntegral

func (d *Dao) UpUserIntegral(ctx context.Context, ub *unicom.UserBind) (row int64, err error)

UpUserIntegral update unicom user integral

func (*Dao) UserBind

func (d *Dao) UserBind(ctx context.Context, mid int64) (res *unicom.UserBind, err error)

UserBind unicom select user bind

func (*Dao) UserBindCache

func (d *Dao) UserBindCache(c context.Context, mid int64) (ub *unicom.UserBind, err error)

UserBindCache user bind cache

func (*Dao) UserFlowCache

func (d *Dao) UserFlowCache(c context.Context, keyStr string) (err error)

UserFlowCache unicom flow cache

func (*Dao) UserFlowListCache

func (d *Dao) UserFlowListCache(c context.Context) (res map[string]*unicom.UnicomUserFlow, err error)

UserFlowListCache unicom flow cache

func (*Dao) UserPackReceiveCache

func (d *Dao) UserPackReceiveCache(c context.Context, mid int64) (count int, err error)

UserPackReceiveCache user pack cache