From e14478c628ebb3fdbd4d9f651be3d976f7dc8fb7 Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期四, 28 三月 2024 15:36:18 +0800 Subject: [PATCH] 代码成交之后不移除L2监听/删除量对买不买的影响/S撤bug修复 --- third_data/data_server.py | 10 +++++++++- 1 files changed, 9 insertions(+), 1 deletions(-) diff --git a/third_data/data_server.py b/third_data/data_server.py index 3fa3678..8858ec0 100644 --- a/third_data/data_server.py +++ b/third_data/data_server.py @@ -8,6 +8,7 @@ import dask from code_attribute.gpcode_manager import BlackListCodeManager, CodePrePriceManager +from l2.l2_transaction_data_manager import HuaXinBuyOrderManager from log_module.log import logger_system, logger_debug, logger_kpl_limit_up from utils import global_util, tool, data_export_util, init_data_util from code_attribute import gpcode_manager @@ -373,8 +374,15 @@ ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()]) code = ps_dict['code'] trade_progress, is_default = transaction_progress.TradeBuyQueue().get_traded_index(code) + # 鑾峰彇姝e湪鎴愪氦, 璁$畻鎴愪氦杩涘害 + dealing_info = HuaXinBuyOrderManager.get_dealing_order_info(code) + percent = 0 + if dealing_info: + total_datas = l2_data_util.local_today_datas.get(code) + if str(total_datas[trade_progress]['val']["orderNo"]) == str(dealing_info[0]): + percent = int(dealing_info[1] / total_datas[trade_progress]['val']['num']) response_data = json.dumps( - {"code": 0, "data": {"trade_progress": trade_progress, "is_default": is_default}}) + {"code": 0, "data": {"trade_progress": trade_progress, "is_default": is_default, "percent": percent}}) elif url.path == "/get_l_cancel_datas": # 鏈�鏂扮殑l鎾ゆ暟鎹� ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()]) -- Gitblit v1.8.0