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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	//HBaseArchiveTablePrefix 分类分端播放
	HBaseArchiveTablePrefix = "video_play_category_"
	//HBaseFamilyPlat  family
	HBaseFamilyPlat = []byte("v")
)

Functions

This section is empty.

Types

type Dao 

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

Dao dao

func New 

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

New fn

func (*Dao) AIDs 

func (d *Dao) AIDs(c context.Context, tagID int, offset int64, limit int64, month string, date time.Time) (aids []*model.AID, err error)

AIDs get aids by tagID

func (*Dao) AIDsByMID 

func (d *Dao) AIDsByMID(c context.Context, mid int64, tagID int, offset int64, limit int64, month string, date time.Time) (aids []*model.AID, err error)

AIDsByMID get aids by mid and tagID

func (*Dao) ActivityMIDExist 

func (d *Dao) ActivityMIDExist(c context.Context, tagID, mid int64) (info *model.TagInfo, err error)

ActivityMIDExist activity mid exist.

func (*Dao) ActivityTagInfo 

func (d *Dao) ActivityTagInfo(c context.Context, date time.Time) (infos []*model.TagUpInfo, err error)

ActivityTagInfo get activity_id tag.

func (*Dao) AddBlacklistBatch 

func (d *Dao) AddBlacklistBatch(c context.Context, blacklist []*model.Blacklist) (count int64, err error)

AddBlacklistBatch add batch to blacklist

func (*Dao) ArchiveStat 

func (d *Dao) ArchiveStat(c context.Context, aid int64, date time.Time) (stat *model.ArchiveStat, err error)

ArchiveStat get the stat of archive.

func (*Dao) AvBreachRecord 

func (d *Dao) AvBreachRecord(c context.Context, id int64, limit int64) (last int64, ds map[int64]bool, err error)

AvBreachRecord get av_ids deducted

func (*Dao) AvChargeRatio 

func (d *Dao) AvChargeRatio(c context.Context, id int64, limit int64) (m map[int64]*model.AvChargeRatio, last int64, err error)

AvChargeRatio get av_charge_ratio

func (*Dao) AvDailyIncCharge 

func (d *Dao) AvDailyIncCharge(c context.Context, avID int64) (incCharge, tagID int64, err error)

AvDailyIncCharge get av_daily_charge inc_charge

func (*Dao) Avs 

func (d *Dao) Avs(c context.Context, date time.Time, aids []int64) (cs map[int64]*model.Cheating, err error)

Avs get avs in av_income_statis

func (*Dao) BatchUpdateUpIncome 

func (d *Dao) BatchUpdateUpIncome(c context.Context, table, values string) (rows int64, err error)

BatchUpdateUpIncome batch update av_base_income

func (*Dao) BeginTran 

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

BeginTran begin transcation

func (*Dao) Close 

func (d *Dao) Close()

Close close connections of mc, redis, db.

func (*Dao) CommonTagInfo 

func (d *Dao) CommonTagInfo(c context.Context, startAt time.Time) (tagInfos []*model.TagUpInfo, err error)

CommonTagInfo get common tag infos

func (*Dao) DelActivity 

func (d *Dao) DelActivity(c context.Context, limit int64) (rows int64, err error)

DelActivity clear activity_info table.

func (*Dao) DelArchiveSpy 

func (d *Dao) DelArchiveSpy(c context.Context, limit int64) (rows int64, err error)

DelArchiveSpy del archive spy

func (*Dao) DelAvRatio 

func (d *Dao) DelAvRatio(c context.Context, limit int64) (rows int64, err error)

DelAvRatio clear av_charge_ratio table

func (*Dao) DelIncome 

func (d *Dao) DelIncome(c context.Context, limit int64) (rows int64, err error)

DelIncome clear up_tag_income table

func (*Dao) DelUpSpy 

func (d *Dao) DelUpSpy(c context.Context, limit int64) (rows int64, err error)

DelUpSpy del up spy

func (*Dao) DoAvBreach 

func (d *Dao) DoAvBreach(c context.Context, mid int64, aid int64, ctype int, reason string) (err error)

DoAvBreach av breach by api.

func (*Dao) DoUpDismiss 

