reply

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AdminDao 

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

AdminDao define admin mysql info

func NewAdminDao 

func NewAdminDao(db *sql.DB) (dao *AdminDao)

NewAdminDao new ReplyReportDao and return.

func (*AdminDao) Insert 

func (dao *AdminDao) Insert(c context.Context, adminid, oid, rpID int64, tp int8, result, remark string, isnew, isreport, state int8, now time.Time) (id int64, err error)

Insert insert reply report.

func (*AdminDao) UpIsNotNew 

func (dao *AdminDao) UpIsNotNew(c context.Context, rpID int64, now time.Time) (rows int64, err error)

UpIsNotNew update reply report.

type BusinessDao 

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

BusinessDao business dao.

func NewBusinessDao 

func NewBusinessDao(db *sql.DB) (dao *BusinessDao)

NewBusinessDao new BusinessDao and return.

func (*BusinessDao) ListBusiness 

func (dao *BusinessDao) ListBusiness(c context.Context) (business []*reply.Business, err error)

ListBusiness gets all business records

type ContentDao 

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

ContentDao define content mysql stmt

func NewContentDao 

func NewContentDao(db *sql.DB) (dao *ContentDao)

NewContentDao new contentDao and return.

func (*ContentDao) Get 

func (dao *ContentDao) Get(c context.Context, oid int64, rpID int64) (rc *reply.Content, err error)

Get get reply content.

func (*ContentDao) TxInsert 

func (dao *ContentDao) TxInsert(tx *sql.Tx, oid int64, rc *reply.Content) (rows int64, err error)

TxInsert insert reply content by transaction.

type Dao 

type Dao struct {
	// memcache
	Mc *MemcacheDao

	Admin    *AdminDao
	Content  *ContentDao
	Report   *ReportDao
	Reply    *RpDao
	Subject  *SubjectDao
	Business *BusinessDao
	// redis
	Redis *RedisDao
	// contains filtered or unexported fields
}

Dao define mysql info

func New 

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

New new a db and return

func (*Dao) BeginTran 

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

BeginTran begin mysql transaction

func (*Dao) Close 

func (d *Dao) Close()

Close close all db connection

func (*Dao) Ping 

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

Ping check db is alive

func (*Dao) PubEvent 

func (d *Dao) PubEvent(c context.Context, action string, mid int64, sub *model.Subject, rp *model.Reply, report *model.Report) error

PubEvent pub reply event.

type MemcacheDao 

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

MemcacheDao define memcache info

func NewMemcacheDao 

func NewMemcacheDao(c *conf.Memcache) *MemcacheDao

NewMemcacheDao return a new mc dao

func (*MemcacheDao) AddReply 

func (dao *MemcacheDao) AddReply(c context.Context, rs ...*model.Reply) (err error)

AddReply add reply into memcache.

func (*MemcacheDao) AddSubject 

func (dao *MemcacheDao) AddSubject(c context.Context, subs ...*model.Subject) (err error)

AddSubject add subject into memcache.

func (*MemcacheDao) AddTop 

func (dao *MemcacheDao) AddTop(c context.Context, rp *model.Reply) (err error)

AddTop add top reply into memcache.

func (*MemcacheDao) DeleteReply 

func (dao *MemcacheDao) DeleteReply(c context.Context, rpID int64) (err error)

DeleteReply delete reply from memcache.

func (*MemcacheDao) DeleteSub 

func (dao *MemcacheDao) DeleteSub(c context.Context, oid int64, tp int8) (err error)

DeleteSub delete sub from memcache.

func (*MemcacheDao) DeleteTop 

func (dao *MemcacheDao) DeleteTop(c context.Context, rp *model.Reply, tp uint32) (err error)

DeleteTop delete topreply from memcache.

func (*MemcacheDao) GetReply 

func (dao *MemcacheDao) GetReply(c context.Context, rpID int64) (rp *model.Reply, err error)

GetReply get reply from memcache.

