dao

package
v0.0.0-...-83adff0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 6, 2020 License: GPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PromCacheHit 

func PromCacheHit(name string)

PromCacheHit prom cache hit

func PromCacheMiss 

func PromCacheMiss(name string)

PromCacheMiss prom cache hit

func RptLogTable 

func RptLogTable(dmid int64) int64

RptLogTable return log table id by dmid

Types

type Dao 

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

Dao dao struct

func New 

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

New new a dao and return.

func (*Dao) AddProtectApply 

func (d *Dao) AddProtectApply(c context.Context, pas []*model.Pa) (affect int64, err error)

AddProtectApply 添加保护弹幕申请

func (*Dao) AddReport 

func (d *Dao) AddReport(c context.Context, rpt *model.Report) (id int64, err error)

AddReport insert or update dm report.

func (*Dao) AddReportLog 

func (d *Dao) AddReportLog(c context.Context, lg *model.RptLog) (err error)

AddReportLog add report log.

func (*Dao) AddReportUser 

func (d *Dao) AddReportUser(c context.Context, u *model.User) (id int64, err error)

AddReportUser add dm report user.

func (*Dao) AddRptBrig 

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

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 

func (d *Dao) CheckTransferID(c context.Context, id int64) (job *model.TransferJob, err error)

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) CidInfo 

func (d *Dao) CidInfo(c context.Context, cid int64) (info *model.CidInfo, err error)

CidInfo 获取cid详细信息

func (*Dao) Content 

func (d *Dao) Content(c context.Context, oid, dmid int64) (ct *model.Content, err error)

Content dm content by dmid

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 

func (d *Dao) FigureInfo(c context.Context, mid int64) (score int32, err error)

FigureInfo .

func (*Dao) Index 

func (d *Dao) Index(c context.Context, tp int32, oid, dmid int64) (dm *model.DM, err error)

Index get index by dmid

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) PaLock 

func (d *Dao) PaLock(c context.Context, key string) (incr int, err error)

PaLock redis定时任务锁，保证只有一个地方在执行定时任务

func (*Dao) PaNoticeClose 

func (d *Dao) PaNoticeClose(c context.Context, uids []int64) (res map[int64]bool, err error)

PaNoticeClose 获取关闭申请保护弹幕站内通知

func (*Dao) PaUsrCnt 

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

PaUsrCnt 保护弹幕申请计数

func (*Dao) PaUsrStat 

func (d *Dao) PaUsrStat(c context.Context) (res []*model.ApplyUserStat, err error)

PaUsrStat 保护弹幕申请用户统计

func (*Dao) Ping 

func (d *Dao) Ping(c context.Context) (err error)

Ping ping dao status

func (*Dao) ProtectAids 

func (d *Dao) ProtectAids(c context.Context, uid int64) (res []int64, err error)

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 

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

ProtectApplyStatistics 保护弹幕申请up统计

func (*Dao) ProtectApplyTime 

func (d *Dao) ProtectApplyTime(c context.Context, dmid int64) (t time.Time, err error)

ProtectApplyTime 根据dmid获取保护弹幕申请

func (*Dao) RecallCnt 

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

RecallCnt 撤回弹幕计数

func (*Dao) Report 

func (d *Dao) Report(c context.Context, cid, dmid int64) (rpt *model.Report, err error)

Report dm report info by cid and dmid.

func (*Dao) ReportLog 

func (d *Dao) ReportLog(c context.Context, dmid int64) (res []*model.RptLog, err error)

ReportLog get report log of dmid.

func (*Dao) ReportUser 

func (d *Dao) ReportUser(c context.Context, dmid int64) (users []*model.User, err error)

ReportUser return report use list of dmid.

func (*Dao) RptBrigTime 

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

RptBrigTime 获得禁闭的开始时间

func (*Dao) RptCnt 

func (d *Dao) RptCnt(c context.Context, uid int64) (n int, err error)

RptCnt 弹幕举报一分钟计数

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 

func (d *Dao) SendAction(c context.Context, k string, act *model.ReportAction) (err error)

SendAction send action to job.

func (*Dao) SendNotify 

func (d *Dao) SendNotify(c context.Context, title, content string, mids []int64) (err error)

SendNotify 发送站内信

func (*Dao) SetReportUserFinished 

func (d *Dao) SetReportUserFinished(c context.Context, dmid int64) (err error)

SetReportUserFinished set dmid state to be noticesend.

func (*Dao) SetTransferState 

func (d *Dao) SetTransferState(c context.Context, id int64, state int8) (affect int64, err error)

SetTransferState change transfer state

func (*Dao) Subject 

func (d *Dao) Subject(c context.Context, tp int32, oid int64) (s *model.Subject, err error)

Subject get subject info from db.

func (*Dao) TransferList 

func (d *Dao) TransferList(c context.Context, cid int64) (l []*model.TransferHistory, err error)

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 

func (d *Dao) UpdateSearchReport(c context.Context, rpts []*model.UptSearchReport) (err error)

UpdateSearchReport update report search index.

func (*Dao) UptPaNoticeSwitch 

func (d *Dao) UptPaNoticeSwitch(c context.Context, uid int64, status int) (affect int64, err error)

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 

func (d *Dao) UptRecallCnt(c context.Context, uid int64) (err error)

UptRecallCnt 更新撤回弹幕计数

func (*Dao) UptRptCnt 

func (d *Dao) UptRptCnt(c context.Context, uid int64) (n int64, err error)

UptRptCnt 更新一分钟的弹幕举报数

func (*Dao) UptUsrPaCnt 

func (d *Dao) UptUsrPaCnt(c context.Context, uid int64, count int64) (err error)

UptUsrPaCnt 设置申请保护弹幕数

func (*Dao) UsrDMAccCnt 

func (d *Dao) UsrDMAccCnt(c context.Context, uid int64, t int64) (cnt int64, err error)

UsrDMAccCnt 我的弹幕访问计数

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.