# l2数据的日志
import time

from log_module import log, async_log_util
from l2 import l2_log


def l2_time(code, time_, description, new_line=False, force=False):
    timestamp = int(time.time() * 1000)
    # 只记录耗时较长的信息
    if time_ > 1 or force:
        async_log_util.info(log.logger_l2_process_time, "{}-{} {}: {}-{}{}", l2_log.threadIds.get(code), timestamp,
                            description, code, time_,
                            "\n" if new_line else "")
    return timestamp


def l2_time_log(code, description):
    async_log_util.info(log.logger_l2_process_time, "{}-{}: {}", l2_log.threadIds.get(code), code,
                        description)


class TradeLog:

    def __init__(self, thread_id):
        self.key = thread_id

    def trade(self, code, content, *args):
        log.logger_l2_trade.debug(("thread-id={} code={}  ".format(self.key, code) + content).format(*args))

    def trade_buy(self, code, content, *args):
        log.logger_l2_trade_buy.debug(("thread-id={} code={}  ".format(self.key, code) + content).format(*args))

    def trade_cancel(self, code, content, *args):
        log.logger_l2_trade_cancel.debug(("thread-id={} code={}  ".format(self.key, code) + content).format(*args))