From 3c0e38433b45adbb7de333c033bc0750f29a3017 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期四, 15 五月 2025 13:39:09 +0800
Subject: [PATCH] 有无大单函数的数据来源的大单数据来源将本地读取改为内存读取，同时减少了打印的逻辑分支
---
strategy/L2_data_analysis.py | 15 ++-------------
1 files changed, 2 insertions(+), 13 deletions(-)
diff --git a/strategy/L2_data_analysis.py b/strategy/L2_data_analysis.py
index c458960..48c8e33 100644
--- a/strategy/L2_data_analysis.py
+++ b/strategy/L2_data_analysis.py
@@ -4,6 +4,7 @@
import os
import constant
from log_module.log import logger_debug, logger_common
+from strategy import data_cache
from utils import huaxin_util
# 鑾峰彇logger瀹炰緥
@@ -39,23 +40,11 @@
# 鎵惧埌鍏蜂綋鐩爣涓偂L2涓湁鏃犲ぇ鍗曡褰�
def find_L2_big_order_of_code(code):
- # 鑾峰彇褰撳墠鏃ユ湡锛屽苟鏍煎紡鍖栦负 'YYYY-MM-DD'
- current_date = datetime.datetime.now().strftime('%Y-%m-%d')
- # 澹版槑瑕佽浆涔夌殑鏂囦欢鐨勮矾寰�
- log_file_path = f'{constant.L2_LOG_PATH}/transaction.{current_date}.log'
- # 妫�鏌ユ枃浠舵槸鍚﹀瓨鍦�,濡傛灉瀛樺湪鍒欑户缁鐞嗭紝濡傛灉涓嶅瓨鍦ㄥ垯灏辨鎵撲綇
- if not os.path.exists(log_file_path):
- logger.info(f"Error閿欒:{log_file_path}----鏂囦欢涓嶅瓨鍦紒")
- return
- parsed_logs = read_and_parse_log(log_file_path)
- # 浣跨敤鍒楄〃鎺ㄥ寮忓拰 ast.literal_eval() 灏嗗瓧绗︿覆杞崲涓哄垪琛�
- true_lists = [ast.literal_eval(log) for log in parsed_logs]
-
# 鍒濆鍖栦竴涓爣蹇楀彉閲忥紝鐢ㄤ簬妫�鏌ユ槸鍚︽壘鍒颁簡鐗瑰畾鑲＄エ浠ｇ爜
found = False
# 閬嶅巻杞崲鍚庣殑鍒楄〃
- for sublist in true_lists:
+ for sublist in data_cache.big_order_deal_dict.get(code, []):
if sublist and sublist[0] and sublist[0][0] == code:
# print(f"鎵惧埌澶у崟鐨勫搴旇鍒楄〃 sublist[0]===={sublist[0]}")
# 鏍煎紡
--
Gitblit v1.8.0