From e924cbefe89aca8927b94b4ba74806efe4704253 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 30 十月 2023 11:20:03 +0800
Subject: [PATCH] 增加获取交易进度接口
---
third_data/data_server.py | 13 ++++++++++---
1 files changed, 10 insertions(+), 3 deletions(-)
diff --git a/third_data/data_server.py b/third_data/data_server.py
index 114fffb..34edcdc 100644
--- a/third_data/data_server.py
+++ b/third_data/data_server.py
@@ -11,7 +11,7 @@
from utils import global_util, tool, data_export_util
from code_attribute import gpcode_manager
from log_module import log, log_analyse, log_export
-from l2 import code_price_manager, l2_data_util, l2_data_manager_new, cancel_buy_strategy
+from l2 import code_price_manager, l2_data_util, l2_data_manager_new, cancel_buy_strategy, transaction_progress
from l2.cancel_buy_strategy import HourCancelBigNumComputer
from output.limit_up_data_filter import IgnoreCodeManager
from third_data import kpl_util, kpl_data_manager, kpl_api, block_info
@@ -28,10 +28,10 @@
from trade.l2_trade_util import BlackListCodeManager
import concurrent.futures
-
# 绂佺敤http.server鐨勬棩蹇楄緭鍑�
logger = logging.getLogger("http.server")
logger.setLevel(logging.CRITICAL)
+
class DataServer(BaseHTTPRequestHandler):
ocr_temp_data = {}
@@ -321,6 +321,14 @@
code = ps_dict['code']
datas = data_export_util.get_l2_datas(code)
response_data = json.dumps({"code": 0, "data": datas})
+ elif url.path == "/get_trade_progress":
+ # 鑾峰彇浜ゆ槗杩涘害
+ 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)
+ datas = data_export_util.get_l2_datas(code)
+ response_data = json.dumps(
+ {"code": 0, "data": {"trade_progress": trade_progress, "is_default": is_default}})
elif url.path == "/kpl/get_limit_up_list":
response_data = self.__get_limit_up_list()
@@ -522,7 +530,6 @@
limit_up_reason_code_dict[b] = set()
limit_up_reason_code_dict[b].add(code)
cancel_buy_strategy.LCancelRateManager.set_block_limit_up_count(limit_up_reason_code_dict)
-
if add_codes:
for code in add_codes:
--
Gitblit v1.8.0