Administrator
2025-07-03 f8872ff72d0bc10b4d17aaa1c309a3c48022013f
拉取L2数据暂时不拉大卖单
1个文件已修改
17 ■■■■■ 已修改文件
servers/data_server.py 17 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
servers/data_server.py
@@ -339,13 +339,28 @@
                else:
                    date = tool.get_now_date_str()
                delegate_datas = data_export_util.get_l2_datas(code, total_datas, date=date, end_index=end_index)
                transaction_datas = data_export_util.get_l2_transaction_datas(code, date=date)
                code_name = gpcode_manager.get_code_name(code)
                response_data = json.dumps({"code": 0, "data": {"code": code, "code_name": code_name,
                                                                "data": {"delegates": delegate_datas,
                                                                         "transactions": [] }}})
            except Exception as e:
                logger_debug.exception(e)
        elif url.path == "/get_l2_datas_of_sell_orders":
            try:
                # 获取L2卖单数据
                ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
                code = ps_dict['code']
                date = ps_dict.get('date')
                if not date:
                    date = tool.get_now_date_str()
                transaction_datas = data_export_util.get_l2_transaction_datas(code, date=date)
                code_name = gpcode_manager.get_code_name(code)
                response_data = json.dumps({"code": 0, "data": {"code": code, "code_name": code_name,
                                                                "data": {"delegates": [],
                                                                         "transactions": transaction_datas}}})
            except Exception as e:
                logger_debug.exception(e)
        elif url.path == "/get_trade_progress":
            # 获取交易进度
            ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])