email_server-test.ipynb

{
 "cells": [
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "Loading Preset variables...\n",
      "Success loading!\n",
      "Trying to connect to IMAP_SLL: imap.exmail.qq.com | Port ID: 993\n",
      "Trying to connect to POP3: pop.exmail.qq.com | Port ID: 110\n",
      "Login...\n",
      "try to connect to STMP...\n",
      "1 unseen email(s) here.\n",
      "--------------------------------------------------\n",
      "Telling with signature...\n",
      "Seems like no signature in this email.\n",
      "--------------------------------------------------\n",
      "Finding attachment(s)...\n",
      "No attachment in this email.\n",
      "--------------------------------------------------\n",
      "-----------Preview the email to be sent-----------\n",
      "Subject: reply: test_Fw to multiple receivers\n",
      "Date: Mon,08 Jul 2019 11:42:45 +0800\n",
      "To: 王永合<wangyonghe@biocloo.com.cn>\n",
      "Content: \n",
      "Dear customer,\n",
      "\n",
      "Thank you for your email and for bringing this to our attention! We understand that you may have received a different package or item than the one you ordered, and we apologize for any inconvenience this may have brought to you. In order to better assist you, we will need your order number as well as further information about the product you ordered and received, along with a picture.\n",
      "\n",
      "Once again, we sincerely apologize for the inconvenience this may have brought to you, and we look forward to assisting you in resolving this issue. As a thank you for your cooperation, we are providing you with a 10% off coupon on your next order with the code THANKS10. From all of us, we hope you have a wonderful rest of your day! \n",
      "--------------------------------------------------\n",
      "Success to send the email!\n",
      "['wangyonghe@biocloo.com.cn', 'wuhongsheng@biocloo.com.cn']\n",
      "-----------Preview the email to be sent-----------\n",
      "Subject: reply: test_Fw to multiple receivers\n",
      "Date: Mon,08 Jul 2019 11:42:46 +0800\n",
      "To: 王永合<wangyonghe@biocloo.com.cn>\n",
      "Content: \n",
      "\n",
      "Dear customer,\n",
      "\n",
      "Thank you for your email and for bringing this to our attention! We understand that you may have received a different package or item than the one you ordered, and we apologize for any inconvenience this may have brought to you. In order to better assist you, we will need your order number as well as further information about the product you ordered and received, along with a picture.\n",
      "\n",
      "Once again, we sincerely apologize for the inconvenience this may have brought to you, and we look forward to assisting you in resolving this issue. As a thank you for your cooperation, we are providing you with a 10% off coupon on your next order with the code THANKS10. From all of us, we hope you have a wonderful rest of your day! \n",
      "\n",
      "\n",
      "------------------ Original ------------------\n",
      "\n",
      "From: 王永合<wangyonghe@biocloo.com.cn>;\n",
      "\n",
      "Date: Mon, 8 Jul 2019 11:30:20 +0800\n",
      "\n",
      "To: 跨境AI员工<xb-aie-test@biocloo.com.cn>;\n",
      "\n",
      "Subject: test_Fw to multiple receivers\n",
      "\n",
      "\n",
      "test.\n",
      "--------------------------------------------------\n",
      "Success to forward the email!\n",
      "['wangyonghe@biocloo.com.cn', 'wuhongsheng@biocloo.com.cn']\n",
      "-----------Preview the email to be sent-----------\n",
      "Subject: reply: test_Fw to multiple receivers\n",
      "Date: Mon,08 Jul 2019 11:42:47 +0800\n",
      "To: 吴宏声<wuhongsheng@biocloo.com.cn>\n",
      "Content: \n",
      "\n",
      "Dear customer,\n",
      "\n",
      "Thank you for your email and for bringing this to our attention! We understand that you may have received a different package or item than the one you ordered, and we apologize for any inconvenience this may have brought to you. In order to better assist you, we will need your order number as well as further information about the product you ordered and received, along with a picture.\n",
      "\n",
      "Once again, we sincerely apologize for the inconvenience this may have brought to you, and we look forward to assisting you in resolving this issue. As a thank you for your cooperation, we are providing you with a 10% off coupon on your next order with the code THANKS10. From all of us, we hope you have a wonderful rest of your day! \n",
      "\n",
      "\n",
      "------------------ Original ------------------\n",
      "\n",
      "From: 王永合<wangyonghe@biocloo.com.cn>;\n",
      "\n",
      "Date: Mon, 8 Jul 2019 11:30:20 +0800\n",
      "\n",
      "To: 跨境AI员工<xb-aie-test@biocloo.com.cn>;\n",
      "\n",
      "Subject: test_Fw to multiple receivers\n",
      "\n",
      "\n",
      "test.\n",
      "--------------------------------------------------\n",
      "Success to forward the email!\n",
      "This \"unseen\" email haw been set to \"seen\"\n",
      "__________________________________________________\n",
      "Trying to connect to IMAP_SLL: imap.exmail.qq.com | Port ID: 993\n",
      "Trying to connect to POP3: pop.exmail.qq.com | Port ID: 110\n",
      "Login...\n",
      "try to connect to STMP...\n",
      "No new unseen mail here. Continue to scan after 20(s)\n",
      "__________________________________________________\n",
      "Trying to connect to IMAP_SLL: imap.exmail.qq.com | Port ID: 993\n",
      "Trying to connect to POP3: pop.exmail.qq.com | Port ID: 110\n",
      "Login...\n",
      "try to connect to STMP...\n",
      "No new unseen mail here. Continue to scan after 20(s)\n",
      "__________________________________________________\n",
      "Trying to connect to IMAP_SLL: imap.exmail.qq.com | Port ID: 993\n",
      "Trying to connect to POP3: pop.exmail.qq.com | Port ID: 110\n",
      "Login...\n",
      "try to connect to STMP...\n",
      "No new unseen mail here. Continue to scan after 20(s)\n",
      "__________________________________________________\n",
      "Trying to connect to IMAP_SLL: imap.exmail.qq.com | Port ID: 993\n",
      "Trying to connect to POP3: pop.exmail.qq.com | Port ID: 110\n",
      "Login...\n",
      "try to connect to STMP...\n",
      "No new unseen mail here. Continue to scan after 20(s)\n",
      "__________________________________________________\n",
      "Trying to connect to IMAP_SLL: imap.exmail.qq.com | Port ID: 993\n",
      "Trying to connect to POP3: pop.exmail.qq.com | Port ID: 110\n",
      "Login...\n",
      "try to connect to STMP...\n",
      "No new unseen mail here. Continue to scan after 20(s)\n",
      "__________________________________________________\n"
     ]
    }
   ],
   "source": [
    "# !/usr/bin/python\n",
    "# -*- coding:UTF-8 -*-\n",
    "from email.parser import Parser\n",
    "from email.header import decode_header\n",
    "import imaplib, string, email\n",
    "import os\n",
    "import poplib\n",
    "from urllib import parse\n",
    "import requests\n",
    "import smtplib\n",
    "from email.mime.text import MIMEText\n",
    "from email.header import Header\n",
    "import HTMLParser\n",
    "import time\n",
    "import sys\n",
    "import re\n",
    "\n",
    "def validateTitle(title):\n",
    "    rstr = r\"[\\/\\\\\\:\\*\\?\\\"\\<\\>\\|]\"  # 非法字符，包含: '/ \\ : * ? \" < > |'\n",
    "    new_title = re.sub(rstr, \"_\", title)  # 替换为下划线\n",
    "    return new_title\n",
    "\n",
    "def mkdir(path):\n",
    "#     去除首位空格\n",
    "    path=path.strip()\n",
    "#     去除尾部 \\ 符号\n",
    "    path=path.rstrip(\"\\\\\")\n",
    "#     判断路径是否存在\n",
    "    isExists=os.path.exists(path)\n",
    "#     如果不存在则创建目录\n",
    "    if not isExists:\n",
    "        os.makedirs(path)  \n",
    "        print(path+' Success to build the path!')\n",
    "        return True\n",
    "#     如果目录存在则不创建，并提示目录已存在\n",
    "    else:\n",
    "        print(path+' The Dir is exsist!')\n",
    "        return False\n",
    "\n",
    "# 邮件的Subject或者Email中包含的名字都是经过编码后的str，要正常显示，就必须decode\n",
    "def decode_str(s):\n",
    "    value, charset = decode_header(s)[0]\n",
    "    # decode_header()返回一个list，因为像Cc、Bcc这样的字段可能包含多个邮件地址，所以解析出来的会有多个元素。上面的代码我们偷了个懒，只取了第一个元素。\n",
    "    if charset:\n",
    "        value = value.decode(charset)\n",
    "#         value = value.decode('gbk')\n",
    "    return value\n",
    "\n",
    "# 判断是否有附件，有则存储在指定路径下（默认为当前文件夹下）\n",
    "def find_atchmt(msg, sender, Dirpath=sys.path[0]+'/'+'tmp_attchment'):\n",
    "    flag = 0# 判断是否有附件\n",
    "    for par in msg.walk():\n",
    "        name = par.get_filename()\n",
    "        if not name is None:\n",
    "            name = decode_str(name)\n",
    "#             使附件名称规范化，防止无法保存\n",
    "            name = validateTitle(name)\n",
    "            sender = validateTitle(sender)\n",
    "            try:\n",
    "                mkdir(Dirpath)\n",
    "            except Exception as e:\n",
    "                print('Fail to make dir: %s' %e)\n",
    "                print('-'*50)\n",
    "                return False\n",
    "            fpath = Dirpath+'/'+sender+'_'+name\n",
    "            data = par.get_payload(decode=True)\n",
    "            try:\n",
    "                f = open(fpath, 'wb')# 注意一定要用wb来打开文件，因为附件一般都是二进制文件\n",
    "                f.write(data)\n",
    "                f.close()\n",
    "                print('save to file %s succeed'%fpath)\n",
    "                print('-'*50)\n",
    "                flag = 1\n",
    "            except Exception as e:\n",
    "                print('open file name error: %s' %e)\n",
    "                print('-'*50)\n",
    "                return False\n",
    "    if flag == 0:        \n",
    "        print('No attachment in this email.')\n",
    "        print('-'*50)\n",
    "        return None\n",
    "    else:\n",
    "        return True\n",
    "\n",
    "# 解析邮件的body\n",
    "def print_info(msg,indent=0):\n",
    "#     print(type(msg), msg)\n",
    "    if indent ==0:\n",
    "        for header in [\"From\", \"Date\", \"To\", \"Subject\", \"name\"]:\n",
    "#             print(header)\n",
    "            value = msg.get(header,\"\")\n",
    "#             print(value, type(value))\n",
    "#             if header == \"Subject\" and value is None:\n",
    "#                 continue\n",
    "            if value or (header == \"Subject\" and value is \"\"):\n",
    "                if header == \"From\":\n",
    "                    sender = decode_header(value)\n",
    "                    try:\n",
    "                        tmp = []\n",
    "                        for i in sender:\n",
    "                            tmp.append(i[0])\n",
    "#                         print('tmp:', tmp)\n",
    "                        lst_tmp = []\n",
    "                        for i in tmp:\n",
    "    #                         print(i)\n",
    "                            try:\n",
    "                                lst_tmp.append(i.decode('gbk'))\n",
    "                            except Exception as e:\n",
    "#                                 print('Fail to decode the name of the sender')\n",
    "                                lst_tmp.append(i.decode())\n",
    "                        sender = \"\".join(lst_tmp)\n",
    "                        sender = sender.replace(\"\\\"\", \"\")\n",
    "                        bgn = sender.find(\"<\", 0)\n",
    "                        if bgn != -1:\n",
    "                            sender = sender[:bgn-1]+sender[bgn:]\n",
    "#                             print(sender)\n",
    "                    except Exception as e:\n",
    "                        print('No need to transform')\n",
    "                        sender = sender[0][0]\n",
    "                if header == \"Date\":\n",
    "                    date = decode_header(value)[0][0]\n",
    "#                     print('Date: ', Date[0])\n",
    "                if header == \"Subject\":\n",
    "                    if not value is \"\":\n",
    "                        value = decode_str(value)\n",
    "#                         print('Subject: ', value)\n",
    "#                     if value == \"邮件主题名\" :#取18封邮件中需要的邮件\n",
    "                    else:\n",
    "                        print('The Subject is None!')\n",
    "                    subject = value\n",
    "                    for par in msg.walk():\n",
    "#                         name = par.get_filename()\n",
    "#                         if not name is None:\n",
    "#                             print('get file! Name is %s' %name)\n",
    "#                         else:\n",
    "#                             print('no file in this email!')\n",
    "#                         print('name_1: ', name_1)\n",
    "                        if not par.is_multipart(): # 这里要判断是否是multipart，是的话，里面的数据是无用的，至于为什么可以了解mime相关知识。\n",
    "                            content_type = par.get_content_type()\n",
    "#                             print(content_type)\n",
    "\n",
    "                            if content_type == 'text/plain' or content_type == 'text/html':\n",
    "#                                 print(par,type(par))\n",
    "                                content = par.get_payload(decode=True)\n",
    "                                try:\n",
    "                                    content = content.decode('utf-8')\n",
    "                                except Exception as e:\n",
    "                                    print('Fail to use \\'utf-8\\' to decode! use \\'gbk\\' to try again...')\n",
    "                                    content = content.decode('gbk')\n",
    "                                if content_type == 'text/html':\n",
    "                                    print('Error! This is a html email, which isn\\'t accepted for the moment.')\n",
    "#                                     content = HTMLParser(content)\n",
    "                                    return None, None, None, None\n",
    "                                return sender, date, subject, content\n",
    "\n",
    "# 获取邮件的有效信息\n",
    "def getMail(host, imap, user, passwd, pop_port=993, imap_port=110):\n",
    "    contents = []\n",
    "    senders = []\n",
    "    subjects = []\n",
    "    \n",
    "    try:\n",
    "        print('Trying to connect to IMAP_SLL: %s | Port ID: %s' %(imap, imap_port))\n",
    "        M = imaplib.IMAP4_SSL(imap, imap_port)\n",
    "    except Exception as e:\n",
    "        print('Failed to access: %s' %e)\n",
    "        return False\n",
    "#         sys.exit()\n",
    "    try:\n",
    "        print('Trying to connect to POP3: %s | Port ID: %s' %(host, pop_port))\n",
    "        p = poplib.POP3(host, pop_port)\n",
    "    except Exception as e:\n",
    "        print('Failed to access: %s' %e)\n",
    "        return False\n",
    "#         sys.exit()\n",
    "    try:\n",
    "        print('Login...')\n",
    "        p.user(user)\n",
    "        p.pass_(passwd)\n",
    "        M.login(user,passwd)\n",
    "#     except (poplib.error_proto,e):\n",
    "    except Exception as e:\n",
    "        print (\"Login failed: %s\" %e)\n",
    "        return False\n",
    "#         sys.exit()\n",
    "    try:\n",
    "        print('try to connect to STMP...')\n",
    "        smtpObj = smtplib.SMTP()\n",
    "        smtpObj.connect(SMTP_host, SMTP_port)\n",
    "        smtpObj.login(user, passwd)\n",
    "    except Exception as e:\n",
    "        print('Failed to access: %s' %e)\n",
    "        return False\n",
    "#     print('Success to connect!')\n",
    "    \n",
    "    try:\n",
    "#         获取未读邮件的UID\n",
    "        try:\n",
    "            M.select('INBOX', False)\n",
    "            _, data = M.search(None, 'unseen')\n",
    "            lst = data[0].decode(encoding='utf-8').split(\" \")# 对btye编码进行解码，获取str形式的UID\n",
    "#             print(lst)\n",
    "            lst = list(map(str, lst))# 将UID转换为list\n",
    "            if data[0] == b'':\n",
    "                print('No new unseen mail here. Continue to scan after %d(s)' %wait_time)\n",
    "                print('_'*50)\n",
    "                return None, None, None\n",
    "            print('%d unseen email(s) here.' %int(len(lst)))\n",
    "            print('-'*50)\n",
    "        except Exception as e:\n",
    "            print('Unknown error: %d' %e)\n",
    "            return False\n",
    "#             sys.exit()\n",
    "#         lst = [0,1]\n",
    "        for index in lst:\n",
    "#             index = str(index)\n",
    "            typ, data = M.fetch(index, '(RFC822)')\n",
    "#             print('typ: ', typ, data)\n",
    "            try:\n",
    "                text = data[0][1].decode('utf-8')\n",
    "            except Exception as e:\n",
    "                print('Failed to decode by \\'utf-8\\', try to decode by \\'gbk\\'...')\n",
    "                try:\n",
    "                    text = data[0][1].decode('gbk')\n",
    "                except Exception as e:\n",
    "                    print('Failed to decode: %s' %e)\n",
    "                    sys.exit()\n",
    "#             print('text: ', text, type(text))\n",
    "            msg = email.message_from_string(text)\n",
    "#             print('Try to get info of this email...')\n",
    "            sender, date,  subject, ori_content = print_info(msg)# 获取发件人，主题和正文文本\n",
    "            if sender is None:\n",
    "                continue\n",
    "            content = del_Fw(ori_content)\n",
    "#             print(content)\n",
    "            print('Telling with signature...')\n",
    "            content = del_signature(content)\n",
    "            print('Finding attachment(s)...')\n",
    "            find_atchmt(msg, sender)\n",
    "#             print('Success!')\n",
    "            try:\n",
    "#             if not senders is None:\n",
    "                query = content\n",
    "                body = {\"userId\": userId, \"botId\": botId, \"query\": query, \"type\": _type}\n",
    "#                 print('body: ', body)\n",
    "                r = requests.post(URL, json=body)\n",
    "            #     print(r.text)\n",
    "                if r.status_code == 200:\n",
    "                    reply_bgn = r.text.find('\\\"reply\\\": ',0)\n",
    "                    reply_end = len(r.text)-2\n",
    "                    reply = r.text[reply_bgn+10:reply_end].encode('utf-8').decode('unicode_escape')\n",
    "                else:\n",
    "                    print('Failed to request API: ', r)\n",
    "                    return False\n",
    "            except Exception as e:\n",
    "                print('Fail to request the API: %s' %e)\n",
    "#             尝试发送邮件\n",
    "            try:\n",
    "                from_addr, to_addr, message = send_email(username, sender, subject, reply)\n",
    "                smtpObj.sendmail(from_addr, to_addr, message)\n",
    "                print(\"Success to send the email!\")\n",
    "            except smtplib.SMTPException:\n",
    "                print('Error! Fail to send the email: %s' %e)\n",
    "                return False\n",
    "#             尝试转发邮件\n",
    "            try:\n",
    "                to = sender_name+'<%s>' % username\n",
    "                Fw_content = '''\n",
    "%s\\r\\n\\r\\n\n",
    "------------------ Original ------------------\\r\\n\n",
    "From: %s;\\r\\n\n",
    "Date: %s\\r\\n\n",
    "To: %s;\\r\\n\n",
    "Subject: %s\\r\\n\\r\\n\n",
    "%s''' %(reply, sender, date, to, subject, ori_content)\n",
    "#                 如果需要转发给多人，则循环多次进行发送\n",
    "                if isinstance(Fw_email, list):\n",
    "                    for i in range(len(Fw_email)):\n",
    "                        print(Fw_email)\n",
    "                        Fw_addr = Fw_name[i]+'<%s>' %Fw_email[i]\n",
    "                        from_addr, to_addr, message = send_email(username, Fw_addr, subject, Fw_content)\n",
    "                        smtpObj.sendmail(from_addr, to_addr, message)\n",
    "                        print(\"Success to forward the email!\")\n",
    "                else:\n",
    "                    Fw_addr = Fw_name[i]+'<%s>' %Fw_email[i]\n",
    "                    from_addr, to_addr, message = send_email(username, Fw_addr, subject, Fw_content)\n",
    "                    smtpObj.sendmail(from_addr, to_addr, message)\n",
    "                    print(\"Success to forward the email!\")\n",
    "            except smtplib.SMTPException:\n",
    "                print('Error! Fail to forward the email: %s' %e)\n",
    "                return False\n",
    "            try:\n",
    "                M.store(str(index), '+FLAGS', '(\\\\Seen)')\n",
    "                print('This \\\"unseen\\\" email haw been set to \\\"seen\\\"')\n",
    "                print('_'*50)\n",
    "            except Exception as e:\n",
    "                print(e)\n",
    "                print('Unknown Error! Can\\'t set this mail to the status of \\'Seen\\'\\nTo prevent users from receiving repeated replies, we skip this mail.')\n",
    "#                 senders.pop()\n",
    "#                 contents.pop()\n",
    "        return True\n",
    "            \n",
    "    except Exception as e:\n",
    "        print ('Error: %s' % e)\n",
    "        return False\n",
    "\n",
    "# 去签名\n",
    "def del_signature(content):\n",
    "#     读取常见的正文与签名分界处格式\n",
    "    try:\n",
    "        sig_format = [line.strip() for line in open(\"email_server_signature-test.ini\",encoding='gb18030',errors='ignore').readlines()]\n",
    "    except Exception as e:\n",
    "        print('Can\\'t find \\\"email_server_signature.ini\\\" here so we can\\'t tell with the signature.')\n",
    "        return content\n",
    "#     查找最靠近文末的疑似签名处\n",
    "    max_bgn = -1\n",
    "    bgn = 0\n",
    "    for elmt in sig_format:\n",
    "        while bgn != -1:\n",
    "            elmt = elmt.encode('utf-8').decode('unicode_escape')\n",
    "            elmt_len = len(elmt.split(\"\\r\\n\"))\n",
    "            bgn = content.find(elmt, bgn)# 对转义格式进行重解码\n",
    "            if not bgn == -1:\n",
    "                if bgn > max_bgn:\n",
    "                    max_bgn = bgn\n",
    "                bgn += 1\n",
    "        bgn = 0\n",
    "    if max_bgn == -1:\n",
    "        print('Seems like no signature in this email.')\n",
    "    else:\n",
    "        sig = content[max_bgn:]\n",
    "        sig_lst = sig.split(\"\\r\\n\")\n",
    "        max_len = 0\n",
    "        flag = 0# 判断是否为签名的标识\n",
    "#         获取疑似签名文本中最长的字符数\n",
    "        for line in sig_lst:\n",
    "            if len(line)>max_len:\n",
    "                max_len = len(line)\n",
    "#         最长字符串小于指定阈值，则标识+1\n",
    "        if max_len < 35 or len(sig_lst) >= elmt_len+3:\n",
    "            print('The content below seems like a signature:\\n%s' % content[max_bgn:])\n",
    "            content = content[:max_bgn]\n",
    "        else:\n",
    "            print('Seems like no signature in this email.')\n",
    "    print('-'*50)    \n",
    "    return content\n",
    "\n",
    "# 删除正文中的转发邮件的Title\n",
    "def del_Fw(content):\n",
    "    bgn = 0\n",
    "    max_bgn = -1\n",
    "#     查找最后一处转发邮件的Title\n",
    "    while bgn != -1:\n",
    "        bgn = content.find('------------------ Original ------------------', bgn)\n",
    "#         保存最后一处Title\n",
    "        if bgn > max_bgn:\n",
    "            max_bgn = bgn\n",
    "#         找到字符串后，若不+1则会死循环\n",
    "        if bgn != -1:\n",
    "            bgn += 1\n",
    "    if max_bgn == -1:\n",
    "        return content\n",
    "    else:\n",
    "        print('This is a Fw email.')\n",
    "        bgn = content.find('Subject:', max_bgn)\n",
    "        bgn = content.find('\\n', bgn)\n",
    "        print('This content seems like the header of the Fw email:\\n%s' %content[:bgn+8])\n",
    "        content = content[bgn+8:]\n",
    "        print('-'*50)\n",
    "        return content\n",
    "\n",
    "# 根据给定邮箱和和指定内容，发送邮件\n",
    "def send_email(from_addr, to_addr, subject, msg):\n",
    "    message = MIMEText(msg, 'plain', 'utf-8')# 文本\n",
    "    message['From'] = Header((sender_name+'<%s>') %from_addr, 'utf-8')# 发送方邮箱\n",
    "    message['Sender'] = Header(sender_name, 'utf-8')# 发送者\n",
    "    message['To'] =  Header(to_addr, 'utf-8')# 接收方邮箱\n",
    "#         message['From'] = sender_name# 发送方邮箱\n",
    "#         message['To'] =  to_addrs[i]# 接收方邮箱\n",
    "    Date = time.strftime(\"%a,%d %b %Y %H:%M:%S %z\")\n",
    "    message['Date'] = Date\n",
    "    subject = 'reply: '+subject\n",
    "    message['Subject'] = Header(subject, 'utf-8')\n",
    "    print('-'*11+'Preview the email to be sent'+'-'*11)\n",
    "    print('Subject: %s\\nDate: %s\\nTo: %s\\nContent: \\n%s' % (subject, Date, to_addr, msg))\n",
    "    print('-'*50)\n",
    "    return from_addr, to_addr, message.as_string()\n",
    "\n",
    "\n",
    "if __name__ == '__main__':\n",
    "#     加载预设变量\n",
    "    print('Loading Preset variables...')\n",
    "    ini_param_tmp = [line.strip() for line in open(\"email_server-test.ini\",encoding='gb18030',errors='ignore').readlines()]\n",
    "    ini_param = []\n",
    "    for line in ini_param_tmp:\n",
    "        line = line.replace(\"\\t\", \"\").\\\n",
    "                    replace(\"=\", \"\").replace(\"：\", \"\")\n",
    "        ini_param.append(line)\n",
    "#     print(ini_param)\n",
    "    pop_host = str(ini_param[1][6:])# pop服务器\n",
    "    pop_port = int(ini_param[2][8:])# pop端口号\n",
    "    imap_host = str(ini_param[3][7:])# imap服务器\n",
    "    imap_port = int(ini_param[4][9:])# imap端口号\n",
    "    SMTP_host = str(ini_param[5][7:])# 发送邮件服务器\n",
    "    SMTP_port = int(ini_param[6][7:])# 发送邮件端口号\n",
    "    username = str(ini_param[7][6:])# 邮箱用户名\n",
    "    sender_name = str(ini_param[8][5:])# 发送者名称\n",
    "    password = str(ini_param[9][5:])# 邮箱密码\n",
    "    Fw_email = str(ini_param[10][5:]).split(',')\n",
    "    Fw_name = str(ini_param[11][5:]).split(',')\n",
    "    URL = str(ini_param[14][7:])# Email_service接口\n",
    "    userId = str(ini_param[15][6:])# 用户ID 参考Email_service接口文档\n",
    "    botId = str(ini_param[16][5:])# 参考Email_service接口文档\n",
    "    _type = str(ini_param[17][5:])# 参考Email_service接口文档\n",
    "    wait_time = int(ini_param[20][7:])# 检测间隔时间\n",
    "    print('Success loading!')\n",
    "\n",
    "#     定期循环检查新邮件\n",
    "    while 1:\n",
    "        status = getMail(pop_host, imap_host, username, password, pop_port, imap_port)\n",
    "#         print(senders, contents)\n",
    "        time.sleep(wait_time)"
   ]
  }
 ],
 "metadata": {
  "kernelspec": {
   "display_name": "Python 3",
   "language": "python",
   "name": "python3"
  },
  "language_info": {
   "codemirror_mode": {
    "name": "ipython",
    "version": 3
   },
   "file_extension": ".py",
   "mimetype": "text/x-python",
   "name": "python",
   "nbconvert_exporter": "python",
   "pygments_lexer": "ipython3",
   "version": "3.7.3"
  }
 },
 "nbformat": 4,
 "nbformat_minor": 2
}