func (d *Dao) DoUpDismiss(c context.Context, mid int64, ctype int, reason string) (err error)

DoUpDismiss up dismiss by api

func (*Dao) DoUpForbid 

func (d *Dao) DoUpForbid(c context.Context, mid int64, days int, ctype int, reason string) (err error)

DoUpForbid up forbid by api

func (*Dao) DoUpPass 

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

DoUpPass up pass by api

func (*Dao) GetAV 

func (d *Dao) GetAV(c context.Context, date time.Time) (infos []*model.IncomeInfo, err error)

GetAV get av income.

func (*Dao) GetActivityAVInfo 

func (d *Dao) GetActivityAVInfo(c context.Context, pn, ps int, activities []int64) (info []*model.ActivityAVInfo, total int, err error)

GetActivityAVInfo get avid by http.

func (*Dao) GetActivityBonus 

func (d *Dao) GetActivityBonus(c context.Context, id int64) (actBonus map[int64]int64, err error)

GetActivityBonus get activity_bonus by activity_id

func (*Dao) GetAllSignedUps 

func (d *Dao) GetAllSignedUps(c context.Context, data time.Time) (count int, err error)

GetAllSignedUps get all signed ups.

func (*Dao) GetAllTypes 

func (d *Dao) GetAllTypes(c context.Context) (rmap map[int16]int16, err error)

GetAllTypes get all types.

func (*Dao) GetArchiveInfo 

func (d *Dao) GetArchiveInfo(c context.Context, activityID, id int64, limit int) (avs []*model.ArchiveStat, err error)

GetArchiveInfo get activity archive info

func (*Dao) GetAvBaseIncome 

func (d *Dao) GetAvBaseIncome(c context.Context, table string, id, limit int64) (abs []*model.AvBaseIncome, last int64, err error)

GetAvBaseIncome get up av baseincome

func (*Dao) GetAvBreach 

func (d *Dao) GetAvBreach(c context.Context, start, end string) (avs []*model.AvBreach, err error)

GetAvBreach get av_breach by date

func (*Dao) GetAvBreachPre 

func (d *Dao) GetAvBreachPre(c context.Context, ctype, state int, cdate string) (avs []*model.AvBreach, err error)

GetAvBreachPre get av breach pre by date and state

func (*Dao) GetAvCharges 

func (d *Dao) GetAvCharges(c context.Context, avIds []int64, date string) (charges map[int64]int64, err error)

GetAvCharges get av charges

func (*Dao) GetAvIncome 

func (d *Dao) GetAvIncome(c context.Context, date time.Time, id, limit int64) (infos []*model.IncomeInfo, err error)

GetAvIncome get av income info from av_income.

func (*Dao) GetAvIncomeInfo 

func (d *Dao) GetAvIncomeInfo(c context.Context, avID int64, date time.Time) (info *model.TagAvIncome, err error)

GetAvIncomeInfo get av income from av_income.

func (*Dao) GetAvStatisCount 

func (d *Dao) GetAvStatisCount(c context.Context) (cnt int, err error)

GetAvStatisCount get av_income_statis count

func (*Dao) GetAvTagRatio 

func (d *Dao) GetAvTagRatio(c context.Context, from, limit int64) (infos []*model.ActivityAVInfo, err error)

GetAvTagRatio get av tag info from av_charge_ratio.

func (*Dao) GetAvUploadByMID 

func (d *Dao) GetAvUploadByMID(c context.Context, id int64, limit int) (avs []*model.AvUpload, err error)

GetAvUploadByMID get up_av_info by mid

func (*Dao) GetAvs 

func (d *Dao) GetAvs(c context.Context, date string, mid int64) (avs map[int64]*model.Av, err error)

GetAvs avs map[av_id]*model.Av

func (*Dao) GetBGMIncome 

func (d *Dao) GetBGMIncome(c context.Context) (statis map[int64]int64, err error)

GetBGMIncome map[sid]totalIncome

func (*Dao) GetCActivities 

func (d *Dao) GetCActivities(c context.Context) (acs []*model.CActivity, err error)

GetCActivities get activity by query

func (*Dao) GetCreditScore 

func (d *Dao) GetCreditScore(c context.Context, table string, id int64, limit int64) (scores map[int64]int, last int64, err error)