func (*MemcacheDao) GetSubject 

func (dao *MemcacheDao) GetSubject(c context.Context, oid int64, tp int8) (sub *model.Subject, err error)

GetSubject get subject from memcache.

func (*MemcacheDao) GetTop 

func (dao *MemcacheDao) GetTop(c context.Context, oid int64, tp int8, top uint32) (rp *model.Reply, err error)

GetTop get subject top reply from memcache

func (*MemcacheDao) Ping 

func (dao *MemcacheDao) Ping(c context.Context) (err error)

Ping check connection success.

type RedisDao 

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

RedisDao define redis dao

func NewRedisDao 

func NewRedisDao(c *conf.Redis) *RedisDao

NewRedisDao new redis dao

func (*RedisDao) AddAuditIndex 

func (dao *RedisDao) AddAuditIndex(c context.Context, rp *reply.Reply) (err error)

AddAuditIndex add audit reply index by user.

func (*RedisDao) AddCountIndex 

func (dao *RedisDao) AddCountIndex(c context.Context, oid int64, tp int8, rp *reply.Reply) (err error)

AddCountIndex add index by count.

func (*RedisDao) AddCountIndexBatch 

func (dao *RedisDao) AddCountIndexBatch(c context.Context, oid int64, tp int8, rs ...*reply.Reply) (err error)

AddCountIndexBatch add index by count.

func (*RedisDao) AddDialogIndex 

func (dao *RedisDao) AddDialogIndex(c context.Context, dialogID int64, rps []*reply.Reply) (err error)

AddDialogIndex add reply to a dialog

func (*RedisDao) AddFloorIndex 

func (dao *RedisDao) AddFloorIndex(c context.Context, oid int64, tp int8, rs ...*reply.Reply) (err error)

AddFloorIndex add index by floor.

func (*RedisDao) AddFloorIndexEnd 

func (dao *RedisDao) AddFloorIndexEnd(c context.Context, oid int64, tp int8) (err error)

AddFloorIndexEnd AddFloorIndexEnd

func (*RedisDao) AddFolderBatch 

func (dao *RedisDao) AddFolderBatch(c context.Context, kind string, ID int64, rps []*reply.Reply) (err error)

AddFolder ...

func (*RedisDao) AddIndex 

func (dao *RedisDao) AddIndex(c context.Context, oid int64, tp int8, rpt *reply.Report, rp *reply.Reply, isRecover bool) (err error)

AddIndex add reply index to redis.

func (*RedisDao) AddLike 

func (dao *RedisDao) AddLike(c context.Context, rpID int64, ras ...*reply.Action) (err error)

AddLike add actions into redis

func (*RedisDao) AddLikeIndex 

func (dao *RedisDao) AddLikeIndex(c context.Context, oid int64, tp int8, rpts map[int64]*reply.Report, r *reply.Reply) (err error)

AddLikeIndex add index by like.

func (*RedisDao) AddLikeIndexBatch 

func (dao *RedisDao) AddLikeIndexBatch(c context.Context, oid int64, tp int8, rpts map[int64]*reply.Report, rs ...*reply.Reply) (err error)

AddLikeIndexBatch add index by like.

func (*RedisDao) AddNewChildIndex 

func (dao *RedisDao) AddNewChildIndex(c context.Context, root int64, rs ...*reply.Reply) (err error)

AddNewChildIndex add root reply index by floor.

func (*RedisDao) AddTopOid 

func (dao *RedisDao) AddTopOid(c context.Context, oid int64, tp int8) (err error)

AddTopOid add oid to set twhich has top reply

func (*RedisDao) AddUserActs 

func (dao *RedisDao) AddUserActs(c context.Context, mid int64, actions map[int64]int8) (err error)

AddUserActs add user actions into redis.

func (*RedisDao) CountReplies 

func (dao *RedisDao) CountReplies(c context.Context, oid int64, tp, sort int8) (count int, err error)

CountReplies get count of reply.

