测试

Administrator

2024-03-18 e4a0c150981df2046ee334fb6b0c3f2beef4e476

测试

 huaxin_client/l2_client.py

@@ -610,7 +610,7 @@
        l2_data_manager.run_upload_common()
        l2_data_manager.run_log()
        # TODO 测试
        # threading.Thread(target=lambda: test_add_codes(queue_r), daemon=True).start()
        threading.Thread(target=lambda: test_add_codes(queue_r), daemon=True).start()
        global l2CommandManager
        l2CommandManager = command_manager.L2CommandManager()
        l2CommandManager.init(MyL2ActionCallback())

 huaxin_client/l2_data_manager.py

@@ -201,9 +201,7 @@
                    if use_time > 0.01:
                        # 记录10ms以上的数据
                        huaxin_l2_log.info(logger_local_huaxin_l2_error, f"耗时:{use_time}s  结束数据：{temp_list[-1]}")

                    temp_list = []

                else:
                    if code not in self.temp_order_queue_dict:
                        self.l2_order_codes.discard(code)

 third_data/kpl_data_manager.py

@@ -417,7 +417,7 @@

    def get_limit_up():
        while True:
            if (tool.is_trade_time() and int(tool.get_now_time_str().replace(':', '')) > int("092530")):
            if (tool.is_trade_time() and int(tool.get_now_time_str().replace(':', '')) > int("092530")) or True:
                try:
                    results = kpl_api.getLimitUpInfoNew()
                    result = json.loads(results)