From e3f4cf3bacac6eda31ddea6aaf70ebb883788817 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 28 五月 2025 17:38:07 +0800
Subject: [PATCH] L2成交大单解析

---
 l2_data_parser.py |    8 ++++++--
 1 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/l2_data_parser.py b/l2_data_parser.py
index 3d72c80..5433d19 100644
--- a/l2_data_parser.py
+++ b/l2_data_parser.py
@@ -407,8 +407,12 @@
             # 鍛戒护妯″紡  /home/userzjj/app/gp-server/l2_data_parser ExtractDealBigOrder 2025-05-09
             # 鏍规嵁code鎻愬彇澶у崟
             if not code:
-                transaction_big_order_parser.extract_big_order_of_all(f"/home/userzjj/ftp/{day}/NGTSTick")
-                transaction_big_order_parser.extract_big_order_of_all(f"/home/userzjj/ftp/{day}/Transaction")
+                # indexed_data = [f"/home/userzjj/ftp/{day}/NGTSTick", f"/home/userzjj/ftp/{day}/Transaction"]
+                # # 鏂板啓娉�
+                # with Pool(processes=2) as pool:
+                #     pool.map(transaction_big_order_parser.extract_big_order_of_all, indexed_data)
+                transaction_big_order_parser.extract_big_order_of_all(f"/home/userzjj/ftp/{day}/NGTSTick", process_count=10)
+                transaction_big_order_parser.extract_big_order_of_all(f"/home/userzjj/ftp/{day}/Transaction", process_count=10)
             else:
                 if tool.is_sh_code(code):
                     transaction_big_order_parser.extract_big_order_of_code(f"/home/userzjj/ftp/{day}/NGTSTick", code)

--
Gitblit v1.8.0