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

Documentation

Index

Constants

View Source 
const (
	// HBaseUpStatTablePrefix hbase up_stat_date
	HBaseUpStatTablePrefix = "up_stats_"
)

Variables

This section is empty.

Functions

func Div 

func Div(x, y float64) float64

Div div

func DivWithRound 

func DivWithRound(x, y float64, places int) float64

DivWithRound div with round

func Mul 

func Mul(x, y float64) float64

Mul mul

func MulWithRound 

func MulWithRound(x, y float64, places int) float64

MulWithRound mul with round

func Round 

func Round(val float64, places int) float64

Round round

Types

type Dao 

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

Dao def dao struct

func New 

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

New fn

func (*Dao) AccountInfos 

func (d *Dao) AccountInfos(c context.Context, mids []int64) (infos map[int64]*model.ActUpInfo, err error)

AccountInfos get account infos

func (*Dao) AddCache 

func (d *Dao) AddCache(f func())

AddCache add to chan for cache

func (*Dao) AddToAwardRecord 

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

AddToAwardRecord add to award record

func (*Dao) ArticleStat 

func (d *Dao) ArticleStat(c context.Context, mid int64, ip string) (res article.UpStat, err error)

ArticleStat article stat

func (*Dao) AvUpStatus 

func (d *Dao) AvUpStatus(c context.Context, mid int64) (status *model.BusinessStatus, err error)

AvUpStatus return av up status

func (*Dao) AwardBonus 

func (d *Dao) AwardBonus(c context.Context, awardID, prizeID int64) (bonus int64, err error)

AwardBonus get bonus by award_id and prize_id

func (*Dao) AwardIDsByWinner 

func (d *Dao) AwardIDsByWinner(c context.Context, mid int64) (am map[int64]int64, err error)

AwardIDsByWinner get winner's record, am map[award_id]prize_id

func (*Dao) BGMCount 

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

BGMCount get up bgm count

func (*Dao) Banner 

func (d *Dao) Banner(c context.Context, t int64) (b *model.Banner, err error)

Banner get banner

func (*Dao) BaseUpStat 

func (d *Dao) BaseUpStat(c context.Context, mid int64, date string) (stat *model.UpBaseStat, err error)

BaseUpStat get base up stat.

func (*Dao) BeginTran 

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

BeginTran begin transcation

func (*Dao) BgmUpCount 

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

BgmUpCount bgm up count in table background_music

func (*Dao) BgmUpStatus 

func (d *Dao) BgmUpStatus(c context.Context, mid int64) (status *model.BusinessStatus, err error)

BgmUpStatus return bgm up status

func (*Dao) BgmWhiteList 

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

BgmWhiteList bgm_white_list

func (*Dao) Blocked 

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

Blocked query mid in blacklist

func (*Dao) Card 

func (d *Dao) Card(c context.Context, mid int64) (res *account.Card, err error)

Card get account.

func (*Dao) CategoryInfo 

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

CategoryInfo return nickname & categoryID

func (*Dao) Close 

func (d *Dao) Close()

Close close db conn

func (*Dao) ColumnUpStatus 

func (d *Dao) ColumnUpStatus(c context.Context, mid int64) (status *model.BusinessStatus, err error)

ColumnUpStatus return bgm up status

func (*Dao) CreditScore 

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

CreditScore get current credit score from up_info_video

func (*Dao) DelCacheKey 

func (d *Dao) DelCacheKey(c context.Context, key string) (err error)

DelCacheKey del redis key

func (*Dao) DivisionName 

func (d *Dao) DivisionName(c context.Context, mid int64) (names map[int64]string, err error)

DivisionName division name by mid, names map[award_id]division_name

func (*Dao) ExchangeBigVIP 

func (d *Dao) ExchangeBigVIP(c context.Context, mid, resourceID, orderNo int64, remark string) (err error)

ExchangeBigVIP exchange big vip

func (*Dao) Fans 

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

Fans return fans count

func (*Dao) GetAccountState 

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

GetAccountState account state

func (*Dao) GetActivity 

func (d *Dao) GetActivity(c context.Context, id int64) (ac *model.CActivity, err error)

GetActivity get activity by query

func (*Dao) GetAvBreachByType 

func (d *Dao) GetAvBreachByType(c context.Context, mid int64, begin string, end string, typ []int64) (rs map[xtime.Time]int64, err error)

GetAvBreachByType get av breach record

func (*Dao) GetAvBreachs 

func (d *Dao) GetAvBreachs(c context.Context, avs []int64, ctype int) (breachs map[int64]*model.AvBreach, err error)

