From 6567e8cd1fb11ea10912bb3ac5bf2965c74c0e4b Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 06 一月 2025 18:09:47 +0800
Subject: [PATCH] 统计大卖单
---
third_data/custom_block_in_money_manager.py | 36 +++++++++++++++++++++++++++++-------
1 files changed, 29 insertions(+), 7 deletions(-)
diff --git a/third_data/custom_block_in_money_manager.py b/third_data/custom_block_in_money_manager.py
index 0267992..be1cbc1 100644
--- a/third_data/custom_block_in_money_manager.py
+++ b/third_data/custom_block_in_money_manager.py
@@ -23,8 +23,10 @@
# 鎬诲崠鍗曚俊鎭細{"code":[閲戦, 鏁伴噺]}
self.__code_sell_money_dict = {}
- # 鍑�娴佸叆澶у崟閲戦
- self.__code_big_buy_mmoney_list_dict = {}
+ # 鍑�娴佸叆澶у崟涔伴噾棰�
+ self.__code_big_buy_money_list_dict = {}
+ # 鍑�娴佸嚭澶у崟鍗栭噾棰�
+ self.__code_big_sell_money_list_dict = {}
self.__latest_price = {}
self.__load_data()
@@ -39,6 +41,11 @@
self.add_data(item)
def add_data(self, item):
+ """
+ 娣诲姞鏁版嵁
+ @param item: (浠ｇ爜,绫诲瀷, 璁㈠崟鏁版嵁) 璁㈠崟鏁版嵁锛�(璁㈠崟鍙�, 閲�, 閲戦, 鏃堕棿, 鏈�鏂版垚浜や环鏍�)
+ @return:
+ """
code = item[0]
if code not in self.__code_money_dict:
self.__code_money_dict[code] = 0
@@ -59,15 +66,22 @@
self.__code_buy_money_dict[code][0] += item[2][2]
self.__code_buy_money_dict[code][1] += 1
- if code not in self.__code_big_buy_mmoney_list_dict:
- self.__code_big_buy_mmoney_list_dict[code] = []
- # 澶т拱鍗曚俊鎭細(閲戦,鏈�鍚庝环鏍�)
+ if code not in self.__code_big_buy_money_list_dict:
+ self.__code_big_buy_money_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]))
+ self.__code_big_buy_money_list_dict[code].append((item[2][2], item[2][4], item[2][0]))
else:
self.__code_money_dict[code] -= item[2][2]
self.__code_sell_money_dict[code][0] += item[2][2]
self.__code_sell_money_dict[code][1] += 1
+ # 澶у崠鍗曚俊鎭�
+ if code not in self.__code_big_sell_money_list_dict:
+ self.__code_big_sell_money_list_dict[code] = []
+ if len(item[2]) >= 5:
+ # 澶у崠鍗曚俊鎭細(閲戦, 鏈�鏂颁环鏍�, 璁㈠崟鍙�)
+ self.__code_big_sell_money_list_dict[code].append((item[2][2], item[2][4], item[2][0]))
+
self.__latest_price[code] = item[2][4]
def get_code_money_dict(self):
@@ -96,7 +110,15 @@
@param code:
@return:[(閲戦, 浠锋牸, 璁㈠崟鍙�)]
"""
- return self.__code_big_buy_mmoney_list_dict.get(code)
+ return self.__code_big_buy_money_list_dict.get(code)
+
+ def get_big_sell_money_list(self, code):
+ """
+ 鑾峰彇浠ｇ爜鐨勫ぇ涔板崟鍒楄〃
+ @param code:
+ @return:[(閲戦, 浠锋牸, 璁㈠崟鍙�)]
+ """
+ return self.__code_big_sell_money_list_dict.get(code)
def get_latest_price(self, code):
return self.__latest_price.get(code)
--
Gitblit v1.8.0