func (*RedisDao) DelAuditIndexs 

func (dao *RedisDao) DelAuditIndexs(c context.Context, rs ...*reply.Reply) (err error)

DelAuditIndexs delete aduit reply cache.

func (*RedisDao) DelIndex 

func (dao *RedisDao) DelIndex(c context.Context, rp *reply.Reply) (err error)

DelIndex delete reply index.

func (*RedisDao) DelIndexBySortType 

func (dao *RedisDao) DelIndexBySortType(c context.Context, rp *reply.Reply, sortType int8) (err error)

DelIndexBySortType del index by sort.

func (*RedisDao) DelLike 

func (dao *RedisDao) DelLike(c context.Context, rpID int64, ra *reply.Action) (err error)

DelLike del user like from redis

func (*RedisDao) DelTopOid 

func (dao *RedisDao) DelTopOid(c context.Context, oid int64, tp int8) (err error)

DelTopOid delete oid from set

func (*RedisDao) DelUserAct 

func (dao *RedisDao) DelUserAct(c context.Context, mid int64, rpID int64) (err error)

DelUserAct add user actions into redis.

func (*RedisDao) ExpireDialogIndex 

func (dao *RedisDao) ExpireDialogIndex(c context.Context, dialogID int64) (ok bool, err error)

ExpireDialogIndex expire time for dialog index

func (*RedisDao) ExpireFolder 

func (dao *RedisDao) ExpireFolder(c context.Context, kind string, ID int64) (ok bool, err error)

ExpireFolder ...

func (*RedisDao) ExpireIndex 

func (dao *RedisDao) ExpireIndex(c context.Context, oid int64, tp, sort int8) (ok bool, err error)

ExpireIndex set expire time for index.

func (*RedisDao) ExpireLike 

func (dao *RedisDao) ExpireLike(c context.Context, rpID int64) (ok bool, err error)

ExpireLike set expire time for action.

func (*RedisDao) ExpireNewChildIndex 

func (dao *RedisDao) ExpireNewChildIndex(c context.Context, root int64) (ok bool, err error)

ExpireNewChildIndex set expire time for root's index.

func (*RedisDao) ExpireUserAct 

func (dao *RedisDao) ExpireUserAct(c context.Context, mid int64) (ok bool, err error)

ExpireUserAct set expire time for user actions.

func (*RedisDao) FloorEnd 

func (dao *RedisDao) FloorEnd(c context.Context, oid int64, tp int8) (score int, found bool, err error)

FloorEnd FloorEnd

func (*RedisDao) GetUserReportCnt 

func (dao *RedisDao) GetUserReportCnt(c context.Context, mid int64, now time.Time) (count int, err error)

GetUserReportCnt get user report count.

func (*RedisDao) GetUserReportTTL 

func (dao *RedisDao) GetUserReportTTL(c context.Context, mid int64, now time.Time) (ttl int, err error)

GetUserReportTTL get TTL of user report count redis.

func (*RedisDao) MaxLikeCnt 

func (dao *RedisDao) MaxLikeCnt(c context.Context, rpid int64) (cnt int, err error)

MaxLikeCnt return reply max like count.

func (*RedisDao) MinScore 

func (dao *RedisDao) MinScore(c context.Context, oid int64, tp int8, sort int8) (score int, err error)

MinScore get the lowest score from sorted set

func (*RedisDao) NotifyCnt 

func (dao *RedisDao) NotifyCnt(c context.Context, oid int64, typ int8) (cnt int, err error)

NotifyCnt return notify max count.

func (*RedisDao) Ping 

func (dao *RedisDao) Ping(c context.Context) (err error)

Ping check connection success.

func (*RedisDao) Range 

func (dao *RedisDao) Range(c context.Context, oid int64, tp, sort int8, start, end int) (rpIds []int64, err error)

Range range replyies.

func (*RedisDao) RankIndex 

func (dao *RedisDao) RankIndex(c context.Context, oid int64, tp int8, rpID int64, sort int8) (rank int, err error)

