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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrCursorDirection = errors.New("error cursor direction")

ErrCursorDirection ErrCursorDirection

Functions

func GenNewChildrenKeyByRootReplyID 

func GenNewChildrenKeyByRootReplyID(id int64) string

GenNewChildrenKeyByRootReplyID GenNewChildrenKeyByRootReplyID

Types

type AdminDao 

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

AdminDao AdminDao

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 BlockInfo 

type BlockInfo struct {
	// block_status 变成了 PassTest,原因不可描述
	PassTest     int   `json:"block_status"` // 1: fail 0: succ
	ForeverBlock bool  `json:"blocked_forever"`
	BlockUntil   int64 `json:"blocked_end"`
	Moral        int   `json:"moral"`
}

BlockInfo BlockInfo

type BlockStatusDao 

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

BlockStatusDao BlockStatusDao

func NewBlockStatusDao 

func NewBlockStatusDao(c *conf.Config) *BlockStatusDao

NewBlockStatusDao NewBlockStatusDao

func (*BlockStatusDao) BlockInfo 

func (dao *BlockStatusDao) BlockInfo(c context.Context, mid int64) (*BlockInfo, error)

BlockInfo BlockInfo

type BlockStatusResp 

type BlockStatusResp struct {
	Code int       `json:"code"`
	Data BlockInfo `json:"data"`
	Msg  string    `json:"msg"`
}

BlockStatusResp BlockStatusResp

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 CaptchaDao 

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

CaptchaDao CaptchaDao

func NewCaptchaDao 

func NewCaptchaDao(c *httpx.ClientConfig) *CaptchaDao

NewCaptchaDao NewCaptchaDao

func (*CaptchaDao) Captcha 

func (s *CaptchaDao) Captcha(c context.Context) (string, string, error)

Captcha Captcha.

func (*CaptchaDao) Verify 

func (s *CaptchaDao) Verify(c context.Context, token, code string) error

Verify Verify.

type ConfigDao 

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

ConfigDao ConfigDao

func NewConfigDao 

func NewConfigDao(db *sql.DB) (dao *ConfigDao)

NewConfigDao new ConfigDao and return.

func (*ConfigDao) LoadConfig 

func (dao *ConfigDao) LoadConfig(c context.Context, oid int64, tp, category int8) (m *reply.Config, err error)

LoadConfig :load a config record

type ContentDao 

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

ContentDao ContentDao

func NewContentDao 

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

NewContentDao new replyDao 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) GetByIds 

func (dao *ContentDao) GetByIds(c context.Context, oid int64, rpIds []int64) (rcMap map[int64]*reply.Content, err error)

GetByIds get reply contents by reply ids.

func (*ContentDao) UpMessage 

func (dao *ContentDao) UpMessage(c context.Context, oid int64, rpID int64, msg string, now time.Time) (rows int64, err error)

UpMessage update content's message.

type CreditUserDao 

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

CreditUserDao CreditUserDao

func NewCreditDao 

func NewCreditDao(c *conf.Config) *CreditUserDao

NewCreditDao NewCreditDao

func (*CreditUserDao) IsCreditUser 

func (dao *CreditUserDao) IsCreditUser(c context.Context, mid int64) (bool, error)

IsCreditUser IsCreditUser

type Dao 

type Dao struct {
	// memcache
	Mc *MemcacheDao

	Admin       *AdminDao
	Content     *ContentDao
	Report      *ReportDao
	Reply       *RpDao
	Captcha     *CaptchaDao
	Notice      *NoticeDao
	CreditUser  *CreditUserDao
	Subject     *SubjectDao
	Config      *ConfigDao
	BlockStatus *BlockStatusDao
	Business    *BusinessDao
	// redis
	Redis *RedisDao
	// kafka
	Databus *DatabusDao
	Emoji   *EmoDao
	// contains filtered or unexported fields
}

Dao Dao

func New 

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

New New

func (*Dao) Close 

func (d *Dao) Close()

Close Close

func (*Dao) FilterContents 

func (d *Dao) FilterContents(ctx context.Context, rpMaps map[int64]string) error

