income

Documentation

Index

• type Service
  • func New(c *conf.Config) (s *Service)
  • func (s *Service) ArchiveBlack(c context.Context, typ int, aIDs []int64, mid int64) (err error)
  • func (s *Service) ArchiveBreach(c context.Context, typ int, aids []int64, mid int64, reason string, ...) (err error)
  • func (s *Service) ArchiveChargeDetail(c context.Context, aid int64, typ int) (archives []*model.ArchiveCharge, err error)
  • func (s *Service) ArchiveChargeSection(c context.Context, categoryID []int64, typ, groupType int, ...) (data interface{}, err error)
  • func (s *Service) ArchiveChargeStatis(c context.Context, categoryID []int64, typ, groupType int, ...) (data interface{}, err error)
  • func (s *Service) ArchiveDetail(c context.Context, mid int64, typ, groupType int, fromTime, toTime int64) (archives []*model.ArchiveIncome, err error)
  • func (s *Service) ArchiveSection(c context.Context, categoryID []int64, typ, groupType int, ...) (data interface{}, err error)
  • func (s *Service) ArchiveStatis(c context.Context, categoryID []int64, typ, groupType int, ...) (data interface{}, err error)
  • func (s *Service) ArchiveTop(c context.Context, aIDs []int64, typ int, groupType int, ...) (data []*model.ArchiveIncome, total int, err error)
  • func (s *Service) BgmChargeDetail(c context.Context, sid int64) (archives []*model.ArchiveCharge, err error)
  • func (s *Service) BgmDetail(c context.Context, sid int64, fromTime, toTime int64, from, limit int) (avs []*model.ArchiveIncome, total int, err error)
  • func (s *Service) BreachList(c context.Context, mids, aids []int64, typ int, fromTime, toTime int64, ...) (breachs []*model.AvBreach, total int, err error)
  • func (s *Service) BreachStatis(c context.Context, mids, aids []int64, typ, groupType int, ...) (date interface{}, err error)
  • func (s *Service) Close()
  • func (s *Service) ExportBreach(c context.Context, mids, aids []int64, typ int, fromTime, toTime int64, ...) (res []byte, err error)
  • func (s *Service) GetArchiveByUpAccount(c context.Context, typ int, aids []int64, mid int64) (archives []*model.ArchiveIncome, withdrawMonth time.Month, err error)
  • func (s *Service) GetArchiveChargeStatis(c context.Context, table, query string) (archs []*model.ArchiveChargeStatis, err error)
  • func (s *Service) GetArchiveIncome(c context.Context, typ int, query string, from, to string) (archs []*model.ArchiveIncome, err error)
  • func (s *Service) GetArchiveStatis(c context.Context, table, query string) (avs []*model.ArchiveStatis, err error)
  • func (s *Service) GetAvBlackListByAvIds(c context.Context, avs []*model.ArchiveIncome, ctype int) (avBMap map[int64]struct{}, err error)
  • func (s *Service) GetAvCharges(c context.Context, avID int64) (avs []*model.ArchiveCharge, err error)
  • func (s *Service) GetUpAccount(c context.Context, query string, isDeleted int) (ups []*model.UpAccount, err error)
  • func (s *Service) GetUpIncome(c context.Context, table, incomeType, query string) (upIncomes []*model.UpIncome, err error)
  • func (s *Service) GetUpInfoByAIDs(c context.Context, avs []*model.ArchiveIncome) (upInfoMap map[int64]string, err error)
  • func (s *Service) GetUpWithdraw(c context.Context, query string) (upW []*model.UpIncomeWithdraw, err error)
  • func (s *Service) ListUpAccount(c context.Context, query string, isDeleted, from, limit int) (ups []*model.UpAccount, err error)
  • func (s *Service) ListUpWithdraw(c context.Context, id int64, query string, limit int) (upWithdraw []*model.UpIncomeWithdraw, err error)
  • func (s *Service) Ping(c context.Context) (err error)
  • func (s *Service) TxInsertAvBlacklist(c context.Context, tx *sql.Tx, ctype int, aIDs []int64, mid int64, reason int, ...) (err error)
  • func (s *Service) TxUpAccountBreach(c context.Context, tx *sql.Tx, mid, preMonthBreach, thisMonthBreach int64) error
  • func (s *Service) TxUpdateUpInfoScore(tx *sql.Tx, mid int64, score int) (err error)
  • func (s *Service) UpAccountCount(c context.Context, query string, isDeleted int) (total int64, err error)
  • func (s *Service) UpIncomeList(c context.Context, mids []int64, typ, groupType int, ...) (upIncome []*model.UpIncome, total int, err error)
  • func (s *Service) UpIncomeListExport(c context.Context, mids []int64, typ, groupType int, ...) (res []byte, err error)
  • func (s *Service) UpIncomeStatis(c context.Context, mids []int64, typ, groupType int, fromTime, toTime int64) (data interface{}, err error)
  • func (s *Service) UpRatio(c context.Context, from, limit int64) (map[int64]int64, error)
  • func (s *Service) UpWithdraw(c context.Context, mids []int64, isDeleted, from, limit int) (data []*model.UpWithdrawRes, total int64, err error)
  • func (s *Service) UpWithdrawDetail(c context.Context, mid int64) (upWithdraw []*model.UpIncomeWithdraw, err error)
  • func (s *Service) UpWithdrawDetailExport(c context.Context, mid int64) (res []byte, err error)
  • func (s *Service) UpWithdrawExport(c context.Context, mids []int64, isDeleted, from, limit int) (res []byte, err error)
  • func (s *Service) UpWithdrawStatis(c context.Context, from, to int64, isDeleted int) (data interface{}, err error)
  • func (s *Service) UpdateUpCredit(c context.Context, tx *sql.Tx, ctype int, mid int64, aids []int64, ...) (err error)