RankIndex get rank from reply index.

func (*RedisDao) RemFolder 

func (dao *RedisDao) RemFolder(c context.Context, kind string, ID, rpID int64) (err error)

RemFolder ...

func (*RedisDao) SetMaxLikeCnt 

func (dao *RedisDao) SetMaxLikeCnt(c context.Context, rpid, cnt int64) (err error)

SetMaxLikeCnt set reply max like count.

func (*RedisDao) SetNotifyCnt 

func (dao *RedisDao) SetNotifyCnt(c context.Context, oid int64, typ int8, cnt int) (err error)

SetNotifyCnt set notify max count.

func (*RedisDao) SetUserReportCnt 

func (dao *RedisDao) SetUserReportCnt(c context.Context, mid int64, count int, now time.Time) (err error)

SetUserReportCnt set user report count.

func (*RedisDao) SpamAction 

func (dao *RedisDao) SpamAction(c context.Context, mid int64) (code int, err error)

SpamAction return spam of add action

func (*RedisDao) SpamReply 

func (dao *RedisDao) SpamReply(c context.Context, mid int64) (rec, daily int, err error)

SpamReply return spam of add reply

func (*RedisDao) UserAct 

func (dao *RedisDao) UserAct(c context.Context, mid int64, rpID int64) (act int, err error)

UserAct get user action from redis.

func (*RedisDao) UserActs 

func (dao *RedisDao) UserActs(c context.Context, mid int64, rpids []int64) (acts map[int64]int8, err error)

UserActs get user actions from redis. NOTE: HGETALL quicker than HMEGT BUT transfer more data

type ReportDao 

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

ReportDao define report mysql stmt

func NewReportDao 

func NewReportDao(db *sql.DB) (dao *ReportDao)

NewReportDao new ReplyReportDao and return.

func (*ReportDao) Get 

func (dao *ReportDao) Get(c context.Context, oid, rpID int64) (rpt *model.Report, err error)

Get get a reply report.

func (*ReportDao) GetMapByOid 

func (dao *ReportDao) GetMapByOid(c context.Context, oid int64, typ int8) (res map[int64]*model.Report, err error)

GetMapByOid return report map by oid.

func (*ReportDao) GetUsers 

func (dao *ReportDao) GetUsers(c context.Context, oid int64, tp int8, rpID int64) (res map[int64]*model.ReportUser, err error)

GetUsers return a report users from mysql.

func (*ReportDao) SetUserReported 

func (dao *ReportDao) SetUserReported(c context.Context, oid int64, tp int8, rpID int64, now time.Time) (rows int64, err error)

SetUserReported set a user report state by rpID.

func (*ReportDao) Update 

func (dao *ReportDao) Update(c context.Context, rpt *model.Report) (rows int64, err error)

Update update reply report.

type RpDao 

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

RpDao define reply db sqlStmt

func NewReplyDao 

func NewReplyDao(db *sql.DB) (dao *RpDao)

NewReplyDao new replyDao and return.

func (*RpDao) FixDialogGetRepliesByRoot 

func (dao *RpDao) FixDialogGetRepliesByRoot(c context.Context, oid int64, tp int8, rootID int64) (rps []*reply.RpItem, err error)

FixDialogGetRepliesByRoot ...

func (*RpDao) FixDialogSetDialogBatch 

func (dao *RpDao) FixDialogSetDialogBatch(c context.Context, oid, dialog int64, rpIDs []int64)

FixDialogSetDialogBatch ...

func (*RpDao) FoldedReplies 

func (dao *RpDao) FoldedReplies(ctx context.Context, oid int64, tp int8, root int64) (rps []*reply.Reply, err error)

FoldedReplies ...

func (*RpDao) Get 

func (dao *RpDao) Get(c context.Context, oid, rpID int64) (r *reply.Reply, err error)

Get get reply.

func (*RpDao) GetAll 