FilterContents get filtered contents from db

func (*Dao) Ping 

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

Ping Ping

type DatabusDao 

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

DatabusDao DatabusDao

func NewDatabusDao 

func NewDatabusDao(c *databus.Config) (dao *DatabusDao)

NewDatabusDao new ReplyKafkaDao and return.

func (*DatabusDao) AddReply 

func (dao *DatabusDao) AddReply(c context.Context, oid int64, rp *reply.Reply)

AddReply push event message into kafka.

func (*DatabusDao) AddReport 

func (dao *DatabusDao) AddReport(c context.Context, oid, rpID int64, tp int8)

AddReport push event message into kafka.

func (*DatabusDao) AddSpam 

func (dao *DatabusDao) AddSpam(c context.Context, oid, mid int64, isUp bool, tp int8)

AddSpam push event message into kafka.

func (*DatabusDao) AddTop 

func (dao *DatabusDao) AddTop(c context.Context, oid int64, tp int8, top uint32)

AddTop AddTop

func (*DatabusDao) AdminAddTop 

func (dao *DatabusDao) AdminAddTop(c context.Context, adid, oid, rpID, ts int64, act, tp int8)

AdminAddTop push event message into kafka.

func (*DatabusDao) AdminDelete 

func (dao *DatabusDao) AdminDelete(c context.Context, adid, oid, rpID, ftime int64, moral int, notify bool, adname, remark string, ts int64, tp, reason, freason int8)

AdminDelete push event message into kafka.

func (*DatabusDao) AdminDeleteByReport 

func (dao *DatabusDao) AdminDeleteByReport(c context.Context, adid, oid, rpID, mid, ftime int64, moral int, notify bool, adname, remark string, ts int64, tp, audit, reason int8, content string, freason int8)

AdminDeleteByReport push event message into kafka.

func (*DatabusDao) AdminEdit 

func (dao *DatabusDao) AdminEdit(c context.Context, oid, rpID int64, tp int8)

AdminEdit push event message into kafka.

func (*DatabusDao) AdminIgnore 

func (dao *DatabusDao) AdminIgnore(c context.Context, adid, oid, rpID, ts int64, tp, audit int8)

AdminIgnore push event message into kafka.

func (*DatabusDao) AdminPass 

func (dao *DatabusDao) AdminPass(c context.Context, adid, oid, rpID int64, remark string, ts int64, tp int8)

AdminPass push pass event message into kafka.

func (*DatabusDao) AdminRecover 

func (dao *DatabusDao) AdminRecover(c context.Context, adid, oid, rpID int64, remark string, ts int64, tp int8)

AdminRecover push event message into kafka.

func (*DatabusDao) AdminReportRecover 

func (dao *DatabusDao) AdminReportRecover(c context.Context, adid, oid, rpID int64, remark string, ts int64, tp, audit int8)

AdminReportRecover push event message into kafka.

func (*DatabusDao) AdminStateSet 

func (dao *DatabusDao) AdminStateSet(c context.Context, adid, oid, rpID, ts int64, tp, state int8)

AdminStateSet push event message into kafka.

func (*DatabusDao) AdminTransfer 

func (dao *DatabusDao) AdminTransfer(c context.Context, adid, oid, rpID, ts int64, tp, audit int8)

AdminTransfer push event message into kafka.

func (*DatabusDao) Delete 

func (dao *DatabusDao) Delete(c context.Context, mid, oid, rpID int64, ts int64, tp int8, assist bool)

Delete push event message into kafka.

func (*DatabusDao) Hate 

func (dao *DatabusDao) Hate(c context.Context, oid, rpID, mid int64, action int8, ts int64)

Hate push event message into kafka.

func (*DatabusDao) Hide 

func (dao *DatabusDao) Hide(c context.Context, oid, rpID int64, tp int8, ts int64)

Hide push event message into kafka.

func (*DatabusDao) Like 

func (dao *DatabusDao) Like(c context.Context, oid, rpID, mid int64, action int8, ts int64)

Like push event message into kafka.

func (*DatabusDao) RecoverDialogIdx 

