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: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Dao 

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

Dao struct info of Dao.

func New 

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

New new a Dao and return.

func (*Dao) AddBlockInfo 

func (d *Dao) AddBlockInfo(c context.Context, b *model.BlockedInfo, ts time.Time) (id int64, err error)

AddBlockInfo add user block info.

func (*Dao) AddBlockInfoIdx 

func (d *Dao) AddBlockInfoIdx(c context.Context, bl *model.BlockedInfo) (err error)

AddBlockInfoIdx ZADD block info idx.

func (*Dao) AddBlockedCase 

func (d *Dao) AddBlockedCase(c context.Context, ca *model.Case) (err error)

AddBlockedCase add blocked case.

func (*Dao) AddBlockedCaseModifyLog 

func (d *Dao) AddBlockedCaseModifyLog(c context.Context, cid int64, mType, oReason, mReason int8) (err error)

AddBlockedCaseModifyLog add blocked case modify log.

func (*Dao) AddMoney 

func (d *Dao) AddMoney(c context.Context, mid int64, money float64, reason string) (err error)

AddMoney Modify user Coins（old）.

func (*Dao) AddMoral 

func (d *Dao) AddMoral(c context.Context, mid int64, moral float64, reasonType int8, oper, reason, remark, remoteIP string) (err error)

AddMoral add or reduce moral to user

func (*Dao) AutoCaseConf 

func (d *Dao) AutoCaseConf(c context.Context, otype int8) (ac *model.AutoCaseConf, err error)

AutoCaseConf get auto case config.

func (*Dao) BlockAccount 

func (d *Dao) BlockAccount(c context.Context, r *model.BlockedInfo) (err error)

BlockAccount block account.

func (*Dao) BlockedInfoID 

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

BlockedInfoID get user blocked new info.

func (*Dao) CaseApplyReasonNum 

func (d *Dao) CaseApplyReasonNum(c context.Context, cid int64, aReasons []int64) (cas []*model.CaseApplyModifyLog, err error)

CaseApplyReasonNum case group apply reasons num.

func (*Dao) CaseApplyReasons 

func (d *Dao) CaseApplyReasons(c context.Context, cid int64) (aReasons []int64, err error)

CaseApplyReasons case apply reasons.

func (*Dao) CaseByID 

func (d *Dao) CaseByID(c context.Context, id int64) (res model.Case, err error)

CaseByID get case info by id.

func (*Dao) CaseRelationIDCount 

func (d *Dao) CaseRelationIDCount(c context.Context, tp int8, relationID string) (count int64, err error)

CaseRelationIDCount get case relation_id count.

func (*Dao) CaseVote 

func (d *Dao) CaseVote(c context.Context, id int64) (res *model.CaseVote, err error)

CaseVote get blocked case vote info.

func (*Dao) CaseVotesCID 

func (d *Dao) CaseVotesCID(c context.Context, cid int64) (res []*model.CaseVote, err error)

CaseVotesCID is blocked case vote list by cid.

func (*Dao) CasesStatus 

func (d *Dao) CasesStatus(c context.Context, cids []int64) (map[int64]int8, error)

CasesStatus get cases status.

func (*Dao) CheckFilter 

func (d *Dao) CheckFilter(c context.Context, area, msg, ip string) (need bool, err error)

CheckFilter check content filter.

func (*Dao) Close 

func (d *Dao) Close()

Close close connections of mc, redis, db.

func (*Dao) CountBlocked 

func (d *Dao) CountBlocked(c context.Context, uid int64, ts time.Time) (count int64, err error)

CountBlocked get user block count ofter ts.

func (*Dao) CountCaseMID 

func (d *Dao) CountCaseMID(c context.Context, mid int64, tp int8) (count int64, err error)

CountCaseMID get count case by mid.

func (*Dao) CountKPIRate 

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

CountKPIRate count KPI rate<=4(C).

func (*Dao) DelAnswerStateCache 

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

DelAnswerStateCache del answer state cache info.

func (*Dao) DelBlockedInfoIdx 

func (d *Dao) DelBlockedInfoIdx(c context.Context, bl *model.BlockedInfo) (err error)

DelBlockedInfoIdx ZREM block info idx.

func (*Dao) DelCaseIdx 

func (d *Dao) DelCaseIdx(c context.Context, cid int64) (err error)

DelCaseIdx DEL case opinion idx.

func (*Dao) DelCaseInfoCache 

func (d *Dao) DelCaseInfoCache(c context.Context, cid int64) (err error)

DelCaseInfoCache del case info cache info.

func (*Dao) DelCaseVoteTopCache 

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

DelCaseVoteTopCache del case vote total cache.

func (*Dao) DelGrantCase 

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

DelGrantCase del grant case id.

func (*Dao) DelJuryInfoCache 

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

DelJuryInfoCache del jury cache info.

func (*Dao) DelOpinionCache 

func (d *Dao) DelOpinionCache(c context.Context, vid int64) (err error)

DelOpinionCache del opinion cache info.

func (*Dao) DelReply 

