From dad46b192e8fc3dcc657877b7189a8d0fe5f4aa7 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 30 十二月 2024 12:36:05 +0800
Subject: [PATCH] 大于200亿的流出不算作净流出
---
third_data/custom_block_in_money_manager.py | 16 ++++++++++++++--
1 files changed, 14 insertions(+), 2 deletions(-)
diff --git a/third_data/custom_block_in_money_manager.py b/third_data/custom_block_in_money_manager.py
index 03b2d43..82f880f 100644
--- a/third_data/custom_block_in_money_manager.py
+++ b/third_data/custom_block_in_money_manager.py
@@ -10,7 +10,7 @@
from huaxin_client import l1_subscript_codes_manager
from third_data.kpl_data_constant import LimitUpCodesBlockRecordManager
from third_data.third_blocks_manager import BlockMapManager
-from utils import tool
+from utils import tool, global_util
@tool.singleton
@@ -20,6 +20,7 @@
self.__code_money_dict = {}
# 鍑�娴佸叆澶у崟閲戦
self.__code_big_buy_mmoney_list_dict = {}
+ self.__latest_price = {}
self.__load_data()
def __load_data(self):
@@ -50,6 +51,7 @@
self.__code_big_buy_mmoney_list_dict[code].append((item[2][2], item[2][4], item[2][0]))
else:
self.__code_money_dict[code] -= item[2][2]
+ self.__latest_price[code] = item[2][4]
def get_code_money_dict(self):
return self.__code_money_dict
@@ -69,6 +71,9 @@
@return:[(閲戦, 浠锋牸, 璁㈠崟鍙�)]
"""
return self.__code_big_buy_mmoney_list_dict.get(code)
+
+ def get_latest_price(self, code):
+ return self.__latest_price.get(code)
@tool.singleton
@@ -172,6 +177,13 @@
money = CodeInMoneyManager().get_money(code)
if money is None:
continue
+ # 澶ц嚜鐢辨祦閫氬競鍊肩殑娴佸嚭涓嶇畻
+ if money < 0:
+ price = CodeInMoneyManager().get_latest_price(code)
+ zylt_volume = global_util.zylt_volume_map.get(code)
+ if price and zylt_volume and zylt_volume * price > 200e8:
+ continue
+
before_fblocks = LimitUpCodesBlockRecordManager().get_radical_buy_blocks(code)
if not before_fblocks:
before_fblocks = set()
@@ -220,7 +232,7 @@
if __name__ == '__main__':
- code ="600839"
+ code = "600839"
before_fblocks = LimitUpCodesBlockRecordManager().get_radical_buy_blocks(code)
print(before_fblocks)
--
Gitblit v1.8.0