"""
GUI管理
"""

import multiprocessing

from db import redis_manager
from log_module.log import logger_l2_process_time

from server import *

# 交易服务
from third_data import data_server
from trade.huaxin import trade_server, trade_api_server


def createTradeServer(pipe):
    # 初始化参数
    global_data_loader.init()

    # 数据服务
    t1 = threading.Thread(target=createDataServer, daemon=True)
    t1.start()

    # 交易接口服务
    t1 = threading.Thread(target=trade_api_server.run, args=(pipe,), daemon=True)
    t1.start()

    # redis后台服务
    t1 = threading.Thread(target=redis_manager.RedisUtils.run_loop,  daemon=True)
    t1.start()

    # 交易服务
    trade_server.run()


# 主服务
def createServer(pipe):
    print("create Server")
    laddr = "", 9001
    tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle, pipe_trade=pipe)  # 注意：参数是MyBaseRequestHandle
    # tcpserver.handle_request()  # 只接受一个客户端连接
    tcpserver.serve_forever()  # 永久循环执行,可以接受多个客户端连接


def createDataServer():
    print("create DataServer")
    tcpserver = data_server.run("", 9004)
    tcpserver.serve_forever()


if __name__ == '__main__':
    pipe_server, pipe_trade = multiprocessing.Pipe()
    logger_l2_process_time.info("测试123")
    serverProcess = multiprocessing.Process(target=createServer, args=(pipe_server,))
    serverProcess.start()
    # 将tradeServer作为主进程
    createTradeServer(pipe_trade)