From 300cd8f128dd74ae7c3602ae3895f4d34312193e Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 21 三月 2024 18:17:06 +0800
Subject: [PATCH] L2数据插入主动卖单
---
log_module/log_export.py | 30 +++++++++++++++++++++++++++---
1 files changed, 27 insertions(+), 3 deletions(-)
diff --git a/log_module/log_export.py b/log_module/log_export.py
index 1e0370e..fcdcffd 100644
--- a/log_module/log_export.py
+++ b/log_module/log_export.py
@@ -351,7 +351,7 @@
# 鍔犺浇涔板叆寰楀垎璁板綍
-def load_trade_recod(code,date=tool.get_now_date_str()):
+def load_trade_recod(code, date=tool.get_now_date_str()):
path = f"{constant.get_path_prefix()}/logs/gp/trade/trade_record.{date}.log"
fdatas = []
lines = __load_file_content(path)
@@ -370,7 +370,7 @@
# 鍔犺浇l2璁㈠崟鎴愪氦鏁版嵁
-def load_huaxin_deal_record(code,date = tool.get_now_date_str()):
+def load_huaxin_deal_record(code, date=tool.get_now_date_str()):
path = f"{constant.get_path_prefix()}/logs/huaxin/l2/transaction_desc.{date}.log"
# 鏍煎紡:[(璁㈠崟鍙�,鎵嬫暟,寮�濮嬫垚浜ゆ椂闂�,鎴愪氦缁撴潫鏃堕棿,涓嬪崟鎵嬫暟)]
fdatas = []
@@ -414,6 +414,7 @@
fdatas.append((time_str, codes))
return fdatas
+
# 鍔犺浇鍗庨懌鏈湴涔板叆璁㈠崟鍙�
def load_huaxin_local_buy_no():
path = f"{constant.get_path_prefix()}/logs/huaxin_local/l2/l2_buy_no.{tool.get_now_date_str()}.log"
@@ -431,6 +432,29 @@
if code not in fdatas:
fdatas[code] = set()
fdatas[code].add(buy_no)
+ return fdatas
+
+
+# 鍔犺浇鍗庨懌鎴愪氦鐨勫崠鍗�
+def load_huaxin_transaction_sell_no(code=None,date = tool.get_now_date_str()):
+ path = f"{constant.get_path_prefix()}/logs/huaxin/l2/transaction_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:
+ data = line.split(" - ")[1].strip()
+ if data.startswith("["):
+ data = data[data.find("]") + 1:].strip()
+ data = data.split("code=")[1]
+ code_ = data[:6]
+ if code and code !=code_:
+ continue
+ data = data[6:].strip()
+ if code_ not in fdatas:
+ fdatas[code_] = []
+ fdatas[code_].append(eval(data))
return fdatas
@@ -500,7 +524,7 @@
if __name__ == '__main__':
- fdatas = load_kpl_open_limit_up()
+ fdatas = load_huaxin_transaction_sell_no("600990")
print(len(fdatas))
# print(get_h_cancel_compute_info("603912"))
--
Gitblit v1.8.0