From d957e0dc6dcfb15304a6499e1b9ddee4e18be531 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 02 一月 2025 18:10:23 +0800
Subject: [PATCH] 拆单初步规划/禁止交易板块管理
---
servers/data_server.py | 26 ++++++++++++++++++++++----
1 files changed, 22 insertions(+), 4 deletions(-)
diff --git a/servers/data_server.py b/servers/data_server.py
index 20f1638..f0dd2e7 100644
--- a/servers/data_server.py
+++ b/servers/data_server.py
@@ -52,7 +52,6 @@
__IgnoreCodeManager = IgnoreCodeManager()
__KPLPlatManager = KPLPlatManager()
__KPLCodeLimitUpReasonManager = KPLCodeLimitUpReasonManager()
- __KPLPlateForbiddenManager = KPLPlateForbiddenManager()
# 鍘嗗彶鏉垮潡
__history_plates_dict = {}
# 鏉垮潡
@@ -436,7 +435,7 @@
# 绮鹃�夛紝涓诲姏鍑�棰濋『搴�
result = kpl_api.getMarketJingXuanRealRankingInfo(False)
result = kpl_util.parseMarketJingXuan(result)
- forbidden_plates = self.__KPLPlateForbiddenManager.list_all()
+ forbidden_plates = KPLPlateForbiddenManager().list_all()
fresult = []
for d in result:
if type_ == 2 or type_ == 3:
@@ -454,11 +453,24 @@
self.__IgnoreCodeManager.ignore_code(type_, code)
response_data = json.dumps({"code": 0})
elif url.path == "/kpl/forbidden_plate":
+ # 娣诲姞涓嶈兘涔扮殑鏉垮潡
ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
plate = ps_dict["plate"]
# 鍔犲叆绂佹
- self.__KPLPlateForbiddenManager.save_plate(plate)
+ KPLPlateForbiddenManager().save_plate(plate)
response_data = json.dumps({"code": 0})
+ elif url.path == "/kpl/del_forbidden_plate":
+ # 鍒犻櫎涓嶈兘涔扮殑鏉垮潡
+ ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
+ plate = ps_dict["plate"]
+ # 鍔犲叆绂佹
+ KPLPlateForbiddenManager().delete_plate(plate)
+ response_data = json.dumps({"code": 0})
+ elif url.path == "/kpl/list_forbidden_plate":
+ # 涓嶈兘涔扮殑鏉垮潡鍒楄〃
+ results = KPLPlateForbiddenManager().list_all_cache()
+ response_data = json.dumps({"code": 0, "data": list(results)})
+
elif url.path == "/kpl/get_plate_codes":
# 鑾峰彇娑ㄥ仠鍘熷洜涓嬮潰鐨勪唬鐮�
ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
@@ -902,18 +914,24 @@
codes = huaxin_target_codes_manager.HuaXinL2SubscriptCodesManager.get_subscript_codes()
if codes:
for code in codes:
+ deal_big_order_detail_info = None
try:
# 鑾峰彇鎴愪氦澶у崟锛�(鍙傝�冨ぇ鍗曢噾棰�,宸叉垚浜ゅぇ鍗曢噾棰�,澶у崟瑕佹眰閲戦)
th = BeforeSubDealBigOrderManager().get_big_order_threshold(code)
deal_big_money_info = radical_buy_data_manager.get_total_deal_big_order_info(
code, gpcode_manager.get_limit_up_price_as_num(code))
+ # 澶у崟鎴愪氦淇℃伅
deal_big_order_info = (
output_util.money_desc(th), output_util.money_desc(deal_big_money_info[1]),
output_util.money_desc(deal_big_money_info[2]))
+ if len(codes) ==1:
+ # 鍔犺浇澶у崟璇︽儏
+ deal_big_order_detail_info = radical_buy_data_manager.get_l2_big_order_deal_info(code)
+
except:
deal_big_order_info = None
code_name = gpcode_manager.get_code_name(code)
- fresults.append((code, code_name, deal_big_order_info))
+ fresults.append((code, code_name, deal_big_order_info, deal_big_order_detail_info))
response_data = json.dumps({"code": 0, "data": fresults})
except Exception as e:
response_data = json.dumps({"code": 1, "data": str(1)})
--
Gitblit v1.8.0