From 7adad3e127f11ffcd69836257fee2e15f1565daf Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 29 五月 2025 16:18:58 +0800
Subject: [PATCH] 没有订阅的代码，计算比较准确的总大单阈值
---
servers/data_server.py | 21 +++++++++++++++++++++
1 files changed, 21 insertions(+), 0 deletions(-)
diff --git a/servers/data_server.py b/servers/data_server.py
index a911462..384cbd5 100644
--- a/servers/data_server.py
+++ b/servers/data_server.py
@@ -950,6 +950,27 @@
th_sell = 0
deal_big_money_info = radical_buy_data_manager.get_total_deal_big_order_info(
code, gpcode_manager.get_limit_up_price_as_num(code))
+ if deal_big_money_info[1] == 0 and len(codes) == 1:
+ deal_big_money_info = list(deal_big_money_info)
+ # 娌℃湁璁㈤槄L2浼氬嚭鐜版病鏈夊�肩殑鎯呭喌锛屽鏋滄定鍋滆繃灏辨媺鍙栦箣鍓嶇殑娑ㄥ仠涔�/鍗栧ぇ鍗�
+ deal_big_orders_result = radical_buy_data_manager.request_deal_big_orders(code)
+ if deal_big_orders_result:
+ buy_datas, sell_datas = deal_big_orders_result[0], deal_big_orders_result[1]
+ limit_up_price = gpcode_manager.get_limit_up_price_as_num(code)
+ limit_up_price_money_list = [x[0] for x in buy_datas if x[1] == limit_up_price]
+ threshold_money = BeforeSubDealBigOrderManager.compute_re_limit_up_big_money_threshold(
+ limit_up_price_money_list)
+ # 璁剧疆涔板崟闃堝��
+ th_buy = threshold_money
+ buy_money = sum(limit_up_price_money_list)
+ sell_money = sum([x[0] for x in sell_datas if x[1] == limit_up_price])
+ # 娑ㄥ仠澶у崟鍑�涔板叆
+ deal_big_money_info[1] = buy_money - sell_money
+ deal_big_money_info[
+ 2] = radical_buy_data_manager.compute_total_deal_big_order_threshold_money(code,
+ limit_up_price,
+ threshold_money)
+
big_money_rate = radical_buy_data_manager.TotalDealBigOrderInfoManager.get_big_order_rate(
code)
if not big_money_rate:
--
Gitblit v1.8.0