import threading

from log_module.log import logger_system
from servers import data_server
from utils import tool, socket_util

DATA_SERVER_PORT = 9004


def run_data_server():
    logger_system.info("create DataServer")
    logger_system.info(f"createDataServer 线程ID:{tool.get_thread_id()}")
    tcpserver = data_server.run("", DATA_SERVER_PORT)
    tcpserver.serve_forever()
    try:
        tcpserver.serve_forever()
    except Exception as e:
        logger_system.exception(e)
        logger_system.error(f"端口服务器：{DATA_SERVER_PORT} 启动失败")


def repaire_data_server():
    if not socket_util.is_port_bind(DATA_SERVER_PORT):
        threading.Thread(target=run_data_server, daemon=True).start()