#coding:utf-8
import tornado.ioloop
import tornado.web
import json
import pymysql
import urllib
import urllib.request

class GetVoucherHandler(tornado.web.RequestHandler):

    def post(self, *args, **kwargs):
        #解析传过来的数据：订单id和车型指示（0代表普通，1代表动车高铁）
        data = json.loads(self.request.body)
        orderId = data["orderId"]
        type = data["type"]
        #根据订单id查询是否存在对应的凭证
        queryVoucher = self.fetchVoucherByOrderId(orderId)

        if(queryVoucher == None):
            #根据订单id请求订单的详细信息
            orderResult = self.queryOrderByIdAndType(orderId,type)
            order = orderResult['order']

            # jsonStr = json.dumps(orderResult)
            # self.write(jsonStr)

            #往voucher表中插入报销凭证
            config = {
                'host':'ts-voucher-mysql',
                'port':3306,
                'user':'root',
                'password':'<PASSWORD>',
                'db':'voucherservice'
            }
            conn = pymysql.connect(**config)
            cur = conn.cursor()
            #插入语句
            sql = 'INSERT INTO voucher (order_id,travelDate,travelTime,contactName,trainNumber,seatClass,seatNumber,startStation,destStation,price)VALUES(%s, %s, %s, %s, %s, %s, %s, %s, %s, %s)'
            try:
                cur.execute(sql,(order['id'],order['travelDate'],order['travelTime'],order['contactsName'],order['trainNumber'],order['seatClass'],order['seatNumber'],order['from'],order['to'],order['price']))
                conn.commit()
            finally:
                conn.close()
            #再次查询，可以获得刚刚插入的凭证信息
            self.write(self.fetchVoucherByOrderId(orderId))
        else:
            self.write(queryVoucher)

    def queryOrderByIdAndType(self,orderId,type):
        type = int(type)
        #普通列车
        if(type == 0):
            url='http://ts-order-other-service:12032/order/getById'
        else:
            url='http://ts-order-service:12031/order/getById'
        values ={'orderId':orderId}
        jdata = json.dumps(values).encode(encoding='utf-8')# 对数据进行JSON格式化编码
        header_dict = {'User-Agent': 'Mozilla/5.0 (Windows NT 6.1; Trident/7.0; rv:11.0) like Gecko',"Content-Type": "application/json"}
        req = urllib.request.Request(url=url,data=jdata,headers=header_dict)# 生成页面请求的完整数据
        response = urllib.request.urlopen(req)# 发送页面请求
        return json.loads(response.read())# 获取服务器返回的页面信息

    def fetchVoucherByOrderId(self,orderId):
        #从voucher表中查询orderId对应的报销凭证
        config = {
            'host':'ts-voucher-mysql',
            'port':3306,
            'user':'root',
            'password':'<PASSWORD>',
            'db':'voucherservice'
        }
        conn = pymysql.connect(**config)
        cur = conn.cursor()
        #查询语句
        sql = 'SELECT * FROM voucher where order_id = %s'
        try:
            cur.execute(sql,(orderId))
            voucher = cur.fetchone()
            conn.commit()
            #构建返回数据
            if(cur.rowcount < 1):
                return None
            else:
                voucherData = {}
                voucherData['voucher_id'] = voucher[0]
                voucherData['order_id'] = voucher[1]
                voucherData['travelDate'] = voucher[2]
                voucherData['contactName'] = voucher[4]
                voucherData['train_number'] = voucher[5]
                voucherData['seat_number'] = voucher[7]
                voucherData['start_station'] = voucher[8]
                voucherData['dest_station'] = voucher[9]
                voucherData['price'] = voucher[10]
                jsonStr = json.dumps(voucherData)
                print(jsonStr)
                return jsonStr
        finally:
            conn.close()

def make_app():
    return tornado.web.Application([
        (r"/getVoucher", GetVoucherHandler)
    ])

