feat(notify): email

Author: Cooooing

app/notify/cmd/main.go

@@ -46,7 +46,7 @@ func newApp(logger log.Logger, log *log.Helper, gs *grpc.Server, hs *http.Server
 	log.Infof("start server %s", id)
 
 	go eventHandler.Handle()
-	log.Infof("start message quque event handler")
+	log.Infof("start message queue event handler")
 
 	return kratos.New(
 		kratos.ID(id),

app/notify/cmd/wire_gen.go

@@ -42,3 +42,11 @@ trace:
   endpoint: "127.0.0.1:4317"  # OTel Collector 地址
   insecure: true
   sampler: 1  # 100% 采样率
+
+email:
+  enable: true
+  smtp_host: smtp.qq.com
+  smtp_port: 465
+  username: example
+  password: example
+  from: example@example.com

app/notify/configs/config.yaml

@@ -16,11 +16,11 @@ require (
 	github.com/panjf2000/ants/v2 v2.11.3
 	github.com/prometheus/client_golang v1.23.2
 	github.com/rabbitmq/amqp091-go v1.10.0
-	github.com/redis/go-redis/v9 v9.17.2
 	go.etcd.io/etcd/client/v3 v3.6.6
 	go.opentelemetry.io/otel v1.38.0
 	go.opentelemetry.io/otel/metric v1.38.0
 	google.golang.org/protobuf v1.36.10
+	gopkg.in/gomail.v2 v2.0.0-20160411212932-81ebce5c23df
 )
 
 require (
@@ -64,6 +64,7 @@ require (
 	github.com/prometheus/client_model v0.6.2 // indirect
 	github.com/prometheus/common v0.66.1 // indirect
 	github.com/prometheus/procfs v0.16.1 // indirect
+	github.com/redis/go-redis/v9 v9.17.2 // indirect
 	github.com/stoewer/go-strcase v1.3.0 // indirect
 	github.com/zclconf/go-cty v1.14.4 // indirect
 	github.com/zclconf/go-cty-yaml v1.1.0 // indirect
@@ -88,6 +89,7 @@ require (
 	google.golang.org/genproto/googleapis/api v0.0.0-20251202230838-ff82c1b0f217 // indirect
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20251202230838-ff82c1b0f217 // indirect
 	google.golang.org/grpc v1.77.0 // indirect
+	gopkg.in/alexcesaro/quotedprintable.v3 v3.0.0-20150716171945-2caba252f4dc // indirect
 	gopkg.in/natefinch/lumberjack.v2 v2.2.1 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )

app/notify/go.mod

@@ -237,9 +237,13 @@ google.golang.org/grpc v1.77.0 h1:wVVY6/8cGA6vvffn+wWK5ToddbgdU3d8MNENr4evgXM=
 google.golang.org/grpc v1.77.0/go.mod h1:z0BY1iVj0q8E1uSQCjL9cppRj+gnZjzDnzV0dHhrNig=
 google.golang.org/protobuf v1.36.10 h1:AYd7cD/uASjIL6Q9LiTjz8JLcrh/88q5UObnmY3aOOE=
 google.golang.org/protobuf v1.36.10/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=
+gopkg.in/alexcesaro/quotedprintable.v3 v3.0.0-20150716171945-2caba252f4dc h1:2gGKlE2+asNV9m7xrywl36YYNnBG5ZQ0r/BOOxqPpmk=
+gopkg.in/alexcesaro/quotedprintable.v3 v3.0.0-20150716171945-2caba252f4dc/go.mod h1:m7x9LTH6d71AHyAX77c9yqWCCa3UKHcVEj9y7hAtKDk=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
+gopkg.in/gomail.v2 v2.0.0-20160411212932-81ebce5c23df h1:n7WqCuqOuCbNr617RXOY0AWRXxgwEyPp2z+p0+hgMuE=
+gopkg.in/gomail.v2 v2.0.0-20160411212932-81ebce5c23df/go.mod h1:LRQQ+SO6ZHR7tOkpBDuZnXENFzX8qRjMDMyPD6BRkCw=
 gopkg.in/natefinch/lumberjack.v2 v2.2.1 h1:bBRl1b0OH9s/DuPhuXpNl+VtCaJXFZ5/uEFST95x9zc=
 gopkg.in/natefinch/lumberjack.v2 v2.2.1/go.mod h1:YD8tP3GAjkrDg1eZH7EGmyESg/lsYskCTPBJVb9jqSc=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

app/notify/go.sum

@@ -0,0 +1,36 @@
+package base
+
+import (
+	"fmt"
+
+	"gopkg.in/gomail.v2"
+)
+
+type EmailDomain struct {
+	*BaseDomain
+}
+
+func NewEmailDomain(base *BaseDomain) *EmailDomain {
+	return &EmailDomain{
+		BaseDomain: base,
+	}
+}
+
+// Send 发送邮件
+func (d *EmailDomain) Send(to []string, subject string, body string) error {
+	m := gomail.NewMessage()
+	m.SetHeader("From", d.Conf.Email.From)
+	m.SetHeader("To", to...)
+	m.SetHeader("Subject", subject)
+	m.SetBody("text/html", body)
+
+	dialer := gomail.NewDialer(d.Conf.Email.SmtpHost, int(d.Conf.Email.SmtpPort), d.Conf.Email.Username, d.Conf.Email.Password)
+	dialer.SSL = d.Conf.Email.SmtpPort == 465
+
+	err := dialer.DialAndSend(m)
+	if err != nil {
+		return fmt.Errorf("send email error: %v", err)
+	}
+	d.Log.Infof(" %s send email to %v success", d.Conf.Email.From, to)
+	return nil
+}

app/notify/internal/biz/base/email.go

@@ -18,4 +18,5 @@ var BizProviderSet = wire.NewSet(
 	NewNotificationMetaDomain,
 	NewNotificationRecordDomain,
 	NewNotificationTemplateDomain,
+	base.NewEmailDomain,
 )

app/notify/internal/biz/biz.go

@@ -137,6 +137,7 @@ func (h *EventHandler) Handle() {
 						if err != nil {
 							break
 						}
+						notification.Title = template.Title
 						notification.Content = template.Content
 						_, err = handler.Handle(h.ctx, notification)
 						if err != nil {

app/notify/internal/biz/event_handler.go

@@ -10,15 +10,15 @@ import (
 
 var HandlerSet = wire.NewSet(
 	NewFullHandler,
-	NewFilter,
+	NewRegisterVerifyCode,
 )
 
 func ProvideHandlers(
-	filter *Filter,
+	registerVerifyCode *RegisterVerifyCode,
 	fullHandler *FullHandler,
 ) dict.Map[string, handlerchain.Handler[*commonModel.Notification]] {
 	m := dict.New[string, handlerchain.Handler[*commonModel.Notification]](0)
-	m.Set(filter.Name(), filter)
+	m.Set(registerVerifyCode.Name(), registerVerifyCode)
 	m.Set(fullHandler.Name(), fullHandler)
 	return m
 }

app/notify/internal/biz/handler/handler.go

@@ -0,0 +1,54 @@
+package handler
+
+import (
+	"bytes"
+	"common/pkg/cutil/handlerchain"
+	commonModel "common/pkg/model"
+	"context"
+	"html/template"
+	"notify/internal/biz/base"
+)
+
+type RegisterVerifyCode struct {
+	*handlerchain.BaseHandler[*commonModel.Notification]
+	emailDomain *base.EmailDomain
+}
+
+func NewRegisterVerifyCode(emailDomain *base.EmailDomain) *RegisterVerifyCode {
+	return &RegisterVerifyCode{
+		BaseHandler: &handlerchain.BaseHandler[*commonModel.Notification]{Name: "register_verify_code"},
+		emailDomain: emailDomain,
+	}
+}
+
+func (h *RegisterVerifyCode) Handle(ctx context.Context, data *commonModel.Notification) (*commonModel.Notification, error) {
+
+	// 按模板渲染
+	data.Meta.RegisterVerifyCode.ExpireMinutes = int(data.Meta.RegisterVerifyCode.Expire.Minutes())
+	tpl, err := template.New(data.UUID).Parse(data.Content)
+	if err != nil {
+		return nil, err
+	}
+
+	buf := &bytes.Buffer{}
+	if err := tpl.Execute(buf, data.Meta); err != nil {
+		return nil, err
+	}
+	data.ContentRender = buf.String()
+
+	// 发送邮件
+	err = h.emailDomain.Send([]string{data.Meta.RegisterVerifyCode.Email}, data.Title, data.ContentRender)
+	if err != nil {
+		return nil, err
+	}
+
+	return h.BaseHandler.Next(ctx, data)
+}
+
+func (h *RegisterVerifyCode) SetNext(next handlerchain.Handler[*commonModel.Notification]) {
+	h.BaseHandler.SetNext(next)
+}
+
+func (h *RegisterVerifyCode) Name() string {
+	return h.BaseHandler.GetName()
+}