func (dao *RpDao) GetAll(c context.Context, oid int64, tp int8) (rs []*reply.Reply, err error)

GetAll get all replies.

func (*RpDao) GetAllByFloor 

func (dao *RpDao) GetAllByFloor(ctx context.Context, oid int64, typ int8, start int, end int) (rs []*reply.Reply, err error)

GetAllByFloor GetAllByFloor

func (*RpDao) GetAllByRoot 

func (dao *RpDao) GetAllByRoot(c context.Context, oid, rpID int64, tp int8) (rs []*reply.Reply, err error)

GetAllByRoot get all replies by root reply.

func (*RpDao) GetAllInSlice 

func (dao *RpDao) GetAllInSlice(c context.Context, oid int64, typ int8, maxFloor int, shard int) (rs []*reply.Reply, err error)

GetAllInSlice GetAllInSlice

func (*RpDao) GetByCountLimit 

func (dao *RpDao) GetByCountLimit(ctx context.Context, oid int64, typ int8, limit int) (rs []*reply.Reply, err error)

GetByCountLimit GetByCountLimit

func (*RpDao) GetByDialog 

func (dao *RpDao) GetByDialog(c context.Context, oid int64, typ int8, root int64, dialog int64) (rps []*reply.Reply, err error)

GetByDialog get all reply by dialog

func (*RpDao) GetByFloorLimit 

func (dao *RpDao) GetByFloorLimit(ctx context.Context, oid int64, typ int8, floor int, limit int) (rs []*reply.Reply, err error)

GetByFloorLimit GetByFloorLimit

func (*RpDao) GetByLikeLimit 

func (dao *RpDao) GetByLikeLimit(ctx context.Context, oid int64, typ int8, limit int) (rs []*reply.Reply, err error)

GetByLikeLimit GetByLikeLimit

func (*RpDao) GetForUpdate 

func (dao *RpDao) GetForUpdate(tx *sql.Tx, oid, rpID int64) (r *reply.Reply, err error)

GetForUpdate decr rcount of reply by transaction.

func (*RpDao) GetTop 

func (dao *RpDao) GetTop(c context.Context, oid int64, tp int8, bit uint32) (r *reply.Reply, err error)

GetTop get top reply

func (*RpDao) GetsByRoot 

func (dao *RpDao) GetsByRoot(c context.Context, oid, rpID int64, tp, state int8) (rs []*reply.Reply, err error)

GetsByRoot get all replies by root reply.

func (*RpDao) TxCountFoldedReplies 

func (dao *RpDao) TxCountFoldedReplies(tx *sql.Tx, oid int64, tp int8, root int64) (count int, err error)

TxCountFoldedReplies ...

func (*RpDao) TxDecrCount 

func (dao *RpDao) TxDecrCount(tx *sql.Tx, oid, rpID int64, now time.Time) (rows int64, err error)

TxDecrCount decr rcount of reply by transaction.

func (*RpDao) TxIncrCount 

func (dao *RpDao) TxIncrCount(tx *sql.Tx, oid, rpID int64, now time.Time) (rows int64, err error)

TxIncrCount incr count and rcount of reply by transaction.

func (*RpDao) TxIncrFCount 

func (dao *RpDao) TxIncrFCount(tx *sql.Tx, oid, rpID int64, now time.Time) (rows int64, err error)

TxIncrFCount incr rcount of reply by transaction

func (*RpDao) TxIncrRCount 

func (dao *RpDao) TxIncrRCount(tx *sql.Tx, oid, rpID int64, now time.Time) (rows int64, err error)

TxIncrRCount incr rcount of reply by transaction

func (*RpDao) TxInsert 

func (dao *RpDao) TxInsert(tx *sql.Tx, r *reply.Reply) (rows int64, err error)

TxInsert insert reply by transaction.

func (*RpDao) TxUpAttr 

func (dao *RpDao) TxUpAttr(tx *sql.Tx, oid, rpID int64, attr uint32, now time.Time) (rows int64, err error)