def initDatabase():
    config = {
        'host':'ts-voucher-mysql',
        'port':3306,
        'user':'root',
        'password':'<PASSWORD>'
    }
    # 创建连接
    connect = pymysql.connect(**config)
    cur = connect.cursor()
    #创建db
    sql = "CREATE SCHEMA IF NOT EXISTS voucherservice;"
    try:
        cur.execute(sql)
        connect.commit()
    finally:
        pass

    #Use the database
    sql = "use voucherservice;"
    try:
        cur.execute(sql)
        connect.commit()
    finally:
        pass

    #Create the table
    sql = """
    CREATE TABLE if not exists voucherservice.voucher (
    voucher_id INT NOT NULL AUTO_INCREMENT,
    order_id VARCHAR(1024) NOT NULL,
    travelDate VARCHAR(1024) NOT NULL,
    travelTime VARCHAR(1024) NOT NULL,
    contactName VARCHAR(1024) NOT NULL,
    trainNumber VARCHAR(1024) NOT NULL,
    seatClass INT NOT NULL,
    seatNumber VARCHAR(1024) NOT NULL,
    startStation VARCHAR(1024) NOT NULL,
    destStation VARCHAR(1024) NOT NULL,
    price FLOAT NOT NULL,
    PRIMARY KEY (voucher_id));"""
    try:
        cur.execute(sql)
        connect.commit()
    finally:
        connect.close()

if __name__ == "__main__":
    #创建数据库和表格
    initDatabase()
    app = make_app()
    app.listen(16101)
    tornado.ioloop.IOLoop.current().start()


    
#coding:utf-8
import tornado.ioloop
import tornado.web
import json
import pymysql
import urllib
import urllib.request

class GetVoucherHandler(tornado.web.RequestHandler):

    def post(self, *args, **kwargs):
        #解析传过来的数据：订单id和车型指示（0代表普通，1代表动车高铁）
        data = json.loads(self.request.body)
        orderId = data["orderId"]
        type = data["type"]
        #根据订单id查询是否存在对应的凭证
        queryVoucher = self.fetchVoucherByOrderId(orderId)

        if(queryVoucher == None):
            #根据订单id请求订单的详细信息
            orderResult = self.queryOrderByIdAndType(orderId,type)
            order = orderResult['order']

            # jsonStr = json.dumps(orderResult)
            # self.write(jsonStr)

            #往voucher表中插入报销凭证
            config = {
                'host':'ts-voucher-mysql',
                'port':3306,
                'user':'root',
                'password':'<PASSWORD>',
                'db':'voucherservice'
            }
            conn = pymysql.connect(**config)
            cur = conn.cursor()
            #插入语句
            sql = 'INSERT INTO voucher (order_id,travelDate,travelTime,contactName,trainNumber,seatClass,seatNumber,startStation,destStation,price)VALUES(%s, %s, %s, %s, %s, %s, %s, %s, %s, %s)'
            try:
                cur.execute(sql,(order['id'],order['travelDate'],order['travelTime'],order['contactsName'],order['trainNumber'],order['seatClass'],order['seatNumber'],order['from'],order['to'],order['price']))
                conn.commit()
            finally:
                conn.close()
            #再次查询，可以获得刚刚插入的凭证信息
            self.write(self.fetchVoucherByOrderId(orderId))
        else:
            self.write(queryVoucher)

    def queryOrderByIdAndType(self,orderId,type):
        type = int(type)
        #普通列车
        if(type == 0):
            url='http://ts-order-other-service:12032/order/getById'
        else:
            url='http://ts-order-service:12031/order/getById'
        values ={'orderId':orderId}
        jdata = json.dumps(values).encode(encoding='utf-8')# 对数据进行JSON格式化编码
        header_dict = {'User-Agent': 'Mozilla/5.0 (Windows NT 6.1; Trident/7.0; rv:11.0) like Gecko',"Content-Type": "application/json"}
        req = urllib.request.Request(url=url,data=jdata,headers=header_dict)# 生成页面请求的完整数据
        response = urllib.request.urlopen(req)# 发送页面请求
        return json.loads(response.read())# 获取服务器返回的页面信息

    def fetchVoucherByOrderId(self,orderId):
        #从voucher表中查询orderId对应的报销凭证
        config = {
            'host':'ts-voucher-mysql',
            'port':3306,
            'user':'root',
            'password':'<PASSWORD>',
            'db':'voucherservice'
        }
        conn = pymysql.connect(**config)
        cur = conn.cursor()
        #查询语句
        sql = 'SELECT * FROM voucher where order_id = %s'
        try:
            cur.execute(sql,(orderId))
            voucher = cur.fetchone()
            conn.commit()
            #构建返回数据
            if(cur.rowcount < 1):
                return None
            else:
                voucherData = {}
                voucherData['voucher_id'] = voucher[0]
                voucherData['order_id'] = voucher[1]
                voucherData['travelDate'] = voucher[2]
                voucherData['contactName'] = voucher[4]
                voucherData['train_number'] = voucher[5]
                voucherData['seat_number'] = voucher[7]
                voucherData['start_station'] = voucher[8]
                voucherData['dest_station'] = voucher[9]
                voucherData['price'] = voucher[10]
                jsonStr = json.dumps(voucherData)
                print(jsonStr)
                return jsonStr
        finally:
            conn.close()

