subscribe

package
v1.0.10 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 26, 2026 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SubscribeRepo 

type SubscribeRepo interface {
	// Subscribe operations
	CreateSubscribe(ctx context.Context, sub *model.Subscribe) error
	GetSubscribeByID(ctx context.Context, id int) (*ent.ProxySubscribe, error)
	UpdateSubscribe(ctx context.Context, sub *model.Subscribe) error
	DeleteSubscribe(ctx context.Context, id int) error
	GetSubscribeList(ctx context.Context, req *model.SubscribeListParams) ([]*ent.ProxySubscribe, int32, error)
	GetSubscribePriceOptionsBySubscribeIDs(ctx context.Context, ids []int64) (map[int64][]*ent.ProxySubscribePriceOption, error)
	CheckSubscribeInUse(ctx context.Context, subscribeID int) (bool, error)
	BatchDeleteSubscribe(ctx context.Context, ids []int) error
	GetSubscribeMinSort(ctx context.Context, ids []int) (int64, error)
	BatchUpdateSubscribeSort(ctx context.Context, subscribes []*ent.ProxySubscribe) error

	// Subscribe category operations
	CreateSubscribeCategory(ctx context.Context, category *model.SubscribeCategory) error
	GetSubscribeCategoryByID(ctx context.Context, id int64) (*ent.ProxySubscribeCategory, error)
	UpdateSubscribeCategory(ctx context.Context, category *model.SubscribeCategory) error
	DeleteSubscribeCategory(ctx context.Context, id int64) error
	BatchDeleteSubscribeCategory(ctx context.Context, ids []int64) error
	GetSubscribeCategoryList(ctx context.Context, req *model.SubscribeCategoryListParams) ([]*ent.ProxySubscribeCategory, int32, error)
	CountSubscribeByCategoryID(ctx context.Context, categoryID int64) (int, error)
	CountSubscribeCategoryChildren(ctx context.Context, categoryID int64) (int, error)

	// Subscribe group operations
	CreateSubscribeGroup(ctx context.Context, group *model.SubscribeGroup) error
	GetSubscribeGroupByID(ctx context.Context, id int) (*ent.ProxySubscribeGroup, error)
	UpdateSubscribeGroup(ctx context.Context, group *model.SubscribeGroup) error
	DeleteSubscribeGroup(ctx context.Context, id int) error
	GetSubscribeGroupList(ctx context.Context) ([]*ent.ProxySubscribeGroup, int32, error)
	BatchDeleteSubscribeGroup(ctx context.Context, ids []int) error

	// User subscription query (for checking if subscribe is in use)
	GetActiveUserSubscriptionCount(ctx context.Context, subscribeID int) (int64, error)
	GetActiveUserSubscriptionCountByIDs(ctx context.Context, subscribeIDs []int64) (map[int64]int64, error)
	ResetAllSubscribeToken(ctx context.Context) error
}

SubscribeRepo subscribe repository interface

type SubscribeUseCase 

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

SubscribeUseCase subscribe use case

func NewSubscribeUseCase 

func NewSubscribeUseCase(repo SubscribeRepo, logger log.Logger) *SubscribeUseCase

NewSubscribeUseCase create subscribe use case

func (*SubscribeUseCase) BatchDeleteSubscribe 

func (uc *SubscribeUseCase) BatchDeleteSubscribe(ctx context.Context, ids []int) error

BatchDeleteSubscribe batch delete subscribes

func (*SubscribeUseCase) BatchDeleteSubscribeCategory added in v1.0.9 

func (uc *SubscribeUseCase) BatchDeleteSubscribeCategory(ctx context.Context, ids []int64) error

BatchDeleteSubscribeCategory batch delete subscribe categories.

func (*SubscribeUseCase) BatchDeleteSubscribeGroup 

func (uc *SubscribeUseCase) BatchDeleteSubscribeGroup(ctx context.Context, ids []int) error

BatchDeleteSubscribeGroup batch delete subscribe groups

func (*SubscribeUseCase) CreateSubscribe 

func (uc *SubscribeUseCase) CreateSubscribe(ctx context.Context, req *v1.CreateSubscribeRequest) error

CreateSubscribe create subscribe

func (*SubscribeUseCase) CreateSubscribeCategory added in v1.0.9 

func (uc *SubscribeUseCase) CreateSubscribeCategory(ctx context.Context, req *v1.CreateSubscribeCategoryRequest) error

CreateSubscribeCategory create subscribe category.

func (*SubscribeUseCase) CreateSubscribeGroup 

func (uc *SubscribeUseCase) CreateSubscribeGroup(ctx context.Context, req *v1.CreateSubscribeGroupRequest) error

CreateSubscribeGroup create subscribe group

func (*SubscribeUseCase) DeleteSubscribe 

func (uc *SubscribeUseCase) DeleteSubscribe(ctx context.Context, id int) error

DeleteSubscribe delete subscribe

func (*SubscribeUseCase) DeleteSubscribeCategory added in v1.0.9 

func (uc *SubscribeUseCase) DeleteSubscribeCategory(ctx context.Context, id int64) error

DeleteSubscribeCategory delete subscribe category.

func (*SubscribeUseCase) DeleteSubscribeGroup 

func (uc *SubscribeUseCase) DeleteSubscribeGroup(ctx context.Context, id int) error

DeleteSubscribeGroup delete subscribe group

func (*SubscribeUseCase) GetSubscribeCategoryList added in v1.0.9 

func (uc *SubscribeUseCase) GetSubscribeCategoryList(ctx context.Context, req *v1.GetSubscribeCategoryListRequest) (*v1.GetSubscribeCategoryListData, error)

GetSubscribeCategoryList get subscribe category list.

func (*SubscribeUseCase) GetSubscribeDetails 

func (uc *SubscribeUseCase) GetSubscribeDetails(ctx context.Context, id int) (*v1.SubscribeInfo, error)

GetSubscribeDetails get subscribe details

func (*SubscribeUseCase) GetSubscribeGroupList 

func (uc *SubscribeUseCase) GetSubscribeGroupList(ctx context.Context) (*v1.GetSubscribeGroupListData, error)

GetSubscribeGroupList get subscribe group list

func (*SubscribeUseCase) GetSubscribeList 

func (uc *SubscribeUseCase) GetSubscribeList(ctx context.Context, req *v1.GetSubscribeListRequest) (*v1.GetSubscribeListData, error)

GetSubscribeList get subscribe list

func (*SubscribeUseCase) ResetAllSubscribeToken 

func (uc *SubscribeUseCase) ResetAllSubscribeToken(ctx context.Context) error

func (*SubscribeUseCase) SubscribeSort 

func (uc *SubscribeUseCase) SubscribeSort(ctx context.Context, req *v1.SubscribeSortRequest) error

SubscribeSort subscribe sort

func (*SubscribeUseCase) UpdateSubscribe 

func (uc *SubscribeUseCase) UpdateSubscribe(ctx context.Context, req *v1.UpdateSubscribeRequest) error

UpdateSubscribe update subscribe

func (*SubscribeUseCase) UpdateSubscribeCategory added in v1.0.9 

func (uc *SubscribeUseCase) UpdateSubscribeCategory(ctx context.Context, req *v1.UpdateSubscribeCategoryRequest) error

UpdateSubscribeCategory update subscribe category.

func (*SubscribeUseCase) UpdateSubscribeGroup 

func (uc *SubscribeUseCase) UpdateSubscribeGroup(ctx context.Context, req *v1.UpdateSubscribeGroupRequest) error

UpdateSubscribeGroup update subscribe group

Source Files

View all Source files

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.