# tcp server

 import socket;

 import time;

 import threading;

 from JinkoRobot import *;

 #应用程序入口类

 class ApplicationServer:

     #构造函数初始化 socket

     def __init__(self, host="localhost", port=8005):

         self.connList = [];

         self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM);

         self.socket.bind((host, port));

         self.socket.listen(100);

         print("我是Jinko, 我来自[图灵机器人:http://www.tuling123.com]");

         print("");

         print("赶紧打开客户端和我聊天吧!");

         self.accept();

     #多线程接受用户请求

     def accept(self):

         while True:

             connection, address = self.socket.accept();

             # print('connect')

             thread = ChatThread(connection);

             thread.start();

 #聊天线程

 class ChatThread(threading.Thread):

     def __init__(self, conn):

         threading.Thread.__init__(self);

         self.__connection = conn;

     def run(self):

         while True:

             try:

                 recv = self.__connection.recv(8192);

             except:

                 break;

             # print("收到:" + recv.decode('utf-8'))

             rebot = JinkoRobot();

             rebot.listenFor(recv.decode('utf-8'));

             answer = rebot.answer();

             # print('say:' + answer)

             self.__connection.send(answer.encode('utf-8'));

 ApplicationServer();

 import socket;

 import time;

 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM);

 print("正在和Jinko连线...");

 sock.connect(('localhost', 8005));

 print("");

 while True:

     speak = input("和Jinko说点什么:");

     if speak == "quit":

         break;

     if speak == "":

         continue;

     # print("发送中..." + "("+ speak +")")

     sock.send(speak.encode('utf-8'));

     # print("已发送")

     print("Jinko在思考...");

     answer = sock.recv(8192);

     print("Jinko回复你:" + answer.decode('utf-8'));

     print("");

 sock.close();

 #Jinko Robot

 import json;

 import urllib.request;

 import urllib.parse;

 class JinkoRobot:

     __answer = '';

     def __init__(self):

         pass;

     #倾听话语

     def listenFor(self, string):

         self.__answer = self.thinking(string);

     # 思考着

     def thinking(self, string):

         says = urllib.parse.quote_plus(string);

         f = urllib.request.urlopen("http://www.tuling123.com/openapi/api?key=4bc32d41c10be18627438ae45eb839ac&info=" + says);

         json_str = f.read();

         thinkdata = json.loads(json_str.decode('utf-8'));

         f.close();

         if(thinkdata['code'] > 40000 and thinkdata['code'] < 40010):

             return "今天Jinko被你问得有点累了, 过会再问吧!";

         if(thinkdata['code'] == 200000):

             return thinkdata['text'] + ", 猛戳这里>>" +  thinkdata['url'];

         if(thinkdata['code'] == 302000) :

             info = thinkdata['text'];

             for content in thinkdata['list']:

                 info += "\n\n>" + content['article'] \

                         + "  来源于" + content['source'] \

                         + "  详细信息请猛戳这里>>" + content['detailurl'];

             return info;

         if(thinkdata['code'] == 305000):

             info = thinkdata['text'];

             for key in thinkdata['list']:

                 info += "\n\n>" + key + ": 车次>" + content['trainnum'] \

                         + "  从" + content['start'] + "到" + content['terminal'] \

                         + "  发车时间:" + content['starttime'] \

                         + "  到达时间:" + content['endtime'] \

                         + "  详细信息请猛戳这里>>" + content['detailurl'];

             return info;

         return thinkdata['text'];

     #和你交流回答

     def answer(self):

         return self.__answer;