forked from DreAymi/decodeSAXS
-
Notifications
You must be signed in to change notification settings - Fork 0
/
emailserver.py
109 lines (95 loc) · 4.6 KB
/
emailserver.py
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
# -*- coding: utf-8 -*-
import socket
import threading
import SocketServer
import json, types,string
import os, time
import numpy as np
import re
from email import encoders
from email.header import Header
from email.mime.text import MIMEText
from email.mime.base import MIMEBase
from email.mime.multipart import MIMEMultipart
from email.utils import parseaddr, formataddr
import smtplib
web_outpath=os.path.join(os.path.dirname(os.path.abspath(__file__)), 'reconstruction_web/media/result')
def _format_addr(s):
name, addr = parseaddr(s)
return formataddr(( \
Header(name, 'utf-8').encode(), \
addr.encode('utf-8') if isinstance(addr, unicode) else addr))
class ThreadedTCPRequestHandler(SocketServer.BaseRequestHandler):
def handle(self):
data = self.request.recv(1024)
jdata = json.loads(data)
job_file = jdata[0]['job_file'].encode("utf-8")
send_email = jdata[0]['send_email'].encode("utf-8")
from_addr = '[email protected]'
password = 'hehao1777'
to_addr = send_email
smtp_server = 'smtp.163.com'
msg = MIMEMultipart()
msg['From'] = _format_addr(u'decodeSAXS <%s>' % from_addr)
msg['To'] = _format_addr(u'Users <%s>' % to_addr)
msg['Subject'] = Header(u'the results of decodeSAXS', 'utf-8').encode()
# add MIMEText:
contenthtml="""<html><head><body><p>Thanks for using decodeSAXS, hope it helpful for you, any suggestions you can contact with us.</p><p>Your job ID is :""" + job_file + """</p><p>you can check your result here: </p><p><a href="http://liulab.csrc.ac.cn:10005/check/" mce_href="http://liulab.csrc.ac.cn:10005/check/">liulab.csrc.ac.cn:10005/check/</a></p></body></head></html>"""
#msg.attach(MIMEText("Thanks for using decodeSAXS, hope it helpful for you, any suggestions you can contact with us.\nYour job ID is : %s\nyou can check your result here: liulab.csrc.ac.cn:10005/check/"%job_file, 'plain'))
msg.attach(MIMEText(contenthtml, 'html'))
# add file:
filepath=web_outpath+'/'+job_file
files=os.listdir(filepath)
job_name=''
for filei in files:
if '.tar.gz' in filei:
job_name=filei
break
with open('%s/%s/%s'%(web_outpath,job_file,job_name), 'rb') as f:
att = MIMEBase('application', 'octet-stream')
att.set_payload(f.read())
att.add_header('Content-Disposition', 'attachment', filename = ('utf-8','','%s'%job_name))
encoders.encode_base64(att)
msg.attach(att)
#mime = MIMEBase('image', 'jpg', filename='0.jpg')
#mime.add_header('Content-Disposition', 'attachment', filename='0.jpg')
#mime.add_header('Content-ID', '<0>')
#mime.add_header('X-Attachment-Id', '0')
#mime.set_payload(f.read())
#encoders.encode_base64(attachfile)
#msg.attach(attachfile)
server = smtplib.SMTP(smtp_server, 25)
server.set_debuglevel(1)
server.login(from_addr, password)
try:
server.sendmail(from_addr, [to_addr], msg.as_string())
except smtplib.SMTPConnectError as e:
print '邮件发送失败，连接失败:', e.smtp_code, e.smtp_error
except smtplib.SMTPAuthenticationError as e:
print '邮件发送失败，认证错误:', e.smtp_code, e.smtp_error
except smtplib.SMTPSenderRefused as e:
print '邮件发送失败，发件人被拒绝:', e.smtp_code, e.smtp_error
except smtplib.SMTPRecipientsRefused as e:
print '邮件发送失败，收件人被拒绝:', e.smtp_code, e.smtp_error
except smtplib.SMTPDataError as e:
print '邮件发送失败，数据接收拒绝:', e.smtp_code, e.smtp_error
except smtplib.SMTPException as e:
print '邮件发送失败, ', e.message
except Exception as e:
print '邮件发送异常, ', str(e)
finally:
server.quit()
class ThreadedTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
pass
if __name__ == "__main__":
# Port 0 means to select an arbitrary unused port
HOST, PORT = "0.0.0.0", 10006
SocketServer.TCPServer.allow_reuse_address = True
server = ThreadedTCPServer((HOST, PORT), ThreadedTCPRequestHandler)
ip, port = server.server_address
server_thread = threading.Thread(target=server.serve_forever)
server_thread.daemon = True
server_thread.start()
print "Server loop running in thread:", server_thread.name
print " .... waiting to send email"
server.serve_forever()