Types

type Service

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

Service struct

func New

func New(c *conf.Config) (s *Service)

New fn

func (*Service) ArchiveBlack

func (s *Service) ArchiveBlack(c context.Context, typ int, aIDs []int64, mid int64) (err error)

ArchiveBlack stop archives income, add archive into av_black_list

func (*Service) ArchiveBreach

func (s *Service) ArchiveBreach(c context.Context, typ int, aids []int64, mid int64, reason string, operator string) (err error)

ArchiveBreach breach archive batch

func (*Service) ArchiveChargeDetail

func (s *Service) ArchiveChargeDetail(c context.Context, aid int64, typ int) (archives []*model.ArchiveCharge, err error)

ArchiveChargeDetail archive charge details

func (*Service) ArchiveChargeSection

func (s *Service) ArchiveChargeSection(c context.Context, categoryID []int64, typ, groupType int, fromTime, toTime int64) (data interface{}, err error)

ArchiveChargeSection get av_charge section

func (*Service) ArchiveChargeStatis

func (s *Service) ArchiveChargeStatis(c context.Context, categoryID []int64, typ, groupType int, fromTime, toTime int64) (data interface{}, err error)

ArchiveChargeStatis av_charge statis

func (*Service) ArchiveDetail

func (s *Service) ArchiveDetail(c context.Context, mid int64, typ, groupType int, fromTime, toTime int64) (archives []*model.ArchiveIncome, err error)

ArchiveDetail archive detail (av column)

func (*Service) ArchiveSection

func (s *Service) ArchiveSection(c context.Context, categoryID []int64, typ, groupType int, fromTime, toTime int64) (data interface{}, err error)

ArchiveSection get av/column income section

func (*Service) ArchiveStatis

func (s *Service) ArchiveStatis(c context.Context, categoryID []int64, typ, groupType int, fromTime, toTime int64) (data interface{}, err error)

ArchiveStatis archive income statis

func (*Service) ArchiveTop

func (s *Service) ArchiveTop(c context.Context, aIDs []int64, typ int, groupType int, fromTime, toTime int64, from, limit int) (data []*model.ArchiveIncome, total int, err error)

ArchiveTop archive_income top

func (*Service) BgmChargeDetail

func (s *Service) BgmChargeDetail(c context.Context, sid int64) (archives []*model.ArchiveCharge, err error)

BgmChargeDetail bgm charge detail

func (*Service) BgmDetail

func (s *Service) BgmDetail(c context.Context, sid int64, fromTime, toTime int64, from, limit int) (avs []*model.ArchiveIncome, total int, err error)

BgmDetail bgm detail

func (*Service) BreachList

func (s *Service) BreachList(c context.Context, mids, aids []int64, typ int, fromTime, toTime int64, reason string, from, limit int) (breachs []*model.AvBreach, total int, err error)

BreachList list

func (*Service) BreachStatis

func (s *Service) BreachStatis(c context.Context, mids, aids []int64, typ, groupType int, fromTime, toTime int64, reason string) (date interface{}, err error)

BreachStatis statis

func (*Service) Close

func (s *Service) Close()

Close dao

func (*Service) ExportBreach

func (s *Service) ExportBreach(c context.Context, mids, aids []int64, typ int, fromTime, toTime int64, reason string, from, limit int) (res []byte, err error)

ExportBreach export

func (*Service) GetArchiveByUpAccount

func (s *Service) GetArchiveByUpAccount(c context.Context, typ int, aids []int64, mid int64) (archives []*model.ArchiveIncome, withdrawMonth time.Month, err error)

GetArchiveByUpAccount get archive income by withdraw date

func (*Service) GetArchiveChargeStatis

func (s *Service) GetArchiveChargeStatis(c context.Context, table, query string) (archs []*model.ArchiveChargeStatis, err error)

GetArchiveChargeStatis get archive charge date statis

func (*Service) GetArchiveIncome

func (s *Service) GetArchiveIncome(c context.Context, typ int, query string, from, to string) (archs []*model.ArchiveIncome, err error)

GetArchiveIncome get archive income

func (*Service) GetArchiveStatis

func (s *Service) GetArchiveStatis(c context.Context, table, query string) (avs []*model.ArchiveStatis, err error)

