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