Documentation
¶
Index ¶
- type MarketingRepo
- type MarketingUsecase
- func (uc *MarketingUsecase) CreateBatchSendEmailTask(ctx context.Context, subject, content string, scope uint32, ...) error
- func (uc *MarketingUsecase) CreateQuotaTask(ctx context.Context, subscribers []int, isActive *bool, ...) error
- func (uc *MarketingUsecase) GetBatchSendEmailTaskList(ctx context.Context, page, size int32, scope, status *uint32) ([]*ent.ProxyTask, int32, error)
- func (uc *MarketingUsecase) GetBatchSendEmailTaskStatus(ctx context.Context, id int) (*ent.ProxyTask, error)
- func (uc *MarketingUsecase) GetPreSendEmailCount(ctx context.Context, scope uint32, registerStartTime, registerEndTime int64) (int64, error)
- func (uc *MarketingUsecase) QueryQuotaTaskList(ctx context.Context, page, size int32, status *uint32) ([]*ent.ProxyTask, int32, error)
- func (uc *MarketingUsecase) QueryQuotaTaskPreCount(ctx context.Context, subscribers []int, isActive *bool, ...) (int64, error)
- func (uc *MarketingUsecase) StopBatchSendEmailTask(ctx context.Context, id int) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MarketingRepo ¶
type MarketingRepo interface {
// CreateBatchSendEmailTask 创建批量发送邮件任务
CreateBatchSendEmailTask(ctx context.Context, subject, content string, scope uint32,
registerStartTime, registerEndTime int64, additional string, scheduled int64, interval uint32, limit uint64) error
// GetBatchSendEmailTaskList 获取批量发送邮件任务列表
GetBatchSendEmailTaskList(ctx context.Context, page, size int32, scope, status *uint32) ([]*ent.ProxyTask, int32, error)
// StopBatchSendEmailTask 停止批量发送邮件任务
StopBatchSendEmailTask(ctx context.Context, id int) error
// GetPreSendEmailCount 获取预发送邮件数量
GetPreSendEmailCount(ctx context.Context, scope uint32, registerStartTime, registerEndTime int64) (int64, error)
// GetBatchSendEmailTaskStatus 获取批量发送邮件任务状态
GetBatchSendEmailTaskStatus(ctx context.Context, id int) (*ent.ProxyTask, error)
// CreateQuotaTask 创建配额任务
CreateQuotaTask(ctx context.Context, subscribers []int, isActive *bool,
startTime, endTime int64, resetTraffic bool, days uint64, giftType uint32, giftValue uint64) error
// QueryQuotaTaskPreCount 查询配额任务预计数量
QueryQuotaTaskPreCount(ctx context.Context, subscribers []int, isActive *bool, startTime, endTime int64) (int64, error)
// QueryQuotaTaskList 查询配额任务列表
QueryQuotaTaskList(ctx context.Context, page, size int32, status *uint32) ([]*ent.ProxyTask, int32, error)
}
MarketingRepo 营销仓库接口
type MarketingUsecase ¶
type MarketingUsecase struct {
// contains filtered or unexported fields
}
MarketingUsecase 营销用例
func NewMarketingUsecase ¶
func NewMarketingUsecase(repo MarketingRepo, logger log.Logger) *MarketingUsecase
NewMarketingUsecase 创建营销用例
func (*MarketingUsecase) CreateBatchSendEmailTask ¶
func (uc *MarketingUsecase) CreateBatchSendEmailTask(ctx context.Context, subject, content string, scope uint32, registerStartTime, registerEndTime int64, additional string, scheduled int64, interval uint32, limit uint64) error
CreateBatchSendEmailTask 创建批量发送邮件任务
func (*MarketingUsecase) CreateQuotaTask ¶
func (uc *MarketingUsecase) CreateQuotaTask(ctx context.Context, subscribers []int, isActive *bool, startTime, endTime int64, resetTraffic bool, days uint64, giftType uint32, giftValue uint64) error
CreateQuotaTask 创建配额任务
func (*MarketingUsecase) GetBatchSendEmailTaskList ¶
func (uc *MarketingUsecase) GetBatchSendEmailTaskList(ctx context.Context, page, size int32, scope, status *uint32) ([]*ent.ProxyTask, int32, error)
GetBatchSendEmailTaskList 获取批量发送邮件任务列表
func (*MarketingUsecase) GetBatchSendEmailTaskStatus ¶
func (uc *MarketingUsecase) GetBatchSendEmailTaskStatus(ctx context.Context, id int) (*ent.ProxyTask, error)
GetBatchSendEmailTaskStatus 获取批量发送邮件任务状态
func (*MarketingUsecase) GetPreSendEmailCount ¶
func (uc *MarketingUsecase) GetPreSendEmailCount(ctx context.Context, scope uint32, registerStartTime, registerEndTime int64) (int64, error)
GetPreSendEmailCount 获取预发送邮件数量
func (*MarketingUsecase) QueryQuotaTaskList ¶
func (uc *MarketingUsecase) QueryQuotaTaskList(ctx context.Context, page, size int32, status *uint32) ([]*ent.ProxyTask, int32, error)
QueryQuotaTaskList 查询配额任务列表
func (*MarketingUsecase) QueryQuotaTaskPreCount ¶
func (uc *MarketingUsecase) QueryQuotaTaskPreCount(ctx context.Context, subscribers []int, isActive *bool, startTime, endTime int64) (int64, error)
QueryQuotaTaskPreCount 查询配额任务预计数量
func (*MarketingUsecase) StopBatchSendEmailTask ¶
func (uc *MarketingUsecase) StopBatchSendEmailTask(ctx context.Context, id int) error
StopBatchSendEmailTask 停止批量发送邮件任务
Click to show internal directories.
Click to hide internal directories.