| package common
|
|
|
| import (
|
| "crypto/tls"
|
| "encoding/base64"
|
| "fmt"
|
| "net/smtp"
|
| "slices"
|
| "strings"
|
| "time"
|
| )
|
|
|
| func generateMessageID() (string, error) {
|
| split := strings.Split(SMTPFrom, "@")
|
| if len(split) < 2 {
|
| return "", fmt.Errorf("invalid SMTP account")
|
| }
|
| domain := strings.Split(SMTPFrom, "@")[1]
|
| return fmt.Sprintf("<%d.%s@%s>", time.Now().UnixNano(), GetRandomString(12), domain), nil
|
| }
|
|
|
| func SendEmail(subject string, receiver string, content string) error {
|
| if SMTPFrom == "" {
|
| SMTPFrom = SMTPAccount
|
| }
|
| id, err2 := generateMessageID()
|
| if err2 != nil {
|
| return err2
|
| }
|
| if SMTPServer == "" && SMTPAccount == "" {
|
| return fmt.Errorf("SMTP 服务器未配置")
|
| }
|
| encodedSubject := fmt.Sprintf("=?UTF-8?B?%s?=", base64.StdEncoding.EncodeToString([]byte(subject)))
|
| mail := []byte(fmt.Sprintf("To: %s\r\n"+
|
| "From: %s <%s>\r\n"+
|
| "Subject: %s\r\n"+
|
| "Date: %s\r\n"+
|
| "Message-ID: %s\r\n"+
|
| "Content-Type: text/html; charset=UTF-8\r\n\r\n%s\r\n",
|
| receiver, SystemName, SMTPFrom, encodedSubject, time.Now().Format(time.RFC1123Z), id, content))
|
| auth := smtp.PlainAuth("", SMTPAccount, SMTPToken, SMTPServer)
|
| addr := fmt.Sprintf("%s:%d", SMTPServer, SMTPPort)
|
| to := strings.Split(receiver, ";")
|
| var err error
|
| if SMTPPort == 465 || SMTPSSLEnabled {
|
| tlsConfig := &tls.Config{
|
| InsecureSkipVerify: true,
|
| ServerName: SMTPServer,
|
| }
|
| conn, err := tls.Dial("tcp", fmt.Sprintf("%s:%d", SMTPServer, SMTPPort), tlsConfig)
|
| if err != nil {
|
| return err
|
| }
|
| client, err := smtp.NewClient(conn, SMTPServer)
|
| if err != nil {
|
| return err
|
| }
|
| defer client.Close()
|
| if err = client.Auth(auth); err != nil {
|
| return err
|
| }
|
| if err = client.Mail(SMTPFrom); err != nil {
|
| return err
|
| }
|
| receiverEmails := strings.Split(receiver, ";")
|
| for _, receiver := range receiverEmails {
|
| if err = client.Rcpt(receiver); err != nil {
|
| return err
|
| }
|
| }
|
| w, err := client.Data()
|
| if err != nil {
|
| return err
|
| }
|
| _, err = w.Write(mail)
|
| if err != nil {
|
| return err
|
| }
|
| err = w.Close()
|
| if err != nil {
|
| return err
|
| }
|
| } else if isOutlookServer(SMTPAccount) || slices.Contains(EmailLoginAuthServerList, SMTPServer) {
|
| auth = LoginAuth(SMTPAccount, SMTPToken)
|
| err = smtp.SendMail(addr, auth, SMTPFrom, to, mail)
|
| } else {
|
| err = smtp.SendMail(addr, auth, SMTPFrom, to, mail)
|
| }
|
| if err != nil {
|
| SysError(fmt.Sprintf("failed to send email to %s: %v", receiver, err))
|
| }
|
| return err
|
| }
|
|
|