def make_app():
    return tornado.web.Application([
        (r"/getVoucher", GetVoucherHandler)
    ])

def initDatabase():
    config = {
        'host':'ts-voucher-mysql',
        'port':3306,
        'user':'root',
        'password':'<PASSWORD>'
    }
    # 创建连接
    connect = pymysql.connect(**config)
    cur = connect.cursor()
    #创建db
    sql = "CREATE SCHEMA IF NOT EXISTS voucherservice;"
    try:
        cur.execute(sql)
        connect.commit()
    finally:
        pass

    #Use the database
    sql = "use voucherservice;"
    try:
        cur.execute(sql)
        connect.commit()
    finally:
        pass

    #Create the table
    sql = """
    CREATE TABLE if not exists voucherservice.voucher (
    voucher_id INT NOT NULL AUTO_INCREMENT,
    order_id VARCHAR(1024) NOT NULL,
    travelDate VARCHAR(1024) NOT NULL,
    travelTime VARCHAR(1024) NOT NULL,
    contactName VARCHAR(1024) NOT NULL,
    trainNumber VARCHAR(1024) NOT NULL,
    seatClass INT NOT NULL,
    seatNumber VARCHAR(1024) NOT NULL,
    startStation VARCHAR(1024) NOT NULL,
    destStation VARCHAR(1024) NOT NULL,
    price FLOAT NOT NULL,
    PRIMARY KEY (voucher_id));"""
    try:
        cur.execute(sql)
        connect.commit()
    finally:
        connect.close()

if __name__ == "__main__":
    #创建数据库和表格
    initDatabase()
    app = make_app()
    app.listen(16101)
    tornado.ioloop.IOLoop.current().start()


    
#coding:utf-8 #解析传过来的数据：订单id和车型指示（0代表普通，1代表动车高铁） #根据订单id查询是否存在对应的凭证 #根据订单id请求订单的详细信息 # jsonStr = json.dumps(orderResult) # self.write(jsonStr) #往voucher表中插入报销凭证 #插入语句 #再次查询，可以获得刚刚插入的凭证信息 #普通列车 # 对数据进行JSON格式化编码 # 生成页面请求的完整数据 # 发送页面请求 # 获取服务器返回的页面信息 #从voucher表中查询orderId对应的报销凭证 #查询语句 #构建返回数据 # 创建连接 #创建db #Use the database #Create the table CREATE TABLE if not exists voucherservice.voucher (     voucher_id INT NOT NULL AUTO_INCREMENT,     order_id VARCHAR(1024) NOT NULL,     travelDate VARCHAR(1024) NOT NULL,     travelTime VARCHAR(1024) NOT NULL,     contactName VARCHAR(1024) NOT NULL,     trainNumber VARCHAR(1024) NOT NULL,     seatClass INT NOT NULL,     seatNumber VARCHAR(1024) NOT NULL,     startStation VARCHAR(1024) NOT NULL,     destStation VARCHAR(1024) NOT NULL,     price FLOAT NOT NULL,     PRIMARY KEY (voucher_id)); #创建数据库和表格