eta_server
/
eta_api


			
				
					
						
						
							123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165
							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 := `<!DOCTYPE html>
<html lang="en">
  <head>
    <meta charset="UTF-8" />
    <meta http-equiv="X-UA-Compatible" content="IE=edge" />
    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
    <title>Document</title>
  </head>
  <body>
    <div>
      <p>Hello,</p>
      <p></p>
      <p> We are pleased to invite you to the launch of our <span style="font-weight: 700;">Mon. Date with HI</span> , a weekly event where we share timely updates and expert analysis on Global Macro, Base Metal, Ferrous Metal, and Energy markets.</p>
      <h3 style="font-weight: 700;">Event Details:</h3>
      <ul>
        <li>Date: August 26th</li>
        <li>Time: 5:00 PM (Shanghai/Singapore) | 10:00 AM (London)</li>
        <li>Platform: Zoom (the same link will be used for all future sessions)</li>
      </ul>
      <h3 style="font-weight: 700;">Join Zoom Meeting:</h3>
      <a href="https://us06web.zoom.us/j/84723517075?pwd=3GHNOCHq6sAgBGXsA7qtX9r1PuA1uK.1" target="_blank">https://us06web.zoom.us/j/84723517075?pwd=3GHNOCHq6sAgBGXsA7qtX9r1PuA1uK.1</a>
      <p>
        <span style="font-weight: 700;">Meeting ID:</span>
        <span>847 2351 7075</span>
      </p>
      <p>
        <span style="font-weight: 700;">Passcode:</span>
        <span>564439</span>
      </p>
      <p style="font-weight: 700;">Theme for Today’s Session: Diverging Expectations between Market and Policymakers</p>
      <p>Our analysts will discuss the impact of the current macro environment on commodity markets, exploring both short-term challenges and longer-term outlooks.<br>This series will be a recurring event every Monday at the same time. </p>
      <h3 style="font-weight: 700;">Please note:</h3>
      <ul>
        <li>This event will be conducted in listen-only mode. However, participants are encouraged to ask questions via the chat function during the Q&A segments.</li>
        <li>For privacy concerns, you may change your display name upon joining the event.</li>
      </ul>
      <p></p>
      <p>We look forward to your participation.</p>
      <p></p>
      <p>Best regards,<br>Horizon Insights</p>
      <img style="max-width: 375px;width: 100%;" src="https://hzstatic.hzinsights.com/static/images/202408/20240826/z0qJ4cpM5mIaHrHv0BaMsNXYkLKa.jpg" alt="">
    </div>
  </body>
</html>`

	// 推送信息
	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
}