From 091c8c8eccb8d78390cd8f2b962ade31016fdd5b Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 05 十二月 2024 18:52:56 +0800
Subject: [PATCH] L2净流入订阅修改/买流入前几修改/创业板大单数量要求修改/将市场强度纳入策略

---
 third_data/custom_block_in_money_manager.py |   17 +++++++++++++++++
 1 files changed, 17 insertions(+), 0 deletions(-)

diff --git a/third_data/custom_block_in_money_manager.py b/third_data/custom_block_in_money_manager.py
index ef37049..5b6eac2 100644
--- a/third_data/custom_block_in_money_manager.py
+++ b/third_data/custom_block_in_money_manager.py
@@ -16,7 +16,10 @@
 @tool.singleton
 class CodeInMoneyManager:
     def __init__(self):
+        # 鎬荤殑鍑�娴佸叆
         self.__code_money_dict = {}
+        # 鍑�娴佸叆澶у崟閲戦
+        self.__code_big_buy_mmoney_list_dict = {}
         self.__load_data()
 
     def __load_data(self):
@@ -38,7 +41,13 @@
         if tool.is_ge_code(code) and item[2][2] < 299e4 and item[2][1] < 290000:
             return
         if item[1] == 0:
+            # item[2]鐨勬暟鎹粨鏋勶細  (涔板崟鍙�, 閲�, 閲戦, 鏃堕棿, 鏈�鏂版垚浜や环鏍�)
             self.__code_money_dict[code] += item[2][2]
+            if code not in self.__code_big_buy_mmoney_list_dict:
+                self.__code_big_buy_mmoney_list_dict[code] = []
+            # 澶т拱鍗曚俊鎭細(閲戦,鏈�鍚庝环鏍�)
+            if len(item[2]) >= 5:
+                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]
 
@@ -53,6 +62,14 @@
     def set_money(self, code, money):
         self.__code_money_dict[code] = money
 
+    def get_big_buy_money_list(self, code):
+        """
+        鑾峰彇浠g爜鐨勫ぇ涔板崟鍒楄〃
+        @param code:
+        @return:[(閲戦, 浠锋牸, 璁㈠崟鍙�)]
+        """
+        return self.__code_big_buy_mmoney_list_dict.get(code)
+
 
 @tool.singleton
 class BlockInMoneyRankManager:

--
Gitblit v1.8.0