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

Documentation

Index

Constants

View Source 
const (
	NoticeBizTypeSv      = 1
	NoticeBizTypeComment = 2
	NoticeBizTypeUser    = 3
	NoticeBizTypeSysMsg  = 4
)

通知的业务类型

View Source 
const (
	NoticeTypeLike    = 1
	NoticeTypeComment = 2
	NoticeTypeFan     = 3
	NoticeTypeSysMsg  = 4
)

通知类型

View Source 
const (

	// MaxSyncESNum 限制每次更新到es的数量
	MaxSyncESNum = 100
	// QueryVideoByMtime 根据mtime获取视频基础信息
	QueryVideoByMtime = "select `svid`,`mtime` from video where mtime >= ? order by mtime asc"
	// QueryVideoStatisticsByMtime 根据mtime获取视频相关播放信息
	QueryVideoStatisticsByMtime = "select `svid`,`mtime` from video_statistics where mtime >= ? order by mtime asc"
	// QueryVideoStatisticsHiveByMtime 根据mtime获取视频主站信息
	QueryVideoStatisticsHiveByMtime = "select `svid`,`mtime` from video_statistics_hive where mtime >= ? order by mtime asc"
	// QueryVideoTagByMtime 根据mtime获取视频tag信息
	QueryVideoTagByMtime = "select `svid`,`mtime` from video_tag where mtime >= ? order by mtime asc"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Dao 

type Dao struct {
	HTTPClient    *bm.Client
	SearchClient  searchv1.SearchClient
	VideoClient   videov1.VideoClient
	AccountClient account.AccountClient
	// contains filtered or unexported fields
}

Dao dao

func New 

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

New init mysql db

func (*Dao) AddSVTotal 

func (d *Dao) AddSVTotal(mid int64) (err error)

AddSVTotal ...

func (*Dao) AddUpUserDmg 

func (d *Dao) AddUpUserDmg(c context.Context, upUserDmg *model.UpUserDmg) (num int64, err error)

AddUpUserDmg .

func (*Dao) BeginTran 

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

BeginTran begin mysql transaction

func (*Dao) CacheUserBbqDmg 

func (d *Dao) CacheUserBbqDmg(c context.Context, userBbqDmg *model.UserBbqDmg) (mid string, err error)

CacheUserBbqDmg ...

func (*Dao) CacheUserBbqDmgBuvid 

func (d *Dao) CacheUserBbqDmgBuvid(c context.Context, userBbqDmgBuvid *model.UserBbqBuvidDmg) (Buvid string, err error)

CacheUserBbqDmgBuvid ...

func (*Dao) CacheUserDmg 

func (d *Dao) CacheUserDmg(c context.Context, userDmg *model.UserDmg) (mid string, err error)

CacheUserDmg ...

func (*Dao) Close 

func (d *Dao) Close()

Close close the resource.

func (*Dao) CmsRule 

func (d *Dao) CmsRule(svid int64) (flag bool)

CmsRule ...

func (*Dao) CreateDir 

func (d *Dao) CreateDir(path string) (err error)

CreateDir 创建文件夹

func (*Dao) CreateNotice 

func (d *Dao) CreateNotice(ctx context.Context, notice *notice.NoticeBase) (err error)

CreateNotice 创建通知

func (*Dao) DelUpUserDmg 

func (d *Dao) DelUpUserDmg(c context.Context) (num int64, err error)

DelUpUserDmg .

func (*Dao) Download 

func (d *Dao) Download(url string, name string) (fpath string, err error)

Download 下载文件

func (*Dao) GetNewSysMsg 

func (d *Dao) GetNewSysMsg(ctx context.Context, id int64) (list []*msg.SysMsg, err error)

GetNewSysMsg 获取未被推送的系统消息

func (*Dao) GetRecallOpVideo 

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

GetRecallOpVideo 获取精选视频

func (*Dao) GetSvidByCid 

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

GetSvidByCid 根据cid获取svid

func (*Dao) GetSyncOperVideoExportTime 

func (d *Dao) GetSyncOperVideoExportTime(c context.Context) (t string, err error)

GetSyncOperVideoExportTime ...

func (*Dao) GetSyncOperVideoFlag 

func (d *Dao) GetSyncOperVideoFlag(c context.Context) (tag int64, err error)

GetSyncOperVideoFlag 获取同步信号灯

func (*Dao) GetVideoByLastID 

func (d *Dao) GetVideoByLastID(c context.Context, last int64) (IDs []int64, lastRet int64, err error)

GetVideoByLastID 获取所有SVID

func (*Dao) HandlerMid 

func (d *Dao) HandlerMid(s string)

HandlerMid update userbase by mid

func (*Dao) HandlerMids 

func (d *Dao) HandlerMids(mids []int64)

HandlerMids update userbase by mids

func (*Dao) HandlerUserBbqDmg 

func (d *Dao) HandlerUserBbqDmg(user string)

HandlerUserBbqDmg ..

func (*Dao) HandlerUserBbqDmgBuvid 

func (d *Dao) HandlerUserBbqDmgBuvid(user string)

HandlerUserBbqDmgBuvid ..

func (*Dao) HandlerUserDmg 

func (d *Dao) HandlerUserDmg(user string)

HandlerUserDmg mid, gender, age, geo, content_tag, viewed_video, content_zone, content_count, follow_ups

func (*Dao) HandlerViewedVideo 

func (d *Dao) HandlerViewedVideo(v string) (res map[int64]string)

HandlerViewedVideo 处理看过的视频，保存最近看过的100个

func (*Dao) InsertOnDup 

func (d *Dao) InsertOnDup(c context.Context, upUserDmg *model.UpUserDmg) (err error)

InsertOnDup ...

func (*Dao) MergeUpInfo 

func (d *Dao) MergeUpInfo(mid int64) (err error)

MergeUpInfo merge up info

func (*Dao) Ping 

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

Ping dao ping

func (*Dao) QueryJobStatus 

func (d *Dao) QueryJobStatus(c context.Context, jobURL string) (urls []string, err error)

QueryJobStatus 查询hive脚本执行结果

func (*Dao) QueryOperaVideo 

func (d *Dao) QueryOperaVideo(c context.Context, date string, ch chan<- *model.VideoHiveInfo) (err error)

QueryOperaVideo query operation video once

func (*Dao) QueryPlayDaily 

func (d *Dao) QueryPlayDaily(c context.Context, date string) (vlist []*model.VideoHiveInfo, err error)

QueryPlayDaily get video play rank list from berserker

func (*Dao) QueryUpMid 

func (d *Dao) QueryUpMid(c context.Context, date string) (jobURL string, err error)

QueryUpMid .发起hive查询，取粉丝数大于1万的up mid

func (*Dao) QueryUpUserDmg 

func (d *Dao) QueryUpUserDmg(c context.Context, mid int64) (upUserDmg []*model.UpUserDmg, err error)

QueryUpUserDmg .

func (*Dao) QueryUserBasic 

func (d *Dao) QueryUserBasic(c context.Context) (jobURL string, err error)

QueryUserBasic ...

func (*Dao) QueryUserDmg 

func (d *Dao) QueryUserDmg(c context.Context) (jobURL string, err error)

QueryUserDmg .

func (*Dao) RawBbqVideo 

func (d *Dao) RawBbqVideo(ctx context.Context, SVID []int64) (res *model.VideoRaw, err error)

RawBbqVideo ..

func (*Dao) RawCheckTask 

func (d *Dao) RawCheckTask(c context.Context, taskName string) (res *model.CheckTask, err error)

RawCheckTask 查询脚本任务

func (*Dao) RawGetIDByMtime 

func (d *Dao) RawGetIDByMtime(baseTableQuery string, mtime int64) (ids []int64, lastMtime int64, err error)

RawGetIDByMtime 获取最近更新的那些svid，该函数可以用于多个表的查询，只需传入不同表的查询语句即可

func (*Dao) RawTagByMtime 

func (d *Dao) RawTagByMtime(c context.Context, mtime int64) (ids string, res int64, err error)

RawTagByMtime 根据mtime获取tag信息

func (*Dao) RawVideo 

func (d *Dao) RawVideo(ctx context.Context, SVID int64) (res *model.VideoRepRaw, err error)

RawVideo 从数据库获取视频信息

func (*Dao) RawVideoByID 

func (d *Dao) RawVideoByID(ctx context.Context, ID int64) (res *model.VideoRepRaw, err error)

RawVideoByID ...get video info by id

func (*Dao) RawVideoBySVIDS 

func (d *Dao) RawVideoBySVIDS(c context.Context, svids []string) (res map[int64]string, err error)

RawVideoBySVIDS 根据svids获取视频

func (*Dao) RawVideoTagByIDs 

func (d *Dao) RawVideoTagByIDs(c context.Context, ids string, id int64) (svids string, res int64, err error)

RawVideoTagByIDs .

func (*Dao) ReadLine 

func (d *Dao) ReadLine(path string, handler func(string)) (err error)

ReadLine 按行读取文件，hander回调

func (*Dao) ReadLines 

func (d *Dao) ReadLines(path string, handler func([]int64)) (err error)

ReadLines 50条发起一次grpc请求

func (*Dao) ReplyReg 

func (d *Dao) ReplyReg(c context.Context, req map[string]interface{}) (err error)

ReplyReg 评论注册/冻结

func (*Dao) SelMidFromUserBase 

func (d *Dao) SelMidFromUserBase(start int) (mids []int64, err error)

SelMidFromUserBase get distinct mid list from table user_base

func (*Dao) SelMidFromVideo 

func (d *Dao) SelMidFromVideo() (mids []int64, err error)

SelMidFromVideo get distinct mid list from table video

func (*Dao) SendMail 

func (d *Dao) SendMail(message *gomail.Message) (err error)

SendMail asynchronous send mail.

func (*Dao) SetRecallOpVideo 

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

SetRecallOpVideo 写入精选视频

func (*Dao) SetSyncOperVideoFlag 

func (d *Dao) SetSyncOperVideoFlag(c context.Context, v int64) (err error)

SetSyncOperVideoFlag 设置同步信号灯

func (*Dao) TransToCheckBack 

func (d *Dao) TransToCheckBack() (err error)

TransToCheckBack ..

func (*Dao) TransToReview 

func (d *Dao) TransToReview() (err error)

TransToReview ...

func (*Dao) UpUserBases 

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

UpUserBases 根据mids更新用户基本信息

func (*Dao) UpdateCms 

func (d *Dao) UpdateCms(c context.Context, v *model.VideoRaw) (err error)

UpdateCms ..

func (*Dao) UpdateSvid 

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

UpdateSvid ...

func (*Dao) UpdateSyncStatus 

func (d *Dao) UpdateSyncStatus(ctx context.Context, SVID int64, st int64) (err error)

UpdateSyncStatus update video_repository sync_status

func (*Dao) UpdateTaskLastCheck 

func (d *Dao) UpdateTaskLastCheck(c context.Context, taskName string, lastCheck int64) (num int64, err error)

UpdateTaskLastCheck 更新上次执行时间

func (*Dao) UpdateUVSt 

func (d *Dao) UpdateUVSt(mid int64, field string) (err error)

UpdateUVSt 更新用户视频统计信息

func (*Dao) UpdateUVStDel 

func (d *Dao) UpdateUVStDel(mid int64, field string) (err error)

UpdateUVStDel ...

func (*Dao) UpdateUpUserDmg 

func (d *Dao) UpdateUpUserDmg(c context.Context, upUserDmg *model.UpUserDmg) (num int64, err error)

UpdateUpUserDmg .

func (*Dao) UpdateVideoUploadProcessStatus 

func (d *Dao) UpdateVideoUploadProcessStatus(ctx context.Context, SVID int64, st int64) (err error)

UpdateVideoUploadProcessStatus ...

func (*Dao) UserProfileGet 

func (d *Dao) UserProfileGet(c context.Context) (jobURL []string, err error)

UserProfileGet ...

func (*Dao) UsersByLast 

func (d *Dao) UsersByLast(c context.Context, lastid int64) (r []*model.UserBaseDB, err error)

UsersByLast 使用lastid批量获取用户

func (*Dao) VideoList 

func (d *Dao) VideoList(c context.Context, id int64) (ids string, res []*v1.VideoESInfo, err error)

VideoList 获取视频基础信息

func (*Dao) VideoListByIDs 

func (d *Dao) VideoListByIDs(c context.Context, ids string) (res []*v1.VideoESInfo, err error)

VideoListByIDs 根据视频id获取视频基础信息

func (*Dao) VideoStatisticsHiveList 

func (d *Dao) VideoStatisticsHiveList(c context.Context, ids string) (res map[int64]*v1.VideoESInfo, err error)

VideoStatisticsHiveList 获取视频互动信息，hive表

func (*Dao) VideoStatisticsList 

func (d *Dao) VideoStatisticsList(c context.Context, ids string) (res map[int64]*v1.VideoESInfo, err error)

VideoStatisticsList 获取视频互动信息

func (*Dao) VideoTagsList 

func (d *Dao) VideoTagsList(c context.Context, ids string) (res map[int64][]*v1.VideoESTags, err error)

VideoTagsList 获取视频tags

func (*Dao) VideosByLast 

func (d *Dao) VideosByLast(c context.Context, lastid int64) (svinfo []*model.VideoDB, err error)

VideosByLast 使用lastid批量获取视屏

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.