2022年 11月 5日

python群发邮件

1. 前言

    1.1 应朋友要求，写一个群发邮件的脚本，用来实现往每个人的邮箱里边发送自己的工资条

2. 数据格式，最后一列是邮箱地址

3. 脚本实现的功能

    3.1 自定义邮件标题

    3.2 记录发送成功或失败的个数，防止发送失败

4. 代码实现
    

  1. # -*- coding: utf-8 -*-
  2. # @Time : 2021/3/26 10:11
  3. # @Author : liyf--95/02/02
  4. # @File : send_email.py
  5. # @Software: PyCharm
  6.  
  7. import xlrd
  8. import time
  9. import re
  10. from email.mime.text import MIMEText
  11. from smtplib import SMTP_SSL
  12.  
  13. from loguru import logger
  14.  
  15. # qq邮箱smtp服务器
  16. host_server = 'smtp.qq.com'
  17. # sender_qq为发件人的qq号码
  18. sender_qq = '123456@qq.com'
  19. # 第三方客户端登录时需要的授权码，不是qq密码
  20. pwd = 'xxxxxxxxxxxxx'
  21. # 发件人的邮箱
  22. sender_qq_mail = '123456@qq.com'
  23. # 获取当前月份
  24. batch = time.strftime("%Y-%m", time.localtime())
  25.  
  26. suffix = time.strftime("%Y%m", time.localtime())
  27. # ssl登录
  28. smtp = SMTP_SSL(host_server)
  29. # set_debuglevel()是用来调试的。参数值为1表示开启调试模式，参数值为0关闭调试模式，
  30. smtp.set_debuglevel(0)
  31. smtp.ehlo(host_server)
  32. smtp.login(sender_qq, pwd)
  33.  
  34.  
  35. def get_success_error_counts():
  36.     """
  37.     用来读取日志文件中的数据，并转成列表形式，方便调用该函数处理列表中的数据，用来做去重处理
  38.     :return: 列表
  39.     """
  40.     success_email_list = []
  41.  
  42.     try:
  43.         with open(f'success_log_{suffix}.txt', 'r', encoding='utf8') as f:
  44.             results = f.readlines()
  45.             for res in results:
  46.                 success_email_list.append(res.strip())
  47.     except Exception:
  48.         logger.error(f'success_log_{suffix}.txt 文件不存在，初始化列表为0！')
  49.         success_email_list = success_email_list
  50.  
  51.     error_list = []
  52.     try:
  53.         with open(f'error_log_{suffix}.txt', 'r', encoding='utf8') as f:
  54.             results = f.readlines()
  55.             for res in results:
  56.                 restr = res.strip()
  57.                 email = re.findall(re.compile(r"email': '(.*?)', '", re.S), restr)[0]
  58.                 error_list.append(email)
  59.     except Exception:
  60.         error_list = error_list
  61.  
  62.     return success_email_list, error_list
  63.  
  64.  
  65. def read_excel(subject):
  66.     """
  67.     读取excel数据
  68.     :param subject: 自定义的邮件标题
  69.     :return:
  70.     """
  71.     workbook = xlrd.open_workbook('工资条2.xlsx')
  72.  
  73.     worksheet = workbook.sheet_by_index(0)
  74.  
  75.     nrows = worksheet.nrows
  76.     # 定义一个空列表，用来存放每一个员工的数据，包括表头
  77.     total_list = []
  78.     for i in range(nrows):
  79.         data_list = worksheet.row_values(i)
  80.         if data_list[0] == '':
  81.             pass
  82.         else:
  83.             total_list.append(data_list)
  84.     logger.info(f'数据读取完毕，共有 {len(total_list) - 1} 位同事')
  85.     logger.info('------------------------------------------------------------')
  86.     time.sleep(2)
  87.     for k, v in enumerate(total_list[1:]):
  88.         msg_content = ''
  89.         for i, j in enumerate(v):
  90.             if total_list[0][i] == '邮箱':
  91.                 pass
  92.             else:
  93.                 # 有一些列的数据为空，处理数据
  94.                 val = '无' if str(v[i]).strip() == '' else v[i]
  95.                 msg = f'#     {total_list[0][i]}：{val}\n'
  96.                 msg_content += msg
  97.         name = v[0]
  98.         email_addr = v[-1]
  99.         success, error = get_success_error_counts()
  100.         logger.info(f'正在向第 {k + 1}/{len(total_list) - 1} 位同事 {name} 发送邮件，请稍等...')
  101.         if len(success) == 0:
  102.             # 说明日志中没有数据，即还没有发送成功的例子
  103.             # 开始发送数据
  104.             email_content = f'尊敬的 {name} 同事，您好，您的 {batch} 月份工资单信息如下：\n{msg_content}#     发送时间：{time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())}'
  105.             send_email_to_member(email_addr, email_content, name, subject)
  106.             logger.info(f'已发送至邮箱：{email_addr}，接收人：{name}')
  107.         else:
  108.             # 已经有发送成功的例子，并已存入success_log.txt文件中
  109.             email_list = []  # 用来存放success_log.txt文件中的邮箱地址，用来去重
  110.             for data in success:
  111.                 email_list.append(str(data).split('---->')[-1])
  112.             if email_addr in email_list:
  113.                 # 如果需要发送邮件的邮箱地址在success_log.txt文件中，则说明该邮箱已经发送过，无需重复发送
  114.                 logger.warning(f'{name} 同事：{email_addr} 已经发送过了，无需重复发送邮件！！')
  115.                 pass
  116.             else:
  117.                 # 正常发送邮件
  118.                 email_content = f'尊敬的 {name} 同事，你好，您的 {batch} 月份工资单信息如下：\n{msg_content}#     发送时间：{time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())}'
  119.                 send_email_to_member(email_addr, email_content, name, subject)
  120.                 logger.info(f'已发送至邮箱：{email_addr}，接收人：{name}')
  121.         logger.info('------------------------------------------------------------')
  122.     logger.info(f'脚本运行结束！等待5分钟后自动关闭窗口（或者手动点击窗口右上角关闭）！！！')
  123.     logger.info('运行结果：')
  124.     logger.info(f'{len(total_list) - 1} 位同事已全部发送完毕')
  125.     success, error = get_success_error_counts()
  126.     logger.info(f'Successd：{len(success)}，Failed：{len(error)}')
  127.     time.sleep(300)
  128.  
  129.  
  130. def send_email_to_member(email_addr, email_content, name, subject):
  131.     """
  132.     发送邮件
  133.     :param email_addr: 收件人邮箱地址
  134.     :param email_content: 需要发送的正文内容
  135.     :param name: 收件人姓名
  136.     :return:
  137.     """
  138.     msg = MIMEText(email_content, "plain", 'utf-8')
  139.     msg["Subject"] = subject  # 邮件标题
  140.     msg["From"] = sender_qq_mail  # 发件人
  141.     msg["To"] = email_addr  # 收件人邮箱
  142.     try:
  143.         smtp.sendmail(sender_qq_mail, email_addr, msg.as_string())
  144.         smtp.quit()
  145.         msg = f'{name} 发送成功，时间: {time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())}---->{email_addr}'
  146.         with open(f'success_log_{suffix}.txt', 'a', encoding='utf8') as f:
  147.             f.write(msg)
  148.             f.write('\n')
  149.             f.close()
  150.         time.sleep(0.5)
  151.     except Exception as e:
  152.         logger.error(f'发送失败--->{name}\n原因：{e}')
  153.         item = {}
  154.         item['name'] = name
  155.         item['email'] = email_addr
  156.         item['error_reason'] = e
  157.         item['date'] = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
  158.         with open(f'error_log_{suffix}.txt', 'a', encoding='utf8') as f:
  159.             f.write(str(item))
  160.             f.write('\n')
  161.             f.close()
  162.  
  163.  
  164. if __name__ == '__main__':
  165.     subject = input('请输入自定义邮件标题：')
  166.     logger.info(f'自定义邮件标题为：{subject}')
  167.     read_excel(subject)

