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: 22 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) AddAnsLog 

func (d *Dao) AddAnsLog(c context.Context, mid int64, score int64, anstr string, stime ctime.Time) (affect int64, err error)

AddAnsLog add labour answer log.

func (*Dao) AddAppeal 

func (d *Dao) AddAppeal(c context.Context, tid, btid, oid, mid, business int64, content, reason string) (err error)

AddAppeal add appeal.

func (*Dao) AddBlockedCases 

func (d *Dao) AddBlockedCases(c context.Context, bc []*model.ArgJudgeCase) (err error)

AddBlockedCases batch add blocked cases.

func (*Dao) AddBlockedInfo 

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

AddBlockedInfo add blocked info

func (*Dao) AddCaseReasonApply 

func (d *Dao) AddCaseReasonApply(c context.Context, mid, cid int64, applyType, originReason, applyReason int8) (err error)

AddCaseReasonApply add case reason apply log.

func (*Dao) AddCaseVoteTotal 

func (d *Dao) AddCaseVoteTotal(c context.Context, field string, cid int64, voteNum int8) (err error)

AddCaseVoteTotal add case vote total.

func (*Dao) AddHates 

func (d *Dao) AddHates(c context.Context, ids []int64) (affect int64, err error)

AddHates add user like opinions.

func (*Dao) AddLikes 

func (d *Dao) AddLikes(c context.Context, ids []int64) (affect int64, err error)

AddLikes add user like opinions.

func (*Dao) AddOpinionCache 

func (d *Dao) AddOpinionCache(c context.Context, op *model.Opinion) (err error)

AddOpinionCache add opinion cache.

func (*Dao) AddOpinionTx 

func (d *Dao) AddOpinionTx(tx *sql.Tx, cid, opid, mid int64, content string, attr, vote, state int8) (affect int64, err error)

AddOpinionTx add user opinion by transaction.

func (*Dao) AddQs 

func (d *Dao) AddQs(c context.Context, qs *model.LabourQs) (err error)

AddQs add labour question log.

func (*Dao) AddUserVoteTotal 

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

AddUserVoteTotal add user vote total.

func (*Dao) AnnouncementInfo 

func (d *Dao) AnnouncementInfo(c context.Context, aid int64) (r *model.BlockedAnnouncement, err error)

AnnouncementInfo get announcement detail.

func (*Dao) AnnouncementList 

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

AnnouncementList get accnoucement list.

func (*Dao) AnswerStatus 

func (d *Dao) AnswerStatus(c context.Context, mid int64, ts time.Time) (status bool, err error)

AnswerStatus get blocked user answer status.

func (*Dao) AppealList 

func (d *Dao) AppealList(c context.Context, mid int64, business int) (as []*model.Appeal, err error)

AppealList appeal list .

func (*Dao) BLKHistoryCount 

func (d *Dao) BLKHistoryCount(c context.Context, ArgHis *model.ArgHistory) (count int64, err error)

BLKHistoryCount get blocked historys count.

func (*Dao) BLKHistorys 

func (d *Dao) BLKHistorys(c context.Context, ah *model.ArgHistory) (res []*model.BlockedInfo, err error)

BLKHistorys get blocked historys list.

func (*Dao) BatchPublishs 

func (d *Dao) BatchPublishs(c context.Context, ids []int64) (res map[int64]*model.BlockedAnnouncement, err error)

BatchPublishs get publish info list.

func (*Dao) BeginTran 

func (d *Dao) BeginTran(c context.Context) (*sql.Tx, error)

BeginTran begin mysql transaction.

func (*Dao) BlockTotalTime 

func (d *Dao) BlockTotalTime(c context.Context, mid int64, ts time.Time) (total int64, err error)

BlockTotalTime get block total by time.

func (*Dao) BlockedCount 

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

BlockedCount get user blocked count.

func (*Dao) BlockedIdxCache 

func (d *Dao) BlockedIdxCache(c context.Context, otype, btype int8, start, end int) (ids []int64, err error)

BlockedIdxCache get block list idx.

func (*Dao) BlockedInfoByID 

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

BlockedInfoByID get blocked info by id.

func (*Dao) BlockedInfoCache 

func (d *Dao) BlockedInfoCache(c context.Context, id int64) (info *model.BlockedInfo, err error)

BlockedInfoCache get blocked info by blocked id.

func (*Dao) BlockedInfoIDs 

func (d *Dao) BlockedInfoIDs(c context.Context, ids []int64) (res map[int64]*model.BlockedInfo, err error)

BlockedInfoIDs get blocked info by ids

func (*Dao) BlockedInfos 

func (d *Dao) BlockedInfos(c context.Context, ids []int64) (res []*model.BlockedInfo, err error)

BlockedInfos get blocked infos. Queryed without mid or id, public default.

