华鑫适配

Administrator

2023-07-10 f066daeb362816cb23217b5be1abe43f87f4ff96

华鑫适配

 logs_/log.py

@@ -17,31 +17,31 @@
    def __init__(self):
        logger.remove()
        #   每一天生成一个日志文件，历史日志文件采用zip压缩,异步写入日志
        logger.add(self.get_path("../trade", "trade_gui"),
        logger.add(self.get_path("trade", "trade_gui"),
                   filter=lambda record: record["extra"].get("name") == "trade_gui",
                   rotation="00:00", compression="zip", enqueue=True)
        logger.add(self.get_path("../trade", "trade"), filter=lambda record: record["extra"].get("name") == "trade",
        logger.add(self.get_path("trade", "trade"), filter=lambda record: record["extra"].get("name") == "trade",
                   rotation="00:00",
                   compression="zip")
        logger.add(self.get_path("../trade", "delegate"), filter=lambda record: record["extra"].get("name") == "delegate",
        logger.add(self.get_path("trade", "delegate"), filter=lambda record: record["extra"].get("name") == "delegate",
                   rotation="00:00",
                   compression="zip")
        logger.add(self.get_path("../l2", "l2_error"), filter=lambda record: record["extra"].get("name") == "l2_error",
        logger.add(self.get_path("l2", "l2_error"), filter=lambda record: record["extra"].get("name") == "l2_error",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../l2", "l2_process"), filter=lambda record: record["extra"].get("name") == "l2_process",
        logger.add(self.get_path("l2", "l2_process"), filter=lambda record: record["extra"].get("name") == "l2_process",
                   rotation="00:00", compression="zip", enqueue=True)
        logger.add(self.get_path("../l2", "l2_process_time"),
        logger.add(self.get_path("l2", "l2_process_time"),
                   filter=lambda record: record["extra"].get("name") == "l2_process_time",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../l2", "l2_trade"), filter=lambda record: record["extra"].get("name") == "l2_trade",
        logger.add(self.get_path("l2", "l2_trade"), filter=lambda record: record["extra"].get("name") == "l2_trade",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../l2", "l2_data"), filter=lambda record: record["extra"].get("name") == "l2_data",
        logger.add(self.get_path("l2", "l2_data"), filter=lambda record: record["extra"].get("name") == "l2_data",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../l2", "l2_latest_data"),
        logger.add(self.get_path("l2", "l2_latest_data"),
                   filter=lambda record: record["extra"].get("name") == "l2_latest_data",
                   rotation="00:00", compression="zip", enqueue=True)

@@ -49,35 +49,35 @@
        logger.add(sys.stdout,
                   filter=lambda record: record["extra"].get("name") == "l2_trade")

        logger.add(self.get_path("../l2", "l2_trade_cancel"),
        logger.add(self.get_path("l2", "l2_trade_cancel"),
                   filter=lambda record: record["extra"].get("name") == "l2_trade_cancel",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../l2", "cancel/s_cancel"),
        logger.add(self.get_path("l2", "cancel/s_cancel"),
                   filter=lambda record: record["extra"].get("name") == "s_cancel",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../l2", "cancel/h_cancel"),
        logger.add(self.get_path("l2", "cancel/h_cancel"),
                   filter=lambda record: record["extra"].get("name") == "h_cancel",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../l2", "l2_trade_buy"),
        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)

        logger.add(self.get_path("../l2", "l2_big_data"),
        logger.add(self.get_path("l2", "l2_big_data"),
                   filter=lambda record: record["extra"].get("name") == "l2_big_data",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../l2", "l2_trade_queue"),
        logger.add(self.get_path("l2", "l2_trade_queue"),
                   filter=lambda record: record["extra"].get("name") == "l2_trade_queue",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../l2", "l2_trade_buy_queue"),
        logger.add(self.get_path("l2", "l2_trade_buy_queue"),
                   filter=lambda record: record["extra"].get("name") == "l2_trade_buy_queue",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../l2", "l2_trade_buy_progress"),
        logger.add(self.get_path("l2", "l2_trade_buy_progress"),
                   filter=lambda record: record["extra"].get("name") == "l2_trade_buy_progress",
                   rotation="00:00", compression="zip", enqueue=True)

@@ -93,7 +93,7 @@
                   filter=lambda record: record["extra"].get("name") == "huaxin_trade",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../ths", "code_operate"),
        logger.add(self.get_path("ths", "code_operate"),
                   filter=lambda record: record["extra"].get("name") == "code_operate",
                   rotation="00:00", compression="zip", enqueue=True)
        # 显示在控制台
@@ -106,23 +106,23 @@
        logger.add(self.get_path("system", "system"), filter=lambda record: record["extra"].get("name") == "system",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../ths", "buy_1_volumn"),
        logger.add(self.get_path("ths", "buy_1_volumn"),
                   filter=lambda record: record["extra"].get("name") == "buy_1_volumn",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../ths", "buy_1_volumn_record"),
        logger.add(self.get_path("ths", "buy_1_volumn_record"),
                   filter=lambda record: record["extra"].get("name") == "buy_1_volumn_record",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../ths", "trade_queue_price_info"),
        logger.add(self.get_path("ths", "trade_queue_price_info"),
                   filter=lambda record: record["extra"].get("name") == "trade_queue_price_info",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../ths", "day_volumn"),
        logger.add(self.get_path("ths", "day_volumn"),
                   filter=lambda record: record["extra"].get("name") == "day_volumn",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../ths", "buy_win_distibute"),
        logger.add(self.get_path("ths", "buy_win_distibute"),
                   filter=lambda record: record["extra"].get("name") == "buy_win_distibute",
                   rotation="00:00", compression="zip", enqueue=True)

@@ -134,7 +134,7 @@
                   filter=lambda record: record["extra"].get("name") == "debug",
                   rotation="00:00", compression="zip", enqueue=True)

        logger.add(self.get_path("../trade", "trade_record"),
        logger.add(self.get_path("trade", "trade_record"),
                   filter=lambda record: record["extra"].get("name") == "trade_record",
                   rotation="00:00", compression="zip", enqueue=True)

@@ -164,7 +164,7 @@
                   rotation="00:00", compression="zip", enqueue=True)

    def get_path(self, dir_name, log_name):
        return "{}/logs/gp/{}/{}".format('D:' if constant.is_windows() else '/home', dir_name,
        return "{}/logs/gp/{}/{}".format(constant.get_path_prefix(), dir_name,
                                         log_name) + ".{time:YYYY-MM-DD}.log"

    def get_logger(self, log_name):