From e160c832d31e99b44fe2084310398a3b26891839 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 08 十一月 2024 18:43:20 +0800
Subject: [PATCH] 建立扫入代码不算身位机制/优化代码/提供设置影子单的量
---
third_data/code_plate_key_manager.py | 20 ++++++++++++++------
1 files changed, 14 insertions(+), 6 deletions(-)
diff --git a/third_data/code_plate_key_manager.py b/third_data/code_plate_key_manager.py
index be18794..126ebe6 100644
--- a/third_data/code_plate_key_manager.py
+++ b/third_data/code_plate_key_manager.py
@@ -23,7 +23,7 @@
from log_module.log import logger_kpl_block_can_buy, logger_debug, logger_kpl_jx_out
from third_data.kpl_util import KPLPlatManager
-from trade import trade_manager, l2_trade_util, trade_constant
+from trade import trade_manager, l2_trade_util, trade_constant, radical_buy_data_manager
# 浠ｇ爜绮鹃�夋澘鍧楃鐞�
from utils.kpl_data_db_util import KPLLimitUpDataUtil
@@ -1386,7 +1386,7 @@
if history_index == 1:
# 褰撳墠浠ｇ爜涓鸿��2锛岃鍒ゆ柇鑰佸ぇ鏄惁鍙拱
if RadicalBuyDataManager.is_code_can_buy(history_before_codes_info[0][0],
- DealAndDelegateWithBuyModeDataManager().get_deal_codes())[0]:
+ DealAndDelegateWithBuyModeDataManager().get_deal_codes(), is_refered=True)[0]:
return False, f"寮�1鏁伴噺锛歿count}锛屽墠鎺掍唬鐮佸彲涔帮細{history_before_codes_info[0]}"
return True, f"寮�1鏁伴噺锛歿count}锛屽墠鎺掍唬鐮佷笉鍙拱锛歿history_before_codes_info[0]}锛屽巻鍙插墠鎺�-{history_before_codes_info}锛屽紑1浠ｇ爜-{open_limit_up_block_codes}"
return True, f"寮�1鏁伴噺锛歿count}锛屽巻鍙�-{history_index + 1} 瀹炴椂-{current_index + 1}锛� 鍓嶆帓浠ｇ爜-{current_before_codes_info}, 寮�1浠ｇ爜-{open_limit_up_block_codes}"
@@ -1394,7 +1394,7 @@
@classmethod
def __filter_before_codes(cls, block, index, before_codes_info, yesterday_codes):
"""
- 杩囨护鍓嶆帓娑ㄥ仠鍘熷洜涓嶆鐨勪唬鐮�
+ 杩囨护鍓嶆帓娑ㄥ仠鍘熷洜涓嶆/涓嶇畻韬綅鐨勪唬鐮�
@param code:
@param block:鏉垮潡
@param index: 鐩爣浠ｇ爜浣嶇疆
@@ -1408,14 +1408,22 @@
temp_before_codes_info = []
for b in before_codes_info:
# 褰撲綔鐩爣绁ㄨ幏鍙栨壂鍏ユ澘鍧�
- blocks = LimitUpCodesBlockRecordManager().get_radical_buy_blocks(b[0])
+ code_ = b[0]
+ blocks = LimitUpCodesBlockRecordManager().get_radical_buy_blocks(code_)
blocks = BlockMapManager().filter_blocks(blocks)
+ need_delete = False
+ # 鍒ゆ柇鍘熷洜涓嶆
if block not in blocks and b[0] not in yesterday_codes:
# 棣栨澘娑ㄥ仠鍘熷洜涓嶆
+ need_delete = True
+ # 鍒ゆ柇鏄惁鏄笉璁＄畻韬綅
+ if not need_delete:
+ if radical_buy_data_manager.ExcludeIndexComputeCodesManager.is_in_cache(code_):
+ need_delete = True
+ if need_delete:
temp_index -= 1
else:
temp_before_codes_info.append(b)
-
return temp_index, temp_before_codes_info
except Exception as e:
async_log_util.error(logger_debug, f"鎵叆鏉垮潡杩囨护鍑洪敊锛歿str(e)}")
@@ -1502,7 +1510,7 @@
pre_code = history_before_codes_info[0][0]
# pre_code涓嶈兘涔帮紝鎵嶈兘涔�
if RadicalBuyDataManager.is_code_can_buy(pre_code,
- DealAndDelegateWithBuyModeDataManager().get_deal_codes())[0]:
+ DealAndDelegateWithBuyModeDataManager().get_deal_codes(), is_refered=True)[0]:
return False, f"鍓嶆帓浠ｇ爜鍙拱锛歿pre_code}"
# 鍓嶉潰涓�涓唬鐮佷笉鑳戒拱锛屽墠涓�涓唬鐮佸繀椤讳笌鍓嶅墠涓唬鐮佹定鍋滄椂闂寸浉宸�15鍒嗛挓鍐�
for i in range(len(all_history_before_codes_info) - 1, -1, -1):
--
Gitblit v1.8.0