func (*Dao) BlockedInfosCache 

func (d *Dao) BlockedInfosCache(c context.Context, ids []int64) (infos []*model.BlockedInfo, miss []int64, err error)

BlockedInfosCache get blocked infos by ids.

func (*Dao) BlockedList 

func (d *Dao) BlockedList(c context.Context, otype, btype int8) (res []*model.BlockedInfo, err error)

BlockedList get blocked list.

func (*Dao) BlockedNumUser 

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

BlockedNumUser get blocked user number.

func (*Dao) BlockedUserList 

func (d *Dao) BlockedUserList(c context.Context, mid int64) (res []*model.BlockedInfo, err error)

BlockedUserList get user blocked list.

func (*Dao) BlockedUserListCache 

func (d *Dao) BlockedUserListCache(c context.Context, mid int64) (ls []*model.BlockedInfo, err error)

BlockedUserListCache get user blocked list.

func (*Dao) CaseInfo 

func (d *Dao) CaseInfo(c context.Context, cid int64) (r *model.BlockedCase, err error)

CaseInfo jury get case info.

func (*Dao) CaseInfoCache 

func (d *Dao) CaseInfoCache(c context.Context, cid int64) (bc *model.BlockedCase, err error)

CaseInfoCache get case info cache

func (*Dao) CaseInfoIDs 

func (d *Dao) CaseInfoIDs(c context.Context, ids []int64) (cases map[int64]*model.BlockedCase, err error)

CaseInfoIDs get case info by ids.

func (*Dao) CaseObtainMID 

func (d *Dao) CaseObtainMID(c context.Context, mid int64, isToday bool) (cases map[int64]*model.SimCase, err error)

CaseObtainMID get voted cids by MID.

func (*Dao) CaseOpIdxCache 

func (d *Dao) CaseOpIdxCache(c context.Context, cid, start, end int64) (ids []int64, err error)

CaseOpIdxCache get case opinion index from cache.

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

func (d *Dao) CaseVoteIDMID(c context.Context, mid, pn, ps int64) (vids []int64, cids []int64, err error)

CaseVoteIDMID get user's vote case ids and cids.

func (*Dao) CaseVoteIDTop 

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

CaseVoteIDTop get user's vote case ids and cids by top 100.

func (*Dao) CaseVoteIDs 

func (d *Dao) CaseVoteIDs(c context.Context, ids []int64) (mbc map[int64]*model.BlockedCase, err error)

CaseVoteIDs get user's vote info by ids.

func (*Dao) CaseVoteTopCache 

func (d *Dao) CaseVoteTopCache(c context.Context, mid int64) (bs []*model.BlockedCase, err error)

CaseVoteTopCache get case votes by top 100.

func (*Dao) CaseVotesMID 

func (d *Dao) CaseVotesMID(c context.Context, ids []int64) (mvo map[int64]*model.VoteInfo, err error)

CaseVotesMID get user's vote case ids.

func (*Dao) Close 

func (d *Dao) Close()

Close close connections of mc, redis, db.

func (*Dao) CountCaseVote 

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

CountCaseVote jury count case vote total.

func (*Dao) DelCaseIdx 

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

DelCaseIdx DEL case opinion idx.

func (*Dao) DelJuryInfoCache 

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

DelJuryInfoCache del jury cache info.

func (*Dao) DelNoticeInfoCache 

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

DelNoticeInfoCache delete notice info cache.

func (*Dao) DelOpinion 

func (d *Dao) DelOpinion(c context.Context, opid int64) (err error)

DelOpinion del opinion.

func (*Dao) DelQs 

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

DelQs del labour question.

func (*Dao) DelQsCache 

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

DelQsCache delete labour questions cache.

func (*Dao) DelReasonListCache 

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

DelReasonListCache delete reason info cache.

func (*Dao) DelVoteIdx 

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

DelVoteIdx DEL case opinion idx.

func (*Dao) ExpireBlockedIdx 

func (d *Dao) ExpireBlockedIdx(c context.Context, otype, btype int8) (ok bool, err error)

ExpireBlockedIdx expire case index cache.

func (*Dao) ExpireCaseIdx 

func (d *Dao) ExpireCaseIdx(c context.Context, cid int64) (ok bool, err error)

ExpireCaseIdx expire case index cache.

func (*Dao) ExpireVoteIdx 

func (d *Dao) ExpireVoteIdx(c context.Context, cid int64, otype int8) (ok bool, err error)

ExpireVoteIdx expire vote idx.

func (*Dao) GetAnswerStateCache 

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

GetAnswerStateCache get labour answer state cache.

func (*Dao) GetQS 

func (dao *Dao) GetQS(c context.Context, mid int64) (qs *model.AIQsID, err error)

GetQS get question from big data.

