package services import ( "crypto/tls" "eta/eta_api/models" "eta/eta_api/utils" "fmt" "gopkg.in/gomail.v2" "strconv" "strings" ) func SendEmailToCompany() { // 获取收件人列表 emailCond := " AND enabled = 1 AND status in (1,2) " //emailCond := "" emailPars := make([]interface{}, 0) emails, e := models.GetEnglishReportEmailList(emailCond, emailPars, "") if e != nil { fmt.Println("获取收件人列表失败, Err: " + e.Error()) return } if len(emails) == 0 { fmt.Println("收件人列表为空") return } // TODO:这是HTML模板内容 template := ` Document

Hello,

We are pleased to invite you to the launch of our Mon. Date with HI , a weekly event where we share timely updates and expert analysis on Global Macro, Base Metal, Ferrous Metal, and Energy markets.

Event Details:

Join Zoom Meeting:

https://us06web.zoom.us/j/84723517075?pwd=3GHNOCHq6sAgBGXsA7qtX9r1PuA1uK.1

Meeting ID: 847 2351 7075

Passcode: 564439

Theme for Today’s Session: Diverging Expectations between Market and Policymakers

Our analysts will discuss the impact of the current macro environment on commodity markets, exploring both short-term challenges and longer-term outlooks.
This series will be a recurring event every Monday at the same time.

Please note:

We look forward to your participation.

Best regards,
Horizon Insights

` // 推送信息 sendData := make([]*EnglishReportSendEmailRequest, 0) for i := range emails { r := new(EnglishReportSendEmailRequest) r.EmailId = emails[i].Id r.Email = strings.Replace(emails[i].Email, " ", "", -1) r.Subject = "Invitation to Weekly Call with Horizon Insights Analysts: Mon. Date with HI" // TODO:这是主题 r.FromAlias = "Horizon FICC" // TODO:这是推送人(中文) r.HtmlBody = template sendData = append(sendData, r) } if len(sendData) == 0 { fmt.Println("无邮件可推送") return } // 请求阿里云接口批量推送 aliEmail := new(AliyunEmail) resultList, e := aliEmail.BatchSendEmail(sendData) if e != nil { fmt.Println("批量推送失败, Err: " + e.Error()) return } for _, r := range resultList { utils.FileLog.Info("email: %s, ok: %v, res: %s", r.Email, r.Ok, r.ResultData) if r.Ok { fmt.Println("发送成功") } else { fmt.Println("发送失败:" + r.ResultData) } } } type SendEmailReq struct { Title string `description:"标题"` Content string `description:"内容"` ToUser []string `description:"收信人邮箱"` } func SendEmail(req SendEmailReq) (success bool, err error) { if req.Title == "" { err = fmt.Errorf("邮件主题不可为空") return } if req.Content == "" { err = fmt.Errorf("邮件内容不可为空") return } if len(req.ToUser) <= 0 { err = fmt.Errorf("收信人不可为空") return } // 邮箱配置 confMap, e := models.GetBusinessConf() if e != nil { err = fmt.Errorf("GetBusinessConf err: %s", e.Error()) return } checkArr := []string{ models.BusinessConfEmailServerHost, models.BusinessConfEmailServerPort, models.BusinessConfEmailSender, models.BusinessConfEmailSenderUserName, models.BusinessConfEmailSenderPassword, } for _, v := range checkArr { if confMap[v] == "" { err = fmt.Errorf("%s配置有误", v) return } } port, _ := strconv.Atoi(confMap[models.BusinessConfEmailServerPort]) if port <= 0 { port = 587 // 默认587端口 } m := gomail.NewMessage() m.SetHeader("From", confMap[models.BusinessConfEmailSender]) m.SetHeader("To", req.ToUser...) m.SetHeader("Subject", req.Title) m.SetBody("text/html", req.Content) d := gomail.NewDialer(confMap[models.BusinessConfEmailServerHost], port, confMap[models.BusinessConfEmailSenderUserName], confMap[models.BusinessConfEmailSenderPassword]) // 解决x509报错的问题。证书不通过。跳过证书验证 config := &tls.Config{ServerName: confMap[models.BusinessConfEmailServerHost], InsecureSkipVerify: true} d.TLSConfig = config if e = d.DialAndSend(m); e != nil { err = fmt.Errorf("邮件发送失败, Err: %s", e.Error()) return } success = true return }