Documentation ¶
Index ¶
- func PromCacheHit(name string)
- func PromCacheMiss(name string)
- func RptLogTable(dmid int64) int64
- type Dao
- func (d *Dao) AddProtectApply(c context.Context, pas []*model.Pa) (affect int64, err error)
- func (d *Dao) AddReport(c context.Context, rpt *model.Report) (id int64, err error)
- func (d *Dao) AddReportLog(c context.Context, lg *model.RptLog) (err error)
- func (d *Dao) AddReportUser(c context.Context, u *model.User) (id int64, err error)
- func (d *Dao) AddRptBrig(c context.Context, mid int64) (err error)
- func (d *Dao) AddTransferJob(c context.Context, fromCid, toCid, mid int64, offset float64, state int8) (affect int64, err error)
- func (d *Dao) CheckTransferID(c context.Context, id int64) (job *model.TransferJob, err error)
- func (d *Dao) CheckTransferJob(c context.Context, fromCid, toCid int64) (job *model.TransferJob, err error)
- func (d *Dao) CidInfo(c context.Context, cid int64) (info *model.CidInfo, err error)
- func (d *Dao) Content(c context.Context, oid, dmid int64) (ct *model.Content, err error)
- func (d *Dao) ContentSpecial(c context.Context, dmid int64) (contentSpe *model.ContentSpecial, err error)
- func (d *Dao) Contents(c context.Context, oid int64, dmids []int64) (res []*model.Content, err error)
- func (d *Dao) ContentsSpecial(c context.Context, dmids []int64) (res map[int64]*model.ContentSpecial, err error)
- func (d *Dao) FigureInfo(c context.Context, mid int64) (score int32, err error)
- func (d *Dao) Index(c context.Context, tp int32, oid, dmid int64) (dm *model.DM, err error)
- func (d *Dao) IndexsByID(c context.Context, tp int32, oid int64, dmids []int64) (res map[int64]*model.DM, special []int64, err error)
- func (d *Dao) PaLock(c context.Context, key string) (incr int, err error)
- func (d *Dao) PaNoticeClose(c context.Context, uids []int64) (res map[int64]bool, err error)
- func (d *Dao) PaUsrCnt(c context.Context, uid int64) (cnt int, err error)
- func (d *Dao) PaUsrStat(c context.Context) (res []*model.ApplyUserStat, err error)
- func (d *Dao) Ping(c context.Context) (err error)
- func (d *Dao) ProtectAids(c context.Context, uid int64) (res []int64, err error)
- func (d *Dao) ProtectApplies(c context.Context, uid, aid int64, order string) (res []*model.Apply, err error)
- func (d *Dao) ProtectApplyByIDs(c context.Context, uid int64, ids string) (res map[int64][]int64, err error)
- func (d *Dao) ProtectApplyStatistics(c context.Context) (res []int64, err error)
- func (d *Dao) ProtectApplyTime(c context.Context, dmid int64) (t time.Time, err error)
- func (d *Dao) RecallCnt(c context.Context, uid int64) (cnt int, err error)
- func (d *Dao) Report(c context.Context, cid, dmid int64) (rpt *model.Report, err error)
- func (d *Dao) ReportLog(c context.Context, dmid int64) (res []*model.RptLog, err error)
- func (d *Dao) ReportUser(c context.Context, dmid int64) (users []*model.User, err error)
- func (d *Dao) RptBrigTime(c context.Context, mid int64) (t int64, err error)
- func (d *Dao) RptCnt(c context.Context, uid int64) (n int, err error)
- func (d *Dao) SearchReport(c context.Context, mid, aid, pn, ps int64, upOp int8, states []int64) (res *model.SearchReportResult, err error)
- func (d *Dao) SearchReportAid(c context.Context, mid int64, upOp int8, states []int8, pn, ps int64) (aids []int64, err error)
- func (d *Dao) SendAction(c context.Context, k string, act *model.ReportAction) (err error)
- func (d *Dao) SendNotify(c context.Context, title, content string, mids []int64) (err error)
- func (d *Dao) SetReportUserFinished(c context.Context, dmid int64) (err error)
- func (d *Dao) SetTransferState(c context.Context, id int64, state int8) (affect int64, err error)
- func (d *Dao) Subject(c context.Context, tp int32, oid int64) (s *model.Subject, err error)
- func (d *Dao) TransferList(c context.Context, cid int64) (l []*model.TransferHistory, err error)
- func (d *Dao) UpdateDMStat(c context.Context, tp int32, oid int64, state int32, dmids []int64) (affect int64, err error)
- func (d *Dao) UpdateReportStat(c context.Context, cid, dmid int64, state int8) (affect int64, err error)
- func (d *Dao) UpdateReportUPOp(c context.Context, cid, dmid int64, op int8) (affect int64, err error)
- func (d *Dao) UpdateSearchReport(c context.Context, rpts []*model.UptSearchReport) (err error)
- func (d *Dao) UptPaNoticeSwitch(c context.Context, uid int64, status int) (affect int64, err error)
- func (d *Dao) UptPaStatus(c context.Context, uid int64, ids string, status int) (affect int64, err error)
- func (d *Dao) UptRecallCnt(c context.Context, uid int64) (err error)
- func (d *Dao) UptRptCnt(c context.Context, uid int64) (n int64, err error)
- func (d *Dao) UptUsrPaCnt(c context.Context, uid int64, count int64) (err error)
- func (d *Dao) UsrDMAccCnt(c context.Context, uid int64, t int64) (cnt int64, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Dao ¶
type Dao struct {
// contains filtered or unexported fields
}
Dao dao struct
func (*Dao) AddProtectApply ¶
AddProtectApply 添加保护弹幕申请
func (*Dao) AddReportLog ¶
AddReportLog add report log.
func (*Dao) AddReportUser ¶
AddReportUser add dm report user.
func (*Dao) AddRptBrig ¶
AddRptBrig 将用户禁闭,30分钟不让举报
func (*Dao) AddTransferJob ¶
func (d *Dao) AddTransferJob(c context.Context, fromCid, toCid, mid int64, offset float64, state int8) (affect int64, err error)
AddTransferJob add transfer job.
func (*Dao) CheckTransferID ¶
CheckTransferID check transfer job state by id
func (*Dao) CheckTransferJob ¶
func (d *Dao) CheckTransferJob(c context.Context, fromCid, toCid int64) (job *model.TransferJob, err error)
CheckTransferJob check transfer job state.
func (*Dao) ContentSpecial ¶
func (d *Dao) ContentSpecial(c context.Context, dmid int64) (contentSpe *model.ContentSpecial, err error)
ContentSpecial get special dm content by dmids.
func (*Dao) Contents ¶
func (d *Dao) Contents(c context.Context, oid int64, dmids []int64) (res []*model.Content, err error)
Contents multi get dm content by dmids.
func (*Dao) ContentsSpecial ¶
func (d *Dao) ContentsSpecial(c context.Context, dmids []int64) (res map[int64]*model.ContentSpecial, err error)
ContentsSpecial multi get special dm content by dmids.
func (*Dao) FigureInfo ¶
FigureInfo .
func (*Dao) IndexsByID ¶
func (d *Dao) IndexsByID(c context.Context, tp int32, oid int64, dmids []int64) (res map[int64]*model.DM, special []int64, err error)
IndexsByID get dm index by dmids.
func (*Dao) PaNoticeClose ¶
PaNoticeClose 获取关闭申请保护弹幕站内通知
func (*Dao) ProtectAids ¶
ProtectAids 被申请保护弹幕稿件列表
func (*Dao) ProtectApplies ¶
func (d *Dao) ProtectApplies(c context.Context, uid, aid int64, order string) (res []*model.Apply, err error)
ProtectApplies 保护弹幕申请列表
func (*Dao) ProtectApplyByIDs ¶
func (d *Dao) ProtectApplyByIDs(c context.Context, uid int64, ids string) (res map[int64][]int64, err error)
ProtectApplyByIDs get protect apply by dmid
func (*Dao) ProtectApplyStatistics ¶
ProtectApplyStatistics 保护弹幕申请up统计
func (*Dao) ProtectApplyTime ¶
ProtectApplyTime 根据dmid获取保护弹幕申请
func (*Dao) ReportUser ¶
ReportUser return report use list of dmid.
func (*Dao) RptBrigTime ¶
RptBrigTime 获得禁闭的开始时间
func (*Dao) SearchReport ¶
func (d *Dao) SearchReport(c context.Context, mid, aid, pn, ps int64, upOp int8, states []int64) (res *model.SearchReportResult, err error)
SearchReport 根据up主id,稿件id获取举报弹幕列表
func (*Dao) SearchReportAid ¶
func (d *Dao) SearchReportAid(c context.Context, mid int64, upOp int8, states []int8, pn, ps int64) (aids []int64, err error)
SearchReportAid 根据mid获取用户的所有有举报弹幕的稿件
func (*Dao) SendAction ¶
SendAction send action to job.
func (*Dao) SendNotify ¶
SendNotify 发送站内信
func (*Dao) SetReportUserFinished ¶
SetReportUserFinished set dmid state to be noticesend.
func (*Dao) SetTransferState ¶
SetTransferState change transfer state
func (*Dao) TransferList ¶
TransferList cid 的转移历史
func (*Dao) UpdateDMStat ¶
func (d *Dao) UpdateDMStat(c context.Context, tp int32, oid int64, state int32, dmids []int64) (affect int64, err error)
UpdateDMStat edit dm state
func (*Dao) UpdateReportStat ¶
func (d *Dao) UpdateReportStat(c context.Context, cid, dmid int64, state int8) (affect int64, err error)
UpdateReportStat update report state
func (*Dao) UpdateReportUPOp ¶
func (d *Dao) UpdateReportUPOp(c context.Context, cid, dmid int64, op int8) (affect int64, err error)
UpdateReportUPOp update dm report state.
func (*Dao) UpdateSearchReport ¶
UpdateSearchReport update report search index.
func (*Dao) UptPaNoticeSwitch ¶
UptPaNoticeSwitch 设置申请保护弹幕站内通知开关
func (*Dao) UptPaStatus ¶
func (d *Dao) UptPaStatus(c context.Context, uid int64, ids string, status int) (affect int64, err error)
UptPaStatus 修改保护弹幕状态
func (*Dao) UptRecallCnt ¶
UptRecallCnt 更新撤回弹幕计数
func (*Dao) UptUsrPaCnt ¶
UptUsrPaCnt 设置申请保护弹幕数