func (*Dao) GetQsCache 

func (d *Dao) GetQsCache(c context.Context, mid int64) (qsid *model.QsCache, err error)

GetQsCache get labour qestions info cache.

func (*Dao) GrantCases 

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

GrantCases get granting case cids.

func (*Dao) InsVote 

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

InsVote insert user vote.

func (*Dao) IsExpiredObtainMID 

func (d *Dao) IsExpiredObtainMID(c context.Context, mid int64, isToday bool) (ok bool, err error)

IsExpiredObtainMID voted cids by MID of key is expired.

func (*Dao) IsVote 

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

IsVote jury user is vote.

func (*Dao) JuryApply 

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

JuryApply user jury apply.

func (*Dao) JuryInfo 

func (d *Dao) JuryInfo(c context.Context, mid int64) (r *model.BlockedJury, err error)

JuryInfo get user's jury info

func (*Dao) JuryInfoCache 

func (d *Dao) JuryInfoCache(c context.Context, mid int64) (bj *model.BlockedJury, err error)

JuryInfoCache .

func (*Dao) JuryInfos 

func (d *Dao) JuryInfos(c context.Context, mids []int64) (mbj map[int64]*model.BlockedJury, err error)

JuryInfos get user's applying jury info

func (*Dao) KPIList 

func (d *Dao) KPIList(c context.Context, mid int64) (res []*model.KPIData, err error)

KPIList get kpi list.

func (*Dao) LastAuditQuestion 

func (d *Dao) LastAuditQuestion(c context.Context) (res []*model.LabourQs, avIDs []int64, err error)

LastAuditQuestion get new audit question data.

func (*Dao) LastNoAuditQuestion 

func (d *Dao) LastNoAuditQuestion(c context.Context) (res []*model.LabourQs, avIDs []int64, err error)

LastNoAuditQuestion get new no audit question data.

func (*Dao) LenCaseIdx 

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

LenCaseIdx get lenth of vote index.

func (*Dao) LenVoteIdx 

func (d *Dao) LenVoteIdx(c context.Context, cid int64, otype int8) (count int, err error)

LenVoteIdx get lenth of vote index.

func (*Dao) LoadBlockedIdx 

func (d *Dao) LoadBlockedIdx(c context.Context, otype, btype int8, infos []*model.BlockedInfo) (err error)

LoadBlockedIdx laod blocked info index.

func (*Dao) LoadCaseIdxs 

func (d *Dao) LoadCaseIdxs(c context.Context, cid int64, ops []*model.Opinion) (err error)

LoadCaseIdxs load case opinion index into redis.

func (*Dao) LoadConf 

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

LoadConf load conf.

func (*Dao) LoadVoteCaseMID 

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

LoadVoteCaseMID load mid vote cases.

func (*Dao) LoadVoteIDsMid 

func (d *Dao) LoadVoteIDsMid(c context.Context, mid int64, day int) (cases map[int64]*model.SimCase, err error)

LoadVoteIDsMid load user vote case ids.

func (*Dao) LoadVoteOpIdxs 

func (d *Dao) LoadVoteOpIdxs(c context.Context, cid int64, otype int8, idx []int64) (err error)

LoadVoteOpIdxs load vote opinion index into cache.

func (*Dao) Manager 

func (d *Dao) Manager(c context.Context, pn, ps int64) (mi []*model.MangerInfo, err error)

Manager get manager users.

func (*Dao) ManagerTotal 

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

ManagerTotal get manager user total.

func (*Dao) Managers 

func (d *Dao) Managers(c context.Context) (manMap map[string]int64, err error)

Managers get manager users info.

func (*Dao) NewKPI 

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

NewKPI return user newest KPI rate.

func (*Dao) Notice 

func (d *Dao) Notice(c context.Context) (n *model.Notice, err error)

Notice get notice

func (*Dao) NoticeInfoCache 

func (d *Dao) NoticeInfoCache(c context.Context) (dt *model.Notice, err error)

NoticeInfoCache get notice info cache.

func (*Dao) OpContentMid 

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

OpContentMid get opinion content.

func (*Dao) OpinionCaseIdx 

func (d *Dao) OpinionCaseIdx(c context.Context, cid int64) (ops []*model.Opinion, err error)

OpinionCaseIdx get opinion case index.

func (*Dao) OpinionIdx 

func (d *Dao) OpinionIdx(c context.Context, cid int64) (ops []*model.Opinion, err error)

OpinionIdx get opinion index.

func (*Dao) Opinions 

func (d *Dao) Opinions(c context.Context, opids []int64) (ops []*model.Opinion, err error)

Opinions get opinions.

func (*Dao) OpinionsCache 

func (d *Dao) OpinionsCache(c context.Context, opids []int64) (ops map[int64]*model.Opinion, miss []int64, err error)

