From 2f2516749615da866e96d8d24e499b7ecbb63a3e Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 23 六月 2025 12:28:52 +0800
Subject: [PATCH] 默认交易模式变更/真实下单位置计算位置修改
---
log_module/log.py | 212 +++++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 204 insertions(+), 8 deletions(-)
diff --git a/log_module/log.py b/log_module/log.py
index 3dcad95..f245283 100644
--- a/log_module/log.py
+++ b/log_module/log.py
@@ -40,6 +40,18 @@
filter=lambda record: record["extra"].get("name") == "l2_latest_data",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_path("mysql", "mysql_debug"),
+ filter=lambda record: record["extra"].get("name") == "mysql_debug",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("code_attribute", "pre_close_price"),
+ filter=lambda record: record["extra"].get("name") == "pre_close_price",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("code_attribute", "zylt_gb"),
+ filter=lambda record: record["extra"].get("name") == "codes_zyltgb",
+ rotation="00:00", compression="zip", enqueue=True)
+
# 鏄剧ず鍦ㄦ帶鍒跺彴
# logger.add(sys.stdout,
# filter=lambda record: record["extra"].get("name") == "l2_trade", enqueue=True)
@@ -68,6 +80,14 @@
filter=lambda record: record["extra"].get("name") == "d_cancel",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_path("l2", "cancel/f_cancel"),
+ filter=lambda record: record["extra"].get("name") == "f_cancel",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("l2", "cancel/j_cancel"),
+ filter=lambda record: record["extra"].get("name") == "j_cancel",
+ rotation="00:00", compression="zip", enqueue=True)
+
logger.add(self.get_path("l2", "l2_trade_buy"),
filter=lambda record: record["extra"].get("name") == "l2_trade_buy",
rotation="00:00", compression="zip", enqueue=True)
@@ -92,6 +112,26 @@
filter=lambda record: record["extra"].get("name") == "l2_real_place_order_position",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_path("l2", "l2_subscript"),
+ filter=lambda record: record["extra"].get("name") == "l2_codes_subscript",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("l2", "l2_market_sell"),
+ filter=lambda record: record["extra"].get("name") == "l2_market_sell",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("l2", "l2_not_buy_reasons"),
+ filter=lambda record: record["extra"].get("name") == "l2_not_buy_reasons",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("l2", "l2_radical_buy"),
+ filter=lambda record: record["extra"].get("name") == "l2_radical_buy",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("l2", "l2_radical_buy_data"),
+ filter=lambda record: record["extra"].get("name") == "l2_radical_buy_data",
+ rotation="00:00", compression="zip", enqueue=True)
+
logger.add(self.get_path("juejin", "juejin_tick"),
filter=lambda record: record["extra"].get("name") == "juejin_tick",
rotation="00:00", compression="zip", enqueue=True)
@@ -106,6 +146,10 @@
logger.add(self.get_path("ths", "code_operate"),
filter=lambda record: record["extra"].get("name") == "code_operate",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("strategy", "buy_strategy"),
+ filter=lambda record: record["extra"].get("name") == "buy_strategy",
rotation="00:00", compression="zip", enqueue=True)
# 鏄剧ず鍦ㄦ帶鍒跺彴
# logger.add(sys.stdout,
@@ -145,8 +189,16 @@
filter=lambda record: record["extra"].get("name") == "debug",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_path("debug", "request_api"),
+ filter=lambda record: record["extra"].get("name") == "request_api",
+ rotation="00:00", compression="zip", enqueue=True)
+
logger.add(self.get_path("trade", "trade_record"),
filter=lambda record: record["extra"].get("name") == "trade_record",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("trade", "position_api_request"),
+ filter=lambda record: record["extra"].get("name") == "position_api_request",
rotation="00:00", compression="zip", enqueue=True)
logger.add(self.get_path("score", "place_order_score"),
@@ -161,12 +213,46 @@
filter=lambda record: record["extra"].get("name") == "kpl_limit_up",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_path("kpl", "kpl_new_blocks"),
+ filter=lambda record: record["extra"].get("name") == "kpl_new_blocks",
+ 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)
+
+ logger.add(self.get_path("kpl", "kpl_open_limit_up"),
+ filter=lambda record: record["extra"].get("name") == "kpl_open_limit_up",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("kpl", "kpl_jx_out"),
+ filter=lambda record: record["extra"].get("name") == "kpl_jx_out",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("kpl", "kpl_jx_in"),
+ filter=lambda record: record["extra"].get("name") == "kpl_jx_in",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("kpl", "kpl_latest_gaobiao"),
+ filter=lambda record: record["extra"].get("name") == "kpl_latest_gaobiao",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("kpl", "kpl_market_strong"),
+ filter=lambda record: record["extra"].get("name") == "kpl_market_strong",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("plates", "special_codes"),
+ filter=lambda record: record["extra"].get("name") == "plate_special_codes",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("plates", "code_plates"),
+ filter=lambda record: record["extra"].get("name") == "plate_code_plates",
rotation="00:00", compression="zip", enqueue=True)
# 鐪嬬洏鏃ュ織
@@ -186,15 +272,47 @@
logger.add(self.get_hx_path("l2", "transaction"),
filter=lambda record: record["extra"].get("name") == "hx_l2_transaction",
rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_hx_path("l2", "transaction_sell_order"),
+ filter=lambda record: record["extra"].get("name") == "hx_l2_transaction_sell_order",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_hx_path("l2", "transaction_desc"),
+ filter=lambda record: record["extra"].get("name") == "hx_l2_transaction_desc",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_hx_path("l2", "l2_transaction_big_buy"),
+ filter=lambda record: record["extra"].get("name") == "hx_l2_transaction_big_buy",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_hx_path("l2", "l2_transaction_big_sell"),
+ filter=lambda record: record["extra"].get("name") == "hx_l2_transaction_big_sell",
+ rotation="00:00", compression="zip", enqueue=True)
+
logger.add(self.get_hx_path("l2", "orderdetail"),
filter=lambda record: record["extra"].get("name") == "hx_l2_orderdetail",
rotation="00:00", compression="zip", enqueue=True)
logger.add(self.get_hx_path("l2", "marketdata"),
filter=lambda record: record["extra"].get("name") == "hx_l2_market_data",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_hx_path("l2", "marketdata"),
+ filter=lambda record: record["extra"].get("name") == "hx_l2_market_data_before_open",
+ rotation="00:00", compression="zip", enqueue=True)
logger.add(self.get_hx_path("l2", "upload"),
filter=lambda record: record["extra"].get("name") == "hx_l2_upload",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_hx_path("l2", "debug"),
+ filter=lambda record: record["extra"].get("name") == "hx_l2_debug",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_hx_path("l2", "sell_l2_delegate"),
+ filter=lambda record: record["extra"].get("name") == "hx_l2_sell_delegate",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_hx_path("l2", "sell_l2_deal"),
+ filter=lambda record: record["extra"].get("name") == "hx_l2_sell_deal",
+ rotation="00:00", compression="zip", enqueue=True)
+
logger.add(self.get_hx_path("contact", "debug"),
filter=lambda record: record["extra"].get("name") == "hx_contact_debug",
rotation="00:00", compression="zip", enqueue=True)
@@ -207,10 +325,21 @@
logger.add(self.get_hx_path("trade", "trade_loop"),
filter=lambda record: record["extra"].get("name") == "hx_trade_loop",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_hx_path("trade", "l2_active_sell"),
+ filter=lambda record: record["extra"].get("name") == "hx_l2_active_sell",
+ rotation="00:00", compression="zip", enqueue=True)
logger.add(self.get_local_huaxin_path("l2", "transaction"),
filter=lambda record: record["extra"].get("name") == "local_huaxin_transaction",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_local_huaxin_path("l2", "transaction_big_order"),
+ filter=lambda record: record["extra"].get("name") == "local_huaxin_transaction_for_big_order",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_local_huaxin_path("l2", "transaction_accurate_big_order"),
+ filter=lambda record: record["extra"].get("name") == "local_huaxin_transaction_for_accurate_big_order",
+ rotation="00:00", compression="zip", enqueue=True)
+
logger.add(self.get_local_huaxin_path("l2", "orderdetail"),
filter=lambda record: record["extra"].get("name") == "local_huaxin_orderdetail",
rotation="00:00", compression="zip", enqueue=True)
@@ -238,8 +367,16 @@
filter=lambda record: record["extra"].get("name") == "local_huaxin_l1_show_info",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_local_huaxin_path("l1", "l1_for_trade"),
+ filter=lambda record: record["extra"].get("name") == "local_huaxin_l1_trade_info",
+ rotation="00:00", compression="zip", enqueue=True)
+
logger.add(self.get_local_huaxin_path("l2", "g_cancel"),
filter=lambda record: record["extra"].get("name") == "local_huaxin_g_cancel",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_local_huaxin_path("l2", "special_volume"),
+ filter=lambda record: record["extra"].get("name") == "local_huaxin_l2_special_volume",
rotation="00:00", compression="zip", enqueue=True)
logger.add(self.get_local_huaxin_path("l2", "l2_buy_no"),
@@ -277,19 +414,25 @@
logger_l2_process_time = __mylogger.get_logger("l2_process_time")
logger_l2_data = __mylogger.get_logger("l2_data")
logger_l2_latest_data = __mylogger.get_logger("l2_latest_data")
+logger_l2_market_sell = __mylogger.get_logger("l2_market_sell")
+logger_l2_not_buy_reasons = __mylogger.get_logger("l2_not_buy_reasons")
logger_l2_trade = __mylogger.get_logger("l2_trade")
logger_l2_trade_cancel = __mylogger.get_logger("l2_trade_cancel")
logger_l2_s_cancel = __mylogger.get_logger("s_cancel")
logger_l2_h_cancel = __mylogger.get_logger("h_cancel")
logger_l2_d_cancel = __mylogger.get_logger("d_cancel")
+logger_l2_f_cancel = __mylogger.get_logger("f_cancel")
logger_l2_l_cancel = __mylogger.get_logger("l_cancel")
logger_l2_g_cancel = __mylogger.get_logger("g_cancel")
+logger_l2_j_cancel = __mylogger.get_logger("j_cancel")
logger_l2_trade_buy = __mylogger.get_logger("l2_trade_buy")
logger_l2_trade_queue = __mylogger.get_logger("l2_trade_queue")
logger_l2_trade_buy_queue = __mylogger.get_logger("l2_trade_buy_queue")
logger_l2_trade_buy_progress = __mylogger.get_logger("l2_trade_buy_progress")
logger_real_place_order_position = __mylogger.get_logger("l2_real_place_order_position")
+# 浠ｇ爜璁㈤槄鏃ュ織
+logger_l2_codes_subscript = __mylogger.get_logger("l2_codes_subscript")
logger_l2_big_data = __mylogger.get_logger("l2_big_data")
logger_juejin_tick = __mylogger.get_logger("juejin_tick")
@@ -313,7 +456,11 @@
logger_debug = __mylogger.get_logger("debug")
+logger_request_api = __mylogger.get_logger("request_api")
+
logger_trade_record = __mylogger.get_logger("trade_record")
+
+logger_trade_position_api_request = __mylogger.get_logger("position_api_request")
logger_place_order_score = __mylogger.get_logger("place_order_score")
@@ -321,9 +468,34 @@
logger_kpl_limit_up = __mylogger.get_logger("kpl_limit_up")
+logger_kpl_new_blocks = __mylogger.get_logger("kpl_new_blocks")
+
logger_kpl_debug = __mylogger.get_logger("kpl_debug")
logger_kpl_block_can_buy = __mylogger.get_logger("kpl_block_can_buy")
+
+logger_kpl_open_limit_up = __mylogger.get_logger("kpl_open_limit_up")
+
+logger_kpl_jx_out = __mylogger.get_logger("kpl_jx_out")
+
+logger_kpl_jx_in = __mylogger.get_logger("kpl_jx_in")
+
+logger_kpl_latest_gaobiao = __mylogger.get_logger("kpl_latest_gaobiao")
+
+# 寮�鐩樺暒甯傚満寮哄害
+logger_kpl_market_strong = __mylogger.get_logger("kpl_market_strong")
+
+
+
+logger_plate_special_codes = __mylogger.get_logger("plate_special_codes")
+
+logger_plate_code_plates = __mylogger.get_logger("plate_code_plates")
+
+
+
+
+
+
logger_kp_msg = __mylogger.get_logger("kp_msg")
@@ -331,18 +503,37 @@
logger_profile = __mylogger.get_logger("profile")
+logger_mysql_debug = __mylogger.get_logger("mysql_debug")
+
+logger_buy_strategy = __mylogger.get_logger("buy_strategy")
+
+logger_l2_radical_buy = __mylogger.get_logger("l2_radical_buy")
+
+logger_l2_radical_buy_data = __mylogger.get_logger("l2_radical_buy_data")
+
# -------------------------------鍗庨懌鏃ュ織---------------------------------
hx_logger_l2_orderdetail = __mylogger.get_logger("hx_l2_orderdetail")
hx_logger_l2_transaction = __mylogger.get_logger("hx_l2_transaction")
+hx_logger_l2_transaction_sell_order = __mylogger.get_logger("hx_l2_transaction_sell_order")
+hx_logger_l2_transaction_desc = __mylogger.get_logger("hx_l2_transaction_desc")
+hx_logger_l2_transaction_big_buy_order = __mylogger.get_logger("hx_l2_transaction_big_buy")
+hx_logger_l2_transaction_big_sell_order = __mylogger.get_logger("hx_l2_transaction_big_sell")
hx_logger_l2_market_data = __mylogger.get_logger("hx_l2_market_data")
+hx_logger_l2_market_data_before_open = __mylogger.get_logger("hx_l2_market_data_before_open")
hx_logger_l2_upload = __mylogger.get_logger("hx_l2_upload")
+hx_logger_l2_debug = __mylogger.get_logger("hx_l2_debug")
hx_logger_contact_debug = __mylogger.get_logger("hx_contact_debug")
hx_logger_trade_callback = __mylogger.get_logger("hx_trade_callback")
hx_logger_trade_debug = __mylogger.get_logger("hx_trade_debug")
hx_logger_trade_loop = __mylogger.get_logger("hx_trade_loop")
+hx_logger_l2_active_sell = __mylogger.get_logger("hx_l2_active_sell")
+hx_logger_l2_sell_delegate = __mylogger.get_logger("hx_l2_sell_delegate")
+hx_logger_l2_sell_deal = __mylogger.get_logger("hx_l2_sell_deal")
# -------------------------------鍗庨懌鏈湴鏃ュ織---------------------------------
logger_local_huaxin_l2_transaction = __mylogger.get_logger("local_huaxin_transaction")
+logger_local_huaxin_l2_transaction_big_order = __mylogger.get_logger("local_huaxin_transaction_for_big_order")
+logger_local_huaxin_l2_transaction_accurate_big_order = __mylogger.get_logger("local_huaxin_transaction_for_accurate_big_order")
logger_local_huaxin_l2_orderdetail = __mylogger.get_logger("local_huaxin_orderdetail")
logger_local_huaxin_l2_upload = __mylogger.get_logger("local_huaxin_upload")
logger_local_huaxin_l2_error = __mylogger.get_logger("local_huaxin_error")
@@ -352,17 +543,22 @@
logger_local_huaxin_l1 = __mylogger.get_logger("local_huaxin_l1_show_info")
logger_local_huaxin_g_cancel = __mylogger.get_logger("local_huaxin_g_cancel")
logger_local_huaxin_l2_buy_no = __mylogger.get_logger("local_huaxin_l2_buy_no")
+logger_local_huaxin_l1_trade_info = __mylogger.get_logger("local_huaxin_l1_trade_info")
+logger_local_huaxin_l2_special_volume = __mylogger.get_logger("local_huaxin_l2_special_volume")
+
+# 鏀剁洏浠锋棩蹇�
+logger_pre_close_price = __mylogger.get_logger("pre_close_price")
+logger_codes_zyltgb = __mylogger.get_logger("codes_zyltgb")
+
def close_print():
- pass
- # logging.basicConfig(level=logging.ERROR)
- # if not constant.is_windows():
- # os.close(1)
- # os.open('/dev/null', os.O_WRONLY)
+ logging.basicConfig(level=logging.ERROR)
+ if not constant.is_windows():
+ os.close(1)
+ os.open('/dev/null', os.O_WRONLY)
if __name__ == "__main__":
- close_print()
- logger_local_huaxin_l1.info("娴嬭瘯")
- input()
+ open_limit_up_codes = set({"000333", "000222"})
+ logger_kpl_open_limit_up.info(f"鐐告澘浠ｇ爜锛歿open_limit_up_codes}")
--
Gitblit v1.8.0