ASJLanguageSys/Utils/NeteaseMail.py

import email
import imaplib
import re
import smtplib
from email.header import  Header
from email.mime.text import MIMEText
from nntplib import decode_header
from turtle import pd

from boto3 import Session
from imapclient import IMAPClient



class NeteaseMail:

    # 连接邮箱服务器并登录。
    def loginEmail(self, imap_server, from_addr, password, imap_port, isssl=True):
        '''第一部分：收件IMAP4********************************************'''
        '''登录邮箱IMAP4=========================================================='''
        email_server = None
        #993  465
        try:

            email_server = IMAPClient(imap_server, ssl=isssl, port=imap_port)
            #email_server = imaplib.IMAP4_SSL(IMAP_SERVER, 993)  # 网易企业邮箱服务器及SSL端口
            print("imap4 服务器连接成功")

            email_server.login(from_addr, password)

            email_server.id_({"name": "IMAPClient", "version": "2.1.0"})
            #email_server.login(FROM_ADDR, PASSWORD)
            print("imap4 账号密码正确，登录成功")
        except:
            print("imap4 服务器连接失败")
        else:
            return email_server

    #关闭邮箱服务器连接
    def closeEmail(self, email_server):
        # 关闭select
        email_server.close()
        # 关闭连接
        email_server.logout()

    #获取邮箱内容、标题、发件人
    def getEmailContext(self, email_server):
        ''' 邮箱中收到的未读邮件的数量=========================================================='''
        #email_server.select_folder('INBOX', readonly=True)

        email_server.select_folder('INBOX', readonly=True)  # readonly=True表明只读并不修改任何信息
        results = email_server.search()
        subject_list = []
        bodydata_list = []
        from_list = []
        try:
            for uid in results:
                msgdict = email_server.fetch(uid, ['Body[]','ENVELOPE'], '(RFC822)')
                mailbody = msgdict[uid][b'BODY[]']
                envelope = msgdict[uid][b'ENVELOPE']
                message = email.message_from_bytes(mailbody)

                msgfrom = message['from']
                m_type = message.get('Content-Type')
                if m_type and 'text/html' in m_type:
                    con3 = message.get_payload(decode=True).strip()
                    subject = message['Subject']
                    subdecode = decode_header(subject)
                    subject_list.append(subdecode)
                    from_list.append(message['from'])
                    bodydata_list.append(con3.decode('utf8'))

        except:
           print('获取内容出错')
        else:
            return subject_list, from_list, bodydata_list
        # if subject_list and bodydata_list:
        #     data_unseen = [subject_list, bodydata_list]
        #     data_unseen1 = pd.DataFrame(data_unseen)
        #     data_unseen1.to_csv('data_unseen.csv', sep=',', header=True, index=True, encoding='utf_8_sig')
        #
        #     aws_key = "ASIA2E67UIMDTJFRF7UE"  # 【你的 aws_access_key】
        #     aws_secret = "5u6MDvm3Fabdbc6EG9+JPJE3x07peNkrvok76Dqq"  # 【你的 aws_secret_key】
        #     aws_session_token = "FwoGZXIvYXdzEHQaDKQchZxanXOpNJ2UriLoARUmKF/Uf6HZMhB4Bdo1Df4BlirgpqOyXmMULjx1yvqah1+BKIV2rzEoxxaVmvjcvLjHMQamPR7QzLZYP/WgJ6biPTnfqJWy5rCVpIZtD3D2nmGWAf5RSedADILJgBQmrXumFX2jrnm6THbqfdyfT2eitKt5ZD82zvLOaHMWu7mzomzmye8Eimt28Dhj6jsLeZPxOhhHBLUi+gddHAMCQq8HmGbnsXN5OrOBvqreRAxdR/u6vuQHbVpV3b8V5nkAtTVhOCaGRcPETARB8F/jFuFRhW9tAjPZisP/SEa8vUDR32FoMNQeda4o5+7l/gUyKYlem5bIB96gywY6s4C8c1PAa3l09+5tdGNp5laAJf7vMUzMJckR2EgF"
        #     session = Session(aws_access_key_id=aws_key,
        #                       aws_secret_access_key=aws_secret,
        #                       aws_session_token=aws_session_token,
        #                       region_name="ap-southeast-1")  # 此处根据自己的 s3 地区位置改变
        #     s3 = session.resource("s3")
        #     client = session.client("s3")
        #     bucket = "asj-oct-ipc"  # 【你 bucket 的名字】 # 首先需要保.证 s3 上已经存在该存储桶，否则报错
        #     upload_data = open("./././static/log/error.log", "rb")
        #     upload_key = "86YC8Z192VB1VMKU111A/vod1/test"
        #     file_obj = s3.Bucket(bucket).put_object(Key=upload_key, Body=upload_data)


    #发送邮箱
    def faEmail(self,email_server,message,subject,from_addr,to_addr):
        if email_server:
            print("邮件开始发送")

            message = message
            msg = MIMEText(message, 'plain', 'utf-8')
            msg['Subject'] = Header(subject, 'utf-8')
            msg['From'] = Header(from_addr)

        try:
            msg['To'] = Header(to_addr, 'utf-8')
            email_server.sendmail(from_addr, to_addr, msg.as_string())  # 将msg转化成string发出
            print("邮件发送成功")

        except Exception as e:
            print('Error:', e)

        email_server.quit()

    # def sentemail(self,message,subject,from_addr,to_addr):
    #     host = 'smtp.163.com'
    #     # 设置发件服务器地址
    #     port = 465
    #     # 设置发件服务器端口号。注意，这里有SSL和非SSL两种形式，现在一般是SSL方式
    #     sender = FROM_ADDR
    #     # 设置发件邮箱，一定要自己注册的邮箱
    #     pwd = PASSWORD
    #     # 设置发件邮箱的授权码密码，根据163邮箱提示，登录第三方邮件客户端需要授权码
    #     receiver = to_addr
    #     # 设置邮件接收人，可以是QQ邮箱
    #     body = message
    #     # 设置邮件正文，这里是支持HTML的
    #     msg = MIMEText(body, 'html')
    #     # 设置正文为符合邮件格式的HTML内容
    #     msg['subject'] = subject
    #     # 设置邮件标题
    #     msg['from'] = from_addr
    #     # 设置发送人
    #     msg['to'] = to_addr
    #     # 设置接收人
    #     try:
    #         s = smtplib.SMTP_SSL(host, port)
    #         # 注意！如果是使用SSL端口，这里就要改为SMTP_SSL
    #         s.login(sender, pwd)
    #         # 登陆邮箱
    #         s.sendmail(sender, receiver, msg.as_string())
    #         # 发送邮件！
    #         print('Done.sent email success')
    #     except smtplib.SMTPException:
    #         print('Error.sent email fail')

    # mailto_list = ['xxxxxx@xx.com]
    #                mail_host = "smtp.163.com"
    # mail_user = "xxxxxx"
    # mail_pass = "xxxxxxxxxx"
    #
    # def send_mail(mailto_list, sub, content,mail_user,mail_pass):
    #     me = "hello" + "<" + mail_user + "@1368035>"
    #     msg = MIMEText(content, _subtype='plain')
    #     msg['Subject'] = sub
    #     msg['From'] = me
    #     try:
    #         for mail in mailto_list:
    #             msg['To'] = mail
    #             server = smtplib.SMTP()
    #             server.connect(mail_host)
    #             server.login(mail_user, mail_pass)
    #             server.sendmail(me, mail, msg.as_string())
    #             server.close()
    #             del msg['To']
    #         return True
    #     except Exception, e:
    #         print
    #         str(e)
    #         return False