From da92ffcb444eab6a7d6caf7607db6cb09617c779 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 19 五月 2025 17:16:20 +0800
Subject: [PATCH] 增加所有大单的解析
---
l2_data_parser.py | 6 +++---
1 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/l2_data_parser.py b/l2_data_parser.py
index d1f12b4..e59f03a 100644
--- a/l2_data_parser.py
+++ b/l2_data_parser.py
@@ -43,7 +43,7 @@
writer.writerow(row)
-def parse_transaction(day, save=True):
+def parse_transaction(day, save=True, parse_all=False):
target_codes = __get_target_codes(day)
base_path = f"/home/userzjj/ftp/{day}"
fdatas = []
@@ -59,7 +59,7 @@
writer = csv.writer(csvfile)
# 閫愯鍐欏叆鏁版嵁
for row in csv_reader:
- if row[1] not in target_codes:
+ if row[1] not in target_codes and not parse_all:
continue
# 灏嗘枃浠跺啓鍏ュ埌鏂囨湰
if save:
@@ -103,7 +103,7 @@
l2_data_manager_dict = {}
# 瑙ｆ瀽鏁版嵁
__start_time = time.time()
- transaction_data = parse_transaction(day)
+ transaction_data = parse_transaction(day, parse_all=True)
print("*******Transaction 璇诲彇瀹屾瘯", len(transaction_data), "鑰楁椂", int(time.time() - __start_time))
__start_time = time.time()
ngtstick_data = parse_ngtstick(day)
--
Gitblit v1.8.0