dao

Documentation

Index

• type Dao
  • func New(c *conf.Config) (d *Dao)
  • func (d *Dao) AddReply(c context.Context, r *model.Reply) (id int64, err error)
  • func (d *Dao) AddSession(c context.Context, s *model.Session) (id int64, err error)
  • func (d *Dao) AddSessionTag(c context.Context, sessionID, tagID int64, now time.Time) (id int64, err error)
  • func (d *Dao) BeginTran(c context.Context) (tx *sql.Tx, err error)
  • func (d *Dao) InPlayCheck(c context.Context, platform, isp, ipChangeTimes int, ...) (rows int64, err error)
  • func (d *Dao) JudgeSsnRecord(c context.Context, sid int64) (cnt int, err error)
  • func (d *Dao) Replys(c context.Context, ssnID int64, offset, limit int) (rs []model.Reply, err error)
  • func (d *Dao) ReplysByMid(c context.Context, mid int64, offset, limit int) (rs []model.Reply, err error)
  • func (d *Dao) SSnBySsnIDAllSate(c context.Context, sid []int64, start, end time.Time) (ssns []*model.Session, err error)
  • func (d *Dao) Session(c context.Context, buvid, system, version string, mid int64) (ssn *model.Session, err error)
  • func (d *Dao) SessionByMid(c context.Context, mid int64, platform string) (ssns []*model.Session, err error)
  • func (d *Dao) SessionBySsnID(c context.Context, sid []int64, state string, start, end time.Time) (ssns []*model.Session, err error)
  • func (d *Dao) SessionCount(c context.Context, mid int64) (cnt int, err error)
  • func (d *Dao) SessionIDByTagID(c context.Context, tagID []int64) (sid []int64, err error)
  • func (d *Dao) TagBySsnID(c context.Context, sids []int64) (tagMap map[int64][]*model.Tag, err error)
  • func (d *Dao) TagIDBySid(c context.Context, sids []int64) (tsMap map[int64]int64, err error)
  • func (d *Dao) Tags(c context.Context, mold int, platform string) (tMap map[string][]*model.Tag, err error)
  • func (d *Dao) TxAddReply(tx *sql.Tx, r *model.Reply) (id int64, err error)
  • func (d *Dao) TxAddSession(tx *sql.Tx, s *model.Session) (id int64, err error)
  • func (d *Dao) TxAddSessionTag(tx *sql.Tx, sessionID, tagID int64, now time.Time) (id int64, err error)
  • func (d *Dao) TxUpSsnMtime(tx *sql.Tx, now time.Time, id int64) (err error)
  • func (d *Dao) TxUpdateSessionState(tx *sql.Tx, state int, sid int64) (err error)
  • func (d *Dao) UpSsnMtime(c context.Context, now time.Time, id int64) (err error)
  • func (d *Dao) UpdateSession(c context.Context, s *model.Session) (affected int64, err error)
  • func (d *Dao) UpdateSessionState(c context.Context, state int, sid int64) (err error)
  • func (d *Dao) Upload(c context.Context, fileName, fileType string, expire int64, body io.Reader) (location string, err error)
  • func (d *Dao) WebReplys(c context.Context, ssnID, mid int64) (rs []*model.Reply, err error)

Types

type Dao

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

Dao is feedback dao.

func New

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

New dao.

func (*Dao) AddReply

func (d *Dao) AddReply(c context.Context, r *model.Reply) (id int64, err error)

AddReply insert reply.

func (*Dao) AddSession

func (d *Dao) AddSession(c context.Context, s *model.Session) (id int64, err error)

AddSession add feedback session

func (*Dao) AddSessionTag

func (d *Dao) AddSessionTag(c context.Context, sessionID, tagID int64, now time.Time) (id int64, err error)

AddSessionTag add feedback session and tag.

func (*Dao) BeginTran

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

BeginTran begin tran.

func (*Dao) InPlayCheck

func (d *Dao) InPlayCheck(c context.Context, platform, isp, ipChangeTimes int, mid, checkTime, aid, connectSpeed, ioSpeed int64, region, school, ip, cdn string) (rows int64, err error)