func (dao *DatabusDao) RecoverDialogIdx(c context.Context, oid int64, tp int8, root, dialog int64)

RecoverDialogIdx Recover dialog index

func (*DatabusDao) RecoverFixDialogIdx 

func (dao *DatabusDao) RecoverFixDialogIdx(c context.Context, oid int64, tp int8, root int64)

RecoverFixDialogIdx ...

func (*DatabusDao) RecoverFloorIdx 

func (dao *DatabusDao) RecoverFloorIdx(c context.Context, oid int64, tp int8, num int, isFloor bool)

RecoverFloorIdx RecoverFloorIdx

func (*DatabusDao) RecoverFolderIdx 

func (dao *DatabusDao) RecoverFolderIdx(c context.Context, oid int64, tp int8, root int64)

RecoverFolderIdx ...

func (*DatabusDao) RecoverIndex 

func (dao *DatabusDao) RecoverIndex(c context.Context, oid int64, tp, sort int8)

RecoverIndex push event message into kafka.

func (*DatabusDao) RecoverIndexByRoot 

func (dao *DatabusDao) RecoverIndexByRoot(c context.Context, oid, root int64, tp int8)

RecoverIndexByRoot push event message into kafka.

func (*DatabusDao) Show 

func (dao *DatabusDao) Show(c context.Context, oid, rpID int64, tp int8, ts int64)

Show push event message into kafka.

func (*DatabusDao) UpperAddTop 

func (dao *DatabusDao) UpperAddTop(c context.Context, mid, oid, rpID, ts int64, act, tp int8)

UpperAddTop push event message into kafka.

type EmoDao 

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

EmoDao emoji dao

func NewEmojiDao 

func NewEmojiDao(db *sql.DB) (dao *EmoDao)

NewEmojiDao NewEmojiDao

func (*EmoDao) EmojiList 

func (dao *EmoDao) EmojiList(c context.Context) (emo []*reply.Emoji, err error)

EmojiList get all emoji

func (*EmoDao) EmojiListByPid 

func (dao *EmoDao) EmojiListByPid(c context.Context, pid int64) (emo []*reply.Emoji, err error)

EmojiListByPid get emoji by package_id

func (*EmoDao) ListEmojiPack 

func (dao *EmoDao) ListEmojiPack(c context.Context) (packs []*reply.EmojiPackage, err error)

ListEmojiPack get all emojipack

type MemcacheDao 

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

MemcacheDao memcache dao.

func NewMemcacheDao 

func NewMemcacheDao(c *conf.Memcache) *MemcacheDao

NewMemcacheDao new a memcache dao and return.

func (*MemcacheDao) AddReply 

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

AddReply add reply into memcache.

func (*MemcacheDao) AddReplyConfigCache 

func (dao *MemcacheDao) AddReplyConfigCache(c context.Context, m *model.Config) (err error)

AddReplyConfigCache add/update reply configuration cache from 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, oid int64, tp int8, rp *model.Reply) (err error)

AddTop add top reply into memcache.

func (*MemcacheDao) CaptchaToken 

func (dao *MemcacheDao) CaptchaToken(c context.Context, mid int64) (string, error)

CaptchaToken CaptchaToken

func (*MemcacheDao) DeleteReply 

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

DeleteReply delete reply from memcache.

func (*MemcacheDao) DeleteSubject 

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

DeleteSubject delete subject from memcache.

func (*MemcacheDao) GetMultiReply 

func (dao *MemcacheDao) GetMultiReply(c context.Context, rpIDs []int64) (rpMap map[int64]*model.Reply, missed []int64, err error)

GetMultiReply multi get replies from memcache.

func (*MemcacheDao) GetMultiSubject 

func (dao *MemcacheDao) GetMultiSubject(c context.Context, oids []int64, tp int8) (res map[int64]*model.Subject, missed []int64, err error)

GetMultiSubject get subject 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) GetReplyByIDs 

func (dao *MemcacheDao) GetReplyByIDs(ctx context.Context, ids []int64) ([]*model.Reply, []int64, error)

GetReplyByIDs GetReplyByIDs

