namespace java com.imooc.thrift.demo # 希望生成的语言及生成包的名字
namespace py thrift.demo # 语言二

# 声明类名及接口
service DemoService { 
    void sayHello(1:string name); # 需要指定参数index
}

namespace java com.imooc.thrift.message
namespace py message.api

service MessageService {
    bool SendMobilMessage(1:string mobile, 2:string message);
    bool SendEmailMessage(1:string email, 2:string message);
}

#! /usr/bin/env python
# -*- coding: utf-8 -*-

from message.api import MessageService
# from message.api import ttypes # 自定义类型会用到这个东东
from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
from thrift.server import TServer

import smtplib
import mail_sender

__HOST = 'localhost'
__PORT = 9090

class MessageServiceHandler(object):
    def SendMobilMessage(self, mobile, message):
        print "send mobil message"
        return True

    def SendEmailMessage(self, email, message):

        try:
            mail_sender.postEmail(email, message)
            print "send mail success"
            return True
        except smtplib.SMTPException, ex:
            print "send mail failed"
            print ex
            return False      

if __name__ == '__main__':
    handler = MessageServiceHandler()
    processor = MessageService.Processor(handler)
    transport = TSocket.TServerSocket(__HOST, __PORT)
    tfactory = TTransport.TBufferedTransportFactory()
    pfactory = TBinaryProtocol.TBinaryProtocolFactory()

    rpcServer = TServer.TSimpleServer(processor, transport, tfactory, pfactory)

    print('Starting the rpc server at', __HOST, ':', __PORT)
    rpcServer.serve()
    print "python thrift server exit"

#! /usr/bin/env python
# -*- coding: utf-8 -*-

from email.header import Header
from email.mime.text import MIMEText
from email.utils import formataddr
import smtplib

# 用户信息
from_addr = 'xxx@xxx.com'
# 腾讯企业邮箱必须使用授权码进行第三方登陆 获取方式参考：https://jingyan.baidu.com/article/d8072ac4b697cbec95cefdf3.html
password = '*********'
smtp_server = 'smtp.exmail.qq.com'  # 腾讯服务器地址

def postEmail(to, message):
    to_addr = to #'xxx@xxx.com'

    # 内容初始化，定义内容格式（普通文本，html）
    msg = MIMEText(message, 'plain', 'utf-8')

    # 发件人收件人信息格式化 ，可防空
    # 固定用法不必纠结，我使用lambda表达式进行简单封装方便调用

    def lam_format_addr(name, addr): return formataddr(
        (Header(name, 'utf-8').encode(), addr))

    # 传入昵称和邮件地址
    msg['From'] = lam_format_addr('', from_addr)  # 发件人昵称，腾讯邮箱可略
    msg['To'] = lam_format_addr('', to_addr)  # 收件人昵称（服务商会自动替换成用户名），腾讯邮箱可略

    # 邮件标题
    msg['Subject'] = Header('来自服务器的邮件', 'utf-8').encode()  # 腾讯邮箱略过会导致邮件被屏蔽

    # 服务端配置，账密登陆
    server = smtplib.SMTP(smtp_server, 25)

    # 腾讯邮箱支持SSL(不强制)， 不支持TLS。
    # server = smtplib.SMTP_SSL(smtp_server, 465) # 按需开启
    # 调试模式，打印日志
    # server.set_debuglevel(1) # 按需开启

    # 登陆服务器
    server.login(from_addr, password)

    # 发送邮件及退出
    server.sendmail(from_addr, [to_addr], msg.as_string())  # 发送地址需与登陆的邮箱一致
    server.quit()


if __name__ == '__main__':
    postEmail('xxx@xxx.com', '这是一封测试邮件')
    print "test mail send to azen@daker.wang"

#! /usr/bin/env python
# coding: utf-8

from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
from message.api.MessageService import Client

__HOST = 'localhost'
__PORT = 9090

tsocket = TSocket.TSocket(__HOST, __PORT)
transport = TTransport.TBufferedTransport(tsocket)
protocol = TBinaryProtocol.TBinaryProtocol(transport)
client = Client(protocol)

transport.open()

print(client.SendEmailMessage("x@xxx.com","just test"))