data

Documentation

Index

• Constants
• type Dao
  • func New(c *conf.Config) (d *Dao)
  • func (d *Dao) CheckReply(c context.Context, aid int64) (replyState int64, err error)
  • func (d *Dao) CloseReply(c context.Context, aid int64, mid int64) (err error)
  • func (d *Dao) HotArchive(c context.Context) (aids []int64, err error)
  • func (d *Dao) MidGroups(c context.Context, mid int64) (groups map[int64]*manager.UpGroup, err error)
  • func (d *Dao) MonitorNotify(c context.Context) (data []*monitor.RuleResultData, err error)
  • func (d *Dao) OpenReply(c context.Context, aid int64, mid int64) (err error)
  • func (d *Dao) UpProfitState(c context.Context, mid int64) (state int8, err error)

Constants

const UpProfitStateSigned = 3 //激励计划签约状态

Types

type Dao

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

Dao dao

func New

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

New new

func (*Dao) CheckReply

func (d *Dao) CheckReply(c context.Context, aid int64) (replyState int64, err error)

CheckReply get subject state

func (*Dao) CloseReply

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

CloseReply change subject state to close

func (*Dao) HotArchive

func (d *Dao) HotArchive(c context.Context) (aids []int64, err error)

HotArchive get hot archives which need rechecking

func (*Dao) MidGroups

func (d *Dao) MidGroups(c context.Context, mid int64) (groups map[int64]*manager.UpGroup, err error)

UpGroups get all up groups

func (*Dao) MonitorNotify

func (d *Dao) MonitorNotify(c context.Context) (data []*monitor.RuleResultData, err error)

func (*Dao) OpenReply

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

OpenReply change subject state to open

func (*Dao) UpProfitState

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

UpProfitState 获取UP主激励计划状态 返回State： 1: 未申请; 2: 待审核; 3: 已签约; 4.已驳回; 5.主动退出; 6:被动退出; 7:封禁