service

Documentation

Index

• Variables
• type ArticleService
  • func NewArticleService(repo article.ArticleRepository, l logger.LoggerV1, producer events.Producer) ArticleService
  • func NewArticleServiceV1(author article.ArticleAuthorRepository, reader article.ArticleReaderRepository, ...) ArticleService
• type CodeService
  • func NewSMSCodeService(svc sms.Service, repo repository.CodeRepository) CodeService
• type InteractiveService
  • func NewInteractiveService(repo repository.InteractiveRepository, l logger.LoggerV1) InteractiveService
• type SMSCodeService
  • func (c *SMSCodeService) Send(ctx context.Context, biz string, phone string) error
  • func (c *SMSCodeService) Verify(ctx context.Context, biz string, phone string, inputCode string) (bool, error)
• type UserService
  • func NewUserService(repo repository.UserRepository, l logger.LoggerV1) UserService
  • func NewUserServiceV1(repo repository.UserRepository, l *zap.Logger) UserService

Variables

var ErrCodeSendTooMany = repository.ErrCodeSendTooMany

var ErrInvalidUserOrPassword = errors.New("邮箱或者密码不正确")

var ErrUserDuplicateEmail = repository.ErrUserDuplicate

Types

type ArticleService

type ArticleService interface {
	Save(ctx context.Context, art domain.Article) (int64, error)
	Withdraw(ctx context.Context, art domain.Article) error
	Publish(ctx context.Context, art domain.Article) (int64, error)
	PublishV1(ctx context.Context, art domain.Article) (int64, error)
	List(ctx context.Context, uid int64, offset int, limit int) ([]domain.Article, error)
	GetById(ctx context.Context, id int64) (domain.Article, error)
	GetPublishedById(ctx context.Context, id, uid int64) (domain.Article, error)
}

func NewArticleService

func NewArticleService(repo article.ArticleRepository,
	l logger.LoggerV1,
	producer events.Producer) ArticleService

func NewArticleServiceV1

func NewArticleServiceV1(author article.ArticleAuthorRepository,
	reader article.ArticleReaderRepository, l logger.LoggerV1) ArticleService

type CodeService

type CodeService interface {
	Send(ctx context.Context, biz string, phone string) error
	Verify(ctx context.Context, biz string, phone string, inputCode string) (bool, error)
}

func NewSMSCodeService

func NewSMSCodeService(svc sms.Service, repo repository.CodeRepository) CodeService

type InteractiveService

type InteractiveService interface {
	IncrReadCnt(ctx context.Context, biz string, bizId int64) error
	// Like 点赞
	Like(ctx context.Context, biz string, bizId int64, uid int64) error
	// CancelLike 取消点赞
	CancelLike(ctx context.Context, biz string, bizId int64, uid int64) error
	// Collect 收藏, cid 是收藏夹的 ID
	// cid 不一定有，或者说 0 对应的是该用户的默认收藏夹
	Collect(ctx context.Context, biz string, bizId, cid, uid int64) error
	Get(ctx context.Context, biz string, bizId, uid int64) (domain.Interactive, error)
}

func NewInteractiveService

func NewInteractiveService(repo repository.InteractiveRepository,
	l logger.LoggerV1) InteractiveService

type SMSCodeService

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

SMSCodeService 短信验证码的实现

func (*SMSCodeService) Send

func (c *SMSCodeService) Send(ctx context.Context, biz string, phone string) error

Send 生成一个随机验证码，并发送

func (*SMSCodeService) Verify

func (c *SMSCodeService) Verify(ctx context.Context,
	biz string,
	phone string,
	inputCode string) (bool, error)

Verify 验证验证码

type UserService

type UserService interface {
	Login(ctx context.Context, email, password string) (domain.User, error)
	Signup(ctx context.Context, u domain.User) error
	FindOrCreate(ctx context.Context, phone string) (domain.User, error)
	FindOrCreateByWechat(ctx context.Context, wechatInfo domain.WechatInfo) (domain.User, error)
	Profile(ctx context.Context, id int64) (domain.User, error)
	// UpdateNonSensitiveInfo 更新非敏感数据
	// 你可以在这里进一步补充究竟哪些数据会被更新
	UpdateNonSensitiveInfo(ctx context.Context, user domain.User) error
}

func NewUserService

func NewUserService(repo repository.UserRepository, l logger.LoggerV1) UserService

func NewUserServiceV1

func NewUserServiceV1(repo repository.UserRepository, l *zap.Logger) UserService