GetCreditScore get credit scores

func (*Dao) GetDateSignedUps 

func (d *Dao) GetDateSignedUps(c context.Context, startAt time.Time, endAt time.Time) (count int, err error)

GetDateSignedUps get date signed ups

func (*Dao) GetExecuteOrder 

func (d *Dao) GetExecuteOrder(c context.Context, startTime, endTime time.Time) (executeOrders []*model.ExecuteOrder, err error)

GetExecuteOrder get execute order by date

func (*Dao) GetHasSignUpInfo 

func (d *Dao) GetHasSignUpInfo(c context.Context, offset, limit int, m map[int64]string) (err error)

GetHasSignUpInfo get all has signed up info

func (*Dao) GetLastCtime 

func (d *Dao) GetLastCtime(c context.Context, reason int) (ctime int64, err error)

GetLastCtime get last ctime by query

func (*Dao) GetLotteryRIDs 

func (d *Dao) GetLotteryRIDs(c context.Context, start, end, offset int64) (info *model.LotteryRes, err error)

GetLotteryRIDs get lottery id

func (*Dao) GetMID 

func (d *Dao) GetMID(c context.Context, TagID int64) (infos []*model.MIDInfo, err error)

GetMID get tag mid.

func (*Dao) GetNickname 

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

GetNickname get nickname by mid.

func (*Dao) GetTag 

func (d *Dao) GetTag(c context.Context, date time.Time) (infos []*model.TagInfo, err error)

GetTag get tag.

func (*Dao) GetTagAvTotalIncome 

func (d *Dao) GetTagAvTotalIncome(c context.Context, tagID, avID int64) (infos []*model.AvIncome, err error)

GetTagAvTotalIncome get av total_income from up_tag_income.

func (*Dao) GetTagTotalIncome 

func (d *Dao) GetTagTotalIncome(c context.Context, tagIDs []int64) (infos []*model.TagInfo, err error)

GetTagTotalIncome get tag and totalIncome from tag_info.

func (*Dao) GetTotalExpenseByDate 

func (d *Dao) GetTotalExpenseByDate(c context.Context, date string) (expense map[int64]int64, err error)

GetTotalExpenseByDate get expense_daily_info by date

func (*Dao) GetUpBaseInfo 

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

GetUpBaseInfo get up_base_info

func (*Dao) GetUpChargeRatio 

func (d *Dao) GetUpChargeRatio(c context.Context, tagID int64) (ups map[int64]int64, err error)

GetUpChargeRatio get up_charge_ratio

func (*Dao) GetUpCreditScore 

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

GetUpCreditScore get up credit score

func (*Dao) GetUpIncome 

func (d *Dao) GetUpIncome(c context.Context, date time.Time, from, limit int64) (infos []*model.MIDInfo, err error)

GetUpIncome get up date income.

func (*Dao) GetUpIncomeDate 

func (d *Dao) GetUpIncomeDate(c context.Context, mids []int64, table, date string) (ups map[int64]int64, err error)

GetUpIncomeDate get up_income by date

func (*Dao) GetUpIncomeStatis 

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

GetUpIncomeStatis get up_income_statis

func (*Dao) GetUpQuality 

func (d *Dao) GetUpQuality(c context.Context, table string, id int64, limit int) (up []*model.UpQuality, last int64, err error)

GetUpQuality get up_quality_info

func (*Dao) GetUpStateByMID 

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

GetUpStateByMID get up account_state

func (*Dao) GetUpTotalIncome 

func (d *Dao) GetUpTotalIncome(c context.Context, from, limit int64) (infos []*model.MIDInfo, err error)

GetUpTotalIncome get up totalIncome.

func (*Dao) GetUpTotalIncomeCnt 

func (d *Dao) GetUpTotalIncomeCnt(c context.Context) (upCnt int, err error)

GetUpTotalIncomeCnt get up t-2 total income > 0 upcnt

func (*Dao) GetVideoApplyUpCount 

func (d *Dao) GetVideoApplyUpCount(c context.Context, startAt, endAt time.Time) (count int, err error)

GetVideoApplyUpCount get up_info_video count

func (*Dao) InsertAvBreachPre 