OpinionsCache get opids opinion detail.

func (*Dao) Ping 

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

Ping ping health.

func (*Dao) PubLabour 

func (d *Dao) PubLabour(c context.Context, aid int64, msg interface{}) (err error)

PubLabour pub labour answer log msg into databus.

func (*Dao) QsAllList 

func (d *Dao) QsAllList(c context.Context, idStr string) (mlab map[int64]*model.LabourQs, labs []*model.LabourQs, avIDs []int64, err error)

QsAllList get question list.

func (*Dao) QsList 

func (d *Dao) QsList(c context.Context, idStr string) (res []*model.LabourQs, err error)

QsList get question list.

func (*Dao) ReasonList 

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

ReasonList get reason list

func (*Dao) ReasonListCache 

func (d *Dao) ReasonListCache(c context.Context) (dt []*model.Reason, err error)

ReasonListCache get Reason info cache.

func (*Dao) ReplysCount 

func (dao *Dao) ReplysCount(c context.Context, oid []int64) (counts map[string]int64, err error)

ReplysCount get reply count.

func (*Dao) SendMedal 

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

SendMedal send mdal.

func (*Dao) SendSysMsg 

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

SendSysMsg send msg.

func (*Dao) SetAnswerStateCache 

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

SetAnswerStateCache set labour answer state cache.

func (*Dao) SetBlockedInfoCache 

func (d *Dao) SetBlockedInfoCache(c context.Context, id int64, info *model.BlockedInfo) (err error)

SetBlockedInfoCache set user blocked list cache.

func (*Dao) SetBlockedInfosCache 

func (d *Dao) SetBlockedInfosCache(c context.Context, infos []*model.BlockedInfo) (err error)

SetBlockedInfosCache set user blocked list cache.

func (*Dao) SetBlockedUserListCache 

func (d *Dao) SetBlockedUserListCache(c context.Context, mid int64, ls []*model.BlockedInfo) (err error)

SetBlockedUserListCache set user blocked list cache.

func (*Dao) SetCaseInfoCache 

func (d *Dao) SetCaseInfoCache(c context.Context, cid int64, bc *model.BlockedCase) (err error)

SetCaseInfoCache set case info.

func (*Dao) SetCaseVoteTopCache 

func (d *Dao) SetCaseVoteTopCache(c context.Context, mid int64, bs []*model.BlockedCase) (err error)

SetCaseVoteTopCache set case votes by top 100.

func (*Dao) SetJuryInfoCache 

func (d *Dao) SetJuryInfoCache(c context.Context, mid int64, bj *model.BlockedJury) (err error)

SetJuryInfoCache .

func (*Dao) SetNoticeInfoCache 

func (d *Dao) SetNoticeInfoCache(c context.Context, n *model.Notice) (err error)

SetNoticeInfoCache get Notice info cache.

func (*Dao) SetQs 

func (d *Dao) SetQs(c context.Context, id int64, ans int64, status int64) (err error)

SetQs set labour question field.

func (*Dao) SetQsCache 

func (d *Dao) SetQsCache(c context.Context, mid int64, qsid *model.QsCache) (err error)

SetQsCache set labour questions cache.

func (*Dao) SetReasonListCache 

func (d *Dao) SetReasonListCache(c context.Context, dt []*model.Reason) (err error)

SetReasonListCache get notice info cache.

func (*Dao) SetVoteCaseMID 

func (d *Dao) SetVoteCaseMID(c context.Context, mid int64, sc *model.SimCase) (err error)

SetVoteCaseMID set vote case by mid on today.

func (*Dao) SetVoteInfoCache 

func (d *Dao) SetVoteInfoCache(c context.Context, mid, cid int64, vi *model.VoteInfo) (err error)

SetVoteInfoCache set vote case info.

func (*Dao) SetVoteTx 

func (d *Dao) SetVoteTx(tx *sql.Tx, mid, cid int64, vote int8) (affect int64, err error)

SetVoteTx set vote info by tx.

func (*Dao) Setvote 

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

Setvote set user vote.

func (*Dao) TxAddBlockedInfo 

func (d *Dao) TxAddBlockedInfo(tx *sql.Tx, rs []*model.BlockedInfo) (err error)

TxAddBlockedInfo add blocked info

func (*Dao) VoteInfo 

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

VoteInfo jury user get vote info.

func (*Dao) VoteInfoCache 

func (d *Dao) VoteInfoCache(c context.Context, mid, cid int64) (vi *model.VoteInfo, err error)

VoteInfoCache get vote case info cache

func (*Dao) VoteOpIdxCache 

func (d *Dao) VoteOpIdxCache(c context.Context, cid, start, end int64, otype int8) (ids []int64, err error)

VoteOpIdxCache get vote opinion index from cache.

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.