GetAvBreachs get av_breach map by avids

func (*Dao) GetAwardJoinRecord 

func (d *Dao) GetAwardJoinRecord(c context.Context, mid int64) (awardIDs map[int64]bool, err error)

GetAwardJoinRecord get award join record

func (*Dao) GetAwardSchedule 

func (d *Dao) GetAwardSchedule(c context.Context, awardID int64) (award *model.SpecialAward, err error)

GetAwardSchedule get special award by award id

func (*Dao) GetAwardWinRecord 

func (d *Dao) GetAwardWinRecord(c context.Context, mid int64) (awardIDs map[int64]bool, err error)

GetAwardWinRecord get award win record

func (*Dao) GetBgmTitle 

func (d *Dao) GetBgmTitle(c context.Context, ids []int64) (titles map[int64]string, err error)

GetBgmTitle get bgm titles

func (*Dao) GetColumnTitle 

func (d *Dao) GetColumnTitle(c context.Context, ids []int64) (titles map[int64]string, err error)

GetColumnTitle get column title by id

func (*Dao) GetDisplayGoods 

func (d *Dao) GetDisplayGoods(c context.Context, isDisplay int) (goods []*model.GoodsInfo, err error)

GetDisplayGoods get up from up_activity

func (*Dao) GetFirstUpIncome 

func (d *Dao) GetFirstUpIncome(c context.Context, mid int64) (date time.Time, err error)

GetFirstUpIncome get first up income

func (*Dao) GetGoodsByProductID 

func (d *Dao) GetGoodsByProductID(c context.Context, productID string, goodsType int) (goods *model.GoodsInfo, err error)

GetGoodsByProductID get goods by product id

func (*Dao) GetGoodsOrderCount 

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

GetGoodsOrderCount get order count

func (*Dao) GetGoodsOrders 

func (d *Dao) GetGoodsOrders(c context.Context, mid int64, start, end int) (orders []*model.GoodsOrder, err error)

GetGoodsOrders get orders

func (*Dao) GetIncomeCache 

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

GetIncomeCache get income cache

func (*Dao) GetResources 

func (d *Dao) GetResources(c context.Context, awardID int64) (res map[int]map[int]string, err error)

GetResources get special award resource map[type]map[index]content

func (*Dao) GetSpecialAwardDivision 

func (d *Dao) GetSpecialAwardDivision(c context.Context, awardID int64) (divisions []string, err error)

GetSpecialAwardDivision get special award division name

func (*Dao) GetSpecialAwards 

func (d *Dao) GetSpecialAwards(c context.Context) (awards []*model.SpecialAward, err error)

GetSpecialAwards get all display sepcial award

func (*Dao) GetUpAccountCount 

func (d *Dao) GetUpAccountCount(c context.Context, dateVersion string) (count int, err error)

GetUpAccountCount get up account withdraw count

func (*Dao) GetUpBill 

func (d *Dao) GetUpBill(c context.Context, mid int64) (up *model.UpBill, err error)

GetUpBill get up bill by mid

func (*Dao) GetUpDailyCharge 

func (d *Dao) GetUpDailyCharge(c context.Context, mid int64, begin string) (incs []int, err error)

GetUpDailyCharge get up daily charge

func (*Dao) GetUpIncome 

func (d *Dao) GetUpIncome(c context.Context, mid int64, begin string, end string) (result []*model.UpIncomeStat, err error)

GetUpIncome list up income by date

func (*Dao) GetUpIncomeCount 

func (d *Dao) GetUpIncomeCount(c context.Context, date string) (count int, err error)

GetUpIncomeCount get up income count by date

func (*Dao) GetUpSignedAt 

func (d *Dao) GetUpSignedAt(c context.Context, table string, mid int64) (signedAt time.Time, err error)

GetUpSignedAt get up signed_at

func (*Dao) GetUpYearTag 

func (d *Dao) GetUpYearTag(c context.Context, mid int64) (tags []int64, income int64, err error)

GetUpYearTag get up year tag income

func (*Dao) GetWinners 

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

GetWinners get winner mids by award_id

func (*Dao) InsertUpInfo 

func (d *Dao) InsertUpInfo(c context.Context, table string, totalCountField string, v *model.UpInfo) (rows int64, err error)

InsertUpInfo add upinfo

func (*Dao) InsertUpWithdrawRecord 

func (d *Dao) InsertUpWithdrawRecord(c context.Context, upWithdraw *model.UpIncomeWithdraw) (result int64, err error)

InsertUpWithdrawRecord insert record into up_income_withdraw

