repo

package
v0.8.1 Latest Latest
Warning

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

Go to latest
Published: Jun 30, 2023 License: MIT Imports: 6 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 CancelExpiredTask

func CancelExpiredTask(taskId int)

取消超时的task

func CreateApnsMessage

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

func CreateCloudMailMessage

func CreateCloudMailMessage(ctx persistence.TxContext, message model.MessageInfo,
	cloudTemplateId string,
	templateParams string,
	subject, receiver string) (m model.MailMessageInfo, err error)

func CreateMailMessage

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

func CreateMailSenderInfo

func CreateMailSenderInfo(code, vendor, config string, defaultSender int) (m model.MailSenderInfo, err error)

创建邮件箱配置内容

func CreateMailTemplate

func CreateMailTemplate(code, name, body, description string, category int) (m model.MailTemplateInfo, err error)

func CreateMailTemplateNew

func CreateMailTemplateNew(code, name, body, description, vendor string, category int) (m model.MailTemplateInfo, err error)

func CreateMessage

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

func CreateSmsMessage

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

func CreateSmsTemplate

func CreateSmsTemplate(code, name, templateId, params, description, vendor string) (m model.SmsTemplateInfo, err error)

func CreateSmsTemplateNew

func CreateSmsTemplateNew(code, name, templateId, params, description, vendor, signature string, sender int) (m model.SmsTemplateInfo, err error)

func CreateSmslSenderInfo

func CreateSmslSenderInfo(code, vendor, config string, defaultSender int) (m model.SmsSenderInfo, err error)

创建配置内容

func DeleteApnsSender

func DeleteApnsSender(id int) (err error)

func DeleteMailSender

func DeleteMailSender(id int) (err error)

func DeleteMailTemplate

func DeleteMailTemplate(id int) (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 DeleteSmsSender

func DeleteSmsSender(id int) (err error)

func DeleteSmsTemplate

func DeleteSmsTemplate(id int) (err error)

func GetApnsByMessageId

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

func GetApnsSenderByCode

func GetApnsSenderByCode(code string) (s model.ApnsSenderInfo, err error)

GetApnsSenderByCode 查询发送账号

func GetApnsSenderById

func GetApnsSenderById(id int) (s model.ApnsSenderInfo, err error)

GetApnsSenderById 查询发送账号

func GetApnsSenderList

func GetApnsSenderList(status int, page app.Pager) (p app.Pager, senders []model.ApnsSenderInfo, err error)

GetApnsSenderList 查询发送账号列表

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 GetDefaultMailSender

func GetDefaultMailSender(org string) (s model.MailSenderInfo, err error)

func GetDefaultSmsSender

func GetDefaultSmsSender(org int) (s model.SmsSenderInfo, err error)

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 GetMailSenderByCode

func GetMailSenderByCode(code string) (s model.MailSenderInfo, err error)

GetMailSenderByCode 查询邮件发送账号

func GetMailSenderById

func GetMailSenderById(id int) (s model.MailSenderInfo, err error)

GetMailSenderById 查询邮件发送账号

func GetMailSenderList

func GetMailSenderList(status int, page app.Pager) (p app.Pager, senders []model.MailSenderInfo, err error)

GetMailSenderList 查询邮件发送账号列表

func GetMailSenders

func GetMailSenders(org int) (senders []model.MailSenderInfo, err error)

func GetMailTemplateByCode

func GetMailTemplateByCode(code string) (s model.MailTemplateInfo, err error)

查询邮件Template

func GetMailTemplateById

func GetMailTemplateById(id int) (s model.MailTemplateInfo, err error)

查询邮件Template

func GetMailTemplateList

func GetMailTemplateList(status int, page app.Pager) (p app.Pager, tpls []model.MailTemplateInfo, err error)

查询邮件Template列表

func GetMessageById

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

func GetMessageTask

func GetMessageTask(id int) (t model.MessageTask, 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 GetSmsSenderByCode

func GetSmsSenderByCode(code string) (s model.SmsSenderInfo, err error)

GetSmsSenderByCode 查询短信发送账号

func GetSmsSenderById

func GetSmsSenderById(id int) (s model.SmsSenderInfo, err error)

GetSmsSenderById 查询短信发送账号

func GetSmsSenderList

func GetSmsSenderList(status int, page app.Pager) (p app.Pager, senders []model.SmsSenderInfo, err error)

GetSmsSenderList 查询短信发送账号列表

func GetSmsSenders

func GetSmsSenders(status int) (senders []model.SmsSenderInfo, err error)

func GetSmsTemplateByCode

func GetSmsTemplateByCode(code string) (s model.SmsTemplateInfo, err error)

GetSmsTemplateByCode 查询Template

func GetSmsTemplateById

func GetSmsTemplateById(id int) (s model.SmsTemplateInfo, err error)

GetSmsTemplateById 查询Template

func GetSmsTemplateList

func GetSmsTemplateList(status int, page app.Pager) (p app.Pager, tpls []model.SmsTemplateInfo, err error)

GetSmsTemplateList 查询Template列表

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 SmsSenderDisable

func SmsSenderDisable(id int) (err error)

func SmsSenderEnable

func SmsSenderEnable(id int) (err error)

func TaskSendFail

func TaskSendFail(messageId int)

func UpdateMailSenderInfo

func UpdateMailSenderInfo(ori model.MailSenderInfo, cols ...string) (m model.MailSenderInfo, err error)

编辑邮件箱配置内容

func UpdateMailTemplate

func UpdateMailTemplate(ctx persistence.TxContext, ori model.MailTemplateInfo, cols ...string) (m model.MailTemplateInfo, err error)

func UpdateMailTemplateInfo

func UpdateMailTemplateInfo(ori model.MailTemplateInfo, cols ...string) (m model.MailTemplateInfo, err error)

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 UpdateSmsSenderInfo

func UpdateSmsSenderInfo(ori model.SmsSenderInfo, cols ...string) (m model.SmsSenderInfo, err error)

编辑配置内容

func UpdateSmsTemplate

func UpdateSmsTemplate(ori model.SmsTemplateInfo, cols ...string) (m model.SmsTemplateInfo, err error)

func UpdateSmsTemplateInfo

func UpdateSmsTemplateInfo(ctx persistence.TxContext, ori model.SmsTemplateInfo, cols ...string) (m model.SmsTemplateInfo, 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