sugarBecomer
62 lines
1.8 KiB
Go
62 lines
1.8 KiB
Go
package schedule
|
|
|
|
import (
|
|
"bytes"
|
|
"context"
|
|
"encoding/gob"
|
|
"likedream-goframe/internal/framework/logger"
|
|
"likedream-goframe/internal/framework/model/email"
|
|
"likedream-goframe/internal/utils"
|
|
"time"
|
|
|
|
"github.com/hibiken/asynq"
|
|
"github.com/samber/oops"
|
|
"github.com/wneessen/go-mail"
|
|
"go.uber.org/zap"
|
|
)
|
|
|
|
type EmailTaskHandler struct {
|
|
}
|
|
|
|
func (h *EmailTaskHandler) ProcessTask(ctx context.Context, task *asynq.Task) (err error) {
|
|
defer utils.Pass(&err)
|
|
var payload email.SendPayload
|
|
e := gob.NewDecoder(bytes.NewReader(task.Payload())).Decode(&payload)
|
|
utils.OkOrPanic(e, oops.WithContext(ctx).Wrap)
|
|
logger.Logger.Info("开始处理邮件发送", zap.String("邮箱", payload.To))
|
|
defer func() {
|
|
if r := recover(); r != nil {
|
|
// 打印日志
|
|
logger.Logger.Error("邮件发送失败", zap.String("邮箱", payload.To), zap.Error(r.(error)))
|
|
// 重新抛出相同的 panic
|
|
panic(r)
|
|
}
|
|
}()
|
|
|
|
message := mail.NewMsg()
|
|
|
|
e = message.FromFormat(payload.FromName, payload.FromEmail)
|
|
utils.OkOrPanic(e, oops.WithContext(ctx).Wrap)
|
|
|
|
e = message.AddTo(payload.To)
|
|
utils.OkOrPanic(e, oops.WithContext(ctx).Wrap)
|
|
|
|
message.Subject(payload.Subject)
|
|
|
|
message.SetBodyString(mail.TypeTextHTML, payload.Body)
|
|
|
|
client, e := mail.NewClient(payload.SMTPHost, mail.WithPort(payload.SMTPPort),
|
|
mail.WithSMTPAuth(mail.SMTPAuthLogin), // Outlook 使用 LOGIN 认证
|
|
mail.WithTLSPortPolicy(mail.TLSMandatory),
|
|
mail.WithTimeout(30*time.Second), // 连接超时 30 秒
|
|
mail.WithUsername(payload.SMTPUsername), mail.WithPassword(payload.SMTPPassword))
|
|
utils.OkOrPanic(e, oops.WithContext(ctx).Wrap)
|
|
|
|
defer utils.LogError(ctx, "关闭邮件客户端失败", client.Close())
|
|
|
|
e = client.DialAndSendWithContext(ctx, message)
|
|
utils.OkOrPanic(e, oops.WithContext(ctx).Wrap)
|
|
logger.Logger.Info("邮件发送完成", zap.String("邮箱", payload.To))
|
|
return
|
|
}
|