service

Documentation

Index

• type Service
  • func New(c *conf.Config) (s *Service)
  • func (s *Service) AccountExp(c context.Context, mid, exp int64) (err error)
  • func (s *Service) AccountReg(c context.Context, mid int64) (err error)
  • func (s *Service) AccountViewVideo(c context.Context, mid int64) (err error)
  • func (s *Service) BlockedKPIInfo(c context.Context, mid int64, rage int16) (err error)
  • func (s *Service) Close()
  • func (s *Service) DanmakuReport(c context.Context, d *model.DMAction) (err error)
  • func (s *Service) PayOrderInfo(c context.Context, mid, money int64, merchant int8) (err error)
  • func (s *Service) Ping(c context.Context) (err error)
  • func (s *Service) PutCoinInfo(c context.Context, msg *coinm.DataBus) (err error)
  • func (s *Service) PutReplyInfo(c context.Context, info *model.ReplyEvent) (err error)
  • func (s *Service) PutSpyScore(c context.Context, sc *spym.ScoreChange) (err error)
  • func (s *Service) SyncUserVIP(ctx context.Context, file string)
  • func (s *Service) UpdateVipStatus(c context.Context, mid int64, vs int32) (err error)

Types

type Service

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

Service biz service def.

func New

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

New new a Service and return.

func (*Service) AccountExp

func (s *Service) AccountExp(c context.Context, mid, exp int64) (err error)

AccountExp handle user exp chenage message

func (*Service) AccountReg

func (s *Service) AccountReg(c context.Context, mid int64) (err error)

AccountReg handle user register message, init user figure info

func (*Service) AccountViewVideo

func (s *Service) AccountViewVideo(c context.Context, mid int64) (err error)

AccountViewVideo handle user view video message

func (*Service) BlockedKPIInfo

func (s *Service) BlockedKPIInfo(c context.Context, mid int64, rage int16) (err error)

BlockedKPIInfo .

func (*Service) Close

func (s *Service) Close()

Close close all dao.

func (*Service) DanmakuReport

func (s *Service) DanmakuReport(c context.Context, d *model.DMAction) (err error)

DanmakuReport .

func (*Service) PayOrderInfo

func (s *Service) PayOrderInfo(c context.Context, mid, money int64, merchant int8) (err error)

PayOrderInfo handle user coin chenage message

func (*Service) Ping

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

Ping check dao health.

func (*Service) PutCoinInfo

func (s *Service) PutCoinInfo(c context.Context, msg *coinm.DataBus) (err error)

PutCoinInfo handle user coin chenage message

func (*Service) PutReplyInfo

func (s *Service) PutReplyInfo(c context.Context, info *model.ReplyEvent) (err error)

PutReplyInfo handle user reply info chenage message

func (*Service) PutSpyScore

func (s *Service) PutSpyScore(c context.Context, sc *spym.ScoreChange) (err error)

PutSpyScore handle user spy score chenage message

func (*Service) SyncUserVIP

func (s *Service) SyncUserVIP(ctx context.Context, file string)

func (*Service) UpdateVipStatus

func (s *Service) UpdateVipStatus(c context.Context, mid int64, vs int32) (err error)

UpdateVipStatus handle user vip staus change