From 97cc7f2d7428ea890c0a0ada76e5bffafd2463e4 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 26 十月 2023 22:56:11 +0800
Subject: [PATCH] L2总卖实现

---
 log_module/log_export.py |   23 ++++++++++++++++++++++-
 1 files changed, 22 insertions(+), 1 deletions(-)

diff --git a/log_module/log_export.py b/log_module/log_export.py
index fd508ec..92c07ab 100644
--- a/log_module/log_export.py
+++ b/log_module/log_export.py
@@ -350,6 +350,27 @@
     return fdatas
 
 
+# 鍔犺浇鍗庨懌鏈湴涔板叆璁㈠崟鍙�
+def load_l2_market_data():
+    path = f"{constant.get_path_prefix()}/logs/huaxin/l2/marketdata.{tool.get_now_date_str()}.log"
+    fdatas = {}
+    if os.path.exists(path):
+        with open(path, 'r', encoding="utf-8") as f:
+            lines = f.readlines()
+            for line in lines:
+                if line:
+                    data = line.split(" - ")[1].strip()
+                    if data.startswith("["):
+                        data = data[data.find("]") + 1:].strip()
+                    code = data.split("#")[0]
+                    d = data.split("#")[1].strip()
+                    d = eval(d)
+                    if code not in fdatas:
+                        fdatas[code] = []
+                    fdatas[code].append(d)
+    return fdatas
+
+
 # 璇诲彇绯荤粺鏃ュ織
 def load_system_log():
     path = f"{constant.get_path_prefix()}/logs/gp/system/system.{tool.get_now_date_str()}.log"
@@ -372,7 +393,7 @@
 
 
 if __name__ == '__main__':
-    datas = load_buy_score_recod("000333")
+    datas = load_l2_market_data()
     for d in datas:
         print(d)
     # print(get_h_cancel_compute_info("603912"))

--
Gitblit v1.8.0