func (d *Dao) DelReply(c context.Context, rpid, tp, oid string) (err error)

DelReply del reply.

func (*Dao) DelTag 

func (d *Dao) DelTag(c context.Context, tid, aid string) (err error)

DelTag del tag.

func (*Dao) DelVoteCaseCache 

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

DelVoteCaseCache del vote case cache info.

func (*Dao) DelVoteIdx 

func (d *Dao) DelVoteIdx(c context.Context, cid int64) (err error)

DelVoteIdx DEL case opinion idx.

func (*Dao) GrantCases 

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

GrantCases get granting case cids.

func (*Dao) Grantcase 

func (d *Dao) Grantcase(c context.Context, limit int) (mcases map[int64]*model.SimCase, err error)

Grantcase get case from state of CaseStatusQueueing.

func (*Dao) InvalidJury 

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

InvalidJury set jury invalid.

func (*Dao) KPIInfo 

func (d *Dao) KPIInfo(c context.Context, id int64) (res model.Kpi, err error)

KPIInfo get KPI info.

func (*Dao) KPIList 

func (d *Dao) KPIList(c context.Context, day string) (res []model.Kpi, err error)

KPIList get kpi list.

func (*Dao) LoadConf 

func (d *Dao) LoadConf(c context.Context) (cf map[string]string, err error)

LoadConf load conf.

func (*Dao) Ping 

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

Ping ping health of db.

func (*Dao) RegReply 

func (d *Dao) RegReply(c context.Context, id int64, tid int8) (err error)

RegReply del reply.

func (*Dao) ReportDM 

func (d *Dao) ReportDM(c context.Context, cid string, dmid string, result int64) (err error)

ReportDM report dm is delete.

func (*Dao) SendMedal 

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

SendMedal send Medal.

func (*Dao) SendMsg 

func (d *Dao) SendMsg(c context.Context, mid int64, title string, context string) (err error)

SendMsg send message.

func (*Dao) SendPendant 

func (d *Dao) SendPendant(c context.Context, mid int64, pids []int64, day int64) (err error)

SendPendant send pendant.

func (*Dao) SetGrantCase 

func (d *Dao) SetGrantCase(c context.Context, mcases map[int64]*model.SimCase) (err error)

SetGrantCase set grant case ids.

func (*Dao) Sms 

func (d *Dao) Sms(c context.Context, phone, token, msg string) (err error)

Sms send monitor sms.

func (*Dao) TotalGrantCase 

func (d *Dao) TotalGrantCase(c context.Context) (count int, err error)

TotalGrantCase get length of grant case ids.

func (*Dao) UnBlockAccount 

func (d *Dao) UnBlockAccount(c context.Context, r *model.BlockedInfo) (err error)

UnBlockAccount unblock account.

func (*Dao) UpAppealState 

func (d *Dao) UpAppealState(c context.Context, bid, oid, eid int64) (err error)

UpAppealState .

func (*Dao) UpBlockedCaseReason 

func (d *Dao) UpBlockedCaseReason(c context.Context, cid int64, reasonType int8) (affect int64, err error)

UpBlockedCaseReason update blocked case reason.

func (*Dao) UpBlockedCaseStatus 

func (d *Dao) UpBlockedCaseStatus(c context.Context, cid int64, status int8) (err error)

UpBlockedCaseStatus update blocked case status.

func (*Dao) UpGrantCase 

func (d *Dao) UpGrantCase(c context.Context, ids []int64, stime xtime.Time, etime xtime.Time) (err error)

UpGrantCase update blocked_case from que to granting.

func (*Dao) UpReplyState 

func (d *Dao) UpReplyState(c context.Context, oid, rpid int64, tp, state int8) (err error)

UpReplyState update reply state.

func (*Dao) UpdateCase 

func (d *Dao) UpdateCase(c context.Context, st, jt, id int64) (err error)

UpdateCase update case status to st.

func (*Dao) UpdateJuryExpired 

func (d *Dao) UpdateJuryExpired(c context.Context, mid int64, expired time.Time) (err error)

UpdateJuryExpired update jury expired.

func (*Dao) UpdateKPI 

func (d *Dao) UpdateKPI(c context.Context, id int64) (err error)

UpdateKPI update kpi status to st.

func (*Dao) UpdateKPIHandlerStatus 

func (d *Dao) UpdateKPIHandlerStatus(c context.Context, id int64) (err error)

UpdateKPIHandlerStatus update blocked_kpi handler status.

func (*Dao) UpdateKPIPendentStatus 

func (d *Dao) UpdateKPIPendentStatus(c context.Context, id int64) (err error)

UpdateKPIPendentStatus update blocked_kpi status to st.

func (*Dao) UpdatePunishResult 

func (d *Dao) UpdatePunishResult(c context.Context, id int64, punishResult int8) (err error)

UpdatePunishResult update table blocked_case punish_result field =0

func (*Dao) UpdateVoteRight 

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

UpdateVoteRight update vote total and vote right.

func (*Dao) UpdateVoteTotal 

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

UpdateVoteTotal update vote total.

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.