func (d *Dao) InsertAvBreachPre(c context.Context, val string) (rows int64, err error)

InsertAvBreachPre insert into av_breach_pre

func (*Dao) InsertBGMIncomeStatis 

func (d *Dao) InsertBGMIncomeStatis(c context.Context, sid int64, income int64) (rows int64, err error)

InsertBGMIncomeStatis fix bgm income statis

func (*Dao) InsertBgmWhiteList 

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

InsertBgmWhiteList insert into bgm_white_list

func (*Dao) InsertBubbleIncome 

func (d *Dao) InsertBubbleIncome(c context.Context, vals string) (rows int64, err error)

InsertBubbleIncome insert lottery income

func (*Dao) InsertBubbleMeta 

func (d *Dao) InsertBubbleMeta(c context.Context, values string) (rows int64, err error)

InsertBubbleMeta insert lottery avs

func (*Dao) InsertCheatArchives 

func (d *Dao) InsertCheatArchives(c context.Context, values string) (rows int64, err error)

InsertCheatArchives insert cheat archives

func (*Dao) InsertCheatUps 

func (d *Dao) InsertCheatUps(c context.Context, values string) (rows int64, err error)

InsertCheatUps insert cheat ups

func (*Dao) InsertDailyExpense 

func (d *Dao) InsertDailyExpense(c context.Context, e *model.BudgetExpense) (rows int64, err error)

InsertDailyExpense insert expense_daily_info

func (*Dao) InsertMonthlyExpense 

func (d *Dao) InsertMonthlyExpense(c context.Context, e *model.BudgetExpense) (rows int64, err error)

InsertMonthlyExpense insert expense_monthly_info

func (*Dao) InsertRatio 

func (d *Dao) InsertRatio(c context.Context, values string) (rows int64, err error)

InsertRatio insert av charge ratio

func (*Dao) InsertTaskStatus 

func (d *Dao) InsertTaskStatus(c context.Context, typ, status int, date, message string) (rows int64, err error)

InsertTaskStatus insert task status

func (*Dao) InsertUpActivityBatch 

func (d *Dao) InsertUpActivityBatch(c context.Context, vals string) (count int64, err error)

InsertUpActivityBatch insert up_activity

func (*Dao) InsertUpBillBatch 

func (d *Dao) InsertUpBillBatch(c context.Context, values string) (rows int64, err error)

InsertUpBillBatch insert up_bill

func (*Dao) ListAvIncome 

func (d *Dao) ListAvIncome(c context.Context, id int64, limit int) (avIncome []*model.AvIncome, err error)

ListAvIncome list av income by query

func (*Dao) ListBlacklist 

func (d *Dao) ListBlacklist(c context.Context, query string, from, limit int) (backlists []*model.Blacklist, err error)

ListBlacklist list all blacklist

func (*Dao) ListUpAccount 

func (d *Dao) ListUpAccount(c context.Context, withdrawDate, ctime string, from, limit int) (upAct []*model.UpAccount, err error)

ListUpAccount list up_acoount by date

func (*Dao) ListUpActivity 

func (d *Dao) ListUpActivity(c context.Context, id int64) (ups []*model.UpActivity, err error)

ListUpActivity get up from up_activity

func (*Dao) ListUpIncome 

func (d *Dao) ListUpIncome(c context.Context, table, date string, id int64, limit int) (um []*model.UpIncome, err error)

ListUpIncome list up_income_? by date

func (*Dao) ListUpNickname 

func (d *Dao) ListUpNickname(c context.Context, mids []int64, m map[int64]string) (err error)

ListUpNickname list up_category_info by mids

func (*Dao) ListUpSignedAvs 

func (d *Dao) ListUpSignedAvs(c context.Context, id int64, limit int) (ups map[int64]int64, last int64, err error)

ListUpSignedAvs list up_signed_avs

func (*Dao) ListUpWithdraw 

func (d *Dao) ListUpWithdraw(c context.Context, date string, from, limit int) (ups map[int64]int64, err error)

ListUpWithdraw list up_withdraw_income by date

func (*Dao) MIDToAV 

func (d *Dao) MIDToAV(c context.Context, mid int64, category int, date time.Time) (infos []*model.TagInfo, err error)

MIDToAV no common tag av.

