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