From 751183dcd74207a50834cacc575f0dfccb41658c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 06 六月 2023 18:13:05 +0800
Subject: [PATCH] 交易优化，看盘接口完善
---
log.py | 48 +++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 47 insertions(+), 1 deletions(-)
diff --git a/log.py b/log.py
index 821e70d..e5599cb 100644
--- a/log.py
+++ b/log.py
@@ -85,6 +85,14 @@
filter=lambda record: record["extra"].get("name") == "juejin_tick",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_path("juejin", "juejin_trade"),
+ filter=lambda record: record["extra"].get("name") == "juejin_trade",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("juejin", "huaxin_trade"),
+ filter=lambda record: record["extra"].get("name") == "huaxin_trade",
+ rotation="00:00", compression="zip", enqueue=True)
+
logger.add(self.get_path("ths", "code_operate"),
filter=lambda record: record["extra"].get("name") == "code_operate",
rotation="00:00", compression="zip", enqueue=True)
@@ -142,6 +150,14 @@
filter=lambda record: record["extra"].get("name") == "kpl_limit_up",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_path("kpl", "kpl_debug"),
+ filter=lambda record: record["extra"].get("name") == "kpl_debug",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("kpl", "kpl_block_can_buy"),
+ filter=lambda record: record["extra"].get("name") == "kpl_block_can_buy",
+ rotation="00:00", compression="zip", enqueue=True)
+
def get_path(self, dir_name, log_name):
return "D:/logs/gp/{}/{}".format(dir_name, log_name) + ".{time:YYYY-MM-DD}.log"
@@ -171,6 +187,8 @@
logger_l2_big_data = __mylogger.get_logger("l2_big_data")
logger_juejin_tick = __mylogger.get_logger("juejin_tick")
+logger_juejin_trade = __mylogger.get_logger("juejin_trade")
+logger_huaxin_trade = __mylogger.get_logger("huaxin_trade")
logger_code_operate = __mylogger.get_logger("code_operate")
logger_device = __mylogger.get_logger("device")
logger_system = __mylogger.get_logger("system")
@@ -196,6 +214,10 @@
logger_kpl_limit_up_reason_change = __mylogger.get_logger("kpl_limit_up_reason_change")
logger_kpl_limit_up = __mylogger.get_logger("kpl_limit_up")
+
+logger_kpl_debug = __mylogger.get_logger("kpl_debug")
+
+logger_kpl_block_can_buy = __mylogger.get_logger("kpl_block_can_buy")
class LogUtil:
@@ -383,6 +405,30 @@
return index_list, buy_queues
+# 鑾峰彇H绾ф挙鍗曡绠楃粨鏋�
+def get_h_cancel_compute_info(code, date=None):
+ if not date:
+ date = datetime.datetime.now().strftime("%Y-%m-%d")
+ path_str = f"D:/logs/gp/l2/cancel/h_cancel.{date}.log"
+ latest_info = None
+ if os.path.exists(path_str):
+ with open(path_str, mode='r', encoding="utf-8") as f:
+ while True:
+ line = f.readline()
+ if not line:
+ break
+ if line.find(f"code-{code}") < 0:
+ continue
+ if line.find(f"H绾ф挙鍗曡绠楃粨鏋�") < 0:
+ continue
+ print(line)
+ target_rate = line.split("鐩爣姣斾緥锛�")[1].split(" ")[0].strip()
+ cancel_num = line.split("鍙栨秷璁＄畻缁撴灉")[1][1:].split("/")[0].strip()
+ total_num = line.split("鍙栨秷璁＄畻缁撴灉")[1][1:].split("/")[1].split(" ")[0].strip()
+ latest_info = (target_rate, round(int(cancel_num) / int(total_num), 2), cancel_num, total_num,)
+ return latest_info
+
+
def export_logs(code):
code_name = gpcode_manager.get_code_name(code)
date = datetime.datetime.now().strftime("%Y-%m-%d")
@@ -453,7 +499,7 @@
if __name__ == '__main__':
- print(load_kpl_reason_changes())
+ print(get_h_cancel_compute_info("603912"))
# logger_l2_h_cancel.info("test")
# logger_l2_process_time.info("test123")
--
Gitblit v1.8.0