From e231e49fdbf1cc3c14b2da7738d7e049c45bfebe Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 24 十二月 2024 17:41:21 +0800
Subject: [PATCH] 开盘前自动卖出策略修改

---
 log_module/log_export.py |   53 +++++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 47 insertions(+), 6 deletions(-)

diff --git a/log_module/log_export.py b/log_module/log_export.py
index e474279..2088219 100644
--- a/log_module/log_export.py
+++ b/log_module/log_export.py
@@ -38,7 +38,8 @@
 
 # 瀵煎嚭浜ゆ槗鍙栨秷鏃ュ織
 def __export_l2_trade_cancel_log(code, date, dir):
-    LogUtil.extract_log_from_key(code, "{}/sell_logs/gp/l2/l2_trade_cancel.{}.log".format(constant.get_path_prefix(), date),
+    LogUtil.extract_log_from_key(code,
+                                 "{}/sell_logs/gp/l2/l2_trade_cancel.{}.log".format(constant.get_path_prefix(), date),
                                  "{}/l2_trade_cancel_{}.log".format(dir, date))
 
 
@@ -179,7 +180,6 @@
     return pos_list
 
 
-
 __log_file_contents = {}
 
 
@@ -196,7 +196,6 @@
                 contents.append(line)
     __log_file_contents[md5] = (time.time(), contents)
     return contents
-
 
 
 # 鍔犺浇l2璁㈠崟鎴愪氦鏁版嵁
@@ -216,7 +215,6 @@
             data = eval(data)
             fdatas.append(data)
     return fdatas
-
 
 
 # 鍔犺浇鍗庨懌鎴愪氦鐨勫崠鍗�
@@ -240,8 +238,6 @@
                         fdatas[code_] = []
                     fdatas[code_].append(eval(data))
     return fdatas
-
-
 
 
 # 璇诲彇绯荤粺鏃ュ織
@@ -287,3 +283,48 @@
                         pass
     return fdatas
 
+
+# 璇诲彇鎴愪氦鐨勫ぇ涔板崟
+def load_huaxin_transaction_big_buy_order_infos(date=tool.get_now_date_str()):
+    path = f"{constant.get_path_prefix()}/sell_logs/huaxin/l2/transaction_big_buy_order.{date}.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:
+                    try:
+                        data = line.split(" - ")[1].strip()
+                        if data.startswith("["):
+                            data = data[data.find("]") + 1:].strip()
+                        code = data.split("#")[0]
+                        l2_data = eval(data.split("#")[1])
+                        if code not in fdatas:
+                            fdatas[code] = []
+                        fdatas[code].append(l2_data)
+                    except:
+                        pass
+    return fdatas
+
+
+# 璇诲彇鎴愪氦鐨勫ぇ鍗栧崟
+def load_huaxin_transaction_big_sell_order_infos(date=tool.get_now_date_str()):
+    path = f"{constant.get_path_prefix()}/sell_logs/huaxin/l2/transaction_big_sell_order.{date}.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:
+                    try:
+                        data = line.split(" - ")[1].strip()
+                        if data.startswith("["):
+                            data = data[data.find("]") + 1:].strip()
+                        code = data.split("#")[0]
+                        l2_data = eval(data.split("#")[1])
+                        if code not in fdatas:
+                            fdatas[code] = []
+                        fdatas[code].append(l2_data)
+                    except:
+                        pass
+    return fdatas

--
Gitblit v1.8.0