From ad615df734b4d82f9a83a7d1805ac9fabdf01a53 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 21 八月 2025 18:27:39 +0800
Subject: [PATCH] 200元股价以下的不足4手算4手/撤单率设置为100%不计算L后后半段撤单
---
log_module/log_export.py | 65 +++++++++++++++++++++++++-------
1 files changed, 51 insertions(+), 14 deletions(-)
diff --git a/log_module/log_export.py b/log_module/log_export.py
index 6e19079..9ece516 100644
--- a/log_module/log_export.py
+++ b/log_module/log_export.py
@@ -453,23 +453,39 @@
return cancel_reason_dict
+
+def __parse_content(line):
+ line = line.split(" - ")[1]
+ time_str = line[line.find("[") + 1:line.find("[") + 9]
+ data = line[line.find("]") + 1:].strip()
+ if data.find("thread-id=")>-1 and data.find("code=")>-1:
+ data = data[data.find("code=")+11:].strip()
+ return time_str, data
+
+
# 鍔犺浇l2璁㈠崟鎴愪氦鏁版嵁
@cache_log
def load_huaxin_deal_record(code, date=tool.get_now_date_str()):
+ datas_dict = load_huaxin_deal_record_all(date)
+ return datas_dict.get(code)
+
+
+@cache_log
+def load_huaxin_deal_record_all(date=tool.get_now_date_str()):
path = f"{constant.get_path_prefix()}/logs/huaxin/l2/transaction_desc.{date}.log"
# 鏍煎紡:[(璁㈠崟鍙�,鎵嬫暟,寮�濮嬫垚浜ゆ椂闂�,鎴愪氦缁撴潫鏃堕棿,涓嬪崟鎵嬫暟)]
- fdatas = []
+ fdatas = {}
lines = __load_file_content(path)
for line in lines:
- data_index = line.find(f"{code}#")
+ data_index = line.find(f"#")
if data_index > 0:
- line = line.split(" - ")[1]
- time_str = line[line.find("[") + 1:line.find("[") + 9]
- data = line[line.find("]") + 1:].strip()
+ time_str, data = __parse_content(line)
code = data.split("#")[0]
data = data.split("#")[1]
data = eval(data)
- fdatas.append(data)
+ if code not in fdatas:
+ fdatas[code] = []
+ fdatas[code].append(data)
return fdatas
@@ -820,18 +836,39 @@
"""
fdatas = {}
path = f"{constant.get_path_prefix()}/logs/gp/code_attribute/pre_close_price.{date}.log"
- lines = __load_file_content(path)
- for line in lines:
- if line:
- data = line.split(" - ")[1]
- code, price = data.split("-")[0].strip(), data.split("-")[1].strip()
- fdatas[code] = price
+ if os.path.exists(path):
+ lines = __load_file_content(path)
+ for line in lines:
+ if line:
+ data = line.split(" - ")[1]
+ code, price = data.split("-")[0].strip(), data.split("-")[1].strip()
+ fdatas[code] = price
return fdatas
+def load_special_codes(date=tool.get_now_date_str()):
+ """
+ 鍔犺浇涔嬪墠鐨勬敹鐩樹环
+ @param date:
+ @return:
+ """
+ fdatas = {}
+ path = f"{constant.get_path_prefix()}/logs/gp/plates/special_codes.{date}.log"
+ lines = __load_file_content(path)
+ if lines:
+ line = lines[0]
+ line = line[line.find(" - ") + 3:]
+ return eval(line)
+ return None
+
+
if __name__ == '__main__':
- load_huaxin_transaction_sell_no(code='2024-11-10')
- load_huaxin_transaction_sell_no(code='2024-11-10')
+ line = """
+ 2025-03-12 14:49:15.028 | DEBUG | log_module.async_log_util:run_sync:66 - [14:49:14.899602] thread-id=3048 code=600841 L鍓嶇洃鎺ц寖鍥达細{1477, 1478, 1479, 1480, 1481, 1482, 1486, 1487, 1488, 1489, 1492, 1493, 1495, 1498, 1500} 璁＄畻鑼冨洿锛�1477-1503
+ """
+ print(__parse_content(line))
+ # load_huaxin_transaction_sell_no(code='2024-11-10')
+ # load_huaxin_transaction_sell_no(code='2024-11-10')
# print(get_h_cancel_compute_info("603912"))
# logger_l2_h_cancel.info("test")
--
Gitblit v1.8.0