From 5fe8286e58ef5ea05e70a7d716f7073cb0f05204 Mon Sep 17 00:00:00 2001 From: cycz <838143144@qq.com> Date: Fri, 7 Feb 2020 21:56:54 +0800 Subject: [PATCH] =?UTF-8?q?windows=20=E8=B7=AF=E5=BE=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- config/config.py | 23 ----------------------- log/jdlogger.py | 26 -------------------------- message/jdEmail.py | 41 ----------------------------------------- message/message.py | 30 ------------------------------ message/wechat_ftqq.py | 31 ------------------------------- 5 files changed, 151 deletions(-) delete mode 100644 config/config.py delete mode 100644 log/jdlogger.py delete mode 100644 message/jdEmail.py delete mode 100644 message/message.py delete mode 100644 message/wechat_ftqq.py diff --git a/config/config.py b/config/config.py deleted file mode 100644 index 2c730a6..0000000 --- a/config/config.py +++ /dev/null @@ -1,23 +0,0 @@ -# -*- coding: utf-8 -*- -import os -import configparser - - -class Config(object): - def __init__(self, config_file='configDemo.ini'): - self._path = os.path.join(os.getcwd(), config_file) - if not os.path.exists(self._path): - raise FileNotFoundError("No such file: config.ini") - self._config = configparser.ConfigParser() - self._config.read(self._path, encoding='utf-8-sig') - self._configRaw = configparser.RawConfigParser() - self._configRaw.read(self._path, encoding='utf-8-sig') - - def get(self, section, name): - return self._config.get(section, name) - - def getRaw(self, section, name): - return self._configRaw.get(section, name) - - -global_config = Config() diff --git a/log/jdlogger.py b/log/jdlogger.py deleted file mode 100644 index d8c5f17..0000000 --- a/log/jdlogger.py +++ /dev/null @@ -1,26 +0,0 @@ -# -*- coding=utf-8 -*- -import logging -import logging.handlers -''' -日志模块 -''' -LOG_FILENAME = 'jdBuyMask.log' - -logger = logging.getLogger() - - -def set_logger(): - logger.setLevel(logging.INFO) - formatter = logging.Formatter('%(asctime)s %(levelname)s: %(message)s') - - console_handler = logging.StreamHandler() - console_handler.setFormatter(formatter) - logger.addHandler(console_handler) - - file_handler = logging.handlers.RotatingFileHandler( - LOG_FILENAME, maxBytes=10485760, backupCount=5, encoding="utf-8") - file_handler.setFormatter(formatter) - logger.addHandler(file_handler) - - -set_logger() diff --git a/message/jdEmail.py b/message/jdEmail.py deleted file mode 100644 index 292c80f..0000000 --- a/message/jdEmail.py +++ /dev/null @@ -1,41 +0,0 @@ -# -*- coding=utf-8 -*- -''' -发送邮件模块 -''' -import traceback - - -def sendMail(mail, msgtext): - try: - import smtplib - from email.mime.text import MIMEText - # email 用于构建邮件内容 - from email.header import Header - - # 用于构建邮件头 - # 发信方的信息：发信邮箱，QQ 邮箱授权码 - from_addr = 'jdbuymask@163.com' - password = 'alpsneahcyz123' - - # 收信方邮箱 - to_addr = mail - # 发信服务器 - smtp_server = 'smtp.163.com' - # 邮箱正文内容，第一个参数为内容，第二个参数为格式(plain 为纯文本)，第三个参数为编码 - msg = MIMEText(msgtext, 'plain', 'utf-8') - # 邮件头信息 - # msg['From'] = Header(from_addr) - msg['From'] = Header(u'from Mark<{}>'.format(from_addr), 'utf-8') - msg['To'] = Header(to_addr) - msg['Subject'] = Header('京东口罩监控','utf-8') - # 开启发信服务，这里使用的是加密传输 - server = smtplib.SMTP_SSL(host=smtp_server) - server.connect(smtp_server, 465) - # 登录发信邮箱 - server.login(from_addr, password) - # 发送邮件 - server.sendmail(from_addr, to_addr, msg.as_string()) - # 关闭服务器 - server.quit() - except Exception as e: - print(traceback.format_exc()) diff --git a/message/message.py b/message/message.py deleted file mode 100644 index db4f976..0000000 --- a/message/message.py +++ /dev/null @@ -1,30 +0,0 @@ -# -*- encoding=utf8 -*- -from message.jdEmail import sendMail -from message.wechat_ftqq import sendWechat -from log.jdlogger import logger - - -class message(object): - """消息推送类""" - - def __init__(self, messageTtpe, sc_key, mail): - if messageTtpe == '2': - if not sc_key: - raise Exception('sc_key can not be empty') - self.sc_key = sc_key - elif messageTtpe == '1': - if not mail: - raise Exception('mail can not be empty') - self.mail = mail - self.messageTtpe = messageTtpe - - def send(self, desp='', isOrder=False): - desp = str(desp) - if isOrder: - msg = desp + ' 类型口罩，已经下单了。24小时内付款' - else: - msg = desp + ' 类型口罩，下单失败了，快去抢购！' - if self.messageTtpe == '1': - sendMail(self.mail, msg) - if self.messageTtpe == '2': - sendWechat(sc_key=self.sc_key, desp=msg) diff --git a/message/wechat_ftqq.py b/message/wechat_ftqq.py deleted file mode 100644 index 78ecc49..0000000 --- a/message/wechat_ftqq.py +++ /dev/null @@ -1,31 +0,0 @@ -#!/usr/bin/env python -# -*- encoding=utf8 -*- -import datetime -import json - -import requests - -from log.jdlogger import logger - - -def sendWechat(sc_key, text='京东商品监控', desp=''): - if not text.strip(): - logger.error('Text of message is empty!') - return - - now_time = str(datetime.datetime.now()) - desp = '[{0}]'.format(now_time) if not desp else '{0} [{1}]'.format(desp, now_time) - - try: - resp = requests.get( - 'https://sc.ftqq.com/{}.send?text={}&desp={}'.format(sc_key, text, desp) - ) - resp_json = json.loads(resp.text) - if resp_json.get('errno') == 0: - logger.info('Message sent successfully [text: %s, desp: %s]', text, desp) - else: - logger.error('Fail to send message, reason: %s', resp.text) - except requests.exceptions.RequestException as req_error: - logger.error('Request error: %s', req_error) - except Exception as e: - logger.error('Fail to send message [text: %s, desp: %s]: %s', text, desp, e) -- GitLab