mirror of
https://github.com/Rain-kl/OpenFlare.git
synced 2026-10-11 01:36:37 +08:00
[优化] 邮件工具类去耦合
This commit is contained in:
@@ -93,7 +93,14 @@ func SendEmailVerification(c *gin.Context) {
|
|||||||
content := fmt.Sprintf("<p>您好,你正在进行%s邮箱验证。</p>"+
|
content := fmt.Sprintf("<p>您好,你正在进行%s邮箱验证。</p>"+
|
||||||
"<p>您的验证码为: <strong>%s</strong></p>"+
|
"<p>您的验证码为: <strong>%s</strong></p>"+
|
||||||
"<p>验证码 %d 分钟内有效,如果不是本人操作,请忽略。</p>", common.SystemName, code, security.VerificationValidMinutes)
|
"<p>验证码 %d 分钟内有效,如果不是本人操作,请忽略。</p>", common.SystemName, code, security.VerificationValidMinutes)
|
||||||
err := mail.SendEmail(subject, email, content)
|
cfg := mail.SMTPConfig{
|
||||||
|
Server: common.SMTPServer,
|
||||||
|
Port: common.SMTPPort,
|
||||||
|
Account: common.SMTPAccount,
|
||||||
|
Token: common.SMTPToken,
|
||||||
|
SystemName: common.SystemName,
|
||||||
|
}
|
||||||
|
err := mail.SendEmail(cfg, subject, email, content)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
c.JSON(http.StatusOK, gin.H{
|
c.JSON(http.StatusOK, gin.H{
|
||||||
"success": false,
|
"success": false,
|
||||||
@@ -131,7 +138,14 @@ func SendPasswordResetEmail(c *gin.Context) {
|
|||||||
content := fmt.Sprintf("<p>您好,你正在进行%s密码重置。</p>"+
|
content := fmt.Sprintf("<p>您好,你正在进行%s密码重置。</p>"+
|
||||||
"<p>点击<a href='%s'>此处</a>进行密码重置。</p>"+
|
"<p>点击<a href='%s'>此处</a>进行密码重置。</p>"+
|
||||||
"<p>重置链接 %d 分钟内有效,如果不是本人操作,请忽略。</p>", common.SystemName, link, security.VerificationValidMinutes)
|
"<p>重置链接 %d 分钟内有效,如果不是本人操作,请忽略。</p>", common.SystemName, link, security.VerificationValidMinutes)
|
||||||
err := mail.SendEmail(subject, email, content)
|
cfg := mail.SMTPConfig{
|
||||||
|
Server: common.SMTPServer,
|
||||||
|
Port: common.SMTPPort,
|
||||||
|
Account: common.SMTPAccount,
|
||||||
|
Token: common.SMTPToken,
|
||||||
|
SystemName: common.SystemName,
|
||||||
|
}
|
||||||
|
err := mail.SendEmail(cfg, subject, email, content)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
c.JSON(http.StatusOK, gin.H{
|
c.JSON(http.StatusOK, gin.H{
|
||||||
"success": false,
|
"success": false,
|
||||||
|
|||||||
@@ -5,31 +5,40 @@ import (
|
|||||||
"encoding/base64"
|
"encoding/base64"
|
||||||
"fmt"
|
"fmt"
|
||||||
"net/smtp"
|
"net/smtp"
|
||||||
"openflare/common"
|
|
||||||
"strings"
|
"strings"
|
||||||
)
|
)
|
||||||
|
|
||||||
func SendEmail(subject string, receiver string, content string) error {
|
// SMTPConfig holds all the configuration parameters required to send an email.
|
||||||
|
type SMTPConfig struct {
|
||||||
|
Server string
|
||||||
|
Port int
|
||||||
|
Account string
|
||||||
|
Token string
|
||||||
|
SystemName string
|
||||||
|
}
|
||||||
|
|
||||||
|
// SendEmail sends an HTML email to the receiver using the provided SMTP configuration.
|
||||||
|
func SendEmail(config SMTPConfig, subject string, receiver string, content string) error {
|
||||||
encodedSubject := fmt.Sprintf("=?UTF-8?B?%s?=", base64.StdEncoding.EncodeToString([]byte(subject)))
|
encodedSubject := fmt.Sprintf("=?UTF-8?B?%s?=", base64.StdEncoding.EncodeToString([]byte(subject)))
|
||||||
mail := []byte(fmt.Sprintf("To: %s\r\n"+
|
mail := []byte(fmt.Sprintf("To: %s\r\n"+
|
||||||
"From: %s<%s>\r\n"+
|
"From: %s<%s>\r\n"+
|
||||||
"Subject: %s\r\n"+
|
"Subject: %s\r\n"+
|
||||||
"Content-Type: text/html; charset=UTF-8\r\n\r\n%s\r\n",
|
"Content-Type: text/html; charset=UTF-8\r\n\r\n%s\r\n",
|
||||||
receiver, common.SystemName, common.SMTPAccount, encodedSubject, content))
|
receiver, config.SystemName, config.Account, encodedSubject, content))
|
||||||
auth := smtp.PlainAuth("", common.SMTPAccount, common.SMTPToken, common.SMTPServer)
|
auth := smtp.PlainAuth("", config.Account, config.Token, config.Server)
|
||||||
addr := fmt.Sprintf("%s:%d", common.SMTPServer, common.SMTPPort)
|
addr := fmt.Sprintf("%s:%d", config.Server, config.Port)
|
||||||
to := strings.Split(receiver, ";")
|
to := strings.Split(receiver, ";")
|
||||||
var err error
|
var err error
|
||||||
if common.SMTPPort == 465 {
|
if config.Port == 465 {
|
||||||
tlsConfig := &tls.Config{
|
tlsConfig := &tls.Config{
|
||||||
InsecureSkipVerify: true,
|
InsecureSkipVerify: true,
|
||||||
ServerName: common.SMTPServer,
|
ServerName: config.Server,
|
||||||
}
|
}
|
||||||
conn, err := tls.Dial("tcp", fmt.Sprintf("%s:%d", common.SMTPServer, common.SMTPPort), tlsConfig)
|
conn, err := tls.Dial("tcp", fmt.Sprintf("%s:%d", config.Server, config.Port), tlsConfig)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
client, err := smtp.NewClient(conn, common.SMTPServer)
|
client, err := smtp.NewClient(conn, config.Server)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
@@ -37,12 +46,12 @@ func SendEmail(subject string, receiver string, content string) error {
|
|||||||
if err = client.Auth(auth); err != nil {
|
if err = client.Auth(auth); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
if err = client.Mail(common.SMTPAccount); err != nil {
|
if err = client.Mail(config.Account); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
receiverEmails := strings.Split(receiver, ";")
|
receiverEmails := strings.Split(receiver, ";")
|
||||||
for _, receiver := range receiverEmails {
|
for _, r := range receiverEmails {
|
||||||
if err = client.Rcpt(receiver); err != nil {
|
if err = client.Rcpt(r); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -59,7 +68,7 @@ func SendEmail(subject string, receiver string, content string) error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
err = smtp.SendMail(addr, auth, common.SMTPAccount, to, mail)
|
err = smtp.SendMail(addr, auth, config.Account, to, mail)
|
||||||
}
|
}
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user