GetArchiveStatis get up income

func (*Service) GetAvBlackListByAvIds

func (s *Service) GetAvBlackListByAvIds(c context.Context, avs []*model.ArchiveIncome, ctype int) (avBMap map[int64]struct{}, err error)

GetAvBlackListByAvIds get av_black_list by av_id and ctype

func (*Service) GetAvCharges

func (s *Service) GetAvCharges(c context.Context, avID int64) (avs []*model.ArchiveCharge, err error)

GetAvCharges get av charge by av id

func (*Service) GetUpAccount

func (s *Service) GetUpAccount(c context.Context, query string, isDeleted int) (ups []*model.UpAccount, err error)

GetUpAccount get up_account

func (*Service) GetUpIncome

func (s *Service) GetUpIncome(c context.Context, table, incomeType, query string) (upIncomes []*model.UpIncome, err error)

GetUpIncome get

func (*Service) GetUpInfoByAIDs

func (s *Service) GetUpInfoByAIDs(c context.Context, avs []*model.ArchiveIncome) (upInfoMap map[int64]string, err error)

GetUpInfoByAIDs get up_info by av id

func (*Service) GetUpWithdraw

func (s *Service) GetUpWithdraw(c context.Context, query string) (upW []*model.UpIncomeWithdraw, err error)

GetUpWithdraw get up_withdraw

func (*Service) ListUpAccount

func (s *Service) ListUpAccount(c context.Context, query string, isDeleted, from, limit int) (ups []*model.UpAccount, err error)

ListUpAccount list up account bu query

func (*Service) ListUpWithdraw

func (s *Service) ListUpWithdraw(c context.Context, id int64, query string, limit int) (upWithdraw []*model.UpIncomeWithdraw, err error)

ListUpWithdraw list up_withdraw

func (*Service) Ping

func (s *Service) Ping(c context.Context) (err error)

Ping check dao health.

func (*Service) TxInsertAvBlacklist

func (s *Service) TxInsertAvBlacklist(c context.Context, tx *sql.Tx, ctype int, aIDs []int64, mid int64, reason int, count int) (err error)

TxInsertAvBlacklist insert av_black_list

func (*Service) TxUpAccountBreach

func (s *Service) TxUpAccountBreach(c context.Context, tx *sql.Tx, mid, preMonthBreach, thisMonthBreach int64) error

TxUpAccountBreach up_account breach

func (*Service) TxUpdateUpInfoScore

func (s *Service) TxUpdateUpInfoScore(tx *sql.Tx, mid int64, score int) (err error)

TxUpdateUpInfoScore update up_info_video score

func (*Service) UpAccountCount

func (s *Service) UpAccountCount(c context.Context, query string, isDeleted int) (total int64, err error)

UpAccountCount get up_account count

func (*Service) UpIncomeList

func (s *Service) UpIncomeList(c context.Context, mids []int64, typ, groupType int, fromTime, toTime, minIncome, maxIncome int64, from, limit int) (upIncome []*model.UpIncome, total int, err error)

UpIncomeList up income list

func (*Service) UpIncomeListExport

func (s *Service) UpIncomeListExport(c context.Context, mids []int64, typ, groupType int, fromTime, toTime, minIncome, maxIncome int64, from, limit int) (res []byte, err error)

UpIncomeListExport up income list

func (*Service) UpIncomeStatis

func (s *Service) UpIncomeStatis(c context.Context, mids []int64, typ, groupType int, fromTime, toTime int64) (data interface{}, err error)

UpIncomeStatis up income statis

func (*Service) UpRatio

func (s *Service) UpRatio(c context.Context, from, limit int64) (map[int64]int64, error)

UpRatio up charge ratio

func (*Service) UpWithdraw

func (s *Service) UpWithdraw(c context.Context, mids []int64, isDeleted, from, limit int) (data []*model.UpWithdrawRes, total int64, err error)

UpWithdraw get up_account infos

func (*Service) UpWithdrawDetail

func (s *Service) UpWithdrawDetail(c context.Context, mid int64) (upWithdraw []*model.UpIncomeWithdraw, err error)

UpWithdrawDetail get up withdraw by mid

func (*Service) UpWithdrawDetailExport

func (s *Service) UpWithdrawDetailExport(c context.Context, mid int64) (res []byte, err error)

UpWithdrawDetailExport export up withdraw detail

func (*Service) UpWithdrawExport

func (s *Service) UpWithdrawExport(c context.Context, mids []int64, isDeleted, from, limit int) (res []byte, err error)

UpWithdrawExport export up withdraw

func (*Service) UpWithdrawStatis

func (s *Service) UpWithdrawStatis(c context.Context, from, to int64, isDeleted int) (data interface{}, err error)

UpWithdrawStatis up_withdraw statis

func (*Service) UpdateUpCredit

func (s *Service) UpdateUpCredit(c context.Context, tx *sql.Tx, ctype int, mid int64, aids []int64, operator string) (err error)

UpdateUpCredit update up_info credit score