From d873f18025970f81d5ad93d9ba948ff4747a1964 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 12 六月 2024 10:45:28 +0800
Subject: [PATCH] bug修复
---
trade/l2_transaction_data_manager.py | 15 +++++++++++----
1 files changed, 11 insertions(+), 4 deletions(-)
diff --git a/trade/l2_transaction_data_manager.py b/trade/l2_transaction_data_manager.py
index 73fada4..d0c4662 100644
--- a/trade/l2_transaction_data_manager.py
+++ b/trade/l2_transaction_data_manager.py
@@ -1,5 +1,5 @@
# 鎴愪氦鏁版嵁缁熻
-from log_module import async_log_util
+from log_module import async_log_util, log_export
from log_module.log import hx_logger_l2_transaction_big_buy_order
from utils import l2_huaxin_util
@@ -12,7 +12,7 @@
# 鏈�杩戞垚浜ょ殑璁㈠崟{"code":(璁㈠崟鍙凤紝鏄惁鎴愪氦瀹屾垚)}
__latest_deal_order_info_dict = {}
- __total_big_buy_orders_dict={}
+ __total_big_buy_orders_dict = {}
def __new__(cls, *args, **kwargs):
if not cls.__instance:
@@ -22,7 +22,9 @@
@classmethod
def __load_datas(cls):
- pass
+ fdatas = log_export.load_big_buy_order()
+ for code in fdatas:
+ cls.__total_big_buy_orders_dict[code] = fdatas[code]
@classmethod
def get_big_buy_orders(cls, code):
@@ -32,6 +34,11 @@
:return:[(璁㈠崟鍙凤紝鎬昏偂鏁帮紝鎴愪氦閲戦,鎴愪氦寮�濮嬫椂闂�,鎴愪氦缁撴潫鏃堕棿)]
"""
return cls.__total_big_buy_orders_dict.get(code)
+
+ @classmethod
+ def get_big_buy_orders_from_file(cls, code):
+ fdatas = log_export.load_big_buy_order()
+ return fdatas.get(code)
@classmethod
def get_dealing_order_info(cls, code):
@@ -74,7 +81,7 @@
# 鏄惁涓哄ぇ涔板崟
if deal_info[2] >= threshold_big_money:
big_buy_datas.append(deal_info)
- async_log_util.info(hx_logger_l2_transaction_big_buy_order,f"{code}#{deal_info}")
+ async_log_util.info(hx_logger_l2_transaction_big_buy_order, f"{code}#{deal_info}")
if deal_info[2] >= 500000:
normal_buy_datas.append(deal_info)
# 鍒濆鍖栨湰鏉℃暟鎹�
--
Gitblit v1.8.0