mcndao

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (

	// UpPermissionApplyCannotApplyStates 在这此状态下，不能再申请改变Up主
	UpPermissionApplyCannotApplyStates = []adminmodel.MCNUPPermissionState{
		adminmodel.MCNUPPermissionStateNoAuthorize,
		adminmodel.MCNUPPermissionStateReview,
	}

	// UpSignedStates up signed state
	UpSignedStates = []model.MCNUPState{
		model.MCNUPStateOnSign,
		model.MCNUPStateOnPreOpen,
	}
)

Functions

func RecommendSortByArchiveCountDesc 

func RecommendSortByArchiveCountDesc(p1, p2 *mcnmodel.McnGetRecommendPoolInfo) bool

RecommendSortByArchiveCountDesc .

func RecommendSortByFansAsc 

func RecommendSortByFansAsc(p1, p2 *mcnmodel.McnGetRecommendPoolInfo) bool

RecommendSortByFansAsc .

func RecommendSortByFansDesc 

func RecommendSortByFansDesc(p1, p2 *mcnmodel.McnGetRecommendPoolInfo) bool

RecommendSortByFansDesc .

func RecommendSortByMonthFansDesc 

func RecommendSortByMonthFansDesc(p1, p2 *mcnmodel.McnGetRecommendPoolInfo) bool

RecommendSortByMonthFansDesc .

Types

type Dao 

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

Dao dao

func New 

func New(c *conf.Config, localcache gcache.Cache) (dao *Dao)

New init mysql db

func (*Dao) AddCacheMcnDataSummary 

func (d *Dao) AddCacheMcnDataSummary(c context.Context, id int64, val *mcnmodel.McnGetDataSummaryReply, generateDate time.Time) (err error)

AddCacheMcnDataSummary Set data to mc

func (*Dao) AddCacheMcnSign 

func (d *Dao) AddCacheMcnSign(c context.Context, id int64, val *mcnmodel.McnSign) (err error)

AddCacheMcnSign Set data to mc

func (*Dao) AddCachePublicationPrice 

func (d *Dao) AddCachePublicationPrice(c context.Context, id int64, val *mcnmodel.PublicationPriceCache, mid int64) (err error)

AddCachePublicationPrice Set data to mc

func (*Dao) AddCacheUpPermission 

func (d *Dao) AddCacheUpPermission(c context.Context, id int64, val *mcnmodel.UpPermissionCache, mid int64) (err error)

AddCacheUpPermission Set data to mc

func (*Dao) AsyncDelCacheMcnSign 

func (d *Dao) AsyncDelCacheMcnSign(id int64) (err error)

AsyncDelCacheMcnSign delete in async way

func (*Dao) BindUp 

func (d *Dao) BindUp(up *mcnmodel.McnUp, sign *mcnmodel.McnSign, arg *mcnmodel.McnBindUpApplyReq) (result *mcnmodel.McnUp, affectedRow int64, err error)

BindUp .

func (*Dao) CacheMcnDataSummary 

func (d *Dao) CacheMcnDataSummary(c context.Context, id int64, generateDate time.Time) (res *mcnmodel.McnGetDataSummaryReply, err error)

CacheMcnDataSummary get data from mc

func (*Dao) CacheMcnSign 

func (d *Dao) CacheMcnSign(c context.Context, id int64) (res *mcnmodel.McnSign, err error)

CacheMcnSign get data from mc

func (*Dao) CachePublicationPrice 

func (d *Dao) CachePublicationPrice(c context.Context, id int64, mid int64) (res *mcnmodel.PublicationPriceCache, err error)

CachePublicationPrice get data from mc

func (*Dao) CacheUpPermission 

func (d *Dao) CacheUpPermission(c context.Context, id int64, mid int64) (res *mcnmodel.UpPermissionCache, err error)

CacheUpPermission get data from mc

func (*Dao) Close 

func (d *Dao) Close()

Close close the resource.

func (*Dao) DelCacheMcnSign 

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

DelCacheMcnSign delete data from mc

func (*Dao) DelMcnDataSummary 

func (d *Dao) DelMcnDataSummary(c context.Context, id int64, generateDate time.Time) (err error)

DelMcnDataSummary delete data from mc

func (*Dao) DelPublicationPrice 

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

DelPublicationPrice delete data from mc

func (*Dao) DelUpPermission 

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

