From f30bd1ce29e4670d3ae245dd049fdcb7cc52bd84 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 28 五月 2025 10:13:24 +0800
Subject: [PATCH] 解析修改
---
data_parser/transaction_big_order_parser.py | 16 +++++++++++-----
1 files changed, 11 insertions(+), 5 deletions(-)
diff --git a/data_parser/transaction_big_order_parser.py b/data_parser/transaction_big_order_parser.py
index 42aa437..31f3eb9 100644
--- a/data_parser/transaction_big_order_parser.py
+++ b/data_parser/transaction_big_order_parser.py
@@ -223,6 +223,15 @@
if not os.path.exists(combined_path):
print("鎷兼帴鏁版嵁涓嶅瓨鍦�")
return
+
+ if code:
+ output_path = os.path.join(dir_path, f"big_buy_{code}.csv")
+ else:
+ output_path = os.path.join(dir_path, f"big_buy.csv")
+
+ if os.path.exists(output_path):
+ print("璺緞宸插瓨鍦�")
+ return
df = pd.read_csv(combined_path)
df_copy = df.copy()
if code:
@@ -237,11 +246,8 @@
grouped_result = grouped_result[grouped_result["TotalAmount"] > 500000]
# print(grouped_result)
# 閬嶅巻鍐呭
- if code:
- grouped_result.to_csv(os.path.join(dir_path, f"big_buy_{code}.csv"), index=False)
- else:
- grouped_result.to_csv(os.path.join(dir_path, f"big_buy.csv"), index=False)
- print("淇濆瓨鎴愬姛")
+ grouped_result.to_csv(output_path, index=False)
+ print(f"淇濆瓨鎴愬姛锛岃矾寰勶細{output_path}")
def extract_big_order_codes(dir_path):
--
Gitblit v1.8.0