BIT_Mail.py

import datetime
import imaplib
from apscheduler.schedulers.blocking import BlockingScheduler
from apscheduler.triggers.cron import CronTrigger
import warnings

from Mail_Push_Core.keywds_cache import cache_delete
from Mail_Push_Core.myprint import myprint

warnings.filterwarnings("ignore")

from Mail_Push_Core.Pushing import push_config
from Mail_Push_Core.file_select_GUI import file_select_GUI
from Mail_Push_Core.monitor_config import monitor_config
from Mail_Push_Core.mail_keywds import keywds_monitor
from Mail_Push_Core.mail_summary import mail_summary

"""
User: 邮箱地址
Passwd：密码
Keywords_raw：关键词，由config文件配置
hour_keywd, minute_keywd, hour_summary, minute_summary：定时任务相关设置
Date_range：监测时间范围，单位（天）
Imap_url：IMAP服务地址
Port_raw：IMAP服务端口-字符串格式
Sendkeys：推送设置
"""


def main():
    config_filename = file_select_GUI()
    User, Passwd, Keywords_raw, hour_keywd, minute_keywd, hour_summary, minute_summary, Date_range, Imap_url, Port_raw = monitor_config(
        config_filename)
    Sendkeys = push_config(config_filename)

    Port = int(Port_raw)
    BIT_mail = imaplib.IMAP4(host=Imap_url, port=Port)
    try:
        BIT_mail.login(User, Passwd)
        myprint(datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S') + ' 验证成功，登录信息正确，定时任务已启动')
    except Exception as e:
        myprint(datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S') + ' 验证失败，请重新检查登录信息')
        myprint("ErrorType : {}, Error : {}".format(type(e).__name__, e))
    BIT_mail.logout()

    scheduler = BlockingScheduler(timezone="Asia/Shanghai")
    # Cron定时器设置方法参阅：'https://crontab.guru'
    # 添加关键词监测任务
    if Keywords_raw != '':
        trigger_Keywords = CronTrigger(hour=hour_keywd, minute=minute_keywd)
        scheduler.add_job(keywds_monitor, trigger_Keywords, max_instances=5,
                          args=[Imap_url, Port, User, Passwd, Date_range, Keywords_raw, Sendkeys])
        trigger_kc_delete = CronTrigger(hour='02', minute='03')  # 缓存清理时间，每天凌晨2点
        scheduler.add_job(cache_delete, trigger_kc_delete, max_instances=5)
    # 添加邮件汇总推送任务
    trigger_mail_summary = CronTrigger(hour=hour_summary, minute=minute_summary, second='30')
    scheduler.add_job(mail_summary, trigger_mail_summary, max_instances=5,
                      args=[Imap_url, Port, User, Passwd, Date_range, Sendkeys])
    # 启动任务
    scheduler.start()

    # 调试使用
    # keywds_monitor(Imap_url, Port, User, Passwd, Date_range, Keywords_raw, Sendkeys)
    # mail_summary(Imap_url, Port, User, Passwd, Date_range, Sendkeys)


if __name__ == '__main__':
    main()