func (*Dao) JoinedCount 

func (d *Dao) JoinedCount(c context.Context, mid, awardID int64) (count int64, err error)

JoinedCount get signed up count by mid, award_id

func (*Dao) JoinedSpecialAwards 

func (d *Dao) JoinedSpecialAwards(c context.Context, awardIDs []int64) (sas []*model.SpecialAward, err error)

JoinedSpecialAwards get joined awards

func (*Dao) LatestNotice 

func (d *Dao) LatestNotice(c context.Context, platform int) (n *model.Notice, err error)

LatestNotice latest notice

func (*Dao) ListActiveInfo 

func (d *Dao) ListActiveInfo(c context.Context, avIds []int64) (acM map[int64]int64, err error)

ListActiveInfo list active_info by avid

func (*Dao) ListAvBlackList 

func (d *Dao) ListAvBlackList(c context.Context, avIds []int64, typ int) (avb map[int64]struct{}, err error)

ListAvBlackList list av_blakc_list by av_id

func (*Dao) ListAvBreach 

func (d *Dao) ListAvBreach(c context.Context, mid int64, startTime, endTime string) (records []*model.AvBreach, err error)

ListAvBreach list av_breach_record by mid

func (*Dao) ListAvIncome 

func (d *Dao) ListAvIncome(c context.Context, mid int64, startTime, endTime string) (avs []*model.ArchiveIncome, err error)

ListAvIncome list av_income by mid

func (*Dao) ListAvIncomeByID 

func (d *Dao) ListAvIncomeByID(c context.Context, avID int64, endTime string) (avs []*model.ArchiveIncome, err error)

ListAvIncomeByID list av_income by av_id

func (*Dao) ListBgmIncome 

func (d *Dao) ListBgmIncome(c context.Context, mid int64, startTime, endTime string) (bgms []*model.ArchiveIncome, err error)

ListBgmIncome list bgm income

func (*Dao) ListBgmIncomeByID 

func (d *Dao) ListBgmIncomeByID(c context.Context, id int64, endTime string) (bgms []*model.ArchiveIncome, err error)

ListBgmIncomeByID list bgm_income by sid

func (*Dao) ListColumnIncome 

func (d *Dao) ListColumnIncome(c context.Context, mid int64, startTime, endTime string) (columns []*model.ArchiveIncome, err error)

ListColumnIncome list column_income by mid

func (*Dao) ListColumnIncomeByID 

func (d *Dao) ListColumnIncomeByID(c context.Context, id int64, endTime string) (columns []*model.ArchiveIncome, err error)

ListColumnIncomeByID list column_income by aid

func (*Dao) ListTagInfo 

func (d *Dao) ListTagInfo(c context.Context, tagIds []int64) (tagM map[int64]*model.TagInfo, err error)

ListTagInfo list tag_info by avid

func (*Dao) ListUpAccount 

func (d *Dao) ListUpAccount(c context.Context, mid int64) (up *model.UpAccount, err error)

ListUpAccount list up_account by mid

func (*Dao) ListUpActivity 

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

ListUpActivity get up from up_activity

func (*Dao) ListUpIncome 

func (d *Dao) ListUpIncome(c context.Context, mid int64, table, startTime, endTime string) (ups []*model.UpIncome, err error)

ListUpIncome list up_income by mid

func (*Dao) ListVipProducts 

func (d *Dao) ListVipProducts(c context.Context, mid int64) (r map[string]*model.GoodsInfo, err error)

ListVipProducts list vip products

func (*Dao) Nickname 

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

Nickname get nickname from up_info_video

func (*Dao) NoticeCount 

func (d *Dao) NoticeCount(c context.Context, typ string, platform int) (count int64, err error)

NoticeCount notice count

func (*Dao) Notices 

func (d *Dao) Notices(c context.Context, typ string, platform int, offset, limit int) (notices []*model.Notice, err error)

Notices notices

func (*Dao) PastAwards 

func (d *Dao) PastAwards(c context.Context) (as []*model.SimpleSpecialAward, err error)

PastAwards get award basic info

func (*Dao) Ping 

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

Ping ping db

func (*Dao) ProfileWithStat 

func (d *Dao) ProfileWithStat(c context.Context, mid int64) (res *account.ProfileStat, err error)

ProfileWithStat get account.

func (*Dao) QueryUpAccountByDate 

func (d *Dao) QueryUpAccountByDate(c context.Context, dateVersion string, from, limit int) (upAccounts []*model.UpAccount, err error)

QueryUpAccountByDate query up_account by date

func (*Dao) QueryUpWithdrawByID 

