#! /usr/bin/env python3
# -*- coding: UTF-8 -*-
# Author: Bary Chen

from concurrent import futures
import time
import grpc
from ui_grpc import test_pb2, test_pb2_grpc

class RemotePatientInfoServicer(test_pb2_grpc.RemotePatientInfoServicer):
    def show_patient_info(self, request, context):
        try:
            # print(request.ID)
            # print(request.FirstName)
            # print(request.MiddleName)
            # print(request.LastName)
            # print(request.Gender)
            # print(request.BirthDate)
            # print(request.Address)
            # print(request.Department)
            # print(request.AutoNext)
            pass
            return test_pb2.SetPatientInfoReply(Success=True)
        except Exception as e:
            print(e)


if __name__ == '__main__':
    # 多线程服务器
    server = grpc.server(futures.ThreadPoolExecutor(max_workers=4))

    service = RemotePatientInfoServicer()
    test_pb2_grpc.add_RemotePatientInfoServicer_to_server(service, server)
    server.add_insecure_port('127.0.0.1:55000')
    server.start()
    try:
        print("running...")
        time.sleep(2000)
    except KeyboardInterrupt:
        print("stopping...")
        server.stop(0)