TxUpAttr update reply state.

func (*RpDao) TxUpState 

func (dao *RpDao) TxUpState(tx *sql.Tx, oid, rpID int64, state int8, now time.Time) (rows int64, err error)

TxUpState update reply state by transaction.

func (*RpDao) UpLike 

func (dao *RpDao) UpLike(c context.Context, oid, rpID int64, like, hate int, now time.Time) (rows int64, err error)

UpLike incr or decr reply like.

func (*RpDao) UpState 

func (dao *RpDao) UpState(c context.Context, oid, rpID int64, state int8, now time.Time) (rows int64, err error)

UpState update reply state.

type SubjectDao 

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

SubjectDao define subject mysql stmt

func NewSubjectDao 

func NewSubjectDao(db *sql.DB) (dao *SubjectDao)

NewSubjectDao new ReplySubjectDao and return.

func (*SubjectDao) Get 

func (dao *SubjectDao) Get(c context.Context, oid int64, tp int8) (sub *reply.Subject, err error)

Get get a subject.

func (*SubjectDao) GetForUpdate 

func (dao *SubjectDao) GetForUpdate(tx *sql.Tx, oid int64, tp int8) (sub *reply.Subject, err error)

GetForUpdate get a subject for update.

func (*SubjectDao) TxDecrACount 

func (dao *SubjectDao) TxDecrACount(tx *sql.Tx, oid int64, tp int8, count int, now time.Time) (rows int64, err error)

TxDecrACount decr subject rcount by transaction.

func (*SubjectDao) TxDecrCount 

func (dao *SubjectDao) TxDecrCount(tx *sql.Tx, oid int64, tp int8, now time.Time) (rows int64, err error)

TxDecrCount decr subject count by transaction.

func (*SubjectDao) TxDecrMCount 

func (dao *SubjectDao) TxDecrMCount(tx *sql.Tx, oid int64, tp int8, now time.Time) (rows int64, err error)

TxDecrMCount decr subject mcount by transaction.

func (*SubjectDao) TxIncrACount 

func (dao *SubjectDao) TxIncrACount(tx *sql.Tx, oid int64, tp int8, count int, now time.Time) (rows int64, err error)

TxIncrACount incr subject acount by transaction.

func (*SubjectDao) TxIncrCount 

func (dao *SubjectDao) TxIncrCount(tx *sql.Tx, oid int64, tp int8, now time.Time) (rows int64, err error)

TxIncrCount incr subject count and rcount by transaction.

func (*SubjectDao) TxIncrFCount 

func (dao *SubjectDao) TxIncrFCount(tx *sql.Tx, oid int64, tp int8, now time.Time) (rows int64, err error)

TxIncrFCount incr subject count and rcount by transaction.

func (*SubjectDao) TxIncrMCount 

func (dao *SubjectDao) TxIncrMCount(tx *sql.Tx, oid int64, tp int8, now time.Time) (rows int64, err error)

TxIncrMCount incr subject mcount by transaction.

func (*SubjectDao) TxIncrRCount 

func (dao *SubjectDao) TxIncrRCount(tx *sql.Tx, oid int64, tp int8, now time.Time) (rows int64, err error)

TxIncrRCount incr subject rcount by transaction

func (*SubjectDao) TxUpAttr 

func (dao *SubjectDao) TxUpAttr(tx *sql.Tx, oid int64, tp int8, attr uint32, now time.Time) (rows int64, err error)

TxUpAttr update subject attr.

func (*SubjectDao) TxUpMeta 

func (dao *SubjectDao) TxUpMeta(tx *sql.Tx, oid int64, tp int8, meta string, now time.Time) (rows int64, err error)

TxUpMeta update subject meta.

func (*SubjectDao) UpMeta 

func (dao *SubjectDao) UpMeta(c context.Context, oid int64, tp int8, meta string, now time.Time) (rows int64, err error)

UpMeta update subject meta.

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.