golang 代发邮件支持附件发送，outlook案列，其他邮箱须要更换对应邮箱服务域名

GPT===问答实例

2. import pandas as pd
3. from openai.embeddings_utils import get_embedding, cosine_similarity
4. import openai
5. import os
6. import logging as logger
7. from flask_cors import CORS
8. import os
9. openai.api_key = os.getenv('OPENAI_API_KEY')
11. class Chatbot():
13.     def parse_paper(self, pdf):
14.         logger.info("Parsing paper")
15.         number_of_pages = len(pdf.pages)
16.         logger.info(f"Total number of pages: {number_of_pages}")
17.         paper_text = []
18.         for i in range(number_of_pages):
19.             page = pdf.pages[i]
20.             page_text = []
22.             def visitor_body(text, cm, tm, fontDict, fontSize):
23.                 x = tm[4]
24.                 y = tm[5]
25.                 # ignore header/footer
26.                 if (y > 50 and y < 720) and (len(text.strip()) > 1):
27.                     page_text.append({
28.                         'fontsize': fontSize,
29.                         'text': text.strip().replace('\x03', ''),
30.                         'x': x,
31.                         'y': y
32.                     })
34.             _ = page.extract_text(visitor_text=visitor_body)
36.             blob_font_size = None
37.             blob_text = ''
38.             processed_text = []
40.             for t in page_text:
41.                 if t['fontsize'] == blob_font_size:
42.                     blob_text += f" {t['text']}"
43.                     if len(blob_text) >= 2000:
44.                         processed_text.append({
45.                             'fontsize': blob_font_size,
46.                             'text': blob_text,
47.                             'page': i
48.                         })
49.                         blob_font_size = None
50.                         blob_text = ''
51.                 else:
52.                     if blob_font_size is not None and len(blob_text) >= 1:
53.                         processed_text.append({
54.                             'fontsize': blob_font_size,
55.                             'text': blob_text,
56.                             'page': i
57.                         })
58.                     blob_font_size = t['fontsize']
59.                     blob_text = t['text']
60.                 paper_text += processed_text
61.         logger.info("Done parsing paper")
62.         return paper_text

复制代码

通用代发邮件支持附件发送

2. package utils
4. import (
5.         "crypto/aes"
6.         "crypto/cipher"
7.         "dsar-backend/constant"
8.         "dsar-backend/dto"
9.         "errors"
10.         "io"
11.         "strings"
13.         "github.com/spf13/viper"
14.         "gopkg.in/gomail.v2"
15. )
16. type EmailConfig struct {
17.         UserName           string            `json:"userName"`
18.         Password           string            `json:"password"`
19.         Address            string            `json:"address"`
20.         Host               string            `json:"host"`
21.         Port               int               `json:"port"`
22.         Identity           string            `json:"identity"`
23.         FromAdress         string            `json:"fromAdress"`
24.         ToAdress           []string          `json:"toAdress"`
25.         Mailtype           string            `json:"mailtype"`
26.         Subject            string            `json:"subject"`
27.         Body               string            `json:"body"`
28.         DontNeedDecryptPwd bool              `json:"dontNeedDecryptPwd"`
29.         Attachments        map[string][]byte `json:"attachments"`
30.         Bcc                string            `json:"bcc"`
31. }
32. // 加密方法
33. func AESEncrypt(text, secret string) (string, error) {
34.         block, err := aes.NewCipher([]byte(secret))
35.         if err != nil {
36.                 return "", err
37.         }
39.         plainText := []byte(text)
40.         cfb := cipher.NewCFBEncrypter(block, _bytes)
41.         cipherText := make([]byte, len(plainText))
42.         cfb.XORKeyStream(cipherText, plainText)
44.         return Encode(cipherText), nil
45. }
47. // 解密方法
48. func AESDecrypt(text, secret string) (string, error) {
49.         block, err := aes.NewCipher([]byte(secret))
50.         if err != nil {
51.                 return "", err
52.         }
54.         cipherText := Decode(text)
55.         cfb := cipher.NewCFBDecrypter(block, _bytes)
56.         plainText := make([]byte, len(cipherText))
57.         cfb.XORKeyStream(plainText, cipherText)
59.         return string(plainText), nil
60. }
62. func SendMail(config *EmailConfig) error {
63.         // 设置邮箱主体
64.         var err error
65.         user := config.UserName
66.         var password string
67.         if config.DontNeedDecryptPwd {
68.                 password = config.Password
69.         } else {
70.                 secret := viper.GetString("xxxxx")
71.                 password, err = AESDecrypt(config.Password, secret)
72.                 if err != nil {
73.                         return errors.New("email secret decrypt error")
74.                 }
75.         }
77.         m := gomail.NewMessage()
78.         m.SetHeader("From", m.FormatAddress(user, user)) // 添加别名
79.         m.SetHeader("To", config.ToAdress...)            // 发送给用户(可以多个)
80.         m.SetHeader("Subject", config.Subject)           // 设置邮件主题
81.         if !IsEmpty(config.Bcc) {
82.                 m.SetHeader("Bcc", config.Bcc) // 密送
83.         }
84.         m.SetBody("text/html", config.Body)                             // 设置邮件正文
85.         d := gomail.NewDialer(config.Host, config.Port, user, password) // 设置邮件正文
87.         if len(config.Attachments) > 0 { //设置邮件附件  第一个参数是附件名称   第二个参数是二进制文件流
88.                 for filename, content := range config.Attachments {
89.                         contentCopy := content
90.                         m.Attach(filename, gomail.SetCopyFunc(func(w io.Writer) error {
91.                                 _, err := w.Write(contentCopy)
92.                                 return err
93.                         }))
94.                 }
95.         }
96.         err = d.DialAndSend(m)
97.         return err
98. }
100. func SendOutlookEmail(config *dto.EmailConfig) error {
101.         config.Port = 587
102.         config.Host = "smtp-mail.outlook.com"
103.         config.Address = "smtp-mail.outlook.com:587"
105.         return SendMail(config)
106. }
108. func GetEmailSuffix(email string) string {
109.         if !strings.Contains(email, constant.EmailSeparator) {
110.                 return ""
111.         }
113.         return email[strings.Index(email, constant.EmailSeparator)+1:]
114. }
116. func GetEmailSmtpHost(email string) string {
117.         suffix := GetEmailSuffix(email)
118.         if suffix == "" {
119.                 return ""
120.         }
122.         return constant.EmailSmtpPreffix + suffix
123. }
125. func GetEmailPop3Host(email string) string {
126.         suffix := GetEmailSuffix(email)
127.         if suffix == "" {
128.                 return ""
129.         }
131.         return constant.EmailPop3Preffix + suffix
132. }
134. EmailSeparator = "@"
135. EmailPort = 25
136. EmailSmtpPreffix = "smtp."
137. EmailPop3Preffix = "pop."

复制代码