func (*MemcacheDao) GetReplyConfig 

func (dao *MemcacheDao) GetReplyConfig(c context.Context, oid int64, typ, category int8) (config *model.Config, err error)

GetReplyConfig get reply configuration from memocache by oid and type value

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.

func (*MemcacheDao) SetCaptchaToken 

func (dao *MemcacheDao) SetCaptchaToken(c context.Context, mid int64, token string) error

SetCaptchaToken SetCaptchaToken

type NoticeDao 

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

NoticeDao notice dao.

func NewNoticeDao 

func NewNoticeDao(db *sql.DB) (dao *NoticeDao)

NewNoticeDao new a notice dao and return.

func (*NoticeDao) ReplyNotice 

func (dao *NoticeDao) ReplyNotice(c context.Context) (nts []*reply.Notice, err error)

ReplyNotice get reply notice infos from db

type RedisDao 

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

RedisDao RedisDao

func NewRedisDao 

func NewRedisDao(c *conf.Redis) *RedisDao

NewRedisDao NewRedisDao

func (*RedisDao) AddCountIndex 

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

AddCountIndex add index by count.

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

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

AddFloorIndexByRoot add root reply index by floor.

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, r *reply.Reply, rpt *reply.Report) (err error)

AddLikeIndex add index by like.

func (*RedisDao) CacheKeyRootReplyIDs 

func (dao *RedisDao) CacheKeyRootReplyIDs(oid int64, tp, sort int8) string

CacheKeyRootReplyIDs CacheKeyRootReplyIDs

func (*RedisDao) CountReplies 

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

CountReplies CountReplies

func (*RedisDao) DelIndex 

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

DelIndex delete reply index.

func (*RedisDao) DelLike 

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

DelLike add actions into redis

func (*RedisDao) DelReplyIncr 

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

DelReplyIncr reply cd key

func (*RedisDao) DelReplySpam 

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

DelReplyIncr reply cd key

func (*RedisDao) DialogByCursor 

func (dao *RedisDao) DialogByCursor(c context.Context, dialog int64, cursor *reply.Cursor) (rpIDs []int64, err error)

DialogByCursor return replies by dialog

func (*RedisDao) DialogDesc 

func (dao *RedisDao) DialogDesc(c context.Context, dialog int64, floor, size int) (rpIDs []int64, err error)

DialogBySide ...

func (*RedisDao) DialogMinMaxFloor 

func (dao *RedisDao) DialogMinMaxFloor(c context.Context, dialog int64) (minFloor, maxFloor int, err error)

DialogMaxMinFloor return min and max floor

func (*RedisDao) ExpireCache 

func (dao *RedisDao) ExpireCache(ctx context.Context, key string) (bool, error)

ExpireCache ExpireCache

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

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

ExpireIndexByRoot set expire time for root's 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) FolderByCursor 

func (dao *RedisDao) FolderByCursor(c context.Context, kind string, ID int64, cursor *xreply.Cursor) (rpIDs []int64, err error)

FolderByCursor ...

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

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

OidHaveTop OidHaveTop

func (*RedisDao) ParentChildrenReplyIDMap 

func (dao *RedisDao) ParentChildrenReplyIDMap(ctx context.Context,
	parentIDs []int64, start, end int) (parentChildrenMap map[int64][]int64, missedIDs []int64, err error)

ParentChildrenReplyIDMap ParentChildrenReplyIDMap

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, isEnd bool, err error)

func (*RedisDao) RangeByOids 

func (dao *RedisDao) RangeByOids(c context.Context, oids []int64, tp, sort, start, end int8) (oidMap map[int64][]int64, miss []int64, err error)

RangeByOids range oids

func (*RedisDao) RangeByRoot 

func (dao *RedisDao) RangeByRoot(c context.Context, root int64, start, end int) (rpIds []int64, err error)

RangeByRoot range root's replyies.

func (*RedisDao) RangeByRoots 

func (dao *RedisDao) RangeByRoots(c context.Context, roots []int64, start, end int) (mrpids map[int64][]int64, idx, miss []int64, err error)