func (d *Dao) QueryUpWithdrawByID(c context.Context, id int64) (upWithdraw *model.UpIncomeWithdraw, err error)

QueryUpWithdrawByID get up_income_withdraw by id

func (*Dao) QueryUpWithdrawByMID 

func (d *Dao) QueryUpWithdrawByMID(c context.Context, mid int64) (upWithdraws []*model.UpIncomeWithdraw, err error)

QueryUpWithdrawByMID query up_income_withdraw by mid

func (*Dao) QueryUpWithdrawByMids 

func (d *Dao) QueryUpWithdrawByMids(c context.Context, mids []int64, dateVersion string) (upWithdraws map[int64]*model.UpIncomeWithdraw, err error)

QueryUpWithdrawByMids query up_income_withdraw by mids

func (*Dao) SetIncomeCache 

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

SetIncomeCache set income cache

func (*Dao) SignUpActivity 

func (d *Dao) SignUpActivity(c context.Context, up *model.UpBonus) (rows int64, err error)

SignUpActivity up sign up activity

func (*Dao) TxDeductCreditScore 

func (d *Dao) TxDeductCreditScore(tx *sql.Tx, score int, mid int64) (rows int64, err error)

TxDeductCreditScore tx update credit score

func (*Dao) TxInsertBgmUpInfo 

func (d *Dao) TxInsertBgmUpInfo(tx *sql.Tx, v *model.UpInfo) (rows int64, err error)

TxInsertBgmUpInfo insert bgm up info

func (*Dao) TxInsertCreditRecord 

func (d *Dao) TxInsertCreditRecord(tx *sql.Tx, cr *model.CreditRecord) (rows int64, err error)

TxInsertCreditRecord tx insert credit deduct record

func (*Dao) TxInsertCreditScore 

func (d *Dao) TxInsertCreditScore(tx *sql.Tx, mid int64) (rows int64, err error)

TxInsertCreditScore insert credit score

func (*Dao) TxInsertGoodsOrder 

func (d *Dao) TxInsertGoodsOrder(tx *xsql.Tx, o *model.GoodsOrder) (rows int64, err error)

TxInsertGoodsOrder insert goods order

func (*Dao) TxQueryMaxUpWithdrawDateVersion 

func (d *Dao) TxQueryMaxUpWithdrawDateVersion(tx *xsql.Tx, mid int64) (dateVersion string, err error)

TxQueryMaxUpWithdrawDateVersion query max date_version from up_income_withdraw by mid

func (*Dao) TxQueryUpAccountVersion 

func (d *Dao) TxQueryUpAccountVersion(tx *xsql.Tx, mid int64) (version int64, err error)

TxQueryUpAccountVersion query up_account version

func (*Dao) TxQuit 

func (d *Dao) TxQuit(tx *sql.Tx, table string, mid int64, quitAt, expiredIn time.Time, reason string) (rows int64, err error)

TxQuit update up status

func (*Dao) TxUpdateUpAccountExchangeIncome 

func (d *Dao) TxUpdateUpAccountExchangeIncome(tx *xsql.Tx, mid, income, version int64) (result int64, err error)

TxUpdateUpAccountExchangeIncome update up_account unwithdraw and exchange_income

func (*Dao) TxUpdateUpAccountUnwithdrawIncome 

func (d *Dao) TxUpdateUpAccountUnwithdrawIncome(tx *xsql.Tx, mid int64, dateVersion string, version int64) (result int64, err error)

TxUpdateUpAccountUnwithdrawIncome update up_account unwithdraw and version

func (*Dao) TxUpdateUpAccountWithdraw 

func (d *Dao) TxUpdateUpAccountWithdraw(tx *xsql.Tx, mid, thirdCoin int64) (result int64, err error)

TxUpdateUpAccountWithdraw update up_account withdraw

func (*Dao) TxUpdateUpWithdrawState 

func (d *Dao) TxUpdateUpWithdrawState(tx *xsql.Tx, id int64, state int) (result int64, err error)

TxUpdateUpWithdrawState update up_income_withdraw state

func (*Dao) UpBusinessInfos 

func (d *Dao) UpBusinessInfos(c context.Context, mid int64) (identify *model.UpIdentify, err error)

UpBusinessInfos get business infos

func (*Dao) UpStat 

func (d *Dao) UpStat(c context.Context, mid int64, dt string) (st *model.UpBaseStat, err error)

UpStat get up stat from hbase

func (*Dao) White 

func (d *Dao) White(c context.Context, mid int64) (m map[int]bool, err error)

White map: key: type value: bool

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.