From 70a9bc61565e0b2fd9e3d8c26e3fe31fc88a3766 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 14 八月 2025 11:08:55 +0800
Subject: [PATCH] 想买单详细接口
---
servers/data_server.py | 29 ++++++++++++++++++++++++++++-
1 files changed, 28 insertions(+), 1 deletions(-)
diff --git a/servers/data_server.py b/servers/data_server.py
index f0603ce..91a71b7 100644
--- a/servers/data_server.py
+++ b/servers/data_server.py
@@ -11,10 +11,11 @@
import constant
import inited_data
from api import low_suction_data_pusher
-from code_attribute.gpcode_manager import BlackListCodeManager, HumanRemoveForbiddenManager
+from code_attribute.gpcode_manager import BlackListCodeManager, HumanRemoveForbiddenManager, CodePrePriceManager
from l2.code_price_manager import CurrentPriceManager
from l2.huaxin import huaxin_target_codes_manager
from l2.l2_transaction_data_manager import HuaXinBuyOrderManager
+from l2.l2_transaction_data_processor import HuaXinTransactionDatasProcessor
from log_module.log import logger_system, logger_debug, logger_kpl_limit_up, logger_request_api, \
logger_kpl_market_strong, logger_kpl_new_blocks
from third_data.custom_block_in_money_manager import CodeInMoneyManager
@@ -1101,6 +1102,32 @@
for k in code_blocks_dict:
fdata[k] = list(code_blocks_dict[k])
response_data = json.dumps({"code": 0, "data": fdata})
+ elif url.path == "/get_want_buy_detail_list":
+ # 鑾峰彇鎯充拱鍗曡缁嗕俊鎭�
+ codes = gpcode_manager.WantBuyCodesManager().list_code_cache()
+ # 鎷夊彇娑ㄥ仠鏃堕棿
+ # 鎷夊彇鏈�杩戞垚浜や俊鎭�
+ fdatas = []
+ for code in codes:
+ # (浠ｇ爜,鍚嶇О,娑ㄥ仠鏃堕棿,娑ㄥ箙,鐜版墜,鑷敱甯傚��,鐜颁环)
+ data = [code, gpcode_manager.get_code_name(code)]
+ limit_up_time = LimitUpDataConstant.get_first_limit_up_time(code)
+ data.append(limit_up_time)
+ pre_close_price = CodePrePriceManager.get_price_pre_cache(code)
+ latest_transaction_data = HuaXinTransactionDatasProcessor.get_latest_transaction_data(code)
+ zyltgb = global_util.zyltgb_map.get(code)
+ if latest_transaction_data:
+ data.append(round((latest_transaction_data[1] - pre_close_price) * 100 / pre_close_price, 2))
+ data.append((latest_transaction_data[2]//100, latest_transaction_data[6] - latest_transaction_data[7]))
+ data.append(output_util.money_desc(zyltgb) if zyltgb else '--')
+ data.append(latest_transaction_data[1])
+ else:
+ data.append("--")
+ data.append(("--", 0))
+ data.append(output_util.money_desc(zyltgb) if zyltgb else '--')
+ data.append("--")
+ fdatas.append(data)
+ response_data = json.dumps({"code": 0, "data": fdatas})
async_log_util.info(logger_request_api, f"缁撴潫璇锋眰{tool.get_thread_id()}-{url}")
self.send_response(200)
--
Gitblit v1.8.0