DelUpPermission delete data from mc

func (*Dao) GetActiveTid 

func (d *Dao) GetActiveTid(mids []int64) (res map[int64]int64, err error)

GetActiveTid get tid from crm database

func (*Dao) GetAllUpData 

func (d *Dao) GetAllUpData(signID int64, upmid int64, generateDate time.Time) (res []*mcnmodel.McnUpDataInfo, err error)

GetAllUpData .

func (*Dao) GetAllUpDataTemp 

func (d *Dao) GetAllUpDataTemp(signID int64, upmid int64, generateDate time.Time) (res []*mcnmodel.McnUpDataInfo, err error)

GetAllUpDataTemp .

func (*Dao) GetBindInfo 

func (d *Dao) GetBindInfo(arg *mcnmodel.McnUpGetBindReq) (res *mcnmodel.McnGetBindReply, err error)

GetBindInfo .

func (*Dao) GetDataUpLatestDate 

func (d *Dao) GetDataUpLatestDate(dataType mcnmodel.DataType, signID int64) (generateDate time.Time, err error)

GetDataUpLatestDate .

func (*Dao) GetMcnDB 

func (d *Dao) GetMcnDB() *gorm.DB

GetMcnDB get mcn db

func (*Dao) GetMcnDataSummary 

func (d *Dao) GetMcnDataSummary(selec string, query interface{}, args ...interface{}) (res *mcnmodel.McnDataSummary, err error)

GetMcnDataSummary .

func (*Dao) GetMcnDataSummaryWithDiff 

func (d *Dao) GetMcnDataSummaryWithDiff(signID int64, dataTYpe mcnmodel.McnDataType, generateDate time.Time) (res *mcnmodel.McnGetDataSummaryReply, err error)

GetMcnDataSummaryWithDiff get data with datacenter diff

func (*Dao) GetMcnOldInfo 

func (d *Dao) GetMcnOldInfo(mcnMid int64) (res *mcnmodel.McnSign, err error)

GetMcnOldInfo 获取冷却中的信息

func (*Dao) GetMcnSignState 

func (d *Dao) GetMcnSignState(fields string, mcnMid int64) (mcn *mcnmodel.McnSign, state model.MCNSignState, err error)

GetMcnSignState . mcnList, it's all mcn sign found with the state state, the mcn's state of qualified, if multiple state found, will be return in priority

func (*Dao) GetRankArchiveLikes 

func (d *Dao) GetRankArchiveLikes(signID int64) (result *RankByTid, err error)

GetRankArchiveLikes get fans

func (*Dao) GetRankUpFans 

func (d *Dao) GetRankUpFans(signID int64) (result *RankByTid, err error)

GetRankUpFans get fans

func (*Dao) GetRecommendPool 

func (d *Dao) GetRecommendPool() (res *RecommendPoolCache, err error)

GetRecommendPool get recommend pool

func (*Dao) GetUpBaseInfo 

func (d *Dao) GetUpBaseInfo(fields string, mids []int64) (res map[int64]*mcnmodel.UpBaseInfo, err error)

GetUpBaseInfo get up base info from crm database

func (*Dao) GetUpBind 

func (d *Dao) GetUpBind(query interface{}, args ...interface{}) (upList []*mcnmodel.McnUp, err error)

GetUpBind .

func (*Dao) GetUpPermissionApply 

func (d *Dao) GetUpPermissionApply(fields string, query interface{}, args ...interface{}) (res []*mcnmodel.McnUpPermissionApply, err error)

GetUpPermissionApply 从permission apply表中读取数据

func (*Dao) GetUpPermissionBindInfo 

func (d *Dao) GetUpPermissionBindInfo(arg *mcnmodel.McnUpGetBindReq) (res *mcnmodel.McnGetBindReply, err error)

GetUpPermissionBindInfo .

func (*Dao) McnDataSummary 

func (d *Dao) McnDataSummary(c context.Context, id int64, generateDate time.Time) (res *mcnmodel.McnGetDataSummaryReply, err error)

McnDataSummary get data from cache if miss will call source method, then add to cache.

func (*Dao) McnSign 

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

McnSign get data from cache if miss will call source method, then add to cache.

func (*Dao) Ping 

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

Ping dao ping

func (*Dao) RawMcnDataSummary 

