repo

package
v0.11.3 Latest Latest
Warning

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

Go to latest
Published: Apr 12, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ConditionIgnore = 0
	DefaultPageNo   = 1
	DefaultPageSize = 10
)

Variables

This section is empty.

Functions

func AddMessageTask

func AddMessageTask(ctx persistence.TxContext, messageId int, messageInstanceId int) (task model.MessageTask, err error)

创建投送task 从未投送的message中取出一个

func AddRunningTask

func AddRunningTask(ctx persistence.TxContext, task model.MessageTask) (runningTask model.MessageRunningTask, err error)

func CalcPageOffset added in v0.11.0

func CalcPageOffset(p app.Pager) int

func CancelExpiredTask

func CancelExpiredTask(taskId int)

取消超时的task

func CreateApnsMessage

func CreateApnsMessage(ctx persistence.TxContext, message model.MessageInfo, sender model.MessageSenderInfo,
	mode int, bundleId string, params string,
	subject, receiver string) (m model.ApnsMessageInfo, err error)

func CreateMailMessage

func CreateMailMessage(ctx persistence.TxContext, message model.MessageInfo,
	template model.MessageTemplate,
	templateParams string,
	subject, receiver string) (m model.MailMessageInfo, err error)

func CreateMessage

func CreateMessage(ctx persistence.TxContext, org int, subject string, category msg.MessageCategory) (m model.MessageInfo, err error)

func CreateMessageTemplate added in v0.11.0

func CreateMessageTemplate(code, name, body, templateId, params, description string, category msg.MessageCategory, provider msg.MessageProvider) (m model.MessageTemplate, err error)

func CreateSmsMessage

func CreateSmsMessage(ctx persistence.TxContext, message model.MessageInfo, template model.MessageTemplate,
	templateParams string, receiver string) (m model.SmsMessageInfo, err error)

func DeleteRunningTask

func DeleteRunningTask(ctx persistence.TxContext, id int) (err error)

func DeleteRunningTaskByTaskId

func DeleteRunningTaskByTaskId(ctx persistence.TxContext, taskId int) (err error)

func GetApnsByMessageId

func GetApnsByMessageId(msgId int) (m model.ApnsMessageInfo, err error)

func GetClientByAppId added in v0.7.1

func GetClientByAppId(appId string) (c model.OpenClient, err error)

func GetClientById

func GetClientById(ctx persistence.OrmContext, id int) (c model.OpenClient, err error)

func GetClients

func GetClients(ctx persistence.OrmContext, key string) (c []model.OpenClient, err error)

func GetDefMessageSender added in v0.11.0

func GetDefMessageSender(org int, category msg.MessageCategory, provider msg.MessageProvider) (s model.MessageSenderInfo, err error)

GetDefMessageSender 获取默认的消息发送者

func GetExpiredTasks

func GetExpiredTasks(size int, timeLatest time.Time) (tasks []model.MessageRunningTask, err error)

超时的列表 size:取出数据量

func GetMailByMessageId

func GetMailByMessageId(msgId int) (m model.MailMessageInfo, err error)

func GetMessageById

func GetMessageById(id int) (m model.MessageInfo, err error)

func GetMessageTask

func GetMessageTask(id int) (t model.MessageTask, err error)

func GetMessageTemplateByCode added in v0.11.0

func GetMessageTemplateByCode(code string) (tpl model.MessageTemplate, err error)

func GetMessageTemplateById added in v0.11.0

func GetMessageTemplateById(id int) (tpl model.MessageTemplate, err error)

func GetMessageTemplates added in v0.11.0

func GetMessageTemplates(
	org int,
	category msg.MessageCategory,
	provider msg.MessageProvider,
) (templates []model.MessageTemplate, err error)

func GetMessageToSend

func GetMessageToSend(size int) (messages []model.MessageInfo, err error)

查询需要发送的消息

func GetMessages

func GetMessages(status int, category int, page app.Pager) (p app.Pager, messages []model.MessageInfo, err error)

func GetSmsByMessageId

func GetSmsByMessageId(msgId int) (m model.SmsMessageInfo, err error)

func GetTaskByMessage

func GetTaskByMessage(messageId int) (t model.MessageTask, err error)

func GetTaskList

func GetTaskList(status int, page app.Pager) (p app.Pager, list []model.MessageTask, err error)

func GetTemplateByCode added in v0.11.0

func GetTemplateByCode(code string, category msg.MessageCategory) (s model.MessageTemplate, err error)

func GetTenant added in v0.9.1

func GetTenant(code string) (t model.Tenant, err error)

func TaskSendFail

func TaskSendFail(messageId int)

func UpdateMessagePriority

func UpdateMessagePriority(id int, priority int) (m model.MessageInfo, err error)

func UpdateMessageStatus

func UpdateMessageStatus(ctx persistence.TxContext, id int, status int) (m model.MessageInfo, err error)

func UpdateMessageTemplate added in v0.11.0

func UpdateMessageTemplate(status int, code, name, body, description string) (m model.MessageTemplate, err error)

func UpdateTaskStatus

func UpdateTaskStatus(ctx persistence.TxContext, taskId int, status int) (task model.MessageTask, err error)

Types

type PagerReq

type PagerReq struct {
	PageSize int
	PageNo   int
}

type PagerRes

type PagerRes struct {
	// 页面大小
	PageSize int
	// 页号
	PageNo int
	// 总页数
	TotalPage int
	// 总条数
	Count int
	// 首页
	FirstPage bool
	// 尾页
	LastPage bool
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL