From 6142a09ed31bcb0f0049a826a12227234b9c2b8c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 22 三月 2024 16:53:40 +0800
Subject: [PATCH] 日志修改

---
 log_module/log.py |   42 ++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 42 insertions(+), 0 deletions(-)

diff --git a/log_module/log.py b/log_module/log.py
index f996290..c27a616 100644
--- a/log_module/log.py
+++ b/log_module/log.py
@@ -214,6 +214,44 @@
                    filter=lambda record: record["extra"].get("name") == "profile",
                    rotation="00:00", compression="zip", enqueue=True)
 
+        ################################鍗庨懌鏃ュ織################################
+        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", "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", "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("contact", "debug"),
+                   filter=lambda record: record["extra"].get("name") == "hx_contact_debug",
+                   rotation="00:00", compression="zip", enqueue=True)
+        logger.add(self.get_hx_path("trade", "trade_callback"),
+                   filter=lambda record: record["extra"].get("name") == "hx_trade_callback",
+                   rotation="00:00", compression="zip", enqueue=True)
+        logger.add(self.get_hx_path("trade", "debug"),
+                   filter=lambda record: record["extra"].get("name") == "hx_trade_debug",
+                   rotation="00:00", compression="zip", enqueue=True)
+        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_local_huaxin_path("l2", "transaction"),
                    filter=lambda record: record["extra"].get("name") == "local_huaxin_transaction",
                    rotation="00:00", compression="zip", enqueue=True)
@@ -265,6 +303,10 @@
                                                   log_name) + ".{time:YYYY-MM-DD}.log"
         return path_str
 
+    def get_hx_path(self, dir_name, log_name):
+        path_str = "{}/sell_logs/huaxin/{}/{}".format(constant.get_path_prefix(), dir_name,
+                                                      log_name) + ".{time:YYYY-MM-DD}.log"
+
     def get_local_huaxin_path(self, dir_name, log_name):
         path_str = "{}/sell_logs/huaxin_local/{}/{}".format(constant.get_path_prefix(), dir_name,
                                                             log_name) + ".{time:YYYY-MM-DD}.log"

--
Gitblit v1.8.0