InPlayCheck insert player check info into db

func (*Dao) JudgeSsnRecord

func (d *Dao) JudgeSsnRecord(c context.Context, sid int64) (cnt int, err error)

JudgeSsnRecord judge session is exist or not .

func (*Dao) Replys

func (d *Dao) Replys(c context.Context, ssnID int64, offset, limit int) (rs []model.Reply, err error)

Replys returns corresponding user feedback reply records

func (*Dao) ReplysByMid

func (d *Dao) ReplysByMid(c context.Context, mid int64, offset, limit int) (rs []model.Reply, err error)

ReplysByMid returns corresponding user feedback reply records by mid

func (*Dao) SSnBySsnIDAllSate

func (d *Dao) SSnBySsnIDAllSate(c context.Context, sid []int64, start, end time.Time) (ssns []*model.Session, err error)

SSnBySsnIDAllSate get all SSn by ssnID all sate.

func (*Dao) Session

func (d *Dao) Session(c context.Context, buvid, system, version string, mid int64) (ssn *model.Session, err error)

Session select feedback session

func (*Dao) SessionByMid

func (d *Dao) SessionByMid(c context.Context, mid int64, platform string) (ssns []*model.Session, err error)

SessionByMid select feedback session by mid

func (*Dao) SessionBySsnID

func (d *Dao) SessionBySsnID(c context.Context, sid []int64, state string, start, end time.Time) (ssns []*model.Session, err error)

SessionBySsnID get session by ssnID

func (*Dao) SessionCount

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

SessionCount session count.

func (*Dao) SessionIDByTagID

func (d *Dao) SessionIDByTagID(c context.Context, tagID []int64) (sid []int64, err error)

SessionIDByTagID session find by time state and mid .

func (*Dao) TagBySsnID

func (d *Dao) TagBySsnID(c context.Context, sids []int64) (tagMap map[int64][]*model.Tag, err error)

TagBySsnID get tag by ssnID.

func (*Dao) TagIDBySid

func (d *Dao) TagIDBySid(c context.Context, sids []int64) (tsMap map[int64]int64, err error)

TagIDBySid get tagid by sid.

func (*Dao) Tags

func (d *Dao) Tags(c context.Context, mold int, platform string) (tMap map[string][]*model.Tag, err error)

Tags get tags.

func (*Dao) TxAddReply

func (d *Dao) TxAddReply(tx *sql.Tx, r *model.Reply) (id int64, err error)

TxAddReply implements add a new reply record

func (*Dao) TxAddSession

func (d *Dao) TxAddSession(tx *sql.Tx, s *model.Session) (id int64, err error)

TxAddSession add session

func (*Dao) TxAddSessionTag

func (d *Dao) TxAddSessionTag(tx *sql.Tx, sessionID, tagID int64, now time.Time) (id int64, err error)

TxAddSessionTag add session tag.

func (*Dao) TxUpSsnMtime

func (d *Dao) TxUpSsnMtime(tx *sql.Tx, now time.Time, id int64) (err error)

TxUpSsnMtime up ssn mtime.

func (*Dao) TxUpdateSessionState

func (d *Dao) TxUpdateSessionState(tx *sql.Tx, state int, sid int64) (err error)

TxUpdateSessionState up date session state.

func (*Dao) UpSsnMtime

func (d *Dao) UpSsnMtime(c context.Context, now time.Time, id int64) (err error)

UpSsnMtime up ssn mtime.

func (*Dao) UpdateSession

func (d *Dao) UpdateSession(c context.Context, s *model.Session) (affected int64, err error)

UpdateSession update feedback session

func (*Dao) UpdateSessionState

func (d *Dao) UpdateSessionState(c context.Context, state int, sid int64) (err error)

UpdateSessionState update session state.

func (*Dao) Upload

func (d *Dao) Upload(c context.Context, fileName, fileType string, expire int64, body io.Reader) (location string, err error)

Upload upload picture or log file to bfs

func (*Dao) WebReplys

func (d *Dao) WebReplys(c context.Context, ssnID, mid int64) (rs []*model.Reply, err error)

WebReplys get by ssnID.