-
Notifications
You must be signed in to change notification settings - Fork 19
/
receive_mails.py
225 lines (191 loc) · 8.96 KB
/
receive_mails.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
# coding: utf8
# @Author: 郭 璞
# @File: receive_mails.py
# @Time: 2017/3/27
# @Contact: 1064319632@qq.com
# @blog: http://blog.csdn.net/marksinoberg
# @Description: 收邮件咯
import poplib
from email.parser import Parser
import base64
import re
import getpass
class MailInfo(object):
"""
用于临时保存邮件信息的类
"""
def __init__(self):
self.index = 0
self.size = 0
self.status = ""
self.data = ""
# self.details = None
class MailDetails(object):
"""
包括邮件的发件人的昵称， 发件人的账号
收件人的昵称，收件人的账号
信件的主题
信件发送到服务器上的时间
信件的正文
"""
def __init__(self):
self.from_nickname = ""
self.from_account = ""
self.to_nickname = ""
self.to_account = ""
self.subject = ""
self.receivedtime = ""
self.text_content = ""
self.html_content = ""
def get_parsed_msg(useraccount, password, limits=1, debuglevel=1):
"""
:param useraccount: 邮件用户名
:param password: 邮件接收授权码
:param limits: 要接收的信件数目. 默认按时间最新排序
:return: email.message.Message对象。已是被解析过的数据，可使用Message对象的api方法进一步操作。
"""
# 邮件服务器地址, 可以通过邮箱账号来分析得到
pop3_server = 'pop.'+useraccount.split('@')[-1]
# 开始连接到服务器
server = poplib.POP3(pop3_server)
# 可选项： 打开或者关闭调试信息，1为打开，会在控制台打印客户端与服务器的交互信息
server.set_debuglevel(debuglevel)
# 可选项： 打印POP3服务器的欢迎文字，验证是否正确连接到了邮件服务器
print(server.getwelcome().decode('utf8'))
# 开始进行身份验证
server.user(useraccount)
server.pass_(password)
# 使用list()返回所有邮件的编号，默认为字节类型的串
resp, mails, octets = server.list()
print('邮件总数： {}'.format(len(mails)))
# 总的邮件数
total_mail_numbers = len(mails)
# 获取最新的limits封邮件, 最多获取全部的邮件，用一个列表保存
recv_mails = []
limits = limits if limits <= total_mail_numbers else total_mail_numbers
for item in mails[-1:-(limits+1):-1]:
# 为每一封邮件进行实例化处理
mailinfo = MailInfo()
index, size = decode_byte(item).split(' ')
mailinfo.index = index
mailinfo.size = size
resp_status, mail_lines, mail_octets = server.retr(index)
mailinfo.status = resp_status
content_charset = get_rawcontent_charset(mail_lines)
msg = parse_raw_mail_data(mail_lines, charset=content_charset)
mailinfo.data = msg
# print("++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++"+str(type(msg)))
# maildetails = get_mail_details(msg)
# mailinfo.details = maildetails
recv_mails.append(mailinfo)
# 关闭与服务器的连接，释放资源
server.close()
# 返回获取到的limits封邮件详情
return recv_mails
# # 下面单纯获取最新的一封邮件
# # 默认下标越大，邮件越新，所以total_mail_numbers代表最新的那封邮件
# response_status, mail_message_lines, octets = server.retr(total_mail_numbers)
# print('邮件获取状态： {}'.format(response_status))
# print('原始邮件数据:\n{}'.format(mail_message_lines))
# print('该封邮件所占字节大小: {}'.format(octets))
# msg_content = b'\r\n'.join(mail_message_lines).decode('gbk')
# # 邮件原始数据没法正常浏览，因此需要相应的进行解码操作
# msg = Parser().parsestr(text=msg_content)
# # print('解码后的邮件信息:\n{}'.format(msg))
# 关闭与服务器的连接，释放资源
# server.close()
# return msg
def get_mail_details(msg):
# 新建一个Bean对象
maildetails = MailDetails()
# 获取发件人详情
fromstr = msg.get('From')
# print(fromstr)
from_nickname, from_account = get_mail_info(fromstr)
maildetails.from_nickname = from_nickname
maildetails.from_account = from_account
# print(from_nickname, from_account)
# 获取收件人详情
tostr = msg.get('To')
to_nickname, to_account = get_mail_info(tostr)
# print(to_account, to_nickname)
maildetails.to_nickname = to_nickname
maildetails.to_account = to_account
# 获取主题信息，也就是标题内容
subject = msg.get('Subject')
print("原生Subject信息："+subject)
maildetails.subject = decode_base64(subject.split("?")[3], charset=subject.split("?")[1])
# 获取时间信息，也即是邮件被服务器收到的时间
received_time = msg.get("Date")
# print(received_time)
maildetails.receivedtime = received_time
parts = msg.get_payload()
# print('8'*9, parts[0].as_string())
content_type = parts[0].get_content_type()
content_charset = parts[0].get_content_charset()
# parts[0] 默认为文本信息，而parts[1]默认为添加了HTML代码的数据信息
content = parts[0].as_string().split('base64')[-1]
# print('Content*********', decode_base64(content, content_charset))
maildetails.text_content = decode_base64(content, content_charset)
content = parts[1].as_string().split('base64')[-1]
# print('HTML Content:', decode_base64(content, content_charset))
maildetails.html_content = decode_base64(content, content_charset)
return maildetails
# 为base64编码的串进行解码操作，返回字符串信息
def decode_base64(s, charset='utf8'):
return str(base64.decodebytes(s.encode(encoding=charset)), encoding=charset)
# 获取FROM， TO等字段的解析详情
def get_mail_info(s):
# print("++++++++++++++++++++++++++++++++++++++++++++++++++++++"+str(type(s)))
nickname, account = s.split(" ")
# 获取字串的编码信息
charset = nickname.split('?')[1]
# print('编码：{}'.format(charset))
nickname = nickname.split('?')[3]
nickname = str(base64.decodebytes(nickname.encode(encoding=charset)), encoding=charset)
account = account.lstrip('<')
account = account.rstrip('>')
return nickname, account
# 因为邮件中格式是由英文确定的，所以在此处查找文本的编码时可以使用utf8作为临时解码集，用于查找文本正文编码信息
def get_rawcontent_charset(rawcontent):
for item in rawcontent:
if decode_byte(item).find('charset='):
charset = []
charset = re.findall(re.compile('charset="(.*)"'), decode_byte(item))
for item in charset:
if item is not None:
return item
# 返回被email.Parser模块解码后的邮件数据信息
def parse_raw_mail_data(raw_lines, charset='utf8'):
msg_content = b'\r\n'.join(raw_lines).decode(encoding=charset)
return Parser().parsestr(text=msg_content)
# 将字节数据通过相应的编码转换成字符串类型的数据
def decode_byte(bstr, charset='utf8'):
return bstr.decode(charset)
if __name__ == '__main__':
useraccount = input('Mail User Account:')
password = getpass.getpass(prompt='Your Auth Code:')
limits = int(input('How many mails you want to receive:'))
debug_level = int(input('the debug level, default is on which is number 1'))
# 获取到limits限制下的所有的邮件
mails = get_parsed_msg(useraccount=useraccount, password=password, limits=limits, debuglevel=debug_level)
# 进入循环操作体
exitcode = 0
while not exitcode:
# 输出获取到的邮件的主题，给出相应下标，让用户进行选择
for index, mail in enumerate(mails):
print("["+str(index)+": "+decode_byte(mail.status)+"]", end='\t')
choice = int(input('Please choose one mail to check details, use index from 0:'))
print('\n')
# 给出可选菜单，让用户选择输出哪些字段的值，另新增全字段显示ALL
maildetails = get_mail_details(mails[choice].data)
print("["+str(index)+": "+maildetails.subject+", "+ maildetails.from_nickname+", "+maildetails.receivedtime+", "+maildetails.text_content+"]")
# 询问是否退出邮件查询系统，是则退出，否则继续进行下一步的查询操作
userinput = input('ready to exit? (Y/N)')
exitcode = 0 if (userinput=='y' or userinput=='Y') else 1
# mails = get_parsed_msg('spidersmall@163.com', 'yourpassword', 3, 1)
# data = mails[1].data
# maildetails = get_mail_details(data)
# print(maildetails.receivedtime)
# print(maildetails.subject)
# print(maildetails.from_nickname)