import smtplib
from email.mime.text import MIMEText
from email.utils import formataddr
import requests
import logging
import datetime
import time
from requests import exceptions
from getConfig import getConfig
def send_mail(body):
# 发件人
from_name = getConfig('listen.ini','listen','from_name')
# 发件邮箱
from_addr = getConfig('listen.ini','listen','from_addr')
# 发件邮箱授权码，注意不是QQ邮箱密码
from_pwd = getConfig('listen.ini','listen','from_pwd')
# 收件邮箱
to_addrs = getConfig('listen.ini','listen','to_addrs')
to_addrs = to_addrs.split(',')
# 邮件标题
my_title = getConfig('listen.ini','listen','my_title')
# 邮件正文
msg = MIMEText(body, 'plain', 'utf-8')
msg['From'] = formataddr([from_name, from_addr])
# 邮件的标题
msg['Subject'] = my_title
# SMTP服务器地址，QQ邮箱的SMTP地址是"smtp.qq.com"
# smtp_srv = "smtp.qq.com"
smtp_srv = getConfig('listen.ini','listen','smtp_srv')
try:
# 不能直接使用smtplib.SMTP来实例化，第三方邮箱会认为它是不安全的而报错
# 使用加密过的SMTP_SSL来实例化，它负责让服务器做出具体操作，它有两个参数
# 第一个是服务器地址，但它是bytes格式，所以需要编码
# 第二个参数是服务器的接受访问端口，SMTP_SSL协议默认端口是465 25
srv = smtplib.SMTP_SSL(smtp_srv.encode(), 465)
# 使用授权码登录QQ邮箱
srv.login(from_addr, from_pwd)
# 使用sendmail方法来发送邮件，它有三个参数
# 第一个是发送地址
# 第二个是接受地址，是list格式，可以同时发送给多个邮箱
# 第三个是发送内容，作为字符串发送
for to_addr in to_addrs:
srv.sendmail(from_addr, [to_addr], msg.as_string())
# srv.sendmail(from_addr, [to_addr1], msg.as_string())
logger.info(to_addr+'发送成功')
except Exception as e:
logger.error('发送失败 '+str(e))
finally:
#无论发送成功还是失败都要退出你的QQ邮箱 检测srv是否存在 不检测会程序报错
if 'srv' in globals():
srv.quit()
if __name__ == '__main__':
logger = logging.getLogger()
logger.setLevel(logging.INFO)
#设置将日志输出到文件中，并且定义文件内容
now = datetime.datetime.now().strftime("%Y-%m-%d_%H-%M-%S")
fileinfo = logging.FileHandler(f"listen_{now}.log")
fileinfo.setLevel(logging.INFO)
#设置将日志输出到控制台
controlshow = logging.StreamHandler()
controlshow.setLevel(logging.INFO)
#设置日志的格式
formatter = logging.Formatter("%(asctime)s - %(levelname)s: %(message)s")
fileinfo.setFormatter(formatter)
controlshow.setFormatter(formatter)
logger.addHandler(fileinfo)
logger.addHandler(controlshow)
# os.system('pause')
print( " ...............正在监听V8移动端wechat...............")
print( " .....................阿弥陀佛.......................")
print( " _oo0oo_ ")
print( " o8888888o ")
print( ' 88" . "88 ')
print( " (| -_- |) ")
print( " 0\\ = /0 ")
print( " ___/‘---’\\___ ")
print( " .' \\| |/ '. ")
print( " / \\\\||| : |||// \\ ")
print( " / _||||| -卍-|||||_ \\ ")
print( " | | \\\\\\ - /// | | ")
print( " | \\_| ''\\---/'' |_/ | ")
print( " \\ .-\\__ '-' ___/-. / ")
print( " ___'. .' /--.--\\ '. .'___ ")
print( " ."" ‘< ‘.___\\_<|>_/___.’>’ "". ")
print( " | | : ‘- \\‘.;‘\\ _ /’;.’/ - ’ : | | ")
print( " \\ \\ ‘_. \\_ __\\ /__ _/ .-’ / / ")
print( " =====‘-.____‘.___ \\_____/___.-’___.-’===== ")
print( " ‘=---=’ ")
print( " ")
print( "..................佛祖保佑, 一直监听..................")
urls = getConfig('listen.ini','listen','urls')
urls = urls.split(',')
while True:
for url in urls:
try:
response = requests.get(url,timeout=5)
code = response.status_code
body = str(url) + ' 运行异常,状态码：' + str(code) + ' 请检查服务运行情况'
# 定义邮件数量5
i = 0
if code != 200:
i += 1
logger.error(body)
send_mail(body)
if i >= 5:
# 延时30分钟
time.sleep(1800)
i = 0
except exceptions.HTTPError as e:
logger.error("发生HTTP错误，原因是："+ str(e))
send_mail("发生HTTP错误，原因是："+ str(e))
time.sleep(5)
except exceptions.Timeout as e:
logger.error("访问超时，原因是："+ str(e))
send_mail("访问超时，原因是："+ str(e))
time.sleep(5)
except Exception as e:
logger.error("未知错误，原因是：" + str(e))
send_mail("未知错误，原因是：" + str(e))
time.sleep(5)