func (d *Dao) RawMcnDataSummary(c context.Context, signID int64, generateDate time.Time) (res *mcnmodel.McnGetDataSummaryReply, err error)

RawMcnDataSummary raw get

func (*Dao) RawMcnSign 

func (d *Dao) RawMcnSign(c context.Context, mcnmid int64) (up *mcnmodel.McnSign, err error)

RawMcnSign raw db .

func (*Dao) RawRankArchiveLikes 

func (d *Dao) RawRankArchiveLikes(signID int64, date time.Time) (result []*mcnmodel.McnRankArchiveLike, err error)

RawRankArchiveLikes get from db

func (*Dao) RawRankUpFans 

func (d *Dao) RawRankUpFans(signID int64, date time.Time) (result []*mcnmodel.McnRankUpFan, err error)

RawRankUpFans get from db

func (*Dao) RawUpPermission 

func (d *Dao) RawUpPermission(c context.Context, signID int64, mid int64) (res *mcnmodel.UpPermissionCache, err error)

RawUpPermission get permissino from db

func (*Dao) ReloadRank 

func (d *Dao) ReloadRank(signID int64) (err error)

ReloadRank reload rank from db

func (*Dao) UpConfirm 

func (d *Dao) UpConfirm(arg *mcnmodel.McnUpConfirmReq, state model.MCNUPState) (err error)

UpConfirm up confrim

func (*Dao) UpPermission 

func (d *Dao) UpPermission(c context.Context, id int64, mid int64) (res *mcnmodel.UpPermissionCache, err error)

UpPermission get data from cache if miss will call source method, then add to cache.

func (*Dao) UpPermissionConfirm 

func (d *Dao) UpPermissionConfirm(arg *mcnmodel.McnUpConfirmReq, state adminmodel.MCNUPPermissionState) (err error)

UpPermissionConfirm up confrim

func (*Dao) UpdateBindUp 

func (d *Dao) UpdateBindUp(values map[string]interface{}, query interface{}, args ...interface{}) (affectedRow int64, err error)

UpdateBindUp .

type RankByTid 

type RankByTid struct {
	// [tid][datatype] rank list
	TidMap         map[int16]map[mcnmodel.DataType][]mcnmodel.RankDataInterface
	TidTypeListMap map[mcnmodel.DataType][]*mcnmodel.TidnameInfo
}

RankByTid . 存储rank的缓存 对每种排行榜的分类进行缓存 对排序进行实时计算 先去localcache中取，取不到的话，去db中取

func (*RankByTid) GetList 

func (s *RankByTid) GetList(tid int16, dataType mcnmodel.DataType) (res []mcnmodel.RankDataInterface)

GetList get list

func (*RankByTid) GetTypeList 

func (s *RankByTid) GetTypeList(dataType mcnmodel.DataType) (res []*mcnmodel.TidnameInfo)

GetTypeList get type's list

func (*RankByTid) Sort 

func (s *RankByTid) Sort(sortFunc sortRankFunc)

Sort sort by sorting function

func (*RankByTid) Truncate 

func (s *RankByTid) Truncate(max int)

Truncate truncate all the sorted list by max item number

type RankFunc 

type RankFunc func(signId int64) (result *RankByTid, err error)

RankFunc rank func

type RecommendDataSorter 

type RecommendDataSorter struct {
	Datas []*mcnmodel.McnGetRecommendPoolInfo
	By    RecommendSortFunc // Closure used in the Less method.
}

RecommendDataSorter data sorter

func (*RecommendDataSorter) Len 

func (s *RecommendDataSorter) Len() int

Len is part of sort.Interface.

func (*RecommendDataSorter) Less 

func (s *RecommendDataSorter) Less(i, j int) bool

Less is part of sort.Interface. It is implemented by calling the "by" closure in the sorter.

func (*RecommendDataSorter) Swap 

func (s *RecommendDataSorter) Swap(i, j int)

Swap is part of sort.Interface.

type RecommendPoolCache 

type RecommendPoolCache struct {
	// map[tid] list
	UpTidMap    map[int16][]*mcnmodel.McnGetRecommendPoolInfo
	TidTypeList []*mcnmodel.TidnameInfo
}

RecommendPoolCache .

type RecommendSortFunc 

type RecommendSortFunc func(p1, p2 *mcnmodel.McnGetRecommendPoolInfo) bool

RecommendSortFunc sort func

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.