5. 逻辑梳理

    5.1 该脚本的使用qq邮箱发送，其中获取授权码可以 点击这里参考博客

    5.2 注意事项

        5.2.1 excel名称必须为 `工资条2.xlsx`

        5.2.2 `邮箱` 列必须为最后一列，`姓名` 列必须在第一列，因为代码中 `name=v[0], email_addr=v[-1]` 是固定的。可以自己做适当修改

        5.2.3 表头名称可以随意改动，列数也可以随意增减，但要保证 `邮箱` 和 `姓名` 列存在

6. success_log_202103.txt 和 error_log_202103.txt 的作用

    6.1 success_log_202103.txt

        6.1.1 用来记录发送成功的数据

        6.1.2 发送邮件之前，会先读取该txt文件，并判断要发送的email地址是否在txt里边，如果存在，则不发送，防止重复发送

    6.2 error_log_202103.txt

        6.2.1 一般情况下，没有这个文件，但是由于一些不可控因素，比如邮箱地址不存在或者断网等，会导致发送邮件失败

        6.2.2 发送失败之后会把当前发送的数据记录下来，就会生成这个文件

       6.2.3 如果该文件有数据，则首先检查是否是邮箱不正确导致的，如果不是，重新运行exe文件

7. 测试

    7.1 使用 `pyinstaller -F send_email.py` 打包 py 文件为 exe 可执行文件

    7.2 运行截图         

      

    7.3 邮件内容