dao

Documentation

Index

• type Dao
  • func New(c *conf.Config) (dao *Dao)
  • func (d *Dao) ClearHourPushAction(c context.Context, mid int64, noticeType int32) error
  • func (d *Dao) ClearPushActionMid(c context.Context, mid int64, noticeType int32) error
  • func (d *Dao) ClearUnread(ctx context.Context, mid int64, noticeType int32) (err error)
  • func (d *Dao) Close()
  • func (d *Dao) CreateNotice(ctx context.Context, notice *v1.NoticeBase) (id int64, err error)
  • func (d *Dao) DeleteUserPushDev(c context.Context, req *v1.UserPushDev) (int64, error)
  • func (d *Dao) FetchPushDev(c context.Context, mid int64) (result *push.Device, err error)
  • func (d *Dao) FetchUserFansNum(c context.Context, mid int64) (num int, err error)
  • func (d *Dao) FetchUserPushDev(c context.Context, mid int64, buvid string) (result *v1.UserPushDev, err error)
  • func (d *Dao) GetPushActionMid(c context.Context, mid int64, noticeType int32) ([]int64, error)
  • func (d *Dao) GetUnreadInfo(ctx context.Context, mid int64) (list []*v1.UnreadItem, err error)
  • func (d *Dao) GetUserName(c context.Context, midList []int64, count int) (names []string, err error)
  • func (d *Dao) IncrDailyPushCount(c context.Context, mid int64) (count int, err error)
  • func (d *Dao) IncrHourPushAction(c context.Context, mid int64, noticeType int32, t int) (count int, err error)
  • func (d *Dao) IncreaseUnread(ctx context.Context, mid int64, noticeType int32, num int64) (err error)
  • func (d *Dao) InsertUserPushDev(c context.Context, req *v1.UserPushDev) (int64, error)
  • func (d *Dao) ListNotices(ctx context.Context, mid, cursorID int64, noticeType int32) (list []*v1.NoticeBase, err error)
  • func (d *Dao) Ping(ctx context.Context) error
  • func (d *Dao) PushMessage(c context.Context, req *push.MessageRequest) (result []*push.PushResult, err error)
  • func (d *Dao) PushNotice(c context.Context, req *push.NotificationRequest) (result []*push.PushResult, err error)
  • func (d *Dao) SetPushActionMid(c context.Context, mid int64, actionMid int64, noticeType int32) error
  • func (d *Dao) UpdateUserPushDev(c context.Context, req *v1.UserPushDev) (int64, 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) ClearHourPushAction

func (d *Dao) ClearHourPushAction(c context.Context, mid int64, noticeType int32) error

ClearHourPushAction .

func (*Dao) ClearPushActionMid

func (d *Dao) ClearPushActionMid(c context.Context, mid int64, noticeType int32) error

ClearPushActionMid .

func (*Dao) ClearUnread

func (d *Dao) ClearUnread(ctx context.Context, mid int64, noticeType int32) (err error)

ClearUnread 清理未读

func (*Dao) Close

func (d *Dao) Close()

Close close the resource.

func (*Dao) CreateNotice

func (d *Dao) CreateNotice(ctx context.Context, notice *v1.NoticeBase) (id int64, err error)

CreateNotice 创建通知

func (*Dao) DeleteUserPushDev

func (d *Dao) DeleteUserPushDev(c context.Context, req *v1.UserPushDev) (int64, error)

DeleteUserPushDev .

func (*Dao) FetchPushDev

func (d *Dao) FetchPushDev(c context.Context, mid int64) (result *push.Device, err error)

FetchPushDev .

func (*Dao) FetchUserFansNum

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

FetchUserFansNum .

func (*Dao) FetchUserPushDev

func (d *Dao) FetchUserPushDev(c context.Context, mid int64, buvid string) (result *v1.UserPushDev, err error)

FetchUserPushDev .

func (*Dao) GetPushActionMid

func (d *Dao) GetPushActionMid(c context.Context, mid int64, noticeType int32) ([]int64, error)

GetPushActionMid .

func (*Dao) GetUnreadInfo

func (d *Dao) GetUnreadInfo(ctx context.Context, mid int64) (list []*v1.UnreadItem, err error)

GetUnreadInfo 获取未读情况

func (*Dao) GetUserName

func (d *Dao) GetUserName(c context.Context, midList []int64, count int) (names []string, err error)

GetUserName .

func (*Dao) IncrDailyPushCount

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

IncrDailyPushCount .

func (*Dao) IncrHourPushAction

func (d *Dao) IncrHourPushAction(c context.Context, mid int64, noticeType int32, t int) (count int, err error)

IncrHourPushAction .

func (*Dao) IncreaseUnread

func (d *Dao) IncreaseUnread(ctx context.Context, mid int64, noticeType int32, num int64) (err error)

IncreaseUnread 增加未读

func (*Dao) InsertUserPushDev

func (d *Dao) InsertUserPushDev(c context.Context, req *v1.UserPushDev) (int64, error)

InsertUserPushDev .

func (*Dao) ListNotices

func (d *Dao) ListNotices(ctx context.Context, mid, cursorID int64, noticeType int32) (list []*v1.NoticeBase, err error)

ListNotices 获取通知列表

func (*Dao) Ping

func (d *Dao) Ping(ctx context.Context) error

Ping dao ping

func (*Dao) PushMessage

func (d *Dao) PushMessage(c context.Context, req *push.MessageRequest) (result []*push.PushResult, err error)

PushMessage .

func (*Dao) PushNotice

func (d *Dao) PushNotice(c context.Context, req *push.NotificationRequest) (result []*push.PushResult, err error)

PushNotice .

func (*Dao) SetPushActionMid

func (d *Dao) SetPushActionMid(c context.Context, mid int64, actionMid int64, noticeType int32) error

SetPushActionMid .

func (*Dao) UpdateUserPushDev

func (d *Dao) UpdateUserPushDev(c context.Context, req *v1.UserPushDev) (int64, error)

UpdateUserPushDev .