func (*Dao) MIDs 

func (d *Dao) MIDs(c context.Context, offset, limit int64) (last int64, mids []int64, err error)

MIDs get mids from up_info_viode

func (*Dao) MIDsByState 

func (d *Dao) MIDsByState(c context.Context, state int, table string) (result map[int64]xtime.Time, err error)

MIDsByState get mids and expired

func (*Dao) MIDsByStateType 

func (d *Dao) MIDsByStateType(c context.Context, typ int, state int, table string) (result map[int64]xtime.Time, err error)

MIDsByStateType get mids and expired by account_type and account_state

func (*Dao) NoCommonTagInfo 

func (d *Dao) NoCommonTagInfo(c context.Context, startAt time.Time) (tagInfos []*model.TagUpInfo, err error)

NoCommonTagInfo get no common tag infos

func (*Dao) Ping 

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

Ping ping health.

func (*Dao) PlayCount 

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

PlayCount get play count in up_base_statistics

func (*Dao) SyncCreditScore 

func (d *Dao) SyncCreditScore(c context.Context, values string) (rows int64, err error)

SyncCreditScore sync credit score

func (*Dao) TagToAV 

func (d *Dao) TagToAV(c context.Context, category int, date time.Time) (infos []*model.TagInfo, err error)

TagToAV common tag av.

func (*Dao) TaskStatus 

func (d *Dao) TaskStatus(c context.Context, date string, typ int) (status int, err error)

TaskStatus get task status

func (*Dao) TotalIncome 

func (d *Dao) TotalIncome(c context.Context, date time.Time, from, limit int64) (infos []*model.IncomeInfo, err error)

TotalIncome get date totalincome,upcount, avcount

func (*Dao) TxInsertTagIncome 

func (d *Dao) TxInsertTagIncome(tx *sql.Tx, sql string) (rows int64, err error)

TxInsertTagIncome insert tag_income.

func (*Dao) TxUpdateTagInfo 

func (d *Dao) TxUpdateTagInfo(tx *sql.Tx, tagID int64, query string) (rows int64, err error)

TxUpdateTagInfo update tag_info total_income.

func (*Dao) TxUpdateTagUpInfo 

func (d *Dao) TxUpdateTagUpInfo(tx *sql.Tx, query string) (rows int64, err error)

TxUpdateTagUpInfo update tag_up_info totalIncome.

func (*Dao) UpInfoVideo 

func (d *Dao) UpInfoVideo(c context.Context, offset int64, limit int64) (last int64, ups map[int64]*model.UpInfoVideo, err error)

UpInfoVideo get up_info_video

func (*Dao) UpdateAccountState 

func (d *Dao) UpdateAccountState(c context.Context, state int, mids []int64, table string) (rows int64, err error)

UpdateAccountState update account state

func (*Dao) UpdateAvBreachPre 

func (d *Dao) UpdateAvBreachPre(c context.Context, aid, ctype int64, date string, state int) (rows int64, err error)

UpdateAvBreachPre update av breach pre

func (*Dao) UpdateDate 

func (d *Dao) UpdateDate(tx *sql.Tx, stmt string) (count int64, err error)

UpdateDate update date

func (*Dao) UpdateTaskStatus 

func (d *Dao) UpdateTaskStatus(c context.Context, date string, typ int, status int) (rows int64, err error)

UpdateTaskStatus update task status

func (*Dao) UpdateUpActivityState 

func (d *Dao) UpdateUpActivityState(c context.Context, id int64, oldState, newState int) (count int64, err error)

UpdateUpActivityState update up_activity state

func (*Dao) UpdateUpInfo 

func (d *Dao) UpdateUpInfo(c context.Context, values string) (rows int64, err error)

UpdateUpInfo update up_info_video

func (*Dao) Ups 

func (d *Dao) Ups(c context.Context, mids []int64) (cs map[int64]*model.Cheating, err error)

Ups get ups in up_info_video

func (*Dao) VoteBIZArchive 

func (d *Dao) VoteBIZArchive(c context.Context, start, end int64) (data []*model.VoteBIZArchive, err error)

VoteBIZArchive fetch avs in vote biz

Source Files

View all Source files

Directories

Path Synopsis

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.