File size: 7,291 Bytes
7ec53ba |
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 |
import asyncio
import poplib
import datetime
from email.parser import Parser
from email.header import decode_header
from email.utils import parseaddr
# QQ邮箱轮询等待tradingview报警
# indent用于缩进显示:
def parse_email(msg, indent):
if indent == 0:
# 邮件的From, To, Subject存在于根对象上:
for header in ['From', 'To', 'Subject', 'Date']:
value = msg.get(header, '')
if value:
if header == 'Subject':
# 需要解码Subject字符串:
value = decode_str(value)
if header == 'Date':
value = value
else:
# 需要解码Email地址:
hdr, addr = parseaddr(value)
name = decode_str(hdr)
value = u'%s <%s>' % (name, addr)
print('%s%s: %s' % (' ' * indent, header, value))
if (msg.is_multipart()):
# 如果邮件对象是一个MIMEMultipart,
# get_payload()返回list，包含所有的子对象:
parts = msg.get_payload()
for n, part in enumerate(parts):
# 递归打印每一个子对象:
return parse_email(part, indent + 1)
else:
# 邮件对象不是一个MIMEMultipart,
# 就根据content_type判断:
content_type = msg.get_content_type()
if content_type == 'text/plain' or content_type == 'text/html':
# 纯文本或HTML内容:
content = msg.get_payload(decode=True)
# 要检测文本编码:
charset = guess_charset(msg)
if charset:
global Text
Text = content.decode(charset)
print('%sText: %s' % (' ' * indent, Text))
else:
# 不是文本，作为附件处理:
print('%sAttachment: %s' % (' ' * indent, content_type))
# 解码
def decode_str(s):
value, charset = decode_header(s)[0]
if charset:
value = value.decode(charset)
return value
# 猜测字符编码
def guess_charset(msg):
# 先从msg对象获取编码:
charset = msg.get_charset()
if charset is None:
# 如果获取不到，再从Content-Type字段获取:
content_type = msg.get('Content-Type', '').lower()
for item in content_type.split(';'):
item = item.strip()
if item.startswith('charset'):
charset = item.split('=')[1]
break
return charset
# 此函数通过使用poplib实现接收邮件
async def qq_pop_serve():
# 要进行邮件接收的邮箱。改成自己的邮箱
email_address = "1348006516@qq.com"
# 要进行邮件接收的邮箱的密码。改成自己的邮箱的密码
# 设置 -> 账户 -> POP3/IMAP/SMTP/Exchange/CardDAV/CalDAV服务 -> 开启服务：POP3/SMTP服务
# 设置 -> 账户 -> POP3/IMAP/SMTP/Exchange/CardDAV/CalDAV服务 -> 生成授权码
email_password = "tfspjbixhevlihfi"
# 邮箱对应的pop服务器，也可以直接是IP地址
# 改成自己邮箱的pop服务器；qq邮箱不需要修改此值
pop_server_host = "pop.qq.com"
# 邮箱对应的pop服务器的监听端口。改成自己邮箱的pop服务器的端口；qq邮箱不需要修改此值
pop_server_port = 995
try:
# 连接pop服务器。如果没有使用SSL，将POP3_SSL()改成POP3()即可其他都不需要做改动
email_server = poplib.POP3_SSL(
host=pop_server_host, port=pop_server_port, timeout=10)
print("pop3----connect server success, now will check username")
except:
print("pop3----sorry the given email server address connect time out")
exit(1)
try:
# 验证邮箱是否存在
email_server.user(email_address)
print("pop3----username exist, now will check password")
except:
print("pop3----sorry the given email address seem do not exist")
exit(1)
try:
# 验证邮箱密码是否正确
email_server.pass_(email_password)
print("pop3----password correct,now will list email")
except:
print("pop3----sorry the given username seem do not correct")
exit(1)
while True:
# 邮箱中其收到的邮件的数量
email_count = len(email_server.list()[1])
# list()返回所有邮件的编号:
resp, mails, octets = email_server.list()
# 遍历所有的邮件
for i in range(1, len(mails) + 1):
# 通过retr(index)读取第index封邮件的内容；这里读取最后一封，也即最新收到的那一封邮件
resp, lines, octets = email_server.retr(i)
# lines是邮件内容，列表形式使用join拼成一个byte变量
email_content = b'\r\n'.join(lines)
try:
# 再将邮件内容由byte转成str类型
email_content = email_content.decode('utf-8')
except Exception as e:
print(str(e))
continue
# # 将str类型转换成<class 'email.message.Message'>
# msg = email.message_from_string(email_content)
msg = Parser().parsestr(email_content)
print('------------------------------ 华丽分隔符 ------------------------------')
# 写入邮件内容到文件
parse_email(msg, 0)
# 服务一直开启不用关闭
# email_server.close()
# 将收件时间转为标准时间
global gtime
gtime = msg.get('Date', '')
gtime = gtime.replace(":", ' ')
gtime = gtime.split()
day = int(gtime[1])
mon = ['Jan', 'Feb', 'Mar', 'Apr', 'May', 'Jun',
'Jul', 'Aug', 'Sep', 'Oct', 'Nov', 'Dec']
month = mon.index(gtime[2]) + 1
year = int(gtime[3])
hour = int(gtime[4])
minute = int(gtime[5])
second = int(gtime[6])
# 时区为0无需加减
# tUTC = +0000
totime = datetime.datetime(year, month, day, hour, minute, second)
# 只看最新lasttime秒内收到的邮件，并且在警报触发时执行在websocket上的交易命令
lasttime = 500000
if msg.get("From", '') == "TradingView <noreply@tradingview.com>" and (totime-datetime.datetime.now()).seconds <= lasttime:
# 判断警报触发时需要执行的命令:针对Text文本执行
print('totime=', totime, 'now=', datetime.datetime.now())
print('TEXT=', Text)
# 删除邮件方式1：警报读取并触发交易之后删除邮件
# email_server.dele(i)
# print('警报读取完毕，删除邮件')
# 删除邮件方式2：判断1天前的邮件
# if maildate.date() < datetime.datetime.now().date() - datetime.timedelta(days=1):
# print("正在删除邮件 第{}封，邮件日期：{} {}".format(i+1,maildate.date(),maildate.time()))
# mailServer.dele(i + 1)
await asyncio.sleep(1)
loop = asyncio.get_event_loop()
loop.run_until_complete(
qq_pop_serve(),
)
# loop.close()、
|