bug修复

Administrator

2023-08-24 29f13406f60ece2d7397a6cff780f19408c9f244

bug修复

 huaxin_client/trade_client.py

@@ -741,6 +741,7 @@
                             daemon=True).start()
            self.__temp_order_list_dict.pop(nRequestID)


# 获取响应发送socket
global req_rid_dict
req_rid_dict = {}
@@ -854,7 +855,7 @@
    def OnTest(self, client_id, request_id, data):
        send_response(
            json.dumps({"type": "response", "data": {"code": 0, "data": data}, "client_id": client_id,
                        "request_id": request_id}), type, client_id, request_id,show_log=False)
                        "request_id": request_id}), type, client_id, request_id, show_log=False)


def __init_trade_data_server():
@@ -923,8 +924,9 @@
        sk.close()


def send_response(data, type, _client_id, _request_id,show_log=True):
    logger_local_huaxin_trade_debug.debug(f"回调返回内容：{data}")
def send_response(data, type, _client_id, _request_id, show_log=True):
    if show_log:
        logger_local_huaxin_trade_debug.debug(f"回调返回内容：{data}")
    strategy_pipe.send(data)



 log_module/log_export.py

@@ -314,7 +314,7 @@
            lines = f.readlines()
            for line in lines:
                if line:
                    data = line.split("-")[1].strip()
                    data = line.split(" - ")[1].strip()
                    code = data.split("#")[0]
                    buy_no = int(data.split("#")[1])
                    if code not in fdatas:
@@ -324,7 +324,7 @@


if __name__ == '__main__':
    logger_l2_process_time.info("test123")
    load_huaxin_local_buy_no()
    # print(get_h_cancel_compute_info("603912"))

    # logger_l2_h_cancel.info("test")