RangeByRoots range roots's replyies.

func (*RedisDao) RangeChildrenIDByCursorScore 

func (dao *RedisDao) RangeChildrenIDByCursorScore(ctx context.Context, key string, cursor *model.Cursor) ([]int64, error)

RangeChildrenIDByCursorScore RangeChildrenIDByCursorScore

func (*RedisDao) RangeChildrenReplyIDs 

func (dao *RedisDao) RangeChildrenReplyIDs(ctx context.Context,
	keys []string, start, end int) (arrOfChildrenReplyIDs [][]int64, missedKeys []string, err error)

RangeChildrenReplyIDs RangeChildrenReplyIDs

func (*RedisDao) RangeRootIDByCursorScore 

func (dao *RedisDao) RangeRootIDByCursorScore(ctx context.Context, key string, cursor *model.Cursor) ([]int64, bool, error)

RangeRootIDByCursorScore RangeRootIDByCursorScore

func (*RedisDao) RangeRootReplyIDs 

func (dao *RedisDao) RangeRootReplyIDs(ctx context.Context, key string, start, end int) ([]int64, error)

RangeRootReplyIDs RangeRootReplyIDs

func (*RedisDao) RangeRpsByDialog 

func (dao *RedisDao) RangeRpsByDialog(c context.Context, dialog int64, start, end int) (rpIDs []int64, err error)

RangeRpsByDialog return replies by dialog ID

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

func (dao *RedisDao) RankIndexByRoot(c context.Context, root int64, rpID int64) (rank int, err error)

RankIndexByRoot get rank from root reply index.

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 SpamAction

func (*RedisDao) SpamReply 

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

SpamReply SpamReply

func (*RedisDao) UserAuditReplies 

func (dao *RedisDao) UserAuditReplies(c context.Context, mid, oid int64, tp int8) (rpIds []int64, err error)

UserAuditReplies return user audit replies.

type ReportDao 

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

ReportDao report dao.

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 return a report from mysql.

func (*ReportDao) Insert 

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

Insert insert a report to mysql.

func (*ReportDao) InsertUser 

func (dao *ReportDao) InsertUser(c context.Context, ru *model.ReportUser) (id int64, err error)

InsertUser inser a report user to mysql.

type Result 

type Result struct {
	Code int `json:"code"`
	Data map[int64]struct {
		Mid     int64 `json:"mid"`
		Expired int64 `json:"expired"`
		Status  int   `json:"status"`
	} `json:"data"`
	Msg string `json:"msg"`
}

Result Result

type RpDao 

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

RpDao reply dao.

func NewReplyDao 

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

NewReplyDao new replyDao and return.

func (*RpDao) AddFilteredReply 

func (dao *RpDao) AddFilteredReply(c context.Context, rpID, oid, mid int64, tp, level int8, message string, now time.Time) (err error)

AddFilteredReply AddFilteredReply

func (*RpDao) ChildrenIDSortByFloorCursor 

func (dao *RpDao) ChildrenIDSortByFloorCursor(ctx context.Context, oid int64, tp int8, rootID int64, cursor *model.Cursor) ([]int64, error)

ChildrenIDSortByFloorCursor ChildrenIDSortByFloorCursor

func (*RpDao) ChildrenIDsOfRootReply 

func (dao *RpDao) ChildrenIDsOfRootReply(ctx context.Context,
	oid, rootID int64, tp int8, offset, limit int) ([]int64, error)

ChildrenIDsOfRootReply ChildrenIDsOfRootReply

func (*RpDao) CountLike 

func (dao *RpDao) CountLike(c context.Context, oid int64, tp int8) (count int, err error)

CountLike get count of reply like

func (*RpDao) FoldedRepliesCursor 

func (dao *RpDao) FoldedRepliesCursor(c context.Context, oid int64, tp int8, root int64, cursor *xreply.Cursor) (ids []int64, err error)

FoldedRepliesCursor ...

func (*RpDao) Get 

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

Get get reply.

func (*RpDao) GetByIds 

func (dao *RpDao) GetByIds(c context.Context, oid int64, tp int8, rpIds []int64) (rpMap map[int64]*reply.Reply, err error)

