线程ID记录

Administrator

2023-09-14 a29622874377f194aa83b5c51422d7ce5516bd9c

 trade/huaxin/trade_server.py

@@ -435,6 +435,7 @@


def clear_invalid_client():
    logger_system.info(f"trade_server clear_invalid_client 线程ID:{tool.get_thread_id()}")
    while True:
        try:
            huaxin_trade_api.ClientSocketManager.del_invalid_clients()
@@ -445,6 +446,7 @@


def __recv_pipe_l1(pipe_l1):
    logger_system.info(f"trade_server __recv_pipe_l1 线程ID:{tool.get_thread_id()}")
    if pipe_l1 is not None:
        while True:
            try:
@@ -792,11 +794,12 @@
        type_ = data_json["type"]
        if type_ == 0:
            # 获取是否交易成功
            data =  data_json["data"]
            data = data_json["data"]
            order_status = data["orderStatus"]
            huaxin_trade_record_manager.DelegateRecordManager.add([data])
            if huaxin_util.is_deal(order_status):
                l2_trade_util.forbidden_trade(data["securityID"],msg="已成交")
                if int(str(data["direction"])) == huaxin_util.TORA_TSTP_D_Buy:
                    l2_trade_util.forbidden_trade(data["securityID"], msg="已成交")
                # 成交，更新成交列表与资金列表
                huaxin_trade_data_update.add_deal_list()
                huaxin_trade_data_update.add_money_list()