GetByIds get replies by reply ids.

func (*RpDao) GetDialogMinMaxFloor 

func (dao *RpDao) GetDialogMinMaxFloor(c context.Context, oid int64, tp int8, root, dialog int64) (minFloor, maxFloor int, err error)

GetDialogMinMaxFloor ...

func (*RpDao) GetIDsByDialog 

func (dao *RpDao) GetIDsByDialog(c context.Context, oid int64, tp int8, root, dialog int64, offset, count int) (rpIDs []int64, err error)

GetIDsByDialog get replies by dialog

func (*RpDao) GetIDsByDialogAsc 

func (dao *RpDao) GetIDsByDialogAsc(c context.Context, oid int64, tp int8, root, dialog, maxFloor int64, count int) (rpIDs []int64, err error)

GetIDsByDialogAsc ...

func (*RpDao) GetIDsByDialogDesc 

func (dao *RpDao) GetIDsByDialogDesc(c context.Context, oid int64, tp int8, root, dialog, minFloor int64, count int) (rpIDs []int64, err error)

GetIDsByDialogDesc ...

func (*RpDao) GetIDsByFloorOffset 

func (dao *RpDao) GetIDsByFloorOffset(c context.Context, oid int64, tp int8, start, end int) (res []int64, err error)

GetIDsByFloorOffset get reply ids in floor range

func (*RpDao) GetIDsByRootWithoutState 

func (dao *RpDao) GetIDsByRootWithoutState(c context.Context, oid, root int64, tp int8, offset, count int) (res []int64, err error)

GetIDsByRootWithoutState limit get reply ids of root reply and order by floor.

func (*RpDao) GetIdsByRoot 

func (dao *RpDao) GetIdsByRoot(c context.Context, oid, root int64, tp int8, offset, count int) (res []int64, err error)

GetIdsByRoot limit get reply ids of root reply and order by floor.

func (*RpDao) GetIdsSortCount 

func (dao *RpDao) GetIdsSortCount(c context.Context, oid int64, tp int8, offset, count int) (res []int64, err error)

GetIdsSortCount limit get reply ids and order by rcount desc.

func (*RpDao) GetIdsSortFloor 

func (dao *RpDao) GetIdsSortFloor(c context.Context, oid int64, tp int8, offset, count int) (res []int64, err error)

GetIdsSortFloor limit get reply ids and order by floor desc.

func (*RpDao) GetIdsSortLike 

func (dao *RpDao) GetIdsSortLike(c context.Context, oid int64, tp int8, offset, count int) (res []int64, err error)

GetIdsSortLike limit get reply ids and order by like desc.

func (*RpDao) RootIDSortByFloorCursor 

func (dao *RpDao) RootIDSortByFloorCursor(ctx context.Context, oid int64, tp int8, cursor *model.Cursor) ([]int64, error)

RootIDSortByFloorCursor RootIDSortByFloorCursor

func (*RpDao) SetHateCount 

func (dao *RpDao) SetHateCount(c context.Context, oid, rpID int64, count int32, now time.Time) (rows int64, err error)

SetHateCount set a reply hate count.

func (*RpDao) SetLikeCount 

func (dao *RpDao) SetLikeCount(c context.Context, oid, rpID int64, count int32, now time.Time) (rows int64, err error)

SetLikeCount set a reply hate count.

type SubjectDao 

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

SubjectDao subject dao.

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

func (dao *SubjectDao) Gets(c context.Context, oids []int64, tp int8) (res map[int64]*reply.Subject, err error)

Gets get a subject.

func (*SubjectDao) Insert 

func (dao *SubjectDao) Insert(c context.Context, sub *reply.Subject) (id int64, err error)

Insert insert a reply subject.

func (*SubjectDao) Set 

func (dao *SubjectDao) Set(c context.Context, sub *reply.Subject) (id int64, err error)

Set insert or update subject state.

func (*SubjectDao) UpMid 

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

UpMid update subject mid.

func (*SubjectDao) UpState 

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

UpState update subject state.

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.